Use DiffEqBase.check_error!

src/StochasticDiffEq.jl

@@ -4,8 +4,6 @@ module StochasticDiffEq
 
   import Base: linspace
 
-  import Base: start, next, done, eltype
-
   import RandomNumbers: Xorshifts
 
   using Reexport
@@ -31,7 +29,9 @@ module StochasticDiffEq
                      resize_non_user_cache!,deleteat_non_user_cache!,addat_non_user_cache!,
                      terminate!,get_du, get_dt,get_proposed_dt,set_proposed_dt!,
                      u_modified!,savevalues!,add_tstop!,add_saveat!,set_reltol!,
-                     set_abstol!
+                     set_abstol!, postamble!, last_step_failed
+
+  using DiffEqBase: check_error!
 
   const CompiledFloats = Union{Float32,Float64}
 

src/integrators/integrator_utils.jl

@@ -59,37 +59,11 @@ end
   end
 end
 
+last_step_failed(integrator::SDEIntegrator) =
+  integrator.last_stepfail && !integrator.opts.adaptive
+
 @def sde_exit_condtions begin
-  if integrator.iter > integrator.opts.maxiters
-    if integrator.opts.verbose
-      warn("Max Iters Reached. Aborting")
-    end
-    postamble!(integrator)
-    integrator.sol = solution_new_retcode(integrator.sol,:MaxIters)
-    return integrator.sol
-  end
-  if !integrator.opts.force_dtmin && integrator.opts.adaptive && abs(integrator.dt) <= abs(integrator.opts.dtmin)
-    if integrator.opts.verbose
-      warn("dt <= dtmin. Aborting. If you would like to force continuation with dt=dtmin, set force_dtmin=true")
-    end
-    postamble!(integrator)
-    integrator.sol = solution_new_retcode(integrator.sol,:DtLessThanMin)
-    return integrator.sol
-  end
-  if integrator.opts.unstable_check(integrator.dt,integrator.u,integrator.p,integrator.t)
-    if integrator.opts.verbose
-      warn("Instability detected. Aborting")
-    end
-    postamble!(integrator)
-    integrator.sol = solution_new_retcode(integrator.sol,:Unstable)
-    return integrator.sol
-  end
-  if integrator.last_stepfail && !integrator.opts.adaptive # Only false if doubled
-    if integrator.opts.verbose
-      warn("Newton steps could not converge and algorithm is not adaptive. Use a lower dt.")
-    end
-    postamble!(integrator)
-    integrator.sol = solution_new_retcode(integrator.sol,:ConvergenceFailure)
+  if check_error!(integrator) != :Success
     return integrator.sol
   end
 end

src/iterator_interface.jl

@@ -1,51 +1,3 @@
-function start(integrator::SDEIntegrator)
-  0
-end
-
-@inline function next(integrator::SDEIntegrator,state)
-  state += 1
-  step!(integrator) # Iter updated in the step! header
-  # Next is callbacks -> iterator  -> top
-  integrator,state
-end
-
-done(integrator::SDEIntegrator) = done(integrator,integrator.iter)
-
-@inline function done(integrator::SDEIntegrator,state)
-  if integrator.iter > integrator.opts.maxiters
-    if integrator.opts.verbose
-      warn("Interrupted. Larger maxiters is needed.")
-    end
-    postamble!(integrator)
-    return true
-  end
-  if integrator.opts.unstable_check(integrator.dt,integrator.u,integrator.p,integrator.t)
-    if integrator.opts.verbose
-      warn("Instability detected. Aborting")
-    end
-    postamble!(integrator)
-    return true
-  end
-  if !integrator.opts.force_dtmin && integrator.opts.adaptive && abs(integrator.dt) <= abs(integrator.opts.dtmin)
-    if integrator.opts.verbose
-      warn("dt <= dtmin. Aborting. If you would like to force continuation with dt=dtmin, set force_dtmin=true")
-    end
-    postamble!(integrator)
-    return true
-  end
-  if isempty(integrator.opts.tstops)
-    postamble!(integrator)
-    return true
-  elseif integrator.just_hit_tstop
-    integrator.just_hit_tstop = false
-    if integrator.opts.stop_at_next_tstop
-      postamble!(integrator)
-      return true
-    end
-  end
-  false
-end
-
 @inline function step!(integrator::SDEIntegrator)
   if integrator.opts.advance_to_tstop
     @inbounds while integrator.tdir*integrator.t < integrator.tdir*top(integrator.opts.tstops)
@@ -65,5 +17,3 @@ end
   end
   @inbounds handle_tstop!(integrator)
 end
-
-eltype(integrator::SDEIntegrator) = typeof(integrator)