openstack/oslo.messaging
Code Issues Proposed changes

Merge "Use the warn_eventlet_not_patched util function"

Browse Source
This commit is contained in:
Jenkins 2015-07-14 10:40:56 +00:00 committed by Gerrit Code Review
commit ead733a2dc
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
oslo_messaging/_executors/impl_eventlet.py
View File

@ -19,7 +19,7 @@ from eventlet.green import threading as greenthreading
import futurist
from oslo_messaging._executors import impl_pooledexecutor
from oslo_messaging import localcontext
from oslo_utils import eventletutils
LOG = logging.getLogger(__name__)
@ -37,13 +37,9 @@ class EventletExecutor(impl_pooledexecutor.PooledExecutor):
def __init__(self, conf, listener, dispatcher):
super(EventletExecutor, self).__init__(conf, listener, dispatcher)
if not isinstance(localcontext._STORE, greenthreading.local):
LOG.debug('eventlet executor in use but the threading module '
'has not been monkeypatched or has been '
'monkeypatched after the oslo.messaging library '
'have been loaded. This will results in unpredictable '
'behavior. In the future, we will raise a '
'RuntimeException in this case.')
eventletutils.warn_eventlet_not_patched(
expected_patched_modules=['thread'],
what="the 'oslo.messaging eventlet executor'")
_executor_cls = futurist.GreenThreadPoolExecutor
_lock_cls = greenthreading.Lock