TeamPGM/pyrogram
2
0
Fork 0
mirror of https://github.com/TeamPGM/pyrogram.git synced 2024-11-18 13:34:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

Further improve save_file

Browse Source
This commit is contained in:
Dan 2018-07-03 16:34:55 +02:00
parent dc7c9af826
commit f6886bd0e4
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
pyrogram/client/client.py
View File

@ -1072,14 +1072,17 @@ class Client(Methods, BaseClient):
file_part: int = 0, file_part: int = 0,
progress: callable = None, progress: callable = None,
progress_args: tuple = ()): progress_args: tuple = ()):
async def worker(): async def worker(session):
while True: while True:
data = await queue.get() data = await queue.get()
if data is None: if data is None:
return return
await asyncio.ensure_future(session.send(data)) try:
await asyncio.ensure_future(session.send(data))
except Exception as e:
log.error(e)
part_size = 512 * 1024 part_size = 512 * 1024
file_size = os.path.getsize(path) file_size = os.path.getsize(path)
@ -1088,12 +1091,13 @@ class Client(Methods, BaseClient):
is_missing_part = file_id is not None is_missing_part = file_id is not None
file_id = file_id or self.rnd_id() file_id = file_id or self.rnd_id()
md5_sum = md5() if not is_big and not is_missing_part else None md5_sum = md5() if not is_big and not is_missing_part else None
session = Session(self, self.dc_id, self.auth_key, is_media=True) pool = [Session(self, self.dc_id, self.auth_key, is_media=True) for _ in range(3)]
workers = [asyncio.ensure_future(worker()) for _ in range(4)] workers = [asyncio.ensure_future(worker(session)) for session in pool for _ in range(4)]
queue = asyncio.Queue(16) queue = asyncio.Queue(16)
try: try:
await session.start() for session in pool:
await session.start()
with open(path, "rb") as f: with open(path, "rb") as f:
f.seek(part_size * file_part) f.seek(part_size * file_part)
@ -1154,7 +1158,9 @@ class Client(Methods, BaseClient):
await queue.put(None) await queue.put(None)
await asyncio.gather(*workers) await asyncio.gather(*workers)
await session.stop()
for session in pool:
await session.stop()
async def get_file(self, async def get_file(self,
dc_id: int, dc_id: int,