dist/services/rpz.c

1564 	struct comm_reply* repinfo, struct module_qstate* ms, char* log_name)
1581 	} else if(ms && ms->mesh_info && ms->mesh_info->reply_list) {
1582 		addr_to_str(&ms->mesh_info->reply_list->query_reply.client_addr,
1583 			ms->mesh_info->reply_list->query_reply.client_addrlen,
1585 		port = ntohs(((struct sockaddr_in*)&ms->mesh_info->reply_list->query_reply.client_addr)->sin_port);
1831 rpz_add_soa(struct reply_info* rep, struct module_qstate* ms,
1841 	rsoa = make_soa_ubrrset(az, soa, ms->region);
1844 	rep->rrsets = regional_alloc_zero(ms->region,
1869 rpz_synthesize_nodata(struct rpz* ATTR_UNUSED(r), struct module_qstate* ms,
1872 	struct dns_msg* msg = rpz_dns_msg_new(ms->region);
1875 	msg->rep = construct_reply_info_base(ms->region,
1889 	if(!rpz_add_soa(msg->rep, ms, az))
1895 rpz_synthesize_nxdomain(struct rpz* r, struct module_qstate* ms,
1898 	struct dns_msg* msg = rpz_dns_msg_new(ms->region);
1905 	msg->rep = construct_reply_info_base(ms->region,
1919 	if(!rpz_add_soa(msg->rep, ms, az))
1925 rpz_synthesize_localdata_from_rrset(struct rpz* ATTR_UNUSED(r), struct module_qstate* ms,
1933 	msg = rpz_dns_msg_new(ms->region);
1936         new_reply_info = construct_reply_info_base(ms->region,
1953 	rp = respip_copy_rrset(rrset->rrset, ms->region);
1971 	if(!rpz_add_soa(msg->rep, ms, az))
1977 rpz_synthesize_nsip_localdata(struct rpz* r, struct module_qstate* ms,
1980 	struct query_info* qi = &ms->qinfo;
1989 	return rpz_synthesize_localdata_from_rrset(r, ms, &ms->qinfo, rrset, az);
2009 rpz_synthesize_nsdname_localdata(struct rpz* r, struct module_qstate* ms,
2032 	rrset = local_data_find_type(ld, ms->qinfo.qtype, 1);
2038 	return rpz_synthesize_localdata_from_rrset(r, ms, &ms->qinfo, rrset, az);
2043 rpz_synthesize_qname_localdata_msg(struct rpz* r, struct module_qstate* ms,
2063 	return rpz_synthesize_localdata_from_rrset(r, ms, qinfo, rrset, az);
2137 rpz_apply_nsip_trigger(struct module_qstate* ms, struct rpz* r,
2151 		ret = rpz_synthesize_nodata(r, ms, &ms->qinfo, az);
2157 		ret = rpz_synthesize_nxdomain(r, ms, &ms->qinfo, az);
2160 		ret = rpz_synthesize_nodata(r, ms, &ms->qinfo, az);
2165 		ms->tcp_required = 1;
2169 		ret = rpz_synthesize_nodata(r, ms, &ms->qinfo, az);
2170 		ms->is_drop = 1;
2173 		ret = rpz_synthesize_nsip_localdata(r, ms, raddr, az);
2174 		if(ret == NULL) { ret = rpz_synthesize_nodata(r, ms, &ms->qinfo, az); }
2178 		ms->rpz_passthru = 1;
2189 			action, &ms->qinfo, NULL, ms, r->log_name);
2190 	if(ms->env->worker)
2191 		ms->env->worker->stats.rpz_action[action]++;
2197 rpz_apply_nsdname_trigger(struct module_qstate* ms, struct rpz* r,
2212 		ret = rpz_synthesize_nxdomain(r, ms, &ms->qinfo, az);
2215 		ret = rpz_synthesize_nodata(r, ms, &ms->qinfo, az);
2220 		ms->tcp_required = 1;
2224 		ret = rpz_synthesize_nodata(r, ms, &ms->qinfo, az);
2225 		ms->is_drop = 1;
2228 		ret = rpz_synthesize_nsdname_localdata(r, ms, z, match, az);
2229 		if(ret == NULL) { ret = rpz_synthesize_nodata(r, ms, &ms->qinfo, az); }
2233 		ms->rpz_passthru = 1;
2243 			action, &ms->qinfo, NULL, ms, r->log_name);
2244 	if(ms->env->worker)
2245 		ms->env->worker->stats.rpz_action[action]++;
2288 rpz_callback_from_iterator_module(struct module_qstate* ms, struct iter_qstate* is)
2297 	if(ms->rpz_passthru) {
2302 	if(ms->env == NULL || ms->env->auth_zones == NULL) { return 0; }
2304 	az = ms->env->auth_zones;
2327 						     ms->qinfo.qclass, &match);
2350 		return rpz_apply_nsip_trigger(ms, r, raddr, a);
2352 	return rpz_apply_nsdname_trigger(ms, r, z, &match, a);
2355 struct dns_msg* rpz_callback_from_iterator_cname(struct module_qstate* ms,
2365 	if(ms->rpz_passthru) {
2370 	if(ms->env == NULL || ms->env->auth_zones == NULL) { return 0; }
2371 	az = ms->env->auth_zones;
2388 					&ms->qinfo, NULL, ms, r->log_name);
2389 			if(ms->env->worker)
2390 				ms->env->worker->stats.rpz_action[r->action_override]++;
2423 		ret = rpz_synthesize_nxdomain(r, ms, &is->qchase, a);
2426 		ret = rpz_synthesize_nodata(r, ms, &is->qchase, a);
2431 		ms->tcp_required = 1;
2435 		ret = rpz_synthesize_nodata(r, ms, &is->qchase, a);
2436 		ms->is_drop = 1;
2439 		ret = rpz_synthesize_qname_localdata_msg(r, ms, &is->qchase, z, a);
2440 		if(ret == NULL) { ret = rpz_synthesize_nodata(r, ms, &is->qchase, a); }
2444 		ms->rpz_passthru = 1;
2454 			&is->qchase, NULL, ms, r->log_name);