openstack/oslo.messaging
Code Issues Proposed changes

ensure we set channel in lock

Browse Source 
_set_current_channel must be called  with a lock

Change-Id: I151564670946b3399158352c51d1670b9e7291fb
This commit is contained in:
gord chung 2017-01-03 14:39:21 +00:00
parent 8d2331a3b7
commit 1dc575ce5b
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
oslo_messaging/_drivers/impl_rabbit.py
View File

@ -607,7 +607,8 @@ class Connection(object):
self._heartbeat_support_log_emitted = False self._heartbeat_support_log_emitted = False
# NOTE(sileht): just ensure the connection is setuped at startup # NOTE(sileht): just ensure the connection is setuped at startup
self.ensure_connection() with self._connection_lock:
self.ensure_connection()
# NOTE(sileht): if purpose is PURPOSE_LISTEN # NOTE(sileht): if purpose is PURPOSE_LISTEN
# the consume code does the heartbeat stuff # the consume code does the heartbeat stuff