StuffAnThings/qbit_manage
1
1
Fork 0
mirror of https://github.com/StuffAnThings/qbit_manage.git synced 2025-10-06 03:46:40 +08:00
Code Issues Projects Releases Packages Wiki Activity

Potential fix for windows crashing on RemoveOrphaned

Browse source
This commit is contained in:
buthed010203 2023-05-20 12:00:38 -04:00 • committed by GitHub
parent 6ddeca80d4
commit e817472ccd
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
modules/core/remove_orphaned.py
View file

@ -7,7 +7,6 @@ from multiprocessing import Pool
from modules import util
logger = util.logger
_config = None
class RemoveOrphaned:
@ -23,7 +22,7 @@ class RemoveOrphaned:
global _config
_config = self.config
self.pool = Pool(processes=max(cpu_count() - 1, 1))
self.pool = Pool(processes=max(cpu_count() - 1, 1), initializer=init_pool, initargs=(self.config,))
self.rem_orphaned()
self.cleanup_pool()
@ -106,6 +105,10 @@ class RemoveOrphaned:
self.pool.join()
def init_pool(conf):
global _config
_config = conf
def get_full_path_of_torrent_files(torrent_files, save_path):
fullpath_torrent_files = []
for file in torrent_files:
@ -115,7 +118,6 @@ def get_full_path_of_torrent_files(torrent_files, save_path):
fullpath_torrent_files.append(fullpath)
return fullpath_torrent_files
def move_orphan(file):
src = file.replace(_config.root_dir, _config.remote_dir) # Could be optimized to only run when root != remote
dest = os.path.join(_config.orphaned_dir, file.replace(_config.root_dir, ""))