unbound/util/netevent.c

1061 	new_fd = comm_point_perform_accept(c, &c_hdl->repinfo.addr,
1062 		&c_hdl->repinfo.addrlen);
1133 				&c->repinfo) ) {
1159 		if( (*c->callback)(c, c->cb_arg, NETEVENT_NOERROR, &c->repinfo) ) {
1250 				log_addr(VERB_OPS, "ssl handshake failed", &c->repinfo.addr,
1251 					c->repinfo.addrlen);
1264 					&c->repinfo.addr, c->repinfo.addrlen);
1274 				log_addr(VERB_ALGO, buf, &c->repinfo.addr,
1275 					c->repinfo.addrlen);
1279 					"authenticated", &c->repinfo.addr,
1280 					c->repinfo.addrlen);
1293 				&c->repinfo.addr, c->repinfo.addrlen);
1299 		log_addr(VERB_ALGO, "SSL connection", &c->repinfo.addr,
1300 			c->repinfo.addrlen);
1646 					&c->repinfo.addr, c->repinfo.addrlen);
1662 				&c->repinfo.addr, c->repinfo.addrlen);
1706 			&c->repinfo.addr, c->repinfo.addrlen);
1759 				&c->repinfo.addr, c->repinfo.addrlen);
1771 				&c->repinfo.addr, c->repinfo.addrlen);
1803 		msg.msg_name = &c->repinfo.addr;
1804 		msg.msg_namelen = c->repinfo.addrlen;
1822 					&c->repinfo.addr, c->repinfo.addrlen);
1828 			if(connect(fd, (struct sockaddr *)&c->repinfo.addr, c->repinfo.addrlen) == -1) {
1839 					(struct sockaddr *)&c->repinfo.addr, c->repinfo.addrlen)) {
1841 						strerror(errno), &c->repinfo.addr, c->repinfo.addrlen);
1906 				&c->repinfo.addr, c->repinfo.addrlen);
1909 				&c->repinfo.addr, c->repinfo.addrlen);
1925 				&c->repinfo.addr, c->repinfo.addrlen);
1973 			&c->repinfo.addr, c->repinfo.addrlen);
2233 			&c->repinfo.addr, c->repinfo.addrlen);
2432 		struct comm_reply repinfo;
2445 		repinfo = c->repinfo;
2447 		(void)(*c->callback)(c, c->cb_arg, NETEVENT_NOERROR, &repinfo);
2451 		if(!repinfo.c) {
2663 			&h2_session->c->repinfo.addr,
2664 			h2_session->c->repinfo.addrlen);
2677 			&h2_session->c->repinfo.addr,
2678 			h2_session->c->repinfo.addrlen);
2700 			addr_to_str(&c->repinfo.addr, c->repinfo.addrlen,
2844 			&c->repinfo.addr, c->repinfo.addrlen);
2856 			&c->repinfo.addr, c->repinfo.addrlen);
2926 			&c->repinfo.addr, c->repinfo.addrlen);
2990 			&h2_session->c->repinfo.addr,
2991 			h2_session->c->repinfo.addrlen);
3006 			&h2_session->c->repinfo.addr,
3007 			h2_session->c->repinfo.addrlen);
3361 	c->repinfo.c = c;
3454 	c->repinfo.c = c;
3660 	c->repinfo.c = c;
3726 	c->repinfo.c = c;
3952 comm_point_send_reply(struct comm_reply *repinfo)
3955 	log_assert(repinfo && repinfo->c);
3957 	buffer = repinfo->c->dnscrypt_buffer;
3958 	if(!dnsc_handle_uncurved_request(repinfo)) {
3962 	buffer = repinfo->c->buffer;
3964 	if(repinfo->c->type == comm_udp) {
3965 		if(repinfo->srctype)
3966 			comm_point_send_udp_msg_if(repinfo->c,
3967 			buffer, (struct sockaddr*)&repinfo->addr,
3968 			repinfo->addrlen, repinfo);
3970 			comm_point_send_udp_msg(repinfo->c, buffer,
3971 			(struct sockaddr*)&repinfo->addr, repinfo->addrlen, 0);
3973 		if(repinfo->c->dtenv != NULL &&
3974 		   repinfo->c->dtenv->log_client_response_messages)
3975 			dt_msg_send_client_response(repinfo->c->dtenv,
3976 			&repinfo->addr, repinfo->c->type, repinfo->c->buffer);
3980 		if(repinfo->c->tcp_parent->dtenv != NULL &&
3981 		   repinfo->c->tcp_parent->dtenv->log_client_response_messages)
3982 			dt_msg_send_client_response(repinfo->c->tcp_parent->dtenv,
3983 			&repinfo->addr, repinfo->c->type,
3984 			( repinfo->c->tcp_req_info
3985 			? repinfo->c->tcp_req_info->spool_buffer
3986 			: repinfo->c->buffer ));
3988 		if(repinfo->c->tcp_req_info) {
3989 			tcp_req_info_send_reply(repinfo->c->tcp_req_info);
3990 		} else if(repinfo->c->use_h2) {
3991 			if(!http2_submit_dns_response(repinfo->c->h2_session)) {
3992 				comm_point_drop_reply(repinfo);
3995 			repinfo->c->h2_stream = NULL;
3996 			repinfo->c->tcp_is_reading = 0;
3997 			comm_point_stop_listening(repinfo->c);
3998 			comm_point_start_listening(repinfo->c, -1,
3999 				adjusted_tcp_timeout(repinfo->c));
4002 			comm_point_start_listening(repinfo->c, -1,
4003 				adjusted_tcp_timeout(repinfo->c));
4009 comm_point_drop_reply(struct comm_reply* repinfo)
4011 	if(!repinfo)
4013 	log_assert(repinfo->c);
4014 	log_assert(repinfo->c->type != comm_tcp_accept);
4015 	if(repinfo->c->type == comm_udp)
4017 	if(repinfo->c->tcp_req_info)
4018 		repinfo->c->tcp_req_info->is_drop = 1;
4019 	if(repinfo->c->type == comm_http) {
4020 		if(repinfo->c->h2_session) {
4021 			repinfo->c->h2_session->is_drop = 1;
4022 			if(!repinfo->c->h2_session->postpone_drop)
4023 				reclaim_http_handler(repinfo->c);
4026 		reclaim_http_handler(repinfo->c);
4029 	reclaim_tcp_handler(repinfo->c);