First version from fanf.

diff --git a/client/adnslogres.c b/client/adnslogres.c
new file mode 100644 (file)
index 0000000..7aa46f1
--- /dev/null
+++ b/client/adnslogres.c
@@ -0,0 +1,167 @@
+/*
+ * adnslogres.c
+ * - a replacement for the Apache logresolve program using adns
+ */
+/*
+ *  This file is Copyright (C) 1999 Tony Finch <fanf@demon.net> <dot@dotat.at>
+ *  
+ *  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; either version 2, or (at your option)
+ *  any later version.
+ *  
+ *  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.
+ *  
+ *  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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. 
+ */
+
+static const char * const cvsid =
+       "$Id$";
+
+#include <sys/types.h>
+#include <sys/time.h>
+
+#include <string.h>
+#include <stdlib.h>
+#include <stdio.h>
+#include <ctype.h>
+#include <errno.h>
+
+#include "adns.h"
+
+/* maximum number of concurrent DNS queries */
+#define MAXPENDING 1000
+
+/* maximum length of a line */
+#define MAXLINE 1024
+
+static const char *progname;
+
+static void aargh(const char *msg) {
+  fprintf(stderr, "%s: %s: %s (%d)\n", progname, msg,
+         strerror(errno) ? strerror(errno) : "Unknown error", errno);
+  exit(1);
+}
+
+/*
+ * Parse the IP address and convert to a reverse domain name.
+ */
+static void ipaddr2domain(char *start, char **addr, char **rest, char **domain) {
+  static char buf[30]; /* "123.123.123.123.in-addr.arpa.\0" */
+  char *ptrs[5];
+  int i;
+
+  for (ptrs[0]= start; !isdigit(*ptrs[0]); ptrs[0]++)
+    if (!*ptrs[0])
+      goto invalid;
+  for (i= 1; i < 5; i ++) {
+    ptrs[i]= strchr(ptrs[i-1], (i == 4) ? ' ' : '.');
+    if (!ptrs[i] || ptrs[i]-ptrs[i-1] > 3)
+      goto invalid;
+    else
+      ptrs[i]++;
+  }
+  sprintf(buf, "%.*s.%.*s.%.*s.%.*s.in-addr.arpa.",
+         ptrs[4]-ptrs[3]-1, ptrs[3],
+         ptrs[3]-ptrs[2]-1, ptrs[2],
+         ptrs[2]-ptrs[1]-1, ptrs[1],
+         ptrs[1]-ptrs[0]-1, ptrs[0]);
+  *addr= ptrs[0];
+  *rest= ptrs[4]-1;
+  *domain= buf;
+  return;
+invalid:
+  strcpy(buf, "invalid.");
+  *addr= *rest= NULL;
+  *domain= buf;
+  return;
+}
+
+static void printline(char *start, char *addr, char *rest, char *domain) {
+  if (domain)
+    printf("%.*s%s%s", addr - start, start, domain, rest);
+  else
+    fputs(start, stdout);
+  /* XXX: error checking */
+}
+
+typedef struct logline {
+  struct logline *next;
+  char *start, *addr, *rest;
+  adns_query query;
+} logline;
+
+static logline *readline(adns_state adns) {
+  static char buf[MAXLINE];
+  char *str;
+  logline *line;
+
+  if (fgets(buf, MAXLINE, stdin)) {
+    str= malloc(sizeof(*line) + strlen(buf) + 1);
+    if (!str) aargh("malloc");
+    line= (logline*)str;
+    line->next= NULL;
+    line->start= str+sizeof(logline);
+    strcpy(line->start, buf);
+    ipaddr2domain(line->start, &line->addr, &line->rest, &str);
+    if (adns_submit(adns, str, adns_r_ptr,
+                   adns_qf_quoteok_cname|adns_qf_cname_loose,
+                   NULL, &line->query))
+      aargh("adns_submit");
+    return line;
+  }
+  if (!feof(stdin))
+    aargh("fgets");
+  return NULL;
+}
+       
+static void proclog(void) {
+  int eof, err, len;
+  adns_state adns;
+  adns_answer *answer;
+  logline *head, *tail, *line;
+
+  errno= adns_init(&adns, 0, 0);
+  if (errno) aargh("adns_init");
+  head= tail= readline(adns);
+  len= 1; eof= 0;
+  while (head) {
+    if (eof || len > MAXPENDING)
+      err= adns_wait(adns, &head->query, &answer, NULL);
+    else
+      err= adns_check(adns, &head->query, &answer, NULL);
+    if (err != EWOULDBLOCK) {
+       printline(head->start, head->addr, head->rest,
+                 answer->status == adns_s_ok ? *answer->rrs.str : NULL);
+       line= head; head= head->next;
+       free(line); free(answer);
+       len--;
+    }
+    if (!eof) {
+      line= readline(adns);
+      if (!line)
+       eof= 1;
+      else {
+       if (!head)
+         head = line;
+       else
+         tail->next = line;
+       tail = line;
+       len++;
+      }
+    }
+  }
+  adns_finish(adns);
+}
+
+int main(int argc, char *argv[])
+{
+  progname= *argv;
+  proclog();
+  return 0;
+}