format files

1 files changed, 249 insertions, 149 deletions

diff --git a/src/qmail-mrtg.c b/src/qmail-mrtg.c
index 1ccedeb..cecd067 100644
--- a/src/qmail-mrtg.c
+++ b/src/qmail-mrtg.c
@@ -1,18 +1,20 @@
 #include <unistd.h>
-#include "stralloc.h"
+
 #include "buffer.h"
-#include "getln.h"
+#include "case.h"
 #include "exit.h"
+#include "fmt.h"
+#include "getln.h"
+#include "logmsg.h"
 #include "open.h"
 #include "scan.h"
-#include "fmt.h"
-#include "case.h"
-#include "now.h"
 #include "str.h"
+#include "stralloc.h"
+
 #include "datetime.h"
-#include "logmsg.h"
+#include "now.h"
 
-#define WHO "qmail-mrtg"
+#define WHO       "qmail-mrtg"
 #define TAI64NLEN 24
 
 /** @file qmail-mrtg.c
@@ -75,174 +77,262 @@ int grey = 0;
 int rbl = 0;
 
 char bufsmall[64];
-buffer bo = BUFFER_INIT(write,1,bufsmall,sizeof(bufsmall));
+buffer bo = BUFFER_INIT(write, 1, bufsmall, sizeof(bufsmall));
 
-static void outs(char *s) 
+static void outs(char *s)
 {
-  if (buffer_puts(&bo,s) == -1) _exit(1);
-  if (buffer_puts(&bo,"\n") == -1) _exit(1);
+  if (buffer_puts(&bo, s) == -1) _exit(1);
+  if (buffer_puts(&bo, "\n") == -1) _exit(1);
   if (buffer_flush(&bo) == -1) _exit(1);
 }
 
-static void out(int i) 
+static void out(int i)
 {
   char num[FMT_ULONG];
 
-  if (buffer_put(&bo,num,fmt_ulong(num,(unsigned long) i)) == -1) _exit(1); 
-  if (buffer_puts(&bo,"\n") == -1) _exit(1);
+  if (buffer_put(&bo, num, fmt_ulong(num, (unsigned long)i)) == -1) _exit(1);
+  if (buffer_puts(&bo, "\n") == -1) _exit(1);
   if (buffer_flush(&bo) == -1) _exit(1);
 }
 
 char bufspace[1024];
-buffer bi = BUFFER_INIT(read,0,bufspace,sizeof(bufspace)); 
+buffer bi = BUFFER_INIT(read, 0, bufspace, sizeof(bufspace));
 
-void mrtg_results(char flag) 
+void mrtg_results(char flag)
 {
   switch (flag) {
-    case  '1': out(success); out(tlstrans); break;
-    case  '2': bytes = bytes/1024; out(bytes); out(bytes); break;
-    case  '3': out(local); out(remote); break;
-    case  '4': out(failure); out(deferral); break;
-    case  '5': out(bounces); out(triples); break;
-    case  '6': qmtps += qmtp; out(qmtp); out(qmtps); break; /* QMTP */ 
-
-    case  'a': out(asessions); out(rsessions); break; /* total */
-    case  'b': out(aorig); out(arcpt); break; /* accepted */
-    case  'c': out(rsend); out(rhelo); break; /* rejected MTA */
-    case  'd': out(rorigbad); out(rorigdns); break; /* Orig */
-    case  'e': out(rrcptbad); out(rrcptfail); break; /* Recipient */
-    case  'f': out(rmime); out(rloader); break; /* Warlord */
-    case  'g': out(rvirus); out(rspam); break; /* Infected/Spam */
-    case  'h': out(aauth); out(rauth); break; /* Auth */
-    case  'i': out(atls); out(rtls); break;  /* TLS */  
-    case  'j': out(spfpass); out(spfail); break; /* SPF */
-    case  'k': out(grey);  break; /* Greylisted */
-    case  'z': sdeny +=rbl; out(sok); out(sdeny); break; /* reject session */
-
-    case  'A': out(apop); out(rpop); break;
-    case  'B': out(pok); out(pdeny); break;
+    case '1':
+      out(success);
+      out(tlstrans);
+      break;
+    case '2':
+      bytes = bytes / 1024;
+      out(bytes);
+      out(bytes);
+      break;
+    case '3':
+      out(local);
+      out(remote);
+      break;
+    case '4':
+      out(failure);
+      out(deferral);
+      break;
+    case '5':
+      out(bounces);
+      out(triples);
+      break;
+    case '6':
+      qmtps += qmtp;
+      out(qmtp);
+      out(qmtps);
+      break; /* QMTP */
+
+    case 'a':
+      out(asessions);
+      out(rsessions);
+      break; /* total */
+    case 'b':
+      out(aorig);
+      out(arcpt);
+      break; /* accepted */
+    case 'c':
+      out(rsend);
+      out(rhelo);
+      break; /* rejected MTA */
+    case 'd':
+      out(rorigbad);
+      out(rorigdns);
+      break; /* Orig */
+    case 'e':
+      out(rrcptbad);
+      out(rrcptfail);
+      break; /* Recipient */
+    case 'f':
+      out(rmime);
+      out(rloader);
+      break; /* Warlord */
+    case 'g':
+      out(rvirus);
+      out(rspam);
+      break; /* Infected/Spam */
+    case 'h':
+      out(aauth);
+      out(rauth);
+      break; /* Auth */
+    case 'i':
+      out(atls);
+      out(rtls);
+      break; /* TLS */
+    case 'j':
+      out(spfpass);
+      out(spfail);
+      break;                    /* SPF */
+    case 'k': out(grey); break; /* Greylisted */
+    case 'z':
+      sdeny += rbl;
+      out(sok);
+      out(sdeny);
+      break; /* reject session */
+
+    case 'A':
+      out(apop);
+      out(rpop);
+      break;
+    case 'B':
+      out(pok);
+      out(pdeny);
+      break;
 
     default: break;
   }
 }
 
-void mrtg_sendlog(char *in, char flag) 
+void mrtg_sendlog(char *in, char flag)
 {
   int i, j, k = 0;
 
-  switch (flag) { 
-    case  '1': if (case_starts(in,"delivery")) {
-                 i = str_chr(in,':') + 2;
-                 if (case_starts(in + i,"success:")) success++;
-                 i = str_chr(in,'T');
-                 if (case_starts(in + i,"TLS_")) tlstrans++;
-               }; break;
-    case  '2': if (case_starts(in,"info msg")) {
-                  i = str_chr(in,':') + 8;
-                  if ((j = str_chr(in + i,' '))) in[i + j] = '\0';
-                  bytes += atoi(in + i); 
-               }; break;
-    case  '3': if (case_starts(in,"status:")) {
-                 i = str_rchr(in,'c') + 4;
-                 k = str_rchr(in,'r') + 7;
-                 if ((j = str_chr(in + i,'/'))) in[i + j] = '\0';
-                 if (atoi(in + i) > local) local = atoi(in + i); 
-                 if ((j = str_chr(in + k,'/'))) in[k + j] = '\0';
-                 if (atoi(in + k) > remote) remote = atoi(in + k); 
-               }; break;
-    case  '4': if (case_starts(in,"delivery")) {
-                 i = str_chr(in,':') + 2;
-                 if (case_starts(in + i,"failure:")) failure++; 
-                 if (case_starts(in + i,"deferral:")) deferral++; 
-               }; break;
-    case  '5': if (case_starts(in,"bounce msg")) bounces++;
-               if (case_starts(in,"triple bounce:")) triples++;
-               break;
-    case  '6': if (case_starts(in,"delivery")) {
-                 i = str_chr(in,'q');
-                 if (case_starts(in + i,"qmtp:_ok")) qmtp++;
-                 if (case_starts(in + i,"qmtps:_ok")) qmtps++;
-               }; break;
-    default:   break;
+  switch (flag) {
+    case '1':
+      if (case_starts(in, "delivery")) {
+        i = str_chr(in, ':') + 2;
+        if (case_starts(in + i, "success:")) success++;
+        i = str_chr(in, 'T');
+        if (case_starts(in + i, "TLS_")) tlstrans++;
+      };
+      break;
+    case '2':
+      if (case_starts(in, "info msg")) {
+        i = str_chr(in, ':') + 8;
+        if ((j = str_chr(in + i, ' '))) in[i + j] = '\0';
+        bytes += atoi(in + i);
+      };
+      break;
+    case '3':
+      if (case_starts(in, "status:")) {
+        i = str_rchr(in, 'c') + 4;
+        k = str_rchr(in, 'r') + 7;
+        if ((j = str_chr(in + i, '/'))) in[i + j] = '\0';
+        if (atoi(in + i) > local) local = atoi(in + i);
+        if ((j = str_chr(in + k, '/'))) in[k + j] = '\0';
+        if (atoi(in + k) > remote) remote = atoi(in + k);
+      };
+      break;
+    case '4':
+      if (case_starts(in, "delivery")) {
+        i = str_chr(in, ':') + 2;
+        if (case_starts(in + i, "failure:")) failure++;
+        if (case_starts(in + i, "deferral:")) deferral++;
+      };
+      break;
+    case '5':
+      if (case_starts(in, "bounce msg")) bounces++;
+      if (case_starts(in, "triple bounce:")) triples++;
+      break;
+    case '6':
+      if (case_starts(in, "delivery")) {
+        i = str_chr(in, 'q');
+        if (case_starts(in + i, "qmtp:_ok")) qmtp++;
+        if (case_starts(in + i, "qmtps:_ok")) qmtps++;
+      };
+      break;
+    default: break;
   }
 }
 
-void mrtg_smtplog(char *in, char flag) 
+void mrtg_smtplog(char *in, char flag)
 {
   int i, j, k = 0;
 
-  i = str_chr(in,'A');
-  j = str_chr(in,'R');
-  k = str_chr(in,'P');
+  i = str_chr(in, 'A');
+  j = str_chr(in, 'R');
+  k = str_chr(in, 'P');
 
   switch (flag) {
-    case  'a': if (case_starts(in + i,"Accept")) asessions++;
-               if (case_starts(in + j,"Reject")) rsessions++;
-               break;
-    case  'b': if (case_starts(in + i,"Accept::ORIG:")) aorig++; 
-               if (case_starts(in + i,"Accept::RCPT:")) arcpt++; 
-               break;
-    case  'c': if (case_starts(in + j,"Reject::SNDR::Invalid_Relay")) rsend++;
-               if (case_starts(in + j,"Reject::SNDR::Bad_Helo")) rhelo++; 
-               if (case_starts(in + j,"Reject::SNDR::DNS_Helo")) rhelo++; 
-               break;
-    case  'd': if (case_starts(in + j,"Reject::ORIG::Bad_Mailfrom")) rorigbad++;
-               if (case_starts(in + j,"Reject::ORIG::DNS_MF")) rorigdns++;
-               break;
-    case  'e': if (case_starts(in + j,"Reject::RCPT::Bad_Rcptto")) rrcptbad++;
-               if (case_starts(in + j,"Reject::RCPT::Failed_Rcptto")) rrcptfail++; 
-               break;
-    case  'f': if (case_starts(in + j,"Reject::DATA::Invalid_Size")) rsize++;
-               if (case_starts(in + j,"Reject::DATA::Bad_MIME")) rmime++;
-               if (case_starts(in + j,"Reject::DATA::MIME_Attach")) rmime++;
-               if (case_starts(in + j,"Reject::DATA::Bad_Loader")) rloader++;
-               break;
-    case  'g': if (case_starts(in + j,"Reject::DATA::Spam_Message")) rspam++;
-               if (case_starts(in + j,"Reject::DATA::Virus_Infected")) rvirus++;
-               break;
-    case  'h': if (case_starts(in + i,"Accept::AUTH:")) aauth++;
-               if (case_starts(in + j,"Reject::AUTH:")) rauth++;
-               break;
-    case  'i': if (case_starts(in + k,"P:ESMTPS")) atls++;
-               if (case_starts(in + j,"Reject::TLS:")) rtls++;
-               break;
-    case  'j': if (case_starts(in + i,"Accept::SPF:")) spfpass++;
-               if (case_starts(in + j,"Reject::SPF:")) spfail++;
-               break;
-    case  'k': if (case_starts(in + i,"Deferred::SNDR::Grey_Listed")) grey++;
-               break;
-    case  'z': if (case_starts(in,"tcpserver") || case_starts(in,"sslserver") || case_starts(in,"rblsmtpd")) { 
-                 i = str_chr(in,':') + 2;
-                 if (case_starts(in + i,"ok")) sok++;
-                 if (case_starts(in + i,"deny")) sdeny++;
-                 j = str_chr(in+i,':') + 2;
-                 if (case_starts(in + i + j,"451")) rbl++;
-                 if (case_starts(in + i + j,"553")) rbl++;
-                 if (case_starts(in + i + j,"greetdelay:")) greet++;
-               } break;
-    default:   break;
+    case 'a':
+      if (case_starts(in + i, "Accept")) asessions++;
+      if (case_starts(in + j, "Reject")) rsessions++;
+      break;
+    case 'b':
+      if (case_starts(in + i, "Accept::ORIG:")) aorig++;
+      if (case_starts(in + i, "Accept::RCPT:")) arcpt++;
+      break;
+    case 'c':
+      if (case_starts(in + j, "Reject::SNDR::Invalid_Relay")) rsend++;
+      if (case_starts(in + j, "Reject::SNDR::Bad_Helo")) rhelo++;
+      if (case_starts(in + j, "Reject::SNDR::DNS_Helo")) rhelo++;
+      break;
+    case 'd':
+      if (case_starts(in + j, "Reject::ORIG::Bad_Mailfrom")) rorigbad++;
+      if (case_starts(in + j, "Reject::ORIG::DNS_MF")) rorigdns++;
+      break;
+    case 'e':
+      if (case_starts(in + j, "Reject::RCPT::Bad_Rcptto")) rrcptbad++;
+      if (case_starts(in + j, "Reject::RCPT::Failed_Rcptto")) rrcptfail++;
+      break;
+    case 'f':
+      if (case_starts(in + j, "Reject::DATA::Invalid_Size")) rsize++;
+      if (case_starts(in + j, "Reject::DATA::Bad_MIME")) rmime++;
+      if (case_starts(in + j, "Reject::DATA::MIME_Attach")) rmime++;
+      if (case_starts(in + j, "Reject::DATA::Bad_Loader")) rloader++;
+      break;
+    case 'g':
+      if (case_starts(in + j, "Reject::DATA::Spam_Message")) rspam++;
+      if (case_starts(in + j, "Reject::DATA::Virus_Infected")) rvirus++;
+      break;
+    case 'h':
+      if (case_starts(in + i, "Accept::AUTH:")) aauth++;
+      if (case_starts(in + j, "Reject::AUTH:")) rauth++;
+      break;
+    case 'i':
+      if (case_starts(in + k, "P:ESMTPS")) atls++;
+      if (case_starts(in + j, "Reject::TLS:")) rtls++;
+      break;
+    case 'j':
+      if (case_starts(in + i, "Accept::SPF:")) spfpass++;
+      if (case_starts(in + j, "Reject::SPF:")) spfail++;
+      break;
+    case 'k':
+      if (case_starts(in + i, "Deferred::SNDR::Grey_Listed")) grey++;
+      break;
+    case 'z':
+      if (case_starts(in, "tcpserver") || case_starts(in, "sslserver") || case_starts(in, "rblsmtpd")) {
+        i = str_chr(in, ':') + 2;
+        if (case_starts(in + i, "ok")) sok++;
+        if (case_starts(in + i, "deny")) sdeny++;
+        j = str_chr(in + i, ':') + 2;
+        if (case_starts(in + i + j, "451")) rbl++;
+        if (case_starts(in + i + j, "553")) rbl++;
+        if (case_starts(in + i + j, "greetdelay:")) greet++;
+      }
+      break;
+    default: break;
   }
-} 
+}
 
-void mrtg_pop3log(char *in, char flag) 
+void mrtg_pop3log(char *in, char flag)
 {
   int i, j = 0;
 
   switch (flag) {
-    case  'A': i = str_chr(in,'A'); j = str_chr(in,'R');
-               if (case_starts(in + i,"Accept::AUTH:")) apop++;
-               if (case_starts(in + j,"Reject::AUTH:")) rpop++;
-               break;
-    case  'B': if (case_starts(in,"tcpserver:") || case_starts(in,"sslserver:")) { 
-                 i = str_chr(in,':') + 2;
-                 if (case_starts(in + i,"ok")) pok++;
-                 if (case_starts(in + i,"deny")) pdeny++;
-               }; break;
-    default:   break;
+    case 'A':
+      i = str_chr(in, 'A');
+      j = str_chr(in, 'R');
+      if (case_starts(in + i, "Accept::AUTH:")) apop++;
+      if (case_starts(in + j, "Reject::AUTH:")) rpop++;
+      break;
+    case 'B':
+      if (case_starts(in, "tcpserver:") || case_starts(in, "sslserver:")) {
+        i = str_chr(in, ':') + 2;
+        if (case_starts(in + i, "ok")) pok++;
+        if (case_starts(in + i, "deny")) pdeny++;
+      };
+      break;
+    default: break;
   }
 }
 
-int main(int argc, char **argv) 
+int main(int argc, char **argv)
 {
   int i;
   int c;
@@ -258,27 +348,34 @@ int main(int argc, char **argv)
   stralloc line = {0};
   calltime = now();
 
-  if (argc < 2) 
-    logmsg(WHO,100,USAGE,"qmail-mrtg [ -1 | -2 | -3 | -4 | -5 | -6 |\
+  if (argc < 2)
+    logmsg(
+        WHO,
+        100,
+        USAGE,
+        "qmail-mrtg [ -1 | -2 | -3 | -4 | -5 | -6 |\
  -a | -b | -c | -d | -e | -f | -g | -h | -i | -j | -k | -z | -A | -B ] [time] \n\
  qmail-mrtg needs to be called every [time] minutes (i.e. by crontab) - default 305 secs");
 
   flag = *(argv[1] + 1);
-  if (argc == 3) { scan_ulong(argv[2],&u); history = 60 * u; }
+  if (argc == 3) {
+    scan_ulong(argv[2], &u);
+    history = 60 * u;
+  }
 
-/* Read input lines sequentially */
+  /* Read input lines sequentially */
 
-  buffer_init(&bi,read,0,bufspace,sizeof(bufspace));
+  buffer_init(&bi, read, 0, bufspace, sizeof(bufspace));
 
   for (;;) {
-    if (getln(&bi,&line,&match,'\n') != 0) _exit(1);
+    if (getln(&bi, &line, &match, '\n') != 0) _exit(1);
     if (!match) break;
     if (!stralloc_0(&line)) _exit(1);
 
     seconds = 0;
     nanoseconds = 0;
 
-    if (line.s[0] == '@') {	/* tai64 timestamp */
+    if (line.s[0] == '@') { /* tai64 timestamp */
       for (i = 1; i <= TAI64NLEN; i++) {
         c = (int)line.s[i];
         u = c - '0';
@@ -300,23 +397,26 @@ int main(int argc, char **argv)
       _exit(1);
     }
 
-    if (enoughtime) {		/* default history = 305 sec => evaluate logs every ~5 mins */
+    if (enoughtime) { /* default history = 305 sec => evaluate logs every ~5 mins */
       if (seconds <= calltime && seconds >= (calltime - history)) {
-        if (flag >= '1' && flag <= '9') mrtg_sendlog(line.s + TAI64NLEN + 2,flag);
-        else if (flag >= 'a' && flag <= 'z') mrtg_smtplog(line.s + TAI64NLEN + 2,flag);
-        else if (flag >= 'A' && flag <= 'Z') mrtg_pop3log(line.s + TAI64NLEN + 2,flag);
+        if (flag >= '1' && flag <= '9')
+          mrtg_sendlog(line.s + TAI64NLEN + 2, flag);
+        else if (flag >= 'a' && flag <= 'z')
+          mrtg_smtplog(line.s + TAI64NLEN + 2, flag);
+        else if (flag >= 'A' && flag <= 'Z')
+          mrtg_pop3log(line.s + TAI64NLEN + 2, flag);
       }
-    } else { 
+    } else {
       if (seconds) {
         enoughtime++;
       } else {
         outs("Warning: Not enough time left between calls");
         _exit(1);
-      } 
+      }
     }
   }
 
   mrtg_results(flag);
-  
+
   _exit(0);
 }