|
|
@ -138,21 +138,18 @@ class TestOnroad(unittest.TestCase): |
|
|
|
cls.lr = list(LogReader(os.path.join(segs[-1], "rlog.bz2"))) |
|
|
|
cls.lr = list(LogReader(os.path.join(segs[-1], "rlog.bz2"))) |
|
|
|
return |
|
|
|
return |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# setup env |
|
|
|
os.environ['REPLAY'] = "1" |
|
|
|
os.environ['REPLAY'] = "1" |
|
|
|
os.environ['SKIP_FW_QUERY'] = "1" |
|
|
|
os.environ['SKIP_FW_QUERY'] = "1" |
|
|
|
os.environ['FINGERPRINT'] = "TOYOTA COROLLA TSS2 2019" |
|
|
|
os.environ['FINGERPRINT'] = "TOYOTA COROLLA TSS2 2019" |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
params = Params() |
|
|
|
|
|
|
|
params.clear_all() |
|
|
|
set_params_enabled() |
|
|
|
set_params_enabled() |
|
|
|
|
|
|
|
|
|
|
|
# Make sure athena isn't running |
|
|
|
# Make sure athena isn't running |
|
|
|
Params().delete("DongleId") |
|
|
|
|
|
|
|
Params().delete("AthenadPid") |
|
|
|
|
|
|
|
os.system("pkill -9 -f athena") |
|
|
|
os.system("pkill -9 -f athena") |
|
|
|
|
|
|
|
|
|
|
|
logger_root = Path(ROOT) |
|
|
|
|
|
|
|
initial_segments = set() |
|
|
|
|
|
|
|
if logger_root.exists(): |
|
|
|
|
|
|
|
initial_segments = set(Path(ROOT).iterdir()) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# start manager and run openpilot for a minute |
|
|
|
# start manager and run openpilot for a minute |
|
|
|
try: |
|
|
|
try: |
|
|
|
manager_path = os.path.join(BASEDIR, "selfdrive/manager/manager.py") |
|
|
|
manager_path = os.path.join(BASEDIR, "selfdrive/manager/manager.py") |
|
|
@ -164,15 +161,19 @@ class TestOnroad(unittest.TestCase): |
|
|
|
sm.update(1000) |
|
|
|
sm.update(1000) |
|
|
|
|
|
|
|
|
|
|
|
# make sure we get at least two full segments |
|
|
|
# make sure we get at least two full segments |
|
|
|
|
|
|
|
route = None |
|
|
|
cls.segments = [] |
|
|
|
cls.segments = [] |
|
|
|
with Timeout(300, "timed out waiting for logs"): |
|
|
|
with Timeout(300, "timed out waiting for logs"): |
|
|
|
|
|
|
|
while route is None: |
|
|
|
|
|
|
|
route = params.get("CurrentRoute", encoding="utf-8") |
|
|
|
|
|
|
|
time.sleep(0.1) |
|
|
|
|
|
|
|
|
|
|
|
while len(cls.segments) < 3: |
|
|
|
while len(cls.segments) < 3: |
|
|
|
new_paths = set() |
|
|
|
segs = set() |
|
|
|
if logger_root.exists(): |
|
|
|
if Path(ROOT).exists(): |
|
|
|
new_paths = set(logger_root.iterdir()) - initial_segments |
|
|
|
segs = set(Path(ROOT).glob(f"{route}--*")) |
|
|
|
segs = [p for p in new_paths if "--" in str(p)] |
|
|
|
|
|
|
|
cls.segments = sorted(segs, key=lambda s: int(str(s).rsplit('--')[-1])) |
|
|
|
cls.segments = sorted(segs, key=lambda s: int(str(s).rsplit('--')[-1])) |
|
|
|
time.sleep(5) |
|
|
|
time.sleep(2) |
|
|
|
|
|
|
|
|
|
|
|
finally: |
|
|
|
finally: |
|
|
|
proc.terminate() |
|
|
|
proc.terminate() |
|
|
|