From ca1cec48641795c16f3963d48ddc35416dbbd874 Mon Sep 17 00:00:00 2001 From: ThomasV Date: Sun, 24 Nov 2013 13:07:12 +0400 Subject: [PATCH] fix memory leak (caused by thread never terminating) --- transports/stratum_tcp.py | 5 ++++- 1 files changed, 4 insertions(+), 1 deletions(-) diff --git a/transports/stratum_tcp.py b/transports/stratum_tcp.py index 5fb26a5..6c36086 100644 --- a/transports/stratum_tcp.py +++ b/transports/stratum_tcp.py @@ -67,7 +67,10 @@ class TcpClientResponder(threading.Thread): def run(self): while not self.session.stopped(): - response = self.session.response_queue.get() + try: + response = self.session.response_queue.get(timeout=10) + except queue.Empty: + continue data = json.dumps(response) + "\n" try: while data: -- 1.7.1