9 static int udpannounce(char*);
10 static void reply(int, uchar*, DNSmsg*, Request*);
14 typedef struct Inprogress Inprogress;
23 Inprogress inprog[Maxactive+2];
27 * record client id and ignore retransmissions.
30 clientrxmit(DNSmsg *req, uchar *buf)
32 Inprogress *p, *empty;
38 for(p = inprog; p < &inprog[Maxactive]; p++){
45 if(req->qd->owner == p->owner)
46 if(req->qd->type == p->type)
47 if(memcmp(uh, &p->uh, Udphdrsize) == 0){
54 return 0; /* shouldn't happen - see slave() and definition of Maxactive */
58 empty->owner = req->qd->owner;
59 empty->type = req->qd->type;
60 memmove(&empty->uh, uh, Udphdrsize);
67 * a process to act as a dns server for outside reqeusts
74 DNSmsg reqmsg, repmsg;
75 uchar buf[Udphdrsize + Maxudp + 1024];
83 /* loop on requests */
84 for(;; putactivity()){
85 memset(&repmsg, 0, sizeof(repmsg));
86 memset(&reqmsg, 0, sizeof(reqmsg));
87 len = udpread(fd, (Udphdr*)buf, buf+Udphdrsize, sizeof(buf)-Udphdrsize);
92 req.aborttime = now + 30; /* don't spend more than 30 seconds */
93 err = convM2DNS(&buf[Udphdrsize], len, &reqmsg);
95 syslog(0, logfile, "server: input error: %s from %I", err, buf);
98 if(reqmsg.qdcount < 1){
99 syslog(0, logfile, "server: no questions from %I", buf);
102 if(reqmsg.flags & Fresp){
103 syslog(0, logfile, "server: reply not request from %I", buf);
106 op = reqmsg.flags & Omask;
107 if(op != Oquery && op != Onotify){
108 syslog(0, logfile, "server: op %d from %I", reqmsg.flags & Omask, buf);
112 if(debug || (trace && subsume(trace, reqmsg.qd->owner->name))){
113 syslog(0, logfile, "%d: serve (%I/%d) %d %s %s",
114 req.id, buf, ((uh->rport[0])<<8)+uh->rport[1],
116 reqmsg.qd->owner->name,
117 rrname(reqmsg.qd->type, tname, sizeof tname));
120 p = clientrxmit(&reqmsg, buf);
123 syslog(0, logfile, "%d: duplicate", req.id);
127 /* loop through each question */
129 memset(&repmsg, 0, sizeof(repmsg));
132 dnserver(&reqmsg, &repmsg, &req);
135 dnnotify(&reqmsg, &repmsg, &req);
138 reply(fd, buf, &repmsg, &req);
139 rrfreelist(repmsg.qd);
140 rrfreelist(repmsg.an);
141 rrfreelist(repmsg.ns);
142 rrfreelist(repmsg.ar);
148 rrfreelist(reqmsg.qd);
149 rrfreelist(reqmsg.an);
150 rrfreelist(reqmsg.ns);
151 rrfreelist(reqmsg.ar);
156 * announce on udp port
159 udpannounce(char *mntpt)
165 if((fd=announce(udpaddr, buf)) < 0)
166 warning("announce %s: %r", buf);
171 reply(int fd, uchar *buf, DNSmsg *rep, Request *reqp)
177 if(debug || (trace && subsume(trace, rep->qd->owner->name)))
178 syslog(0, logfile, "%d: reply (%I/%d) %d %s %s an %R ns %R ar %R",
179 reqp->id, buf, ((buf[4])<<8)+buf[5],
180 rep->id, rep->qd->owner->name,
181 rrname(rep->qd->type, tname, sizeof tname), rep->an, rep->ns, rep->ar);
183 len = convDNS2M(rep, &buf[Udphdrsize], Maxudp);
185 syslog(0, logfile, "error converting reply: %s %d", rep->qd->owner->name,
187 for(rp = rep->an; rp; rp = rp->next)
188 syslog(0, logfile, "an %R", rp);
189 for(rp = rep->ns; rp; rp = rp->next)
190 syslog(0, logfile, "ns %R", rp);
191 for(rp = rep->ar; rp; rp = rp->next)
192 syslog(0, logfile, "ar %R", rp);
195 if(udpwrite(fd, (Udphdr*)buf, buf+Udphdrsize, len) != len)
196 syslog(0, logfile, "error sending reply: %r");
204 while((fd = udpannounce(v)) < 0)
206 for(i=0; i<Maxactive; i++)
207 proccreate(udpproc, (void*)(uintptr)fd, STACK);