From bc6224e7be2f3edb07c7363ed6d80763be235196 Mon Sep 17 00:00:00 2001 From: Denis Bilenko Date: Thu, 30 Apr 2009 18:32:43 +0700 Subject: [PATCH] twistedutil.protocol: don't call resumeProducer() if disconnection - should prevent AssertionError from inside twisted.internet.abstract --- eventlet/twistedutil/protocol.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/eventlet/twistedutil/protocol.py b/eventlet/twistedutil/protocol.py index cd2eca0..0453fe2 100644 --- a/eventlet/twistedutil/protocol.py +++ b/eventlet/twistedutil/protocol.py @@ -74,7 +74,6 @@ class Event(event): self.reset() return event.send_exception(self, *throw_args) - class Producer2Event(object): # implements IPullProducer @@ -115,7 +114,7 @@ class GreenTransportBase(object): self._write_event.send_exception(reason.value) def _wait(self): - if self._disconnected_event.ready(): + if self.disconnecting or self._disconnected_event.ready(): if self._queue: return self._queue.wait() else: