mirror of
https://github.com/derrod/legendary.git
synced 2025-08-28 04:21:01 +00:00
added #debug to some print()s and cleanup of debug print()s
This commit is contained in:
parent
67b347ab14
commit
fc429502a3
|
@ -620,9 +620,6 @@ class DLManager(Process):
|
||||||
|
|
||||||
self.log.debug(f'Created {len(self.sms)} shared memory segments.')
|
self.log.debug(f'Created {len(self.sms)} shared memory segments.')
|
||||||
|
|
||||||
obj_out = log_dlm.create("cli")
|
|
||||||
print("created obj_out")
|
|
||||||
|
|
||||||
# Create queues
|
# Create queues
|
||||||
self.dl_worker_queue = MPQueue(-1)
|
self.dl_worker_queue = MPQueue(-1)
|
||||||
self.writer_queue = MPQueue(-1)
|
self.writer_queue = MPQueue(-1)
|
||||||
|
@ -641,9 +638,7 @@ class DLManager(Process):
|
||||||
writer_p = FileWorker(self.writer_queue, self.writer_result_q, self.dl_dir,
|
writer_p = FileWorker(self.writer_queue, self.writer_result_q, self.dl_dir,
|
||||||
self.shared_memory.name, self.cache_dir, self.logging_queue)
|
self.shared_memory.name, self.cache_dir, self.logging_queue)
|
||||||
self.children.append(writer_p)
|
self.children.append(writer_p)
|
||||||
print("created obj_ou1t")
|
|
||||||
writer_p.start()
|
writer_p.start()
|
||||||
print("created obj_ou2t")
|
|
||||||
|
|
||||||
num_chunk_tasks = sum(isinstance(t, ChunkTask) for t in self.tasks)
|
num_chunk_tasks = sum(isinstance(t, ChunkTask) for t in self.tasks)
|
||||||
num_dl_tasks = len(self.chunks_to_dl)
|
num_dl_tasks = len(self.chunks_to_dl)
|
||||||
|
@ -672,6 +667,9 @@ class DLManager(Process):
|
||||||
for t in self.threads:
|
for t in self.threads:
|
||||||
t.start()
|
t.start()
|
||||||
|
|
||||||
|
obj_out = log_dlm.create(main_window)
|
||||||
|
print("created obj_out")
|
||||||
|
|
||||||
last_update = time.time()
|
last_update = time.time()
|
||||||
|
|
||||||
while processed_tasks < num_tasks:
|
while processed_tasks < num_tasks:
|
||||||
|
@ -716,7 +714,7 @@ class DLManager(Process):
|
||||||
hours = minutes = seconds = 0
|
hours = minutes = seconds = 0
|
||||||
rt_hours = rt_minutes = rt_seconds = 0
|
rt_hours = rt_minutes = rt_seconds = 0
|
||||||
|
|
||||||
print("loop")
|
#debug print("loop")
|
||||||
log_dlm.update( self,
|
log_dlm.update( self,
|
||||||
perc,
|
perc,
|
||||||
processed_chunks,
|
processed_chunks,
|
||||||
|
|
Loading…
Reference in a new issue