X-Git-Url: https://git.novaco.in/?p=electrum-server.git;a=blobdiff_plain;f=processor.py;h=0ad86ff8cd7369c4623c0abd4d71a36cb20a1bd3;hp=ec62d482686544e77a00d196048fb9c174f20125;hb=f4375ead502d52f5f1e4df8e9b2cc63762326722;hpb=aa8454ee6f18f592e3d679cfde036fd77da111ab diff --git a/processor.py b/processor.py index ec62d48..0ad86ff 100644 --- a/processor.py +++ b/processor.py @@ -177,9 +177,14 @@ class RequestDispatcher(threading.Thread): sessions = self.sessions[:] active_sessions = [] + now = time.time() for session in sessions: - if not session.stopped() and (now - session.time) < 1000: + if (now - session.time) > 1000: + session.stop() + + for session in sessions: + if not session.stopped(): # If session is still alive then re-add it back # to our internal register active_sessions.append(session)