corosync-qdevice/qdevices/log.c

/*
 * Copyright (c) 2015-2019 Red Hat, Inc.
 *
 * All rights reserved.
 *
 * Author: Jan Friesse (jfriesse@redhat.com)
 *
 * This software licensed under BSD license, the text of which follows:
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 * - Redistributions of source code must retain the above copyright notice,
 *   this list of conditions and the following disclaimer.
 * - 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.
 * - Neither the name of the Red Hat, Inc. 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 COPYRIGHT HOLDERS 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 COPYRIGHT OWNER 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 <syslog.h>
#include <stdio.h>
#include <string.h>
#include <time.h>

#include "qnet-config.h"
#include "log.h"

static int log_config_target = 0;
static int log_config_debug = 0;
static int log_config_priority_bump = 0;
static int log_config_syslog_facility = 0;
static char *log_config_ident = NULL;

static const char log_month_str[][4] = {
    "Jan", "Feb", "Mar", "Apr", "May", "Jun",
    "Jul", "Aug", "Sep", "Oct", "Nov", "Dec"
};

struct log_syslog_prio_to_str_item {
	int priority;
	const char *priority_str;
};

static struct log_syslog_prio_to_str_item syslog_prio_to_str_array[] = {
    {LOG_EMERG,		"emerg"},
    {LOG_ALERT,		"alert"},
    {LOG_CRIT,		"crit"},
    {LOG_ERR,		"error"},
    {LOG_WARNING,	"warning"},
    {LOG_NOTICE,	"notice"},
    {LOG_INFO,		"info"},
    {LOG_DEBUG,		"debug"},
    {-1, NULL}};

int
log_init(const char *ident, int target, int syslog_facility)
{

	log_config_ident = strdup(ident);

	if (log_config_ident == NULL) {
		return (-1);
	}

	log_set_target(target, syslog_facility);

	return (0);
}

static const char *
log_syslog_prio_to_str(int priority)
{

	if (priority >= LOG_EMERG && priority <= LOG_DEBUG) {
		return (syslog_prio_to_str_array[priority].priority_str);
	} else {
		return ("none");
	}
}

void
log_vprintf(int priority, const char *format, va_list ap)
{
	time_t current_time;
	struct tm tm_res;
	int final_priority;
	va_list ap_copy;

	if (priority != LOG_DEBUG || (log_config_debug)) {
		if (log_config_target & LOG_TARGET_STDERR) {
			current_time = time(NULL);
			localtime_r(&current_time, &tm_res);

			fprintf(stderr, "%s %02d %02d:%02d:%02d ",
			    log_month_str[tm_res.tm_mon], tm_res.tm_mday, tm_res.tm_hour,
			    tm_res.tm_min, tm_res.tm_sec);

			fprintf(stderr, "%-7s ", log_syslog_prio_to_str(priority));

			va_copy(ap_copy, ap);
			vfprintf(stderr, format, ap_copy);
			va_end(ap_copy);
			fprintf(stderr, "\n");
		}

		if (log_config_target & LOG_TARGET_SYSLOG) {
			final_priority = priority;
			if (log_config_priority_bump && priority > LOG_INFO) {
				final_priority = LOG_INFO;
			}

			va_copy(ap_copy, ap);
			vsyslog(final_priority, format, ap);
			va_end(ap_copy);
		}
	}
}

void
log_printf(int priority, const char *format, ...)
{
	va_list ap;

	va_start(ap, format);

	log_vprintf(priority, format, ap);

	va_end(ap);
}

void
log_close(void)
{

	if (log_config_target & LOG_TARGET_SYSLOG) {
		closelog();
	}
}

void
log_set_debug(int enabled)
{

	log_config_debug = enabled;
}

void
log_set_priority_bump(int enabled)
{

	log_config_priority_bump = enabled;
}

void
log_set_target(int target, int syslog_facility)
{

	log_close();

	log_config_target = target;
	log_config_syslog_facility = syslog_facility;

	if (log_config_target & LOG_TARGET_SYSLOG) {
		openlog(log_config_ident, LOG_PID, log_config_syslog_facility);
	}
}

void
log_msg_decode_error(int ret)
{

	switch (ret) {
	case -1:
		log(LOG_WARNING, "Received message with option with invalid length");
		break;
	case -2:
		log(LOG_CRIT, "Can't allocate memory");
		break;
	case -3:
		log(LOG_WARNING, "Received inconsistent msg (tlv len > msg size)");
		break;
	case -4:
		log(LOG_WARNING, "Received message with option with invalid value");
		break;
	default:
		log(LOG_ERR, "Unknown error occurred when decoding message");
		break;
	}
}