CodeMirror/Rare
1
0
Fork 0
mirror of synced 2024-06-02 10:44:40 +12:00
Code Issues Projects Releases Wiki Activity

Lgndr: Use perf_counter in download (Rare only)

Browse source
This commit is contained in:
loathingKernel 2023-11-30 12:51:39 +02:00
parent f672a678c9
commit 32859715d3
No known key found for this signature in database
GPG key ID: CE0C72D0B53821FD
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
rare/lgndr/downloader/mp/manager.py
View file

@ -72,7 +72,7 @@ class DLManager(DLManagerReal):
self.conditions = [shm_cond, task_cond]
# start threads
s_time = time.time()
s_time = time.perf_counter()
self.threads.append(Thread(target=self.download_job_manager, args=(task_cond, shm_cond)))
self.threads.append(Thread(target=self.dl_results_handler, args=(task_cond,)))
self.threads.append(Thread(target=self.fw_results_handler, args=(shm_cond,)))
@ -80,13 +80,13 @@ class DLManager(DLManagerReal):
for t in self.threads:
t.start()
last_update = time.time()
last_update = time.perf_counter()
# Rare: kill requested
kill_request = False
while processed_tasks < num_tasks:
delta = time.time() - last_update
delta = time.perf_counter() - last_update
if not delta:
time.sleep(self.update_interval)
continue
@ -108,10 +108,10 @@ class DLManager(DLManagerReal):
self.bytes_read_since_last = self.bytes_written_since_last = 0
self.bytes_downloaded_since_last = self.num_processed_since_last = 0
self.bytes_decompressed_since_last = self.num_tasks_processed_since_last = 0
last_update = time.time()
last_update = time.perf_counter()
perc = (processed_chunks / num_chunk_tasks) * 100
runtime = time.time() - s_time
runtime = time.perf_counter() - s_time
total_avail = len(self.sms)
total_used = (num_shared_memory_segments - total_avail) * (self.analysis.biggest_chunk / 1024 / 1024)