Set strict timeout for connection handshake
This commit is contained in:
parent
1803e47c02
commit
f1a54bd7d0
1 changed files with 3 additions and 2 deletions
|
@ -164,13 +164,14 @@ class Connection(object):
|
||||||
self.sock.settimeout(30)
|
self.sock.settimeout(30)
|
||||||
self.sock.connect(sock_address)
|
self.sock.connect(sock_address)
|
||||||
|
|
||||||
self.sock.settimeout(timeout_before)
|
|
||||||
|
|
||||||
# Detect protocol
|
# Detect protocol
|
||||||
self.send({"cmd": "handshake", "req_id": 0, "params": self.getHandshakeInfo()})
|
self.send({"cmd": "handshake", "req_id": 0, "params": self.getHandshakeInfo()})
|
||||||
event_connected = self.event_connected
|
event_connected = self.event_connected
|
||||||
gevent.spawn(self.messageLoop)
|
gevent.spawn(self.messageLoop)
|
||||||
return event_connected.get() # Wait for handshake
|
connect_res = event_connected.get() # Wait for handshake
|
||||||
|
self.sock.settimeout(timeout_before)
|
||||||
|
return connect_res
|
||||||
|
|
||||||
# Handle incoming connection
|
# Handle incoming connection
|
||||||
def handleIncomingConnection(self, sock):
|
def handleIncomingConnection(self, sock):
|
||||||
|
|
Loading…
Reference in a new issue