Fixed set_share_mode call

Tribler · Jul 12, 2016 · bb5c165 · bb5c165
1 parent 79bcd09
commit bb5c165
Showing 1 changed file with 5 additions and 6 deletions.
diff --git 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()