Commit 227cdd5a authored by Julien Muchembled's avatar Julien Muchembled

client: log safely in poll thread during shutdown

git-svn-id: 71dcc9de-d417-0410-9af5-da40c76e7ee4
parent e8a24c9e
......@@ -15,6 +15,7 @@
# along with this program; if not, write to the Free Software
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
from logging import DEBUG, ERROR
from threading import Thread, Event, enumerate as thread_enum
from neo.lib.locking import Lock
import neo.lib
......@@ -22,11 +23,6 @@ import neo.lib
class _ThreadedPoll(Thread):
"""Polling thread."""
# Garbage collector hint:
# Prevent logging module from being garbage-collected as it is needed for
# run method to cleanly exit.
neo = neo
def __init__(self, em, **kw):
Thread.__init__(self, **kw)
self.em = em
......@@ -34,16 +30,23 @@ class _ThreadedPoll(Thread):
self._stop = Event()
def run(self):
neo.lib.logging.debug('Started %s', self)
_log = neo.lib.logging.log
def log(*args, **kw):
# Ignore errors due to garbage collection on exit
_log(*args, **kw)
if not self.stopping():
log(DEBUG, 'Started %s', self)
while not self.stopping():
# First check if we receive any new message from other node
# XXX: Delay cannot be infinite here, unless we have a way to
# interrupt this call when stopping.
# XXX: Delay cannot be infinite here, because we need
# to check connection timeout and thread shutdown.
self.neo.lib.logging.error('poll raised, retrying', exc_info=1)
self.neo.lib.logging.debug('Threaded poll stopped')
log(ERROR, 'poll raised, retrying', exc_info=1)
log(DEBUG, 'Threaded poll stopped')
def stop(self):
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment