62 #include "services/mesh.h"
124 	size_t total, front, back, mesh, msg, rrset, infra, ac, superac;  in worker_mem_report()  local
137 	mesh = mesh_get_mem(worker->env.mesh);  in worker_mem_report()
143 	for(i=0; i<worker->env.mesh->mods.num; i++) {  in worker_mem_report()
144 		fptr_ok(fptr_whitelist_mod_get_mem(worker->env.mesh->  in worker_mem_report()
146 		if(strcmp(worker->env.mesh->mods.mod[i]->name, "validator")==0)  in worker_mem_report()
147 			val += (*worker->env.mesh->mods.mod[i]->get_mem)  in worker_mem_report()
150 		else if(strcmp(worker->env.mesh->mods.mod[i]->name,  in worker_mem_report()
152 			subnet += (*worker->env.mesh->mods.mod[i]->get_mem)  in worker_mem_report()
155 		else	iter += (*worker->env.mesh->mods.mod[i]->get_mem)  in worker_mem_report()
173 	total = front+back+mesh+msg+rrset+infra+iter+val+ac+superac+me;  in worker_mem_report()
176 	log_info("Memory conditions: %u front=%u back=%u mesh=%u msg=%u "  in worker_mem_report()
180 		(unsigned)mesh, (unsigned)msg, (unsigned)rrset, (unsigned)infra,  in worker_mem_report()
185 	log_info("Memory conditions: %u front=%u back=%u mesh=%u msg=%u "  in worker_mem_report()
189 		(unsigned)mesh, (unsigned)msg, (unsigned)rrset,  in worker_mem_report()
204 	for(i=0; i<worker->env.mesh->mods.num; i++) {  in worker_mem_report()
205 		fptr_ok(fptr_whitelist_mod_get_mem(worker->env.mesh->  in worker_mem_report()
207 		if(strcmp(worker->env.mesh->mods.mod[i]->name, "validator")==0)  in worker_mem_report()
208 			val += (*worker->env.mesh->mods.mod[i]->get_mem)  in worker_mem_report()
211 		else if(strcmp(worker->env.mesh->mods.mod[i]->name,  in worker_mem_report()
213 			subnet += (*worker->env.mesh->mods.mod[i]->get_mem)  in worker_mem_report()
253 		mesh_report_reply(worker->env.mesh, e, reply_info, error);  in worker_handle_service_reply()
265 		mesh_report_reply(worker->env.mesh, e, reply_info,  in worker_handle_service_reply()
270 	mesh_report_reply(worker->env.mesh, e, reply_info, NETEVENT_NOERROR);  in worker_handle_service_reply()
847 	 * comm_reply information for ECS generation later. The mesh states are  in reply_and_prefetch()
849 	if(modstack_find(&worker->env.mesh->mods, "subnetcache") != -1  in reply_and_prefetch()
851 		mesh_new_prefetch(worker->env.mesh, qinfo, flags, leeway +  in reply_and_prefetch()
857 	/* create the prefetch in the mesh as a normal lookup without  in reply_and_prefetch()
860 	/* this (potentially) runs the mesh for the new query */  in reply_and_prefetch()
861 	mesh_new_prefetch(worker->env.mesh, qinfo, flags, leeway +  in reply_and_prefetch()
1924 	mesh_new_client(worker->env.mesh, &qinfo, cinfo,  in worker_handle_request()
2039 	mesh_stats(worker->env.mesh, "mesh has");  in worker_stat_timer_cb()
2238 	/* If case prefetch is triggered, the corresponding mesh will clear  in worker_init()
2249 	worker->env.mesh = mesh_create(&worker->daemon->mods, &worker->env);  in worker_init()
2250 	if(!worker->env.mesh) {  in worker_init()
2255 	/* Pass on daemon variables that we would need in the mesh area */  in worker_init()
2256 	worker->env.mesh->use_response_ip = worker->daemon->use_response_ip;  in worker_init()
2257 	worker->env.mesh->use_rpz = worker->daemon->use_rpz;  in worker_init()
2334 	if(worker->env.mesh && verbosity >= VERB_OPS) {  in worker_delete()
2336 		mesh_stats(worker->env.mesh, "mesh has");  in worker_delete()
2340 	mesh_delete(worker->env.mesh);  in worker_delete()
2407 	mesh_stats_clear(worker->env.mesh);  in worker_stats_clear()