codex-storage/deluge
1
0
Fork 0
mirror of https://github.com/codex-storage/deluge.git synced 2025-02-11 10:56:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

Get not cached torrent state in core.apply_queue().

Browse Source
This commit is contained in:
Alex Dedul 2007-08-10 22:42:53 +00:00
parent 038a1dc316
commit db4ef67cff
1 changed files with 26 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
src/core.py
View File

@ -501,28 +501,6 @@ class Manager:
# 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): def apply_queue(self):
# Handle autoseeding - downqueue as needed
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:
torrent_state = self.get_core_torrent_state(unique_ID)
if torrent_state['is_seed'] and not torrent_state['is_paused']:
ratio = self.calc_ratio(unique_ID, torrent_state)
if ratio >= self.get_pref('auto_seed_ratio'):
self.queue_bottom(unique_ID, enforce_queue=False) # don't recurse!
self.set_user_pause(unique_ID, True, enforce_queue=False)
if self.get_pref('clear_max_ratio_torrents'):
for unique_ID in self.state.queue:
torrent_state = self.get_core_torrent_state(unique_ID)
if torrent_state['is_seed']:
ratio = self.calc_ratio(unique_ID, torrent_state)
if ratio >= self.get_pref('auto_seed_ratio'):
self.removed_unique_ids[unique_ID] = 1
self.remove_torrent(unique_ID, False, True)
# Counter for currently active torrent in the queue. Paused in core # Counter for currently active torrent in the queue. Paused in core
# but having self.is_user_paused(unique_ID) == False is # but having self.is_user_paused(unique_ID) == False is
# also considered active. # also considered active.
@ -530,7 +508,10 @@ class Manager:
# Pause and resume torrents # Pause and resume torrents
for unique_ID in self.state.queue: for unique_ID in self.state.queue:
torrent_state = self.get_core_torrent_state(unique_ID) # Get not cached torrent state so we don't pause/resume torrents
# more than 1 time - if cached torrent_state['is_paused'] can be
# still paused after we already paused it.
torrent_state = self.get_core_torrent_state(unique_ID, False)
if not torrent_state['is_paused'] or \ if not torrent_state['is_paused'] or \
(torrent_state['is_paused'] and not \ (torrent_state['is_paused'] and not \
@ -564,6 +545,28 @@ class Manager:
self.is_user_paused(unique_ID)): self.is_user_paused(unique_ID)):
self.pause(unique_ID) self.pause(unique_ID)
# Handle autoseeding - downqueue as needed
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:
torrent_state = self.get_core_torrent_state(unique_ID)
if torrent_state['is_seed'] and not torrent_state['is_paused']:
ratio = self.calc_ratio(unique_ID, torrent_state)
if ratio >= self.get_pref('auto_seed_ratio'):
self.queue_bottom(unique_ID, enforce_queue=False) # don't recurse!
self.set_user_pause(unique_ID, True, enforce_queue=False)
if self.get_pref('clear_max_ratio_torrents'):
for unique_ID in self.state.queue:
torrent_state = self.get_core_torrent_state(unique_ID)
if torrent_state['is_seed']:
ratio = self.calc_ratio(unique_ID, torrent_state)
if ratio >= self.get_pref('auto_seed_ratio'):
self.removed_unique_ids[unique_ID] = 1
self.remove_torrent(unique_ID, False, True)
# Event handling # Event handling
def connect_event(self, event_type, callback): def connect_event(self, event_type, callback):