X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=src%2Fjournal%2Fjournal-internal.h;h=c7e585d810d184fa8585006458f76fde0b03cc18;hb=8060a8b32d9f0c6244dfb6814fb0e339475bcd98;hp=04f77540c91f8eaab4b69f63e1318581fcbbc753;hpb=7827b1a10f4dfe2c6771b515f28f7ae22e0ae039;p=elogind.git diff --git a/src/journal/journal-internal.h b/src/journal/journal-internal.h index 04f77540c..c7e585d81 100644 --- a/src/journal/journal-internal.h +++ b/src/journal/journal-internal.h @@ -1,7 +1,6 @@ /*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/ -#ifndef foojournalinternalhfoo -#define foojournalinternalhfoo +#pragma once /*** This file is part of systemd. @@ -31,6 +30,7 @@ #include "journal-def.h" #include "list.h" #include "hashmap.h" +#include "set.h" #include "journal-file.h" typedef struct Match Match; @@ -58,27 +58,36 @@ struct Match { }; typedef enum LocationType { + /* The first and last entries, resp. */ LOCATION_HEAD, LOCATION_TAIL, - LOCATION_DISCRETE + + /* We already read the entry we currently point to, and the + * next one to read should probably not be this one again. */ + LOCATION_DISCRETE, + + /* We should seek to the precise location specified, and + * return it, as we haven't read it yet. */ + LOCATION_SEEK } LocationType; struct Location { LocationType type; + bool seqnum_set; + bool realtime_set; + bool monotonic_set; + bool xor_hash_set; + uint64_t seqnum; sd_id128_t seqnum_id; - bool seqnum_set; uint64_t realtime; - bool realtime_set; uint64_t monotonic; sd_id128_t boot_id; - bool monotonic_set; uint64_t xor_hash; - bool xor_hash_set; }; struct Directory { @@ -93,6 +102,7 @@ struct sd_journal { char *path; Hashmap *files; + MMapCache *mmap; Location current_location; @@ -104,12 +114,28 @@ struct sd_journal { int inotify_fd; - Match *level0, *level1; + Match *level0, *level1, *level2; unsigned current_invalidate_counter, last_invalidate_counter; + + char *unique_field; + JournalFile *unique_file; + uint64_t unique_offset; + + bool on_network; + + size_t data_threshold; + + Set *errors; + + usec_t last_process_usec; }; char *journal_make_match_string(sd_journal *j); void journal_print_header(sd_journal *j); -#endif +static inline void journal_closep(sd_journal **j) { + sd_journal_close(*j); +} + +#define _cleanup_journal_close_ _cleanup_(journal_closep)