From bb5c1653693ef3978cfb45c2d6a9e8183681587d Mon Sep 17 00:00:00 2001 From: Martijn de Vos Date: Tue, 12 Jul 2016 16:36:08 +0200 Subject: [PATCH] Fixed set_share_mode call --- Tribler/Core/Libtorrent/LibtorrentDownloadImpl.py | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/Tribler/Core/Libtorrent/LibtorrentDownloadImpl.py b/Tribler/Core/Libtorrent/LibtorrentDownloadImpl.py index 3fdff94b6c1..b3b217611b8 100644 --- a/Tribler/Core/Libtorrent/LibtorrentDownloadImpl.py +++ b/Tribler/Core/Libtorrent/LibtorrentDownloadImpl.py @@ -178,8 +178,6 @@ def setup(self, dcfg=None, pstate=None, initialdlstatus=None, # Called by any thread, assume sessionlock is held self.set_checkpoint_disabled(checkpoint_disabled) - self.set_share_mode(share_mode) - try: # The deferred to be returned deferred = Deferred() @@ -204,7 +202,7 @@ def setup(self, dcfg=None, pstate=None, initialdlstatus=None, def schedule_create_engine(): self.cew_scheduled = True create_engine_wrapper_deferred = self.network_create_engine_wrapper( - self.pstate_for_restart, initialdlstatus) + self.pstate_for_restart, initialdlstatus, share_mode=share_mode) create_engine_wrapper_deferred.chainDeferred(deferred) @@ -256,7 +254,7 @@ def do_check(): do_check() return can_create_deferred - def network_create_engine_wrapper(self, pstate, initialdlstatus=None, checkpoint_disabled=False): + def network_create_engine_wrapper(self, pstate, initialdlstatus=None, checkpoint_disabled=False, share_mode=False): with self.dllock: self._logger.debug("LibtorrentDownloadImpl: network_create_engine_wrapper()") @@ -268,7 +266,7 @@ def network_create_engine_wrapper(self, pstate, initialdlstatus=None, checkpoint atp["duplicate_is_error"] = True atp["hops"] = self.get_hops() - if self.get_share_mode(): + if share_mode: atp["flags"] = lt.add_torrent_params_flags_t.flag_share_mode self.set_checkpoint_disabled(checkpoint_disabled) @@ -1051,7 +1049,8 @@ def restart(self, initialdlstatus=None): def schedule_create_engine(_): self.cew_scheduled = True - create_engine_wrapper_deferred = self.network_create_engine_wrapper(self.pstate_for_restart, initialdlstatus) + create_engine_wrapper_deferred = self.network_create_engine_wrapper( + self.pstate_for_restart, initialdlstatus, share_mode=self.get_share_mode()) create_engine_wrapper_deferred.addCallback(self.session.lm.on_download_wrapper_created) can_create_engine_deferred = self.can_create_engine_wrapper()