diff options
Diffstat (limited to '1.4.23-rc4/main/logger.c')
| -rw-r--r-- | 1.4.23-rc4/main/logger.c | 939 |
1 files changed, 0 insertions, 939 deletions
diff --git a/1.4.23-rc4/main/logger.c b/1.4.23-rc4/main/logger.c deleted file mode 100644 index 0d1ef4b71..000000000 --- a/1.4.23-rc4/main/logger.c +++ /dev/null @@ -1,939 +0,0 @@ -/* - * Asterisk -- An open source telephony toolkit. - * - * Copyright (C) 1999 - 2006, Digium, Inc. - * - * Mark Spencer <markster@digium.com> - * - * See http://www.asterisk.org for more information about - * the Asterisk project. Please do not directly contact - * any of the maintainers of this project for assistance; - * the project provides a web site, mailing lists and IRC - * channels for your use. - * - * This program is free software, distributed under the terms of - * the GNU General Public License Version 2. See the LICENSE file - * at the top of the source tree. - */ - -/*! \file - * - * \brief Asterisk Logger - * - * Logging routines - * - * \author Mark Spencer <markster@digium.com> - */ - -#include "asterisk.h" - -ASTERISK_FILE_VERSION(__FILE__, "$Revision$") - -#include <signal.h> -#include <stdarg.h> -#include <stdio.h> -#include <unistd.h> -#include <time.h> -#include <string.h> -#include <stdlib.h> -#include <errno.h> -#include <sys/stat.h> -#if ((defined(AST_DEVMODE)) && (defined(linux))) -#include <execinfo.h> -#define MAX_BACKTRACE_FRAMES 20 -#endif - -#define SYSLOG_NAMES /* so we can map syslog facilities names to their numeric values, - from <syslog.h> which is included by logger.h */ -#include <syslog.h> - -static int syslog_level_map[] = { - LOG_DEBUG, - LOG_INFO, /* arbitrary equivalent of LOG_EVENT */ - LOG_NOTICE, - LOG_WARNING, - LOG_ERR, - LOG_DEBUG, - LOG_DEBUG -}; - -#define SYSLOG_NLEVELS sizeof(syslog_level_map) / sizeof(int) - -#include "asterisk/logger.h" -#include "asterisk/lock.h" -#include "asterisk/options.h" -#include "asterisk/channel.h" -#include "asterisk/config.h" -#include "asterisk/term.h" -#include "asterisk/cli.h" -#include "asterisk/utils.h" -#include "asterisk/manager.h" -#include "asterisk/threadstorage.h" - -#if defined(__linux__) && !defined(__NR_gettid) -#include <asm/unistd.h> -#endif - -#if defined(__linux__) && defined(__NR_gettid) -#define GETTID() syscall(__NR_gettid) -#else -#define GETTID() getpid() -#endif - - -static char dateformat[256] = "%b %e %T"; /* Original Asterisk Format */ - -static int filesize_reload_needed; -static int global_logmask = -1; - -static struct { - unsigned int queue_log:1; - unsigned int event_log:1; -} logfiles = { 1, 1 }; - -static char hostname[MAXHOSTNAMELEN]; - -enum logtypes { - LOGTYPE_SYSLOG, - LOGTYPE_FILE, - LOGTYPE_CONSOLE, -}; - -struct logchannel { - int logmask; /* What to log to this channel */ - int disabled; /* If this channel is disabled or not */ - int facility; /* syslog facility */ - enum logtypes type; /* Type of log channel */ - FILE *fileptr; /* logfile logging file pointer */ - char filename[256]; /* Filename */ - AST_LIST_ENTRY(logchannel) list; -}; - -static AST_LIST_HEAD_STATIC(logchannels, logchannel); - -static FILE *eventlog; -static FILE *qlog; - -static char *levels[] = { - "DEBUG", - "EVENT", - "NOTICE", - "WARNING", - "ERROR", - "VERBOSE", - "DTMF" -}; - -static int colors[] = { - COLOR_BRGREEN, - COLOR_BRBLUE, - COLOR_YELLOW, - COLOR_BRRED, - COLOR_RED, - COLOR_GREEN, - COLOR_BRGREEN -}; - -AST_THREADSTORAGE(verbose_buf, verbose_buf_init); -#define VERBOSE_BUF_INIT_SIZE 128 - -AST_THREADSTORAGE(log_buf, log_buf_init); -#define LOG_BUF_INIT_SIZE 128 - -static int make_components(char *s, int lineno) -{ - char *w; - int res = 0; - char *stringp = s; - - while ((w = strsep(&stringp, ","))) { - w = ast_skip_blanks(w); - if (!strcasecmp(w, "error")) - res |= (1 << __LOG_ERROR); - else if (!strcasecmp(w, "warning")) - res |= (1 << __LOG_WARNING); - else if (!strcasecmp(w, "notice")) - res |= (1 << __LOG_NOTICE); - else if (!strcasecmp(w, "event")) - res |= (1 << __LOG_EVENT); - else if (!strcasecmp(w, "debug")) - res |= (1 << __LOG_DEBUG); - else if (!strcasecmp(w, "verbose")) - res |= (1 << __LOG_VERBOSE); - else if (!strcasecmp(w, "dtmf")) - res |= (1 << __LOG_DTMF); - else { - fprintf(stderr, "Logfile Warning: Unknown keyword '%s' at line %d of logger.conf\n", w, lineno); - } - } - - return res; -} - -static struct logchannel *make_logchannel(char *channel, char *components, int lineno) -{ - struct logchannel *chan; - char *facility; -#ifndef SOLARIS - CODE *cptr; -#endif - - if (ast_strlen_zero(channel) || !(chan = ast_calloc(1, sizeof(*chan)))) - return NULL; - - if (!strcasecmp(channel, "console")) { - chan->type = LOGTYPE_CONSOLE; - } else if (!strncasecmp(channel, "syslog", 6)) { - /* - * syntax is: - * syslog.facility => level,level,level - */ - facility = strchr(channel, '.'); - if(!facility++ || !facility) { - facility = "local0"; - } - -#ifndef SOLARIS - /* - * Walk through the list of facilitynames (defined in sys/syslog.h) - * to see if we can find the one we have been given - */ - chan->facility = -1; - cptr = facilitynames; - while (cptr->c_name) { - if (!strcasecmp(facility, cptr->c_name)) { - chan->facility = cptr->c_val; - break; - } - cptr++; - } -#else - chan->facility = -1; - if (!strcasecmp(facility, "kern")) - chan->facility = LOG_KERN; - else if (!strcasecmp(facility, "USER")) - chan->facility = LOG_USER; - else if (!strcasecmp(facility, "MAIL")) - chan->facility = LOG_MAIL; - else if (!strcasecmp(facility, "DAEMON")) - chan->facility = LOG_DAEMON; - else if (!strcasecmp(facility, "AUTH")) - chan->facility = LOG_AUTH; - else if (!strcasecmp(facility, "SYSLOG")) - chan->facility = LOG_SYSLOG; - else if (!strcasecmp(facility, "LPR")) - chan->facility = LOG_LPR; - else if (!strcasecmp(facility, "NEWS")) - chan->facility = LOG_NEWS; - else if (!strcasecmp(facility, "UUCP")) - chan->facility = LOG_UUCP; - else if (!strcasecmp(facility, "CRON")) - chan->facility = LOG_CRON; - else if (!strcasecmp(facility, "LOCAL0")) - chan->facility = LOG_LOCAL0; - else if (!strcasecmp(facility, "LOCAL1")) - chan->facility = LOG_LOCAL1; - else if (!strcasecmp(facility, "LOCAL2")) - chan->facility = LOG_LOCAL2; - else if (!strcasecmp(facility, "LOCAL3")) - chan->facility = LOG_LOCAL3; - else if (!strcasecmp(facility, "LOCAL4")) - chan->facility = LOG_LOCAL4; - else if (!strcasecmp(facility, "LOCAL5")) - chan->facility = LOG_LOCAL5; - else if (!strcasecmp(facility, "LOCAL6")) - chan->facility = LOG_LOCAL6; - else if (!strcasecmp(facility, "LOCAL7")) - chan->facility = LOG_LOCAL7; -#endif /* Solaris */ - - if (0 > chan->facility) { - fprintf(stderr, "Logger Warning: bad syslog facility in logger.conf\n"); - free(chan); - return NULL; - } - - chan->type = LOGTYPE_SYSLOG; - snprintf(chan->filename, sizeof(chan->filename), "%s", channel); - openlog("asterisk", LOG_PID, chan->facility); - } else { - if (channel[0] == '/') { - if(!ast_strlen_zero(hostname)) { - snprintf(chan->filename, sizeof(chan->filename) - 1,"%s.%s", channel, hostname); - } else { - ast_copy_string(chan->filename, channel, sizeof(chan->filename)); - } - } - - if(!ast_strlen_zero(hostname)) { - snprintf(chan->filename, sizeof(chan->filename), "%s/%s.%s",(char *)ast_config_AST_LOG_DIR, channel, hostname); - } else { - snprintf(chan->filename, sizeof(chan->filename), "%s/%s", (char *)ast_config_AST_LOG_DIR, channel); - } - chan->fileptr = fopen(chan->filename, "a"); - if (!chan->fileptr) { - /* Can't log here, since we're called with a lock */ - fprintf(stderr, "Logger Warning: Unable to open log file '%s': %s\n", chan->filename, strerror(errno)); - } - chan->type = LOGTYPE_FILE; - } - chan->logmask = make_components(components, lineno); - return chan; -} - -static void init_logger_chain(void) -{ - struct logchannel *chan; - struct ast_config *cfg; - struct ast_variable *var; - const char *s; - - /* delete our list of log channels */ - AST_LIST_LOCK(&logchannels); - while ((chan = AST_LIST_REMOVE_HEAD(&logchannels, list))) - free(chan); - AST_LIST_UNLOCK(&logchannels); - - global_logmask = 0; - errno = 0; - /* close syslog */ - closelog(); - - cfg = ast_config_load("logger.conf"); - - /* If no config file, we're fine, set default options. */ - if (!cfg) { - if (errno) - fprintf(stderr, "Unable to open logger.conf: %s; default settings will be used.\n", strerror(errno)); - else - fprintf(stderr, "Errors detected in logger.conf: see above; default settings will be used.\n"); - if (!(chan = ast_calloc(1, sizeof(*chan)))) - return; - chan->type = LOGTYPE_CONSOLE; - chan->logmask = 28; /*warning,notice,error */ - AST_LIST_LOCK(&logchannels); - AST_LIST_INSERT_HEAD(&logchannels, chan, list); - AST_LIST_UNLOCK(&logchannels); - global_logmask |= chan->logmask; - return; - } - - if ((s = ast_variable_retrieve(cfg, "general", "appendhostname"))) { - if (ast_true(s)) { - if (gethostname(hostname, sizeof(hostname) - 1)) { - ast_copy_string(hostname, "unknown", sizeof(hostname)); - ast_log(LOG_WARNING, "What box has no hostname???\n"); - } - } else - hostname[0] = '\0'; - } else - hostname[0] = '\0'; - if ((s = ast_variable_retrieve(cfg, "general", "dateformat"))) - ast_copy_string(dateformat, s, sizeof(dateformat)); - else - ast_copy_string(dateformat, "%b %e %T", sizeof(dateformat)); - if ((s = ast_variable_retrieve(cfg, "general", "queue_log"))) - logfiles.queue_log = ast_true(s); - if ((s = ast_variable_retrieve(cfg, "general", "event_log"))) - logfiles.event_log = ast_true(s); - - AST_LIST_LOCK(&logchannels); - var = ast_variable_browse(cfg, "logfiles"); - for (; var; var = var->next) { - if (!(chan = make_logchannel(var->name, var->value, var->lineno))) - continue; - AST_LIST_INSERT_HEAD(&logchannels, chan, list); - global_logmask |= chan->logmask; - } - AST_LIST_UNLOCK(&logchannels); - - ast_config_destroy(cfg); -} - -void ast_queue_log(const char *queuename, const char *callid, const char *agent, const char *event, const char *fmt, ...) -{ - va_list ap; - AST_LIST_LOCK(&logchannels); - if (qlog) { - va_start(ap, fmt); - fprintf(qlog, "%ld|%s|%s|%s|%s|", (long)time(NULL), callid, queuename, agent, event); - vfprintf(qlog, fmt, ap); - fprintf(qlog, "\n"); - va_end(ap); - fflush(qlog); - } - AST_LIST_UNLOCK(&logchannels); -} - -int reload_logger(int rotate) -{ - char old[PATH_MAX] = ""; - char new[PATH_MAX]; - int event_rotate = rotate, queue_rotate = rotate; - struct logchannel *f; - FILE *myf; - int x, res = 0; - - AST_LIST_LOCK(&logchannels); - - if (eventlog) - fclose(eventlog); - else - event_rotate = 0; - eventlog = NULL; - - if (qlog) - fclose(qlog); - else - queue_rotate = 0; - qlog = NULL; - - mkdir((char *)ast_config_AST_LOG_DIR, 0755); - - AST_LIST_TRAVERSE(&logchannels, f, list) { - if (f->disabled) { - f->disabled = 0; /* Re-enable logging at reload */ - manager_event(EVENT_FLAG_SYSTEM, "LogChannel", "Channel: %s\r\nEnabled: Yes\r\n", f->filename); - } - if (f->fileptr && (f->fileptr != stdout) && (f->fileptr != stderr)) { - fclose(f->fileptr); /* Close file */ - f->fileptr = NULL; - if (rotate) { - ast_copy_string(old, f->filename, sizeof(old)); - - for (x = 0; ; x++) { - snprintf(new, sizeof(new), "%s.%d", f->filename, x); - myf = fopen((char *)new, "r"); - if (myf) - fclose(myf); - else - break; - } - - /* do it */ - if (rename(old,new)) - fprintf(stderr, "Unable to rename file '%s' to '%s'\n", old, new); - } - } - } - - filesize_reload_needed = 0; - - init_logger_chain(); - - if (logfiles.event_log) { - snprintf(old, sizeof(old), "%s/%s", (char *)ast_config_AST_LOG_DIR, EVENTLOG); - if (event_rotate) { - for (x=0;;x++) { - snprintf(new, sizeof(new), "%s/%s.%d", (char *)ast_config_AST_LOG_DIR, EVENTLOG,x); - myf = fopen((char *)new, "r"); - if (myf) /* File exists */ - fclose(myf); - else - break; - } - - /* do it */ - if (rename(old,new)) - ast_log(LOG_ERROR, "Unable to rename file '%s' to '%s'\n", old, new); - } - - eventlog = fopen(old, "a"); - if (eventlog) { - ast_log(LOG_EVENT, "Restarted Asterisk Event Logger\n"); - if (option_verbose) - ast_verbose("Asterisk Event Logger restarted\n"); - } else { - ast_log(LOG_ERROR, "Unable to create event log: %s\n", strerror(errno)); - res = -1; - } - } - - if (logfiles.queue_log) { - snprintf(old, sizeof(old), "%s/%s", (char *)ast_config_AST_LOG_DIR, QUEUELOG); - if (queue_rotate) { - for (x = 0; ; x++) { - snprintf(new, sizeof(new), "%s/%s.%d", (char *)ast_config_AST_LOG_DIR, QUEUELOG, x); - myf = fopen((char *)new, "r"); - if (myf) /* File exists */ - fclose(myf); - else - break; - } - - /* do it */ - if (rename(old, new)) - ast_log(LOG_ERROR, "Unable to rename file '%s' to '%s'\n", old, new); - } - - qlog = fopen(old, "a"); - if (qlog) { - ast_queue_log("NONE", "NONE", "NONE", "CONFIGRELOAD", "%s", ""); - ast_log(LOG_EVENT, "Restarted Asterisk Queue Logger\n"); - if (option_verbose) - ast_verbose("Asterisk Queue Logger restarted\n"); - } else { - ast_log(LOG_ERROR, "Unable to create queue log: %s\n", strerror(errno)); - res = -1; - } - } - - AST_LIST_UNLOCK(&logchannels); - - return res; -} - -/*! \brief Reload the logger module without rotating log files (also used from loader.c during - a full Asterisk reload) */ -int logger_reload(void) -{ - if(reload_logger(0)) - return RESULT_FAILURE; - return RESULT_SUCCESS; -} - -static int handle_logger_reload(int fd, int argc, char *argv[]) -{ - int result = logger_reload(); - if (result == RESULT_FAILURE) - ast_cli(fd, "Failed to reload the logger\n"); - return result; -} - -static int handle_logger_rotate(int fd, int argc, char *argv[]) -{ - if(reload_logger(1)) { - ast_cli(fd, "Failed to reload the logger and rotate log files\n"); - return RESULT_FAILURE; - } - return RESULT_SUCCESS; -} - -/*! \brief CLI command to show logging system configuration */ -static int handle_logger_show_channels(int fd, int argc, char *argv[]) -{ -#define FORMATL "%-35.35s %-8.8s %-9.9s " - struct logchannel *chan; - - ast_cli(fd,FORMATL, "Channel", "Type", "Status"); - ast_cli(fd, "Configuration\n"); - ast_cli(fd,FORMATL, "-------", "----", "------"); - ast_cli(fd, "-------------\n"); - AST_LIST_LOCK(&logchannels); - AST_LIST_TRAVERSE(&logchannels, chan, list) { - ast_cli(fd, FORMATL, chan->filename, chan->type==LOGTYPE_CONSOLE ? "Console" : (chan->type==LOGTYPE_SYSLOG ? "Syslog" : "File"), - chan->disabled ? "Disabled" : "Enabled"); - ast_cli(fd, " - "); - if (chan->logmask & (1 << __LOG_DEBUG)) - ast_cli(fd, "Debug "); - if (chan->logmask & (1 << __LOG_DTMF)) - ast_cli(fd, "DTMF "); - if (chan->logmask & (1 << __LOG_VERBOSE)) - ast_cli(fd, "Verbose "); - if (chan->logmask & (1 << __LOG_WARNING)) - ast_cli(fd, "Warning "); - if (chan->logmask & (1 << __LOG_NOTICE)) - ast_cli(fd, "Notice "); - if (chan->logmask & (1 << __LOG_ERROR)) - ast_cli(fd, "Error "); - if (chan->logmask & (1 << __LOG_EVENT)) - ast_cli(fd, "Event "); - ast_cli(fd, "\n"); - } - AST_LIST_UNLOCK(&logchannels); - ast_cli(fd, "\n"); - - return RESULT_SUCCESS; -} - -struct verb { - void (*verboser)(const char *string); - AST_LIST_ENTRY(verb) list; -}; - -static AST_LIST_HEAD_STATIC(verbosers, verb); - -static char logger_reload_help[] = -"Usage: logger reload\n" -" Reloads the logger subsystem state. Use after restarting syslogd(8) if you are using syslog logging.\n"; - -static char logger_rotate_help[] = -"Usage: logger rotate\n" -" Rotates and Reopens the log files.\n"; - -static char logger_show_channels_help[] = -"Usage: logger show channels\n" -" List configured logger channels.\n"; - -static struct ast_cli_entry cli_logger[] = { - { { "logger", "show", "channels", NULL }, - handle_logger_show_channels, "List configured log channels", - logger_show_channels_help }, - - { { "logger", "reload", NULL }, - handle_logger_reload, "Reopens the log files", - logger_reload_help }, - - { { "logger", "rotate", NULL }, - handle_logger_rotate, "Rotates and reopens the log files", - logger_rotate_help }, -}; - -static int handle_SIGXFSZ(int sig) -{ - /* Indicate need to reload */ - filesize_reload_needed = 1; - return 0; -} - -int init_logger(void) -{ - char tmp[256]; - int res = 0; - - /* auto rotate if sig SIGXFSZ comes a-knockin */ - (void) signal(SIGXFSZ,(void *) handle_SIGXFSZ); - - /* register the logger cli commands */ - ast_cli_register_multiple(cli_logger, sizeof(cli_logger) / sizeof(struct ast_cli_entry)); - - mkdir((char *)ast_config_AST_LOG_DIR, 0755); - - /* create log channels */ - init_logger_chain(); - - /* create the eventlog */ - if (logfiles.event_log) { - mkdir((char *)ast_config_AST_LOG_DIR, 0755); - snprintf(tmp, sizeof(tmp), "%s/%s", (char *)ast_config_AST_LOG_DIR, EVENTLOG); - eventlog = fopen((char *)tmp, "a"); - if (eventlog) { - ast_log(LOG_EVENT, "Started Asterisk Event Logger\n"); - if (option_verbose) - ast_verbose("Asterisk Event Logger Started %s\n",(char *)tmp); - } else { - ast_log(LOG_ERROR, "Unable to create event log: %s\n", strerror(errno)); - res = -1; - } - } - - if (logfiles.queue_log) { - snprintf(tmp, sizeof(tmp), "%s/%s", (char *)ast_config_AST_LOG_DIR, QUEUELOG); - qlog = fopen(tmp, "a"); - ast_queue_log("NONE", "NONE", "NONE", "QUEUESTART", "%s", ""); - } - return res; -} - -void close_logger(void) -{ - struct logchannel *f; - - AST_LIST_LOCK(&logchannels); - - if (eventlog) { - fclose(eventlog); - eventlog = NULL; - } - - if (qlog) { - fclose(qlog); - qlog = NULL; - } - - AST_LIST_TRAVERSE(&logchannels, f, list) { - if (f->fileptr && (f->fileptr != stdout) && (f->fileptr != stderr)) { - fclose(f->fileptr); - f->fileptr = NULL; - } - } - - closelog(); /* syslog */ - - AST_LIST_UNLOCK(&logchannels); - - return; -} - -static void __attribute__((format(printf, 5, 0))) ast_log_vsyslog(int level, const char *file, int line, const char *function, const char *fmt, va_list args) -{ - char buf[BUFSIZ]; - char *s; - - if (level >= SYSLOG_NLEVELS) { - /* we are locked here, so cannot ast_log() */ - fprintf(stderr, "ast_log_vsyslog called with bogus level: %d\n", level); - return; - } - if (level == __LOG_VERBOSE) { - snprintf(buf, sizeof(buf), "VERBOSE[%ld]: ", (long)GETTID()); - level = __LOG_DEBUG; - } else if (level == __LOG_DTMF) { - snprintf(buf, sizeof(buf), "DTMF[%ld]: ", (long)GETTID()); - level = __LOG_DEBUG; - } else { - snprintf(buf, sizeof(buf), "%s[%ld]: %s:%d in %s: ", - levels[level], (long)GETTID(), file, line, function); - } - s = buf + strlen(buf); - vsnprintf(s, sizeof(buf) - strlen(buf), fmt, args); - term_strip(s, s, strlen(s) + 1); - syslog(syslog_level_map[level], "%s", buf); -} - -/*! - * \brief send log messages to syslog and/or the console - */ -void ast_log(int level, const char *file, int line, const char *function, const char *fmt, ...) -{ - struct logchannel *chan; - struct ast_dynamic_str *buf; - time_t t; - struct tm tm; - char date[256]; - - va_list ap; - - if (!(buf = ast_dynamic_str_thread_get(&log_buf, LOG_BUF_INIT_SIZE))) - return; - - if (AST_LIST_EMPTY(&logchannels)) - { - /* - * we don't have the logger chain configured yet, - * so just log to stdout - */ - if (level != __LOG_VERBOSE) { - int res; - va_start(ap, fmt); - res = ast_dynamic_str_thread_set_va(&buf, BUFSIZ, &log_buf, fmt, ap); - va_end(ap); - if (res != AST_DYNSTR_BUILD_FAILED) { - term_filter_escapes(buf->str); - fputs(buf->str, stdout); - } - } - return; - } - - /* don't display LOG_DEBUG messages unless option_verbose _or_ option_debug - are non-zero; LOG_DEBUG messages can still be displayed if option_debug - is zero, if option_verbose is non-zero (this allows for 'level zero' - LOG_DEBUG messages to be displayed, if the logmask on any channel - allows it) - */ - if (!option_verbose && !option_debug && (level == __LOG_DEBUG)) - return; - - /* Ignore anything that never gets logged anywhere */ - if (!(global_logmask & (1 << level))) - return; - - /* Ignore anything other than the currently debugged file if there is one */ - if ((level == __LOG_DEBUG) && !ast_strlen_zero(debug_filename) && strcasecmp(debug_filename, file)) - return; - - time(&t); - ast_localtime(&t, &tm, NULL); - strftime(date, sizeof(date), dateformat, &tm); - - AST_LIST_LOCK(&logchannels); - - if (logfiles.event_log && level == __LOG_EVENT) { - va_start(ap, fmt); - - fprintf(eventlog, "%s asterisk[%ld]: ", date, (long)getpid()); - vfprintf(eventlog, fmt, ap); - fflush(eventlog); - - va_end(ap); - AST_LIST_UNLOCK(&logchannels); - return; - } - - AST_LIST_TRAVERSE(&logchannels, chan, list) { - if (chan->disabled) - break; - /* Check syslog channels */ - if (chan->type == LOGTYPE_SYSLOG && (chan->logmask & (1 << level))) { - va_start(ap, fmt); - ast_log_vsyslog(level, file, line, function, fmt, ap); - va_end(ap); - /* Console channels */ - } else if ((chan->logmask & (1 << level)) && (chan->type == LOGTYPE_CONSOLE)) { - char linestr[128]; - char tmp1[80], tmp2[80], tmp3[80], tmp4[80]; - - if (level != __LOG_VERBOSE) { - int res; - sprintf(linestr, "%d", line); - ast_dynamic_str_thread_set(&buf, BUFSIZ, &log_buf, - "[%s] %s[%ld]: %s:%s %s: ", - date, - term_color(tmp1, levels[level], colors[level], 0, sizeof(tmp1)), - (long)GETTID(), - term_color(tmp2, file, COLOR_BRWHITE, 0, sizeof(tmp2)), - term_color(tmp3, linestr, COLOR_BRWHITE, 0, sizeof(tmp3)), - term_color(tmp4, function, COLOR_BRWHITE, 0, sizeof(tmp4))); - /*filter to the console!*/ - term_filter_escapes(buf->str); - ast_console_puts_mutable(buf->str); - - va_start(ap, fmt); - res = ast_dynamic_str_thread_set_va(&buf, BUFSIZ, &log_buf, fmt, ap); - va_end(ap); - if (res != AST_DYNSTR_BUILD_FAILED) - ast_console_puts_mutable(buf->str); - } - /* File channels */ - } else if ((chan->logmask & (1 << level)) && (chan->fileptr)) { - int res; - ast_dynamic_str_thread_set(&buf, BUFSIZ, &log_buf, - "[%s] %s[%ld] %s: ", - date, levels[level], (long)GETTID(), file); - res = fprintf(chan->fileptr, "%s", buf->str); - if (res <= 0 && !ast_strlen_zero(buf->str)) { /* Error, no characters printed */ - fprintf(stderr,"**** Asterisk Logging Error: ***********\n"); - if (errno == ENOMEM || errno == ENOSPC) { - fprintf(stderr, "Asterisk logging error: Out of disk space, can't log to log file %s\n", chan->filename); - } else - fprintf(stderr, "Logger Warning: Unable to write to log file '%s': %s (disabled)\n", chan->filename, strerror(errno)); - manager_event(EVENT_FLAG_SYSTEM, "LogChannel", "Channel: %s\r\nEnabled: No\r\nReason: %d - %s\r\n", chan->filename, errno, strerror(errno)); - chan->disabled = 1; - } else { - int res; - /* No error message, continue printing */ - va_start(ap, fmt); - res = ast_dynamic_str_thread_set_va(&buf, BUFSIZ, &log_buf, fmt, ap); - va_end(ap); - if (res != AST_DYNSTR_BUILD_FAILED) { - term_strip(buf->str, buf->str, buf->len); - fputs(buf->str, chan->fileptr); - fflush(chan->fileptr); - } - } - } - } - - AST_LIST_UNLOCK(&logchannels); - - if (filesize_reload_needed) { - reload_logger(1); - ast_log(LOG_EVENT,"Rotated Logs Per SIGXFSZ (Exceeded file size limit)\n"); - if (option_verbose) - ast_verbose("Rotated Logs Per SIGXFSZ (Exceeded file size limit)\n"); - } -} - -void ast_backtrace(void) -{ -#ifdef linux -#ifdef AST_DEVMODE - int count=0, i=0; - void **addresses; - char **strings; - - if ((addresses = ast_calloc(MAX_BACKTRACE_FRAMES, sizeof(*addresses)))) { - count = backtrace(addresses, MAX_BACKTRACE_FRAMES); - if ((strings = backtrace_symbols(addresses, count))) { - ast_log(LOG_DEBUG, "Got %d backtrace record%c\n", count, count != 1 ? 's' : ' '); - for (i=0; i < count ; i++) { -#if __WORDSIZE == 32 - ast_log(LOG_DEBUG, "#%d: [%08X] %s\n", i, (unsigned int)addresses[i], strings[i]); -#elif __WORDSIZE == 64 - ast_log(LOG_DEBUG, "#%d: [%016lX] %s\n", i, (unsigned long)addresses[i], strings[i]); -#endif - } - free(strings); - } else { - ast_log(LOG_DEBUG, "Could not allocate memory for backtrace\n"); - } - free(addresses); - } -#else - ast_log(LOG_WARNING, "Must run configure with '--enable-dev-mode' for stack backtraces.\n"); -#endif -#else /* ndef linux */ - ast_log(LOG_WARNING, "Inline stack backtraces are only available on the Linux platform.\n"); -#endif -} - -void ast_verbose(const char *fmt, ...) -{ - struct verb *v; - struct ast_dynamic_str *buf; - int res; - va_list ap; - - if (ast_opt_timestamp) { - time_t t; - struct tm tm; - char date[40]; - char *datefmt; - - time(&t); - ast_localtime(&t, &tm, NULL); - strftime(date, sizeof(date), dateformat, &tm); - datefmt = alloca(strlen(date) + 3 + strlen(fmt) + 1); - sprintf(datefmt, "%c[%s] %s", 127, date, fmt); - fmt = datefmt; - } else { - char *tmp = alloca(strlen(fmt) + 2); - sprintf(tmp, "%c%s", 127, fmt); - fmt = tmp; - } - - if (!(buf = ast_dynamic_str_thread_get(&verbose_buf, VERBOSE_BUF_INIT_SIZE))) - return; - - va_start(ap, fmt); - res = ast_dynamic_str_thread_set_va(&buf, 0, &verbose_buf, fmt, ap); - va_end(ap); - - if (res == AST_DYNSTR_BUILD_FAILED) - return; - - /* filter out possibly hazardous escape sequences */ - term_filter_escapes(buf->str); - - AST_LIST_LOCK(&verbosers); - AST_LIST_TRAVERSE(&verbosers, v, list) - v->verboser(buf->str); - AST_LIST_UNLOCK(&verbosers); - - ast_log(LOG_VERBOSE, "%s", buf->str + 1); -} - -int ast_register_verbose(void (*v)(const char *string)) -{ - struct verb *verb; - - if (!(verb = ast_malloc(sizeof(*verb)))) - return -1; - - verb->verboser = v; - - AST_LIST_LOCK(&verbosers); - AST_LIST_INSERT_HEAD(&verbosers, verb, list); - AST_LIST_UNLOCK(&verbosers); - - return 0; -} - -int ast_unregister_verbose(void (*v)(const char *string)) -{ - struct verb *cur; - - AST_LIST_LOCK(&verbosers); - AST_LIST_TRAVERSE_SAFE_BEGIN(&verbosers, cur, list) { - if (cur->verboser == v) { - AST_LIST_REMOVE_CURRENT(&verbosers, list); - free(cur); - break; - } - } - AST_LIST_TRAVERSE_SAFE_END - AST_LIST_UNLOCK(&verbosers); - - return cur ? 0 : -1; -} |