openstack/oslo.messaging
Code Issues Proposed changes

Record length of queues for ReplyWaiters

Browse Source 
Add the length of queues in warning message when it exceeds
threshold.

Change-Id: I6236720ede71fadac0c61baf792c15c69de3094b
This commit is contained in:
ChangBo Guo(gcb) 2016-10-13 19:50:59 +08:00
parent 293084f9b5
commit 86e779b11b
1 changed files with 8 additions and 5 deletions
Show Stats 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):
self._queues[msg_id] = moves.queue.Queue()
if len(self._queues) > self._wrn_threshold:
LOG.warning(_LW('Number of call queues is greater than warning '
'threshold: %(old_threshold)s. There could be a '
'leak. Increasing threshold to: %(threshold)s'),
{'old_threshold': self._wrn_threshold,
queues_length = len(self._queues)
if queues_length > self._wrn_threshold:
LOG.warning(_LW('Number of call queues is %(queues_length)s, '
'greater than warning threshold: %(old_threshold)s'
'. There could be a leak. Increasing threshold to:'
' %(threshold)s'),
{'queues_length': queues_length,
'old_threshold': self._wrn_threshold,
'threshold': self._wrn_threshold * 2})
self._wrn_threshold *= 2