2 * Copyright (C) 2004, 2005 Internet Systems Consortium, Inc. ("ISC")
3 * Copyright (C) 2000, 2001, 2003 Internet Software Consortium.
5 * Permission to use, copy, modify, and distribute this software for any
6 * purpose with or without fee is hereby granted, provided that the above
7 * copyright notice and this permission notice appear in all copies.
9 * THE SOFTWARE IS PROVIDED "AS IS" AND ISC DISCLAIMS ALL WARRANTIES WITH
10 * REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
11 * AND FITNESS. IN NO EVENT SHALL ISC BE LIABLE FOR ANY SPECIAL, DIRECT,
12 * INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
13 * LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE
14 * OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
15 * PERFORMANCE OF THIS SOFTWARE.
18 /* $Id: lookup.c,v 1.14.18.4 2005/11/30 03:44:39 marka Exp $ */
25 #include <isc/netaddr.h>
26 #include <isc/string.h> /* Required for HP/UX (and others?) */
31 #include <dns/events.h>
32 #include <dns/lookup.h>
33 #include <dns/rdata.h>
34 #include <dns/rdataset.h>
35 #include <dns/rdatastruct.h>
36 #include <dns/resolver.h>
37 #include <dns/result.h>
51 dns_lookupevent_t * event;
53 unsigned int restarts;
54 isc_boolean_t canceled;
55 dns_rdataset_t rdataset;
56 dns_rdataset_t sigrdataset;
59 #define LOOKUP_MAGIC ISC_MAGIC('l', 'o', 'o', 'k')
60 #define VALID_LOOKUP(l) ISC_MAGIC_VALID((l), LOOKUP_MAGIC)
62 #define MAX_RESTARTS 16
64 static void lookup_find(dns_lookup_t *lookup, dns_fetchevent_t *event);
67 fetch_done(isc_task_t *task, isc_event_t *event) {
68 dns_lookup_t *lookup = event->ev_arg;
69 dns_fetchevent_t *fevent;
72 REQUIRE(event->ev_type == DNS_EVENT_FETCHDONE);
73 REQUIRE(VALID_LOOKUP(lookup));
74 REQUIRE(lookup->task == task);
75 fevent = (dns_fetchevent_t *)event;
76 REQUIRE(fevent->fetch == lookup->fetch);
78 lookup_find(lookup, fevent);
81 static inline isc_result_t
82 start_fetch(dns_lookup_t *lookup) {
86 * The caller must be holding the lookup's lock.
89 REQUIRE(lookup->fetch == NULL);
91 result = dns_resolver_createfetch(lookup->view->resolver,
92 dns_fixedname_name(&lookup->name),
95 lookup->task, fetch_done, lookup,
104 build_event(dns_lookup_t *lookup) {
105 dns_name_t *name = NULL;
106 dns_rdataset_t *rdataset = NULL;
107 dns_rdataset_t *sigrdataset = NULL;
110 name = isc_mem_get(lookup->mctx, sizeof(dns_name_t));
112 result = ISC_R_NOMEMORY;
115 dns_name_init(name, NULL);
116 result = dns_name_dup(dns_fixedname_name(&lookup->name),
118 if (result != ISC_R_SUCCESS)
121 if (dns_rdataset_isassociated(&lookup->rdataset)) {
122 rdataset = isc_mem_get(lookup->mctx, sizeof(dns_rdataset_t));
123 if (rdataset == NULL) {
124 result = ISC_R_NOMEMORY;
127 dns_rdataset_init(rdataset);
128 dns_rdataset_clone(&lookup->rdataset, rdataset);
131 if (dns_rdataset_isassociated(&lookup->sigrdataset)) {
132 sigrdataset = isc_mem_get(lookup->mctx,
133 sizeof(dns_rdataset_t));
134 if (sigrdataset == NULL) {
135 result = ISC_R_NOMEMORY;
138 dns_rdataset_init(sigrdataset);
139 dns_rdataset_clone(&lookup->sigrdataset, sigrdataset);
142 lookup->event->name = name;
143 lookup->event->rdataset = rdataset;
144 lookup->event->sigrdataset = sigrdataset;
146 return (ISC_R_SUCCESS);
150 if (dns_name_dynamic(name))
151 dns_name_free(name, lookup->mctx);
152 isc_mem_put(lookup->mctx, name, sizeof(dns_name_t));
154 if (rdataset != NULL) {
155 if (dns_rdataset_isassociated(rdataset))
156 dns_rdataset_disassociate(rdataset);
157 isc_mem_put(lookup->mctx, rdataset, sizeof(dns_rdataset_t));
163 view_find(dns_lookup_t *lookup, dns_name_t *foundname) {
165 dns_name_t *name = dns_fixedname_name(&lookup->name);
166 dns_rdatatype_t type;
168 if (lookup->type == dns_rdatatype_rrsig)
169 type = dns_rdatatype_any;
173 result = dns_view_find(lookup->view, name, type, 0, 0, ISC_FALSE,
174 &lookup->event->db, &lookup->event->node,
175 foundname, &lookup->rdataset,
176 &lookup->sigrdataset);
181 lookup_find(dns_lookup_t *lookup, dns_fetchevent_t *event) {
183 isc_boolean_t want_restart;
184 isc_boolean_t send_event = ISC_FALSE;
185 dns_name_t *name, *fname, *prefix;
186 dns_fixedname_t foundname, fixed;
187 dns_rdata_t rdata = DNS_RDATA_INIT;
188 unsigned int nlabels;
190 dns_namereln_t namereln;
191 dns_rdata_cname_t cname;
192 dns_rdata_dname_t dname;
194 REQUIRE(VALID_LOOKUP(lookup));
198 result = ISC_R_SUCCESS;
199 name = dns_fixedname_name(&lookup->name);
203 want_restart = ISC_FALSE;
205 if (event == NULL && !lookup->canceled) {
206 dns_fixedname_init(&foundname);
207 fname = dns_fixedname_name(&foundname);
208 INSIST(!dns_rdataset_isassociated(&lookup->rdataset));
209 INSIST(!dns_rdataset_isassociated
210 (&lookup->sigrdataset));
211 result = view_find(lookup, fname);
212 if (result == ISC_R_NOTFOUND) {
214 * We don't know anything about the name.
217 if (lookup->event->node != NULL) {
218 INSIST(lookup->event->db != NULL);
219 dns_db_detachnode(lookup->event->db,
220 &lookup->event->node);
222 if (lookup->event->db != NULL)
223 dns_db_detach(&lookup->event->db);
224 result = start_fetch(lookup);
225 if (result != ISC_R_SUCCESS)
226 send_event = ISC_TRUE;
229 } else if (event != NULL) {
230 result = event->result;
231 fname = dns_fixedname_name(&event->foundname);
232 dns_resolver_destroyfetch(&lookup->fetch);
233 INSIST(event->rdataset == &lookup->rdataset);
234 INSIST(event->sigrdataset == &lookup->sigrdataset);
236 fname = NULL; /* Silence compiler warning. */
239 * If we've been canceled, forget about the result.
241 if (lookup->canceled)
242 result = ISC_R_CANCELED;
246 result = build_event(lookup);
247 send_event = ISC_TRUE;
250 if (event->db != NULL)
251 dns_db_attach(event->db, &lookup->event->db);
252 if (event->node != NULL)
253 dns_db_attachnode(lookup->event->db,
255 &lookup->event->node);
259 * Copy the CNAME's target into the lookup's
260 * query name and start over.
262 result = dns_rdataset_first(&lookup->rdataset);
263 if (result != ISC_R_SUCCESS)
265 dns_rdataset_current(&lookup->rdataset, &rdata);
266 result = dns_rdata_tostruct(&rdata, &cname, NULL);
267 dns_rdata_reset(&rdata);
268 if (result != ISC_R_SUCCESS)
270 result = dns_name_copy(&cname.cname, name, NULL);
271 dns_rdata_freestruct(&cname);
272 if (result == ISC_R_SUCCESS)
273 want_restart = ISC_TRUE;
276 namereln = dns_name_fullcompare(name, fname, &order,
278 INSIST(namereln == dns_namereln_subdomain);
280 * Get the target name of the DNAME.
282 result = dns_rdataset_first(&lookup->rdataset);
283 if (result != ISC_R_SUCCESS)
285 dns_rdataset_current(&lookup->rdataset, &rdata);
286 result = dns_rdata_tostruct(&rdata, &dname, NULL);
287 dns_rdata_reset(&rdata);
288 if (result != ISC_R_SUCCESS)
291 * Construct the new query name and start over.
293 dns_fixedname_init(&fixed);
294 prefix = dns_fixedname_name(&fixed);
295 dns_name_split(name, nlabels, prefix, NULL);
296 result = dns_name_concatenate(prefix, &dname.dname,
298 dns_rdata_freestruct(&dname);
299 if (result == ISC_R_SUCCESS)
300 want_restart = ISC_TRUE;
303 send_event = ISC_TRUE;
306 if (dns_rdataset_isassociated(&lookup->rdataset))
307 dns_rdataset_disassociate(&lookup->rdataset);
308 if (dns_rdataset_isassociated(&lookup->sigrdataset))
309 dns_rdataset_disassociate(&lookup->sigrdataset);
313 if (event->node != NULL)
314 dns_db_detachnode(event->db, &event->node);
315 if (event->db != NULL)
316 dns_db_detach(&event->db);
317 isc_event_free(ISC_EVENT_PTR(&event));
321 * Limit the number of restarts.
323 if (want_restart && lookup->restarts == MAX_RESTARTS) {
324 want_restart = ISC_FALSE;
325 result = ISC_R_QUOTA;
326 send_event = ISC_TRUE;
329 } while (want_restart);
332 lookup->event->result = result;
333 lookup->event->ev_sender = lookup;
334 isc_task_sendanddetach(&lookup->task,
335 (isc_event_t **)&lookup->event);
336 dns_view_detach(&lookup->view);
339 UNLOCK(&lookup->lock);
343 levent_destroy(isc_event_t *event) {
344 dns_lookupevent_t *levent;
347 REQUIRE(event->ev_type == DNS_EVENT_LOOKUPDONE);
348 mctx = event->ev_destroy_arg;
349 levent = (dns_lookupevent_t *)event;
351 if (levent->name != NULL) {
352 if (dns_name_dynamic(levent->name))
353 dns_name_free(levent->name, mctx);
354 isc_mem_put(mctx, levent->name, sizeof(dns_name_t));
356 if (levent->rdataset != NULL) {
357 dns_rdataset_disassociate(levent->rdataset);
358 isc_mem_put(mctx, levent->rdataset, sizeof(dns_rdataset_t));
360 if (levent->sigrdataset != NULL) {
361 dns_rdataset_disassociate(levent->sigrdataset);
362 isc_mem_put(mctx, levent->sigrdataset, sizeof(dns_rdataset_t));
364 if (levent->node != NULL)
365 dns_db_detachnode(levent->db, &levent->node);
366 if (levent->db != NULL)
367 dns_db_detach(&levent->db);
368 isc_mem_put(mctx, event, event->ev_size);
373 dns_lookup_create(isc_mem_t *mctx, dns_name_t *name, dns_rdatatype_t type,
374 dns_view_t *view, unsigned int options, isc_task_t *task,
375 isc_taskaction_t action, void *arg, dns_lookup_t **lookupp)
378 dns_lookup_t *lookup;
381 lookup = isc_mem_get(mctx, sizeof(*lookup));
383 return (ISC_R_NOMEMORY);
385 lookup->options = options;
387 ievent = isc_event_allocate(mctx, lookup, DNS_EVENT_LOOKUPDONE,
388 action, arg, sizeof(*lookup->event));
389 if (ievent == NULL) {
390 result = ISC_R_NOMEMORY;
393 lookup->event = (dns_lookupevent_t *)ievent;
394 lookup->event->ev_destroy = levent_destroy;
395 lookup->event->ev_destroy_arg = mctx;
396 lookup->event->result = ISC_R_FAILURE;
397 lookup->event->name = NULL;
398 lookup->event->rdataset = NULL;
399 lookup->event->sigrdataset = NULL;
400 lookup->event->db = NULL;
401 lookup->event->node = NULL;
404 isc_task_attach(task, &lookup->task);
406 result = isc_mutex_init(&lookup->lock);
407 if (result != ISC_R_SUCCESS)
410 dns_fixedname_init(&lookup->name);
412 result = dns_name_copy(name, dns_fixedname_name(&lookup->name), NULL);
413 if (result != ISC_R_SUCCESS)
418 dns_view_attach(view, &lookup->view);
419 lookup->fetch = NULL;
420 lookup->restarts = 0;
421 lookup->canceled = ISC_FALSE;
422 dns_rdataset_init(&lookup->rdataset);
423 dns_rdataset_init(&lookup->sigrdataset);
424 lookup->magic = LOOKUP_MAGIC;
428 lookup_find(lookup, NULL);
430 return (ISC_R_SUCCESS);
433 DESTROYLOCK(&lookup->lock);
436 ievent = (isc_event_t *)lookup->event;
437 isc_event_free(&ievent);
438 lookup->event = NULL;
440 isc_task_detach(&lookup->task);
443 isc_mem_put(mctx, lookup, sizeof(*lookup));
449 dns_lookup_cancel(dns_lookup_t *lookup) {
450 REQUIRE(VALID_LOOKUP(lookup));
454 if (!lookup->canceled) {
455 lookup->canceled = ISC_TRUE;
456 if (lookup->fetch != NULL) {
457 INSIST(lookup->view != NULL);
458 dns_resolver_cancelfetch(lookup->fetch);
462 UNLOCK(&lookup->lock);
466 dns_lookup_destroy(dns_lookup_t **lookupp) {
467 dns_lookup_t *lookup;
469 REQUIRE(lookupp != NULL);
471 REQUIRE(VALID_LOOKUP(lookup));
472 REQUIRE(lookup->event == NULL);
473 REQUIRE(lookup->task == NULL);
474 REQUIRE(lookup->view == NULL);
475 if (dns_rdataset_isassociated(&lookup->rdataset))
476 dns_rdataset_disassociate(&lookup->rdataset);
477 if (dns_rdataset_isassociated(&lookup->sigrdataset))
478 dns_rdataset_disassociate(&lookup->sigrdataset);
480 DESTROYLOCK(&lookup->lock);
482 isc_mem_put(lookup->mctx, lookup, sizeof(*lookup));