unbound/daemon/worker.c

62 #include "services/mesh.h"
121 	size_t total, front, back, mesh, msg, rrset, infra, ac, superac;
134 	mesh = mesh_get_mem(worker->env.mesh);
140 	for(i=0; i<worker->env.mesh->mods.num; i++) {
141 		fptr_ok(fptr_whitelist_mod_get_mem(worker->env.mesh->
143 		if(strcmp(worker->env.mesh->mods.mod[i]->name, "validator")==0)
144 			val += (*worker->env.mesh->mods.mod[i]->get_mem)
147 		else if(strcmp(worker->env.mesh->mods.mod[i]->name,
149 			subnet += (*worker->env.mesh->mods.mod[i]->get_mem)
152 		else	iter += (*worker->env.mesh->mods.mod[i]->get_mem)
168 	total = front+back+mesh+msg+rrset+infra+iter+val+ac+superac+me;
171 	log_info("Memory conditions: %u front=%u back=%u mesh=%u msg=%u "
175 		(unsigned)mesh, (unsigned)msg, (unsigned)rrset, (unsigned)infra,
180 	log_info("Memory conditions: %u front=%u back=%u mesh=%u msg=%u "
184 		(unsigned)mesh, (unsigned)msg, (unsigned)rrset,
199 	for(i=0; i<worker->env.mesh->mods.num; i++) {
200 		fptr_ok(fptr_whitelist_mod_get_mem(worker->env.mesh->
202 		if(strcmp(worker->env.mesh->mods.mod[i]->name, "validator")==0)
203 			val += (*worker->env.mesh->mods.mod[i]->get_mem)
206 		else if(strcmp(worker->env.mesh->mods.mod[i]->name,
208 			subnet += (*worker->env.mesh->mods.mod[i]->get_mem)
249 		mesh_report_reply(worker->env.mesh, &e, reply_info, error);
260 		mesh_report_reply(worker->env.mesh, &e, reply_info,
265 	mesh_report_reply(worker->env.mesh, &e, reply_info, NETEVENT_NOERROR);
280 		mesh_report_reply(worker->env.mesh, e, reply_info, error);
292 		mesh_report_reply(worker->env.mesh, e, reply_info,
297 	mesh_report_reply(worker->env.mesh, e, reply_info, NETEVENT_NOERROR);
798 	/* create the prefetch in the mesh as a normal lookup without
801 	/* this (potentially) runs the mesh for the new query */
802 	mesh_new_prefetch(worker->env.mesh, qinfo, flags, leeway +
1573 	mesh_new_client(worker->env.mesh, &qinfo, cinfo,
1673 	mesh_stats(worker->env.mesh, "mesh has");
1858 	/* If case prefetch is triggered, the corresponding mesh will clear
1869 	worker->env.mesh = mesh_create(&worker->daemon->mods, &worker->env);
1870 	/* Pass on daemon variables that we would need in the mesh area */
1871 	worker->env.mesh->use_response_ip = worker->daemon->use_response_ip;
1872 	worker->env.mesh->use_rpz = worker->daemon->use_rpz;
1932 	if(!worker->env.mesh || !worker->env.scratch_buffer) {
1957 	if(worker->env.mesh && verbosity >= VERB_OPS) {
1959 		mesh_stats(worker->env.mesh, "mesh has");
1963 	mesh_delete(worker->env.mesh);
2030 	mesh_stats_clear(worker->env.mesh);