|
|
@ -201,14 +201,14 @@ def regen_segment(lr, frs=None, outdir=FAKEDATA, disable_tqdm=False): |
|
|
|
params = Params() |
|
|
|
params = Params() |
|
|
|
os.environ["LOG_ROOT"] = outdir |
|
|
|
os.environ["LOG_ROOT"] = outdir |
|
|
|
|
|
|
|
|
|
|
|
for msg in lr: |
|
|
|
# Get and setup initial state |
|
|
|
if msg.which() == 'carParams': |
|
|
|
CP = [m for m in lr if m.which() == 'carParams'][0].carParams |
|
|
|
setup_env(CP=msg.carParams) |
|
|
|
liveCalibration = [m for m in lr if m.which() == 'liveCalibration'][0] |
|
|
|
elif msg.which() == 'liveCalibration': |
|
|
|
|
|
|
|
params.put("CalibrationParams", msg.as_builder().to_bytes()) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
vs, cam_procs = replay_cameras(lr, frs, disable_tqdm=disable_tqdm) |
|
|
|
setup_env(CP=CP) |
|
|
|
|
|
|
|
params.put("CalibrationParams", liveCalibration.as_builder().to_bytes()) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
vs, cam_procs = replay_cameras(lr, frs, disable_tqdm=disable_tqdm) |
|
|
|
fake_daemons = { |
|
|
|
fake_daemons = { |
|
|
|
'sensord': [ |
|
|
|
'sensord': [ |
|
|
|
multiprocessing.Process(target=replay_sensor_events, args=('sensorEvents', lr)), |
|
|
|
multiprocessing.Process(target=replay_sensor_events, args=('sensorEvents', lr)), |
|
|
|