X-Git-Url: https://git.novaco.in/?a=blobdiff_plain;f=transports%2Fstratum_tcp.py;h=b7176b9efce4f4f770ccf01d15d7d15f17d72ad2;hb=3051f46df11fc6c9ebe321c9ef6d726e65310129;hp=85fc8b75bb892067ab56c5e6fb17c077e62c780c;hpb=eeeb2b0657c395ade790d5f16e673f277b000e11;p=electrum-server.git diff --git a/transports/stratum_tcp.py b/transports/stratum_tcp.py index 85fc8b7..b7176b9 100644 --- a/transports/stratum_tcp.py +++ b/transports/stratum_tcp.py @@ -55,6 +55,8 @@ class TcpClientRequestor(threading.Thread): if not self.update(): break + self.session.time = time.time() + while self.parse(): pass @@ -123,11 +125,8 @@ class TcpServer(threading.Thread): sock.listen(1) while not self.shared.stopped(): session = TcpSession(*sock.accept()) - client_req = TcpClientRequestor(self.dispatcher, session) - client_req.start() self.dispatcher.add_session(session) self.dispatcher.collect_garbage() - - - + client_req = TcpClientRequestor(self.dispatcher, session) + client_req.start()