external/tgcloud
1
0
Fork 0
mirror of https://github.com/SlavikMIPT/tgcloud.git synced 2025-02-12 11:12:09 +00:00
Code Issues Releases Wiki Activity

flush() has been removed

Browse source
This commit is contained in:
Вячеслав Баженов 2019-07-10 11:37:24 +03:00
parent 89c4132b46
commit 44cceef636
2 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
dedupfs/dedupfs.py
View file

@ -828,6 +828,8 @@ class DedupFS(fuse.Fuse): # {{{1
with open(FIFO_PIPE, 'wb') as pipe:
os.unlink(FIFO_PIPE)
pipe.write(self.compress(new_block))
# if callable(getattr(pipe, 'flush', None)):
# pipe.flush()
process.wait()
# self.blocks[digest] = self.compress(new_block)

8
telegram_client_x.py
View file

@ -375,8 +375,8 @@ class TelegramClientX(TelegramClient):
cdn_decrypter, result = CdnDecrypter.prepare_decrypter(client, self._get_cdn_client(result), result)
else:
f.write(result.bytes)
if callable(getattr(f, 'flush', None)):
f.flush()
# if callable(getattr(f, 'flush', None)):
# f.flush()
offset += part_size
except FileMigrateError as e:
__log__.info('File lives in another DC')
@ -412,8 +412,8 @@ class TelegramClientX(TelegramClient):
for th in download_thread:
if th.result and th.result.bytes:
f.write(th.result.bytes)
if callable(getattr(f, 'flush', None)):
f.flush()
# if callable(getattr(f, 'flush', None)):
# f.flush()
if progress_callback:
progress_callback(f.tell(), file_size)
else: