result = dns_adb_createfind(adb, t2, lookup_callback, client,
&client->name, dns_rootname, 0, options,
now, NULL, view->dstport, 0, NULL,
- NULL, 0, &client->find);
+ &client->find);
if (result != ISC_R_SUCCESS)
printf("DNS_ADB_CREATEFIND -> %s\n", dns_result_totext(result));
dns_adb_dumpfind(client->find, stderr);
dns_fixedname_name(&fixed),
dns_rootname, 0, options, 0,
dns_fixedname_name(&target), 0,
- 0, NULL, NULL, 0, &find);
+ 0, NULL, &find);
if (result == ISC_R_SUCCESS) {
if (!ISC_LIST_EMPTY(find->list)) {
/*
isc_stdtime_t last_used;
ISC_LINK(dns_adbname_t) plink;
- isc_sockaddr_t client;
- dns_messageid_t id;
};
/*% The adbfetch structure */
dns_rdatatype_t);
static isc_result_t fetch_name(dns_adbname_t *, bool,
unsigned int, isc_counter_t *qc,
- dns_rdatatype_t, const isc_sockaddr_t *client,
- dns_messageid_t id);
+ dns_rdatatype_t);
static inline void check_exit(dns_adb_t *);
static void destroy(dns_adb_t *);
static bool shutdown_names(dns_adb_t *);
isc_task_sendanddetach(&task, (isc_event_t **)&ev);
find->flags |= FIND_EVENT_SENT;
- memset(&name->client, 0, sizeof(name->client));
- name->id = 0;
} else {
DP(DEF_LEVEL, "cfan: skipping find %p", find);
}
name->fetch_aaaa = NULL;
name->fetch_err = FIND_ERR_UNEXPECTED;
name->fetch6_err = FIND_ERR_UNEXPECTED;
- memset(&name->client, 0, sizeof(name->client));
- name->id = 0;
- name->client.length = 0;
ISC_LIST_INIT(name->finds);
ISC_LINK_INIT(name, plink);
dns_rdatatype_t qtype, unsigned int options,
isc_stdtime_t now, dns_name_t *target,
in_port_t port, unsigned int depth, isc_counter_t *qc,
- const isc_sockaddr_t *client, dns_messageid_t id,
dns_adbfind_t **findp)
{
dns_adbfind_t *find;
goto out;
}
- if (adbname != NULL && client != NULL &&
- isc_sockaddr_equal(client, &adbname->client) && id == adbname->id) {
- char buf[DNS_NAME_FORMATSIZE + DNS_RDATATYPE_FORMATSIZE];
- char typebuf[DNS_RDATATYPE_FORMATSIZE];
- dns_name_format(qname, buf, sizeof(buf));
- dns_rdatatype_format(qtype, typebuf, sizeof(typebuf));
- result = DNS_R_DUPLICATE;
- DP(DEF_LEVEL,
- "dns_adb_createfind: duplicate query (possible loop) for %s/%s", buf, typebuf);
- RUNTIME_CHECK(!free_adbfind(adb, &find));
- goto out;
- }
-
/*
* Nothing found. Allocate a new adbname structure for this name.
*/
*/
if (WANT_INET(wanted_fetches) &&
fetch_name(adbname, start_at_zone, depth, qc,
- dns_rdatatype_a, client, id) == ISC_R_SUCCESS) {
+ dns_rdatatype_a) == ISC_R_SUCCESS) {
DP(DEF_LEVEL, "dns_adb_createfind: "
"started A fetch for name %s (%p)",
namebuf, adbname);
*/
if (WANT_INET6(wanted_fetches) &&
fetch_name(adbname, start_at_zone, depth, qc,
- dns_rdatatype_aaaa, client, id) == ISC_R_SUCCESS) {
+ dns_rdatatype_aaaa) == ISC_R_SUCCESS) {
DP(DEF_LEVEL, "dns_adb_createfind: "
"started AAAA fetch for name %s (%p)",
namebuf, adbname);
find->adbname = adbname;
find->name_bucket = bucket;
bool empty = ISC_LIST_EMPTY(adbname->finds);
- /* If there are no finds pending take ownership of adbname */
- if (adbname->client.length == 0 && client != NULL) {
- adbname->client = *client;
- adbname->id = id;
- }
ISC_LIST_APPEND(adbname->finds, find, plink);
find->query_pending = (query_pending & wanted_addresses);
find->flags &= ~DNS_ADBFIND_ADDRESSMASK;
find->flags |= (find->query_pending & DNS_ADBFIND_ADDRESSMASK);
DP(DEF_LEVEL, "createfind: attaching find %p to adbname "
- "%p (%d/%d) %d",
- find, adbname, isc_sockaddr_hash(&adbname->client, true),
- adbname->id, empty);
+ "%p %d",
+ find, adbname, empty);
} else {
/*
* Remove the flag so the caller knows there will never
static isc_result_t
fetch_name(dns_adbname_t *adbname, bool start_at_zone,
- unsigned int depth, isc_counter_t *qc, dns_rdatatype_t type,
- const isc_sockaddr_t *client, dns_messageid_t id)
+ unsigned int depth, isc_counter_t *qc, dns_rdatatype_t type)
{
isc_result_t result;
dns_adbfetch_t *fetch = NULL;
*/
result = dns_resolver_createfetch(adb->view->resolver, &adbname->name,
type, name, nameservers, NULL,
- client, id, options, depth, qc,
+ NULL, 0, options, depth, qc,
adb->task, fetch_callback, adbname,
&fetch->rdataset, NULL,
&fetch->fetch);
dns_rdatatype_t qtype, unsigned int options,
isc_stdtime_t now, dns_name_t *target, in_port_t port,
unsigned int depth, isc_counter_t *qc,
- const isc_sockaddr_t *client, dns_messageid_t id,
dns_adbfind_t **find);
/*%<
* Main interface for clients. The adb will look up the name given in
&fctx->name, fctx->type,
options, now, NULL,
res->view->dstport,
- fctx->depth + 1, fctx->qc, fctx->client,
- fctx->id, &find);
+ fctx->depth + 1, fctx->qc, &find);
isc_log_write(dns_lctx, DNS_LOGCATEGORY_RESOLVER,
DNS_LOGMODULE_RESOLVER, ISC_LOG_DEBUG(3),
"fctx %p(%s): createfind for %p/%d - %s",
task = res->buckets[bucketnum].task;
result = dns_resolver_createfetch(fctx->res, &fctx->qminname,
fctx->qmintype, &fctx->domain,
- &fctx->nameservers, NULL,
- fctx->client, fctx->id,
+ &fctx->nameservers, NULL, NULL, 0,
options, 0, fctx->qc, task,
resume_qmin, fctx,
&fctx->qminrrset, NULL,
else
ISC_LIST_APPEND(fctx->events, event, ev_link);
fctx->references++;
+ fctx->client = client;
fetch->magic = DNS_FETCH_MAGIC;
fetch->private = fctx;
fctx_create(dns_resolver_t *res, const dns_name_t *name, dns_rdatatype_t type,
const dns_name_t *domain, dns_rdataset_t *nameservers,
unsigned int options, unsigned int bucketnum, unsigned int depth,
- isc_counter_t *qc, const isc_sockaddr_t *client, dns_messageid_t id,
- fetchctx_t **fctxp)
+ isc_counter_t *qc, fetchctx_t **fctxp)
{
fetchctx_t *fctx;
isc_result_t result;
fctx->rand_bits = 0;
fctx->timeout = false;
fctx->addrinfo = NULL;
- fctx->client = client;
- fctx->id = id;
fctx->ns_ttl = 0;
fctx->ns_ttl_ok = false;
result = dns_resolver_createfetch(fctx->res, &fctx->nsname,
dns_rdatatype_ns, domain,
- nsrdataset, NULL,
- fctx->client, fctx->id,
+ nsrdataset, NULL, NULL, 0,
fctx->options, 0, NULL, task,
resume_dslookup, fctx,
&fctx->nsrrset, NULL,
result = dns_resolver_createfetch(fctx->res, &fctx->nsname,
dns_rdatatype_ns,
- NULL, NULL, NULL,
- fctx->client, fctx->id,
+ NULL, NULL, NULL, NULL, 0,
fctx->options, 0, NULL, rctx->task,
resume_dslookup, fctx,
&fctx->nsrrset, NULL,
if (fctx == NULL) {
result = fctx_create(res, name, type, domain, nameservers,
- options, bucketnum, depth, qc, client,
- id, &fctx);
+ options, bucketnum, depth, qc, &fctx);
if (result != ISC_R_SUCCESS)
goto unlock;
new_fctx = true;
¬ify->ns, dns_rootname, 0,
options, 0, NULL,
notify->zone->view->dstport,
- 0, NULL, NULL, 0, ¬ify->find);
+ 0, NULL, ¬ify->find);
/* Something failed? */
if (result != ISC_R_SUCCESS)