X-Git-Url: https://git.novaco.in/?p=electrum-server.git;a=blobdiff_plain;f=transports%2Fstratum_tcp.py;fp=transports%2Fstratum_tcp.py;h=17c2b9a2a244955a22f87c7b202414ae5eb6d01b;hp=c843f770a572d4e0d97d69362cb2fe1dd8f5327e;hb=9c7a806d782ee4a3a8a49d2277c41f1513869dc5;hpb=99c1e9407bda694782f79ccbd72d6b0336b91d0a diff --git a/transports/stratum_tcp.py b/transports/stratum_tcp.py index c843f77..17c2b9a 100644 --- a/transports/stratum_tcp.py +++ b/transports/stratum_tcp.py @@ -22,7 +22,7 @@ class TcpSession(Session): self._connection = connection self.address = address[0] - self.name = "TCP" + self.name = "TCP" if not use_ssl else "TCP/SSL" def connection(self): if self.stopped(): @@ -140,7 +140,12 @@ class TcpServer(threading.Thread): sock.bind((self.host, self.port)) sock.listen(1) while not self.shared.stopped(): - session = TcpSession(*sock.accept(), use_ssl=self.use_ssl, ssl_certfile=self.ssl_certfile, ssl_keyfile=self.ssl_keyfile) + try: + session = TcpSession(*sock.accept(), use_ssl=self.use_ssl, ssl_certfile=self.ssl_certfile, ssl_keyfile=self.ssl_keyfile) + except BaseException, e: + error = str(e) + print_log("cannot start TCP session", error) + continue self.dispatcher.add_session(session) self.dispatcher.collect_garbage() client_req = TcpClientRequestor(self.dispatcher, session)