X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Flogfile.c;h=6d0f6e07826f2eb5391a64bc93db72e642948362;hb=b4cc5c7399adf79198aea816d44a42df25431d15;hp=36ac58d711ee8a1764fd19ec72fefc9afffeafc5;hpb=c192de2c944bf9c73903b4a6ac8379db3acc5955;p=collectd.git diff --git a/src/logfile.c b/src/logfile.c index 36ac58d7..11797182 100644 --- a/src/logfile.c +++ b/src/logfile.c @@ -1,24 +1,29 @@ /** * collectd - src/logfile.c - * Copyright (C) 2007 Sebastian Harl + * Copyright (C) 2007 Sebastian Harl * Copyright (C) 2007,2008 Florian Forster * - * 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; only version 2 of the License is applicable. + * Permission is hereby granted, free of charge, to any person obtaining a + * copy of this software and associated documentation files (the "Software"), + * to deal in the Software without restriction, including without limitation + * the rights to use, copy, modify, merge, publish, distribute, sublicense, + * and/or sell copies of the Software, and to permit persons to whom the + * Software is furnished to do so, subject to the following conditions: * - * 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. + * The above copyright notice and this permission notice shall be included in + * all copies or substantial portions of the Software. * - * 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., - * 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR + * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, + * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE + * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER + * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING + * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER + * DEALINGS IN THE SOFTWARE. * * Authors: * Sebastian Harl - * Florian Forster + * Florian Forster **/ #include "collectd.h" @@ -39,47 +44,41 @@ static pthread_mutex_t file_lock = PTHREAD_MUTEX_INITIALIZER; static char *log_file = NULL; static int print_timestamp = 1; +static int print_severity = 0; static const char *config_keys[] = { "LogLevel", "File", - "Timestamp" + "Timestamp", + "PrintSeverity" }; static int config_keys_num = STATIC_ARRAY_SIZE (config_keys); static int logfile_config (const char *key, const char *value) { if (0 == strcasecmp (key, "LogLevel")) { - if ((0 == strcasecmp (value, "emerg")) - || (0 == strcasecmp (value, "alert")) - || (0 == strcasecmp (value, "crit")) - || (0 == strcasecmp (value, "err"))) - log_level = LOG_ERR; - else if (0 == strcasecmp (value, "warning")) - log_level = LOG_WARNING; - else if (0 == strcasecmp (value, "notice")) - log_level = LOG_NOTICE; - else if (0 == strcasecmp (value, "info")) + log_level = parse_log_severity(value); + if (log_level < 0) { log_level = LOG_INFO; -#if COLLECT_DEBUG - else if (0 == strcasecmp (value, "debug")) - log_level = LOG_DEBUG; -#endif /* COLLECT_DEBUG */ - else - return 1; + ERROR ("logfile: invalid loglevel [%s] defaulting to 'info'", value); + return (1); + } } else if (0 == strcasecmp (key, "File")) { sfree (log_file); log_file = strdup (value); } else if (0 == strcasecmp (key, "Timestamp")) { - if ((strcasecmp (value, "false") == 0) - || (strcasecmp (value, "no") == 0) - || (strcasecmp (value, "off") == 0)) + if (IS_FALSE (value)) print_timestamp = 0; else print_timestamp = 1; + } else if (0 == strcasecmp(key, "PrintSeverity")) { + if (IS_FALSE (value)) + print_severity = 0; + else + print_severity = 1; } else { return -1; @@ -87,16 +86,43 @@ static int logfile_config (const char *key, const char *value) return 0; } /* int logfile_config (const char *, const char *) */ -static void logfile_print (const char *msg, time_t timestamp_time) +static void logfile_print (const char *msg, int severity, + cdtime_t timestamp_time) { FILE *fh; - int do_close = 0; + _Bool do_close = 0; struct tm timestamp_tm; char timestamp_str[64]; + char level_str[16] = ""; + + if (print_severity) + { + switch (severity) + { + case LOG_ERR: + snprintf(level_str, sizeof (level_str), "[error] "); + break; + case LOG_WARNING: + snprintf(level_str, sizeof (level_str), "[warning] "); + break; + case LOG_NOTICE: + snprintf(level_str, sizeof (level_str), "[notice] "); + break; + case LOG_INFO: + snprintf(level_str, sizeof (level_str), "[info] "); + break; + case LOG_DEBUG: + snprintf(level_str, sizeof (level_str), "[debug] "); + break; + default: + break; + } + } if (print_timestamp) { - localtime_r (×tamp_time, ×tamp_tm); + time_t tt = CDTIME_T_TO_TIME_T (timestamp_time); + localtime_r (&tt, ×tamp_tm); strftime (timestamp_str, sizeof (timestamp_str), "%Y-%m-%d %H:%M:%S", ×tamp_tm); @@ -130,12 +156,15 @@ static void logfile_print (const char *msg, time_t timestamp_time) else { if (print_timestamp) - fprintf (fh, "[%s] %s\n", timestamp_str, msg); + fprintf (fh, "[%s] %s%s\n", timestamp_str, level_str, msg); else - fprintf (fh, "%s\n", msg); + fprintf (fh, "%s%s\n", level_str, msg); - if (do_close != 0) + if (do_close) { fclose (fh); + } else { + fflush(fh); + } } pthread_mutex_unlock (&file_lock); @@ -143,22 +172,24 @@ static void logfile_print (const char *msg, time_t timestamp_time) return; } /* void logfile_print */ -static void logfile_log (int severity, const char *msg) +static void logfile_log (int severity, const char *msg, + user_data_t __attribute__((unused)) *user_data) { if (severity > log_level) return; - logfile_print (msg, time (NULL)); + logfile_print (msg, severity, cdtime ()); } /* void logfile_log (int, const char *) */ -static int logfile_notification (const notification_t *n) +static int logfile_notification (const notification_t *n, + user_data_t __attribute__((unused)) *user_data) { char buf[1024] = ""; char *buf_ptr = buf; int buf_len = sizeof (buf); int status; - status = snprintf (buf_ptr, buf_len, "Notification: severity = %s", + status = ssnprintf (buf_ptr, buf_len, "Notification: severity = %s", (n->severity == NOTIF_FAILURE) ? "FAILURE" : ((n->severity == NOTIF_WARNING) ? "WARNING" : ((n->severity == NOTIF_OKAY) ? "OKAY" : "UNKNOWN"))); @@ -170,7 +201,7 @@ static int logfile_notification (const notification_t *n) #define APPEND(bufptr, buflen, key, value) \ if ((buflen > 0) && (strlen (value) > 0)) { \ - int status = snprintf (bufptr, buflen, ", %s = %s", key, value); \ + status = ssnprintf (bufptr, buflen, ", %s = %s", key, value); \ if (status > 0) { \ bufptr += status; \ buflen -= status; \ @@ -185,7 +216,8 @@ static int logfile_notification (const notification_t *n) buf[sizeof (buf) - 1] = '\0'; - logfile_print (buf, n->time); + logfile_print (buf, LOG_INFO, + (n->time != 0) ? n->time : cdtime ()); return (0); } /* int logfile_notification */ @@ -194,8 +226,9 @@ void module_register (void) { plugin_register_config ("logfile", logfile_config, config_keys, config_keys_num); - plugin_register_log ("logfile", logfile_log); - plugin_register_notification ("logfile", logfile_notification); + plugin_register_log ("logfile", logfile_log, /* user_data = */ NULL); + plugin_register_notification ("logfile", logfile_notification, + /* user_data = */ NULL); } /* void module_register (void) */ /* vim: set sw=4 ts=4 tw=78 noexpandtab : */