openstack/oslo.messaging
Code Issues Proposed changes

[zmq] Fix timeout in ThreadingPoller.poll

Browse Source 
Change-Id: I3f97ce93c719b5729885b4d37518880dd6213d1d
This commit is contained in:
Gevorg Davoian 2016-06-03 12:27:29 +03:00
parent f7ceec7aa4
commit fbf5cb442d
2 changed files with 5 additions and 2 deletions
oslo_messaging/_drivers/zmq_driver
broker
zmq_queue_proxy.py
poller
threading_poller.py

2
oslo_messaging/_drivers/zmq_driver/broker/zmq_queue_proxy.py

@ -65,7 +65,7 @@ class UniversalQueueProxy(object):
{"router": self.be_router_address})
def run(self):
message, socket = self.poller.poll(self.conf.rpc_poll_timeout)
message, socket = self.poller.poll()
if message is None:
return

5
oslo_messaging/_drivers/zmq_driver/poller/threading_poller.py

@ -46,9 +46,12 @@ class ThreadingPoller(zmq_poller.ZmqPoller):
self.poller.register(socket, zmq.POLLIN)
def poll(self, timeout=None):
if timeout is not None and timeout > 0:
timeout *= 1000 # convert seconds to milliseconds
sockets = {}
try:
sockets = dict(self.poller.poll())
sockets = dict(self.poller.poll(timeout=timeout))
except zmq.ZMQError as e:
LOG.debug("Polling terminated with error: %s", e)