Lines Matching defs:env
59 * @param env: module environment with caches.
78 store_rrsets(struct module_env* env, struct reply_info* rep, time_t now,
89 switch(rrset_cache_update(env->rrset_cache, &rep->ref[i],
90 env->alloc, ((ntohs(rep->ref[i].key->rk.type)==
139 msg_cache_remove(struct module_env* env, uint8_t* qname, size_t qnamelen,
151 slabhash_remove(env->msg_cache, h, &k);
155 dns_cache_store_msg(struct module_env* env, struct query_info* qinfo,
172 reply_info_set_ttls(rep, *env->now);
173 store_rrsets(env, rep, *env->now, leeway, pside, qrep, region,
191 msg_cache_remove(env, qinfo->qname, qinfo->qname_len,
203 slabhash_insert(env->msg_cache, hash, &e->entry, rep, env->alloc);
208 find_closest_of_type(struct module_env* env, uint8_t* qname, size_t qnamelen,
224 if((rrset = rrset_cache_lookup(env->rrset_cache, qname,
243 if(!rrset_cache_expired_above(env->rrset_cache, &qname,
250 if((rrset = rrset_cache_lookup(env->
282 msg_cache_lookup(struct module_env* env, uint8_t* qname, size_t qnamelen,
295 e = slabhash_lookup(env->msg_cache, h, &k, wr);
307 find_add_addrs(struct module_env* env, uint16_t qclass,
315 akey = rrset_cache_lookup(env->rrset_cache, ns->name,
328 neg = msg_cache_lookup(env, ns->name, ns->namelen,
335 akey = rrset_cache_lookup(env->rrset_cache, ns->name,
348 neg = msg_cache_lookup(env, ns->name, ns->namelen,
355 neg = msg_cache_lookup(env, ns->name, ns->namelen,
368 cache_fill_missing(struct module_env* env, uint16_t qclass,
374 time_t now = *env->now;
379 akey = rrset_cache_lookup(env->rrset_cache, ns->name,
393 neg = msg_cache_lookup(env, ns->name, ns->namelen,
400 akey = rrset_cache_lookup(env->rrset_cache, ns->name,
414 neg = msg_cache_lookup(env, ns->name, ns->namelen,
421 neg = msg_cache_lookup(env, ns->name, ns->namelen,
434 find_add_ds(struct module_env* env, struct regional* region,
439 env->rrset_cache, dp->name, dp->namelen, LDNS_RR_TYPE_DS,
444 rrset = rrset_cache_lookup(env->rrset_cache, dp->name,
522 dns_cache_find_delegation(struct module_env* env, uint8_t* qname,
532 nskey = find_closest_of_type(env, qname, qnamelen, qclass, now,
564 find_add_ds(env, region, *msg, dp, now);
566 if(!find_add_addrs(env, qclass, region, dp, now, msg))
601 tomsg(struct module_env* env, struct query_info* q, struct reply_info* r,
615 now_control = r->ttl - env->cfg->serve_expired_reply_ttl;
666 if(env)
667 rrset_array_unlock_touch(env->rrset_cache, scratch, r->ref,
825 fill_any(struct module_env* env,
829 time_t now = *env->now;
837 if(env->cfg->deny_any) {
853 env->rrset_cache, qname, qnamelen, lookup[i],
890 dns_cache_lookup(struct module_env* env,
898 time_t now = *env->now;
908 e = slabhash_lookup(env->msg_cache, h, &k, 0);
912 struct dns_msg* msg = tomsg(env, &key->key, data, region, now, 0,
926 (rrset=find_closest_of_type(env, qname, qnamelen, qclass, now,
948 env->rrset_cache, qname, qnamelen,
965 (rrset=rrset_cache_lookup(env->rrset_cache, qname, qnamelen,
984 (rrset=rrset_cache_lookup(env->rrset_cache, qname, qnamelen,
1013 if(env->cfg->harden_below_nxdomain) {
1020 e = slabhash_lookup(env->msg_cache, h, &k, 0);
1022 env->cfg->qname_minimisation) {
1025 e = slabhash_lookup(env->msg_cache, h, &k, 0);
1034 && (msg=tomsg(env, &k, data, region, now, 0, scratch))) {
1051 return fill_any(env, qname, qnamelen, qtype, qclass, region);
1058 dns_cache_store(struct module_env* env, struct query_info* msgqinf,
1067 struct msgreply_entry* e = msg_cache_lookup(env,
1072 if(cached->ttl < *env->now
1073 && reply_info_could_use_expired(cached, *env->now)
1082 && (env->need_to_validate &&
1105 NORR_TTL + *env->now;
1106 if(env->cfg->serve_expired_ttl_reset &&
1108 < *env->now +
1109 env->cfg->serve_expired_ttl) {
1116 *env->now +
1117 env->cfg->serve_expired_ttl;
1130 rep = reply_info_copy(msgrep, env->alloc, NULL);
1134 * the env->now is added to message and RRsets in this routine. */
1142 rep->rrsets[i]->entry.data, *env->now);
1147 (void)rrset_cache_update(env->rrset_cache, &ref,
1148 env->alloc,
1150 && !pside) ? qstarttime:*env->now + leeway));
1162 reply_info_parsedelete(rep, env->alloc);
1171 dns_cache_store_msg(env, &qinf, h, rep, leeway, pside, msgrep,
1181 dns_cache_prefetch_adjust(struct module_env* env, struct query_info* qinfo,
1185 msg = msg_cache_lookup(env, qinfo->qname, qinfo->qname_len,
1186 qinfo->qtype, qinfo->qclass, flags, *env->now, 1);