syslog.c

Go to the documentation of this file.

/*
 * Copyright (C) 2004 by egnite Software GmbH. All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. Neither the name of the copyright holders nor the names of
 *    contributors may be used to endorse or promote products derived
 *    from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY EGNITE SOFTWARE GMBH AND CONTRIBUTORS
 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
 * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL EGNITE
 * SOFTWARE GMBH OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
 * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS
 * OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
 * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF
 * THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 *
 * For additional information see http://www.ethernut.de/
 *
 * -
 * Portions Copyright (c) 1983, 1988, 1993
 *      The Regents of the University of California.  All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. Neither the name of the University nor the names of its contributors
 *    may be used to endorse or promote products derived from this software
 *    without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 */

#include <cfg/syslog.h>
#include <sys/confos.h>
#include <sys/confnet.h>

#include <stdlib.h>
#include <string.h>
#include <stdio.h>
#include <stdarg.h>
#include <io.h>
#include <time.h>
#include <memdebug.h>

#define SYSLOG_INTERNAL
#include <sys/syslog.h>

#ifndef SYSLOG_PERROR_ONLY

#include <sys/socket.h>
#include <arpa/inet.h>
static UDPSOCKET *syslog_sock;

#ifndef SYSLOG_PORT
#define SYSLOG_PORT     514
#endif

static uint32_t syslog_server;
static uint16_t syslog_port = SYSLOG_PORT;

#endif                          /* SYSLOG_PERROR_ONLY */


static int syslog_fac = LOG_USER;
static int syslog_mask = 0xFF;

static int syslog_stat;
static size_t syslog_taglen;
static char *syslog_tag;
char *syslog_buf;

size_t syslog_header(int pri)
{
    size_t rc;

    /* Remove invalid bits. */
    pri &= LOG_PRIMASK | LOG_FACMASK;

    /* Check priority against setlog mask values. */
    if ((LOG_MASK(LOG_PRI(pri)) & syslog_mask) == 0) {
        return 0;
    }

    /* Set default facility if none specified. */
    if ((pri & LOG_FACMASK) == 0) {
        pri |= syslog_fac;
    }

    /* Open log if not done before. */
    if (syslog_buf == 0) {
        openlog(0, syslog_stat | LOG_NDELAY, syslog_fac);
    }

    /* PRI field. 
    ** This is common to all syslog formats. */
    rc = sprintf(syslog_buf, "<%d>", pri);

    /* VERSION field. 
    ** Note, that there is no space separator. */
#ifdef SYSLOG_RFC5424
    syslog_buf[rc++] = '1';
#endif

    /* TIMESTAMP field. */
#ifdef SYSLOG_OMIT_TIMESTAMP

#ifdef SYSLOG_RFC5424
    syslog_buf[rc++] = ' ';
    syslog_buf[rc++] = '-';
#endif

#else
    {
        time_t now;
        struct _tm *tip;

        time(&now);

#ifdef SYSLOG_RFC5424
        tip = gmtime(&now);
        rc += sprintf(&syslog_buf[rc], " %04d-%02d-%02dT%02d:%02d:%02dZ",
            tip->tm_year + 1900, tip->tm_mon + 1, tip->tm_mday,
            tip->tm_hour, tip->tm_min, tip->tm_sec);
#else
        {
            static char mon_name[] = "JanFebMarAprMayJunJulAugSepOctNovDec";

            tip = localtime(&now);
            rc += sprintf(&syslog_buf[rc], "%.3s%3d %02d:%02d:%02d", 
                &mon_name[tip->tm_mon * 3], tip->tm_mday, 
                tip->tm_hour, tip->tm_min, tip->tm_sec);
        }
#endif /* SYSLOG_RFC5424 */

    }
#endif /* SYSLOG_OMIT_TIMESTAMP */

    /* HOSTNAME field. */
#ifdef SYSLOG_OMIT_HOSTNAME

#ifdef SYSLOG_RFC5424
    syslog_buf[rc++] = ' ';
    syslog_buf[rc++] = '-';
#endif

#else

#ifdef SYSLOG_RFC5424
    syslog_buf[rc++] = ' ';
    if (confnet.cdn_cip_addr) {
        strcpy(&syslog_buf[rc], inet_ntoa(confnet.cdn_cip_addr));
        rc += strlen(&syslog_buf[rc]);
    }
    else if (confos.hostname[0]) {
        strcpy(&syslog_buf[rc], confos.hostname);
        rc += strlen(&syslog_buf[rc]);
    }
    else if (confnet.cdn_ip_addr) {
        strcpy(&syslog_buf[rc], inet_ntoa(confnet.cdn_ip_addr));
        rc += strlen(&syslog_buf[rc]);
    } else {
        syslog_buf[rc++] = '-';
    }
#else
    syslog_buf[rc++] = ' ';
    strcpy(&syslog_buf[rc], confos.hostname);
    rc += strlen(confos.hostname);
#endif /* SYSLOG_RFC5424 */

#endif /* SYSLOG_OMIT_HOSTNAME */

    /* APP-NAME field. */
    if (syslog_taglen) {
        syslog_buf[rc++] = ' ';
        strcpy(&syslog_buf[rc], syslog_tag);
        rc += syslog_taglen;
#ifndef SYSLOG_RFC5424
        syslog_buf[rc++] = ':';
#endif
    }

    /* No PROCID and MSGID fields. */
#ifdef SYSLOG_RFC5424
    syslog_buf[rc++] = ' ';
    syslog_buf[rc++] = '-';
    syslog_buf[rc++] = ' ';
    syslog_buf[rc++] = '-';
#endif

    syslog_buf[rc++] = ' ';
    syslog_buf[rc] = '\0';
    
    return rc;
}

#ifndef SYSLOG_PERROR_ONLY

void syslog_flush(size_t len)
{
    /* Output to stderr if requested */
    if (syslog_stat & LOG_PERROR) {
        _write(_fileno(stderr), syslog_buf, len);
        _write(_fileno(stderr), "\n", 1);
    }

    /* Output the message to a remote logger. */
    if (syslog_server) {
        NutUdpSendTo(syslog_sock, syslog_server, syslog_port, syslog_buf, len);
    }
}
#endif

void vsyslog(int pri, CONST char *fmt, va_list ap)
{
    /* Build the header. */
    size_t cnt = syslog_header(pri);

    if (cnt) {
#ifdef SYSLOG_PERROR_ONLY
        fputs(syslog_buf, stderr);
        vfprintf(stderr, fmt, ap);
        fputc('\n', stderr);
#else
        /* Potentially dangerous. We need vsnprintf() */
        if (cnt + strlen(fmt) >= SYSLOG_MAXBUF) {
            puts("Buffer overflow");
            return;
        }
        cnt += vsprintf(&syslog_buf[cnt], fmt, ap);
        syslog_flush(cnt);
#endif /* SYSLOG_PERROR_ONLY */
    }
}

void syslog(int pri, CONST char *fmt, ...)
{
    va_list ap;

    va_start(ap, fmt);
    vsyslog(pri, (char *) fmt, ap);
    va_end(ap);
}

int setlogmask(int logmask)
{
    int rc = syslog_mask;

    if (logmask) {
        syslog_mask = logmask;
    }
    return rc;
}

uint32_t setlogserver(uint32_t ip, uint16_t port)
{
#ifdef SYSLOG_PERROR_ONLY
    return (uint32_t)-1;
#else
    uint32_t rc = syslog_server;

    syslog_server = ip;
    if (port) {
        syslog_port = port;
    }
    return rc;
#endif
}

void openlog(CONST char *ident, int logstat, int logfac)
{
    if (ident == 0) {
        ident = syslog_tag;
        syslog_taglen = 0;
    }

    closelog();

    syslog_stat = logstat;
    syslog_fac = logfac;
    if (ident && *ident) {
        syslog_taglen = strlen(ident);
        syslog_tag = malloc(syslog_taglen + 1);
        strcpy(syslog_tag, ident);
    }
    if (syslog_stat & LOG_NDELAY) {
        if (syslog_buf == 0) {
            syslog_buf = malloc(SYSLOG_MAXBUF);
        }
#ifndef SYSLOG_PERROR_ONLY
        if (syslog_sock == 0) {
            syslog_sock = NutUdpCreateSocket(514);
        }
#endif
    }
}

void closelog(void)
{
    if (syslog_buf) {
        free(syslog_buf);
        syslog_buf = 0;
    }
    if (syslog_taglen) {
        free(syslog_tag);
        syslog_taglen = 0;
    }
#ifndef SYSLOG_PERROR_ONLY
    if (syslog_sock) {
        NutUdpDestroySocket(syslog_sock);
        syslog_sock = 0;
    }
#endif
}