innd/status.c

   1 /*  $Id: status.c 7547 2006-08-26 06:18:14Z eagle $
   2 **
   3 **  Periodic status reporting.
   4 */
   5 #include "config.h"
   6 #include "clibrary.h"
   7 #include "portable/socket.h"
   8
   9 #include "inn/innconf.h"
  10 #include "innd.h"
  11 #include "innperl.h"
  12
  13 #define MIN_REFRESH   60  /* 1 min */
  14 #define HTML_STATUS
  15 #if defined(HTML_STATUS)
  16 #define STATUS_FILE     "inn_status.html"       /* will be in pathhttp */
  17 #else
  18 #define STATUS_FILE     "inn.status"            /* will be in pathlog */
  19 #endif
  20
  21 typedef struct _STATUS {
  22     char                name[SMBUF];
  23     char                ip_addr[64];
  24     bool                can_stream;
  25     unsigned short      activeCxn;
  26     unsigned short      sleepingCxns;
  27     time_t              seconds;
  28     unsigned long       accepted;
  29     unsigned long       refused;
  30     unsigned long       rejected;
  31     unsigned long       Duplicate;
  32     unsigned long       Unwanted_u;
  33     unsigned long       Unwanted_d;
  34     unsigned long       Unwanted_g;
  35     unsigned long       Unwanted_s;
  36     unsigned long       Unwanted_f;
  37     float               Size;
  38     float               DuplicateSize;
  39     unsigned long       Check;
  40     unsigned long       Check_send;
  41     unsigned long       Check_deferred;
  42     unsigned long       Check_got;
  43     unsigned long       Check_cybercan;
  44     unsigned long       Takethis;
  45     unsigned long       Takethis_Ok;
  46     unsigned long       Takethis_Err;
  47     unsigned long       Ihave;
  48     unsigned long       Ihave_Duplicate;
  49     unsigned long       Ihave_Deferred;
  50     unsigned long       Ihave_SendIt;
  51     unsigned long       Ihave_Cybercan;
  52     struct _STATUS *next;
  53 } STATUS;
  54
  55 static unsigned STATUSlast_time;
  56 char            start_time[50];
  57
  58 static unsigned
  59 STATUSgettime(void)
  60 {
  61   static int            init = 0;
  62   static struct timeval start_tv;
  63   struct timeval        tv;
  64
  65   if (!init) {
  66     gettimeofday(&start_tv, NULL);
  67     init++;
  68   }
  69   gettimeofday(&tv, NULL);
  70   return((tv.tv_sec - start_tv.tv_sec) * 1000 +
  71          (tv.tv_usec - start_tv.tv_usec) / 1000);
  72 }
  73
  74 void
  75 STATUSinit(void)
  76 {
  77   time_t now;
  78
  79   STATUSlast_time = STATUSgettime();    /* First invocation */
  80   now = time (NULL) ;
  81   strlcpy(start_time, ctime(&now), sizeof(start_time));
  82 }
  83
  84 static char *
  85 PrettySize(float size, char *str)
  86 {
  87   if (size > 1073741824) /* 1024*1024*1024 */
  88     sprintf (str, "%.1fGb", size / 1073741824.);
  89   else
  90     if (size > 1048576) /* 1024*1024 */
  91       sprintf (str, "%.1fMb", size / 1048576.);
  92     else
  93       sprintf (str, "%.1fkb", size / 1024.);
  94   return (str);
  95 }
  96
  97 static void
  98 STATUSsummary(void)
  99 {
 100   FILE                  *F;
 101   int                   i, j;
 102   CHANNEL               *cp;
 103   int                   activeCxn = 0;
 104   int                   sleepingCxns = 0;
 105   time_t                seconds = 0;
 106   unsigned long         duplicate = 0;
 107   unsigned long         offered;
 108   unsigned long         accepted = 0;
 109   unsigned long         refused = 0;
 110   unsigned long         rejected = 0;
 111   float                 size = 0;
 112   float                 DuplicateSize = 0;
 113   int                   peers = 0;
 114   char                  TempString[SMBUF];
 115   char                  *path;
 116   STATUS                *head, *status, *tmp;
 117   char                  str[9];
 118   time_t                now;
 119
 120 #if defined(HTML_STATUS)
 121   path = concatpath(innconf->pathhttp, STATUS_FILE);
 122 #else
 123   path = concatpath(innconf->pathlog, STATUS_FILE);
 124 #endif
 125   if ((F = Fopen(path, "w", TEMPORARYOPEN)) == NULL) {
 126     syslog(L_ERROR, "%s cannot open %s: %m", LogName, path);
 127     return;
 128   }
 129
 130 #if defined(HTML_STATUS)
 131   /* HTML Header */
 132
 133   fprintf (F,"<HTML>\n<HEAD>\n<META HTTP-EQUIV=\"Refresh\" CONTENT=\"%ld;\">\n",
 134            innconf->status < MIN_REFRESH ? MIN_REFRESH : innconf->status);
 135   fprintf (F, "<TITLE>%s: incoming feeds</TITLE>\n", innconf->pathhost);
 136   fprintf (F, "</HEAD>\n<BODY>\n<PRE>\n") ;
 137 #endif /* defined(HTML_STATUS) */
 138
 139   fprintf (F, "%s\n", inn_version_string);
 140   fprintf (F, "pid %d started %s\n", (int) getpid(), start_time);
 141
 142   tmp = head = NULL;
 143   for (i = 0; (cp = CHANiter(&i, CTnntp)) != NULL; ) {
 144     j = 0;
 145     strlcpy(TempString,
 146             cp->Address.ss_family == 0 ? "localhost" : RChostname(cp),
 147             sizeof(TempString));
 148     for (status = head ; status != NULL ; status = status->next) {
 149         if (strcmp(TempString, status->name) == 0)
 150             break;
 151     }
 152     if (status == NULL) {
 153       status = xmalloc(sizeof(STATUS));
 154       peers++;                                              /* a new peer */
 155       strlcpy(status->name, TempString, sizeof(status->name));
 156       strlcpy(status->ip_addr,
 157               sprint_sockaddr((struct sockaddr *)&cp->Address),
 158               sizeof(status->ip_addr));
 159       status->can_stream = cp->Streaming;
 160       status->seconds = status->Size = status->DuplicateSize = 0;
 161       status->Ihave = status->Ihave_Duplicate =
 162         status->Ihave_Deferred = status->Ihave_SendIt =
 163         status->Ihave_Cybercan = 0;
 164       status->Check = status->Check_send =
 165         status->Check_deferred = status->Check_got =
 166         status->Check_cybercan = 0;
 167       status->Takethis = status->Takethis_Ok = status->Takethis_Err = 0;
 168       status->activeCxn = status->sleepingCxns = 0;
 169       status->accepted = 0;
 170       status->refused = status->rejected = 0;
 171       status->Duplicate = status->Unwanted_u = 0;
 172       status->Unwanted_d = status->Unwanted_g = 0;
 173       status->Unwanted_s = status->Unwanted_f = 0;
 174       status->next = NULL;
 175       if (head == NULL)
 176         head = status;
 177       else
 178         tmp->next = status;
 179       tmp = status;
 180     }
 181     if (Now.time - cp->Started > status->seconds)
 182       status->seconds = Now.time - cp->Started;
 183     if (Now.time - cp->Started > seconds)
 184       seconds = Now.time - cp->Started;
 185     status->accepted += cp->Received;
 186     accepted += cp->Received;
 187     status->refused += cp->Refused;
 188     refused += cp->Refused;
 189     status->rejected += cp->Rejected;
 190     rejected += cp->Rejected;
 191     status->Duplicate += cp->Duplicate;
 192     duplicate += cp->Duplicate;
 193     status->Unwanted_u += cp->Unwanted_u;
 194     status->Unwanted_d += cp->Unwanted_d;
 195     status->Unwanted_g += cp->Unwanted_g;
 196     status->Unwanted_s += cp->Unwanted_s;
 197     status->Unwanted_f += cp->Unwanted_f;
 198     status->Ihave += cp->Ihave;
 199     status->Ihave_Duplicate += cp->Ihave_Duplicate;
 200     status->Ihave_Deferred += cp->Ihave_Deferred;
 201     status->Ihave_SendIt += cp->Ihave_SendIt;
 202     status->Ihave_Cybercan += cp->Ihave_Cybercan;
 203     status->Check += cp->Check;
 204     status->Check_send += cp->Check_send;
 205     status->Check_deferred += cp->Check_deferred;
 206     status->Check_got += cp->Check_got;
 207     status->Check_cybercan += cp->Check_cybercan;
 208     status->Takethis += cp->Takethis;
 209     status->Takethis_Ok += cp->Takethis_Ok;
 210     status->Takethis_Err += cp->Takethis_Err;
 211     status->Size += cp->Size;
 212     status->DuplicateSize += cp->DuplicateSize;
 213     size += cp->Size;
 214     DuplicateSize += cp->DuplicateSize;
 215     if (CHANsleeping(cp)) {
 216       sleepingCxns++;
 217       status->sleepingCxns++;
 218     } else {
 219       activeCxn++;
 220       status->activeCxn++;
 221     }
 222   }
 223
 224   /* Header */
 225   now = time (NULL);
 226   strlcpy (TempString, ctime (&now), sizeof(TempString));
 227   fprintf (F, "Updated: %s", TempString);
 228   fprintf (F, "(peers: %d, active-cxns: %d, sleeping-cxns: %d)\n\n",
 229            peers, activeCxn, sleepingCxns);
 230
 231   fprintf (F, "Mode: %s", Mode == OMrunning ? "running" :
 232            Mode == OMpaused ? "paused" :
 233            Mode == OMthrottled ? "throttled" : "Unknown");
 234   if ((Mode == OMpaused) || (Mode == OMthrottled))
 235     fprintf (F, " (%s)", ModeReason);
 236
 237   /* Global configuration */
 238   fprintf (F, "\n\nConfiguration file: %s\n\n", _PATH_CONFIG);
 239
 240   fprintf (F, "Global configuration parameters:\n");
 241   fprintf (F, "              Largest Article: %ld bytes\n", innconf->maxartsize);
 242   fprintf (F, "     Max Incoming connections: ");
 243   if (innconf->maxconnections)
 244     fprintf (F, "%ld\n", innconf->maxconnections);
 245   else
 246     fprintf (F, "unlimited\n");
 247   fprintf (F, "      Max Outgoing file feeds: %d\n", MaxOutgoing);
 248   fprintf (F, "                       Cutoff: ");
 249   if (innconf->artcutoff)
 250     fprintf (F, "%ld days\n", innconf->artcutoff);
 251   else
 252     fprintf (F, "none\n");
 253   fprintf (F, "               Timeout period: %ld seconds\n",
 254            (long)TimeOut.tv_sec);
 255   if (innconf->remembertrash) {
 256         fprintf (F, "               Remember Trash: Yes\n");
 257   } else {
 258         fprintf (F, "               Remember Trash: No\n");
 259   }
 260 #if defined(DO_TCL)
 261   fprintf (F, "                Tcl filtering: %s\n",
 262            TCLFilterActive ? "enabled" : "disabled");
 263 #endif /* defined(DO_TCL) */
 264 #if defined(DO_PERL)
 265   fprintf (F, "               Perl filtering: %s\n",
 266            PerlFilterActive ? "enabled" : "disabled");
 267 #endif /* defined(DO_PERL) */
 268
 269   fputc ('\n', F) ;
 270
 271   /* Global values */
 272   fprintf (F, "global (process)\n");
 273   fprintf (F, "         seconds: %ld\n", (long) seconds);
 274   offered = accepted + refused + rejected;
 275   fprintf (F, "         offered: %-9ld\n", offered);
 276   if (!offered) offered = 1; /* to avoid division by zero */
 277   if (!size) size = 1; /* avoid divide by zero here too */
 278   fprintf (F, "        accepted: %-9ld       %%accepted: %.1f%%\n",
 279            accepted, (float) accepted / offered * 100);
 280   fprintf (F, "         refused: %-9ld        %%refused: %.1f%%\n",
 281            refused, (float) refused / offered * 100);
 282   fprintf (F, "        rejected: %-9ld       %%rejected: %.1f%%\n",
 283            rejected, (float) rejected / offered * 100);
 284   fprintf (F, "      duplicated: %-9ld     %%duplicated: %.1f%%\n",
 285            duplicate, (float) duplicate / offered * 100);
 286   fprintf (F, "           bytes: %-7s\n", PrettySize (size + DuplicateSize, str));
 287   fprintf (F, " duplicated size: %-7s  %%duplicated size: %.1f%%\n",
 288            PrettySize(DuplicateSize, str), (float) DuplicateSize / size * 100);
 289   fputc ('\n', F) ;
 290
 291   /* Incoming Feeds */
 292   for (status = head ; status != NULL ;) {
 293     fprintf (F, "%s\n",                      status->name);
 294     fprintf (F, "    seconds: %-7ld  ",      (long) status->seconds);
 295     fprintf (F, "      duplicates: %-7ld ",  status->Duplicate);
 296     fprintf (F, "    ip address: %s\n",      status->ip_addr);
 297     fprintf (F, "    offered: %-7ld  ",
 298              status->accepted + status->refused + status->rejected);
 299     fprintf (F, "   uw newsgroups: %-7ld ",  status->Unwanted_g);
 300     fprintf (F, "   active cxns: %d\n",      status->activeCxn);
 301     fprintf (F, "   accepted: %-7ld  ",      status->accepted);
 302     fprintf (F, "uw distributions: %-7ld ",  status->Unwanted_d);
 303     fprintf (F, " sleeping cxns: %d\n",      status->sleepingCxns);
 304     fprintf (F, "    refused: %-7ld  ",      status->refused);
 305     fprintf (F, "      unapproved: %-7ld ",  status->Unwanted_u);
 306     fprintf (F, "want streaming: %s\n",
 307              status->can_stream ? "Yes" : "No");
 308     fprintf (F, "   rejected: %-7ld  ",      status->rejected);
 309     fprintf (F, "        filtered: %-7ld ",  status->Unwanted_f);
 310     fprintf (F, "  is streaming: %s\n",
 311              (status->Check || status->Takethis) ? "Yes" : "No");
 312     fprintf (F, "       size: %-8s ",        PrettySize(status->Size, str));
 313     fprintf (F, "       bad sites: %-7ld ", status->Unwanted_s);
 314     fprintf (F, "duplicate size: %s\n", PrettySize(status->DuplicateSize, str));
 315     fprintf (F, "  Protocol:\n");
 316     fprintf (F, "      Ihave: %-6ld SendIt[%d]: %-6ld    Got[%d]: %-6ld Deferred[%d]: %ld\n",
 317              status->Ihave, NNTP_SENDIT_VAL, status->Ihave_SendIt,
 318              NNTP_HAVEIT_VAL, status->Ihave_Duplicate, NNTP_RESENDIT_VAL,
 319              status->Ihave_Deferred);
 320     fprintf (F, "      Check: %-6ld SendIt[%d]: %-6ld    Got[%d]: %-6ld Deferred[%d]: %ld\n",
 321              status->Check, NNTP_OK_SENDID_VAL, status->Check_send,
 322              NNTP_ERR_GOTID_VAL, status->Check_got, NNTP_RESENDID_VAL,
 323              status->Check_deferred);
 324     fprintf (F, "   Takethis: %-6ld     Ok[%d]: %-6ld  Error[%d]: %-6ld\n",
 325              status->Takethis, NNTP_OK_RECID_VAL, status->Takethis_Ok,
 326              NNTP_ERR_FAILID_VAL, status->Takethis_Err);
 327     if (innconf->refusecybercancels) {
 328         fprintf (F, "   Cancelrejects:    Ihave[%d]: %-6ld  Check[%d]: %-6ld\n",
 329              NNTP_HAVEIT_VAL, status->Ihave_Cybercan,
 330              NNTP_ERR_GOTID_VAL, status->Check_cybercan);
 331     }
 332     fputc ('\n', F) ;
 333     tmp = status->next;
 334     free(status);
 335     status = tmp;
 336   }
 337
 338 #if defined(HTML_STATUS)
 339   /* HTML Footer */
 340   fprintf (F,"</PRE>\n</BODY>\n</HTML>\n");
 341 #endif /* defined(HTML_STATUS) */
 342
 343   Fclose(F);
 344 }
 345
 346 void
 347 STATUSmainloophook(void)
 348 {
 349   unsigned now;
 350
 351   if (!innconf->status)
 352     return;
 353   now = STATUSgettime();
 354
 355   if (now - STATUSlast_time > (unsigned)(innconf->status * 1000)) {
 356     STATUSsummary();
 357     STATUSlast_time = now;
 358   }
 359 }