Changeset View
Changeset View
Standalone View
Standalone View
swh/journal/client.py
Show First 20 Lines • Show All 128 Lines • ▼ Show 20 Lines | def process(self, worker_fn): | ||||
objects = defaultdict(list) | objects = defaultdict(list) | ||||
while True: | while True: | ||||
# timeout for message poll | # timeout for message poll | ||||
timeout = 1.0 | timeout = 1.0 | ||||
elapsed = time.monotonic() - start_time | elapsed = time.monotonic() - start_time | ||||
if self.process_timeout: | if self.process_timeout: | ||||
if elapsed >= self.process_timeout: | if elapsed + 0.01 >= self.process_timeout: | ||||
break | break | ||||
timeout = self.process_timeout - elapsed | timeout = self.process_timeout - elapsed | ||||
message = self.consumer.poll(timeout=timeout) | message = self.consumer.poll(timeout=timeout) | ||||
if not message: | if not message: | ||||
continue | continue | ||||
Show All 24 Lines |