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

This reverts commit 8cc4d294e436e0cda167e525b80c8ceed1e619ab.

old-commit-hash: 73db7e8e3a

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)