[Checkins] SVN: zc.async/trunk/src/zc/async/monitordb.txt add missing test. Planned remaining changes prior to releasing 1.5 are all doc-related

[Gary Poster]

Log message for revision 91292:
  add missing test.   Planned remaining changes prior to releasing 1.5 are all doc-related

Changed:
  U   zc.async/trunk/src/zc/async/monitordb.txt

-=-
Modified: zc.async/trunk/src/zc/async/monitordb.txt
===================================================================
--- zc.async/trunk/src/zc/async/monitordb.txt	2008-09-20 18:48:45 UTC (rev 91291)
+++ zc.async/trunk/src/zc/async/monitordb.txt	2008-09-20 23:03:02 UTC (rev 91292)
@@ -1316,7 +1316,7 @@
 
     >>> active_lock2.release()
     >>> time.sleep(0.4)
-    >>> j = alt_queue.put(active_pause2)
+    >>> j = queue.put(active_pause2)
     >>> transaction.commit()
     >>> ignore = reactor.time_flies(dispatcher.poll_interval)
     >>> time.sleep(0.4)
@@ -1334,12 +1334,36 @@
 guess, ``lastcompleted`` just gets the first job from the merged list that
 ``jobs`` uses.
 
-    XXX
+    >>> connection.test_input('asyncdb jobs completed display:repr count:3\n')
+    [
+        "<zc.async.job.Job (oid 84, db 'unnamed') ``zc.async.doctest_test.active_pause2()``>", 
+        "<zc.async.job.Job (oid 107, db 'unnamed') ``zc.async.doctest_test.sum_silly(41, 41)``>", 
+        "<zc.async.job.Job (oid 113, db 'unnamed') ``zc.async.doctest_test.send_message()``>"
+    ] 
+    -> CLOSE
 
-    >>> active_lock2.release()
+    >>> ignore = reactor.time_flies(0.25)
     >>> active_lock.release()
-    >>> callback_lock.release()
+    >>> time.sleep(0.4)
+    >>> connection.test_input('asyncdb jobs completed display:repr count:3\n')
+    [
+        "<zc.async.job.Job (oid 118, db 'unnamed') ``zc.async.doctest_test.active_pause()``>", 
+        "<zc.async.job.Job (oid 84, db 'unnamed') ``zc.async.doctest_test.active_pause2()``>", 
+        "<zc.async.job.Job (oid 107, db 'unnamed') ``zc.async.doctest_test.sum_silly(41, 41)``>"
+    ] 
+    -> CLOSE
 
+    >>> ignore = reactor.time_flies(0.25)
+    >>> active_lock2.release()
+    >>> time.sleep(0.4)
+    >>> connection.test_input('asyncdb jobs completed display:repr count:3\n')
+    [
+        "<zc.async.job.Job (oid 135, db 'unnamed') ``zc.async.doctest_test.active_pause2()``>", 
+        "<zc.async.job.Job (oid 118, db 'unnamed') ``zc.async.doctest_test.active_pause()``>", 
+        "<zc.async.job.Job (oid 84, db 'unnamed') ``zc.async.doctest_test.active_pause2()``>"
+    ] 
+    -> CLOSE
+
 [#tearDown]_
 
 .. [#setUp] See the discussion in other documentation to explain this code.
@@ -1394,6 +1418,10 @@
     ...     zc.monitor.interfaces.IMonitorPlugin, 'help')
 
 .. [#tearDown]
+    >>> active_lock2.release()
+    >>> active_lock.release()
+    >>> callback_lock.release()
+
     >>> threads = []
     >>> for d in (dispatcher, alt_dispatcher):
     ...     for queue_pools in d.queues.values():