From 44cceef636f1fdce0ae1e7cfe8c9fe854e4bbcea Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=D0=92=D1=8F=D1=87=D0=B5=D1=81=D0=BB=D0=B0=D0=B2=20=D0=91?= =?UTF-8?q?=D0=B0=D0=B6=D0=B5=D0=BD=D0=BE=D0=B2?= Date: Wed, 10 Jul 2019 11:37:24 +0300 Subject: [PATCH] flush() has been removed --- dedupfs/dedupfs.py | 2 ++ telegram_client_x.py | 8 ++++---- 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/dedupfs/dedupfs.py b/dedupfs/dedupfs.py index 4344fbc..b491930 100644 --- a/dedupfs/dedupfs.py +++ b/dedupfs/dedupfs.py @@ -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) diff --git a/telegram_client_x.py b/telegram_client_x.py index bb5c526..9acf56b 100644 --- a/telegram_client_x.py +++ b/telegram_client_x.py @@ -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: