codex-storage
/
deluge
mirror of https://github.com/codex-storage/deluge.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix scheduler so that it keeps current state, even after global settings change.

This commit is contained in:
Chase Sterling 2010-08-26 01:22:14 -04:00
parent 729daf331c
commit c82ba44be8
1 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
deluge/plugins/scheduler/scheduler/core.py
View File

@ -62,6 +62,14 @@ STATES = {
2: "Red" 2: "Red"
} }
CONTROLLED_SETTINGS = [
"max_download_speed",
"max_download_speed",
"max_active_limit",
"max_active_downloading",
"max_active_seeding"
]
class SchedulerEvent(DelugeEvent): class SchedulerEvent(DelugeEvent):
""" """
Emitted when a schedule state changes. Emitted when a schedule state changes.
@ -94,28 +102,32 @@ class Core(CorePluginBase):
secs_to_next_hour = ((60 - now[4]) * 60) + (60 - now[5]) secs_to_next_hour = ((60 - now[4]) * 60) + (60 - now[5])
self.timer = reactor.callLater(secs_to_next_hour, self.do_schedule) self.timer = reactor.callLater(secs_to_next_hour, self.do_schedule)
# Register for config changes so state isn't overridden
component.get("EventManager").register_event_handler("ConfigValueChangedEvent", self.on_config_value_changed)
def disable(self): def disable(self):
try: try:
self.timer.cancel() self.timer.cancel()
except: except:
pass pass
component.get("EventManager").deregister_event_handler("ConfigValueChangedEvent", self.on_config_value_changed)
self.__apply_set_functions() self.__apply_set_functions()
def update(self): def update(self):
pass pass
def on_config_value_changed(self, key, value):
if key in CONTROLLED_SETTINGS:
self.do_schedule(False)
def __apply_set_functions(self): def __apply_set_functions(self):
""" """
Have the core apply it's bandwidth settings as specified in core.conf. Have the core apply it's bandwidth settings as specified in core.conf.
""" """
core_config = deluge.configmanager.ConfigManager("core.conf") core_config = deluge.configmanager.ConfigManager("core.conf")
core_config.apply_set_functions("max_download_speed") for setting in CONTROLLED_SETTINGS:
core_config.apply_set_functions("max_upload_speed") core_config.apply_set_functions(setting)
core_config.apply_set_functions("max_active_limit")
core_config.apply_set_functions("max_active_downloading")
core_config.apply_set_functions("max_active_seeding")
# Resume the session if necessary # Resume the session if necessary
component.get("Core").session.resume() component.get("Core").session.resume()