[Checkins] SVN: Sandbox/J1m/resumelb/src/zc/resumelb/ Fixed a bug in handling disconnects. (Still need test.)
Jim Fulton
jim at zope.com
Sun Nov 6 16:49:36 UTC 2011
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
More information about the checkins
mailing list