Branch data Line data Source code
1 : : /* SPDX-License-Identifier: LGPL-2.1+ */
2 : :
3 : : #include <stddef.h>
4 : : #include <unistd.h>
5 : :
6 : : #if HAVE_SELINUX
7 : : #include <selinux/selinux.h>
8 : : #endif
9 : :
10 : : #include "sd-daemon.h"
11 : : #include "sd-event.h"
12 : :
13 : : #include "alloc-util.h"
14 : : #include "dirent-util.h"
15 : : #include "env-file.h"
16 : : #include "errno-util.h"
17 : : #include "escape.h"
18 : : #include "fd-util.h"
19 : : #include "fileio.h"
20 : : #include "io-util.h"
21 : : #include "journald-console.h"
22 : : #include "journald-context.h"
23 : : #include "journald-kmsg.h"
24 : : #include "journald-server.h"
25 : : #include "journald-stream.h"
26 : : #include "journald-syslog.h"
27 : : #include "journald-wall.h"
28 : : #include "mkdir.h"
29 : : #include "parse-util.h"
30 : : #include "process-util.h"
31 : : #include "selinux-util.h"
32 : : #include "socket-util.h"
33 : : #include "stdio-util.h"
34 : : #include "string-util.h"
35 : : #include "syslog-util.h"
36 : : #include "tmpfile-util.h"
37 : : #include "unit-name.h"
38 : :
39 : : #define STDOUT_STREAMS_MAX 4096
40 : :
41 : : typedef enum StdoutStreamState {
42 : : STDOUT_STREAM_IDENTIFIER,
43 : : STDOUT_STREAM_UNIT_ID,
44 : : STDOUT_STREAM_PRIORITY,
45 : : STDOUT_STREAM_LEVEL_PREFIX,
46 : : STDOUT_STREAM_FORWARD_TO_SYSLOG,
47 : : STDOUT_STREAM_FORWARD_TO_KMSG,
48 : : STDOUT_STREAM_FORWARD_TO_CONSOLE,
49 : : STDOUT_STREAM_RUNNING
50 : : } StdoutStreamState;
51 : :
52 : : /* The different types of log record terminators: a real \n was read, a NUL character was read, the maximum line length
53 : : * was reached, or the end of the stream was reached */
54 : :
55 : : typedef enum LineBreak {
56 : : LINE_BREAK_NEWLINE,
57 : : LINE_BREAK_NUL,
58 : : LINE_BREAK_LINE_MAX,
59 : : LINE_BREAK_EOF,
60 : : } LineBreak;
61 : :
62 : : struct StdoutStream {
63 : : Server *server;
64 : : StdoutStreamState state;
65 : :
66 : : int fd;
67 : :
68 : : struct ucred ucred;
69 : : char *label;
70 : : char *identifier;
71 : : char *unit_id;
72 : : int priority;
73 : : bool level_prefix:1;
74 : : bool forward_to_syslog:1;
75 : : bool forward_to_kmsg:1;
76 : : bool forward_to_console:1;
77 : :
78 : : bool fdstore:1;
79 : : bool in_notify_queue:1;
80 : :
81 : : char *buffer;
82 : : size_t length;
83 : : size_t allocated;
84 : :
85 : : sd_event_source *event_source;
86 : :
87 : : char *state_file;
88 : :
89 : : ClientContext *context;
90 : :
91 : : LIST_FIELDS(StdoutStream, stdout_stream);
92 : : LIST_FIELDS(StdoutStream, stdout_stream_notify_queue);
93 : :
94 : : char id_field[STRLEN("_STREAM_ID=") + SD_ID128_STRING_MAX];
95 : : };
96 : :
97 : 0 : void stdout_stream_free(StdoutStream *s) {
98 [ # # ]: 0 : if (!s)
99 : 0 : return;
100 : :
101 [ # # ]: 0 : if (s->server) {
102 : :
103 [ # # ]: 0 : if (s->context)
104 : 0 : client_context_release(s->server, s->context);
105 : :
106 [ # # ]: 0 : assert(s->server->n_stdout_streams > 0);
107 : 0 : s->server->n_stdout_streams--;
108 [ # # # # : 0 : LIST_REMOVE(stdout_stream, s->server->stdout_streams, s);
# # # # ]
109 : :
110 [ # # ]: 0 : if (s->in_notify_queue)
111 [ # # # # : 0 : LIST_REMOVE(stdout_stream_notify_queue, s->server->stdout_streams_notify_queue, s);
# # # # ]
112 : : }
113 : :
114 [ # # ]: 0 : if (s->event_source) {
115 : 0 : sd_event_source_set_enabled(s->event_source, SD_EVENT_OFF);
116 : 0 : s->event_source = sd_event_source_unref(s->event_source);
117 : : }
118 : :
119 : 0 : safe_close(s->fd);
120 : 0 : free(s->label);
121 : 0 : free(s->identifier);
122 : 0 : free(s->unit_id);
123 : 0 : free(s->state_file);
124 : 0 : free(s->buffer);
125 : :
126 : 0 : free(s);
127 : : }
128 : :
129 [ # # ]: 0 : DEFINE_TRIVIAL_CLEANUP_FUNC(StdoutStream*, stdout_stream_free);
130 : :
131 : 0 : void stdout_stream_destroy(StdoutStream *s) {
132 [ # # ]: 0 : if (!s)
133 : 0 : return;
134 : :
135 [ # # ]: 0 : if (s->state_file)
136 : 0 : (void) unlink(s->state_file);
137 : :
138 : 0 : stdout_stream_free(s);
139 : : }
140 : :
141 : 0 : static int stdout_stream_save(StdoutStream *s) {
142 : 0 : _cleanup_free_ char *temp_path = NULL;
143 : 0 : _cleanup_fclose_ FILE *f = NULL;
144 : : int r;
145 : :
146 [ # # ]: 0 : assert(s);
147 : :
148 [ # # ]: 0 : if (s->state != STDOUT_STREAM_RUNNING)
149 : 0 : return 0;
150 : :
151 [ # # ]: 0 : if (!s->state_file) {
152 : : struct stat st;
153 : :
154 : 0 : r = fstat(s->fd, &st);
155 [ # # ]: 0 : if (r < 0)
156 [ # # ]: 0 : return log_warning_errno(errno, "Failed to stat connected stream: %m");
157 : :
158 : : /* We use device and inode numbers as identifier for the stream */
159 [ # # ]: 0 : if (asprintf(&s->state_file, "/run/systemd/journal/streams/%lu:%lu", (unsigned long) st.st_dev, (unsigned long) st.st_ino) < 0)
160 : 0 : return log_oom();
161 : : }
162 : :
163 : 0 : (void) mkdir_p("/run/systemd/journal/streams", 0755);
164 : :
165 : 0 : r = fopen_temporary(s->state_file, &f, &temp_path);
166 [ # # ]: 0 : if (r < 0)
167 : 0 : goto fail;
168 : :
169 : 0 : fprintf(f,
170 : : "# This is private data. Do not parse\n"
171 : : "PRIORITY=%i\n"
172 : : "LEVEL_PREFIX=%i\n"
173 : : "FORWARD_TO_SYSLOG=%i\n"
174 : : "FORWARD_TO_KMSG=%i\n"
175 : : "FORWARD_TO_CONSOLE=%i\n"
176 : : "STREAM_ID=%s\n",
177 : : s->priority,
178 : 0 : s->level_prefix,
179 : 0 : s->forward_to_syslog,
180 : 0 : s->forward_to_kmsg,
181 : 0 : s->forward_to_console,
182 : 0 : s->id_field + STRLEN("_STREAM_ID="));
183 : :
184 [ # # ]: 0 : if (!isempty(s->identifier)) {
185 [ # # ]: 0 : _cleanup_free_ char *escaped;
186 : :
187 : 0 : escaped = cescape(s->identifier);
188 [ # # ]: 0 : if (!escaped) {
189 : 0 : r = -ENOMEM;
190 : 0 : goto fail;
191 : : }
192 : :
193 : 0 : fprintf(f, "IDENTIFIER=%s\n", escaped);
194 : : }
195 : :
196 [ # # ]: 0 : if (!isempty(s->unit_id)) {
197 [ # # ]: 0 : _cleanup_free_ char *escaped;
198 : :
199 : 0 : escaped = cescape(s->unit_id);
200 [ # # ]: 0 : if (!escaped) {
201 : 0 : r = -ENOMEM;
202 : 0 : goto fail;
203 : : }
204 : :
205 : 0 : fprintf(f, "UNIT=%s\n", escaped);
206 : : }
207 : :
208 : 0 : r = fflush_and_check(f);
209 [ # # ]: 0 : if (r < 0)
210 : 0 : goto fail;
211 : :
212 [ # # ]: 0 : if (rename(temp_path, s->state_file) < 0) {
213 : 0 : r = -errno;
214 : 0 : goto fail;
215 : : }
216 : :
217 [ # # # # ]: 0 : if (!s->fdstore && !s->in_notify_queue) {
218 [ # # # # ]: 0 : LIST_PREPEND(stdout_stream_notify_queue, s->server->stdout_streams_notify_queue, s);
219 : 0 : s->in_notify_queue = true;
220 : :
221 [ # # ]: 0 : if (s->server->notify_event_source) {
222 : 0 : r = sd_event_source_set_enabled(s->server->notify_event_source, SD_EVENT_ON);
223 [ # # ]: 0 : if (r < 0)
224 [ # # ]: 0 : log_warning_errno(r, "Failed to enable notify event source: %m");
225 : : }
226 : : }
227 : :
228 : 0 : return 0;
229 : :
230 : 0 : fail:
231 : 0 : (void) unlink(s->state_file);
232 : :
233 [ # # ]: 0 : if (temp_path)
234 : 0 : (void) unlink(temp_path);
235 : :
236 [ # # ]: 0 : return log_error_errno(r, "Failed to save stream data %s: %m", s->state_file);
237 : : }
238 : :
239 : 0 : static int stdout_stream_log(StdoutStream *s, const char *p, LineBreak line_break) {
240 : : struct iovec *iovec;
241 : : int priority;
242 : 0 : char syslog_priority[] = "PRIORITY=\0";
243 : : char syslog_facility[STRLEN("SYSLOG_FACILITY=") + DECIMAL_STR_MAX(int) + 1];
244 : 0 : _cleanup_free_ char *message = NULL, *syslog_identifier = NULL;
245 : 0 : size_t n = 0, m;
246 : : int r;
247 : :
248 [ # # ]: 0 : assert(s);
249 [ # # ]: 0 : assert(p);
250 : :
251 [ # # ]: 0 : if (s->context)
252 : 0 : (void) client_context_maybe_refresh(s->server, s->context, NULL, NULL, 0, NULL, USEC_INFINITY);
253 [ # # ]: 0 : else if (pid_is_valid(s->ucred.pid)) {
254 : 0 : r = client_context_acquire(s->server, s->ucred.pid, &s->ucred, s->label, strlen_ptr(s->label), s->unit_id, &s->context);
255 [ # # ]: 0 : if (r < 0)
256 [ # # ]: 0 : log_warning_errno(r, "Failed to acquire client context, ignoring: %m");
257 : : }
258 : :
259 : 0 : priority = s->priority;
260 : :
261 [ # # ]: 0 : if (s->level_prefix)
262 : 0 : syslog_parse_priority(&p, &priority, false);
263 : :
264 [ # # ]: 0 : if (!client_context_test_priority(s->context, priority))
265 : 0 : return 0;
266 : :
267 [ # # ]: 0 : if (isempty(p))
268 : 0 : return 0;
269 : :
270 [ # # # # ]: 0 : if (s->forward_to_syslog || s->server->forward_to_syslog)
271 : 0 : server_forward_syslog(s->server, syslog_fixup_facility(priority), s->identifier, p, &s->ucred, NULL);
272 : :
273 [ # # # # ]: 0 : if (s->forward_to_kmsg || s->server->forward_to_kmsg)
274 : 0 : server_forward_kmsg(s->server, priority, s->identifier, p, &s->ucred);
275 : :
276 [ # # # # ]: 0 : if (s->forward_to_console || s->server->forward_to_console)
277 : 0 : server_forward_console(s->server, priority, s->identifier, p, &s->ucred);
278 : :
279 [ # # ]: 0 : if (s->server->forward_to_wall)
280 : 0 : server_forward_wall(s->server, priority, s->identifier, p, &s->ucred);
281 : :
282 : 0 : m = N_IOVEC_META_FIELDS + 7 + client_context_extra_fields_n_iovec(s->context);
283 [ # # # # ]: 0 : iovec = newa(struct iovec, m);
284 : :
285 : 0 : iovec[n++] = IOVEC_MAKE_STRING("_TRANSPORT=stdout");
286 : 0 : iovec[n++] = IOVEC_MAKE_STRING(s->id_field);
287 : :
288 : 0 : syslog_priority[STRLEN("PRIORITY=")] = '0' + LOG_PRI(priority);
289 : 0 : iovec[n++] = IOVEC_MAKE_STRING(syslog_priority);
290 : :
291 [ # # ]: 0 : if (priority & LOG_FACMASK) {
292 [ # # ]: 0 : xsprintf(syslog_facility, "SYSLOG_FACILITY=%i", LOG_FAC(priority));
293 : 0 : iovec[n++] = IOVEC_MAKE_STRING(syslog_facility);
294 : : }
295 : :
296 [ # # ]: 0 : if (s->identifier) {
297 : 0 : syslog_identifier = strjoin("SYSLOG_IDENTIFIER=", s->identifier);
298 [ # # ]: 0 : if (syslog_identifier)
299 : 0 : iovec[n++] = IOVEC_MAKE_STRING(syslog_identifier);
300 : : }
301 : :
302 [ # # ]: 0 : if (line_break != LINE_BREAK_NEWLINE) {
303 : : const char *c;
304 : :
305 : : /* If this log message was generated due to an uncommon line break then mention this in the log
306 : : * entry */
307 : :
308 [ # # ]: 0 : c = line_break == LINE_BREAK_NUL ? "_LINE_BREAK=nul" :
309 [ # # ]: 0 : line_break == LINE_BREAK_LINE_MAX ? "_LINE_BREAK=line-max" :
310 : : "_LINE_BREAK=eof";
311 : 0 : iovec[n++] = IOVEC_MAKE_STRING(c);
312 : : }
313 : :
314 : 0 : message = strjoin("MESSAGE=", p);
315 [ # # ]: 0 : if (message)
316 : 0 : iovec[n++] = IOVEC_MAKE_STRING(message);
317 : :
318 : 0 : server_dispatch_message(s->server, iovec, n, m, s->context, NULL, priority, 0);
319 : 0 : return 0;
320 : : }
321 : :
322 : 0 : static int stdout_stream_line(StdoutStream *s, char *p, LineBreak line_break) {
323 : : int r;
324 : : char *orig;
325 : :
326 [ # # ]: 0 : assert(s);
327 [ # # ]: 0 : assert(p);
328 : :
329 : 0 : orig = p;
330 : 0 : p = strstrip(p);
331 : :
332 : : /* line breaks by NUL, line max length or EOF are not permissible during the negotiation part of the protocol */
333 [ # # # # ]: 0 : if (line_break != LINE_BREAK_NEWLINE && s->state != STDOUT_STREAM_RUNNING) {
334 [ # # ]: 0 : log_warning("Control protocol line not properly terminated.");
335 : 0 : return -EINVAL;
336 : : }
337 : :
338 [ # # # # : 0 : switch (s->state) {
# # # #
# ]
339 : :
340 : 0 : case STDOUT_STREAM_IDENTIFIER:
341 [ # # ]: 0 : if (!isempty(p)) {
342 : 0 : s->identifier = strdup(p);
343 [ # # ]: 0 : if (!s->identifier)
344 : 0 : return log_oom();
345 : : }
346 : :
347 : 0 : s->state = STDOUT_STREAM_UNIT_ID;
348 : 0 : return 0;
349 : :
350 : 0 : case STDOUT_STREAM_UNIT_ID:
351 [ # # ]: 0 : if (s->ucred.uid == 0 &&
352 [ # # ]: 0 : unit_name_is_valid(p, UNIT_NAME_PLAIN|UNIT_NAME_INSTANCE)) {
353 : :
354 : 0 : s->unit_id = strdup(p);
355 [ # # ]: 0 : if (!s->unit_id)
356 : 0 : return log_oom();
357 : : }
358 : :
359 : 0 : s->state = STDOUT_STREAM_PRIORITY;
360 : 0 : return 0;
361 : :
362 : 0 : case STDOUT_STREAM_PRIORITY:
363 : 0 : r = safe_atoi(p, &s->priority);
364 [ # # # # : 0 : if (r < 0 || s->priority < 0 || s->priority > 999) {
# # ]
365 [ # # ]: 0 : log_warning("Failed to parse log priority line.");
366 : 0 : return -EINVAL;
367 : : }
368 : :
369 : 0 : s->state = STDOUT_STREAM_LEVEL_PREFIX;
370 : 0 : return 0;
371 : :
372 : 0 : case STDOUT_STREAM_LEVEL_PREFIX:
373 : 0 : r = parse_boolean(p);
374 [ # # ]: 0 : if (r < 0) {
375 [ # # ]: 0 : log_warning("Failed to parse level prefix line.");
376 : 0 : return -EINVAL;
377 : : }
378 : :
379 : 0 : s->level_prefix = r;
380 : 0 : s->state = STDOUT_STREAM_FORWARD_TO_SYSLOG;
381 : 0 : return 0;
382 : :
383 : 0 : case STDOUT_STREAM_FORWARD_TO_SYSLOG:
384 : 0 : r = parse_boolean(p);
385 [ # # ]: 0 : if (r < 0) {
386 [ # # ]: 0 : log_warning("Failed to parse forward to syslog line.");
387 : 0 : return -EINVAL;
388 : : }
389 : :
390 : 0 : s->forward_to_syslog = r;
391 : 0 : s->state = STDOUT_STREAM_FORWARD_TO_KMSG;
392 : 0 : return 0;
393 : :
394 : 0 : case STDOUT_STREAM_FORWARD_TO_KMSG:
395 : 0 : r = parse_boolean(p);
396 [ # # ]: 0 : if (r < 0) {
397 [ # # ]: 0 : log_warning("Failed to parse copy to kmsg line.");
398 : 0 : return -EINVAL;
399 : : }
400 : :
401 : 0 : s->forward_to_kmsg = r;
402 : 0 : s->state = STDOUT_STREAM_FORWARD_TO_CONSOLE;
403 : 0 : return 0;
404 : :
405 : 0 : case STDOUT_STREAM_FORWARD_TO_CONSOLE:
406 : 0 : r = parse_boolean(p);
407 [ # # ]: 0 : if (r < 0) {
408 [ # # ]: 0 : log_warning("Failed to parse copy to console line.");
409 : 0 : return -EINVAL;
410 : : }
411 : :
412 : 0 : s->forward_to_console = r;
413 : 0 : s->state = STDOUT_STREAM_RUNNING;
414 : :
415 : : /* Try to save the stream, so that journald can be restarted and we can recover */
416 : 0 : (void) stdout_stream_save(s);
417 : 0 : return 0;
418 : :
419 : 0 : case STDOUT_STREAM_RUNNING:
420 : 0 : return stdout_stream_log(s, orig, line_break);
421 : : }
422 : :
423 : 0 : assert_not_reached("Unknown stream state");
424 : : }
425 : :
426 : 0 : static int stdout_stream_scan(StdoutStream *s, bool force_flush) {
427 : : char *p;
428 : : size_t remaining;
429 : : int r;
430 : :
431 [ # # ]: 0 : assert(s);
432 : :
433 : 0 : p = s->buffer;
434 : 0 : remaining = s->length;
435 : :
436 : : /* XXX: This function does nothing if (s->length == 0) */
437 : :
438 : 0 : for (;;) {
439 : : LineBreak line_break;
440 : : size_t skip;
441 : : char *end1, *end2;
442 : :
443 : 0 : end1 = memchr(p, '\n', remaining);
444 [ # # ]: 0 : end2 = memchr(p, 0, end1 ? (size_t) (end1 - p) : remaining);
445 : :
446 [ # # ]: 0 : if (end2) {
447 : : /* We found a NUL terminator */
448 : 0 : skip = end2 - p + 1;
449 : 0 : line_break = LINE_BREAK_NUL;
450 [ # # ]: 0 : } else if (end1) {
451 : : /* We found a \n terminator */
452 : 0 : *end1 = 0;
453 : 0 : skip = end1 - p + 1;
454 : 0 : line_break = LINE_BREAK_NEWLINE;
455 [ # # ]: 0 : } else if (remaining >= s->server->line_max) {
456 : : /* Force a line break after the maximum line length */
457 : 0 : *(p + s->server->line_max) = 0;
458 : 0 : skip = remaining;
459 : 0 : line_break = LINE_BREAK_LINE_MAX;
460 : : } else
461 : 0 : break;
462 : :
463 : 0 : r = stdout_stream_line(s, p, line_break);
464 [ # # ]: 0 : if (r < 0)
465 : 0 : return r;
466 : :
467 : 0 : remaining -= skip;
468 : 0 : p += skip;
469 : : }
470 : :
471 [ # # # # ]: 0 : if (force_flush && remaining > 0) {
472 : 0 : p[remaining] = 0;
473 : 0 : r = stdout_stream_line(s, p, LINE_BREAK_EOF);
474 [ # # ]: 0 : if (r < 0)
475 : 0 : return r;
476 : :
477 : 0 : p += remaining;
478 : 0 : remaining = 0;
479 : : }
480 : :
481 [ # # ]: 0 : if (p > s->buffer) {
482 : 0 : memmove(s->buffer, p, remaining);
483 : 0 : s->length = remaining;
484 : : }
485 : :
486 : 0 : return 0;
487 : : }
488 : :
489 : 0 : static int stdout_stream_process(sd_event_source *es, int fd, uint32_t revents, void *userdata) {
490 : 0 : StdoutStream *s = userdata;
491 : : size_t limit;
492 : : ssize_t l;
493 : : int r;
494 : :
495 [ # # ]: 0 : assert(s);
496 : :
497 [ # # ]: 0 : if ((revents|EPOLLIN|EPOLLHUP) != (EPOLLIN|EPOLLHUP)) {
498 [ # # ]: 0 : log_error("Got invalid event from epoll for stdout stream: %"PRIx32, revents);
499 : 0 : goto terminate;
500 : : }
501 : :
502 : : /* If the buffer is full already (discounting the extra NUL we need), add room for another 1K */
503 [ # # ]: 0 : if (s->length + 1 >= s->allocated) {
504 [ # # ]: 0 : if (!GREEDY_REALLOC(s->buffer, s->allocated, s->length + 1 + 1024)) {
505 : 0 : log_oom();
506 : 0 : goto terminate;
507 : : }
508 : : }
509 : :
510 : : /* Try to make use of the allocated buffer in full, but never read more than the configured line size. Also,
511 : : * always leave room for a terminating NUL we might need to add. */
512 : 0 : limit = MIN(s->allocated - 1, s->server->line_max);
513 : :
514 : 0 : l = read(s->fd, s->buffer + s->length, limit - s->length);
515 [ # # ]: 0 : if (l < 0) {
516 [ # # ]: 0 : if (errno == EAGAIN)
517 : 0 : return 0;
518 : :
519 [ # # ]: 0 : log_warning_errno(errno, "Failed to read from stream: %m");
520 : 0 : goto terminate;
521 : : }
522 : :
523 [ # # ]: 0 : if (l == 0) {
524 : 0 : stdout_stream_scan(s, true);
525 : 0 : goto terminate;
526 : : }
527 : :
528 : 0 : s->length += l;
529 : 0 : r = stdout_stream_scan(s, false);
530 [ # # ]: 0 : if (r < 0)
531 : 0 : goto terminate;
532 : :
533 : 0 : return 1;
534 : :
535 : 0 : terminate:
536 : 0 : stdout_stream_destroy(s);
537 : 0 : return 0;
538 : : }
539 : :
540 : 0 : int stdout_stream_install(Server *s, int fd, StdoutStream **ret) {
541 : 0 : _cleanup_(stdout_stream_freep) StdoutStream *stream = NULL;
542 : : sd_id128_t id;
543 : : int r;
544 : :
545 [ # # ]: 0 : assert(s);
546 [ # # ]: 0 : assert(fd >= 0);
547 : :
548 : 0 : r = sd_id128_randomize(&id);
549 [ # # ]: 0 : if (r < 0)
550 [ # # ]: 0 : return log_error_errno(r, "Failed to generate stream ID: %m");
551 : :
552 : 0 : stream = new0(StdoutStream, 1);
553 [ # # ]: 0 : if (!stream)
554 : 0 : return log_oom();
555 : :
556 : 0 : stream->fd = -1;
557 : 0 : stream->priority = LOG_INFO;
558 : :
559 [ # # ]: 0 : xsprintf(stream->id_field, "_STREAM_ID=" SD_ID128_FORMAT_STR, SD_ID128_FORMAT_VAL(id));
560 : :
561 : 0 : r = getpeercred(fd, &stream->ucred);
562 [ # # ]: 0 : if (r < 0)
563 [ # # ]: 0 : return log_error_errno(r, "Failed to determine peer credentials: %m");
564 : :
565 [ # # ]: 0 : if (mac_selinux_use()) {
566 : 0 : r = getpeersec(fd, &stream->label);
567 [ # # # # ]: 0 : if (r < 0 && r != -EOPNOTSUPP)
568 [ # # ]: 0 : (void) log_warning_errno(r, "Failed to determine peer security context: %m");
569 : : }
570 : :
571 : 0 : (void) shutdown(fd, SHUT_WR);
572 : :
573 : 0 : r = sd_event_add_io(s->event, &stream->event_source, fd, EPOLLIN, stdout_stream_process, stream);
574 [ # # ]: 0 : if (r < 0)
575 [ # # ]: 0 : return log_error_errno(r, "Failed to add stream to event loop: %m");
576 : :
577 : 0 : r = sd_event_source_set_priority(stream->event_source, SD_EVENT_PRIORITY_NORMAL+5);
578 [ # # ]: 0 : if (r < 0)
579 [ # # ]: 0 : return log_error_errno(r, "Failed to adjust stdout event source priority: %m");
580 : :
581 : 0 : stream->fd = fd;
582 : :
583 : 0 : stream->server = s;
584 [ # # # # ]: 0 : LIST_PREPEND(stdout_stream, s->stdout_streams, stream);
585 : 0 : s->n_stdout_streams++;
586 : :
587 [ # # ]: 0 : if (ret)
588 : 0 : *ret = stream;
589 : :
590 : 0 : stream = NULL;
591 : :
592 : 0 : return 0;
593 : : }
594 : :
595 : 0 : static int stdout_stream_new(sd_event_source *es, int listen_fd, uint32_t revents, void *userdata) {
596 : 0 : _cleanup_close_ int fd = -1;
597 : 0 : Server *s = userdata;
598 : : int r;
599 : :
600 [ # # ]: 0 : assert(s);
601 : :
602 [ # # ]: 0 : if (revents != EPOLLIN)
603 [ # # ]: 0 : return log_error_errno(SYNTHETIC_ERRNO(EIO),
604 : : "Got invalid event from epoll for stdout server fd: %" PRIx32,
605 : : revents);
606 : :
607 : 0 : fd = accept4(s->stdout_fd, NULL, NULL, SOCK_NONBLOCK|SOCK_CLOEXEC);
608 [ # # ]: 0 : if (fd < 0) {
609 [ # # ]: 0 : if (ERRNO_IS_ACCEPT_AGAIN(errno))
610 : 0 : return 0;
611 : :
612 [ # # ]: 0 : return log_error_errno(errno, "Failed to accept stdout connection: %m");
613 : : }
614 : :
615 [ # # ]: 0 : if (s->n_stdout_streams >= STDOUT_STREAMS_MAX) {
616 : : struct ucred u;
617 : :
618 : 0 : r = getpeercred(fd, &u);
619 : :
620 : : /* By closing fd here we make sure that the client won't wait too long for journald to
621 : : * gather all the data it adds to the error message to find out that the connection has
622 : : * just been refused.
623 : : */
624 : 0 : fd = safe_close(fd);
625 : :
626 [ # # ]: 0 : server_driver_message(s, r < 0 ? 0 : u.pid, NULL, LOG_MESSAGE("Too many stdout streams, refusing connection."), NULL);
627 : 0 : return 0;
628 : : }
629 : :
630 : 0 : r = stdout_stream_install(s, fd, NULL);
631 [ # # ]: 0 : if (r < 0)
632 : 0 : return r;
633 : :
634 : 0 : fd = -1;
635 : 0 : return 0;
636 : : }
637 : :
638 : 0 : static int stdout_stream_load(StdoutStream *stream, const char *fname) {
639 : : _cleanup_free_ char
640 : 0 : *priority = NULL,
641 : 0 : *level_prefix = NULL,
642 : 0 : *forward_to_syslog = NULL,
643 : 0 : *forward_to_kmsg = NULL,
644 : 0 : *forward_to_console = NULL,
645 : 0 : *stream_id = NULL;
646 : : int r;
647 : :
648 [ # # ]: 0 : assert(stream);
649 [ # # ]: 0 : assert(fname);
650 : :
651 [ # # ]: 0 : if (!stream->state_file) {
652 : 0 : stream->state_file = path_join("/run/systemd/journal/streams", fname);
653 [ # # ]: 0 : if (!stream->state_file)
654 : 0 : return log_oom();
655 : : }
656 : :
657 : 0 : r = parse_env_file(NULL, stream->state_file,
658 : : "PRIORITY", &priority,
659 : : "LEVEL_PREFIX", &level_prefix,
660 : : "FORWARD_TO_SYSLOG", &forward_to_syslog,
661 : : "FORWARD_TO_KMSG", &forward_to_kmsg,
662 : : "FORWARD_TO_CONSOLE", &forward_to_console,
663 : : "IDENTIFIER", &stream->identifier,
664 : : "UNIT", &stream->unit_id,
665 : : "STREAM_ID", &stream_id);
666 [ # # ]: 0 : if (r < 0)
667 [ # # ]: 0 : return log_error_errno(r, "Failed to read: %s", stream->state_file);
668 : :
669 [ # # ]: 0 : if (priority) {
670 : : int p;
671 : :
672 : 0 : p = log_level_from_string(priority);
673 [ # # ]: 0 : if (p >= 0)
674 : 0 : stream->priority = p;
675 : : }
676 : :
677 [ # # ]: 0 : if (level_prefix) {
678 : 0 : r = parse_boolean(level_prefix);
679 [ # # ]: 0 : if (r >= 0)
680 : 0 : stream->level_prefix = r;
681 : : }
682 : :
683 [ # # ]: 0 : if (forward_to_syslog) {
684 : 0 : r = parse_boolean(forward_to_syslog);
685 [ # # ]: 0 : if (r >= 0)
686 : 0 : stream->forward_to_syslog = r;
687 : : }
688 : :
689 [ # # ]: 0 : if (forward_to_kmsg) {
690 : 0 : r = parse_boolean(forward_to_kmsg);
691 [ # # ]: 0 : if (r >= 0)
692 : 0 : stream->forward_to_kmsg = r;
693 : : }
694 : :
695 [ # # ]: 0 : if (forward_to_console) {
696 : 0 : r = parse_boolean(forward_to_console);
697 [ # # ]: 0 : if (r >= 0)
698 : 0 : stream->forward_to_console = r;
699 : : }
700 : :
701 [ # # ]: 0 : if (stream_id) {
702 : : sd_id128_t id;
703 : :
704 : 0 : r = sd_id128_from_string(stream_id, &id);
705 [ # # ]: 0 : if (r >= 0)
706 [ # # ]: 0 : xsprintf(stream->id_field, "_STREAM_ID=" SD_ID128_FORMAT_STR, SD_ID128_FORMAT_VAL(id));
707 : : }
708 : :
709 : 0 : return 0;
710 : : }
711 : :
712 : 0 : static int stdout_stream_restore(Server *s, const char *fname, int fd) {
713 : : StdoutStream *stream;
714 : : int r;
715 : :
716 [ # # ]: 0 : assert(s);
717 [ # # ]: 0 : assert(fname);
718 [ # # ]: 0 : assert(fd >= 0);
719 : :
720 [ # # ]: 0 : if (s->n_stdout_streams >= STDOUT_STREAMS_MAX) {
721 [ # # ]: 0 : log_warning("Too many stdout streams, refusing restoring of stream.");
722 : 0 : return -ENOBUFS;
723 : : }
724 : :
725 : 0 : r = stdout_stream_install(s, fd, &stream);
726 [ # # ]: 0 : if (r < 0)
727 : 0 : return r;
728 : :
729 : 0 : stream->state = STDOUT_STREAM_RUNNING;
730 : 0 : stream->fdstore = true;
731 : :
732 : : /* Ignore all parsing errors */
733 : 0 : (void) stdout_stream_load(stream, fname);
734 : :
735 : 0 : return 0;
736 : : }
737 : :
738 : 0 : int server_restore_streams(Server *s, FDSet *fds) {
739 : 0 : _cleanup_closedir_ DIR *d = NULL;
740 : : struct dirent *de;
741 : : int r;
742 : :
743 : 0 : d = opendir("/run/systemd/journal/streams");
744 [ # # ]: 0 : if (!d) {
745 [ # # ]: 0 : if (errno == ENOENT)
746 : 0 : return 0;
747 : :
748 [ # # ]: 0 : return log_warning_errno(errno, "Failed to enumerate /run/systemd/journal/streams: %m");
749 : : }
750 : :
751 [ # # # # : 0 : FOREACH_DIRENT(de, d, goto fail) {
# # ]
752 : : unsigned long st_dev, st_ino;
753 : 0 : bool found = false;
754 : : Iterator i;
755 : : int fd;
756 : :
757 [ # # ]: 0 : if (sscanf(de->d_name, "%lu:%lu", &st_dev, &st_ino) != 2)
758 : 0 : continue;
759 : :
760 [ # # ]: 0 : FDSET_FOREACH(fd, fds, i) {
761 : : struct stat st;
762 : :
763 [ # # ]: 0 : if (fstat(fd, &st) < 0)
764 [ # # ]: 0 : return log_error_errno(errno, "Failed to stat %s: %m", de->d_name);
765 : :
766 [ # # # # : 0 : if (S_ISSOCK(st.st_mode) && st.st_dev == st_dev && st.st_ino == st_ino) {
# # ]
767 : 0 : found = true;
768 : 0 : break;
769 : : }
770 : : }
771 : :
772 [ # # ]: 0 : if (!found) {
773 : : /* No file descriptor? Then let's delete the state file */
774 [ # # ]: 0 : log_debug("Cannot restore stream file %s", de->d_name);
775 [ # # ]: 0 : if (unlinkat(dirfd(d), de->d_name, 0) < 0)
776 [ # # ]: 0 : log_warning_errno(errno, "Failed to remove /run/systemd/journal/streams/%s: %m",
777 : : de->d_name);
778 : 0 : continue;
779 : : }
780 : :
781 : 0 : fdset_remove(fds, fd);
782 : :
783 : 0 : r = stdout_stream_restore(s, de->d_name, fd);
784 [ # # ]: 0 : if (r < 0)
785 : 0 : safe_close(fd);
786 : : }
787 : :
788 : 0 : return 0;
789 : :
790 : 0 : fail:
791 [ # # ]: 0 : return log_error_errno(errno, "Failed to read streams directory: %m");
792 : : }
793 : :
794 : 0 : int server_open_stdout_socket(Server *s) {
795 : : static const union sockaddr_union sa = {
796 : : .un.sun_family = AF_UNIX,
797 : : .un.sun_path = "/run/systemd/journal/stdout",
798 : : };
799 : : int r;
800 : :
801 [ # # ]: 0 : assert(s);
802 : :
803 [ # # ]: 0 : if (s->stdout_fd < 0) {
804 : 0 : s->stdout_fd = socket(AF_UNIX, SOCK_STREAM|SOCK_CLOEXEC|SOCK_NONBLOCK, 0);
805 [ # # ]: 0 : if (s->stdout_fd < 0)
806 [ # # ]: 0 : return log_error_errno(errno, "socket() failed: %m");
807 : :
808 : 0 : (void) sockaddr_un_unlink(&sa.un);
809 : :
810 [ # # # # ]: 0 : r = bind(s->stdout_fd, &sa.sa, SOCKADDR_UN_LEN(sa.un));
811 [ # # ]: 0 : if (r < 0)
812 [ # # ]: 0 : return log_error_errno(errno, "bind(%s) failed: %m", sa.un.sun_path);
813 : :
814 : 0 : (void) chmod(sa.un.sun_path, 0666);
815 : :
816 [ # # ]: 0 : if (listen(s->stdout_fd, SOMAXCONN) < 0)
817 [ # # ]: 0 : return log_error_errno(errno, "listen(%s) failed: %m", sa.un.sun_path);
818 : : } else
819 : 0 : (void) fd_nonblock(s->stdout_fd, true);
820 : :
821 : 0 : r = sd_event_add_io(s->event, &s->stdout_event_source, s->stdout_fd, EPOLLIN, stdout_stream_new, s);
822 [ # # ]: 0 : if (r < 0)
823 [ # # ]: 0 : return log_error_errno(r, "Failed to add stdout server fd to event source: %m");
824 : :
825 : 0 : r = sd_event_source_set_priority(s->stdout_event_source, SD_EVENT_PRIORITY_NORMAL+5);
826 [ # # ]: 0 : if (r < 0)
827 [ # # ]: 0 : return log_error_errno(r, "Failed to adjust priority of stdout server event source: %m");
828 : :
829 : 0 : return 0;
830 : : }
831 : :
832 : 0 : void stdout_stream_send_notify(StdoutStream *s) {
833 : 0 : struct iovec iovec = {
834 : : .iov_base = (char*) "FDSTORE=1",
835 : : .iov_len = STRLEN("FDSTORE=1"),
836 : : };
837 : 0 : struct msghdr msghdr = {
838 : : .msg_iov = &iovec,
839 : : .msg_iovlen = 1,
840 : : };
841 : : struct cmsghdr *cmsg;
842 : : ssize_t l;
843 : :
844 [ # # ]: 0 : assert(s);
845 [ # # ]: 0 : assert(!s->fdstore);
846 [ # # ]: 0 : assert(s->in_notify_queue);
847 [ # # ]: 0 : assert(s->server);
848 [ # # ]: 0 : assert(s->server->notify_fd >= 0);
849 : :
850 : : /* Store the connection fd in PID 1, so that we get it passed
851 : : * in again on next start */
852 : :
853 : 0 : msghdr.msg_controllen = CMSG_SPACE(sizeof(int));
854 [ # # ]: 0 : msghdr.msg_control = alloca0(msghdr.msg_controllen);
855 : :
856 [ # # ]: 0 : cmsg = CMSG_FIRSTHDR(&msghdr);
857 : 0 : cmsg->cmsg_level = SOL_SOCKET;
858 : 0 : cmsg->cmsg_type = SCM_RIGHTS;
859 : 0 : cmsg->cmsg_len = CMSG_LEN(sizeof(int));
860 : :
861 : 0 : memcpy(CMSG_DATA(cmsg), &s->fd, sizeof(int));
862 : :
863 : 0 : l = sendmsg(s->server->notify_fd, &msghdr, MSG_DONTWAIT|MSG_NOSIGNAL);
864 [ # # ]: 0 : if (l < 0) {
865 [ # # ]: 0 : if (errno == EAGAIN)
866 : 0 : return;
867 : :
868 [ # # ]: 0 : log_error_errno(errno, "Failed to send stream file descriptor to service manager: %m");
869 : : } else {
870 [ # # ]: 0 : log_debug("Successfully sent stream file descriptor to service manager.");
871 : 0 : s->fdstore = 1;
872 : : }
873 : :
874 [ # # # # : 0 : LIST_REMOVE(stdout_stream_notify_queue, s->server->stdout_streams_notify_queue, s);
# # # # ]
875 : 0 : s->in_notify_queue = false;
876 : :
877 : : }
|
