[Checkins] SVN: Sandbox/J1m/resumelb/src/zc/resumelb/ Added a cleanup method, mainly for tests.

[Jim Fulton]

Log message for revision 124246:
  Added a cleanup method, mainly for tests.
  

Changed:
  U   Sandbox/J1m/resumelb/src/zc/resumelb/lb.py
  U   Sandbox/J1m/resumelb/src/zc/resumelb/worker.py
  U   Sandbox/J1m/resumelb/src/zc/resumelb/worker.test

-=-
Modified: Sandbox/J1m/resumelb/src/zc/resumelb/lb.py
===================================================================
--- Sandbox/J1m/resumelb/src/zc/resumelb/lb.py	2012-01-29 14:49:19 UTC (rev 124245)
+++ Sandbox/J1m/resumelb/src/zc/resumelb/lb.py	2012-01-29 19:22:49 UTC (rev 124246)
@@ -57,6 +57,11 @@
                 logger.exception('lb connecting to %r', addr)
                 gevent.sleep(self.connect_sleep)
 
+    def stop(self):
+        for g in self.workletts.values():
+            g.kill()
+        self.workletts.clear()
+
     def handle_wsgi(self, env, start_response):
         rclass = self.classifier(env)
         logger.debug('wsgi: %s', rclass)

Modified: Sandbox/J1m/resumelb/src/zc/resumelb/worker.py
===================================================================
--- Sandbox/J1m/resumelb/src/zc/resumelb/worker.py	2012-01-29 14:49:19 UTC (rev 124245)
+++ Sandbox/J1m/resumelb/src/zc/resumelb/worker.py	2012-01-29 19:22:49 UTC (rev 124246)
@@ -41,6 +41,9 @@
         self.server.start()
         self.addr = addr[0], self.server.server_port
 
+    def stop(self):
+        self.server.stop()
+
     def handle_connection(self, sock, addr):
         try:
             conn = zc.resumelb.util.Worker()

Modified: Sandbox/J1m/resumelb/src/zc/resumelb/worker.test
===================================================================
--- Sandbox/J1m/resumelb/src/zc/resumelb/worker.test	2012-01-29 14:49:19 UTC (rev 124245)
+++ Sandbox/J1m/resumelb/src/zc/resumelb/worker.test	2012-01-29 19:22:49 UTC (rev 124246)
@@ -357,3 +357,7 @@
     http://localhost/hi.html ->
     6115 10000 44bd0dbf8208fea52dc6180376d14798b86847bd
     <BLANKLINE>
+
+Cleanup:
+
+    >>> worker.stop()