Switch ocean.task to using verify

src/ocean/task/Scheduler.d

@@ -30,6 +30,7 @@ import core.thread;
 
 import ocean.transition;
 import ocean.core.Enforce;
+import ocean.core.Verify;
 import ocean.core.Traits;
 import ocean.core.array.Mutation : reverse;
 import ocean.io.select.EpollSelectDispatcher;
@@ -130,16 +131,6 @@ final class Scheduler
     /// ditto
     private State state = State.Initial;
 
-    /***************************************************************************
-
-        Thrown instead of `AssertError` when scheduler sanity is violated. Such
-        issues are almost impossible to reason about if not caught in time
-        thus we want all sanity checks to remain even in `-release` mode.
-
-    ***************************************************************************/
-
-    private SchedulerSanityException sanity_e;
-
     /***************************************************************************
 
         Thrown when all fibers are busy, task queue is full and no custom
@@ -278,12 +269,10 @@ final class Scheduler
             config.suspended_task_limit
         );
 
-        this.sanity_e = new SchedulerSanityException;
         this.queue_full_e = new TaskQueueFullException;
         this.suspend_queue_full_e = new SuspendQueueFullException;
 
-        enforce(
-            this.sanity_e,
+        verify(
             config.task_queue_limit >= config.worker_fiber_limit,
             "Must configure task queue size at least equal to worker fiber " ~
                 "count for optimal task scheduler performance."
@@ -569,7 +558,7 @@ final class Scheduler
         as there is at least one event registered.
 
         Throws:
-            SchedulerSanityException if there are some active worker fibers
+            SanityException if there are some active worker fibers
             left in the pool by the time there are not events left
 
     ***************************************************************************/
@@ -602,9 +591,9 @@ final class Scheduler
         foreach (ref fiber; iterator)
             fiber.active_task.kill();
 
-        enforce(this.sanity_e, this.fiber_pool.num_busy() == 0);
-        enforce(this.sanity_e, this.queued_tasks.length() == 0);
-        enforce(this.sanity_e, this.suspended_tasks.length() == 0);
+        verify(this.fiber_pool.num_busy() == 0);
+        verify(this.queued_tasks.length() == 0);
+        verify(this.suspended_tasks.length() == 0);
     }
 
     /***************************************************************************
@@ -645,7 +634,7 @@ final class Scheduler
             task   = task to run
 
         Throws:
-            SchedulerSanityException on attempt to run new task from the very
+            SanityException on attempt to run new task from the very
             same fiber which would result in fiber resetting own state.
 
     ***************************************************************************/
@@ -751,7 +740,7 @@ final class Scheduler
         for (auto i = 0; i < current_count; ++i)
         {
             Task task;
-            enforce(this.sanity_e, this.suspended_tasks.pop(task));
+            verify(this.suspended_tasks.pop(task));
             if (this.state == State.Shutdown)
                 task.kill();
             else
@@ -1011,21 +1000,6 @@ public class SuspendQueueFullException : Exception
     }
 }
 
-/******************************************************************************
-
-    Exception class that indicates scheduler internal sanity violation,
-    for example, worker fiber leak.
-
-******************************************************************************/
-
-private class SchedulerSanityException : Exception
-{
-    this ( )
-    {
-        super("Internal sanity violation using the scheduler");
-    }
-}
-
 private void debug_trace ( T... ) ( cstring format, T args )
 {
     debug ( TaskScheduler )

src/ocean/task/internal/FiberPool.d

@@ -24,7 +24,7 @@ module ocean.task.internal.FiberPool;
 import core.thread;
 
 import ocean.task.Task;
-import ocean.core.Enforce;
+import ocean.core.Verify;
 import ocean.util.container.pool.ObjectPool;
 
 debug (TaskScheduler)
@@ -51,15 +51,6 @@ public class FiberPool : ObjectPool!(WorkerFiber)
 
     private size_t stack_size;
 
-    /**************************************************************************
-
-        Exception object thrown if internal pool state is compromised, should
-        normally result in application termination.
-
-    **************************************************************************/
-
-    private FiberPoolSanityException exception;
-
     /**************************************************************************
 
         Constructor
@@ -75,7 +66,6 @@ public class FiberPool : ObjectPool!(WorkerFiber)
     this ( size_t stack_size, size_t limit = 0 )
     {
         this.stack_size = stack_size;
-        this.exception = new FiberPoolSanityException;
         if (limit > 0)
             this.setLimit(limit);
     }
@@ -101,7 +91,7 @@ public class FiberPool : ObjectPool!(WorkerFiber)
         auto fiber = super.get(if_missing);
         if (fiber is null)
             return null;
-        enforce(this.exception, fiber.state() != Fiber.State.EXEC);
+        verify(fiber.state() != Fiber.State.EXEC);
         return fiber;
     }
 
@@ -136,25 +126,9 @@ public class FiberPool : ObjectPool!(WorkerFiber)
     override protected void resetItem ( Item item )
     {
         auto fiber = this.fromItem(item);
-        enforce(
-            this.exception,
+        verify(
             fiber is Fiber.getThis()
                 || fiber.state() == Fiber.State.TERM
         );
     }
 }
-
-/******************************************************************************
-
-    Exception class that indicates fiber pool internal sanity violation,
-    for example, trying to recycle fiber that is still running.
-
-******************************************************************************/
-
-private class FiberPoolSanityException : Exception
-{
-    this ( )
-    {
-        super("Internal sanity violation using fiber pool");
-    }
-}