compressed_vipc: fix issues with VisionIpcServer in ZMQ mode (#30115)

old-commit-hash: 0e5cfa3426

tools/camerastream/compressed_vipc.py

@@ -19,7 +19,11 @@ ENCODE_SOCKETS = {
   VisionStreamType.VISION_STREAM_DRIVER: "driverEncodeData",
 }
 
-def decoder(addr, vipc_server, vst, nvidia, debug=False):
+def decoder(addr, vst, nvidia, debug=False):
+  vipc_server = VisionIpcServer("camerad")
+  vipc_server.create_buffers(vst, 4, False, W, H)
+  vipc_server.start_listener()
+
   sock_name = ENCODE_SOCKETS[vst]
   if debug:
     print("start decoder for %s" % sock_name)
@@ -101,14 +105,9 @@ def decoder(addr, vipc_server, 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, self.vipc_server, vst, nvidia, debug))
+      p = multiprocessing.Process(target=decoder, args=(addr, vst, nvidia, debug))
       p.start()
       self.procs.append(p)