unbound/validator/validator.c

74 	struct val_qstate* vq, int id, int rcode, struct dns_msg* msg,
188 val_init(struct module_env* env, int id)
196 	env->modinfo[id] = (void*)val_env;
224 val_deinit(struct module_env* env, int id)
227 	if(!env || !env->modinfo[id])
229 	val_env = (struct val_env*)env->modinfo[id];
240 	env->modinfo[id] = NULL;
287 val_new(struct module_qstate* qstate, int id)
291 	log_assert(!qstate->minfo[id]);
295 	qstate->minfo[id] = vq;
319  * @param id: validator id.
323 val_error(struct module_qstate* qstate, int id)
325 	qstate->ext_state[id] = module_error;
414  * @param id: module id.
426 generate_request(struct module_qstate* qstate, int id, uint8_t* name,
430 	struct val_qstate* vq = (struct val_qstate*)qstate->minfo[id];
476 	qstate->ext_state[id] = module_wait_subquery;
484  * @param id: module id.
489 generate_keytag_query(struct module_qstate* qstate, int id,
503 	enum module_ext_state ext_state = qstate->ext_state[id];
527 	if(!generate_request(qstate, id, keytagdname, dnamebuf_len,
535 	qstate->ext_state[id] = ext_state;
572  * @param id: module id.
578 	int id, struct trust_anchor* toprime)
581 	int ret = generate_request(qstate, id, toprime->name, toprime->namelen,
585 		!generate_keytag_query(qstate, id, toprime)) {
800 	struct val_qstate* vq, int id, enum val_state resume_state)
814 	qstate->ext_state[id] = module_wait_reply;
1748  * @param id: module id.
1754 	struct val_env* ve, int id)
1764 		return val_error(qstate, id);
1888 		if(!prime_trust_anchor(qstate, vq, id, anchor)) {
1890 			return val_error(qstate, id);
1943  * @param id: module id.
1948 processFindKey(struct module_qstate* qstate, struct val_qstate* vq, int id)
1963 		if(!generate_request(qstate, id, vq->ds_rrset->rk.dname,
1967 			return val_error(qstate, id);
2036 		if(!generate_request(qstate, id, vq->ds_rrset->rk.dname,
2040 			return val_error(qstate, id);
2062 			process_ds_response(qstate, vq, id, LDNS_RCODE_NOERROR,
2067 					id, VAL_FINDKEY_STATE))
2068 					return val_error(qstate, id);
2078 			process_ds_response(qstate, vq, id, LDNS_RCODE_NOERROR,
2083 					id, VAL_FINDKEY_STATE))
2084 					return val_error(qstate, id);
2089 		if(!generate_request(qstate, id, target_key_name,
2093 			return val_error(qstate, id);
2099 	if(!generate_request(qstate, id, vq->ds_rrset->rk.dname,
2103 		return val_error(qstate, id);
2120  * @param id: module id.
2126 	struct val_env* ve, int id)
2133 		return val_error(qstate, id);
2190 				id, VAL_VALIDATE_STATE))
2191 				return val_error(qstate, id);
2226 					vq, id, VAL_VALIDATE_STATE))
2227 					return val_error(qstate, id);
2242 					vq, id, VAL_VALIDATE_STATE))
2243 					return val_error(qstate, id);
2259 					vq, id, VAL_VALIDATE_STATE))
2260 					return val_error(qstate, id);
2277 					vq, id, VAL_VALIDATE_STATE))
2278 					return val_error(qstate, id);
2294 					vq, id, VAL_VALIDATE_STATE))
2295 					return val_error(qstate, id);
2319 					vq, id, VAL_VALIDATE_STATE))
2320 					return val_error(qstate, id);
2349  * @param id: module id.
2355 	struct val_env* ve, int id)
2439 			qstate->ext_state[id] = module_restart_next;
2528 	qstate->ext_state[id] = module_finished;
2539  * @param id: module id.
2543 	struct val_env* ve, int id)
2551 				cont = processInit(qstate, vq, ve, id);
2554 				cont = processFindKey(qstate, vq, id);
2557 				cont = processValidate(qstate, vq, ve, id);
2560 				cont = processFinished(qstate, vq, ve, id);
2572 val_operate(struct module_qstate* qstate, enum module_ev event, int id,
2575 	struct val_env* ve = (struct val_env*)qstate->env->modinfo[id];
2576 	struct val_qstate* vq = (struct val_qstate*)qstate->minfo[id];
2578 		"event:%s", id, strextstate(qstate->ext_state[id]),
2591 		qstate->ext_state[id] = module_wait_module;
2604 			qstate->ext_state[id] = module_finished;
2608 			qstate->ext_state[id] = module_finished;
2620 			qstate->ext_state[id] = module_finished;
2624 		qstate->ext_state[id] = module_error; /* override this */
2626 			vq = val_new(qstate, id);
2629 				qstate->ext_state[id] = module_error;
2635 				qstate->ext_state[id] = module_error;
2639 		val_handle(qstate, vq, ve, id);
2643 		qstate->ext_state[id] = module_error; /* override this */
2645 		val_handle(qstate, vq, ve, id);
2649 	qstate->ext_state[id] = module_error;
2660  * @param id: module id.
2668 	struct trust_anchor* ta, struct module_qstate* qstate, int id)
2670 	struct val_env* ve = (struct val_env*)qstate->env->modinfo[id];
2748  * @param id: module id.
2764         int id, int rcode, struct dns_msg* msg, struct query_info* qinfo,
2767 	struct val_env* ve = (struct val_env*)qstate->env->modinfo[id];
2998  * @param id: module id.
3008 	int id, int rcode, struct dns_msg* msg, struct query_info* qinfo,
3011 	struct val_env* ve = (struct val_env*)qstate->env->modinfo[id];
3017 	ret = ds_response_to_ke(qstate, vq, id, rcode, msg, qinfo, &dske);
3088  * @param id: module id.
3096 	int id, int rcode, struct dns_msg* msg, struct query_info* qinfo,
3099 	struct val_env* ve = (struct val_env*)qstate->env->modinfo[id];
3191  * @param id: module id.
3198 	int id, int rcode, struct dns_msg* msg, struct sock_list* origin)
3200 	struct val_env* ve = (struct val_env*)qstate->env->modinfo[id];
3230 	vq->key_entry = primeResponseToKE(dnskey_rrset, ta, qstate, id);
3263  * @param id: module id.
3267 val_inform_super(struct module_qstate* qstate, int id,
3270 	struct val_qstate* vq = (struct val_qstate*)super->minfo[id];
3280 		process_prime_response(super, vq, id, qstate->return_rcode,
3286 		process_ds_response(super, vq, id, qstate->return_rcode,
3307 		process_dnskey_response(super, vq, id, qstate->return_rcode,
3316 val_clear(struct module_qstate* qstate, int id)
3321 	vq = (struct val_qstate*)qstate->minfo[id];
3328 	qstate->minfo[id] = NULL;
3332 val_get_mem(struct module_env* env, int id)
3334 	struct val_env* ve = (struct val_env*)env->modinfo[id];