1 /* SPDX-License-Identifier: LGPL-2.1+ */
5 This file is part of systemd.
7 Copyright 2011 Lennart Poettering
9 systemd is free software; you can redistribute it and/or modify it
10 under the terms of the GNU Lesser General Public License as published by
11 the Free Software Foundation; either version 2.1 of the License, or
12 (at your option) any later version.
14 systemd is distributed in the hope that it will be useful, but
15 WITHOUT ANY WARRANTY; without even the implied warranty of
16 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
17 Lesser General Public License for more details.
19 You should have received a copy of the GNU Lesser General Public License
20 along with systemd; If not, see <http://www.gnu.org/licenses/>.
24 #include <sys/types.h>
28 typedef struct Server Server
;
31 #include "journal-file.h"
32 #include "journald-context.h"
33 #include "journald-rate-limit.h"
34 #include "journald-stream.h"
38 typedef enum Storage
{
47 typedef enum SplitMode
{
49 SPLIT_LOGIN
, /* deprecated */
55 typedef struct JournalStorageSpace
{
61 uint64_t vfs_used
; /* space used by journal files */
62 uint64_t vfs_available
;
63 } JournalStorageSpace
;
65 typedef struct JournalStorage
{
69 JournalMetrics metrics
;
70 JournalStorageSpace space
;
84 sd_event_source
*syslog_event_source
;
85 sd_event_source
*native_event_source
;
86 sd_event_source
*stdout_event_source
;
87 sd_event_source
*dev_kmsg_event_source
;
88 sd_event_source
*audit_event_source
;
89 sd_event_source
*sync_event_source
;
90 sd_event_source
*sigusr1_event_source
;
91 sd_event_source
*sigusr2_event_source
;
92 sd_event_source
*sigterm_event_source
;
93 sd_event_source
*sigint_event_source
;
94 sd_event_source
*sigrtmin1_event_source
;
95 sd_event_source
*hostname_event_source
;
96 sd_event_source
*notify_event_source
;
97 sd_event_source
*watchdog_event_source
;
99 JournalFile
*runtime_journal
;
100 JournalFile
*system_journal
;
101 OrderedHashmap
*user_journals
;
108 JournalRateLimit
*rate_limit
;
109 usec_t sync_interval_usec
;
110 usec_t rate_limit_interval
;
111 unsigned rate_limit_burst
;
113 JournalStorage runtime_storage
;
114 JournalStorage system_storage
;
120 bool forward_to_kmsg
;
121 bool forward_to_syslog
;
122 bool forward_to_console
;
123 bool forward_to_wall
;
125 unsigned n_forward_syslog_missed
;
126 usec_t last_warn_forward_syslog_missed
;
128 uint64_t var_available_timestamp
;
130 usec_t max_retention_usec
;
131 usec_t max_file_usec
;
132 usec_t oldest_file_usec
;
134 LIST_HEAD(StdoutStream
, stdout_streams
);
135 LIST_HEAD(StdoutStream
, stdout_streams_notify_queue
);
136 unsigned n_stdout_streams
;
141 int max_level_syslog
;
143 int max_level_console
;
147 SplitMode split_mode
;
151 Set
*deferred_closes
;
155 uint64_t *kernel_seqnum
;
156 bool dev_kmsg_readable
:1;
158 bool send_watchdog
:1;
159 bool sent_notify_ready
:1;
160 bool sync_scheduled
:1;
162 char machine_id_field
[sizeof("_MACHINE_ID=") + 32];
163 char boot_id_field
[sizeof("_BOOT_ID=") + 32];
164 char *hostname_field
;
166 /* Cached cgroup root, so that we don't have to query that all the time */
169 usec_t watchdog_usec
;
171 usec_t last_realtime_clock
;
175 /* Caching of client metadata */
176 Hashmap
*client_contexts
;
177 Prioq
*client_contexts_lru
;
179 ClientContext
*my_context
; /* the context of journald itself */
180 ClientContext
*pid1_context
; /* the context of PID 1 */
183 #define SERVER_MACHINE_ID(s) ((s)->machine_id_field + strlen("_MACHINE_ID="))
185 #define N_IOVEC_META_FIELDS 22
186 #define N_IOVEC_KERNEL_FIELDS 64
187 #define N_IOVEC_UDEV_FIELDS 32
188 #define N_IOVEC_OBJECT_FIELDS 14
189 #define N_IOVEC_PAYLOAD_FIELDS 15
191 void server_dispatch_message(Server
*s
, struct iovec
*iovec
, size_t n
, size_t m
, ClientContext
*c
, const struct timeval
*tv
, int priority
, pid_t object_pid
);
192 void server_driver_message(Server
*s
, pid_t object_pid
, const char *message_id
, const char *format
, ...) _sentinel_
;
194 /* gperf lookup function */
195 const struct ConfigPerfItem
* journald_gperf_lookup(const char *key
, GPERF_LEN_TYPE length
);
197 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
);
198 int config_parse_line_max(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
);
200 const char *storage_to_string(Storage s
) _const_
;
201 Storage
storage_from_string(const char *s
) _pure_
;
203 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
);
205 const char *split_mode_to_string(SplitMode s
) _const_
;
206 SplitMode
split_mode_from_string(const char *s
) _pure_
;
208 int server_init(Server
*s
);
209 void server_done(Server
*s
);
210 void server_sync(Server
*s
);
211 int server_vacuum(Server
*s
, bool verbose
);
212 void server_rotate(Server
*s
);
213 int server_schedule_sync(Server
*s
, int priority
);
214 int server_flush_to_var(Server
*s
, bool require_flag_file
);
215 void server_maybe_append_tags(Server
*s
);
216 int server_process_datagram(sd_event_source
*es
, int fd
, uint32_t revents
, void *userdata
);
217 void server_space_usage_message(Server
*s
, JournalStorage
*storage
);