src/log.c

   1 #ifdef HAVE_CONFIG_H
   2 #include <config.h>
   3 #endif
   4 #include <time.h>
   5 #include <syslog.h>
   6 #include <errno.h>
   7 #include <string.h>
   8 #include <unistd.h>
   9 #include <stdlib.h>
  10
  11 #include "log.h"
  12 #include "common.h"
  13
  14
  15 // ----------------------------------------------------------------------------
  16 // LOG
  17
  18 const char *program_name = "";
  19 unsigned long long debug_flags = DEBUG;
  20
  21 int silent = 0;
  22
  23 int access_fd = -1;
  24 FILE *stdaccess = NULL;
  25
  26 int access_log_syslog = 1;
  27 int error_log_syslog = 1;
  28 int output_log_syslog = 1;      // debug log
  29
  30 time_t error_log_throttle_period = 1200;
  31 unsigned long error_log_errors_per_period = 200;
  32
  33 int error_log_limit(int reset) {
  34         static time_t start = 0;
  35         static unsigned long counter = 0, prevented = 0;
  36
  37         // do not throttle if the period is 0
  38         if(error_log_throttle_period == 0)
  39                 return 0;
  40
  41         // prevent all logs if the errors per period is 0
  42         if(error_log_errors_per_period == 0)
  43                 return 1;
  44
  45         time_t now = time(NULL);
  46         if(!start) start = now;
  47
  48         if(reset) {
  49                 if(prevented) {
  50                         log_date(stderr);
  51                         fprintf(stderr, "%s: Resetting logging for process '%s' (prevented %lu logs in the last %ld seconds).\n"
  52                                         , program_name
  53                                 , program_name
  54                                         , prevented
  55                                         , now - start
  56                         );
  57                 }
  58
  59                 start = now;
  60                 counter = 0;
  61                 prevented = 0;
  62         }
  63
  64         // detect if we log too much
  65         counter++;
  66
  67         if(now - start > error_log_throttle_period) {
  68                 if(prevented) {
  69                         log_date(stderr);
  70                         fprintf(stderr, "%s: Resuming logging from process '%s' (prevented %lu logs in the last %ld seconds).\n"
  71                                         , program_name
  72                                 , program_name
  73                                         , prevented
  74                                         , error_log_throttle_period
  75                         );
  76                 }
  77
  78                 // restart the period accounting
  79                 start = now;
  80                 counter = 1;
  81                 prevented = 0;
  82
  83                 // log this error
  84                 return 0;
  85         }
  86
  87         if(counter > error_log_errors_per_period) {
  88                 if(!prevented) {
  89                         log_date(stderr);
  90                         fprintf(stderr, "%s: Too many logs (%lu logs in %ld seconds, threshold is set to %lu logs in %ld seconds). Preventing more logs from process '%s' for %ld seconds.\n"
  91                                         , program_name
  92                                 , counter
  93                                 , now - start
  94                                 , error_log_errors_per_period
  95                                 , error_log_throttle_period
  96                                 , program_name
  97                                         , start + error_log_throttle_period - now);
  98                 }
  99
 100                 prevented++;
 101
 102                 // prevent logging this error
 103                 return 1;
 104         }
 105
 106         return 0;
 107 }
 108
 109 void log_date(FILE *out)
 110 {
 111                 char outstr[24];
 112                 time_t t;
 113                 struct tm *tmp, tmbuf;
 114
 115                 t = time(NULL);
 116                 tmp = localtime_r(&t, &tmbuf);
 117
 118                 if (tmp == NULL) return;
 119                 if (unlikely(strftime(outstr, sizeof(outstr), "%y-%m-%d %H:%M:%S", tmp) == 0)) return;
 120
 121                 fprintf(out, "%s: ", outstr);
 122 }
 123
 124 void debug_int( const char *file, const char *function, const unsigned long line, const char *fmt, ... )
 125 {
 126         va_list args;
 127
 128         log_date(stdout);
 129         va_start( args, fmt );
 130         printf("DEBUG (%04lu@%-10.10s:%-15.15s): %s: ", line, file, function, program_name);
 131         vprintf(fmt, args);
 132         va_end( args );
 133         putchar('\n');
 134
 135         if(output_log_syslog) {
 136                 va_start( args, fmt );
 137                 vsyslog(LOG_ERR,  fmt, args );
 138                 va_end( args );
 139         }
 140 }
 141
 142 void info_int( const char *file, const char *function, const unsigned long line, const char *fmt, ... )
 143 {
 144         va_list args;
 145
 146         // prevent logging too much
 147         if(error_log_limit(0)) return;
 148
 149         log_date(stderr);
 150
 151         va_start( args, fmt );
 152         if(debug_flags) fprintf(stderr, "INFO (%04lu@%-10.10s:%-15.15s): %s: ", line, file, function, program_name);
 153         else            fprintf(stderr, "INFO: %s: ", program_name);
 154         vfprintf( stderr, fmt, args );
 155         va_end( args );
 156
 157         fputc('\n', stderr);
 158
 159         if(error_log_syslog) {
 160                 va_start( args, fmt );
 161                 vsyslog(LOG_INFO,  fmt, args );
 162                 va_end( args );
 163         }
 164 }
 165
 166 void error_int( const char *prefix, const char *file, const char *function, const unsigned long line, const char *fmt, ... )
 167 {
 168         va_list args;
 169
 170         // prevent logging too much
 171         if(error_log_limit(0)) return;
 172
 173         log_date(stderr);
 174
 175         va_start( args, fmt );
 176         if(debug_flags) fprintf(stderr, "%s (%04lu@%-10.10s:%-15.15s): %s: ", prefix, line, file, function, program_name);
 177         else            fprintf(stderr, "%s: %s: ", prefix, program_name);
 178         vfprintf( stderr, fmt, args );
 179         va_end( args );
 180
 181         if(errno) {
 182                 char buf[1024];
 183                 fprintf(stderr, " (errno %d, %s)\n", errno, strerror_r(errno, buf, 1023));
 184                 errno = 0;
 185         }
 186         else
 187                 fputc('\n', stderr);
 188
 189         if(error_log_syslog) {
 190                 va_start( args, fmt );
 191                 vsyslog(LOG_ERR,  fmt, args );
 192                 va_end( args );
 193         }
 194 }
 195
 196 void fatal_int( const char *file, const char *function, const unsigned long line, const char *fmt, ... )
 197 {
 198         va_list args;
 199
 200         log_date(stderr);
 201
 202         va_start( args, fmt );
 203         if(debug_flags) fprintf(stderr, "FATAL (%04lu@%-10.10s:%-15.15s): %s: ", line, file, function, program_name);
 204         else            fprintf(stderr, "FATAL: %s: ", program_name);
 205         vfprintf( stderr, fmt, args );
 206         va_end( args );
 207
 208         perror(" # ");
 209         fputc('\n', stderr);
 210
 211         if(error_log_syslog) {
 212                 va_start( args, fmt );
 213                 vsyslog(LOG_CRIT,  fmt, args );
 214                 va_end( args );
 215         }
 216
 217         netdata_cleanup_and_exit(1);
 218 }
 219
 220 void log_access( const char *fmt, ... )
 221 {
 222         va_list args;
 223
 224         if(stdaccess) {
 225                 log_date(stdaccess);
 226
 227                 va_start( args, fmt );
 228                 vfprintf( stdaccess, fmt, args );
 229                 va_end( args );
 230                 fputc('\n', stdaccess);
 231         }
 232
 233         if(access_log_syslog) {
 234                 va_start( args, fmt );
 235                 vsyslog(LOG_INFO,  fmt, args );
 236                 va_end( args );
 237         }
 238 }
 239