Skip to content

Commit 862567a

Browse files
committed
Tune session settings
1 parent 1736a8e commit 862567a

File tree

1 file changed

+9
-5
lines changed

1 file changed

+9
-5
lines changed

pyrogram/session/session.py

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -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

Comments
 (0)