dispatcher tests

Author: garlic0x1

test/dispatcher.lisp

@@ -5,8 +5,8 @@
 (defun ~= (a b)
   (>= 2 (abs (- a b))))
 
-(deftest test-dispatcher-balancing ()
-  "Make sure all the workers share."
+(deftest test-dispatcher-balanced ()
+  "Make sure all the workers share equally for similarly timed jobs."
   (define-actor counter ((c 0)) (increment)
     (sleep 0.025)
     (incf c increment))
@@ -15,8 +15,10 @@
     (dotimes (i 40) (send actor 1))
     (close-actor actor)
     (let ((stores (join-actor actor)))
-      (is (~= (first stores) (second stores)))))
+      (is (~= (first stores) (second stores))))))
 
+(deftest test-dispatcher-unbalanced ()
+  "Make sure a worker with slow jobs doesn't fill up."
   (define-actor sleeper ((c 0)) (time)
     (sleep time)
     (incf c))
@@ -28,6 +30,7 @@
     (is (equal '((5 20)) (close-and-join-actors actor)))))
 
 (deftest test-dispatcher-registry ()
+  "Test registering a dispatcher with a global name."
   (define-actor counter ((c 0)) (increment)
     (incf c increment))
 

test/fuzz.lisp

@@ -4,5 +4,13 @@
 (deftest fuzz-basic-tests (&optional (times 1024))
   "Detect rare race conditions by brute force."
   (dotimes (i times)
-    (let ((*standard-output* (make-broadcast-stream)))
-      (is (fiasco:run-tests :thespis/test/basic)))))
+    (is (fiasco:run-tests
+         :thespis/test/basic
+         :stream (make-broadcast-stream)))))
+
+(deftest fuzz-dispatcher-tests (&optional (times 16))
+  "Don't try as many reps here because it is too slow."
+  (dotimes (i times)
+    (is (fiasco:run-tests
+         :thespis/test/dispatcher
+         :stream (make-broadcast-stream)))))

thespis.asd

@@ -11,12 +11,14 @@
   :depends-on (#:thespis #:fiasco)
   :components ((:module "test"
                 :components ((:file "basic")
+                             (:file "dispatcher")
                              (:file "fuzz"))))
   :perform (asdf:test-op
             (o c)
             (multiple-value-bind (stat result)
                 (uiop:symbol-call :fiasco :run-tests
                                   '(:thespis/test/basic
+                                    :thespis/test/dispatcher
                                     :thespis/test/fuzz))
               (print result)
               (assert (eql t stat)))))