codex-storage/deluge
1
0
Fork 0
mirror of https://github.com/codex-storage/deluge.git synced 2025-01-29 04:34:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

last commit fix

Browse Source
This commit is contained in:
Marcos Pinto 2007-07-17 05:03:31 +00:00
parent 776004320e
commit d94c7e6986
1 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/core.py
View File

@ -228,6 +228,9 @@ class Manager:
# Event callbacks for use with plugins # Event callbacks for use with plugins
self.event_callbacks = {} self.event_callbacks = {}
# unique_ids removed by core
self.removed_unique_ids = []
PREF_FUNCTIONS["enable_dht"] = self.set_DHT PREF_FUNCTIONS["enable_dht"] = self.set_DHT
# Unpickle the state, or create a new one # Unpickle the state, or create a new one
@ -443,26 +446,25 @@ class Manager:
self.apply_queue() self.apply_queue()
def clear_completed(self): def clear_completed(self):
removed_unique_IDs = []
for unique_ID in self.unique_IDs: for unique_ID in self.unique_IDs:
torrent_state = self.get_core_torrent_state(unique_ID) torrent_state = self.get_core_torrent_state(unique_ID)
if torrent_state['progress'] == 1.0: if torrent_state['progress'] == 1.0:
self.remove_torrent_ns(unique_ID) self.remove_torrent_ns(unique_ID)
removed_unique_IDs.append(unique_ID) self.removed_unique_ids.append(unique_ID)
self.sync() self.sync()
self.apply_queue() self.apply_queue()
return removed_unique_IDs
# Enforce the queue: pause/unpause as needed, based on queue and user_pausing # Enforce the queue: pause/unpause as needed, based on queue and user_pausing
# This should be called after changes to relevant parameters (user_pausing, or # This should be called after changes to relevant parameters (user_pausing, or
# altering max_active_torrents), or just from time to time # altering max_active_torrents), or just from time to time
# ___ALL queuing code should be in this function, and ONLY here___ # ___ALL queuing code should be in this function, and ONLY here___
def apply_queue(self, efficient = True): def apply_queue(self, efficient = True):
# Handle autoseeding - downqueue as needed # Handle autoseeding - downqueue as needed
if self.get_pref('auto_seed_ratio') > 0 and self.get_pref('auto_end_seeding'): if not self.get_pref('clear_max_ratio_torrents') \
and self.get_pref('auto_seed_ratio') > 0 \
and self.get_pref('auto_end_seeding'):
for unique_ID in self.unique_IDs: for unique_ID in self.unique_IDs:
if self.get_core_torrent_state(unique_ID, efficient)['is_seed']: if self.get_core_torrent_state(unique_ID, efficient)['is_seed']:
torrent_state = self.get_core_torrent_state(unique_ID, efficient) torrent_state = self.get_core_torrent_state(unique_ID, efficient)
@ -470,6 +472,16 @@ class Manager:
if ratio >= self.get_pref('auto_seed_ratio'): if ratio >= self.get_pref('auto_seed_ratio'):
self.queue_bottom(unique_ID, enforce_queue=False) # don't recurse! self.queue_bottom(unique_ID, enforce_queue=False) # don't recurse!
self.set_user_pause(unique_ID, True, enforce_queue=False) self.set_user_pause(unique_ID, True, enforce_queue=False)
if self.get_pref('clear_max_ratio_torrents'):
for index in range(len(self.state.queue)):
unique_ID = self.state.queue[index]
if self.get_core_torrent_state(unique_ID, efficient)['is_seed']:
torrent_state = self.get_core_torrent_state(unique_ID, efficient)
ratio = self.calc_ratio(unique_ID, torrent_state)
if ratio >= self.get_pref('auto_seed_ratio'):
self.removed_unique_ids.append(unique_ID)
self.remove_torrent(unique_ID, False, True)
# Pause and resume torrents # Pause and resume torrents
for index in range(len(self.state.queue)): for index in range(len(self.state.queue)):