diff options
| -rw-r--r-- | src/journal/journal-file.h | 1 | ||||
| -rw-r--r-- | src/journal/sd-journal.c | 8 |
2 files changed, 8 insertions, 1 deletions
diff --git a/src/journal/journal-file.h b/src/journal/journal-file.h index 8084176195..561982fe39 100644 --- a/src/journal/journal-file.h +++ b/src/journal/journal-file.h @@ -78,6 +78,7 @@ typedef struct JournalFile { direction_t last_direction; LocationType location_type; + uint64_t last_n_entries; char *path; struct stat last_stat; diff --git a/src/journal/sd-journal.c b/src/journal/sd-journal.c index f3aae9b0ed..0aaf2257d4 100644 --- a/src/journal/sd-journal.c +++ b/src/journal/sd-journal.c @@ -729,12 +729,18 @@ static int next_with_matches( static int next_beyond_location(sd_journal *j, JournalFile *f, direction_t direction) { Object *c; - uint64_t cp; + uint64_t cp, n_entries; int r; assert(j); assert(f); + /* If we hit EOF before, recheck if any new entries arrived. */ + n_entries = le64toh(f->header->n_entries); + if (f->location_type == LOCATION_TAIL && n_entries == f->last_n_entries) + return 0; + f->last_n_entries = n_entries; + if (f->last_direction == direction && f->current_offset > 0) { cp = f->current_offset; |