selfdrive/debug/check_lag.py

#!/usr/bin/env python3
# type: ignore

import cereal.messaging as messaging
from cereal.services import service_list

TO_CHECK = ['carState']


if __name__ == "__main__":
  sm = messaging.SubMaster(TO_CHECK)

  prev_t = {}

  while True:
    sm.update()

    for s in TO_CHECK:
      if sm.updated[s]:
        t = sm.logMonoTime[s] / 1e9

        if s in prev_t:
          expected = 1.0 / (service_list[s].frequency)
          dt = t - prev_t[s]
          if dt > 10 * expected:
            print(t, s, dt)

        prev_t[s] = t
Script to check for lags in message reception old-commit-hash: dd676f323601ab1b8b9e33d7980cd3854f71119d 2020-03-20 16:35:23 -07:00			`#!/usr/bin/env python3`
Run mypy commit hook (#1591) * run mypy commit hook * fix mypy errors old-commit-hash: 3d08dcc3b27936cb14c0eae63605be9a6c077380 2020-05-28 15:05:04 -07:00			`# type: ignore`

Script to check for lags in message reception old-commit-hash: dd676f323601ab1b8b9e33d7980cd3854f71119d 2020-03-20 16:35:23 -07:00			`import cereal.messaging as messaging`
			`from cereal.services import service_list`

			`TO_CHECK = ['carState']`


			`if __name__ == "__main__":`
			`sm = messaging.SubMaster(TO_CHECK)`

			`prev_t = {}`

			`while True:`
			`sm.update()`

			`for s in TO_CHECK:`
			`if sm.updated[s]:`
			`t = sm.logMonoTime[s] / 1e9`

			`if s in prev_t:`
			`expected = 1.0 / (service_list[s].frequency)`
			`dt = t - prev_t[s]`
			`if dt > 10 * expected:`
			`print(t, s, dt)`

			`prev_t[s] = t`