Changeset 9e6230
- Timestamp:
- 01/17/2014 06:29:53 PM (12 years ago)
- Branches:
- 2.0.x, develop, master
- Children:
- bcbeca4
- Parents:
- da6d0b
- git-author:
- Calum Lind <calumlind+deluge@gmail.com> (01/17/2014 06:29:48 PM)
- git-committer:
- Calum Lind <calumlind+deluge@gmail.com> (01/17/2014 06:29:53 PM)
- Location:
- deluge
- Files:
-
- 5 edited
Legend:
- Unmodified
- Added
- Removed
-
deluge/core/core.py
rda6d0b r9e6230 90 90 91 91 # Set the user agent 92 se lf.settings = lt.session_settings()93 se lf.settings.user_agent= "Deluge/%(deluge_version)s libtorrent/%(lt_version)s" % {92 settings = self.session.get_settings() 93 settings["user_agent"] = "Deluge/%(deluge_version)s libtorrent/%(lt_version)s" % { 94 94 'deluge_version': deluge.common.get_version(), 95 95 'lt_version': self.get_libtorrent_version().rpartition(".")[0] 96 96 } 97 97 # Increase the alert queue size so that alerts don't get lost 98 se lf.settings.alert_queue_size= 1000098 settings["alert_queue_size"] = 10000 99 99 100 100 # Set session settings 101 se lf.settings.send_redundant_have= True101 settings["send_redundant_have"] = True 102 102 if deluge.common.windows_check(): 103 self.settings.disk_io_write_mode = \ 104 lt.io_buffer_mode_t.disable_os_cache 105 self.settings.disk_io_read_mode = \ 106 lt.io_buffer_mode_t.disable_os_cache 107 self.session.set_settings(self.settings) 103 settings["disk_io_write_mode"] = lt.io_buffer_mode_t.disable_os_cache 104 settings["disk_io_read_mode"] = lt.io_buffer_mode_t.disable_os_cache 105 self.session.set_settings(settings) 108 106 109 107 self.session.add_extension("metadata_transfer") -
deluge/core/preferencesmanager.py
rda6d0b r9e6230 79 79 "max_upload_slots_global": 4, 80 80 "max_half_open_connections": (lambda: deluge.common.windows_check() and 81 (lambda: deluge.common.vista_check() and 4 or 8)() or 50)(),81 (lambda: deluge.common.vista_check() and 4 or 8)() or 50)(), 82 82 "max_connections_per_second": 20, 83 83 "ignore_limits_on_local_network": True, … … 152 152 } 153 153 154 154 155 class PreferencesManager(component.Component): 155 156 def __init__(self): … … 185 186 186 187 def session_set_setting(self, key, value): 187 settings = self.session. settings()188 set attr(settings, key, value)188 settings = self.session.get_settings() 189 settings[key] = value 189 190 self.session.set_settings(settings) 190 191 … … 226 227 227 228 # Set the listen ports 228 log.debug("listen port range set to %s-%s", listen_ports[0], 229 listen_ports[1]) 229 log.debug("listen port range set to %s-%s", listen_ports[0], listen_ports[1]) 230 230 self.session.listen_on( 231 231 listen_ports[0], listen_ports[1], … … 314 314 log.debug("encryption settings:\n\t\t\tout_policy: %s\n\t\t\ 315 315 in_policy: %s\n\t\t\tlevel: %s\n\t\t\tprefer_rc4: %s", 316 set.out_enc_policy,317 set.in_enc_policy,318 set.allowed_enc_level,319 set.prefer_rc4)316 set.out_enc_policy, 317 set.in_enc_policy, 318 set.allowed_enc_level, 319 set.prefer_rc4) 320 320 321 321 def _on_set_max_connections_global(self, key, value): … … 393 393 self.config = config 394 394 threading.Thread.__init__(self) 395 395 396 def run(self): 396 397 import time -
deluge/core/torrent.py
rda6d0b r9e6230 152 152 self.torrent_info = None 153 153 154 self.has_metadata = self. handle.has_metadata()154 self.has_metadata = self.status.has_metadata 155 155 self.status_funcs = None 156 156 … … 330 330 def set_auto_managed(self, auto_managed): 331 331 self.options["auto_managed"] = auto_managed 332 if not (self. handle.is_paused() and not self.handle.is_auto_managed()):332 if not (self.status.paused and not self.status.auto_managed): 333 333 self.handle.auto_managed(auto_managed) 334 334 self.update_state() … … 445 445 446 446 session_is_paused = component.get("Core").session.is_paused() 447 is_auto_managed = self.handle.is_auto_managed()448 handle_is_paused = self.handle.is_paused()449 447 450 448 if log.isEnabledFor(logging.DEBUG): … … 458 456 self.state = "Error" 459 457 self.set_status_message(status.error) 460 if handle_is_paused:458 if status.paused: 461 459 self.handle.auto_managed(False) 462 460 return 463 461 464 462 if ltstate == LTSTATE["Queued"] or ltstate == LTSTATE["Checking"]: 465 if handle_is_paused:463 if status.paused: 466 464 self.state = "Paused" 467 465 else: … … 475 473 self.state = "Allocating" 476 474 477 if not session_is_paused and handle_is_paused and is_auto_managed:475 if not session_is_paused and status.paused and status.auto_managed: 478 476 self.state = "Queued" 479 elif session_is_paused or ( handle_is_paused and not is_auto_managed):477 elif session_is_paused or (status.paused and not status.auto_managed): 480 478 self.state = "Paused" 481 479 … … 744 742 "file_progress": self.get_file_progress, # Adjust progress to be 0-100 value 745 743 "files": self.get_files, 746 "is_seed": self.handle.is_seed,744 "is_seed": lambda: self.status.is_seeding, 747 745 "peers": self.get_peers, 748 746 "queue": self.handle.queue_position, … … 777 775 # Turn off auto-management so the torrent will not be unpaused by lt queueing 778 776 self.handle.auto_managed(False) 779 if self. handle.is_paused():777 if self.status.paused: 780 778 # This torrent was probably paused due to being auto managed by lt 781 779 # Since we turned auto_managed off, we should update the state which should … … 796 794 """Resumes this torrent""" 797 795 798 if self. handle.is_paused() and self.handle.is_auto_managed():796 if self.status.paused and self.status.auto_managed: 799 797 log.debug("Torrent is being auto-managed, cannot resume!") 800 798 return … … 803 801 self.set_status_message("OK") 804 802 805 if self. handle.is_finished():803 if self.status.is_finished: 806 804 # If the torrent has already reached it's 'stop_seed_ratio' then do not do anything 807 805 if self.options["stop_at_ratio"]: … … 917 915 def force_recheck(self): 918 916 """Forces a recheck of the torrents pieces""" 919 paused = self. handle.is_paused()917 paused = self.status.paused 920 918 try: 921 919 self.handle.force_recheck() -
deluge/core/torrentmanager.py
rda6d0b r9e6230 282 282 self.remove(torrent_id) 283 283 break 284 if not torrent.handle. is_paused():284 if not torrent.handle.status().paused: 285 285 torrent.pause() 286 286 -
deluge/plugins/Scheduler/deluge/plugins/scheduler/core.py
rda6d0b r9e6230 149 149 session.set_download_rate_limit(int(self.config["low_down"] * 1024)) 150 150 session.set_upload_rate_limit(int(self.config["low_up"] * 1024)) 151 settings = session. settings()152 settings .active_limit= self.config["low_active"]153 settings .active_downloads= self.config["low_active_down"]154 settings .active_seeds= self.config["low_active_up"]151 settings = session.get_settings() 152 settings["active_limit"] = self.config["low_active"] 153 settings["active_downloads"] = self.config["low_active_down"] 154 settings["active_seeds"] = self.config["low_active_up"] 155 155 session.set_settings(settings) 156 156 # Resume the session if necessary
Note:
See TracChangeset
for help on using the changeset viewer.