src/journal/journald-syslog.c

	journald-syslog.c revision 8531ae707d4d0203e83304d4af948b8169a5fce1
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering/*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering/***
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering  This file is part of systemd.
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering  Copyright 2011 Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering  systemd is free software; you can redistribute it and/or modify it
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering  under the terms of the GNU Lesser General Public License as published by
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering  the Free Software Foundation; either version 2.1 of the License, or
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering  (at your option) any later version.
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering  systemd is distributed in the hope that it will be useful, but
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering  WITHOUT ANY WARRANTY; without even the implied warranty of
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering  Lesser General Public License for more details.
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering  You should have received a copy of the GNU Lesser General Public License
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering  along with systemd; If not, see <http://www.gnu.org/licenses/>.
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering***/
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering#include <unistd.h>
4871690d9e32608bbd9b18505b5326c2079c9690Allin Cottrell#include <stddef.h>
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering#include <sys/epoll.h>
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering#include "systemd/sd-messages.h"
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering#include "socket-util.h"
d682b3a7e7c7c2941a4d3e193f1e330dbc9fae89Lennart Poettering#include "selinux-util.h"
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek#include "journald-server.h"
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering#include "journald-syslog.h"
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering#include "journald-kmsg.h"
3b7124a8db56ed57525b9ecfd19cfdc8c9facba0Lennart Poettering#include "journald-console.h"
40b71e89bae4e51768db4dc50ec64c1e9c96eec4Sebastian Thorarensen#include "journald-wall.h"
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering/* Warn once every 30s if we missed syslog message */
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering#define WARN_FORWARD_SYSLOG_MISSED_USEC (30 * USEC_PER_SEC)
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering
3b3154df7e2773332bb814e167187367a0ccae4aLennart Poetteringstatic void forward_syslog_iovec(Server *s, const struct iovec *iovec, unsigned n_iovec, const struct ucred *ucred, const struct timeval *tv) {
b92bea5d2a9481de69bb627a7b442a9f58fca43dZbigniew Jędrzejewski-Szmek
46b131574fdd7d77c15a0919ca9010cad7aa6ac7Lennart Poettering        static const union sockaddr_union sa = {
b92bea5d2a9481de69bb627a7b442a9f58fca43dZbigniew Jędrzejewski-Szmek                .un.sun_family = AF_UNIX,
b92bea5d2a9481de69bb627a7b442a9f58fca43dZbigniew Jędrzejewski-Szmek                .un.sun_path = "/run/systemd/journal/syslog",
b92bea5d2a9481de69bb627a7b442a9f58fca43dZbigniew Jędrzejewski-Szmek        };
b92bea5d2a9481de69bb627a7b442a9f58fca43dZbigniew Jędrzejewski-Szmek        struct msghdr msghdr = {
b92bea5d2a9481de69bb627a7b442a9f58fca43dZbigniew Jędrzejewski-Szmek                .msg_iov = (struct iovec *) iovec,
b92bea5d2a9481de69bb627a7b442a9f58fca43dZbigniew Jędrzejewski-Szmek                .msg_iovlen = n_iovec,
46b131574fdd7d77c15a0919ca9010cad7aa6ac7Lennart Poettering                .msg_name = (struct sockaddr*) &sa.sa,
b92bea5d2a9481de69bb627a7b442a9f58fca43dZbigniew Jędrzejewski-Szmek                .msg_namelen = offsetof(union sockaddr_union, un.sun_path)
f8294e4175918117ca6c131720bcf287eadcd029Josh Triplett                               + strlen("/run/systemd/journal/syslog"),
b92bea5d2a9481de69bb627a7b442a9f58fca43dZbigniew Jędrzejewski-Szmek        };
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        struct cmsghdr *cmsg;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        union {
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                struct cmsghdr cmsghdr;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                uint8_t buf[CMSG_SPACE(sizeof(struct ucred))];
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        } control;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        assert(s);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        assert(iovec);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        assert(n_iovec > 0);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (ucred) {
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                zero(control);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                msghdr.msg_control = &control;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                msghdr.msg_controllen = sizeof(control);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                cmsg = CMSG_FIRSTHDR(&msghdr);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                cmsg->cmsg_level = SOL_SOCKET;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                cmsg->cmsg_type = SCM_CREDENTIALS;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                cmsg->cmsg_len = CMSG_LEN(sizeof(struct ucred));
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                memcpy(CMSG_DATA(cmsg), ucred, sizeof(struct ucred));
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                msghdr.msg_controllen = cmsg->cmsg_len;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        }
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        /* Forward the syslog message we received via /dev/log to
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering         * /run/systemd/syslog. Unfortunately we currently can't set
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering         * the SO_TIMESTAMP auxiliary data, and hence we don't. */
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (sendmsg(s->syslog_fd, &msghdr, MSG_NOSIGNAL) >= 0)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                return;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        /* The socket is full? I guess the syslog implementation is
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering         * too slow, and we shouldn't wait for that... */
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering        if (errno == EAGAIN) {
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering                s->n_forward_syslog_missed++;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                return;
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering        }
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (ucred && errno == ESRCH) {
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                struct ucred u;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                /* Hmm, presumably the sender process vanished
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                 * by now, so let's fix it as good as we
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                 * can, and retry */
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                u = *ucred;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                u.pid = getpid();
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                memcpy(CMSG_DATA(cmsg), &u, sizeof(struct ucred));
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                if (sendmsg(s->syslog_fd, &msghdr, MSG_NOSIGNAL) >= 0)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                        return;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering                if (errno == EAGAIN) {
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering                        s->n_forward_syslog_missed++;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                        return;
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering                }
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        }
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (errno != ENOENT)
56f64d95763a799ba4475daf44d8e9f72a1bd474Michal Schmidt                log_debug_errno(errno, "Failed to forward syslog message: %m");
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering}
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
3b3154df7e2773332bb814e167187367a0ccae4aLennart Poetteringstatic void forward_syslog_raw(Server *s, int priority, const char *buffer, const struct ucred *ucred, const struct timeval *tv) {
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        struct iovec iovec;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        assert(s);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        assert(buffer);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (LOG_PRI(priority) > s->max_level_syslog)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                return;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        IOVEC_SET_STRING(iovec, buffer);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        forward_syslog_iovec(s, &iovec, 1, ucred, tv);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering}
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
3b3154df7e2773332bb814e167187367a0ccae4aLennart Poetteringvoid server_forward_syslog(Server *s, int priority, const char *identifier, const char *message, const struct ucred *ucred, const struct timeval *tv) {
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        struct iovec iovec[5];
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        char header_priority[6], header_time[64], header_pid[16];
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        int n = 0;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        time_t t;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        struct tm *tm;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        char *ident_buf = NULL;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        assert(s);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        assert(priority >= 0);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        assert(priority <= 999);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        assert(message);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (LOG_PRI(priority) > s->max_level_syslog)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                return;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        /* First: priority field */
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        snprintf(header_priority, sizeof(header_priority), "<%i>", priority);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        char_array_0(header_priority);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        IOVEC_SET_STRING(iovec[n++], header_priority);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        /* Second: timestamp */
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        t = tv ? tv->tv_sec : ((time_t) (now(CLOCK_REALTIME) / USEC_PER_SEC));
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        tm = localtime(&t);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (!tm)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                return;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (strftime(header_time, sizeof(header_time), "%h %e %T ", tm) <= 0)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                return;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        IOVEC_SET_STRING(iovec[n++], header_time);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        /* Third: identifier and PID */
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (ucred) {
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                if (!identifier) {
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                        get_process_comm(ucred->pid, &ident_buf);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                        identifier = ident_buf;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                }
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
de0671ee7fe465e108f62dcbbbe9366f81dd9e9aZbigniew Jędrzejewski-Szmek                snprintf(header_pid, sizeof(header_pid), "["PID_FMT"]: ", ucred->pid);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                char_array_0(header_pid);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                if (identifier)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                        IOVEC_SET_STRING(iovec[n++], identifier);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                IOVEC_SET_STRING(iovec[n++], header_pid);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        } else if (identifier) {
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                IOVEC_SET_STRING(iovec[n++], identifier);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                IOVEC_SET_STRING(iovec[n++], ": ");
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        }
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        /* Fourth: message */
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        IOVEC_SET_STRING(iovec[n++], message);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        forward_syslog_iovec(s, iovec, n, ucred, tv);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        free(ident_buf);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering}
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poetteringint syslog_fixup_facility(int priority) {
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if ((priority & LOG_FACMASK) == 0)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                return (priority & LOG_PRIMASK) | LOG_USER;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        return priority;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering}
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
e88baee88fad8bc59d33b55a7a2d640ef9e16cd6Zbigniew Jędrzejewski-Szmeksize_t syslog_parse_identifier(const char **buf, char **identifier, char **pid) {
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        const char *p;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        char *t;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        size_t l, e;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        assert(buf);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        assert(identifier);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        assert(pid);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        p = *buf;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        p += strspn(p, WHITESPACE);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        l = strcspn(p, WHITESPACE);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (l <= 0 ||
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering            p[l-1] != ':')
e88baee88fad8bc59d33b55a7a2d640ef9e16cd6Zbigniew Jędrzejewski-Szmek                return 0;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        e = l;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        l--;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (p[l-1] == ']') {
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                size_t k = l-1;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                for (;;) {
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                        if (p[k] == '[') {
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                                t = strndup(p+k+1, l-k-2);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                                if (t)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                                        *pid = t;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                                l = k;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                                break;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                        }
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                        if (k == 0)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                                break;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                        k--;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                }
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        }
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        t = strndup(p, l);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (t)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                *identifier = t;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
e88baee88fad8bc59d33b55a7a2d640ef9e16cd6Zbigniew Jędrzejewski-Szmek        e += strspn(p + e, WHITESPACE);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        *buf = p + e;
e88baee88fad8bc59d33b55a7a2d640ef9e16cd6Zbigniew Jędrzejewski-Szmek        return e;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering}
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
e3bfb7be07d9b1f4ebb12eb22c4c8bcd2a988d51Zbigniew Jędrzejewski-Szmekvoid syslog_parse_priority(const char **p, int *priority, bool with_facility) {
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        int a = 0, b = 0, c = 0;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        int k;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        assert(p);
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        assert(*p);
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        assert(priority);
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        if ((*p)[0] != '<')
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                return;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        if (!strchr(*p, '>'))
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                return;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        if ((*p)[2] == '>') {
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                c = undecchar((*p)[1]);
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                k = 3;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        } else if ((*p)[3] == '>') {
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                b = undecchar((*p)[1]);
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                c = undecchar((*p)[2]);
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                k = 4;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        } else if ((*p)[4] == '>') {
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                a = undecchar((*p)[1]);
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                b = undecchar((*p)[2]);
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                c = undecchar((*p)[3]);
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                k = 5;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        } else
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                return;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
ac50788b0f5aeee09e7d45db28ae8ab7f39cd52eZbigniew Jędrzejewski-Szmek        if (a < 0 || b < 0 || c < 0 ||
ac50788b0f5aeee09e7d45db28ae8ab7f39cd52eZbigniew Jędrzejewski-Szmek            (!with_facility && (a || b || c > 7)))
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                return;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
ac50788b0f5aeee09e7d45db28ae8ab7f39cd52eZbigniew Jędrzejewski-Szmek        if (with_facility)
ac50788b0f5aeee09e7d45db28ae8ab7f39cd52eZbigniew Jędrzejewski-Szmek                *priority = a*100 + b*10 + c;
ac50788b0f5aeee09e7d45db28ae8ab7f39cd52eZbigniew Jędrzejewski-Szmek        else
ac50788b0f5aeee09e7d45db28ae8ab7f39cd52eZbigniew Jędrzejewski-Szmek                *priority = (*priority & LOG_FACMASK) | c;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        *p += k;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering}
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poetteringstatic void syslog_skip_date(char **buf) {
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        enum {
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                LETTER,
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                SPACE,
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                NUMBER,
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                SPACE_OR_NUMBER,
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                COLON
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        } sequence[] = {
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                LETTER, LETTER, LETTER,
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                SPACE,
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                SPACE_OR_NUMBER, NUMBER,
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                SPACE,
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                SPACE_OR_NUMBER, NUMBER,
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                COLON,
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                SPACE_OR_NUMBER, NUMBER,
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                COLON,
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                SPACE_OR_NUMBER, NUMBER,
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                SPACE
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        };
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        char *p;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        unsigned i;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        assert(buf);
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        assert(*buf);
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        p = *buf;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        for (i = 0; i < ELEMENTSOF(sequence); i++, p++) {
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                if (!*p)
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                        return;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                switch (sequence[i]) {
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                case SPACE:
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                        if (*p != ' ')
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                                return;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                        break;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                case SPACE_OR_NUMBER:
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                        if (*p == ' ')
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                                break;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                        /* fall through */
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                case NUMBER:
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                        if (*p < '0' || *p > '9')
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                                return;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                        break;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                case LETTER:
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                        if (!(*p >= 'A' && *p <= 'Z') &&
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                            !(*p >= 'a' && *p <= 'z'))
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                                return;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                        break;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                case COLON:
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                        if (*p != ':')
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                                return;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                        break;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering                }
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        }
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        *buf = p;
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering}
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poetteringvoid server_process_syslog_message(
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        Server *s,
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        const char *buf,
3b3154df7e2773332bb814e167187367a0ccae4aLennart Poettering        const struct ucred *ucred,
3b3154df7e2773332bb814e167187367a0ccae4aLennart Poettering        const struct timeval *tv,
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        const char *label,
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        size_t label_len) {
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
8457f8d6ac7adc6c6ef31378e6e7761cce522141Lennart Poettering        char syslog_priority[sizeof("PRIORITY=") + DECIMAL_STR_MAX(int)],
8457f8d6ac7adc6c6ef31378e6e7761cce522141Lennart Poettering             syslog_facility[sizeof("SYSLOG_FACILITY") + DECIMAL_STR_MAX(int)];
8457f8d6ac7adc6c6ef31378e6e7761cce522141Lennart Poettering        const char *message = NULL, *syslog_identifier = NULL, *syslog_pid = NULL;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        struct iovec iovec[N_IOVEC_META_FIELDS + 6];
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        unsigned n = 0;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        int priority = LOG_USER | LOG_INFO;
8457f8d6ac7adc6c6ef31378e6e7761cce522141Lennart Poettering        _cleanup_free_ char *identifier = NULL, *pid = NULL;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        const char *orig;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        assert(s);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        assert(buf);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        orig = buf;
e3bfb7be07d9b1f4ebb12eb22c4c8bcd2a988d51Zbigniew Jędrzejewski-Szmek        syslog_parse_priority(&buf, &priority, true);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (s->forward_to_syslog)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                forward_syslog_raw(s, priority, orig, ucred, tv);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        syslog_skip_date((char**) &buf);
5809560d858f45351856d6fe786a8117306dd0f2Lennart Poettering        syslog_parse_identifier(&buf, &identifier, &pid);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (s->forward_to_kmsg)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                server_forward_kmsg(s, priority, identifier, buf, ucred);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (s->forward_to_console)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                server_forward_console(s, priority, identifier, buf, ucred);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
40b71e89bae4e51768db4dc50ec64c1e9c96eec4Sebastian Thorarensen        if (s->forward_to_wall)
40b71e89bae4e51768db4dc50ec64c1e9c96eec4Sebastian Thorarensen                server_forward_wall(s, priority, identifier, buf, ucred);
40b71e89bae4e51768db4dc50ec64c1e9c96eec4Sebastian Thorarensen
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        IOVEC_SET_STRING(iovec[n++], "_TRANSPORT=syslog");
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
8457f8d6ac7adc6c6ef31378e6e7761cce522141Lennart Poettering        sprintf(syslog_priority, "PRIORITY=%i", priority & LOG_PRIMASK);
8457f8d6ac7adc6c6ef31378e6e7761cce522141Lennart Poettering        IOVEC_SET_STRING(iovec[n++], syslog_priority);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
8457f8d6ac7adc6c6ef31378e6e7761cce522141Lennart Poettering        if (priority & LOG_FACMASK) {
8457f8d6ac7adc6c6ef31378e6e7761cce522141Lennart Poettering                sprintf(syslog_facility, "SYSLOG_FACILITY=%i", LOG_FAC(priority));
8457f8d6ac7adc6c6ef31378e6e7761cce522141Lennart Poettering                IOVEC_SET_STRING(iovec[n++], syslog_facility);
8457f8d6ac7adc6c6ef31378e6e7761cce522141Lennart Poettering        }
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (identifier) {
8457f8d6ac7adc6c6ef31378e6e7761cce522141Lennart Poettering                syslog_identifier = strappenda("SYSLOG_IDENTIFIER=", identifier);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                if (syslog_identifier)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                        IOVEC_SET_STRING(iovec[n++], syslog_identifier);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        }
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (pid) {
8457f8d6ac7adc6c6ef31378e6e7761cce522141Lennart Poettering                syslog_pid = strappenda("SYSLOG_PID=", pid);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                if (syslog_pid)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                        IOVEC_SET_STRING(iovec[n++], syslog_pid);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        }
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
8457f8d6ac7adc6c6ef31378e6e7761cce522141Lennart Poettering        message = strappenda("MESSAGE=", buf);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (message)
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                IOVEC_SET_STRING(iovec[n++], message);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek        server_dispatch_message(s, iovec, n, ELEMENTSOF(iovec), ucred, tv, label, label_len, NULL, priority, 0);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering}
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poetteringint server_open_syslog_socket(Server *s) {
3b3154df7e2773332bb814e167187367a0ccae4aLennart Poettering        static const int one = 1;
3b3154df7e2773332bb814e167187367a0ccae4aLennart Poettering        int r;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        assert(s);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        if (s->syslog_fd < 0) {
46b131574fdd7d77c15a0919ca9010cad7aa6ac7Lennart Poettering                static const union sockaddr_union sa = {
b92bea5d2a9481de69bb627a7b442a9f58fca43dZbigniew Jędrzejewski-Szmek                        .un.sun_family = AF_UNIX,
03ee5c38cb0da193dd08733fb4c0c2809cee6a99Lennart Poettering                        .un.sun_path = "/run/systemd/journal/dev-log",
b92bea5d2a9481de69bb627a7b442a9f58fca43dZbigniew Jędrzejewski-Szmek                };
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                s->syslog_fd = socket(AF_UNIX, SOCK_DGRAM|SOCK_CLOEXEC|SOCK_NONBLOCK, 0);
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt                if (s->syslog_fd < 0)
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt                        return log_error_errno(errno, "socket() failed: %m");
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                unlink(sa.un.sun_path);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                r = bind(s->syslog_fd, &sa.sa, offsetof(union sockaddr_union, un.sun_path) + strlen(sa.un.sun_path));
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt                if (r < 0)
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt                        return log_error_errno(errno, "bind(%s) failed: %m", sa.un.sun_path);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                chmod(sa.un.sun_path, 0666);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        } else
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering                fd_nonblock(s->syslog_fd, 1);
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        r = setsockopt(s->syslog_fd, SOL_SOCKET, SO_PASSCRED, &one, sizeof(one));
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt        if (r < 0)
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt                return log_error_errno(errno, "SO_PASSCRED failed: %m");
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering#ifdef HAVE_SELINUX
6baa7db00812437bbc87e73faa1a11b6cf631958Lennart Poettering        if (mac_selinux_use()) {
d682b3a7e7c7c2941a4d3e193f1e330dbc9fae89Lennart Poettering                r = setsockopt(s->syslog_fd, SOL_SOCKET, SO_PASSSEC, &one, sizeof(one));
d682b3a7e7c7c2941a4d3e193f1e330dbc9fae89Lennart Poettering                if (r < 0)
56f64d95763a799ba4475daf44d8e9f72a1bd474Michal Schmidt                        log_warning_errno(errno, "SO_PASSSEC failed: %m");
d682b3a7e7c7c2941a4d3e193f1e330dbc9fae89Lennart Poettering        }
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering#endif
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        r = setsockopt(s->syslog_fd, SOL_SOCKET, SO_TIMESTAMP, &one, sizeof(one));
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt        if (r < 0)
4a62c710b62a5a3c7a8a278b810b9d5b5a0c8f4fMichal Schmidt                return log_error_errno(errno, "SO_TIMESTAMP failed: %m");
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
8531ae707d4d0203e83304d4af948b8169a5fce1Lennart Poettering        r = sd_event_add_io(s->event, &s->syslog_event_source, s->syslog_fd, EPOLLIN, server_process_datagram, s);
23bbb0de4e3f85d9704a5c12a5afa2dfa0159e41Michal Schmidt        if (r < 0)
23bbb0de4e3f85d9704a5c12a5afa2dfa0159e41Michal Schmidt                return log_error_errno(r, "Failed to add syslog server fd to event loop: %m");
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering        return 0;
35e2e347d38cc2f8bd7c38a0d8a5129f5fbb0ab9Lennart Poettering}
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering
178cc7700c23ac088cd7190d7854282075028d91Lennart Poetteringvoid server_maybe_warn_forward_syslog_missed(Server *s) {
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering        usec_t n;
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering        assert(s);
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering        if (s->n_forward_syslog_missed <= 0)
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering                return;
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering        n = now(CLOCK_MONOTONIC);
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering        if (s->last_warn_forward_syslog_missed + WARN_FORWARD_SYSLOG_MISSED_USEC > n)
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering                return;
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering        server_driver_message(s, SD_MESSAGE_FORWARD_SYSLOG_MISSED, "Forwarding to syslog missed %u messages.", s->n_forward_syslog_missed);
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering        s->n_forward_syslog_missed = 0;
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering        s->last_warn_forward_syslog_missed = n;
178cc7700c23ac088cd7190d7854282075028d91Lennart Poettering}