X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?p=elogind.git;a=blobdiff_plain;f=src%2Fjournal%2Fjournald-server.h;h=e468b82931233ede3847fd31f4d72ef9356e227b;hp=41f32ba68d90b0d3b6ec398ff616bf7d46f60641;hb=40b71e89bae4e51768db4dc50ec64c1e9c96eec4;hpb=968f319679d9069af037240d0c3bcd126181cdac diff --git a/src/journal/journald-server.h b/src/journal/journald-server.h index 41f32ba68..e468b8293 100644 --- a/src/journal/journald-server.h +++ b/src/journal/journald-server.h @@ -27,6 +27,7 @@ #include #include +#include "sd-event.h" #include "journal-file.h" #include "hashmap.h" #include "util.h" @@ -54,12 +55,24 @@ typedef enum SplitMode { typedef struct StdoutStream StdoutStream; typedef struct Server { - int epoll_fd; - int signal_fd; int syslog_fd; int native_fd; int stdout_fd; int dev_kmsg_fd; + int hostname_fd; + + sd_event *event; + + sd_event_source *syslog_event_source; + sd_event_source *native_event_source; + sd_event_source *stdout_event_source; + sd_event_source *dev_kmsg_event_source; + sd_event_source *sync_event_source; + sd_event_source *sigusr1_event_source; + sd_event_source *sigusr2_event_source; + sd_event_source *sigterm_event_source; + sd_event_source *sigint_event_source; + sd_event_source *hostname_event_source; JournalFile *runtime_journal; JournalFile *system_journal; @@ -84,6 +97,7 @@ typedef struct Server { bool forward_to_kmsg; bool forward_to_syslog; bool forward_to_console; + bool forward_to_wall; unsigned n_forward_syslog_missed; usec_t last_warn_forward_syslog_missed; @@ -97,9 +111,6 @@ typedef struct Server { usec_t max_file_usec; usec_t oldest_file_usec; - gid_t file_gid; - bool file_gid_valid; - LIST_HEAD(StdoutStream, stdout_streams); unsigned n_stdout_streams; @@ -109,6 +120,7 @@ typedef struct Server { int max_level_syslog; int max_level_kmsg; int max_level_console; + int max_level_wall; Storage storage; SplitMode split_mode; @@ -121,27 +133,33 @@ typedef struct Server { struct udev *udev; - int sync_timer_fd; bool sync_scheduled; + + char machine_id_field[sizeof("_MACHINE_ID=") + 32]; + char boot_id_field[sizeof("_BOOT_ID=") + 32]; + char *hostname_field; + + /* Cached cgroup root, so that we don't have to query that all the time */ + char *cgroup_root; } Server; -#define N_IOVEC_META_FIELDS 17 +#define N_IOVEC_META_FIELDS 20 #define N_IOVEC_KERNEL_FIELDS 64 #define N_IOVEC_UDEV_FIELDS 32 #define N_IOVEC_OBJECT_FIELDS 11 void server_dispatch_message(Server *s, struct iovec *iovec, unsigned n, unsigned m, struct ucred *ucred, struct timeval *tv, const char *label, size_t label_len, const char *unit_id, int priority, pid_t object_pid); -void server_driver_message(Server *s, sd_id128_t message_id, const char *format, ...) _printf_attr_(3,4); +void server_driver_message(Server *s, sd_id128_t message_id, const char *format, ...) _printf_(3,4); /* gperf lookup function */ const struct ConfigPerfItem* journald_gperf_lookup(const char *key, unsigned length); -int config_parse_storage(const char *unit, const char *filename, unsigned line, const char *section, const char *lvalue, int ltype, const char *rvalue, void *data, void *userdata); +int config_parse_storage(const char *unit, const char *filename, unsigned line, const char *section, unsigned section_line, const char *lvalue, int ltype, const char *rvalue, void *data, void *userdata); const char *storage_to_string(Storage s) _const_; Storage storage_from_string(const char *s) _pure_; -int config_parse_split_mode(const char *unit, const char *filename, unsigned line, const char *section, const char *lvalue, int ltype, const char *rvalue, void *data, void *userdata); +int config_parse_split_mode(const char *unit, const char *filename, unsigned line, const char *section, unsigned section_line, const char *lvalue, int ltype, const char *rvalue, void *data, void *userdata); const char *split_mode_to_string(SplitMode s) _const_; SplitMode split_mode_from_string(const char *s) _pure_; @@ -153,7 +171,7 @@ void server_done(Server *s); void server_sync(Server *s); void server_vacuum(Server *s); void server_rotate(Server *s); -int server_schedule_sync(Server *s); +int server_schedule_sync(Server *s, int priority); int server_flush_to_var(Server *s); -int process_event(Server *s, struct epoll_event *ev); void server_maybe_append_tags(Server *s); +int process_datagram(sd_event_source *es, int fd, uint32_t revents, void *userdata);