/[svn]/ircd-hybrid/branches/8.2.x/src/res.c
ViewVC logotype

Annotation of /ircd-hybrid/branches/8.2.x/src/res.c

Parent Directory Parent Directory | Revision Log Revision Log


Revision 8880 - (hide annotations)
Sun Apr 14 16:02:11 2019 UTC (16 months ago) by michael
File MIME type: text/x-chdr
File size: 18705 byte(s)
- Add address_compare() and make use of it in some places

1 adx 30 /*
2 michael 2916 * ircd-hybrid: an advanced, lightweight Internet Relay Chat Daemon (ircd)
3     *
4 michael 8751 * Copyright (c) 1997-2019 ircd-hybrid development team
5 michael 2916 *
6     * This program is free software; you can redistribute it and/or modify
7     * it under the terms of the GNU General Public License as published by
8     * the Free Software Foundation; either version 2 of the License, or
9     * (at your option) any later version.
10     *
11     * This program is distributed in the hope that it will be useful,
12     * but WITHOUT ANY WARRANTY; without even the implied warranty of
13     * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14     * GNU General Public License for more details.
15     *
16     * You should have received a copy of the GNU General Public License
17     * along with this program; if not, write to the Free Software
18 michael 4564 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
19 michael 2916 * USA
20     */
21    
22 michael 3322 /*! \file res.c
23 michael 2916 * \brief ircd resolver functions
24     * \version $Id$
25     */
26    
27     /*
28 michael 4312 * A rewrite of Darren Reed's original res.c As there is nothing
29     * left of Darren's original code, this is now licensed by the hybrid group.
30 adx 30 * (Well, some of the function names are the same, and bits of the structs..)
31     * You can use it where it is useful, free even. Buy us a beer and stuff.
32     *
33     * The authors takes no responsibility for any damage or loss
34     * of property which results from the use of this software.
35     *
36     * July 1999 - Rewrote a bunch of stuff here. Change hostent builder code,
37     * added callbacks and reference counting of returned hostents.
38     * --Bleep (Thomas Helvey <tomh@inxpress.net>)
39     *
40     * This was all needlessly complicated for irc. Simplified. No more hostent
41 michael 4312 * All we really care about is the IP -> hostname mappings. That's all.
42 adx 30 *
43     * Apr 28, 2003 --cryogen and Dianora
44     */
45    
46     #include "stdinc.h"
47 michael 1011 #include "list.h"
48 adx 30 #include "event.h"
49     #include "irc_string.h"
50     #include "ircd.h"
51 michael 982 #include "rng_mt.h"
52 adx 30 #include "fdlist.h"
53     #include "s_bsd.h"
54 michael 3347 #include "misc.h"
55 michael 3322 #include "res.h"
56     #include "reslib.h"
57 michael 8384 #include "memory.h"
58 adx 30
59     #if (CHAR_BIT != 8)
60 michael 2916 #error this code needs to be able to address individual octets
61 adx 30 #endif
62    
63 michael 4462 static void res_readreply(fde_t *, void *);
64 adx 30
65 michael 4312 #define MAXPACKET 1024 /**< rfc says 512 but we expand names so ... */
66     #define AR_TTL 600 /**< TTL in seconds for dns cache entries */
67 adx 30
68 michael 4312 /*
69     * RFC 1104/1105 wasn't very helpful about what these fields
70 adx 30 * should be named, so for now, we'll just name them this way.
71 michael 4312 * We probably should look at what named calls them or something.
72 adx 30 */
73     #define TYPE_SIZE (size_t)2
74     #define CLASS_SIZE (size_t)2
75     #define TTL_SIZE (size_t)4
76     #define RDLENGTH_SIZE (size_t)2
77     #define ANSWER_FIXED_SIZE (TYPE_SIZE + CLASS_SIZE + TTL_SIZE + RDLENGTH_SIZE)
78    
79 michael 2916 struct reslist
80 adx 30 {
81 michael 4422 dlink_node node; /**< Doubly linked list node. */
82 michael 7594 unsigned int id; /**< Request ID (from request header). */
83 michael 4422 char type; /**< Current request type. */
84     char retries; /**< Retry counter */
85     unsigned int sends; /**< Number of sends (>1 means resent). */
86 michael 7329 uintmax_t sentat; /**< Timestamp we last sent this request. */
87     uintmax_t timeout; /**< When this request times out. */
88 michael 4422 struct irc_ssaddr addr; /**< Address for this request. */
89     char name[RFC1035_MAX_DOMAIN_LENGTH + 1]; /**< Hostname for this request. */
90     size_t namelength; /**< Actual hostname length. */
91     dns_callback_fnc callback; /**< Callback function on completion. */
92     void *callback_ctx; /**< Context pointer for callback. */
93 adx 30 };
94    
95 michael 8338 static fde_t *ResolverFileDescriptor;
96 michael 3235 static dlink_list request_list;
97 adx 30
98    
99 michael 4312 /*
100     * rem_request - remove a request from the list.
101     * This must also free any memory that has been allocated for
102     * temporary storage of DNS results.
103     */
104     static void
105     rem_request(struct reslist *request)
106     {
107     dlinkDelete(&request->node, &request_list);
108 michael 8384 xfree(request);
109 michael 4312 }
110    
111 adx 30 /*
112 michael 4312 * make_request - Create a DNS request record for the server.
113     */
114     static struct reslist *
115     make_request(dns_callback_fnc callback, void *ctx)
116     {
117 michael 8384 struct reslist *request = xcalloc(sizeof(*request));
118 michael 4312
119 michael 7596 request->sentat = CurrentTime;
120     request->retries = 2;
121     request->timeout = 4; /* Start at 4 and exponential inc. */
122     request->callback = callback;
123 michael 4312 request->callback_ctx = ctx;
124    
125     dlinkAdd(request, &request->node, &request_list);
126     return request;
127     }
128    
129     /*
130 adx 30 * int
131     * res_ourserver(inp)
132     * looks up "inp" in irc_nsaddr_list[]
133     * returns:
134     * 0 : not found
135     * >0 : found
136     * author:
137     * paul vixie, 29may94
138     * revised for ircd, cryogen(stu) may03
139     */
140 michael 8657 static bool
141 michael 2916 res_ourserver(const struct irc_ssaddr *inp)
142 adx 30 {
143 michael 3297 for (unsigned int i = 0; i < irc_nscount; ++i)
144 michael 8880 if (address_compare(inp, &irc_nsaddr_list[i], true) == true)
145     return true;
146 adx 30
147 michael 8657 return false;
148 adx 30 }
149    
150     /*
151     * start_resolver - do everything we need to read the resolv.conf file
152     * and initialize the resolver file descriptor if needed
153     */
154     static void
155     start_resolver(void)
156     {
157     irc_res_init();
158    
159 michael 8521 if (ResolverFileDescriptor == NULL)
160 adx 30 {
161 michael 8338 int fd = comm_socket(irc_nsaddr_list[0].ss.ss_family, SOCK_DGRAM, 0);
162     if (fd == -1)
163 adx 30 return;
164    
165 michael 8657 ResolverFileDescriptor = fd_open(fd, true, "UDP resolver socket");
166 michael 8338
167 adx 30 /* At the moment, the resolver FD data is global .. */
168 michael 8338 comm_setselect(ResolverFileDescriptor, COMM_SELECT_READ, res_readreply, NULL, 0);
169 adx 30 }
170     }
171    
172     /*
173     * restart_resolver - reread resolv.conf, reopen socket
174     */
175     void
176     restart_resolver(void)
177     {
178 michael 8362 if (ResolverFileDescriptor)
179     {
180     fd_close(ResolverFileDescriptor);
181     ResolverFileDescriptor = NULL;
182     }
183 michael 8338
184 adx 30 start_resolver();
185     }
186    
187     /*
188 michael 2916 * delete_resolver_queries - cleanup outstanding queries
189 adx 30 * for which there no longer exist clients or conf lines.
190     */
191     void
192 michael 992 delete_resolver_queries(const void *vptr)
193 adx 30 {
194 michael 7913 dlink_node *node, *node_next;
195 adx 30
196 michael 4816 DLINK_FOREACH_SAFE(node, node_next, request_list.head)
197 adx 30 {
198 michael 4816 struct reslist *request = node->data;
199 michael 997
200     if (request->callback_ctx == vptr)
201     rem_request(request);
202 adx 30 }
203     }
204    
205     /*
206     * send_res_msg - sends msg to all nameservers found in the "_res" structure.
207     * This should reflect /etc/resolv.conf. We will get responses
208     * which arent needed but is easier than checking to see if nameserver
209 michael 4299 * isn't present. Returns number of messages successfully sent to
210 adx 30 * nameservers or -1 if no successful sends.
211     */
212 michael 7594 static void
213 michael 4467 send_res_msg(const unsigned char *msg, int len, unsigned int rcount)
214 adx 30 {
215 michael 3297 unsigned int max_queries = IRCD_MIN(irc_nscount, rcount);
216 adx 30
217     /* RES_PRIMARY option is not implemented
218     * if (res.options & RES_PRIMARY || 0 == max_queries)
219     */
220     if (max_queries == 0)
221     max_queries = 1;
222    
223 michael 3297 for (unsigned int i = 0; i < max_queries; ++i)
224 michael 8338 sendto(ResolverFileDescriptor->fd, msg, len, 0,
225 michael 7594 (struct sockaddr *)&irc_nsaddr_list[i], irc_nsaddr_list[i].ss_len);
226 adx 30 }
227    
228     /*
229     * find_id - find a dns request id (id is determined by dn_mkquery)
230     */
231     static struct reslist *
232 michael 7594 find_id(unsigned int id)
233 adx 30 {
234 michael 7913 dlink_node *node;
235 adx 30
236 michael 4816 DLINK_FOREACH(node, request_list.head)
237 adx 30 {
238 michael 4816 struct reslist *request = node->data;
239 adx 30
240     if (request->id == id)
241 michael 1124 return request;
242 adx 30 }
243    
244 michael 1124 return NULL;
245 adx 30 }
246    
247 michael 2916 /*
248 michael 4312 * query_name - generate a query based on class, type and name.
249 adx 30 */
250 michael 4312 static void
251 michael 4467 query_name(const char *name, int query_class, int type, struct reslist *request)
252 adx 30 {
253 michael 4467 unsigned char buf[MAXPACKET];
254 michael 4312 int request_len = 0;
255 adx 30
256 michael 4312 memset(buf, 0, sizeof(buf));
257 adx 30
258 michael 4467 if ((request_len = irc_res_mkquery(name, query_class, type, buf, sizeof(buf))) > 0)
259 michael 4312 {
260     HEADER *header = (HEADER *)buf;
261    
262     /*
263     * Generate an unique id.
264     * NOTE: we don't have to worry about converting this to and from
265     * network byte order, the nameserver does not interpret this value
266     * and returns it unchanged.
267     */
268     do
269     header->id = (header->id + genrand_int32()) & 0xFFFF;
270     while (find_id(header->id));
271    
272     request->id = header->id;
273     ++request->sends;
274    
275 michael 7594 send_res_msg(buf, request_len, request->sends);
276 michael 4312 }
277 adx 30 }
278    
279     /*
280     * do_query_name - nameserver lookup name
281     */
282     static void
283 michael 992 do_query_name(dns_callback_fnc callback, void *ctx, const char *name,
284 adx 30 struct reslist *request, int type)
285     {
286 michael 4409 char host_name[RFC1035_MAX_DOMAIN_LENGTH + 1];
287 adx 30
288 michael 998 strlcpy(host_name, name, sizeof(host_name));
289 adx 30
290 michael 8521 if (request == NULL)
291 adx 30 {
292 michael 7596 request = make_request(callback, ctx);
293     request->type = type;
294 michael 4409 request->namelength = strlcpy(request->name, host_name, sizeof(request->name));
295 adx 30 }
296    
297     request->type = type;
298     query_name(host_name, C_IN, type, request);
299     }
300    
301     /*
302     * do_query_number - Use this to do reverse IP# lookups.
303     */
304     static void
305 michael 992 do_query_number(dns_callback_fnc callback, void *ctx,
306     const struct irc_ssaddr *addr,
307 adx 30 struct reslist *request)
308     {
309 michael 3298 char ipbuf[128] = "";
310 michael 985
311 adx 30 if (addr->ss.ss_family == AF_INET)
312     {
313 michael 992 const struct sockaddr_in *v4 = (const struct sockaddr_in *)addr;
314 michael 3298 const unsigned char *cp = (const unsigned char *)&v4->sin_addr.s_addr;
315 adx 30
316 michael 1124 snprintf(ipbuf, sizeof(ipbuf), "%u.%u.%u.%u.in-addr.arpa.",
317     (unsigned int)(cp[3]), (unsigned int)(cp[2]),
318     (unsigned int)(cp[1]), (unsigned int)(cp[0]));
319 adx 30 }
320     else if (addr->ss.ss_family == AF_INET6)
321     {
322 michael 992 const struct sockaddr_in6 *v6 = (const struct sockaddr_in6 *)addr;
323 michael 3298 const unsigned char *cp = (const unsigned char *)&v6->sin6_addr.s6_addr;
324 adx 30
325 michael 1124 snprintf(ipbuf, sizeof(ipbuf),
326     "%x.%x.%x.%x.%x.%x.%x.%x.%x.%x.%x.%x.%x.%x.%x.%x.%x."
327     "%x.%x.%x.%x.%x.%x.%x.%x.%x.%x.%x.%x.%x.%x.%x.ip6.arpa.",
328     (unsigned int)(cp[15] & 0xf), (unsigned int)(cp[15] >> 4),
329     (unsigned int)(cp[14] & 0xf), (unsigned int)(cp[14] >> 4),
330     (unsigned int)(cp[13] & 0xf), (unsigned int)(cp[13] >> 4),
331     (unsigned int)(cp[12] & 0xf), (unsigned int)(cp[12] >> 4),
332     (unsigned int)(cp[11] & 0xf), (unsigned int)(cp[11] >> 4),
333     (unsigned int)(cp[10] & 0xf), (unsigned int)(cp[10] >> 4),
334     (unsigned int)(cp[9] & 0xf), (unsigned int)(cp[9] >> 4),
335     (unsigned int)(cp[8] & 0xf), (unsigned int)(cp[8] >> 4),
336     (unsigned int)(cp[7] & 0xf), (unsigned int)(cp[7] >> 4),
337     (unsigned int)(cp[6] & 0xf), (unsigned int)(cp[6] >> 4),
338     (unsigned int)(cp[5] & 0xf), (unsigned int)(cp[5] >> 4),
339     (unsigned int)(cp[4] & 0xf), (unsigned int)(cp[4] >> 4),
340     (unsigned int)(cp[3] & 0xf), (unsigned int)(cp[3] >> 4),
341     (unsigned int)(cp[2] & 0xf), (unsigned int)(cp[2] >> 4),
342     (unsigned int)(cp[1] & 0xf), (unsigned int)(cp[1] >> 4),
343     (unsigned int)(cp[0] & 0xf), (unsigned int)(cp[0] >> 4));
344 adx 30 }
345 michael 4414
346 michael 8521 if (request == NULL)
347 adx 30 {
348 michael 7596 request = make_request(callback, ctx);
349 adx 30 request->type = T_PTR;
350     memcpy(&request->addr, addr, sizeof(struct irc_ssaddr));
351     }
352    
353     query_name(ipbuf, C_IN, T_PTR, request);
354     }
355    
356     /*
357 michael 4312 * gethost_byname_type - get host address from name
358     *
359 adx 30 */
360 michael 4312 void
361     gethost_byname_type(dns_callback_fnc callback, void *ctx, const char *name, int type)
362 adx 30 {
363 michael 4312 assert(name);
364     do_query_name(callback, ctx, name, NULL, type);
365     }
366 adx 30
367 michael 4312 /*
368     * gethost_byaddr - get host name from address
369     */
370     void
371     gethost_byaddr(dns_callback_fnc callback, void *ctx, const struct irc_ssaddr *addr)
372     {
373     do_query_number(callback, ctx, addr, NULL);
374 adx 30 }
375    
376     static void
377     resend_query(struct reslist *request)
378     {
379 michael 982 switch (request->type)
380 adx 30 {
381     case T_PTR:
382 michael 992 do_query_number(NULL, NULL, &request->addr, request);
383 adx 30 break;
384     case T_A:
385 michael 4450 case T_AAAA:
386 michael 992 do_query_name(NULL, NULL, request->name, request, request->type);
387 adx 30 break;
388     default:
389     break;
390     }
391     }
392    
393     /*
394     * proc_answer - process name server reply
395     */
396 michael 8657 static bool
397 michael 4458 proc_answer(struct reslist *request, HEADER *header, unsigned char *buf, unsigned char *eob)
398 adx 30 {
399 michael 4409 char hostbuf[RFC1035_MAX_DOMAIN_LENGTH + 100]; /* working buffer */
400 michael 4458 unsigned char *current = buf + sizeof(HEADER); /* current position in buf */
401 michael 4455 unsigned int type = 0; /* answer type */
402     unsigned int rd_length = 0;
403 adx 30 int n; /* temp count */
404     struct sockaddr_in *v4; /* conversion */
405     struct sockaddr_in6 *v6;
406 michael 4414
407 adx 30 for (; header->qdcount > 0; --header->qdcount)
408     {
409 michael 4458 if ((n = irc_dn_skipname(current, eob)) < 0)
410 adx 30 break;
411    
412 michael 1124 current += (size_t)n + QFIXEDSZ;
413 adx 30 }
414    
415     /*
416 michael 4299 * Process each answer sent to us blech.
417 adx 30 */
418 michael 4458 while (header->ancount > 0 && current < eob)
419 adx 30 {
420 michael 7871 --header->ancount;
421 adx 30
422 michael 4458 n = irc_dn_expand(buf, eob, current, hostbuf, sizeof(hostbuf));
423 adx 30
424 michael 4299 if (n < 0 /* Broken message */ || n == 0 /* No more answers left */)
425 michael 8657 return false;
426 adx 30
427 michael 4409 hostbuf[RFC1035_MAX_DOMAIN_LENGTH] = '\0';
428 adx 30
429 michael 4299 /*
430     * With Address arithmetic you have to be very anal
431 adx 30 * this code was not working on alpha due to that
432     * (spotted by rodder/jailbird/dianora)
433     */
434 michael 3298 current += (size_t)n;
435 adx 30
436 michael 4458 if (!((current + ANSWER_FIXED_SIZE) < eob))
437 adx 30 break;
438    
439     type = irc_ns_get16(current);
440     current += TYPE_SIZE;
441     current += CLASS_SIZE;
442     current += TTL_SIZE;
443     rd_length = irc_ns_get16(current);
444     current += RDLENGTH_SIZE;
445    
446 michael 2916 /*
447     * Wait to set request->type until we verify this structure
448 adx 30 */
449     switch (type)
450     {
451     case T_A:
452     if (request->type != T_A)
453 michael 8657 return false;
454 adx 30
455     /*
456 michael 3298 * Check for invalid rd_length or too many addresses
457 adx 30 */
458     if (rd_length != sizeof(struct in_addr))
459 michael 8657 return false;
460 michael 1124
461 michael 4475 request->addr.ss_len = sizeof(struct sockaddr_in);
462 adx 30 v4 = (struct sockaddr_in *)&request->addr;
463     v4->sin_family = AF_INET;
464     memcpy(&v4->sin_addr, current, sizeof(struct in_addr));
465 michael 8657 return true;
466 adx 30 break;
467 michael 8436
468 adx 30 case T_AAAA:
469     if (request->type != T_AAAA)
470 michael 8657 return false;
471 michael 1124
472 adx 30 if (rd_length != sizeof(struct in6_addr))
473 michael 8657 return false;
474 michael 1124
475 adx 30 request->addr.ss_len = sizeof(struct sockaddr_in6);
476     v6 = (struct sockaddr_in6 *)&request->addr;
477     v6->sin6_family = AF_INET6;
478     memcpy(&v6->sin6_addr, current, sizeof(struct in6_addr));
479 michael 8657 return true;
480 adx 30 break;
481 michael 8436
482 adx 30 case T_PTR:
483     if (request->type != T_PTR)
484 michael 8657 return false;
485 michael 1124
486 michael 4458 n = irc_dn_expand(buf, eob, current, hostbuf, sizeof(hostbuf));
487 michael 4299 if (n < 0 /* Broken message */ || n == 0 /* No more answers left */)
488 michael 8657 return false;
489 adx 30
490 michael 4409 request->namelength = strlcpy(request->name, hostbuf, sizeof(request->name));
491 michael 8657 return true;
492 adx 30 break;
493 michael 8436
494 michael 4451 case T_CNAME:
495 adx 30 current += rd_length;
496     break;
497 michael 8436
498 adx 30 default:
499 michael 8657 return false;
500 adx 30 break;
501     }
502     }
503    
504 michael 8657 return false;
505 adx 30 }
506    
507     /*
508     * res_readreply - read a dns reply from the nameserver and process it.
509     */
510     static void
511 michael 8338 res_readreply(fde_t *F, void *data)
512 adx 30 {
513 michael 4458 unsigned char buf[sizeof(HEADER) + MAXPACKET];
514 michael 4302 ssize_t rc = 0;
515 adx 30 socklen_t len = sizeof(struct irc_ssaddr);
516     struct irc_ssaddr lsin;
517    
518 michael 8338 while ((rc = recvfrom(F->fd, buf, sizeof(buf), 0, (struct sockaddr *)&lsin, &len)) != -1)
519 michael 4318 {
520     if (rc <= (ssize_t)sizeof(HEADER))
521     continue;
522 adx 30
523 michael 4318 /*
524     * Check against possibly fake replies
525     */
526 michael 8657 if (res_ourserver(&lsin) == false)
527 michael 4318 continue;
528 michael 984
529 michael 4318 /*
530     * Convert DNS reply reader from Network byte order to CPU byte order.
531     */
532 michael 7596 HEADER *header = (HEADER *)buf;
533 michael 4318 header->ancount = ntohs(header->ancount);
534     header->qdcount = ntohs(header->qdcount);
535     header->nscount = ntohs(header->nscount);
536     header->arcount = ntohs(header->arcount);
537 adx 30
538 michael 4318 /*
539     * Response for an id which we have already received an answer for
540     * just ignore this response.
541     */
542 michael 8521 struct reslist *request;
543 michael 4318 if ((request = find_id(header->id)) == NULL)
544     continue;
545 michael 4238
546 michael 4450 if (header->rcode != NO_ERRORS || header->ancount == 0)
547 michael 4318 {
548 michael 4450 /*
549 michael 7596 * If a bad error was returned, stop here and don't send
550     * any more (no retries granted).
551 michael 4450 */
552     (*request->callback)(request->callback_ctx, NULL, NULL, 0);
553     rem_request(request);
554 michael 4318 continue;
555     }
556 adx 30
557 michael 4318 /*
558     * If this fails there was an error decoding the received packet.
559     * We only give it one shot. If it fails, just leave the client
560     * unresolved.
561     */
562 michael 8657 if (proc_answer(request, header, buf, buf + rc) == false)
563 db 155 {
564 michael 4409 (*request->callback)(request->callback_ctx, NULL, NULL, 0);
565 michael 984 rem_request(request);
566 michael 4318 continue;
567 michael 984 }
568 michael 4318
569     if (request->type == T_PTR)
570 michael 984 {
571 michael 4409 if (request->namelength == 0)
572 michael 4318 {
573     /*
574     * Got a PTR response with no name, something bogus is happening
575     * don't bother trying again, the client address doesn't resolve
576     */
577 michael 4409 (*request->callback)(request->callback_ctx, NULL, NULL, 0);
578 michael 4318 rem_request(request);
579     continue;
580     }
581    
582 michael 2916 /*
583 michael 4318 * Lookup the 'authoritative' name that we were given for the ip#.
584 adx 30 */
585 michael 4318 if (request->addr.ss.ss_family == AF_INET6)
586     gethost_byname_type(request->callback, request->callback_ctx, request->name, T_AAAA);
587     else
588 michael 4414 gethost_byname_type(request->callback, request->callback_ctx, request->name, T_A);
589 michael 7596
590 michael 4318 rem_request(request);
591 michael 984 }
592 michael 4318 else
593 adx 30 {
594     /*
595 michael 4318 * Got a name and address response, client resolved
596 adx 30 */
597 michael 4409 (*request->callback)(request->callback_ctx, &request->addr, request->name, request->namelength);
598 adx 30 rem_request(request);
599     }
600 michael 4315
601 michael 4318 continue;
602 adx 30 }
603 michael 4318
604 michael 8338 comm_setselect(F, COMM_SELECT_READ, res_readreply, NULL, 0);
605 adx 30 }
606    
607 michael 4312 /*
608     * timeout_query_list - Remove queries from the list which have been
609     * there too long without being resolved.
610     */
611 michael 7329 static uintmax_t
612 michael 4312 timeout_query_list(void)
613     {
614 michael 7913 dlink_node *node, *node_next;
615 michael 7329 uintmax_t next_time = 0;
616 michael 4312
617 michael 4816 DLINK_FOREACH_SAFE(node, node_next, request_list.head)
618 michael 4312 {
619 michael 7913 struct reslist *request = node->data;
620     uintmax_t timeout = request->sentat + request->timeout;
621 michael 4312
622     if (CurrentTime >= timeout)
623     {
624     if (--request->retries <= 0)
625     {
626 michael 4409 (*request->callback)(request->callback_ctx, NULL, NULL, 0);
627 michael 4312 rem_request(request);
628     continue;
629     }
630     else
631     {
632     request->sentat = CurrentTime;
633     request->timeout += request->timeout;
634     resend_query(request);
635     }
636     }
637    
638     if (next_time == 0 || timeout < next_time)
639     next_time = timeout;
640     }
641    
642     return (next_time > CurrentTime) ? next_time : (CurrentTime + AR_TTL);
643     }
644    
645     /*
646     * timeout_resolver - check request list
647     */
648     static void
649 michael 4438 timeout_resolver(void *unused)
650 michael 4312 {
651     timeout_query_list();
652     }
653    
654     /*
655 michael 7568 * resolver_init - initialize resolver and resolver library
656 michael 4312 */
657     void
658 michael 7568 resolver_init(void)
659 michael 4312 {
660     static struct event event_timeout_resolver =
661     {
662     .name = "timeout_resolver",
663     .handler = timeout_resolver,
664     .when = 1
665     };
666    
667     start_resolver();
668     event_add(&event_timeout_resolver, NULL);
669     }

Properties

Name Value
svn:eol-style native
svn:keywords Id

svnadmin@ircd-hybrid.org
ViewVC Help
Powered by ViewVC 1.1.28