CodeMirror/Rare
1
0
Fork 0
mirror of synced 2024-06-26 18:20:50 +12:00
Code Issues Projects Releases Wiki Activity

Lgndr: cleanup

Browse source
This commit is contained in:
loathingKernel 2022-07-15 21:06:41 +03:00
parent 654f734975
commit 8bbb42a045
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
rare/lgndr/manager.py
View file

@ -1,21 +1,21 @@
import logging
import os import os
import time import time
import logging
from multiprocessing import Queue as MPQueue from multiprocessing import Queue as MPQueue
from multiprocessing.shared_memory import SharedMemory from multiprocessing.shared_memory import SharedMemory
from sys import exit from sys import exit
from threading import Condition, Thread from threading import Condition, Thread
import legendary.downloader.mp.manager
from legendary.downloader.mp.workers import DLWorker, FileWorker from legendary.downloader.mp.workers import DLWorker, FileWorker
from legendary.models.downloading import ChunkTask, SharedMemorySegment, TerminateWorkerTask from legendary.models.downloading import ChunkTask, SharedMemorySegment, TerminateWorkerTask
import legendary.downloader.mp.manager
from .downloading import UIUpdate from .downloading import UIUpdate
class DLManager(legendary.downloader.mp.manager.DLManager): class DLManager(legendary.downloader.mp.manager.DLManager):
# fmt: off # fmt: off
# @staticmethod
def run_real(self): def run_real(self):
self.shared_memory = SharedMemory(create=True, size=self.max_shared_memory) self.shared_memory = SharedMemory(create=True, size=self.max_shared_memory)
self.log.debug(f'Created shared memory of size: {self.shared_memory.size / 1024 / 1024:.02f} MiB') self.log.debug(f'Created shared memory of size: {self.shared_memory.size / 1024 / 1024:.02f} MiB')