|
| 1 | +import bz2 |
1 | 2 | import math
|
2 | 3 | import json
|
3 | 4 | import os
|
|
8 | 9 | import subprocess
|
9 | 10 | import time
|
10 | 11 | import numpy as np
|
11 |
| -import zstd |
12 | 12 | from collections import Counter, defaultdict
|
13 | 13 | from functools import cached_property
|
14 | 14 | from pathlib import Path
|
|
20 | 20 | from openpilot.common.timeout import Timeout
|
21 | 21 | from openpilot.common.params import Params
|
22 | 22 | from openpilot.selfdrive.controls.lib.events import EVENTS, ET
|
23 |
| -from openpilot.selfdrive.test.helpers import set_params_enabled, release_only |
24 | 23 | from openpilot.system.hardware import HARDWARE
|
| 24 | +from openpilot.selfdrive.test.helpers import set_params_enabled, release_only |
25 | 25 | from openpilot.system.hardware.hw import Paths
|
26 |
| -from openpilot.system.loggerd.uploader import LOG_COMPRESSION_LEVEL |
27 | 26 | from openpilot.tools.lib.logreader import LogReader
|
28 | 27 |
|
29 | 28 | """
|
@@ -167,10 +166,10 @@ def setup_class(cls):
|
167 | 166 | cls.log_sizes = {}
|
168 | 167 | for f in cls.log_path.iterdir():
|
169 | 168 | assert f.is_file()
|
170 |
| - cls.log_sizes[f] = f.stat().st_size / 1e6 |
| 169 | + cls.log_sizes[f] = f.stat().st_size / 1e6 |
171 | 170 | if f.name in ("qlog", "rlog"):
|
172 | 171 | with open(f, 'rb') as ff:
|
173 |
| - cls.log_sizes[f] = len(zstd.compress(ff.read(), LOG_COMPRESSION_LEVEL)) / 1e6 |
| 172 | + cls.log_sizes[f] = len(bz2.compress(ff.read())) / 1e6 |
174 | 173 |
|
175 | 174 |
|
176 | 175 | @cached_property
|
@@ -207,7 +206,7 @@ def test_log_sizes(self):
|
207 | 206 | if f.name == "qcamera.ts":
|
208 | 207 | assert 2.15 < sz < 2.35
|
209 | 208 | elif f.name == "qlog":
|
210 |
| - assert 0.4 < sz < 0.5 |
| 209 | + assert 0.4 < sz < 0.6 |
211 | 210 | elif f.name == "rlog":
|
212 | 211 | assert 5 < sz < 50
|
213 | 212 | elif f.name.endswith('.hevc'):
|
|
0 commit comments