New properly-asynchronous adnsresfilter seems to work.

diff --git a/client/Makefile.in b/client/Makefile.in
index 770d8acc5b089935dd428e8c515374aaaa46fee6..ee0053957c3fc2b16fb896508855068d6551d901 100644 (file)
--- a/client/Makefile.in
+++ b/client/Makefile.in
@@ -26,17 +26,22 @@ VPATH=              @srcdir@
 
 PROGRAMS=      adnstest adnslogres adnshost adnsresfilter
 PROGRAMS_LOCAL=        fanftest
 
 PROGRAMS=      adnstest adnslogres adnshost adnsresfilter
 PROGRAMS_LOCAL=        fanftest

+PROGRAMS_ALL=  $(PROGRAMS) $(PROGRAMS_LOCAL)

 
 TARG_INSTALL=  $(PROGRAMS)
 
 TARG_INSTALL=  $(PROGRAMS)

-TARG_LOCAL=    $(addsuffix _s, $(PROGRAMS) $(PROGRAMS_LOCAL))
+TARG_LOCAL=    $(addsuffix _s, $(PROGRAMS_ALL))

 TARGETS=       $(TARG_LOCAL) $(TARG_INSTALL)
 include                $(srcdir)/../settings.make
 
 DIRCFLAGS=     -I$(srcdir)/../src
 
 TARGETS=       $(TARG_LOCAL) $(TARG_INSTALL)
 include                $(srcdir)/../settings.make
 
 DIRCFLAGS=     -I$(srcdir)/../src
 

+TARG_OBJS=     $(addsuffix .o, $(PROGRAMS_ALL))

 ADH_OBJS=      adh-main.o adh-opts.o adh-query.o
 ADH_OBJS=      adh-main.o adh-opts.o adh-query.o

+ALL_OBJS=      $(ADH_OBJS) $(TARG_OBJS)

 
 

-STATIC_LIB=    $(srcdir)/../src/libadns.a
+ADNSDIR=       $(srcdir)/../src/
+
+STATIC_LIB=    $(ADNSDIR)/libadns.a

 DYNAMIC_DEP=   $(srcdir)/../dynamic/$(SHLIBFILE)
 DYNAMIC_LINK=  -L$(srcdir)/../dynamic -ladns
 
 DYNAMIC_DEP=   $(srcdir)/../dynamic/$(SHLIBFILE)
 DYNAMIC_LINK=  -L$(srcdir)/../dynamic -ladns
 


@@ -49,16 +54,19 @@ install:    $(TARG_INSTALL)
 uninstall:
                for f in $(TARGETS); do rm -f $(bin_dir)/$$f; done
 
 uninstall:
                for f in $(TARGETS); do rm -f $(bin_dir)/$$f; done
 

-$(ADH_OBJS):   adnshost.h
-

 adnshost:      $(ADH_OBJS) $(DYNAMIC_DEP)
                $(CC) $(LDFLAGS) $(ADH_OBJS) $(DYNAMIC_LINK) -o $@ $(LDLIBS)
 
 adnshost_s:    $(ADH_OBJS) $(STATIC_LIB)
                $(CC) $(LDFLAGS) $(ADH_OBJS) $(STATIC_LIB) -o $@ $(LDLIBS)
 
 adnshost:      $(ADH_OBJS) $(DYNAMIC_DEP)
                $(CC) $(LDFLAGS) $(ADH_OBJS) $(DYNAMIC_LINK) -o $@ $(LDLIBS)
 
 adnshost_s:    $(ADH_OBJS) $(STATIC_LIB)
                $(CC) $(LDFLAGS) $(ADH_OBJS) $(STATIC_LIB) -o $@ $(LDLIBS)
 

+$(ADH_OBJS):           adnshost.h
+$(ALL_OBJS):           $(ADNSDIR)/adns.h $(ADNSDIR)/config.h
+adnsresfilter.o:       $(ADNSDIR)/tvarith.h
+

 %:             %.o $(DYNAMIC_DEP)
                $(CC) $(LDFLAGS) $< $(DYNAMIC_LINK) -o $@ $(LDLIBS)
 
 %_s:           %.o $(STATIC_LIB)
                $(CC) $(LDFLAGS) $< $(STATIC_LIB) -o $@ $(LDLIBS)
 %:             %.o $(DYNAMIC_DEP)
                $(CC) $(LDFLAGS) $< $(DYNAMIC_LINK) -o $@ $(LDLIBS)
 
 %_s:           %.o $(STATIC_LIB)
                $(CC) $(LDFLAGS) $< $(STATIC_LIB) -o $@ $(LDLIBS)

+

diff --git a/client/adnsresfilter.c b/client/adnsresfilter.c
index d091def4323124ae6c1c400d56205e3e68812058..136929d24fdfb2589bb6800fe98abdba0662fc04 100644 (file)
--- a/client/adnsresfilter.c
+++ b/client/adnsresfilter.c
@@ -49,7 +49,8 @@ struct outqueuenode {
   struct treething *addr;
 };
 
   struct treething *addr;
 };
 

-static int bracket, forever, timeout=10;
+static int bracket, forever;
+static unsigned long timeout=100;

 static adns_rrtype rrt= adns_r_ptr;
 
 static int outblocked, inputeof;
 static adns_rrtype rrt= adns_r_ptr;
 
 static int outblocked, inputeof;


@@ -110,7 +111,7 @@ static void usage(void) {
             "       adnsresfilter  -h|--help\n"
             "options: -b|--brackets\n"
             "         -w|--wait\n"
             "       adnsresfilter  -h|--help\n"
             "options: -b|--brackets\n"
             "         -w|--wait\n"

-            "         -t<timeout>|--timeout <timeout>\n"
+            "         -t<timeout>|--timeout <milliseconds>\n"

             "         -u|--unchecked\n")
       == EOF) outputerr();
 }
             "         -u|--unchecked\n")
       == EOF) outputerr();
 }


@@ -128,8 +129,10 @@ static void adnsfail(const char *what, int e) {
   quit(2);
 }
 
   quit(2);
 }
 

-static int comparer(const void *a, const void *b) {
-  return memcmp(a,b,4);
+static void settimeout(const char *arg) {
+  char *ep;
+  timeout= strtoul(arg,&ep,0);
+  if (*ep) usageerr("invalid timeout");

 }
 
 static void parseargs(const char *const *argv) {
 }
 
 static void parseargs(const char *const *argv) {


@@ -147,6 +150,10 @@ static void parseargs(const char *const *argv) {
        forever= 1;
       } else if (!strcmp(arg,"--help")) {
        usage(); quit(0);
        forever= 1;
       } else if (!strcmp(arg,"--help")) {
        usage(); quit(0);

+      } else if (!strcmp(arg,"--timeout")) {
+       if (!(arg= *++argv)) usageerr("--timeout needs a value");
+       settimeout(arg);
+       forever= 0;

       } else {
        usageerr("unknown long option");
       }
       } else {
        usageerr("unknown long option");
       }


@@ -163,7 +170,15 @@ static void parseargs(const char *const *argv) {
          forever= 1;
          break;
        case 'h':
          forever= 1;
          break;
        case 'h':

-         usage(); quit(0);
+         usage();
+         quit(0);
+       case 't':
+         if (*++arg) settimeout(arg);
+         else if ((arg= *++argv)) settimeout(arg);
+         else usageerr("-t needs a value");
+         forever= 0;
+         arg= "\0";
+         break;

        default:
          usageerr("unknown short option");
        }
        default:
          usageerr("unknown short option");
        }


@@ -176,10 +191,10 @@ static void queueoutchar(int c) {
   struct outqueuenode *entry;
   
   entry= outqueue.tail;
   struct outqueuenode *entry;
   
   entry= outqueue.tail;

-  if (!entry->back || entry->addr || entry->textlen >= peroutqueuenode) {
+  if (!entry || entry->addr || entry->textlen >= peroutqueuenode) {
+    peroutqueuenode= !peroutqueuenode || !entry || entry->addr ? 128 : 
+      peroutqueuenode >= 1024 ? 4096 : peroutqueuenode<<2;

     entry= xmalloc(sizeof(*entry));
     entry= xmalloc(sizeof(*entry));

-    peroutqueuenode= !entry->back || entry->addr ? 32 : 
-      peroutqueuenode >= 1024 ? 2048 : peroutqueuenode<<1;

     entry->buffer= xmalloc(peroutqueuenode);
     entry->textp= entry->buffer;
     entry->textlen= 0;
     entry->buffer= xmalloc(peroutqueuenode);
     entry->textp= entry->buffer;
     entry->textlen= 0;


@@ -187,12 +202,11 @@ static void queueoutchar(int c) {
     LIST_LINK_TAIL(outqueue,entry);
     outqueuelen++;
   }
     LIST_LINK_TAIL(outqueue,entry);
     outqueuelen++;
   }

-  *entry->textp++= c;
-  entry->textlen++;
+  entry->textp[entry->textlen++]= c;

 }
 
 static void queueoutstr(const char *str, int len) {
 }
 
 static void queueoutstr(const char *str, int len) {

-  while (len > 0) queueoutchar(*str++);
+  while (len-- > 0) queueoutchar(*str++);

 }
 
 static void writestdout(struct outqueuenode *entry) {
 }
 
 static void writestdout(struct outqueuenode *entry) {


@@ -205,7 +219,7 @@ static void writestdout(struct outqueuenode *entry) {
       if (errno == EAGAIN) { outblocked= 1; break; }
       sysfail("write stdout");
     }
       if (errno == EAGAIN) { outblocked= 1; break; }
       sysfail("write stdout");
     }

-    assert(r < entry->textlen);
+    assert(r <= entry->textlen);

     entry->textp += r;
     entry->textlen -= r;
   }
     entry->textp += r;
     entry->textlen -= r;
   }


@@ -247,6 +261,10 @@ static void restartbuf(void) {
   inbuf= 0;
 }
 
   inbuf= 0;
 }
 

+static int comparer(const void *a, const void *b) {
+  return memcmp(a,b,4);
+}
+

 static void procaddr(void) {
   struct treething *foundthing;
   void **searchfound;
 static void procaddr(void) {
   struct treething *foundthing;
   void **searchfound;


@@ -265,6 +283,7 @@ static void procaddr(void) {
   foundthing= *searchfound;
 
   if (foundthing == newthing) {
   foundthing= *searchfound;
 
   if (foundthing == newthing) {

+    newthing= 0;

     memcpy(&sa.sin_addr,bytes,4);
     r= adns_submit_reverse(ads, (const struct sockaddr*)&sa,
                           rrt,0,foundthing,&foundthing->qu);
     memcpy(&sa.sin_addr,bytes,4);
     r= adns_submit_reverse(ads, (const struct sockaddr*)&sa,
                           rrt,0,foundthing,&foundthing->qu);


@@ -276,6 +295,7 @@ static void procaddr(void) {
   memcpy(entry->textp,addrtextbuf,inbuf);
   entry->textlen= inbuf;
   entry->addr= foundthing;
   memcpy(entry->textp,addrtextbuf,inbuf);
   entry->textlen= inbuf;
   entry->addr= foundthing;

+  entry->printbefore= printbefore;

   LIST_LINK_TAIL(outqueue,entry);
   outqueuelen++;
   inbuf= 0;
   LIST_LINK_TAIL(outqueue,entry);
   outqueuelen++;
   inbuf= 0;


@@ -297,7 +317,7 @@ static void readstdin(void) {
     if (r != EINTR) sysfail("read stdin");
   }
   for (p=readbuf; r>0; r--,p++) {
     if (r != EINTR) sysfail("read stdin");
   }
   for (p=readbuf; r>0; r--,p++) {

-    c= *p++;
+    c= *p;

     if (cbyte==-1 && bracket && c=='[') {
       addrtextbuf[inbuf++]= c;
       startaddr();
     if (cbyte==-1 && bracket && c=='[') {
       addrtextbuf[inbuf++]= c;
       startaddr();


@@ -333,7 +353,6 @@ static void readstdin(void) {
 static void startup(void) {
   int r;
 
 static void startup(void) {
   int r;
 

-  if (setvbuf(stdout,0,_IOLBF,0)) sysfail("setvbuf stdout");

   if (nonblock(0,1)) sysfail("set stdin to nonblocking mode");
   if (nonblock(1,1)) sysfail("set stdout to nonblocking mode");
   memset(&sa,0,sizeof(sa));
   if (nonblock(0,1)) sysfail("set stdin to nonblocking mode");
   if (nonblock(1,1)) sysfail("set stdout to nonblocking mode");
   memset(&sa,0,sizeof(sa));


@@ -362,7 +381,8 @@ int main(int argc, const char *const *argv) {
       if (!entry->addr) {
        writestdout(entry);
        continue;
       if (!entry->addr) {
        writestdout(entry);
        continue;

-      } else if (entry->addr->ans) {
+      }
+      if (entry->addr->ans) {

        if (entry->addr->ans->nrrs) 
          replacetextwithname(entry);
        entry->addr= 0;
        if (entry->addr->ans->nrrs) 
          replacetextwithname(entry);
        entry->addr= 0;


@@ -375,8 +395,8 @@ int main(int argc, const char *const *argv) {
        entry->addr= 0;
        continue;
       } else {
        entry->addr= 0;
        continue;
       } else {

-       tvbuf.tv_sec= printbefore.tv_sec - now.tv_sec - 1;
-       tvbuf.tv_usec= printbefore.tv_usec - now.tv_usec + 1000000;
+       tvbuf.tv_sec= entry->printbefore.tv_sec - now.tv_sec - 1;
+       tvbuf.tv_usec= entry->printbefore.tv_usec - now.tv_usec + 1000000;

        tvbuf.tv_sec += tvbuf.tv_usec / 1000000;
        tvbuf.tv_usec %= 1000000;
        tv= &tvbuf;
        tvbuf.tv_sec += tvbuf.tv_usec / 1000000;
        tvbuf.tv_usec %= 1000000;
        tv= &tvbuf;


@@ -385,7 +405,7 @@ int main(int argc, const char *const *argv) {
                        &tv,&tvbuf,&now);
     }
     if (outblocked) FD_SET(1,&writefds);
                        &tv,&tvbuf,&now);
     }
     if (outblocked) FD_SET(1,&writefds);

-    if (!inputeof && outqueuelen<1000) FD_SET(0,&readfds);
+    if (!inputeof && outqueuelen<1024) FD_SET(0,&readfds);

     
     r= select(maxfd,&readfds,&writefds,&exceptfds,tv);
     if (r < 0) { if (r == EINTR) continue; else sysfail("select"); }
     
     r= select(maxfd,&readfds,&writefds,&exceptfds,tv);
     if (r < 0) { if (r == EINTR) continue; else sysfail("select"); }


@@ -404,9 +424,9 @@ int main(int argc, const char *const *argv) {
       outblocked= 0;
     }
   }
       outblocked= 0;
     }
   }

-  if (ferror(stdin) || fclose(stdin)) sysfail("read stdin");
-  if (fclose(stdout)) sysfail("close stdout");

   if (nonblock(0,0)) sysfail("un-nonblock stdin");
   if (nonblock(1,0)) sysfail("un-nonblock stdout");
   if (nonblock(0,0)) sysfail("un-nonblock stdin");
   if (nonblock(1,0)) sysfail("un-nonblock stdout");

+  if (ferror(stdin) || fclose(stdin)) sysfail("read stdin");
+  if (fclose(stdout)) sysfail("close stdout");

   exit(0);
 }
   exit(0);
 }

diff --git a/client/x.gdb b/client/x.gdb
new file mode 100644 (file)
index 0000000..2ee7597
--- /dev/null
+++ b/client/x.gdb
@@ -0,0 +1,2 @@
+file adnsresfilter_s
+set args <testinput -t2000

diff --git a/src/tvarith.h b/src/tvarith.h
index 4a9ba53a6166d49e96d92a406bcb1942a83260c4..202da1f7933a97bd6367933dbd5db86911bc5e5d 100644 (file)
--- a/src/tvarith.h
+++ b/src/tvarith.h
@@ -32,9 +32,9 @@ static inline void timevaladd(struct timeval *tv_io, long ms) {
   struct timeval tmp;
   assert(ms>=0);
   tmp= *tv_io;
   struct timeval tmp;
   assert(ms>=0);
   tmp= *tv_io;

-  tmp.tv_usec += (ms%1000)*1000000;
+  tmp.tv_usec += (ms%1000)*1000;

   tmp.tv_sec += ms/1000;
   tmp.tv_sec += ms/1000;

-  if (tmp.tv_usec >= 1000000) { tmp.tv_sec++; tmp.tv_usec -= 1000; }
+  if (tmp.tv_usec >= 1000000) { tmp.tv_sec++; tmp.tv_usec -= 1000000; }

   *tv_io= tmp;
 }
 
   *tv_io= tmp;
 }