|
@ -31,7 +31,8 @@ class UWSGIManager(PubSubManager): # pragma: no cover |
|
|
""" |
|
|
""" |
|
|
name = 'uwsgi' |
|
|
name = 'uwsgi' |
|
|
|
|
|
|
|
|
def __init__(self, url='uwsgi:0', channel='socketio', write_only=False, logger=None): |
|
|
def __init__(self, url='uwsgi:0', channel='socketio', write_only=False, |
|
|
|
|
|
logger=None): |
|
|
self._check_configuration() |
|
|
self._check_configuration() |
|
|
self.signum = self._sig_number(url) |
|
|
self.signum = self._sig_number(url) |
|
|
self.queue = Queue() # uWSGI does not provide a a blocking queue |
|
|
self.queue = Queue() # uWSGI does not provide a a blocking queue |
|
@ -46,7 +47,8 @@ class UWSGIManager(PubSubManager): # pragma: no cover |
|
|
try: |
|
|
try: |
|
|
uwsgi.queue_last() |
|
|
uwsgi.queue_last() |
|
|
except AttributeError: |
|
|
except AttributeError: |
|
|
raise RuntimeError('uWSGI queue must be enabled with option --queue 1') |
|
|
raise RuntimeError('uWSGI queue must be enabled with ' |
|
|
|
|
|
'option --queue 1') |
|
|
|
|
|
|
|
|
@staticmethod |
|
|
@staticmethod |
|
|
def _sig_number(url): |
|
|
def _sig_number(url): |
|
@ -54,7 +56,8 @@ class UWSGIManager(PubSubManager): # pragma: no cover |
|
|
try: |
|
|
try: |
|
|
sig = int(url.split(':')[1]) |
|
|
sig = int(url.split(':')[1]) |
|
|
except ValueError: |
|
|
except ValueError: |
|
|
logger.warning('Bad URL format %s, uWSGI signal is listening on default (1)' % url) |
|
|
logger.warning('Bad URL format %s, uWSGI signal ' |
|
|
|
|
|
'is listening on default (1)' % url) |
|
|
else: |
|
|
else: |
|
|
return sig |
|
|
return sig |
|
|
return 0 |
|
|
return 0 |
|
|