diff options
| author | Umut Tezduyar Lindskog <umut.tezduyar@axis.com> | 2013-11-13 15:27:19 +0100 |
|---|---|---|
| committer | Zbigniew Jędrzejewski-Szmek <zbyszek@in.waw.pl> | 2013-11-13 22:44:37 -0500 |
| commit | ad79565d6b37bcc93cf773a39b975e5b85d122da (patch) | |
| tree | aac95c38219f1e29d1fb3fc8a8a386830d5fde07 /src/journal | |
| parent | 4555ec72d6530fce4c978fd894ac22f7e006b0ee (diff) | |
journal: timestamp support on console messages
journald mimics the kernel here: timestamps will be printed if
/sys/module/printk/parameters/time contains "Y".
Diffstat (limited to 'src/journal')
| -rw-r--r-- | src/journal/journald-console.c | 34 |
1 files changed, 31 insertions, 3 deletions
diff --git a/src/journal/journald-console.c b/src/journal/journald-console.c index be55f94878..1ee3afeacc 100644 --- a/src/journal/journald-console.c +++ b/src/journal/journald-console.c @@ -19,13 +19,30 @@ along with systemd; If not, see <http://www.gnu.org/licenses/>. ***/ +#include <time.h> #include <fcntl.h> #include <unistd.h> #include <sys/socket.h> +#include "fileio.h" #include "journald-server.h" #include "journald-console.h" +static bool prefix_timestamp(void) { + + static int cached_printk_time = -1; + + if (_unlikely_(cached_printk_time < 0)) { + _cleanup_free_ char *p = NULL; + + cached_printk_time = + read_one_line_file("/sys/module/printk/parameters/time", &p) >= 0 + && parse_boolean(p) > 0; + } + + return cached_printk_time; +} + void server_forward_console( Server *s, int priority, @@ -33,8 +50,10 @@ void server_forward_console( const char *message, struct ucred *ucred) { - struct iovec iovec[4]; + struct iovec iovec[5]; char header_pid[16]; + struct timespec ts; + char tbuf[4 + DECIMAL_STR_MAX(ts.tv_sec) + DECIMAL_STR_MAX(ts.tv_nsec)-3 + 1]; int n = 0, fd; char *ident_buf = NULL; const char *tty; @@ -45,7 +64,16 @@ void server_forward_console( if (LOG_PRI(priority) > s->max_level_console) return; - /* First: identifier and PID */ + /* First: timestamp */ + if (prefix_timestamp()) { + assert_se(clock_gettime(CLOCK_MONOTONIC, &ts) == 0); + snprintf(tbuf, sizeof(tbuf), "[%5llu.%06llu] ", + (unsigned long long) ts.tv_sec, + (unsigned long long) ts.tv_nsec / 1000); + IOVEC_SET_STRING(iovec[n++], tbuf); + } + + /* Second: identifier and PID */ if (ucred) { if (!identifier) { get_process_comm(ucred->pid, &ident_buf); @@ -64,7 +92,7 @@ void server_forward_console( IOVEC_SET_STRING(iovec[n++], ": "); } - /* Third: message */ + /* Fourth: message */ IOVEC_SET_STRING(iovec[n++], message); IOVEC_SET_STRING(iovec[n++], "\n"); |