Browse Source

fix: register signal

pull/493/head
johaven 5 years ago
parent
commit
95025978c9
  1. 2
      socketio/uwsgi_manager.py

2
socketio/uwsgi_manager.py

@ -44,6 +44,7 @@ class UWSGIManager(PubSubManager): # pragma: no cover
self._check_configuration() self._check_configuration()
self.signum = self._sig_number(url) self.signum = self._sig_number(url)
self.queue = Queue() self.queue = Queue()
uwsgi.register_signal(self.signum, 'workers', self._enqueue)
super(UWSGIManager, self).__init__(channel=channel, super(UWSGIManager, self).__init__(channel=channel,
write_only=write_only, write_only=write_only,
logger=logger) logger=logger)
@ -78,7 +79,6 @@ class UWSGIManager(PubSubManager): # pragma: no cover
self.queue.put(uwsgi.queue_last()) self.queue.put(uwsgi.queue_last())
def _uwsgi_listen(self): def _uwsgi_listen(self):
uwsgi.register_signal(self.signum, 'workers', self._enqueue)
for message in iter(self.queue.get, None): for message in iter(self.queue.get, None):
if message is not None: if message is not None:
yield message yield message

Loading…
Cancel
Save