src/submit.c

   1 /**/
   2
   3 #include "adns-internal.h"
   4
   5 static adns_query allocquery(adns_state ads, const char *owner, int ol,
   6                              int qml, int id, adns_rrtype type,
   7                              adns_queryflags flags, void *context) {
   8   adns_query qu;
   9   unsigned char *qm;
  10
  11   qu= malloc(sizeof(*qu)+ol+1+qml); if (!qu) return 0;
  12   qu->next= qu->back= qu->parent= 0;
  13   qu->children.head= qu->children.tail= 0;
  14   qu->siblings.next= qu->siblings.back= 0;
  15   qu->id= id;
  16   qu->type= type;
  17   qu->answer= 0;
  18   qu->flags= flags;
  19   qu->context= context;
  20   qu->udpretries= 0;
  21   qu->sentudp= qu->senttcp= 0;
  22   qu->nextserver= 0;
  23   memcpy(qu->owner,owner,ol); qu->owner[ol]= 0;
  24   qu->querymsg= qm= qu->owner+ol+1;
  25   memcpy(qm,ads->qbuf,qml);
  26   qu->querylen= qml;
  27   return qu;
  28 }
  29
  30 static int failsubmit(adns_state ads, void *context, adns_query *query_r,
  31                       adns_rrtype type, adns_queryflags flags,
  32                       int id, adns_status stat) {
  33   adns_query qu;
  34
  35   qu= allocquery(ads,0,0,0,id,type,flags,context); if (!qu) return errno;
  36   query_fail(ads,qu,stat);
  37   *query_r= qu;
  38   return 0;
  39 }
  40
  41 int adns_submit(adns_state ads,
  42                 const char *owner,
  43                 adns_rrtype type,
  44                 adns_queryflags flags,
  45                 void *context,
  46                 adns_query *query_r) {
  47   adns_query qu;
  48   adns_status stat;
  49   int ol, id, qml;
  50
  51   id= ads->nextid++;
  52
  53   r= gettimeofday(&now,0); if (r) return errno;
  54
  55   ol= strlen(owner);
  56   if (ol<=1 || ol>MAXDNAME+1)
  57     return failsubmit(ads,context,query_r,type,flags,id,adns_s_invaliddomain);
  58   if (owner[ol-1]=='.' && owner[ol-2]!='\\') { flags &= ~adns_f_search; ol--; }
  59
  60   stat= adns__mkquery(ads,owner,ol,id,type,flags,&qml);
  61   if (stat) return failsubmit(ads,context,query_r,type,flags,id,stat);
  62
  63   qu= allocquery(ads,owner,ol,qml,id,type,flags,context); if (!qu) return errno;
  64   adns__query_udp(ads,qu,now);
  65   autosys(ads,now);
  66
  67   *query_r= qu;
  68   return 0;
  69 }
  70
  71 int adns_synchronous(adns_state ads,
  72                      const char *owner,
  73                      adns_rrtype type,
  74                      adns_queryflags flags,
  75                      adns_answer **answer_r) {
  76   adns_query qu;
  77   int r;
  78
  79   r= adns_submit(ads,owner,type,flags,0,&qu);
  80   if (r) return r;
  81
  82   do {
  83     r= adns_wait(ads,&qu,answer_r,0);
  84   } while (r==EINTR);
  85   if (r) adns_cancel(ads,qu);
  86   return r;
  87 }
  88
  89 void adns_cancel(adns_state ads, adns_query query) {
  90   abort(); /* FIXME */
  91 }