unbound/edns-subnet/subnetmod.c

87 subnet_new_qstate(struct module_qstate *qstate, int id)
93 	qstate->minfo[id] = sq;
142 	struct regional* ATTR_UNUSED(region), int id, void* ATTR_UNUSED(cbargs))
147 	if(!(sq=(struct subnet_qstate*)qstate->minfo[id]))
149 	sn_env = (struct subnet_env*)qstate->env->modinfo[id];
191 subnetmod_init(struct module_env *env, int id)
200 	env->modinfo[id] = (void*)sn_env;
210 		env->modinfo[id] = NULL;
220 		env->modinfo[id] = NULL;
235 		env->modinfo[id] = NULL;
239 		env, id);
241 		inplace_cb_edns_back_parsed, NULL, env, id);
243 		inplace_cb_query_response, NULL, env, id);
249 subnetmod_deinit(struct module_env *env, int id)
252 	if(!env || !env->modinfo[id])
254 	sn_env = (struct subnet_env*)env->modinfo[id];
256 	inplace_cb_delete(env, inplace_cb_edns_back_parsed, id);
257 	inplace_cb_delete(env, inplace_cb_query, id);
258 	inplace_cb_delete(env, inplace_cb_query_response, id);
263 	env->modinfo[id] = NULL;
318 update_cache(struct module_qstate *qstate, int id)
324 	struct subnet_env *sne = qstate->env->modinfo[id];
325 	struct subnet_qstate *sq = (struct subnet_qstate*)qstate->minfo[id];
331 	hashvalue_type h = qstate->minfo[id] ?
332 		((struct subnet_qstate*)qstate->minfo[id])->qinfo_hash :
383 		rep->ref[i].id = rep->rrsets[i]->id;
401 lookup_and_reply(struct module_qstate *qstate, int id, struct subnet_qstate *sq)
405 	struct subnet_env *sne = (struct subnet_env*)env->modinfo[id];
469 eval_response(struct module_qstate *qstate, int id, struct subnet_qstate *sq)
471 	struct subnet_env *sne = qstate->env->modinfo[id];
505 			update_cache(qstate, id);
534 		update_cache(qstate, id);
636 	int id, void* ATTR_UNUSED(cbargs))
640 	if(!response || !(sq=(struct subnet_qstate*)qstate->minfo[id]))
668 ecs_edns_back_parsed(struct module_qstate* qstate, int id,
674 	if(!(sq=(struct subnet_qstate*)qstate->minfo[id]))
698 	int id, struct outbound_entry* outbound)
700 	struct subnet_env *sne = qstate->env->modinfo[id];
701 	struct subnet_qstate *sq = (struct subnet_qstate*)qstate->minfo[id];
704 		"event:%s", id, strextstate(qstate->ext_state[id]),
711 		if(!subnet_new_qstate(qstate, id)) {
713 			qstate->ext_state[id] = module_finished;
717 		sq = (struct subnet_qstate*)qstate->minfo[id];
726 				qstate->ext_state[id] = module_finished;
742 			qstate->ext_state[id] = module_wait_module;
753 				qstate->ext_state[id] = module_finished;
758 		if (lookup_and_reply(qstate, id, sq)) {
762 			qstate->ext_state[id] = module_finished;
802 		qstate->ext_state[id] = module_wait_module;
807 		qstate->ext_state[id] = eval_response(qstate, id, sq);
808 		if(qstate->ext_state[id] == module_finished &&
823 		qstate->ext_state[id] = module_wait_module;
828 		qstate->ext_state[id] = module_finished;
832 	qstate->ext_state[id] = module_error;
838 	int ATTR_UNUSED(id))
845 	int ATTR_UNUSED(id), struct module_qstate *ATTR_UNUSED(super))
851 subnetmod_get_mem(struct module_env *env, int id)
853 	struct subnet_env *sn_env = env->modinfo[id];