unbound/iterator/iterator.c

70 iter_init(struct module_env* env, int id)
78 	env->modinfo[id] = (void*)iter_env;
87 iter_deinit(struct module_env* env, int id)
90 	if(!env || !env->modinfo[id])
92 	iter_env = (struct iter_env*)env->modinfo[id];
97 	env->modinfo[id] = NULL;
102 iter_new(struct module_qstate* qstate, int id)
106 	qstate->minfo[id] = iq;
181  * @param id: module id.
185 error_supers(struct module_qstate* qstate, int id, struct module_qstate* super)
187 	struct iter_qstate* super_iq = (struct iter_qstate*)super->minfo[id];
226  * @param id: module id
232 error_response(struct module_qstate* qstate, int id, int rcode)
239 	qstate->ext_state[id] = module_finished;
247  * @param id: module id
253 error_response_cache(struct module_qstate* qstate, int id, int rcode)
262 			return error_response(qstate, id, rcode);
276 	return error_response(qstate, id, rcode);
489  * @param id: module id.
502 	uint16_t qclass, struct module_qstate* qstate, int id,
539 		subq->curmod = id;
540 		subq->ext_state[id] = module_state_initial;
541 		subq->minfo[id] = regional_alloc(subq->region,
543 		if(!subq->minfo[id]) {
550 		subiq = (struct iter_qstate*)subq->minfo[id];
573  * @param id: module id.
578 prime_root(struct module_qstate* qstate, struct iter_qstate* iq, int id,
594 		qclass, qstate, id, iq, QUERYTARGETS_STATE, PRIME_RESP_STATE,
601 			(struct iter_qstate*)subq->minfo[id];
620 	qstate->ext_state[id] = module_wait_subquery;
630  * @param id: module id.
639 prime_stub(struct module_qstate* qstate, struct iter_qstate* iq, int id,
664 			(void)error_response(qstate, id, LDNS_RCODE_SERVFAIL);
679 		LDNS_RR_TYPE_NS, qclass, qstate, id, iq,
682 		(void)error_response(qstate, id, LDNS_RCODE_SERVFAIL);
687 			(struct iter_qstate*)subq->minfo[id];
697 			(void)error_response(qstate, id, LDNS_RCODE_SERVFAIL);
710 	qstate->ext_state[id] = module_wait_subquery;
720  * @param id: module id.
724 	int id)
726 	struct iter_env* ie = (struct iter_env*)qstate->env->modinfo[id];
760 			qstate, id, iq,
775  * @param id: module id.
778 generate_ns_check(struct module_qstate* qstate, struct iter_qstate* iq, int id)
780 	struct iter_env* ie = (struct iter_env*)qstate->env->modinfo[id];
791 		generate_a_aaaa_check(qstate, iq, id);
798 		LDNS_RR_TYPE_NS, iq->qchase.qclass, qstate, id, iq,
805 			(struct iter_qstate*)subq->minfo[id];
835  * @param id: module id.
839 	struct iter_qstate* iq, int id)
855 		LDNS_RR_TYPE_DNSKEY, iq->qchase.qclass, qstate, id, iq,
863 			(struct iter_qstate*)subq->minfo[id];
918  * @param id: module id.
924 	struct iter_env* ie, int id)
938 		return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
949 		return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
1006 				return error_response(qstate, id,
1034 			return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
1052 			return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
1089 			int r = prime_stub(qstate, iq, id, delname,
1103 					return error_response(qstate, id,
1109 					return error_response(qstate, id,
1116 			if(!prime_root(qstate, iq, id, iq->qchase.qclass))
1117 				return error_response(qstate, id,
1151 					return error_response(qstate, id,
1157 					return error_response(qstate, id,
1192  * @param id: module id.
1198 	int id)
1208 			return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
1222 	if(prime_stub(qstate, iq, id, delname, iq->qchase.qclass)) {
1239  * @param id: module id.
1244 	int id)
1271 		generate_dnskey_prefetch(qstate, iq, id);
1288  * @param id: module id.
1297 	struct iter_qstate* iq, int id, uint8_t* name, size_t namelen,
1302 		id, iq, INIT_REQUEST_STATE, FINISHED_STATE, &subq, 0))
1306 			(struct iter_qstate*)subq->minfo[id];
1340  * @param id: module id.
1349         int id, uint8_t* name, size_t namelen, uint16_t qtype, uint16_t qclass)
1353 		id, iq, INIT_REQUEST_STATE, FINISHED_STATE, &subq, 0))
1366  * @param id: module id.
1375         struct iter_env* ie, int id, int maxtargets, int* num)
1425 			if(!generate_target_query(qstate, iq, id,
1430 					qstate->ext_state[id] = module_wait_subquery;
1437 			if(!generate_target_query(qstate, iq, id,
1442 					qstate->ext_state[id] = module_wait_subquery;
1457 		qstate->ext_state[id] = module_wait_subquery;
1499  * @param id: module id.
1505 	struct iter_env* ie, int id)
1515 		return error_response_cache(qstate, id, LDNS_RCODE_SERVFAIL);
1570 		if(!query_for_targets(qstate, iq, ie, id, 1, &qs)) {
1571 			return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
1576 			qstate->ext_state[id] = module_wait_subquery;
1582 		return error_response_cache(qstate, id, LDNS_RCODE_SERVFAIL);
1590 		return error_response_cache(qstate, id, LDNS_RCODE_SERVFAIL);
1600 			if(!generate_parentside_target_query(qstate, iq, id,
1603 				return error_response(qstate, id,
1610 			if(!generate_parentside_target_query(qstate, iq, id,
1613 				return error_response(qstate, id,
1622 			qstate->ext_state[id] = module_wait_subquery;
1637 	return error_response_cache(qstate, id, LDNS_RCODE_SERVFAIL);
1649  * @param id: module id.
1655 processDSNSFind(struct module_qstate* qstate, struct iter_qstate* iq, int id)
1667 		return error_response_cache(qstate, id, LDNS_RCODE_SERVFAIL);
1685 		LDNS_RR_TYPE_NS, iq->qchase.qclass, qstate, id, iq,
1687 		return error_response_cache(qstate, id, LDNS_RCODE_SERVFAIL);
1704  * @param id: module id.
1711 	struct iter_env* ie, int id)
1731 		return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
1736 		return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
1743 		return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
1756 		qstate->ext_state[id] = module_wait_reply;
1773 		if(!query_for_targets(qstate, iq, ie, id, -1, &extra)) {
1774 			return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
1781 			qstate->ext_state[id] = module_wait_reply;
1814 		(void)query_for_targets(qstate, iq, ie, id, tf_policy, &extra);
1849 				if(!query_for_targets(qstate, iq, ie, id,
1851 					return error_response(qstate, id,
1869 				return processLastResort(qstate, iq, ie, id);
1880 			qstate->ext_state[id] = module_wait_reply;
1885 			qstate->ext_state[id] = module_wait_subquery;
1890 			qstate->ext_state[id] = module_wait_reply;
1919 	qstate->ext_state[id] = module_wait_reply;
1945  * @param id: module id.
1952 	int id)
2041 			return processDSNSFind(qstate, iq, id);
2110 			return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
2113 			return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
2128 			generate_dnskey_prefetch(qstate, iq, id);
2135 			generate_ns_check(qstate, iq, id);
2171 			return processDSNSFind(qstate, iq, id);
2176 			return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
2271  * @param id: module id.
2275 prime_supers(struct module_qstate* qstate, int id, struct module_qstate* forq)
2277 	struct iter_qstate* foriq = (struct iter_qstate*)forq->minfo[id];
2322  * @param id: module id.
2327 processPrimeResponse(struct module_qstate* qstate, int id)
2329 	struct iter_qstate* iq = (struct iter_qstate*)qstate->minfo[id];
2354 			qstate->qinfo.qclass, qstate, id, iq,
2358 		generate_a_aaaa_check(qstate, iq, id);
2362 	qstate->ext_state[id] = module_finished;
2376  * @param id: module id.
2380 processTargetResponse(struct module_qstate* qstate, int id,
2383 	struct iter_qstate* iq = (struct iter_qstate*)qstate->minfo[id];
2384 	struct iter_qstate* foriq = (struct iter_qstate*)forq->minfo[id];
2457  * @param id: module id.
2461 processDSNSResponse(struct module_qstate* qstate, int id,
2464 	struct iter_qstate* foriq = (struct iter_qstate*)forq->minfo[id];
2492  * @param id: module id.
2496 processClassResponse(struct module_qstate* qstate, int id,
2499 	struct iter_qstate* foriq = (struct iter_qstate*)forq->minfo[id];
2589  * @param id: module id.
2593 processCollectClass(struct module_qstate* qstate, int id)
2595 	struct iter_qstate* iq = (struct iter_qstate*)qstate->minfo[id];
2611 				c, qstate, id, iq, INIT_REQUEST_STATE,
2614 				return error_response(qstate, id,
2627 			return error_response(qstate, id, LDNS_RCODE_REFUSED);
2641  * @param id: module id.
2647 	int id)
2659 		return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
2674 	qstate->ext_state[id] = module_finished;
2683 			return error_response(qstate, id, LDNS_RCODE_SERVFAIL);
2711  * @param id: module id.
2715 iter_inform_super(struct module_qstate* qstate, int id,
2719 		processClassResponse(qstate, id, super);
2721 		super->minfo[id])->state == DSNS_FIND_STATE)
2722 		processDSNSResponse(qstate, id, super);
2724 		error_supers(qstate, id, super);
2726 		prime_supers(qstate, id, super);
2727 	else	processTargetResponse(qstate, id, super);
2740  * @param id: module id.
2744 	struct iter_env* ie, int id)
2752 				cont = processInitRequest(qstate, iq, ie, id);
2755 				cont = processInitRequest2(qstate, iq, id);
2758 				cont = processInitRequest3(qstate, iq, id);
2761 				cont = processQueryTargets(qstate, iq, ie, id);
2764 				cont = processQueryResponse(qstate, iq, id);
2767 				cont = processPrimeResponse(qstate, id);
2770 				cont = processCollectClass(qstate, id);
2773 				cont = processDSNSFind(qstate, iq, id);
2776 				cont = processFinished(qstate, iq, id);
2793  * @param id: module id.
2797 	struct iter_env* ie, int id)
2804 	iter_handle(qstate, iq, ie, id);
2810 	struct iter_env* ie, int id, struct outbound_entry* outbound,
2842 		(void)error_response(qstate, id, LDNS_RCODE_SERVFAIL);
2908 				(void)error_response(qstate, id,
2925 	iter_handle(qstate, iq, ie, id);
2929 iter_operate(struct module_qstate* qstate, enum module_ev event, int id,
2932 	struct iter_env* ie = (struct iter_env*)qstate->env->modinfo[id];
2933 	struct iter_qstate* iq = (struct iter_qstate*)qstate->minfo[id];
2935 		id, strextstate(qstate->ext_state[id]), strmodulevent(event));
2945 		if(!iter_new(qstate, id)) {
2946 			(void)error_response(qstate, id, LDNS_RCODE_SERVFAIL);
2949 		iq = (struct iter_qstate*)qstate->minfo[id];
2950 		process_request(qstate, iq, ie, id);
2954 		iter_handle(qstate, iq, ie, id);
2958 		process_response(qstate, iq, ie, id, outbound, event);
2963 		(void)error_response(qstate, id, LDNS_RCODE_SERVFAIL);
2968 	(void)error_response(qstate, id, LDNS_RCODE_SERVFAIL);
2972 iter_clear(struct module_qstate* qstate, int id)
2977 	iq = (struct iter_qstate*)qstate->minfo[id];
2984 	qstate->minfo[id] = NULL;
2988 iter_get_mem(struct module_env* env, int id)
2990 	struct iter_env* ie = (struct iter_env*)env->modinfo[id];