-
-
Notifications
You must be signed in to change notification settings - Fork 147
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'efficiosoft-uwsgi-gevent-support'
- Loading branch information
Showing
4 changed files
with
230 additions
and
4 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,153 @@ | ||
| import importlib | ||
| import sys | ||
| import six | ||
|
|
||
| import gevent | ||
| try: | ||
| import uwsgi | ||
| _websocket_available = hasattr(uwsgi, 'websocket_handshake') | ||
| except ImportError: | ||
| _websocket_available = False | ||
|
|
||
|
|
||
| class Thread(gevent.Greenlet): # pragma: no cover | ||
| """ | ||
| This wrapper class provides gevent Greenlet interface that is compatible | ||
| with the standard library's Thread class. | ||
| """ | ||
| def __init__(self, target, args=[], kwargs={}): | ||
| super(Thread, self).__init__(target, *args, **kwargs) | ||
|
|
||
| def _run(self): | ||
| return self.run() | ||
|
|
||
|
|
||
| class uWSGIWebSocket(object): # pragma: no cover | ||
| """ | ||
| This wrapper class provides a uWSGI WebSocket interface that is | ||
| compatible with eventlet's implementation. | ||
| """ | ||
| def __init__(self, app): | ||
| self.app = app | ||
|
|
||
| def __call__(self, environ, start_response): | ||
| self.environ = environ | ||
|
|
||
| uwsgi.websocket_handshake() | ||
|
|
||
| self._req_ctx = None | ||
| if hasattr(uwsgi, 'request_context'): | ||
| # uWSGI >= 2.1.x with support for api access across-greenlets | ||
| self._req_ctx = uwsgi.request_context() | ||
| else: | ||
| # use event and queue for sending messages | ||
| from gevent.event import Event | ||
| from gevent.queue import Queue | ||
| from gevent.select import select | ||
| self._event = Event() | ||
| self._send_queue = Queue() | ||
|
|
||
| # spawn a select greenlet | ||
| def select_greenlet_runner(fd, event): | ||
| """Sets event when data becomes available to read on fd.""" | ||
| while True: | ||
| event.set() | ||
| select([fd], [], [])[0] | ||
| self._select_greenlet = gevent.spawn( | ||
| select_greenlet_runner, | ||
| uwsgi.connection_fd(), | ||
| self._event) | ||
|
|
||
| return self.app(self) | ||
|
|
||
| def close(self): | ||
| """Disconnects uWSGI from the client.""" | ||
| uwsgi.disconnect() | ||
| if self._req_ctx is None: | ||
| # better kill it here in case wait() is not called again | ||
| self._select_greenlet.kill() | ||
| self._event.set() | ||
|
|
||
| def _send(self, msg): | ||
| """Transmits message either in binary or UTF-8 text mode, | ||
| depending on its type.""" | ||
| if isinstance(msg, six.binary_type): | ||
| method = uwsgi.websocket_send_binary | ||
| else: | ||
| method = uwsgi.websocket_send | ||
| if self._req_ctx is not None: | ||
| method(msg, request_context=self._req_ctx) | ||
| else: | ||
| method(msg) | ||
|
|
||
| def _decode_received(self, msg): | ||
| """Returns either bytes or str, depending on message type.""" | ||
| if not isinstance(msg, six.binary_type): | ||
| # already decoded - do nothing | ||
| return msg | ||
| # only decode from utf-8 if message is not binary data | ||
| type = six.byte2int(msg[0:1]) | ||
| if type >= 48: # no binary | ||
| return msg.decode('utf-8') | ||
| # binary message, don't try to decode | ||
| return msg | ||
|
|
||
| def send(self, msg): | ||
| """Queues a message for sending. Real transmission is done in | ||
| wait method. | ||
| Sends directly if uWSGI version is new enough.""" | ||
| if self._req_ctx is not None: | ||
| self._send(msg) | ||
| else: | ||
| self._send_queue.put(msg) | ||
| self._event.set() | ||
|
|
||
| def wait(self): | ||
| """Waits and returns received messages. | ||
| If running in compatibility mode for older uWSGI versions, | ||
| it also sends messages that have been queued by send(). | ||
| A return value of None means that connection was closed. | ||
| This must be called repeatedly. For uWSGI < 2.1.x it must | ||
| be called from the main greenlet.""" | ||
| while True: | ||
| if self._req_ctx is not None: | ||
| try: | ||
| msg = uwsgi.websocket_recv(request_context=self._req_ctx) | ||
| except IOError: # connection closed | ||
| return None | ||
| return self._decode_received(msg) | ||
| else: | ||
| # we wake up at least every 3 seconds to let uWSGI | ||
| # do its ping/ponging | ||
| event_set = self._event.wait(timeout=3) | ||
| if event_set: | ||
| self._event.clear() | ||
| # maybe there is something to send | ||
| msgs = [] | ||
| while True: | ||
| try: | ||
| msgs.append(self._send_queue.get(block=False)) | ||
| except gevent.queue.Empty: | ||
| break | ||
| for msg in msgs: | ||
| self._send(msg) | ||
| # maybe there is something to receive, if not, at least | ||
| # ensure uWSGI does its ping/ponging | ||
| try: | ||
| msg = uwsgi.websocket_recv_nb() | ||
| except IOError: # connection closed | ||
| self._select_greenlet.kill() | ||
| return None | ||
| if msg: # message available | ||
| return self._decode_received(msg) | ||
|
|
||
|
|
||
| async = { | ||
| 'threading': sys.modules[__name__], | ||
| 'thread_class': 'Thread', | ||
| 'queue': importlib.import_module('gevent.queue'), | ||
| 'queue_class': 'JoinableQueue', | ||
| 'websocket': sys.modules[__name__] if _websocket_available else None, | ||
| 'websocket_class': 'uWSGIWebSocket' if _websocket_available else None, | ||
| 'sleep': gevent.sleep | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters