unbound/daemon/cachedump.c

46 #include "daemon/worker.h"
171 dump_rrset_cache(SSL* ssl, struct worker* worker)
173 	struct rrset_cache* r = worker->env.rrset_cache;
179 			*worker->env.now)) {
290 /** copy msg to worker pad */
316 dump_msg_lruhash(SSL* ssl, struct worker* worker, struct lruhash* h)
325 		regional_free_all(worker->scratchpad);
327 		/* make copy of rrset in worker buffer */
328 		if(!copy_msg(worker->scratchpad, e, &k, &d)) {
335 		if(!dump_msg(ssl, k, d, *worker->env.now)) {
344 dump_msg_cache(SSL* ssl, struct worker* worker)
346 	struct slabhash* sh = worker->env.msg_cache;
351 		if(!dump_msg_lruhash(ssl, worker, sh->array[slab])) {
361 dump_cache(SSL* ssl, struct worker* worker)
363 	if(!dump_rrset_cache(ssl, worker))
365 	if(!dump_msg_cache(ssl, worker))
469 	struct packed_rrset_data* d, struct worker* worker)
477 	ak = alloc_special_obtain(&worker->alloc);
488 		ub_packed_rrset_parsedelete(ak, &worker->alloc);
498 		ub_packed_rrset_parsedelete(ak, &worker->alloc);
520 	(void)rrset_cache_update(worker->env.rrset_cache, &ref,
521 		&worker->alloc, *worker->env.now);
527 load_rrset(SSL* ssl, ldns_buffer* buf, struct worker* worker)
530 	struct regional* region = worker->scratchpad;
568 	d->ttl = (uint32_t)ttl + *worker->env.now;
584 			&go_on, *worker->env.now)) {
591 			&go_on, *worker->env.now)) {
601 	return move_into_cache(rk, d, worker);
606 load_rrset_cache(SSL* ssl, struct worker* worker)
608 	ldns_buffer* buf = worker->env.scratch_buffer;
612 		if(!load_rrset(ssl, buf, worker))
670 load_ref(SSL* ssl, ldns_buffer* buf, struct worker* worker,
697 	k = rrset_cache_lookup(worker->env.rrset_cache, qinfo.qname,
699 		(uint32_t)flags, *worker->env.now, 0);
707 	*rrset = packed_rrset_copy_region(k, region, *worker->env.now);
715 load_msg(SSL* ssl, ldns_buffer* buf, struct worker* worker)
717 	struct regional* region = worker->scratchpad;
757 		if(!load_ref(ssl, buf, worker, region, &rep.rrsets[i],
766 	if(!dns_cache_store(&worker->env, &qinf, &rep, 0, 0, 0, NULL)) {
775 load_msg_cache(SSL* ssl, struct worker* worker)
777 	ldns_buffer* buf = worker->env.scratch_buffer;
781 		if(!load_msg(ssl, buf, worker))
788 load_cache(SSL* ssl, struct worker* worker)
790 	if(!load_rrset_cache(ssl, worker))
792 	if(!load_msg_cache(ssl, worker))
794 	return read_fixed(ssl, worker->env.scratch_buffer, "EOF");
799 print_dp_details(SSL* ssl, struct worker* worker, struct delegpt* dp)
817 		entry_ttl = infra_get_host_rto(worker->env.infra_cache,
819 			&ri, &delay, *worker->env.now, &tA, &tAAAA, &tother);
835 		if(!infra_get_lame_rtt(worker->env.infra_cache,
838 			*worker->env.now)) {
854 		if(infra_host(worker->env.infra_cache, &a->addr, a->addrlen,
855 			dp->name, dp->namelen, *worker->env.now, &edns_vs,
902 int print_deleg_lookup(SSL* ssl, struct worker* worker, uint8_t* nm,
908 	struct regional* region = worker->scratchpad;
923 	dp = forwards_lookup(worker->env.fwds, nm, qinfo.qclass);
928 		print_dp_details(ssl, worker, dp);
933 		dp = dns_cache_find_delegation(&worker->env, nm, nmlen,
935 			*worker->env.now);
943 			print_dp_details(ssl, worker, dp);
962 		stub = hints_lookup_stub(worker->env.hints, nm, qinfo.qclass,
975 			print_dp_details(ssl, worker, stub->dp);
978 			print_dp_details(ssl, worker, dp);