syslog.c File Reference

#include <linux/un.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <regex.h>
#include <time.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include <syslog.h>
#include <errno.h>
#include <ctype.h>
#include <libubox/uloop.h>
#include <libubox/usock.h>
#include <libubox/ustream.h>
#include <libubox/utils.h>

Go to the source code of this file.

Macros
#define	LOG_DEFAULT_SIZE   (16 * 1024)
#define	LOG_DEFAULT_SOCKET   "/dev/log"
#define	SYSLOG_PADDING   16
#define	KLOG_DEFAULT_PROC   "/proc/kmsg"
#define	PAD(x)   (x % 4) ? (((x) - (x % 4)) + 4) : (x)

Functions
static struct log_head *	log_next (struct log_head *h, int size)
static uint64_t	get_kernel_ts (const char *ts_sec, const char *ts_nsec)
static void	log_add_udebug (int priority, char *buf, int size, int source)
void	log_add (char *buf, int size, int source)
static void	syslog_handle_fd (struct uloop_fd *fd, unsigned int events)
static void	klog_cb (struct ustream *s, int bytes)
static int	klog_open (void)
static int	syslog_open (void)
struct log_head *	log_list (int count, struct log_head *h)
int	log_buffer_init (int size)
void	log_udebug_config (struct udebug_ubus *ctx, struct blob_attr *data, bool enabled)
void	log_init (int _log_size)

Variables
static char *	log_dev = "/dev/log"
static int	log_size = (16 * 1024)
static struct log_head *	log
static struct log_head *	log_end
static struct log_head *	oldest
static struct log_head *	newest
static int	current_id = 0
static regex_t	pat_prio
static regex_t	pat_tstamp
static struct udebug	ud
static struct udebug_buf udb_kernel udb_user	udb_debug
static const struct udebug_buf_meta	meta_kernel
static const struct udebug_buf_meta	meta_user
static const struct udebug_buf_meta	meta_debug
static struct udebug_ubus_ring	rings []
static struct uloop_fd	syslog_fd
static struct ustream_fd	klog

Macro Definition Documentation

KLOG_DEFAULT_PROC

#define KLOG_DEFAULT_PROC   "/proc/kmsg"

Definition at line 42 of file syslog.c.

LOG_DEFAULT_SIZE

#define LOG_DEFAULT_SIZE   (16 * 1024)

Definition at line 38 of file syslog.c.

LOG_DEFAULT_SOCKET

#define LOG_DEFAULT_SOCKET   "/dev/log"

Definition at line 39 of file syslog.c.

PAD

#define PAD

(

x

)

(x % 4) ? (((x) - (x % 4)) + 4) : (x)

Definition at line 44 of file syslog.c.

SYSLOG_PADDING

#define SYSLOG_PADDING   16

Definition at line 40 of file syslog.c.

Function Documentation

get_kernel_ts()

static uint64_t get_kernel_ts ( const char *  ts_sec, const char *  ts_nsec  )

static

Definition at line 96 of file syslog.c.

{
        uint64_t ts = strtoull(ts_sec, NULL, 10) * UDEBUG_TS_SEC +
                      strtoull(ts_nsec, NULL, 10) / 1000;
        struct timespec wall, mono;
 
        if (clock_gettime(CLOCK_REALTIME, &wall) ||
            clock_gettime(CLOCK_MONOTONIC, &mono))
                return 0;
 
        ts += (wall.tv_sec - mono.tv_sec) * UDEBUG_TS_SEC;
        ts += (wall.tv_nsec - mono.tv_nsec) / 1000;
 
        return ts;
}

Here is the caller graph for this function:

klog_cb()

static void klog_cb ( struct ustream *  s, int  bytes  )

static

Definition at line 245 of file syslog.c.

{
        struct ustream_buf *buf = s->r.head;
        char *newline, *str;
        int len;
 
        do {
                str = ustream_get_read_buf(s, NULL);
                if (!str)
                        break;
                newline = strchr(buf->data, '\n');
                if (!newline)
                        break;
                *newline = 0;
                len = newline + 1 - str;
                log_add(buf->data, len, SOURCE_KLOG);
                ustream_consume(s, len);
        } while (1);
}

klog_open()

static int klog_open ( void  )

static

Definition at line 275 of file syslog.c.

{
        int fd;
 
        fd = open(KLOG_DEFAULT_PROC, O_RDONLY | O_NONBLOCK);
        if (fd < 0) {
                fprintf(stderr, "Failed to open %s\n", KLOG_DEFAULT_PROC);
                return -1;
        }
        fcntl(fd, F_SETFD, fcntl(fd, F_GETFD) | FD_CLOEXEC);
        ustream_fd_init(&klog, fd);
        return 0;
}

Here is the caller graph for this function:

log_add()

void log_add	(	char *	buf,
		int	size,
		int	source
	)

Definition at line 147 of file syslog.c.

{
        regmatch_t matches[3];
        struct log_head *next;
        int priority = 0;
        int ret;
        char *c;
 
        /* bounce out if we don't have init'ed yet (regmatch etc will blow) */
        if (!log) {
                fprintf(stderr, "%s", buf);
                return;
        }
 
        for (c = buf; *c; c++) {
                if (*c == '\n')
                *c = ' ';
        }
 
        c = buf + size - 2;
        while (isspace(*c)) {
                size--;
                c--;
        }
 
        buf[size - 1] = 0;
 
        /* strip the priority */
        ret = regexec(&pat_prio, buf, 3, matches, 0);
        if (!ret) {
                priority = atoi(&buf[matches[1].rm_so]);
                size -= matches[2].rm_so;
                buf += matches[2].rm_so;
        }
 
        /* strip syslog timestamp */
        if ((source == SOURCE_SYSLOG) && (size > SYSLOG_PADDING) && (buf[SYSLOG_PADDING - 1] == ' ')) {
                size -= SYSLOG_PADDING;
                buf += SYSLOG_PADDING;
        }
 
        log_add_udebug(priority, buf, size, source);
 
        /* debug message */
        if ((priority & LOG_FACMASK) == LOG_LOCAL7)
                return;
 
        /* find new oldest entry */
        next = log_next(newest, size);
        if (next > newest) {
                while ((oldest > newest) && (oldest <= next) && (oldest != log))
                        oldest = log_next(oldest, oldest->size);
        } else {
                //fprintf(stderr, "Log wrap\n");
                newest->size = 0;
                next = log_next(log, size);
                for (oldest = log; oldest <= next; oldest = log_next(oldest, oldest->size))
                        ;
                newest = log;
        }
 
        /* add the log message */
        newest->size = size;
        newest->id = current_id++;
        newest->priority = priority;
        newest->source = source;
        clock_gettime(CLOCK_REALTIME, &newest->ts);
        strcpy(newest->data, buf);
 
        ubus_notify_log(newest);
 
        newest = next;
}

Here is the call graph for this function:

Here is the caller graph for this function:

log_add_udebug()

static void log_add_udebug ( int  priority, char *  buf, int  size, int  source  )

static

Definition at line 113 of file syslog.c.

{
        regmatch_t matches[4];
        struct udebug_buf *udb;
        uint64_t ts = 0;
 
        if (source == SOURCE_KLOG)
                udb = &udb_kernel;
        else if ((priority & LOG_FACMASK) == LOG_LOCAL7)
                udb = &udb_debug;
        else
                udb = &udb_user;
 
        if (!udebug_buf_valid(udb))
                return;
 
        if (source == SOURCE_KLOG &&
            !regexec(&pat_tstamp, buf, 4, matches, 0)) {
                ts = get_kernel_ts(&buf[matches[1].rm_so], &buf[matches[2].rm_so]);
                buf += matches[3].rm_so;
                size -= matches[3].rm_so;
        }
 
        if (!ts)
                ts = udebug_timestamp();
 
        udebug_entry_init_ts(udb, ts);
        udebug_entry_printf(udb, "<%d>", priority);
        udebug_entry_append(udb, buf, size - 1);
        udebug_entry_add(udb);
}

Here is the call graph for this function:

Here is the caller graph for this function:

log_buffer_init()

int log_buffer_init

(

int

size

)

Definition at line 328 of file syslog.c.

{
        struct log_head *_log = calloc(1, size);
 
        if (!_log) {
                fprintf(stderr, "Failed to initialize log buffer with size %d\n", log_size);
                return -1;
        }
 
        if (log && ((log_size + sizeof(struct log_head)) < size)) {
                struct log_head *start = _log;
                struct log_head *end = ((void*) _log) + size;
                struct log_head *l;
 
                l = log_list(0, NULL);
                while ((start < end) && l && l->size) {
                        memcpy(start, l, PAD(sizeof(struct log_head) + l->size));
                        start = (struct log_head *) &l->data[PAD(l->size)];
                        l = log_list(0, l);
                }
                free(log);
                newest = start;
                newest->size = 0;
                oldest = log = _log;
                log_end = ((void*) log) + size;
        } else {
                oldest = newest = log = _log;
                log_end = ((void*) log) + size;
        }
        log_size = size;
 
        return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

log_init()

void log_init

(

int

_log_size

)

Definition at line 369 of file syslog.c.

Here is the call graph for this function:

log_list()

struct log_head* log_list	(	int	count,
		struct log_head *	h
	)

Definition at line 305 of file syslog.c.

{
        unsigned int min = count;
 
        if (count)
                min = (count < current_id) ? (current_id - count) : (0);
        if (!h && oldest->id >= min)
                return oldest;
        if (!h)
                h = oldest;
 
        while (h != newest) {
                h = log_next(h, h->size);
                if (!h->size && (h > newest))
                        h = log;
                if (h->id >= min && (h != newest))
                        return h;
        }
 
        return NULL;
}

Here is the call graph for this function:

Here is the caller graph for this function:

log_next()

static struct log_head* log_next ( struct log_head *  h, int  size  )

static

Definition at line 88 of file syslog.c.

{
        struct log_head *n = (struct log_head *) &h->data[PAD(size)];
 
        return (n >= log_end) ? (log) : (n);
}

Here is the caller graph for this function:

log_udebug_config()

void log_udebug_config	(	struct udebug_ubus *	ctx,
		struct blob_attr *	data,
		bool	enabled
	)

Definition at line 362 of file syslog.c.

{
        udebug_ubus_apply_config(&ud, rings, ARRAY_SIZE(rings), data, enabled);
}

syslog_handle_fd()

static void syslog_handle_fd ( struct uloop_fd *  fd, unsigned int  events  )

static

Definition at line 222 of file syslog.c.

{
        static char buf[LOG_LINE_SIZE];
        int len;
 
        while (1) {
                len = recv(fd->fd, buf, LOG_LINE_SIZE - 1, 0);
                if (len < 0) {
                        if (errno == EINTR)
                                continue;
 
                        break;
                }
                if (!len)
                        break;
 
                buf[len] = 0;
 
                log_add(buf, strlen(buf) + 1, SOURCE_SYSLOG);
        }
}

Here is the call graph for this function:

syslog_open()

static int syslog_open ( void  )

static

Definition at line 290 of file syslog.c.

{
        unlink(log_dev);
        syslog_fd.fd = usock(USOCK_UNIX | USOCK_UDP | USOCK_SERVER | USOCK_NONBLOCK, log_dev, NULL);
        if (syslog_fd.fd < 0) {
                fprintf(stderr,"Failed to open %s\n", log_dev);
                return -1;
        }
        chmod(log_dev, 0666);
        uloop_fd_add(&syslog_fd, ULOOP_READ | ULOOP_EDGE_TRIGGER);
 
        return 0;
}

Here is the caller graph for this function:

Variable Documentation

current_id

int current_id = 0

static

Definition at line 49 of file syslog.c.

klog

struct ustream_fd klog

static

Initial value:

= {
        .stream.string_data = true,
        .stream.notify_read = klog_cb,
}

Definition at line 245 of file syslog.c.

log

struct log_head* log

static

Definition at line 48 of file syslog.c.

log_dev

char* log_dev = "/dev/log"

static

Definition at line 46 of file syslog.c.

log_end

struct log_head * log_end

static

Definition at line 48 of file syslog.c.

log_size

int log_size = (16 * 1024)

static

Definition at line 47 of file syslog.c.

meta_debug

const struct udebug_buf_meta meta_debug

static

Initial value:

= {
        .name = "debug",
        .format = UDEBUG_FORMAT_STRING,
}

Definition at line 51 of file syslog.c.

meta_kernel

const struct udebug_buf_meta meta_kernel

static

Initial value:

= {
        .name = "kernel",
        .format = UDEBUG_FORMAT_STRING,
}

Definition at line 51 of file syslog.c.

meta_user

const struct udebug_buf_meta meta_user

static

Initial value:

= {
        .name = "syslog",
        .format = UDEBUG_FORMAT_STRING,
}

Definition at line 51 of file syslog.c.

newest

struct log_head * newest

static

Definition at line 48 of file syslog.c.

oldest

struct log_head * oldest

static

Definition at line 48 of file syslog.c.

pat_prio

regex_t pat_prio

static

Definition at line 50 of file syslog.c.

pat_tstamp

regex_t pat_tstamp

static

Definition at line 51 of file syslog.c.

rings

struct udebug_ubus_ring rings[]

static

Initial value:

= {
        {
                .buf = &udb_kernel,
                .meta = &meta_kernel,
                .default_entries = 1024,
                .default_size = 65536,
        },
        {
                .buf = &udb_user,
                .meta = &meta_user,
                .default_entries = 1024,
                .default_size = 65536,
        },
        {
                .buf = &udb_debug,
                .meta = &meta_debug,
                .default_entries = 1024,
                .default_size = 65536,
        },
}

Definition at line 51 of file syslog.c.

syslog_fd

struct uloop_fd syslog_fd

static

Initial value:

= {
        .cb = syslog_handle_fd
}

Definition at line 245 of file syslog.c.

ud

struct udebug ud

static

Definition at line 51 of file syslog.c.

udb_debug

struct udebug_buf udb_kernel udb_user udb_debug

static

Definition at line 51 of file syslog.c.