openstack/deb-python-eventlet
Code Issues Proposed changes

zmq: avoid spurious wakeups by forcing zmq events to be processed when no threads waiting

Browse Source
This commit is contained in:
Geoff Salmon
2012-12-27 12:52:04 -05:00
committed by Sergey Shepelev
parent 9576eafac2
commit 7f77620354
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
eventlet/green/zmq.py
View File

@@ -205,8 +205,13 @@ class Socket(_Socket):
# Some events arrived at the zmq socket. This may mean
# there's a message that can be read or there's space for
# a message to be written.
self._eventlet_send_event.wake()
self._eventlet_recv_event.wake()
send_wake = self._eventlet_send_event.wake()
recv_wake = self._eventlet_recv_event.wake()
if not send_wake and not recv_wake:
# if no waiting send or recv thread was woken up, then
# force the zmq socket's events to be processed to
# avoid repeated wakeups
_Socket_getsockopt(self, EVENTS)
hub = hubs.get_hub()
self._eventlet_listener = hub.add(hub.READ, self.getsockopt(FD), event)