Commit fec4d9cc by Owo Sugiana

Log concurrent Invoice ID yang rinci

1 parent 43bb754b
......@@ -349,18 +349,26 @@ class Parser(Log):
def remove_invoice_id(self, inv_id):
remove_invoice_id(self.ip_port, inv_id)
if inv_id in invoice_ids[self.ip_port]:
self.log_debug(
f'Antrian Invoice ID {inv_id} berkurang, threads '
f'{invoice_ids[self.ip_port][inv_id]}')
else:
self.log_debug(f'Antrian Invoice ID {inv_id} sudah habis')
def is_my_turn(self, inv_id):
mem_id = invoice_ids[self.ip_port][inv_id][0]
return mem_id == self.parser_id
def wait_for_same_invoice_id(self, inv_id):
self.log_debug(f'Antrian {invoice_ids[self.ip_port][inv_id]}')
self.log_debug(
f'Antrian Invoice ID {inv_id} threads '
f'{invoice_ids[self.ip_port][inv_id]}')
sleep(1)
duration = time() - self.begin_time
if duration < 10:
return True
self.log_error('Timeout')
self.log_error(f'Invoice ID {inv_id} thread {self.parser_id} timeout')
self.running = False
def run(self):
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!