execute: talk directly to the journald, instead to the stdout-syslog-bridge
This commit is contained in:
parent
33eb8abfa5
commit
54fe0cdbe3
|
@ -173,24 +173,23 @@ static int open_null_as(int flags, int nfd) {
|
|||
|
||||
static int connect_logger_as(const ExecContext *context, ExecOutput output, const char *ident, int nfd) {
|
||||
int fd, r;
|
||||
union {
|
||||
struct sockaddr sa;
|
||||
struct sockaddr_un un;
|
||||
} sa;
|
||||
union sockaddr_union sa;
|
||||
|
||||
assert(context);
|
||||
assert(output < _EXEC_OUTPUT_MAX);
|
||||
assert(ident);
|
||||
assert(nfd >= 0);
|
||||
|
||||
if ((fd = socket(AF_UNIX, SOCK_STREAM, 0)) < 0)
|
||||
fd = socket(AF_UNIX, SOCK_STREAM, 0);
|
||||
if (fd < 0)
|
||||
return -errno;
|
||||
|
||||
zero(sa);
|
||||
sa.sa.sa_family = AF_UNIX;
|
||||
strncpy(sa.un.sun_path, STDOUT_SYSLOG_BRIDGE_SOCKET, sizeof(sa.un.sun_path));
|
||||
sa.un.sun_family = AF_UNIX;
|
||||
strncpy(sa.un.sun_path, "/run/systemd/journal/stdout", sizeof(sa.un.sun_path));
|
||||
|
||||
if (connect(fd, &sa.sa, offsetof(struct sockaddr_un, sun_path) + sizeof(STDOUT_SYSLOG_BRIDGE_SOCKET) - 1) < 0) {
|
||||
r = connect(fd, &sa.sa, offsetof(struct sockaddr_un, sun_path) + strlen(sa.un.sun_path));
|
||||
if (r < 0) {
|
||||
close_nointr_nofail(fd);
|
||||
return -errno;
|
||||
}
|
||||
|
@ -200,26 +199,19 @@ static int connect_logger_as(const ExecContext *context, ExecOutput output, cons
|
|||
return -errno;
|
||||
}
|
||||
|
||||
/* We speak a very simple protocol between log server
|
||||
* and client: one line for the log destination (kmsg
|
||||
* or syslog), followed by the priority field,
|
||||
* followed by the process name. Since we replaced
|
||||
* stdin/stderr we simple use stdio to write to
|
||||
* it. Note that we use stderr, to minimize buffer
|
||||
* flushing issues. */
|
||||
|
||||
dprintf(fd,
|
||||
"%s\n"
|
||||
"%i\n"
|
||||
"%s\n"
|
||||
"%i\n"
|
||||
"%i\n"
|
||||
"%i\n"
|
||||
"%i\n",
|
||||
output == EXEC_OUTPUT_KMSG ? "kmsg" :
|
||||
output == EXEC_OUTPUT_KMSG_AND_CONSOLE ? "kmsg+console" :
|
||||
output == EXEC_OUTPUT_SYSLOG ? "syslog" :
|
||||
"syslog+console",
|
||||
context->syslog_priority,
|
||||
context->syslog_identifier ? context->syslog_identifier : ident,
|
||||
context->syslog_level_prefix);
|
||||
context->syslog_priority,
|
||||
!!context->syslog_level_prefix,
|
||||
output == EXEC_OUTPUT_SYSLOG || output == EXEC_OUTPUT_SYSLOG_AND_CONSOLE,
|
||||
output == EXEC_OUTPUT_KMSG || output == EXEC_OUTPUT_KMSG_AND_CONSOLE,
|
||||
output == EXEC_OUTPUT_SYSLOG_AND_CONSOLE || output == EXEC_OUTPUT_KMSG_AND_CONSOLE);
|
||||
|
||||
if (fd != nfd) {
|
||||
r = dup2(fd, nfd) < 0 ? -errno : nfd;
|
||||
|
|
|
@ -40,8 +40,6 @@ struct CGroupAttribute;
|
|||
#include "list.h"
|
||||
#include "util.h"
|
||||
|
||||
#define STDOUT_SYSLOG_BRIDGE_SOCKET "/run/systemd/stdout-syslog-bridge"
|
||||
|
||||
typedef enum KillMode {
|
||||
KILL_CONTROL_GROUP = 0,
|
||||
KILL_PROCESS,
|
||||
|
|
|
@ -70,7 +70,7 @@
|
|||
/* Services systemd relies on */
|
||||
#define SPECIAL_DBUS_SERVICE "dbus.service"
|
||||
#define SPECIAL_DBUS_SOCKET "dbus.socket"
|
||||
#define SPECIAL_STDOUT_SYSLOG_BRIDGE_SOCKET "systemd-stdout-syslog-bridge.socket"
|
||||
#define SPECIAL_JOURNALD_SOCKET "journald.socket"
|
||||
#define SPECIAL_SYSLOG_SOCKET "syslog.socket"
|
||||
|
||||
/* Magic init signals */
|
||||
|
|
|
@ -573,7 +573,7 @@ int unit_add_exec_dependencies(Unit *u, ExecContext *c) {
|
|||
* logging daemon is run first. */
|
||||
|
||||
if (u->meta.manager->running_as == MANAGER_SYSTEM)
|
||||
if ((r = unit_add_two_dependencies_by_name(u, UNIT_REQUIRES, UNIT_AFTER, SPECIAL_STDOUT_SYSLOG_BRIDGE_SOCKET, NULL, true)) < 0)
|
||||
if ((r = unit_add_two_dependencies_by_name(u, UNIT_REQUIRES, UNIT_AFTER, SPECIAL_JOURNALD_SOCKET, NULL, true)) < 0)
|
||||
return r;
|
||||
|
||||
return 0;
|
||||
|
|
Loading…
Reference in New Issue