Improve threads in netrpc
bzr revid: ced-c0433cae35f57fe36fde662450cad35130324953
This commit is contained in:
parent
2b9c12af43
commit
c96337643d
|
@ -301,12 +301,14 @@ class TinySocketClientThread(threading.Thread):
|
||||||
ts = tiny_socket.mysocket(self.sock)
|
ts = tiny_socket.mysocket(self.sock)
|
||||||
except:
|
except:
|
||||||
self.sock.close()
|
self.sock.close()
|
||||||
|
self.threads.remove(self)
|
||||||
return False
|
return False
|
||||||
while self.running:
|
while self.running:
|
||||||
try:
|
try:
|
||||||
msg = ts.myreceive()
|
msg = ts.myreceive()
|
||||||
except:
|
except:
|
||||||
self.sock.close()
|
self.sock.close()
|
||||||
|
self.threads.remove(self)
|
||||||
return False
|
return False
|
||||||
try:
|
try:
|
||||||
s=LocalService(msg[0])
|
s=LocalService(msg[0])
|
||||||
|
@ -355,8 +357,8 @@ class TinySocketServerThread(threading.Thread):
|
||||||
while self.running:
|
while self.running:
|
||||||
(clientsocket, address) = self.socket.accept()
|
(clientsocket, address) = self.socket.accept()
|
||||||
ct = TinySocketClientThread(clientsocket, self.threads)
|
ct = TinySocketClientThread(clientsocket, self.threads)
|
||||||
ct.start()
|
|
||||||
self.threads.append(ct)
|
self.threads.append(ct)
|
||||||
|
ct.start()
|
||||||
self.socket.close()
|
self.socket.close()
|
||||||
except Exception, e:
|
except Exception, e:
|
||||||
self.socket.close()
|
self.socket.close()
|
||||||
|
|
Loading…
Reference in New Issue