diff options
| author | ced <> | 2007-08-13 07:50:01 +0000 |
|---|---|---|
| committer | ced <> | 2007-08-13 07:50:01 +0000 |
| commit | c96337643d80f87f9e3efdd3a9af0442dcd83e81 (patch) | |
| tree | 43ce07bc5339036223601c2250c7b92697485c15 | |
| parent | 2b9c12af43e52d77356c2991d7b0b11b9c96bacb (diff) | |
Improve threads in netrpc
bzr revid: ced-c0433cae35f57fe36fde662450cad35130324953
| -rw-r--r-- | bin/netsvc.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/bin/netsvc.py b/bin/netsvc.py index 70fa3ca851a..c40d45eee78 100644 --- a/bin/netsvc.py +++ b/bin/netsvc.py @@ -301,12 +301,14 @@ class TinySocketClientThread(threading.Thread): ts = tiny_socket.mysocket(self.sock) except: self.sock.close() + self.threads.remove(self) return False while self.running: try: msg = ts.myreceive() except: self.sock.close() + self.threads.remove(self) return False try: s=LocalService(msg[0]) @@ -355,8 +357,8 @@ class TinySocketServerThread(threading.Thread): while self.running: (clientsocket, address) = self.socket.accept() ct = TinySocketClientThread(clientsocket, self.threads) - ct.start() self.threads.append(ct) + ct.start() self.socket.close() except Exception, e: self.socket.close() |