mawei/sunnypilot
1
0
Fork 0
mirror of https://github.com/sunnypilot/sunnypilot.git synced 2026-08-16 09:33:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

loggerd: only wait to rotate on cameras that are actually streaming (#38362)

Browse Source 
Co-authored-by: Adeeb Shihadeh <adeebshihadeh@gmail.com>
This commit is contained in:
Jimmy
2026-08-07 11:48:13 -07:00
committed by GitHub
parent 4e9e9190a5
commit be191eb8ac
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
openpilot/system/loggerd/loggerd.cc
+2 -2
View File
@@ -31,7 +31,7 @@ void logger_rotate(LoggerdState *s) {
void rotate_if_needed(LoggerdState *s) {
// all encoders ready, trigger rotation
bool all_ready = s->ready_to_rotate == s->max_waiting;
bool all_ready = s->max_waiting > 0 && s->ready_to_rotate == s->max_waiting;
// fallback logic to prevent extremely long segments in the case of camera, encoder, etc. malfunctions
bool timed_out = false;
@@ -125,6 +125,7 @@ int handle_encoder_msg(LoggerdState *s, Message *msg, std::string &name, struct
if (!re.seen_first_packet) {
re.seen_first_packet = true;
re.encoderd_segment_offset = idx.getSegmentNum();
++s->max_waiting; // only count encoders that publish so a disabled/missing camera doesn't stall rotation
LOGD("%s: has encoderd offset %d", name.c_str(), re.encoderd_segment_offset);
}
int offset_segment_num = idx.getSegmentNum() - re.encoderd_segment_offset;
@@ -262,7 +263,6 @@ void loggerd_thread() {
for (const auto &cam : cameras_logged) {
for (const auto &encoder_info : cam.encoder_infos) {
encoder_infos_dict[encoder_info.publish_name] = encoder_info;
s.max_waiting++;
}
}