From 77511c85467a86cd5b03b8da3ddd929857c3f5e8 Mon Sep 17 00:00:00 2001 From: ThomasV Date: Fri, 24 Jan 2014 11:35:16 +0100 Subject: [PATCH 1/1] fix push_response session --- transports/stratum_tcp.py | 4 ++-- 1 files changed, 2 insertions(+), 2 deletions(-) diff --git a/transports/stratum_tcp.py b/transports/stratum_tcp.py index aad4c17..cae116c 100644 --- a/transports/stratum_tcp.py +++ b/transports/stratum_tcp.py @@ -128,7 +128,7 @@ class TcpClientRequestor(threading.Thread): try: command = json.loads(raw_command) except: - self.dispatcher.push_response({"error": "bad JSON", "request": raw_command}) + self.dispatcher.push_response(self.session, {"error": "bad JSON", "request": raw_command}) return True try: @@ -138,7 +138,7 @@ class TcpClientRequestor(threading.Thread): method = command['method'] except KeyError: # Return an error JSON in response. - self.dispatcher.push_response({"error": "syntax error", "request": raw_command}) + self.dispatcher.push_response(self.session, {"error": "syntax error", "request": raw_command}) else: self.dispatcher.push_request(self.session, command) # sleep a bit to prevent a single session from DOSing the queue -- 1.7.1