Commit 49540e5c authored by Jim Fulton's avatar Jim Fulton

Fixed a bug in handling request ends that can cause requests

to "hang" until a select timeout.
parent 17599ebf
...@@ -249,8 +249,8 @@ class ChannelPipe: ...@@ -249,8 +249,8 @@ class ChannelPipe:
sys.ZServerExitCode=r sys.ZServerExitCode=r
self._channel.push(ShutdownProducer(), 0) self._channel.push(ShutdownProducer(), 0)
Wakeup(lambda: asyncore.close_all()) Wakeup(lambda: asyncore.close_all())
elif self._close: else:
self._channel.push(None, 0) if self._close: self._channel.push(None, 0)
Wakeup() Wakeup()
self._channel=None #need to break cycles? self._channel=None #need to break cycles?
......
...@@ -249,8 +249,8 @@ class ChannelPipe: ...@@ -249,8 +249,8 @@ class ChannelPipe:
sys.ZServerExitCode=r sys.ZServerExitCode=r
self._channel.push(ShutdownProducer(), 0) self._channel.push(ShutdownProducer(), 0)
Wakeup(lambda: asyncore.close_all()) Wakeup(lambda: asyncore.close_all())
elif self._close: else:
self._channel.push(None, 0) if self._close: self._channel.push(None, 0)
Wakeup() Wakeup()
self._channel=None #need to break cycles? self._channel=None #need to break cycles?
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment