openstack/oslo.messaging
Code Issues Proposed changes

Merge "Record length of queues for ReplyWaiters"

Browse Source
This commit is contained in:
Jenkins
2016-10-14 18:37:21 +00:00
committed by Gerrit Code Review
parent 96b9618228 86e779b11b
commit 7e0d8a035f
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
oslo_messaging/_drivers/amqpdriver.py
View File

@@ -248,11 +248,14 @@ class ReplyWaiters(object):
def add(self, msg_id): def add(self, msg_id):
self._queues[msg_id] = moves.queue.Queue() self._queues[msg_id] = moves.queue.Queue()
if len(self._queues) > self._wrn_threshold: queues_length = len(self._queues)
LOG.warning(_LW('Number of call queues is greater than warning ' if queues_length > self._wrn_threshold:
'threshold: %(old_threshold)s. There could be a ' LOG.warning(_LW('Number of call queues is %(queues_length)s, '
'leak. Increasing threshold to: %(threshold)s'), 'greater than warning threshold: %(old_threshold)s'
{'old_threshold': self._wrn_threshold, '. There could be a leak. Increasing threshold to:'
' %(threshold)s'),
{'queues_length': queues_length,
'old_threshold': self._wrn_threshold,
'threshold': self._wrn_threshold * 2}) 'threshold': self._wrn_threshold * 2})
self._wrn_threshold *= 2 self._wrn_threshold *= 2