LonamiWebs/Telethon
1
1
Fork 0
mirror of https://github.com/LonamiWebs/Telethon.git synced 2025-02-24 15:30:48 +03:00
Code Issues Packages Projects Releases Wiki Activity

Make offset divisible by limit (#3042)

Browse Source
This commit is contained in:
blank X 2021-05-14 06:11:54 +00:00 committed by GitHub
parent d44928c27b
commit f6a0f5f979
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
telethon/client/downloads.py
View File

@ -142,12 +142,12 @@ class _DirectDownloadIter(RequestIter):
class _GenericDownloadIter(_DirectDownloadIter): class _GenericDownloadIter(_DirectDownloadIter):
async def _load_next_chunk(self, mask=MIN_CHUNK_SIZE - 1): async def _load_next_chunk(self):
# 1. Fetch enough for one chunk # 1. Fetch enough for one chunk
data = b'' data = b''
# 1.1. ``bad`` is how much into the data we have we need to offset # 1.1. ``bad`` is how much into the data we have we need to offset
bad = self.request.offset & mask bad = self.request.offset % self.request.limit
before = self.request.offset before = self.request.offset
# 1.2. We have to fetch from a valid offset, so remove that bad part # 1.2. We have to fetch from a valid offset, so remove that bad part
@ -702,7 +702,8 @@ class DownloadMethods:
if chunk_size == request_size \ if chunk_size == request_size \
and offset % MIN_CHUNK_SIZE == 0 \ and offset % MIN_CHUNK_SIZE == 0 \
and stride % MIN_CHUNK_SIZE == 0: and stride % MIN_CHUNK_SIZE == 0 \
and offset % limit == 0:
cls = _DirectDownloadIter cls = _DirectDownloadIter
self._log[__name__].info('Starting direct file download in chunks of ' self._log[__name__].info('Starting direct file download in chunks of '
'%d at %d, stride %d', request_size, offset, stride) '%d at %d, stride %d', request_size, offset, stride)