[Checkins] SVN: Sandbox/J1m/resumelb/src/zc/resumelb/ Fixed a bug in handling disconnects. (Still need test.)

[Jim Fulton]

Log message for revision 123292:
  Fixed a bug in handling disconnects. (Still need test.)
  

Changed:
  U   Sandbox/J1m/resumelb/src/zc/resumelb/util.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/util.py
===================================================================
--- Sandbox/J1m/resumelb/src/zc/resumelb/util.py	2011-11-06 16:31:01 UTC (rev 123291)
+++ Sandbox/J1m/resumelb/src/zc/resumelb/util.py	2011-11-06 16:49:36 UTC (rev 123292)
@@ -70,7 +70,7 @@
         writeq = gevent.queue.Queue()
         gevent.Greenlet.spawn(writer, writeq, socket, self)
         self.put = writeq.put
-        self.connected = True
+        self.is_connected = True
         return self.readers
 
     def __len__(self):
@@ -92,7 +92,7 @@
 
     def disconnected(self):
         logger.info('worker disconnected %s', self.addr)
-        self.connected = False
+        self.is_connected = False
         for put in self.readers.itervalues():
             put(None)
 

Modified: Sandbox/J1m/resumelb/src/zc/resumelb/worker.py
===================================================================
--- Sandbox/J1m/resumelb/src/zc/resumelb/worker.py	2011-11-06 16:31:01 UTC (rev 123291)
+++ Sandbox/J1m/resumelb/src/zc/resumelb/worker.py	2011-11-06 16:49:36 UTC (rev 123292)
@@ -33,7 +33,7 @@
         readers = self.connected(socket)
         self.put((0, self.resume))
 
-        while self.connected:
+        while self.is_connected:
             try:
                 rno, data = zc.resumelb.util.read_message(socket)
             except gevent.GreenletExit:

Modified: Sandbox/J1m/resumelb/src/zc/resumelb/worker.test
===================================================================
--- Sandbox/J1m/resumelb/src/zc/resumelb/worker.test	2011-11-06 16:31:01 UTC (rev 123291)
+++ Sandbox/J1m/resumelb/src/zc/resumelb/worker.test	2011-11-06 16:49:36 UTC (rev 123292)
@@ -220,3 +220,6 @@
     Content-Type: text/html; charset=UTF-8
     <BLANKLINE>
     1200000
+
+
+XXX Need disconnect/connect test