|
|
@ -53,9 +53,9 @@ def log_thumbnail(thumbnailMsg): |
|
|
|
rr.log("/thumbnail", rr.ImageEncoded(contents=bytesImgData)) |
|
|
|
rr.log("/thumbnail", rr.ImageEncoded(contents=bytesImgData)) |
|
|
|
|
|
|
|
|
|
|
|
@rr.shutdown_at_exit |
|
|
|
@rr.shutdown_at_exit |
|
|
|
def process(lr): |
|
|
|
def process(blueprint, lr): |
|
|
|
rr.init("rerun_test") |
|
|
|
rr.init("rerun_test") |
|
|
|
rr.connect() |
|
|
|
rr.connect(default_blueprint=blueprint) |
|
|
|
|
|
|
|
|
|
|
|
ret = [] |
|
|
|
ret = [] |
|
|
|
for msg in lr: |
|
|
|
for msg in lr: |
|
|
@ -80,10 +80,10 @@ if __name__ == '__main__': |
|
|
|
args = parser.parse_args() |
|
|
|
args = parser.parse_args() |
|
|
|
|
|
|
|
|
|
|
|
blueprint = createBlueprint() |
|
|
|
blueprint = createBlueprint() |
|
|
|
rr.init("rerun_test", default_blueprint=blueprint) |
|
|
|
rr.init("rerun_test") |
|
|
|
rr.spawn(connect=False) # child processes stream data to Viewer |
|
|
|
rr.spawn(connect=False) # child processes stream data to Viewer |
|
|
|
|
|
|
|
|
|
|
|
route_or_segment_name = DEMO_ROUTE if args.demo else args.route_or_segment_name.strip() |
|
|
|
route_or_segment_name = DEMO_ROUTE if args.demo else args.route_or_segment_name.strip() |
|
|
|
print("Getting route log paths") |
|
|
|
print("Getting route log paths") |
|
|
|
lr = LogReader(route_or_segment_name) |
|
|
|
lr = LogReader(route_or_segment_name) |
|
|
|
lr.run_across_segments(NUM_CPUS, partial(process)) |
|
|
|
lr.run_across_segments(NUM_CPUS, partial(process, blueprint)) |
|
|
|