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

Add more logging calls when confirming a request

Browse Source
This commit is contained in:
Lonami Exo 2018-03-07 11:30:03 +01:00
parent d0bdb7ea3f
commit fca4904d0f
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
telethon/network/mtproto_sender.py
View File

@ -69,6 +69,7 @@ class MtProtoSender:
def disconnect(self): def disconnect(self):
"""Disconnects from the server.""" """Disconnects from the server."""
__log__.info('Disconnecting MtProtoSender...')
self.connection.close() self.connection.close()
self._need_confirmation.clear() self._need_confirmation.clear()
self._clear_all_pending() self._clear_all_pending()
@ -244,6 +245,7 @@ class MtProtoSender:
if r: if r:
r.result = True # Telegram won't send this value r.result = True # Telegram won't send this value
r.confirm_received.set() r.confirm_received.set()
__log__.debug('Confirmed %s through ack', type(r).__name__)
return True return True
@ -252,6 +254,7 @@ class MtProtoSender:
if r: if r:
r.result = obj r.result = obj
r.confirm_received.set() r.confirm_received.set()
__log__.debug('Confirmed %s through salt', type(r).__name__)
# If the object isn't any of the above, then it should be an Update. # If the object isn't any of the above, then it should be an Update.
self.session.process_entities(obj) self.session.process_entities(obj)
@ -308,6 +311,7 @@ class MtProtoSender:
""" """
for r in self._pending_receive.values(): for r in self._pending_receive.values():
r.request.confirm_received.set() r.request.confirm_received.set()
__log__.info('Abruptly confirming %s', type(r).__name__)
self._pending_receive.clear() self._pending_receive.clear()
def _resend_request(self, msg_id): def _resend_request(self, msg_id):
@ -337,6 +341,7 @@ class MtProtoSender:
if request: if request:
request.result = pong request.result = pong
request.confirm_received.set() request.confirm_received.set()
__log__.debug('Confirmed %s through pong', type(request).__name__)
return True return True
@ -490,6 +495,9 @@ class MtProtoSender:
if request: if request:
request.rpc_error = error request.rpc_error = error
request.confirm_received.set() request.confirm_received.set()
__log__.debug('Confirmed %s through error %s',
type(request).__name__, error)
# else TODO Where should this error be reported? # else TODO Where should this error be reported?
# Read may be async. Can an error not-belong to a request? # Read may be async. Can an error not-belong to a request?
return True # All contents were read okay return True # All contents were read okay
@ -505,6 +513,10 @@ class MtProtoSender:
self.session.process_entities(request.result) self.session.process_entities(request.result)
request.confirm_received.set() request.confirm_received.set()
__log__.debug(
'Confirmed %s through normal result %s',
type(request).__name__, type(request.result).__name__
)
return True return True
# If it's really a result for RPC from previous connection # If it's really a result for RPC from previous connection