From a7ef4933a6c550fc20beb34d0e356bc8fbddbf71 Mon Sep 17 00:00:00 2001 From: Michal Bloch Date: Wed, 5 Apr 2023 16:11:11 +0200 Subject: [PATCH] Fix single-log dumping readers Change-Id: I1a0326ff43130646affa211ed117bc6f5041f3af --- src/logger/log_compressed_storage.c | 3 ++- src/logger/log_storage.c | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/src/logger/log_compressed_storage.c b/src/logger/log_compressed_storage.c index 2f69410..4c83b6b 100644 --- a/src/logger/log_compressed_storage.c +++ b/src/logger/log_compressed_storage.c @@ -372,7 +372,8 @@ size_t log_compressed_storage_reader_get_new_entry(log_compressed_storage_reader ce = &reader->storage->entries->entry; reader->current = reader->storage->entries; list_remove(&reader->storage->waiting_readers, reader); - list_add(&reader->current->readers, reader); + if (!log_compressed_storage_reader_check_final(reader, reader->current)) + list_add(&reader->current->readers, reader); } } else if (log_compressed_storage_reader_entry_is_not_last(reader, reader->current)) { // there are more logs in the buffer, let's get them diff --git a/src/logger/log_storage.c b/src/logger/log_storage.c index e49a6aa..244f9ae 100644 --- a/src/logger/log_storage.c +++ b/src/logger/log_storage.c @@ -427,7 +427,8 @@ const dlogutil_entry_s *log_storage_reader_get_new_entry(log_storage_reader *rea le = &reader->storage->entries->entry; reader->current = reader->storage->entries; list_remove(&reader->storage->waiting_readers, reader); - list_add(&reader->current->readers, reader); + if (!log_storage_reader_check_final(reader, reader->current)) + list_add(&reader->current->readers, reader); } } else if (log_storage_reader_entry_is_not_last(reader, reader->current)) { // there are more logs in the buffer, let's get them -- 2.7.4