diff --git a/log.capnp b/log.capnp index d96d65c..131ded9 100644 --- a/log.capnp +++ b/log.capnp @@ -1350,6 +1350,18 @@ struct ManagerState { } } +struct UploaderState { + immediateQueueSize @0 :UInt32; + immediateQueueCount @1 :UInt32; + rawQueueSize @2 :UInt32; + rawQueueCount @3 :UInt32; + + # stats for last successfully uploaded file + lastTime @4 :Float32; # s + lastSpeed @5 :Float32; # MB/s + lastFilename @6 :Text; +} + struct Event { logMonoTime @0 :UInt64; # nanoseconds valid @67 :Bool = true; @@ -1400,6 +1412,7 @@ struct Event { # systems stuff androidLog @20 :AndroidLogEntry; managerState @78 :ManagerState; + uploaderState @79 :UploaderState; procLog @33 :ProcLog; clocks @35 :Clocks; deviceState @6 :DeviceState; diff --git a/services.py b/services.py index 56d6e3d..e079089 100755 --- a/services.py +++ b/services.py @@ -60,6 +60,7 @@ services = { "wideRoadCameraState": (True, 20., 20), "modelV2": (True, 20., 40), "managerState": (True, 2., 1), + "uploaderState": (True, 0., 1), } service_list = {name: Service(new_port(idx), *vals) for # type: ignore idx, (name, vals) in enumerate(services.items())}