From f5e836d150f711657717fbf7bbdc068556caed12 Mon Sep 17 00:00:00 2001 From: Shane Smiskol Date: Fri, 1 Aug 2025 19:57:50 -0700 Subject: [PATCH] cu --- selfdrive/test/process_replay/process_replay.py | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/selfdrive/test/process_replay/process_replay.py b/selfdrive/test/process_replay/process_replay.py index acb7aab54f..83243e4e0a 100755 --- a/selfdrive/test/process_replay/process_replay.py +++ b/selfdrive/test/process_replay/process_replay.py @@ -718,7 +718,6 @@ def _replay_multi_process( pbar = tqdm(total=len(external_pub_queue), disable=disable_progress) times = defaultdict(list) while len(external_pub_queue) != 0 or (len(internal_pub_index_heap) != 0 and not all(c.has_empty_queue for c in containers)): - t = time.monotonic() if len(internal_pub_index_heap) == 0 or (len(external_pub_queue) != 0 and external_pub_queue[0].logMonoTime < internal_pub_index_heap[0][0]): msg = external_pub_queue.pop(0) pbar.update(1) @@ -726,9 +725,6 @@ def _replay_multi_process( _, index = heapq.heappop(internal_pub_index_heap) msg = internal_pub_queue[index] - # print(f'get msg took {time.monotonic() - t}s') - - t = time.monotonic() target_containers = pubs_to_containers[msg.which()] for container in target_containers: t1 = time.monotonic() @@ -739,10 +735,8 @@ def _replay_multi_process( internal_pub_queue.append(m) heapq.heappush(internal_pub_index_heap, (m.logMonoTime, len(internal_pub_queue) - 1)) log_msgs.extend(output_msgs) - # print(f'run_step for {container.cfg.proc_name} took {time.monotonic() - t1}s') - # print(f'all run_steps took {time.monotonic() - t}s') - print("Average run_step times:") + print("Total run_step times:") for container, time_list in times.items(): print(f" {container}: {sum(time_list)}s") print('Total run_step time: {:.2f}s'.format(sum(sum(time_list) for time_list in times.values())))