Only install the nginx hub if we're actually using nginx, because the import always works, so that wasn't a good test of whether to use it or not.
This commit is contained in:
@@ -186,14 +186,7 @@ def exc_after(seconds, exc):
|
||||
return call_after(seconds, switch, getcurrent(), None, exc)
|
||||
|
||||
|
||||
def get_default_hub():
|
||||
## TODO some sort of plugin system?
|
||||
try:
|
||||
import eventlet.hubs.nginx
|
||||
return eventlet.hubs.nginx
|
||||
except ImportError:
|
||||
pass
|
||||
|
||||
def get_default_hub():
|
||||
try:
|
||||
import eventlet.hubs.libevent
|
||||
return eventlet.hubs.libevent
|
||||
|
@@ -4,6 +4,8 @@ import sys
|
||||
from eventlet import api
|
||||
from eventlet import httpc
|
||||
|
||||
from eventlet.hubs import nginx
|
||||
|
||||
|
||||
def real_application(env, start_response):
|
||||
#result = httpc.get('http://127.0.0.1:8081/')
|
||||
@@ -23,6 +25,9 @@ def wrap_application(master, env, start_response):
|
||||
def application(env, start_response):
|
||||
hub = api.get_hub()
|
||||
|
||||
if not isinstance(hub, nginx.Hub):
|
||||
api.use_hub(nginx)
|
||||
|
||||
hub.poll_register = env['ngx.poll_register']
|
||||
hub.poll_unregister = env['ngx.poll_unregister']
|
||||
hub.sleep = env['ngx.sleep']
|
||||
|
Reference in New Issue
Block a user