X-Git-Url: https://git.novaco.in/?a=blobdiff_plain;f=transports%2Fstratum_tcp.py;h=0aebc0f78edd4a77ef520bc1b26a8391b3f9b4bd;hb=24bb4c0f2aafe0e6bd32c1ce1ba8df04fc62e58b;hp=ab6c5c3bf948f8ee7d3af7fbd47d0b3480ae0c69;hpb=5ee042c213baa4ae8a0f538de64644ae9abe7b36;p=electrum-server.git diff --git a/transports/stratum_tcp.py b/transports/stratum_tcp.py index ab6c5c3..0aebc0f 100644 --- a/transports/stratum_tcp.py +++ b/transports/stratum_tcp.py @@ -4,15 +4,26 @@ import threading import time import Queue as queue -from processor import Session, Dispatcher +from processor import Session, Dispatcher, timestr class TcpSession(Session): - def __init__(self, connection, address): - self._connection = connection - self.address = address + def __init__(self, connection, address, use_ssl, ssl_certfile, ssl_keyfile): Session.__init__(self) - print "New session", address + print connection, address, use_ssl + if use_ssl: + import ssl + self._connection = ssl.wrap_socket( + connection, + server_side=True, + certfile=ssl_certfile, + keyfile=ssl_keyfile, + ssl_version=ssl.PROTOCOL_SSLv23) + else: + self._connection = connection + + self.address = address[0] + self.name = "TCP" def connection(self): if self.stopped(): @@ -22,18 +33,20 @@ class TcpSession(Session): def stop(self): self._connection.close() - print "Terminating connection:", self.address[0] + #print "Terminating connection:", self.address with self.lock: self._stopped = True def send_response(self, response): - raw_response = json.dumps(response) + data = json.dumps(response) + "\n" # Possible race condition here by having session # close connection? # I assume Python connections are thread safe interfaces try: connection = self.connection() - connection.send(raw_response + "\n") + while data: + l = connection.send(data) + data = data[l:] except: self.stop() @@ -53,6 +66,8 @@ class TcpClientRequestor(threading.Thread): if not self.update(): break + self.session.time = time.time() + while self.parse(): pass @@ -68,7 +83,7 @@ class TcpClientRequestor(threading.Thread): def receive(self): try: - return self.session.connection().recv(1024) + return self.session.connection().recv(2048) except: return '' @@ -104,7 +119,7 @@ class TcpClientRequestor(threading.Thread): class TcpServer(threading.Thread): - def __init__(self, dispatcher, host, port): + def __init__(self, dispatcher, host, port, use_ssl, ssl_certfile, ssl_keyfile): self.shared = dispatcher.shared self.dispatcher = dispatcher.request_dispatcher threading.Thread.__init__(self) @@ -112,20 +127,20 @@ class TcpServer(threading.Thread): self.host = host self.port = port self.lock = threading.Lock() + self.use_ssl = use_ssl + self.ssl_keyfile = ssl_keyfile + self.ssl_certfile = ssl_certfile def run(self): - print "TCP server started." + print "TCP server started.", self.use_ssl sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) sock.bind((self.host, self.port)) sock.listen(1) while not self.shared.stopped(): - session = TcpSession(*sock.accept()) - client_req = TcpClientRequestor(self.dispatcher, session) - client_req.start() + session = TcpSession(*sock.accept(), use_ssl=self.use_ssl, ssl_certfile=self.ssl_certfile, ssl_keyfile=self.ssl_keyfile) self.dispatcher.add_session(session) self.dispatcher.collect_garbage() - - - + client_req = TcpClientRequestor(self.dispatcher, session) + client_req.start()