From: ThomasV Date: Fri, 24 Jan 2014 10:35:16 +0000 (+0100) Subject: fix push_response session X-Git-Url: https://git.novaco.in/?p=electrum-server.git;a=commitdiff_plain;h=77511c85467a86cd5b03b8da3ddd929857c3f5e8;hp=4d29c30f4782abb7b5eb663e17d82b3f51831d21 fix push_response session --- 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