unbound/daemon/worker.c

471 	uint16_t id, uint16_t flags, struct comm_reply* repinfo,
516 				msg->rep, LDNS_RCODE_SERVFAIL, edns, repinfo, worker->scratchpad,
519 			error_encode(repinfo->c->buffer, LDNS_RCODE_SERVFAIL,
548 		(int)(flags&LDNS_RCODE_MASK), edns, repinfo, worker->scratchpad,
553 		repinfo->c, worker->scratchpad) ||
555 		repinfo->c->buffer, 0, 1, worker->scratchpad,
558 			LDNS_RCODE_SERVFAIL, edns, repinfo, worker->scratchpad,
561 		error_encode(repinfo->c->buffer, LDNS_RCODE_SERVFAIL,
566 		server_stats_insrcode(&worker->stats, repinfo->c->buffer);
579 	struct comm_reply* repinfo, struct ub_packed_rrset_key** alias_rrset,
606 			repinfo);
623  * Normally, the answer message will be built in repinfo->c->buffer; if the
636 	struct comm_reply* repinfo, struct edns_data* edns)
690 			LDNS_RCODE_SERVFAIL, edns, repinfo, worker->scratchpad,
693 		error_encode(repinfo->c->buffer, LDNS_RCODE_SERVFAIL,
725 		(int)(flags&LDNS_RCODE_MASK), edns, repinfo, worker->scratchpad,
731 		repinfo, alias_rrset,
757 		repinfo->c, worker->scratchpad) ||
759 		repinfo->c->buffer, timenow, 1, worker->scratchpad,
762 			LDNS_RCODE_SERVFAIL, edns, repinfo, worker->scratchpad,
765 		error_encode(repinfo->c->buffer, LDNS_RCODE_SERVFAIL,
784 	uint16_t flags, struct comm_reply* repinfo, time_t leeway, int noreply)
789 		if(repinfo->c->tcp_req_info) {
791 				repinfo->c->tcp_req_info->spool_buffer,
792 				repinfo->c->buffer);
794 		comm_point_send_reply(repinfo);
814  * @param repinfo: reply information for a communication point.
818 	struct worker* worker, struct comm_reply* repinfo)
851 		LDNS_RCODE_NOERROR, edns, repinfo, worker->scratchpad,
862 	struct worker* worker, struct comm_reply* repinfo)
864 	chaos_replystr(pkt, (char**)&str, 1, edns, worker, repinfo);
872  * @param repinfo: reply information for a communication point.
876 	struct comm_reply* repinfo)
887 		chaos_replystr(pkt, NULL, 0, edns, w, repinfo);
921 	chaos_replystr(pkt, str_array, num, edns, w, repinfo);
930  * @param repinfo: reply information for a communication point.
936 	struct edns_data* edns, struct comm_reply* repinfo, sldns_buffer* pkt)
952 				chaos_replyonestr(pkt, buf, edns, w, repinfo);
955 				chaos_replyonestr(pkt, "no hostname", edns, w, repinfo);
958 		else 	chaos_replyonestr(pkt, cfg->identity, edns, w, repinfo);
969 			chaos_replyonestr(pkt, PACKAGE_STRING, edns, w, repinfo);
970 		else 	chaos_replyonestr(pkt, cfg->version, edns, w, repinfo);
978 		chaos_trustanchor(pkt, edns, w, repinfo);
992  * @param repinfo: reply info with source address.
997 	struct edns_data* edns, sldns_buffer* pkt, struct comm_reply* repinfo)
1006 		qinfo->qname_len, qinfo->qclass, &repinfo->addr,
1007 		repinfo->addrlen, has_serial, serial, &refused)) {
1032 		log_addr(VERB_DETAIL, buf, &repinfo->addr, repinfo->addrlen);
1048 	struct worker* worker, struct comm_reply* repinfo)
1051 		comm_point_drop_reply(repinfo);
1057 			&repinfo->addr, repinfo->addrlen);
1062 			comm_point_drop_reply(repinfo);
1081 	struct worker* worker, struct comm_reply* repinfo)
1083 	return deny_refuse(c, acl, acl_deny, acl_refuse, worker, repinfo);
1088 	struct worker* worker, struct comm_reply* repinfo)
1090 	return deny_refuse(c, acl, acl_deny_non_local, acl_refuse_non_local, worker, repinfo);
1095 	struct comm_reply* repinfo)
1119 	if((error != NETEVENT_NOERROR && error != NETEVENT_DONE)|| !repinfo) {
1125 	repinfo->max_udp_size = worker->daemon->cfg->max_udp_size;
1126 	if(!dnsc_handle_curved_request(worker->daemon->dnscenv, repinfo)) {
1130 	if(c->dnscrypt && !repinfo->is_dnscrypted) {
1136 			log_addr(VERB_CLIENT,"from",&repinfo->addr,
1137 				repinfo->addrlen);
1138 			comm_point_drop_reply(repinfo);
1144 			log_addr(VERB_CLIENT, "from", &repinfo->addr,
1145 				repinfo->addrlen);
1146 			comm_point_drop_reply(repinfo);
1158 			comm_point_drop_reply(repinfo);
1164 	} else if(c->dnscrypt && repinfo->is_dnscrypted) {
1170 		dt_msg_send_client_query(&worker->dtenv, &repinfo->addr, c->type,
1173 	acladdr = acl_addr_lookup(worker->daemon->acl, &repinfo->addr,
1174 		repinfo->addrlen);
1176 	if((ret=deny_refuse_all(c, acl, worker, repinfo)) != -1)
1184 		log_addr(VERB_CLIENT,"from",&repinfo->addr, repinfo->addrlen);
1190 		comm_point_drop_reply(repinfo);
1197 	if(!infra_ip_ratelimit_inc(worker->env.infra_cache, repinfo,
1205 			addr_to_str(&repinfo->addr, repinfo->addrlen,
1211 			comm_point_drop_reply(repinfo);
1219 		log_addr(VERB_CLIENT,"from",&repinfo->addr, repinfo->addrlen);
1222 			comm_point_drop_reply(repinfo);
1233 		addr_to_str(&repinfo->addr, repinfo->addrlen, ip, sizeof(ip));
1239 		log_addr(VERB_CLIENT,"from",&repinfo->addr, repinfo->addrlen);
1256 		log_addr(VERB_CLIENT,"from",&repinfo->addr, repinfo->addrlen);
1258 			comm_point_drop_reply(repinfo);
1273 		log_addr(VERB_CLIENT,"from",&repinfo->addr, repinfo->addrlen);
1294 			log_addr(VERB_CLIENT,"from",&repinfo->addr, repinfo->addrlen);
1308 			log_addr(VERB_CLIENT,"from",&repinfo->addr, repinfo->addrlen);
1320 				log_addr(VERB_CLIENT,"from",&repinfo->addr, repinfo->addrlen);
1337 		log_addr(VERB_CLIENT,"from",&repinfo->addr, repinfo->addrlen);
1342 		log_addr(VERB_CLIENT, "from", &repinfo->addr, repinfo->addrlen);
1356 			qinfo.qclass, &edns, repinfo);
1360 		&edns, repinfo, c->buffer)) {
1366 		answer_notify(worker, &qinfo, &edns, c->buffer, repinfo);
1371 		&edns, c->buffer, worker->scratchpad, repinfo, acladdr->taglist,
1378 			comm_point_drop_reply(repinfo);
1386 		repinfo, acladdr->taglist, acladdr->taglen, &worker->stats)) {
1389 			comm_point_drop_reply(repinfo);
1396 		&qinfo, &edns, repinfo, c->buffer, worker->scratchpad)) {
1399 			comm_point_drop_reply(repinfo);
1412 	if((ret=deny_refuse_non_local(c, acl, worker, repinfo)) != -1)
1436 			&repinfo->addr, repinfo->addrlen);
1492 				sldns_buffer_read_u16_at(c->buffer, 2), repinfo,
1511 						repinfo, leeway,
1552 				sldns_buffer_read_u16_at(c->buffer, 2), repinfo,
1567 				&repinfo->addr, repinfo->addrlen);
1569 				&repinfo->addr, repinfo->addrlen);
1575 		&edns, repinfo, *(uint16_t*)(void *)sldns_buffer_begin(c->buffer));
1584 		comm_point_drop_reply(repinfo);
1596 		dt_msg_send_client_response(&worker->dtenv, &repinfo->addr,
1608 			log_reply_info(NO_VERBOSE, &qinfo, &repinfo->addr, repinfo->addrlen,
1611 			log_reply_info(NO_VERBOSE, &qinfo, &repinfo->addr, repinfo->addrlen,
1616 	if(!dnsc_handle_uncurved_request(repinfo)) {