1 /*-*- Mode: C; c-basic-offset: 8 -*-*/
4 This file is part of systemd.
6 Copyright 2010 Lennart Poettering
8 systemd is free software; you can redistribute it and/or modify it
9 under the terms of the GNU General Public License as published by
10 the Free Software Foundation; either version 2 of the License, or
11 (at your option) any later version.
13 systemd is distributed in the hope that it will be useful, but
14 WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16 General Public License for more details.
18 You should have received a copy of the GNU General Public License
19 along with systemd; If not, see <http://www.gnu.org/licenses/>.
27 #include <sys/socket.h>
34 #define SYSLOG_TIMEOUT_USEC (5*USEC_PER_SEC)
35 #define LOG_BUFFER_MAX 1024
37 static LogTarget log_target = LOG_TARGET_CONSOLE;
38 static int log_max_level = LOG_DEBUG;
40 static int console_fd = STDERR_FILENO;
41 static int syslog_fd = -1;
42 static int kmsg_fd = -1;
44 /* Akin to glibc's __abort_msg; which is private and we hance cannot
46 static char *log_abort_msg = NULL;
48 void log_close_console(void) {
53 if (getpid() == 1 || console_fd != STDERR_FILENO) {
54 close_nointr_nofail(console_fd);
59 static int log_open_console(void) {
66 if ((console_fd = open_terminal("/dev/console", O_WRONLY|O_NOCTTY|O_CLOEXEC)) < 0) {
67 log_error("Failed to open /dev/console for logging: %s", strerror(-console_fd));
71 log_info("Succesfully opened /dev/console for logging.");
73 console_fd = STDERR_FILENO;
78 void log_close_kmsg(void) {
83 close_nointr_nofail(kmsg_fd);
87 static int log_open_kmsg(void) {
92 if ((kmsg_fd = open("/dev/kmsg", O_WRONLY|O_NOCTTY|O_CLOEXEC)) < 0) {
93 log_info("Failed to open /dev/kmsg for logging: %s", strerror(errno));
97 log_info("Succesfully opened /dev/kmsg for logging.");
102 void log_close_syslog(void) {
107 close_nointr_nofail(syslog_fd);
111 static int log_open_syslog(void) {
114 struct sockaddr_un un;
122 if ((syslog_fd = socket(AF_UNIX, SOCK_DGRAM|SOCK_CLOEXEC, 0)) < 0) {
127 /* Make sure we don't block for more than 5s when talking to
129 timeval_store(&tv, SYSLOG_TIMEOUT_USEC);
130 if (setsockopt(syslog_fd, SOL_SOCKET, SO_SNDTIMEO, &tv, sizeof(tv)) < 0) {
136 sa.un.sun_family = AF_UNIX;
137 strncpy(sa.un.sun_path, "/dev/log", sizeof(sa.un.sun_path));
139 if (connect(syslog_fd, &sa.sa, sizeof(sa)) < 0) {
144 log_info("Succesfully opened syslog for logging.");
150 log_info("Failed to open syslog for logging: %s", strerror(-r));
157 /* If we don't use the console we close it here, to not get
158 * killed by SAK. If we don't use syslog we close it here so
159 * that we are not confused by somebody deleting the socket in
160 * the fs. If we don't use /dev/kmsg we still keep it open,
161 * because there is no reason to close it. */
163 if (log_target == LOG_TARGET_SYSLOG_OR_KMSG ||
164 log_target == LOG_TARGET_SYSLOG)
165 if ((r = log_open_syslog()) >= 0) {
170 if (log_target == LOG_TARGET_SYSLOG_OR_KMSG ||
171 log_target == LOG_TARGET_KMSG)
172 if ((r = log_open_kmsg()) >= 0) {
179 return log_open_console();
182 void log_set_target(LogTarget target) {
184 assert(target < _LOG_TARGET_MAX);
189 void log_set_max_level(int level) {
190 assert((level & LOG_PRIMASK) == level);
192 log_max_level = level;
195 static int write_to_console(
200 const char *buffer) {
203 struct iovec iovec[5];
210 snprintf(location, sizeof(location), "(%s:%u) ", file, line);
211 char_array_0(location);
213 highlight = LOG_PRI(level) <= LOG_ERR;
216 IOVEC_SET_STRING(iovec[n++], location);
218 IOVEC_SET_STRING(iovec[n++], "\x1B[1;31m");
219 IOVEC_SET_STRING(iovec[n++], buffer);
221 IOVEC_SET_STRING(iovec[n++], "\x1B[0m");
222 IOVEC_SET_STRING(iovec[n++], "\n");
224 if (writev(console_fd, iovec, n) < 0)
230 static int write_to_syslog(
235 const char *buffer) {
237 char header_priority[16], header_time[64], header_pid[16];
238 struct iovec iovec[5];
239 struct msghdr msghdr;
246 snprintf(header_priority, sizeof(header_priority), "<%i>", LOG_MAKEPRI(LOG_DAEMON, LOG_PRI(level)));
247 char_array_0(header_priority);
249 t = (time_t) (now(CLOCK_REALTIME) / USEC_PER_SEC);
250 if (!(tm = localtime(&t)))
253 if (strftime(header_time, sizeof(header_time), "%h %e %T ", tm) <= 0)
256 snprintf(header_pid, sizeof(header_pid), "[%llu]: ", (unsigned long long) getpid());
257 char_array_0(header_pid);
260 IOVEC_SET_STRING(iovec[0], header_priority);
261 IOVEC_SET_STRING(iovec[1], header_time);
262 IOVEC_SET_STRING(iovec[2], __progname);
263 IOVEC_SET_STRING(iovec[3], header_pid);
264 IOVEC_SET_STRING(iovec[4], buffer);
267 msghdr.msg_iov = iovec;
268 msghdr.msg_iovlen = ELEMENTSOF(iovec);
270 if (sendmsg(syslog_fd, &msghdr, 0) < 0)
276 static int write_to_kmsg(
281 const char *buffer) {
283 char header_priority[16], header_pid[16];
284 struct iovec iovec[5];
289 snprintf(header_priority, sizeof(header_priority), "<%i>", LOG_PRI(level));
290 char_array_0(header_priority);
292 snprintf(header_pid, sizeof(header_pid), "[%llu]: ", (unsigned long long) getpid());
293 char_array_0(header_pid);
296 IOVEC_SET_STRING(iovec[0], header_priority);
297 IOVEC_SET_STRING(iovec[1], __progname);
298 IOVEC_SET_STRING(iovec[2], header_pid);
299 IOVEC_SET_STRING(iovec[3], buffer);
300 IOVEC_SET_STRING(iovec[4], "\n");
302 if (writev(kmsg_fd, iovec, ELEMENTSOF(iovec)) < 0)
308 static int log_dispatch(
313 const char *buffer) {
317 if (log_target == LOG_TARGET_SYSLOG_OR_KMSG ||
318 log_target == LOG_TARGET_SYSLOG) {
320 if ((r = write_to_syslog(level, file, line, func, buffer)) < 0) {
327 if (log_target == LOG_TARGET_SYSLOG_OR_KMSG ||
328 log_target == LOG_TARGET_KMSG) {
330 if ((r = write_to_kmsg(level, file, line, func, buffer)) < 0) {
337 return write_to_console(level, file, line, func, buffer);
345 const char *format, ...) {
347 char buffer[LOG_BUFFER_MAX];
351 if (_likely(LOG_PRI(level) > log_max_level))
356 va_start(ap, format);
357 vsnprintf(buffer, sizeof(buffer), format, ap);
360 char_array_0(buffer);
362 r = log_dispatch(level, file, line, func, buffer);
372 const char *format, ...) {
374 static char buffer[LOG_BUFFER_MAX];
375 int saved_errno = errno;
378 va_start(ap, format);
379 vsnprintf(buffer, sizeof(buffer), format, ap);
382 char_array_0(buffer);
383 log_abort_msg = buffer;
385 log_dispatch(LOG_CRIT, file, line, func, buffer);
388 /* If the user chose to ignore this SIGABRT, we are happy to go on, as if nothing happened. */
392 int log_set_target_from_string(const char *e) {
395 if ((t = log_target_from_string(e)) < 0)
402 int log_set_max_level_from_string(const char *e) {
405 if ((t = log_level_from_string(e)) < 0)
408 log_set_max_level(t);
412 void log_parse_environment(void) {
415 if ((e = getenv("SYSTEMD_LOG_TARGET")))
416 if (log_set_target_from_string(e) < 0)
417 log_warning("Failed to parse log target %s. Ignoring.", e);
419 if ((e = getenv("SYSTEMD_LOG_LEVEL")))
420 if (log_set_max_level_from_string(e) < 0)
421 log_warning("Failed to parse log level %s. Ignoring.", e);
424 LogTarget log_get_target(void) {
428 int log_get_max_level(void) {
429 return log_max_level;
432 static const char *const log_target_table[] = {
433 [LOG_TARGET_CONSOLE] = "console",
434 [LOG_TARGET_SYSLOG] = "syslog",
435 [LOG_TARGET_KMSG] = "kmsg",
436 [LOG_TARGET_SYSLOG_OR_KMSG] = "syslog-or-kmsg",
439 DEFINE_STRING_TABLE_LOOKUP(log_target, LogTarget);