--- /dev/null
+/* ply-kmsg-reader.c - kernel log message reader
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2, or (at your option)
+ * any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
+ * 02111-1307, USA.
+ *
+ */
+
+#include "ply-list.h"
+#include "ply-kmsg-reader.h"
+#include "ply-terminal-emulator.h"
+#include "ply-event-loop.h"
+#include "ply-logger.h"
+#include "ply-utils.h"
+#include <fcntl.h>
+#include <stdlib.h>
+#include <string.h>
+
+
+#include <stdio.h>
+#include <ctype.h>
+
+#ifndef LOG_LINE_MAX
+#define LOG_LINE_MAX 8192
+#endif
+
+#define from_hex(c) (isdigit (c) ? c - '0' : tolower (c) - 'a' + 10)
+
+size_t
+unhexmangle_to_buffer (const char *s,
+ char *buf,
+ size_t len)
+{
+ size_t sz = 0;
+ const char *buf0 = buf;
+
+ if (!s)
+ return 0;
+
+ while (*s && sz < len - 1) {
+ if (*s == '\\' && sz + 3 < len - 1 && s[1] == 'x' &&
+ isxdigit (s[2]) && isxdigit (s[3])) {
+ *buf++ = from_hex (s[2]) << 4 | from_hex (s[3]);
+ s += 4;
+ sz += 4;
+ } else {
+ *buf++ = *s++;
+ sz++;
+ }
+ }
+ *buf = '\0';
+ return buf - buf0 + 1;
+}
+
+int
+handle_kmsg_message (ply_kmsg_reader_t *kmsg_reader,
+ int fd)
+{
+ ssize_t bytes_read;
+ char read_buffer[LOG_LINE_MAX] = "";
+ int current_log_level = LOG_ERR, default_log_level = LOG_WARNING;
+
+ ply_get_kmsg_log_levels (¤t_log_level,
+ &default_log_level);
+
+ bytes_read = read (fd, read_buffer, sizeof(read_buffer) - 1);
+ if (bytes_read > 0) {
+ ply_terminal_style_attributes_t bold_enabled = PLY_TERMINAL_ATTRIBUTE_NO_BOLD;
+ ply_terminal_color_t color = PLY_TERMINAL_ATTRIBUTE_FOREGROUND_COLOR_OFFSET + PLY_TERMINAL_COLOR_DEFAULT;
+ char *fields, *field_prefix, *field_sequence, *field_timestamp, *message, *message_substr, *msgptr, *saveptr, *format_begin, *new_message;
+ int prefix, priority, facility;
+ uint64_t sequence;
+ unsigned long long timestamp;
+ kmsg_message_t *kmsg_message;
+
+ fields = strtok_r (read_buffer, ";", &message);
+
+ /* Messages end in \n, any following lines are machine readable. Actual multiline messages are expanded with unhexmangle_to_buffer */
+ msgptr = strchr (message, '\n');
+ if (*msgptr && *msgptr != '\n')
+ msgptr--;
+
+ unhexmangle_to_buffer (message, (char *) message, msgptr - message + 1);
+
+ field_prefix = strtok_r (fields, ",", &fields);
+ field_sequence = strtok_r (fields, ",", &fields);
+ field_timestamp = strtok_r (fields, ",", &fields);
+
+ prefix = atoi (field_prefix);
+ sequence = strtoull (field_sequence, NULL, 0);
+ timestamp = strtoull (field_timestamp, NULL, 0);
+
+ if (prefix > 0) {
+ priority = LOG_PRI (prefix);
+ facility = LOG_FAC (prefix);
+ } else {
+ priority = default_log_level;
+ facility = LOG_USER;
+ }
+
+ if (priority > current_log_level)
+ return 0;
+
+ if (priority < LOG_ALERT)
+ bold_enabled = PLY_TERMINAL_ATTRIBUTE_BOLD;
+
+ switch (priority) {
+ case LOG_EMERG:
+ case LOG_ALERT:
+ case LOG_CRIT:
+ case LOG_ERR:
+ color = PLY_TERMINAL_ATTRIBUTE_FOREGROUND_COLOR_OFFSET + PLY_TERMINAL_COLOR_RED;
+ break;
+ case LOG_WARNING:
+ color = PLY_TERMINAL_ATTRIBUTE_FOREGROUND_COLOR_OFFSET + PLY_TERMINAL_COLOR_BROWN;
+ break;
+ case LOG_NOTICE:
+ color = PLY_TERMINAL_ATTRIBUTE_FOREGROUND_COLOR_OFFSET + PLY_TERMINAL_COLOR_GREEN;
+ break;
+ }
+ asprintf (&format_begin, "\033[0;%i;%im", bold_enabled, color);
+
+ message_substr = strtok_r (message, "\n", &saveptr);
+ while (message_substr != NULL) {
+ kmsg_message = calloc (1, sizeof(kmsg_message_t));
+
+ kmsg_message->priority = priority;
+ kmsg_message->facility = facility;
+ kmsg_message->sequence = sequence;
+ kmsg_message->timestamp = timestamp;
+
+ asprintf (&new_message, "%s%s%s", format_begin, message_substr, "\033[0m");
+ kmsg_message->message = strndup (new_message, strlen (new_message));
+
+ ply_trigger_pull (kmsg_reader->kmsg_trigger, kmsg_message);
+ ply_list_append_data (kmsg_reader->kmsg_messages, kmsg_message);
+ free (new_message);
+
+ message_substr = strtok_r (NULL, "\n", &saveptr);
+ }
+ free (format_begin);
+
+ return 0;
+ } else {
+ ply_event_loop_stop_watching_fd (ply_event_loop_get_default (), kmsg_reader->fd_watch);
+ close (kmsg_reader->kmsg_fd);
+ return -1;
+ }
+}
+
+ply_kmsg_reader_t *
+ply_kmsg_reader_new (void)
+{
+ ply_kmsg_reader_t *kmsg_reader = calloc (1, sizeof(ply_kmsg_reader_t));
+ kmsg_reader->kmsg_trigger = ply_trigger_new (NULL);
+ kmsg_reader->kmsg_messages = ply_list_new ();
+
+ return kmsg_reader;
+}
+
+void
+ply_kmsg_message_free (kmsg_message_t *kmsg_message)
+{
+ if (kmsg_message == NULL)
+ return;
+
+ free (kmsg_message->message);
+ free (kmsg_message);
+}
+
+void
+ply_kmsg_reader_free (ply_kmsg_reader_t *kmsg_reader)
+{
+ ply_list_node_t *node;
+ kmsg_message_t *kmsg_message;
+
+ if (kmsg_reader == NULL)
+ return;
+
+ ply_list_foreach (kmsg_reader->kmsg_messages, node) {
+ kmsg_message = ply_list_node_get_data (node);
+ ply_kmsg_message_free (kmsg_message);
+ }
+
+ ply_trigger_free (kmsg_reader->kmsg_trigger);
+ free (kmsg_reader);
+}
+
+void
+ply_kmsg_reader_start (ply_kmsg_reader_t *kmsg_reader)
+{
+ kmsg_reader->kmsg_fd = open ("/dev/kmsg", O_RDWR | O_NONBLOCK);
+ if (kmsg_reader->kmsg_fd < 0)
+ return;
+
+ kmsg_reader->fd_watch = ply_event_loop_watch_fd (ply_event_loop_get_default (), kmsg_reader->kmsg_fd, PLY_EVENT_LOOP_FD_STATUS_HAS_DATA,
+ (ply_event_handler_t) handle_kmsg_message,
+ NULL,
+ kmsg_reader);
+}
+
+void
+ply_kmsg_reader_stop (ply_kmsg_reader_t *kmsg_reader)
+{
+ if (kmsg_reader->kmsg_fd < 0)
+ return;
+
+ ply_event_loop_stop_watching_fd (ply_event_loop_get_default (),
+ kmsg_reader->fd_watch);
+ kmsg_reader->fd_watch = NULL;
+
+ close (kmsg_reader->kmsg_fd);
+ kmsg_reader->kmsg_fd = -1;
+}
+
+void
+ply_kmsg_reader_watch_for_messages (ply_kmsg_reader_t *kmsg_reader,
+ ply_kmsg_reader_message_handler_t message_handler,
+ void *user_data)
+{
+ ply_trigger_add_handler (kmsg_reader->kmsg_trigger,
+ (ply_trigger_handler_t)
+ message_handler,
+ user_data);
+}
--- /dev/null
+/* ply-kmsg-reader.h - kernel log message reader
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2, or (at your option)
+ * any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
+ * 02111-1307, USA.
+ *
+ */
+#ifndef PLY_KMSG_READER_H
+#define PLY_KMSG_READER_H
+
+#include "ply-list.h"
+#include "ply-boot-splash.h"
+#include <sys/syslog.h>
+
+typedef struct _ply_kmsg_reader ply_kmsg_reader_t;
+
+struct dmesg_name
+{
+ const char *name;
+};
+
+typedef struct
+{
+ int priority;
+ int facility;
+ unsigned long sequence;
+ unsigned long long timestamp;
+ char *message;
+} kmsg_message_t;
+
+struct _ply_kmsg_reader
+{
+ int kmsg_fd;
+ ply_fd_watch_t *fd_watch;
+ ply_trigger_t *kmsg_trigger;
+ ply_list_t *kmsg_messages;
+};
+
+typedef void (* ply_kmsg_reader_message_handler_t) (void *,
+ kmsg_message_t *);
+
+#ifndef PLY_HIDE_FUNCTION_DECLARATIONS
+ply_kmsg_reader_t *ply_kmsg_reader_new (void);
+void ply_kmsg_reader_free (ply_kmsg_reader_t *kmsg_reader);
+void ply_kmsg_reader_start (ply_kmsg_reader_t *kmsg_reader);
+void ply_kmsg_reader_stop (ply_kmsg_reader_t *kmsg_reader);
+void ply_kmsg_reader_watch_for_messages (ply_kmsg_reader_t *kmsg_reader,
+ ply_kmsg_reader_message_handler_t message_handler,
+ void *user_data);
+
+#endif //PLY_HIDE_FUNCTION_DECLARATIONS
+
+#endif //PLY_KMSG_READER_H
projects / thirdparty / plymouth.git / commitdiff
