54 lines
1001 B
Python
54 lines
1001 B
Python
"""
|
|
kombu.syn
|
|
=========
|
|
|
|
"""
|
|
from __future__ import absolute_import
|
|
|
|
import sys
|
|
|
|
__all__ = ['detect_environment']
|
|
|
|
_environment = None
|
|
|
|
|
|
def blocking(fun, *args, **kwargs):
|
|
return fun(*args, **kwargs)
|
|
|
|
|
|
def select_blocking_method(type):
|
|
pass
|
|
|
|
|
|
def _detect_environment():
|
|
# ## -eventlet-
|
|
if 'eventlet' in sys.modules:
|
|
try:
|
|
from eventlet.patcher import is_monkey_patched as is_eventlet
|
|
import socket
|
|
|
|
if is_eventlet(socket):
|
|
return 'eventlet'
|
|
except ImportError:
|
|
pass
|
|
|
|
# ## -gevent-
|
|
if 'gevent' in sys.modules:
|
|
try:
|
|
from gevent import socket as _gsocket
|
|
import socket
|
|
|
|
if socket.socket is _gsocket.socket:
|
|
return 'gevent'
|
|
except ImportError:
|
|
pass
|
|
|
|
return 'default'
|
|
|
|
|
|
def detect_environment():
|
|
global _environment
|
|
if _environment is None:
|
|
_environment = _detect_environment()
|
|
return _environment
|