18  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
22  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
103 	/** pointer to parent */
112 	/** need to set source address in reply; set for INADDR_ANY */
162 	/** activate a port */
163 	activate_func *activate;  member
171 /** to be used in bind_addr field */
210  * Stop the transport. This tries to unregister the transport which
227  * \param tp	port to close
232 	p->deactivate(p);  in deactivate_port()
238  * during runtime this is called when the RowStatus is set to Active or
250 	return (port->activate(port));  in inet_activate()
256  * \param tp	port to close
267 	free(port->dns_addr);  in inet_destroy_port()
277  * \return -1 if allocation fails, 0 otherwise
284 	if (pi->buf == NULL) {  in inet_alloc_buf()
285 		if ((pi->buf = buf_alloc(0)) == NULL) {  in inet_alloc_buf()
286 			(void)recvfrom(pi->fd, drop_buf, sizeof(drop_buf),  in inet_alloc_buf()
288 			return (-1);  in inet_alloc_buf()
290 		pi->buflen = buf_size(0);  in inet_alloc_buf()
301  * \param msg	message object to fill
304  * \return -1 when something goes wrong, 0 othersise
311 	iov[0].iov_base = pi->buf;  in inet_read_msg()
312 	iov[0].iov_len = pi->buflen;  in inet_read_msg()
314 	msg->msg_name = pi->peer;  in inet_read_msg()
315 	msg->msg_namelen = pi->peerlen;  in inet_read_msg()
316 	msg->msg_iov = iov;  in inet_read_msg()
317 	msg->msg_iovlen = 1;  in inet_read_msg()
318 	msg->msg_control = cbuf;  in inet_read_msg()
319 	msg->msg_controllen = RECV_CBUF_SIZE;  in inet_read_msg()
320 	msg->msg_flags = 0;  in inet_read_msg()
324 	const ssize_t len = recvmsg(pi->fd, msg, 0);  in inet_read_msg()
326 	if (len == -1 || len == 0)  in inet_read_msg()
328 		return (-1);  in inet_read_msg()
330 	if (msg->msg_flags & MSG_TRUNC) {  in inet_read_msg()
331 		/* truncated - drop */  in inet_read_msg()
334 		return (-1);  in inet_read_msg()
337 	pi->length = (size_t)len;  in inet_read_msg()
356 	assert(port->proto == BegemotSnmpdTransportProto_udp);  in inet_recv()
358 	if (inet_alloc_buf(pi) == -1)  in inet_recv()
359 		return (-1);  in inet_recv()
364 	if (inet_read_msg(pi, &msg, cbuf) == -1)  in inet_recv()
365 		return (-1);  in inet_recv()
367 	sock->parse_ctrl(sock, &msg);  in inet_recv()
376  * \param buf		data to send
377  * \param len		number of bytes to send
388 	struct port_sock *s = (pi == NULL) ?  TAILQ_FIRST(&p->socks) :  in inet_send2()
401 	msg.msg_name = (void *)pi->peer;  in inet_send2()
402 	msg.msg_namelen = pi->peerlen;  in inet_send2()
405 	if (s->set_ret_source) {  in inet_send2()
406 		s->setsrc(s, &msg, cbuf);  in inet_send2()
412 	return (sendmsg(s->input.fd, &msg, 0));  in inet_send2()
415 /** exported to daemon */
452  * \param port		the port to create
461 	if (params->addr_len != 4)  in ipv4_create()
468 	snmpd_input_init(&sock->input);  in ipv4_create()
470 	TAILQ_INSERT_HEAD(&port->socks, sock, link);  in ipv4_create()
473 	    (struct sockaddr_in *)&sock->bind_addr;  in ipv4_create()
475 	sin->sin_len = sizeof(struct sockaddr_in);  in ipv4_create()
476 	sin->sin_family = AF_INET;  in ipv4_create()
477 	sin->sin_port = htons(params->port);  in ipv4_create()
478 	memcpy(&sin->sin_addr, params->addr, 4); /* network byte order */  in ipv4_create()
480 	sock->port = port;  in ipv4_create()
486  * An IPv4 inet port is ready. Delegate to the generic code to read the data
497 	sock->input.peerlen = sizeof(struct sockaddr_in);  in ipv4_input()
498 	snmpd_input(&sock->input, &sock->port->tport);  in ipv4_input()
502  * Activate an IPv4 socket.
504  * \param sock	thhe socket to activate
511 	if ((sock->input.fd = socket(PF_INET, SOCK_DGRAM, 0)) == -1) {  in ipv4_activate_sock()
517 	    (const struct sockaddr_in *)&sock->bind_addr;  in ipv4_activate_sock()
519 	if (sin->sin_addr.s_addr == INADDR_ANY) {  in ipv4_activate_sock()
520 		/* need to know from which address to return */  in ipv4_activate_sock()
523 		if (setsockopt(sock->input.fd, IPPROTO_IP, IP_RECVDSTADDR, &on,  in ipv4_activate_sock()
524 		    sizeof(on)) == -1) {  in ipv4_activate_sock()
526 			(void)close(sock->input.fd);  in ipv4_activate_sock()
527 			sock->input.fd = -1;  in ipv4_activate_sock()
530 		sock->set_ret_source = true;  in ipv4_activate_sock()
533 	if (bind(sock->input.fd, (const struct sockaddr *)sin, sizeof(*sin))) {  in ipv4_activate_sock()
535 			(void)close(sock->input.fd);  in ipv4_activate_sock()
536 			sock->input.fd = -1;  in ipv4_activate_sock()
539 		syslog(LOG_ERR, "bind: %s:%u %m", inet_ntoa(sin->sin_addr),  in ipv4_activate_sock()
540 		    ntohs(sin->sin_port));  in ipv4_activate_sock()
541 		(void)close(sock->input.fd);  in ipv4_activate_sock()
542 		sock->input.fd = -1;  in ipv4_activate_sock()
546 	if ((sock->input.id = fd_select(sock->input.fd, ipv4_input,  in ipv4_activate_sock()
548 		(void)close(sock->input.fd);  in ipv4_activate_sock()
549 		sock->input.fd = -1;  in ipv4_activate_sock()
552 	sock->input.peer = (struct sockaddr *)&sock->ret_dest;  in ipv4_activate_sock()
554 	sock->parse_ctrl = ipv4_parse_ctrl;  in ipv4_activate_sock()
555 	sock->setsrc = ipv4_setsrc;  in ipv4_activate_sock()
571 	struct port_sock *sock = TAILQ_FIRST(&p->socks);  in ipv4_activate()
577 		p->row_status = RowStatus_active;  in ipv4_activate()
590 	struct port_sock *sock = TAILQ_FIRST(&p->socks);  in ipv4_deactivate()
594 	snmpd_input_close(&sock->input);  in ipv4_deactivate()
596 	p->row_status = RowStatus_notInService;  in ipv4_deactivate()
616 		if (cmsg->cmsg_level == IPPROTO_IP &&  in ipv4_parse_ctrl()
617 		    cmsg->cmsg_type == IP_RECVDSTADDR) {  in ipv4_parse_ctrl()
618 			memcpy(&sock->ret_source.a4, CMSG_DATA(cmsg),  in ipv4_parse_ctrl()
621 		} else if (cmsg->cmsg_level == SOL_SOCKET &&  in ipv4_parse_ctrl()
622 		    cmsg->cmsg_type == SCM_CREDS) {  in ipv4_parse_ctrl()
627 	sock->input.priv = 0;  in ipv4_parse_ctrl()
628 	if (sock->input.cred && cred)  in ipv4_parse_ctrl()
630 		sock->input.priv = (cred->sc_euid == 0);  in ipv4_parse_ctrl()
644 	msg->msg_control = cbuf;  in ipv4_setsrc()
645 	msg->msg_controllen = CMSG_SPACE(sizeof(struct in_addr));  in ipv4_setsrc()
649 	cmsg->cmsg_level = IPPROTO_IP;  in ipv4_setsrc()
650 	cmsg->cmsg_type = IP_SENDSRCADDR;  in ipv4_setsrc()
651 	cmsg->cmsg_len = CMSG_LEN(sizeof(struct in_addr));  in ipv4_setsrc()
652 	memcpy(CMSG_DATA(cmsg), &sock->ret_source.a4,  in ipv4_setsrc()
675 	struct sockaddr_in6 *sin = (struct sockaddr_in6 *)&sock->bind_addr;  in ipv6_create_common()
677 	sin->sin6_len = sizeof(struct sockaddr_in6);  in ipv6_create_common()
678 	sin->sin6_family = AF_INET6;  in ipv6_create_common()
679 	sin->sin6_port = htons(params->port);  in ipv6_create_common()
680 	sin->sin6_flowinfo = 0;  in ipv6_create_common()
681 	sin->sin6_scope_id = scope_id;  in ipv6_create_common()
683 	memcpy(sin->sin6_addr.s6_addr, params->addr, 16);  in ipv6_create_common()
685 	if (IN6_IS_ADDR_LINKLOCAL(&sin->sin6_addr) && scope_id == 0) {  in ipv6_create_common()
689 		    &sin->sin6_addr, buf, sizeof(buf)));  in ipv6_create_common()
694 	sock->port = port;  in ipv6_create_common()
696 	snmpd_input_init(&sock->input);  in ipv6_create_common()
697 	TAILQ_INSERT_HEAD(&port->socks, sock, link);  in ipv6_create_common()
706  * \param port		the port to create
714 	if (params->addr_len != 16)  in ipv6_create()
725  * An IPv6 inet port is ready. Delegate to the generic code to read the data
736 	sock->input.peerlen = sizeof(struct sockaddr_in6);  in ipv6_input()
737 	snmpd_input(&sock->input, &sock->port->tport);  in ipv6_input()
741  * Activate an IPv6 socket.
743  * \param sock	thhe socket to activate
750 	if ((sock->input.fd = socket(PF_INET6, SOCK_DGRAM, 0)) == -1) {  in ipv6_activate_sock()
756 	    (const struct sockaddr_in6 *)&sock->bind_addr;  in ipv6_activate_sock()
758 	if (memcmp(&sin->sin6_addr, &in6addr_any, sizeof(in6addr_any)) == 0) {  in ipv6_activate_sock()
759 		/* need to know from which address to return */  in ipv6_activate_sock()
762 		if (setsockopt(sock->input.fd, IPPROTO_IPV6, IPV6_RECVPKTINFO,  in ipv6_activate_sock()
763 		    &on, sizeof(on)) == -1) {  in ipv6_activate_sock()
765 			(void)close(sock->input.fd);  in ipv6_activate_sock()
766 			sock->input.fd = -1;  in ipv6_activate_sock()
769 		sock->set_ret_source = true;  in ipv6_activate_sock()
772 	if (bind(sock->input.fd, (const struct sockaddr *)sin, sizeof(*sin))) {  in ipv6_activate_sock()
774 			(void)close(sock->input.fd);  in ipv6_activate_sock()
775 			sock->input.fd = -1;  in ipv6_activate_sock()
780 		    &sin->sin6_addr, buf, sizeof(buf)), sin->sin6_scope_id,  in ipv6_activate_sock()
781 		    ntohs(sin->sin6_port));  in ipv6_activate_sock()
782 		(void)close(sock->input.fd);  in ipv6_activate_sock()
783 		sock->input.fd = -1;  in ipv6_activate_sock()
786 	if ((sock->input.id = fd_select(sock->input.fd, ipv6_input,  in ipv6_activate_sock()
788 		(void)close(sock->input.fd);  in ipv6_activate_sock()
789 		sock->input.fd = -1;  in ipv6_activate_sock()
792 	sock->input.peer = (struct sockaddr *)&sock->ret_dest;  in ipv6_activate_sock()
794 	sock->parse_ctrl = ipv6_parse_ctrl;  in ipv6_activate_sock()
795 	sock->setsrc = ipv6_setsrc;  in ipv6_activate_sock()
810 	struct port_sock *sock = TAILQ_FIRST(&p->socks);  in ipv6_activate()
816 		p->row_status = RowStatus_active;  in ipv6_activate()
828 	struct port_sock *sock = TAILQ_FIRST(&p->socks);  in ipv6_deactivate()
832 	snmpd_input_close(&sock->input);  in ipv6_deactivate()
834 	p->row_status = RowStatus_notInService;  in ipv6_deactivate()
853 		if (cmsg->cmsg_level == IPPROTO_IPV6 &&  in ipv6_parse_ctrl()
854 		    cmsg->cmsg_type == IPV6_PKTINFO) {  in ipv6_parse_ctrl()
858 			sock->ret_source.a6.ipi6_addr = info->ipi6_addr;  in ipv6_parse_ctrl()
859 			sock->ret_source.a6.ipi6_ifindex =  in ipv6_parse_ctrl()
860 			    !IN6_IS_ADDR_LINKLOCAL(&info->ipi6_addr) ? 0:  in ipv6_parse_ctrl()
861 			    info->ipi6_ifindex;  in ipv6_parse_ctrl()
863 		} else if (cmsg->cmsg_level == SOL_SOCKET &&  in ipv6_parse_ctrl()
864 		    cmsg->cmsg_type == SCM_CREDS) {  in ipv6_parse_ctrl()
869 	sock->input.priv = 0;  in ipv6_parse_ctrl()
870 	if (sock->input.cred && cred)  in ipv6_parse_ctrl()
872 		sock->input.priv = (cred->sc_euid == 0);  in ipv6_parse_ctrl()
886 	msg->msg_control = cbuf;  in ipv6_setsrc()
887 	msg->msg_controllen = CMSG_SPACE(sizeof(struct in6_pktinfo));  in ipv6_setsrc()
891 	cmsg->cmsg_level = IPPROTO_IPV6;  in ipv6_setsrc()
892 	cmsg->cmsg_type = IPV6_PKTINFO;  in ipv6_setsrc()
893 	cmsg->cmsg_len = CMSG_LEN(sizeof(struct in6_pktinfo));  in ipv6_setsrc()
894 	memcpy(CMSG_DATA(cmsg), &sock->ret_source.a6,  in ipv6_setsrc()
902  * \param port		the port to create
910 	if (params->addr_len != 20)  in ipv6z_create()
916 		scope_id |= params->addr[i];  in ipv6z_create()
930  * \param port		the port to create
938 	if (params->addr_len > 64)  in dns_create()
941 	if (strnlen(params->addr, params->addr_len) !=  in dns_create()
942 	    params->addr_len)  in dns_create()
945 	if ((port->dns_addr = realloc(params->addr,  in dns_create()
946 	    params->addr_len + 1)) == NULL)  in dns_create()
949 	port->dns_addr[params->addr_len] = '\0';  in dns_create()
950 	params->addr = NULL;  in dns_create()
952 	port->dns_port = htons(params->port);  in dns_create()
971 	hints.ai_socktype = SOCK_DGRAM;		// XXX udp-only  in dns_activate()
975 	sprintf(portbuf, "%hu", ntohs(port->dns_port));  in dns_activate()
978 	int error = getaddrinfo(port->dns_addr[0] == '\0'  in dns_activate()
979 	    ? NULL : port->dns_addr,  in dns_activate()
984 		    port->dns_addr, gai_strerror(error));  in dns_activate()
988 	for (struct addrinfo *res = res0; res != NULL; res = res->ai_next) {  in dns_activate()
989 		if (res->ai_family != AF_INET && res->ai_family != AF_INET6)  in dns_activate()
996 		snmpd_input_init(&sock->input);  in dns_activate()
997 		sock->port = port;  in dns_activate()
1001 		if (res->ai_family == AF_INET) {  in dns_activate()
1002 			*(struct sockaddr_in *)&sock->bind_addr =  in dns_activate()
1003 			    *(struct sockaddr_in *)(void *)res->ai_addr;  in dns_activate()
1006 			*(struct sockaddr_in6 *)&sock->bind_addr =  in dns_activate()
1007 			    *(struct sockaddr_in6 *)(void *)res->ai_addr;  in dns_activate()
1014 			TAILQ_INSERT_HEAD(&port->socks, sock, link);  in dns_activate()
1017 	if (!TAILQ_EMPTY(&port->socks))  in dns_activate()
1018 		port->row_status = RowStatus_active;  in dns_activate()
1032 	while (!TAILQ_EMPTY(&port->socks)) {  in dns_deactivate()
1033 		struct port_sock *sock = TAILQ_FIRST(&port->socks);  in dns_deactivate()
1034 		TAILQ_REMOVE(&port->socks, sock, link);  in dns_deactivate()
1035 		snmpd_input_close(&sock->input);  in dns_deactivate()
1038 	port->row_status = RowStatus_notInService;  in dns_deactivate()
1047 	if (params->port > 0xffff) {  in inet_create()
1057 	TAILQ_INIT(&port->socks);  in inet_create()
1059 	port->proto = params->proto;  in inet_create()
1060 	port->tport.index = params->index;  in inet_create()
1062 	switch (params->type) {  in inet_create()
1065 		port->create = ipv4_create;  in inet_create()
1066 		port->activate = ipv4_activate;  in inet_create()
1067 		port->deactivate = ipv4_deactivate;  in inet_create()
1071 		port->create = ipv6_create;  in inet_create()
1072 		port->activate = ipv6_activate;  in inet_create()
1073 		port->deactivate = ipv6_deactivate;  in inet_create()
1077 		port->create = ipv6z_create;  in inet_create()
1078 		port->activate = ipv6_activate;  in inet_create()
1079 		port->deactivate = ipv6_deactivate;  in inet_create()
1083 		port->create = dns_create;  in inet_create()
1084 		port->activate = dns_activate;  in inet_create()
1085 		port->deactivate = dns_deactivate;  in inet_create()
1093 	if ((err = port->create(port, params)) != SNMP_ERR_NOERROR)  in inet_create()
1097 	trans_insert_port(my_trans, &port->tport);  in inet_create()
1101 	free(port->dns_addr);  in inet_create()
1115 	port->row_status = RowStatus_createAndGo;  in create_and_go()
1116 	ctx->scratch->ptr1 = port;  in create_and_go()
1121 	return (inet_activate(&port->tport));  in create_and_go()
1133 	port->row_status = RowStatus_createAndWait;  in create_and_wait()
1134 	ctx->scratch->ptr1 = port;  in create_and_wait()
1140  * This is called to set a RowStatus value in the port table during
1144  * to CreateAndGo, the port is actually not activated. This is done when
1156 		ctx->scratch->int1 = SET_CREATED;  in inet_port_set()
1162 		ctx->scratch->int1 = SET_CREATED;  in inet_port_set()
1169 		switch (port->row_status) {  in inet_port_set()
1176 			ctx->scratch->int1 = SET_ACTIVATED;  in inet_port_set()
1177 			return (inet_activate(&port->tport));  in inet_port_set()
1193 		switch (port->row_status) {  in inet_port_set()
1204 			ctx->scratch->int1 = SET_DEACTIVATE;  in inet_port_set()
1216 		ctx->scratch->int1 = SET_DESTROY;  in inet_port_set()
1232 	asn_subid_t which = value->var.subs[sub - 1];  in op_snmp_trans_inet()
1241 		    &value->var, sub)) == NULL)  in op_snmp_trans_inet()
1243 		index_append(&value->var, sub, &port->tport.index);  in op_snmp_trans_inet()
1248 		    &value->var, sub)) == NULL)  in op_snmp_trans_inet()
1254 		    &value->var, sub);  in op_snmp_trans_inet()
1258 		if (!isok_RowStatus(value->v.integer))  in op_snmp_trans_inet()
1261 		if (index_decode(&value->var, sub, iidx, &params.type,  in op_snmp_trans_inet()
1266 		asn_slice_oid(&params.index, &value->var, sub, value->var.len);  in op_snmp_trans_inet()
1269 		    (enum RowStatus)value->v.integer);  in op_snmp_trans_inet()
1276 		    &value->var, sub)) == NULL)  in op_snmp_trans_inet()
1280 		switch (ctx->scratch->int1) {  in op_snmp_trans_inet()
1285 			inet_destroy_port(&port->tport);  in op_snmp_trans_inet()
1304 		    &value->var, sub)) == NULL)  in op_snmp_trans_inet()
1308 		switch (ctx->scratch->int1) {  in op_snmp_trans_inet()
1318 			inet_destroy_port(&port->tport);  in op_snmp_trans_inet()
1336 		value->v.integer = port->row_status;  in op_snmp_trans_inet()