mawei/onepilot
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

compressed_vipc: add main()

Browse Source 
old-commit-hash: f18773acbea2c54a2edc70d74c35a8dea6cfdf82
This commit is contained in:
Adeeb Shihadeh
2022-09-26 22:27:30 -07:00
parent 7e200374a8
commit da2d4bebd1
1 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
tools/camerastream/compressed_vipc.py
View File

@@ -85,6 +85,16 @@ def decoder(addr, sock_name, vipc_server, vst, nvidia):
time_q = time_q[1:]
print("%2d %4d %.3f %.3f roll %6.2f ms latency %6.2f ms + %6.2f ms + %6.2f ms = %6.2f ms" % (len(msgs), evta.idx.encodeId, evt.logMonoTime/1e9, evta.idx.timestampEof/1e6, frame_latency, process_latency, network_latency, pc_latency, process_latency+network_latency+pc_latency ), len(evta.data), sock_name)
def main(addr, cams, nvidia=False):
vipc_server = VisionIpcServer("camerad")
for vst in cams.values():
vipc_server.create_buffers(vst, 4, False, W, H)
vipc_server.start_listener()
for k, v in cams.items():
multiprocessing.Process(target=decoder, args=(addr, k, vipc_server, v, nvidia)).start()
if __name__ == "__main__":
parser = argparse.ArgumentParser(description="Decode video streams and broadcast on VisionIPC")
parser.add_argument("addr", help="Address of comma three")
@@ -98,11 +108,4 @@ if __name__ == "__main__":
("driverEncodeData", VisionStreamType.VISION_STREAM_DRIVER),
]
cams = dict([all_cams[int(x)] for x in args.cams.split(",")])
vipc_server = VisionIpcServer("camerad")
for vst in cams.values():
vipc_server.create_buffers(vst, 4, False, W, H)
vipc_server.start_listener()
for k,v in cams.items():
multiprocessing.Process(target=decoder, args=(args.addr, k, vipc_server, v, args.nvidia)).start()
main(args.addr, cams, args.nvidia)