X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?p=elogind.git;a=blobdiff_plain;f=src%2Fjournal%2Fjournal-file.h;h=4d6e1407711bad50df1d7896f88c0399cbd8df24;hp=664f917bb0e6dfbcce90f7f961a050e3ddbef0e4;hb=9447a7f1de5e5798cf324ef26579d0dd7e601203;hpb=de190aef08bb267b645205a747762df573b36834 diff --git a/src/journal/journal-file.h b/src/journal/journal-file.h index 664f917bb..4d6e14077 100644 --- a/src/journal/journal-file.h +++ b/src/journal/journal-file.h @@ -24,9 +24,10 @@ #include +#include + #include "journal-def.h" #include "util.h" -#include "sd-id128.h" typedef struct Window { void *ptr; @@ -45,6 +46,13 @@ enum { _WINDOW_MAX }; +typedef struct JournalMetrics { + uint64_t max_use; + uint64_t max_size; + uint64_t min_size; + uint64_t keep_free; +} JournalMetrics; + typedef struct JournalFile { int fd; char *path; @@ -62,6 +70,15 @@ typedef struct JournalFile { Window windows[_WINDOW_MAX]; uint64_t current_offset; + + JournalMetrics metrics; + + bool compress; + +#ifdef HAVE_XZ + void *compress_buffer; + uint64_t compress_buffer_size; +#endif } JournalFile; typedef enum direction { @@ -72,6 +89,8 @@ typedef enum direction { int journal_file_open(const char *fname, int flags, mode_t mode, JournalFile *template, JournalFile **ret); void journal_file_close(JournalFile *j); +int journal_file_open_reliably(const char *fname, int flags, mode_t mode, JournalFile *template, JournalFile **ret); + int journal_file_move_to_object(JournalFile *f, int type, uint64_t offset, Object **ret); uint64_t journal_file_entry_n_items(Object *o); @@ -93,10 +112,16 @@ int journal_file_move_to_entry_by_monotonic(JournalFile *f, sd_id128_t boot_id, int journal_file_move_to_entry_by_seqnum_for_data(JournalFile *f, uint64_t data_offset, uint64_t seqnum, direction_t direction, Object **ret, uint64_t *offset); int journal_file_move_to_entry_by_realtime_for_data(JournalFile *f, uint64_t data_offset, uint64_t realtime, direction_t direction, Object **ret, uint64_t *offset); +int journal_file_copy_entry(JournalFile *from, JournalFile *to, Object *o, uint64_t p, uint64_t *seqnum, Object **ret, uint64_t *offset); + void journal_file_dump(JournalFile *f); int journal_file_rotate(JournalFile **f); int journal_directory_vacuum(const char *directory, uint64_t max_use, uint64_t min_free); +void journal_file_post_change(JournalFile *f); + +void journal_default_metrics(JournalMetrics *m, int fd); + #endif