LonamiWebs/Telethon
1
1
Fork 0
mirror of https://github.com/LonamiWebs/Telethon.git synced 2025-06-01 04:03:18 +03:00
Code Issues Packages Projects Releases Wiki Activity

Ignore InvalidChecksumError's

Browse Source
This commit is contained in:
Lonami Exo 2017-09-11 11:04:19 +02:00
parent 48dead76ac
commit a2fdd4b196
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
telethon/network/mtproto_sender.py
View File

@ -4,7 +4,7 @@ from threading import RLock
from .. import helpers as utils from .. import helpers as utils
from ..crypto import AES from ..crypto import AES
from ..errors import BadMessageError, rpc_message_to_error from ..errors import BadMessageError, InvalidChecksumError, rpc_message_to_error
from ..extensions import BinaryReader, BinaryWriter from ..extensions import BinaryReader, BinaryWriter
from ..tl.all_tlobjects import tlobjects from ..tl.all_tlobjects import tlobjects
from ..tl.types import MsgsAck from ..tl.types import MsgsAck
@ -87,7 +87,16 @@ class MtProtoSender:
update_state.process(TLObject). update_state.process(TLObject).
""" """
with self._recv_lock: with self._recv_lock:
body = self.connection.recv() try:
body = self.connection.recv()
except InvalidChecksumError:
# "This packet should be skipped"; since this may have
# been a result for a request, invalidate every request
# and just re-invoke them to avoid problems
for r in self._pending_receive:
r.confirm_received.set()
self._pending_receive.clear()
return
message, remote_msg_id, remote_seq = self._decode_msg(body) message, remote_msg_id, remote_seq = self._decode_msg(body)
with BinaryReader(message) as reader: with BinaryReader(message) as reader: