H A D | mesh.c | 2 * services/mesh.c - deal with mesh of query states and handle events for that. 39 * This file contains functions to assist in dealing with a mesh of 40 * query states. This mesh is supposed to be thread-specific. 46 #include "services/mesh.h" 95 * Compare two response-ip client info entries for the purpose of mesh state 99 * We cannot share the mesh state for two queries if different response-ip in client_info_compare() 209 struct mesh_area* mesh = calloc(1, sizeof(struct mesh_area)); in mesh_create() 210 if(!mesh) { in mesh_create() 211 log_err("mesh are in mesh_create() 193 struct mesh_area* mesh = calloc(1, sizeof(struct mesh_area)); mesh_create() local 241 mesh_delete(struct mesh_area * mesh) mesh_delete() argument 254 mesh_delete_all(struct mesh_area * mesh) mesh_delete_all() argument 273 mesh_make_new_space(struct mesh_area * mesh,sldns_buffer * qbuf) mesh_make_new_space() argument 405 mesh_new_client(struct mesh_area * mesh,struct query_info * qinfo,struct respip_client_info * cinfo,uint16_t qflags,struct edns_data * edns,struct comm_reply * rep,uint16_t qid,int rpz_passthru) mesh_new_client() argument 580 mesh_new_callback(struct mesh_area * mesh,struct query_info * qinfo,uint16_t qflags,struct edns_data * edns,sldns_buffer * buf,uint16_t qid,mesh_cb_func_type cb,void * cb_arg,int rpz_passthru) mesh_new_callback() argument 678 mesh_schedule_prefetch(struct mesh_area * mesh,struct query_info * qinfo,uint16_t qflags,time_t leeway,int run,int rpz_passthru) mesh_schedule_prefetch() argument 759 mesh_schedule_prefetch_subnet(struct mesh_area * mesh,struct query_info * qinfo,uint16_t qflags,time_t leeway,int run,int rpz_passthru,struct sockaddr_storage * addr,struct edns_option * edns_list) mesh_schedule_prefetch_subnet() argument 842 mesh_new_prefetch(struct mesh_area * mesh,struct query_info * qinfo,uint16_t qflags,time_t leeway,int rpz_passthru,struct sockaddr_storage * addr,struct edns_option * opt_list) mesh_new_prefetch() argument 858 mesh_report_reply(struct mesh_area * mesh,struct outbound_entry * e,struct comm_reply * reply,int what) mesh_report_reply() argument 960 struct mesh_area* mesh; mesh_state_cleanup() local 1010 struct mesh_area* mesh; mesh_state_delete() local 1077 struct mesh_area* mesh = qstate->env->mesh; mesh_detach_subs() local 1107 struct mesh_area* mesh = qstate->env->mesh; mesh_add_sub() local 1151 struct mesh_area* mesh = qstate->env->mesh; mesh_attach_sub() local 1646 mesh_walk_supers(struct mesh_area * mesh,struct mesh_state * mstate) mesh_walk_supers() argument 1663 mesh_area_find(struct mesh_area * mesh,struct respip_client_info * cinfo,struct query_info * qinfo,uint16_t qflags,int prime,int valrec) mesh_area_find() argument 1832 mesh_continue(struct mesh_area * mesh,struct mesh_state * mstate,enum module_ext_state s,enum module_ev * ev) mesh_continue() argument 1945 mesh_run(struct mesh_area * mesh,struct mesh_state * mstate,enum module_ev ev,struct outbound_entry * e) mesh_run() argument 1982 mesh_log_list(struct mesh_area * mesh) mesh_log_list() argument 2003 mesh_stats(struct mesh_area * mesh,const char * str) mesh_stats() argument 2028 mesh_stats_clear(struct mesh_area * mesh) mesh_stats_clear() argument 2048 mesh_get_mem(struct mesh_area * mesh) mesh_get_mem() argument 2065 struct mesh_area* mesh = qstate->env->mesh; mesh_detect_cycle() local 2094 mesh_state_remove_reply(struct mesh_area * mesh,struct mesh_state * m,struct comm_point * cp) mesh_state_remove_reply() argument 2165 struct mesh_area* mesh = qstate->env->mesh; mesh_serve_expired_callback() local 2363 mesh_jostle_exceeded(struct mesh_area * mesh) mesh_jostle_exceeded() argument [all...] |