mirrors/deluge
0
0
Fork 0
mirror of https://git.deluge-torrent.org/deluge synced 2025-08-04 15:38:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix #358 properly emit torrent_removed signal to clients when torrent is

Browse source 
removed by queue system
This commit is contained in:
Andrew Resch 2008-07-20 20:32:54 +00:00
commit fefc78f468
2 changed files with 7 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
deluge/core/core.py
View file

@ -424,8 +424,6 @@ class Core(
if self.torrents.remove(torrent_id, remove_torrent, remove_data): if self.torrents.remove(torrent_id, remove_torrent, remove_data):
# Run the plugin hooks for 'post_torrent_remove' # Run the plugin hooks for 'post_torrent_remove'
self.plugins.run_post_torrent_remove(torrent_id) self.plugins.run_post_torrent_remove(torrent_id)
# Emit the torrent_removed signal
self.torrent_removed(torrent_id)
def export_force_reannounce(self, torrent_ids): def export_force_reannounce(self, torrent_ids):
log.debug("Forcing reannouncment to: %s", torrent_ids) log.debug("Forcing reannouncment to: %s", torrent_ids)

9
deluge/core/torrentmanager.py
View file

@ -186,10 +186,11 @@ class TorrentManager(component.Component):
if torrent.stop_at_ratio: if torrent.stop_at_ratio:
stop_ratio = torrent.stop_ratio stop_ratio = torrent.stop_ratio
if torrent.get_ratio() >= stop_ratio and torrent.is_finished: if torrent.get_ratio() >= stop_ratio and torrent.is_finished:
if not torrent.handle.is_paused():
torrent.pause()
if self.config["remove_seed_at_ratio"] or torrent.remove_at_ratio: if self.config["remove_seed_at_ratio"] or torrent.remove_at_ratio:
self.remove(torrent_id) self.remove(torrent_id)
break
if not torrent.handle.is_paused():
torrent.pause()
def __getitem__(self, torrent_id): def __getitem__(self, torrent_id):
"""Return the Torrent with torrent_id""" """Return the Torrent with torrent_id"""
@ -434,6 +435,10 @@ class TorrentManager(component.Component):
# Save the session state # Save the session state
self.save_state() self.save_state()
# Emit the signal to the clients
self.signals.emit("torrent_removed", torrent_id)
return True return True
def pause_all(self): def pause_all(self):