unbound/ipset/ipset.c

28  * @param qstate: our query state
34 static int error_response(struct module_qstate* qstate, int id, int rcode) {
38 	qstate->return_rcode = rcode;
39 	qstate->return_msg = NULL;
40 	qstate->ext_state[id] = module_finished;
276 static int ipset_new(struct module_qstate* qstate, int id) {
278 		qstate->region, sizeof(struct ipset_qstate));
279 	qstate->minfo[id] = iq;
291 void ipset_operate(struct module_qstate *qstate, enum module_ev event, int id,
293 	struct ipset_env *ie = (struct ipset_env *)qstate->env->modinfo[id];
294 	struct ipset_qstate *iq = (struct ipset_qstate *)qstate->minfo[id];
296 		id, strextstate(qstate->ext_state[id]), strmodulevent(event));
298 		log_query_info(VERB_QUERY, "ipset operate: query", &qstate->qinfo);
303 		if (!ipset_new(qstate, id)) {
304 			(void)error_response(qstate, id, LDNS_RCODE_SERVFAIL);
307 		iq = (struct ipset_qstate*)qstate->minfo[id];
311 		qstate->ext_state[id] = module_wait_module;
316 		if (qstate->return_msg && qstate->return_msg->rep) {
317 			ipset_update(qstate->env, qstate->return_msg, qstate->qinfo, ie);
319 		qstate->ext_state[id] = module_finished;
326 		ipset_process_response(qstate, iq, ie, id, outbound, event);
333 		(void)error_response(qstate, id, LDNS_RCODE_SERVFAIL);
339 		qstate->ext_state[id] = module_finished;
344 	(void)error_response(qstate, id, LDNS_RCODE_SERVFAIL);
347 void ipset_inform_super(struct module_qstate *ATTR_UNUSED(qstate),
353 void ipset_clear(struct module_qstate *qstate, int id) {
355 	if (!qstate) {
358 	iq = (struct cachedb_qstate *)qstate->minfo[id];
363 	qstate->minfo[id] = NULL;