From 73db7e8e3a9daec01c7e7b7cfb404a1687544b21 Mon Sep 17 00:00:00 2001 From: Adeeb Shihadeh Date: Tue, 12 Dec 2023 19:15:25 -0800 Subject: [PATCH] Revert "compressed_vipc: fix issues with VisionIpcServer in ZMQ mode (#30115)" This reverts commit 0e5cfa3426a3cc2e270c239169a126cdd233865d. --- tools/camerastream/compressed_vipc.py | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/tools/camerastream/compressed_vipc.py b/tools/camerastream/compressed_vipc.py index c6e05a0af8..ac7ca2520b 100755 --- a/tools/camerastream/compressed_vipc.py +++ b/tools/camerastream/compressed_vipc.py @@ -19,11 +19,7 @@ ENCODE_SOCKETS = { VisionStreamType.VISION_STREAM_DRIVER: "driverEncodeData", } -def decoder(addr, vst, nvidia, debug=False): - vipc_server = VisionIpcServer("camerad") - vipc_server.create_buffers(vst, 4, False, W, H) - vipc_server.start_listener() - +def decoder(addr, vipc_server, vst, nvidia, debug=False): sock_name = ENCODE_SOCKETS[vst] if debug: print("start decoder for %s" % sock_name) @@ -105,9 +101,14 @@ def decoder(addr, vst, nvidia, debug=False): class CompressedVipc: def __init__(self, addr, vision_streams, nvidia=False, debug=False): + self.vipc_server = VisionIpcServer("camerad") + for vst in vision_streams: + self.vipc_server.create_buffers(vst, 4, False, W, H) + self.vipc_server.start_listener() + self.procs = [] for vst in vision_streams: - p = multiprocessing.Process(target=decoder, args=(addr, vst, nvidia, debug)) + p = multiprocessing.Process(target=decoder, args=(addr, self.vipc_server, vst, nvidia, debug)) p.start() self.procs.append(p)