@@ -61,7 +61,7 @@ class Session:
6161
6262 INITIAL_SALT = 0x616e67656c696361
6363 NET_WORKERS = 1
64- WAIT_TIMEOUT = 30
64+ WAIT_TIMEOUT = 15
6565 MAX_RETRIES = 5
6666 ACKS_THRESHOLD = 8
6767 PING_INTERVAL = 5
@@ -308,7 +308,9 @@ def ping(self):
308308 break
309309
310310 try :
311- self ._send (functions .PingDelayDisconnect (0 , self .PING_INTERVAL + 15 ), False )
311+ self ._send (functions .PingDelayDisconnect (
312+ 0 , self .WAIT_TIMEOUT + 10
313+ ), False )
312314 except (OSError , TimeoutError ):
313315 pass
314316
@@ -338,7 +340,7 @@ def next_salt(self):
338340
339341 try :
340342 self .current_salt = self ._send (functions .GetFutureSalts (1 )).salts [0 ]
341- except (OSError , TimeoutError ):
343+ except (OSError , TimeoutError , Error ):
342344 self .connection .close ()
343345 break
344346
@@ -395,12 +397,14 @@ def _send(self, data: Object, wait_response: bool = True):
395397
396398 def send (self , data : Object ):
397399 for i in range (self .MAX_RETRIES ):
398- self .is_connected .wait ()
400+ self .is_connected .wait (self . WAIT_TIMEOUT )
399401
400402 try :
401403 return self ._send (data )
402404 except (OSError , TimeoutError ):
403- (log .warning if i > 0 else log .info )("{}: {} Retrying {}" .format (i , datetime .now (), type (data )))
405+ (log .warning if i > 2 else log .info )(
406+ "{}: {} Retrying {}" .format (i , datetime .now (), type (data ))
407+ )
404408 continue
405409 else :
406410 return None
0 commit comments