From 064a51fe59af5a9e7fac47f7bee47cdbd2e65371 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Harald=20Sch=C3=A4fer?= Date: Sun, 13 Sep 2026 09:38:23 -0700 Subject: [PATCH] model replay: use a mici segment (#38878) * model replay: use a mici segment * process replay: wait for vision listener startup --- openpilot/selfdrive/test/process_replay/model_replay.py | 4 ++-- openpilot/selfdrive/test/process_replay/process_replay.py | 3 ++- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/openpilot/selfdrive/test/process_replay/model_replay.py b/openpilot/selfdrive/test/process_replay/model_replay.py index 47ca3fb104..fb46e83ef0 100755 --- a/openpilot/selfdrive/test/process_replay/model_replay.py +++ b/openpilot/selfdrive/test/process_replay/model_replay.py @@ -20,8 +20,8 @@ from openpilot.tools.lib.framereader import FrameReader from openpilot.tools.lib.logreader import LogReader, save_log from openpilot.tools.lib.github_utils import GithubUtils -TEST_ROUTE = "8494c69d3c710e81|000001d4--2648a9a404" -SEGMENT = 4 +TEST_ROUTE = "98395b7c5b27882e|0000002b--2686b5a2d0" +SEGMENT = 1 START_FRAME = 0 END_FRAME = 60 diff --git a/openpilot/selfdrive/test/process_replay/process_replay.py b/openpilot/selfdrive/test/process_replay/process_replay.py index 5abfab2c35..df60d54e88 100755 --- a/openpilot/selfdrive/test/process_replay/process_replay.py +++ b/openpilot/selfdrive/test/process_replay/process_replay.py @@ -17,7 +17,7 @@ from openpilot.common.hardware.hw import Paths import openpilot.cereal.messaging as messaging from opendbc.car.structs import car from openpilot.cereal.services import SERVICE_LIST -from msgq.visionipc import VisionIpcServer, get_endpoint_name as vipc_get_endpoint_name +from msgq.visionipc import VisionIpcClient, VisionIpcServer, get_endpoint_name as vipc_get_endpoint_name from opendbc.car.can_definitions import CanData from opendbc.car.car_helpers import get_car, interfaces from openpilot.common.params import Params @@ -209,6 +209,7 @@ class ProcessContainer: stride, y_height, _, yuv_size = get_nv12_info(frame_size[0], frame_size[1]) vipc_server.create_buffers_with_sizes(meta.stream, 2, frame_size[0], frame_size[1], yuv_size, stride, stride * y_height) vipc_server.start_listener() + VisionIpcClient.available_streams("camerad", block=True) self.vipc_server = vipc_server self.cfg.vision_pubs = [meta.camera_state for meta in streams_metas if meta.camera_state in self.cfg.vision_pubs]