mirrors/deluge
0
0
Fork 0
mirror of https://git.deluge-torrent.org/deluge synced 2025-09-29 21:48:37 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

[Core] Save torrent state only if state has changed

Browse source
This commit is contained in:
Rato 2017-06-13 06:53:10 +02:00
commit 275c93657f
1 changed files with 20 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

20
deluge/core/torrentmanager.py
View file

@ -111,10 +111,22 @@ class TorrentState:
self.move_completed = move_completed
self.move_completed_path = move_completed_path
def __eq__(self, other):
return isinstance(other, TorrentState) and self.__dict__ == other.__dict__
def __ne__(self, other):
return not self == other
class TorrentManagerState:
def __init__(self):
self.torrents = []
def __eq__(self, other):
return isinstance(other, TorrentManagerState) and self.torrents == other.torrents
def __ne__(self, other):
return not self == other
class TorrentManager(component.Component):
"""
TorrentManager contains a list of torrents in the current libtorrent
@ -157,6 +169,9 @@ class TorrentManager(component.Component):
# Workaround to determine if TorrentAddedEvent is from state file
self.session_started = False
# Keep the previous saved state
self.prev_saved_state = None
# Register set functions
self.config.register_set_function("max_connections_per_torrent",
self.on_set_max_connections_per_torrent)
@ -719,6 +734,10 @@ class TorrentManager(component.Component):
)
state.torrents.append(torrent_state)
# If the state hasn't changed, no need to save it
if self.prev_saved_state == state:
return
# Pickle the TorrentManagerState object
filepath = os.path.join(get_config_dir(), "state", "torrents.state")
filepath_tmp = filepath + ".tmp"
@ -741,6 +760,7 @@ class TorrentManager(component.Component):
os.fsync(state_file.fileno())
state_file.close()
os.rename(filepath_tmp, filepath)
self.prev_saved_state = state
except IOError, ex:
log.error("Unable to save %s: %s", filepath, ex)
if os.path.isfile(filepath_bak):