mawei/dragonpilot
1
0
Fork 0
mirror of https://github.com/dragonpilot/dragonpilot.git synced 2026-07-10 15:32:10 +08:00
Code Issues Packages Projects Releases Wiki Activity

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

Browse Source 
This reverts commit 0e5cfa3426.
This commit is contained in:
Adeeb Shihadeh
2023-12-12 19:15:25 -08:00
parent a4179a7c23
commit 73db7e8e3a
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tools/camerastream/compressed_vipc.py
+7 -6
View File
@@ -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)