Lines Matching refs:worker
123 dump_rrset_cache(RES* ssl, struct worker* worker) in dump_rrset_cache() argument
125 struct rrset_cache* r = worker->env.rrset_cache; in dump_rrset_cache()
131 *worker->env.now)) { in dump_rrset_cache()
252 dump_msg_lruhash(RES* ssl, struct worker* worker, struct lruhash* h) in dump_msg_lruhash() argument
261 regional_free_all(worker->scratchpad); in dump_msg_lruhash()
264 if(!copy_msg(worker->scratchpad, e, &k, &d)) { in dump_msg_lruhash()
271 if(!dump_msg(ssl, k, d, *worker->env.now)) { in dump_msg_lruhash()
280 dump_msg_cache(RES* ssl, struct worker* worker) in dump_msg_cache() argument
282 struct slabhash* sh = worker->env.msg_cache; in dump_msg_cache()
287 if(!dump_msg_lruhash(ssl, worker, sh->array[slab])) { in dump_msg_cache()
297 dump_cache(RES* ssl, struct worker* worker) in dump_cache() argument
299 if(!dump_rrset_cache(ssl, worker)) in dump_cache()
301 if(!dump_msg_cache(ssl, worker)) in dump_cache()
383 struct packed_rrset_data* d, struct worker* worker) in move_into_cache() argument
391 ak = alloc_special_obtain(worker->alloc); in move_into_cache()
402 ub_packed_rrset_parsedelete(ak, worker->alloc); in move_into_cache()
412 ub_packed_rrset_parsedelete(ak, worker->alloc); in move_into_cache()
434 (void)rrset_cache_update(worker->env.rrset_cache, &ref, in move_into_cache()
435 worker->alloc, *worker->env.now); in move_into_cache()
442 load_rrset(RES* ssl, sldns_buffer* buf, struct worker* worker) in load_rrset() argument
445 struct regional* region = worker->scratchpad; in load_rrset()
488 d->ttl = (time_t)ttl + *worker->env.now; in load_rrset()
504 &go_on, *worker->env.now)) { in load_rrset()
511 &go_on, *worker->env.now)) { in load_rrset()
521 return move_into_cache(rk, d, worker); in load_rrset()
526 load_rrset_cache(RES* ssl, struct worker* worker) in load_rrset_cache() argument
528 sldns_buffer* buf = worker->env.scratch_buffer; in load_rrset_cache()
532 if(!load_rrset(ssl, buf, worker)) in load_rrset_cache()
582 load_ref(RES* ssl, sldns_buffer* buf, struct worker* worker, in load_ref() argument
609 k = rrset_cache_lookup(worker->env.rrset_cache, qinfo.qname, in load_ref()
611 (uint32_t)flags, *worker->env.now, 0); in load_ref()
619 *rrset = packed_rrset_copy_region(k, region, *worker->env.now); in load_ref()
627 load_msg(RES* ssl, sldns_buffer* buf, struct worker* worker) in load_msg() argument
629 struct regional* region = worker->scratchpad; in load_msg()
685 if(!load_ref(ssl, buf, worker, region, &rep.rrsets[i], in load_msg()
694 if(!dns_cache_store(&worker->env, &qinf, &rep, 0, 0, 0, NULL, flags, in load_msg()
695 *worker->env.now)) { in load_msg()
704 load_msg_cache(RES* ssl, struct worker* worker) in load_msg_cache() argument
706 sldns_buffer* buf = worker->env.scratch_buffer; in load_msg_cache()
710 if(!load_msg(ssl, buf, worker)) in load_msg_cache()
717 load_cache(RES* ssl, struct worker* worker) in load_cache() argument
719 if(!load_rrset_cache(ssl, worker)) in load_cache()
721 if(!load_msg_cache(ssl, worker)) in load_cache()
723 return read_fixed(ssl, worker->env.scratch_buffer, "EOF"); in load_cache()
728 print_dp_details(RES* ssl, struct worker* worker, struct delegpt* dp) in print_dp_details() argument
747 entry_ttl = infra_get_host_rto(worker->env.infra_cache, in print_dp_details()
749 &ri, &delay, *worker->env.now, &tA, &tAAAA, &tother); in print_dp_details()
765 if(!infra_get_lame_rtt(worker->env.infra_cache, in print_dp_details()
768 *worker->env.now)) { in print_dp_details()
784 if(infra_host(worker->env.infra_cache, &a->addr, a->addrlen, in print_dp_details()
785 dp->name, dp->namelen, *worker->env.now, &edns_vs, in print_dp_details()
832 int print_deleg_lookup(RES* ssl, struct worker* worker, uint8_t* nm, in print_deleg_lookup() argument
838 struct regional* region = worker->scratchpad; in print_deleg_lookup()
855 dp = forwards_lookup(worker->env.fwds, nm, qinfo.qclass, nolock); in print_deleg_lookup()
858 lock_rw_unlock(&worker->env.fwds->lock); in print_deleg_lookup()
862 print_dp_details(ssl, worker, dp); in print_deleg_lookup()
863 lock_rw_unlock(&worker->env.fwds->lock); in print_deleg_lookup()
868 dp = dns_cache_find_delegation(&worker->env, nm, nmlen, in print_deleg_lookup()
870 *worker->env.now, 0, NULL, 0); in print_deleg_lookup()
877 (worker->env.cfg->do_ip4 && worker->back->num_ip4 != 0), in print_deleg_lookup()
878 (worker->env.cfg->do_ip6 && worker->back->num_ip6 != 0), in print_deleg_lookup()
879 worker->env.cfg->do_nat64)) { in print_deleg_lookup()
881 print_dp_details(ssl, worker, dp); in print_deleg_lookup()
900 stub = hints_lookup_stub(worker->env.hints, nm, qinfo.qclass, in print_deleg_lookup()
906 lock_rw_unlock(&worker->env.hints->lock); in print_deleg_lookup()
912 lock_rw_unlock(&worker->env.hints->lock); in print_deleg_lookup()
917 print_dp_details(ssl, worker, stub->dp); in print_deleg_lookup()
918 lock_rw_unlock(&worker->env.hints->lock); in print_deleg_lookup()
921 print_dp_details(ssl, worker, dp); in print_deleg_lookup()