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 /* Extra fields for any log messages */
186 #define N_IOVEC_META_FIELDS 22
188 /* Extra fields for log messages that contain OBJECT_PID= (i.e. log about another process) */
189 #define N_IOVEC_OBJECT_FIELDS 18
191 /* Maximum number of fields we'll add in for driver (i.e. internal) messages */
192 #define N_IOVEC_PAYLOAD_FIELDS 16
194 /* kmsg: Maximum number of extra fields we'll import from the kernel's /dev/kmsg */
195 #define N_IOVEC_KERNEL_FIELDS 64
197 /* kmsg: Maximum number of extra fields we'll import from udev's devices */
198 #define N_IOVEC_UDEV_FIELDS 32
200 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
);
201 void server_driver_message(Server
*s
, pid_t object_pid
, const char *message_id
, const char *format
, ...) _sentinel_
_printf_(4,0);
203 /* gperf lookup function */
204 const struct ConfigPerfItem
* journald_gperf_lookup(const char *key
, GPERF_LEN_TYPE length
);
206 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
);
207 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
);
209 const char *storage_to_string(Storage s
) _const_
;
210 Storage
storage_from_string(const char *s
) _pure_
;
212 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
);
214 const char *split_mode_to_string(SplitMode s
) _const_
;
215 SplitMode
split_mode_from_string(const char *s
) _pure_
;
217 int server_init(Server
*s
);
218 void server_done(Server
*s
);
219 void server_sync(Server
*s
);
220 int server_vacuum(Server
*s
, bool verbose
);
221 void server_rotate(Server
*s
);
222 int server_schedule_sync(Server
*s
, int priority
);
223 int server_flush_to_var(Server
*s
, bool require_flag_file
);
224 void server_maybe_append_tags(Server
*s
);
225 int server_process_datagram(sd_event_source
*es
, int fd
, uint32_t revents
, void *userdata
);
226 void server_space_usage_message(Server
*s
, JournalStorage
*storage
);