Head

GCC Code Coverage Report

Directory:	./		Exec	Total	Coverage
File:	usr.sbin/dvmrpd/igmp.c	Lines:	0	89	0.0 %
Date:	2017-11-13	Branches:	0	50	0.0 %


/*	$OpenBSD: igmp.c,v 1.4 2015/12/07 19:14:49 mmcc Exp $ */

/*
 * Copyright (c) 2005, 2006 Esben Norby <norby@openbsd.org>
 *
 * Permission to use, copy, modify, and distribute this software for any
 * purpose with or without fee is hereby granted, provided that the above
 * copyright notice and this permission notice appear in all copies.
 *
 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 */

#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/time.h>
#include <stdlib.h>
#include <string.h>
#include <event.h>

#include "igmp.h"
#include "dvmrpd.h"
#include "dvmrp.h"
#include "log.h"
#include "dvmrpe.h"

int	 igmp_chksum(struct igmp_hdr *);

/* IGMP packet handling */
int
send_igmp_query(struct iface *iface, struct group *group)
{
	struct igmp_hdr		 igmp_hdr;
	struct sockaddr_in	 dst;
	struct ibuf		*buf;
	int			 ret = 0;

	log_debug("send_igmp_query: interface %s", iface->name);

	if (iface->passive)
		return (0);

	if ((buf = ibuf_open(iface->mtu - sizeof(struct ip))) == NULL)
		fatal("send_igmp_query");

	/* IGMP header */
	memset(&igmp_hdr, 0, sizeof(igmp_hdr));
	igmp_hdr.type = PKT_TYPE_MEMBER_QUERY;

	if (group == NULL) {
		/* general query - version is configured */
		igmp_hdr.grp_addr = 0;

		switch (iface->igmp_version) {
		case 1:
			break;
		case 2:
			igmp_hdr.max_resp_time = iface->query_resp_interval;
			break;
		default:
			fatal("send_igmp_query: invalid igmp version");
		}
	} else {
		/* group specific query - only version 2 */
		igmp_hdr.grp_addr = group->addr.s_addr;
		igmp_hdr.max_resp_time = iface->last_member_query_interval;
	}

	/* update chksum */
	igmp_hdr.chksum = in_cksum(&igmp_hdr, sizeof(igmp_hdr));

	ibuf_add(buf, &igmp_hdr, sizeof(igmp_hdr));

	/* set destination address */
	dst.sin_family = AF_INET;
	dst.sin_len = sizeof(struct sockaddr_in);
	inet_aton(AllSystems, &dst.sin_addr);

	ret = send_packet(iface, buf->buf, buf->wpos, &dst);
	ibuf_free(buf);
	return (ret);
}

void
recv_igmp_query(struct iface *iface, struct in_addr src, char *buf,
    u_int16_t len)
{
	struct igmp_hdr	 igmp_hdr;
	struct group	*group;

	log_debug("recv_igmp_query: interface %s", iface->name);

	if (len < sizeof(igmp_hdr)) {
		log_debug("recv_igmp_query: invalid IGMP report, interface %s",
		    iface->name);
		return;
	}

	memcpy(&igmp_hdr, buf, sizeof(igmp_hdr));
	iface->recv_query_resp_interval = igmp_hdr.max_resp_time;

	/* verify chksum */
	if (igmp_chksum(&igmp_hdr) == -1) {
		log_debug("recv_igmp_query: invalid chksum, interface %s",
		    iface->name);
		return;
	}

	if (src.s_addr < iface->addr.s_addr && igmp_hdr.grp_addr == 0) {
		/* we received a general query and we lost the election */
		if_fsm(iface, IF_EVT_QRECVD);
		/* remember who is querier */
		iface->querier = src;
		return;
	}

	if (iface->state == IF_STA_NONQUERIER && igmp_hdr.grp_addr != 0) {
		/* validate group id */
		if (!IN_MULTICAST(ntohl(igmp_hdr.grp_addr))) {
			log_debug("recv_igmp_query: invalid group, "
			    "interface %s", iface->name);
			return;
		}

		if ((group = group_list_add(iface, igmp_hdr.grp_addr))
		    != NULL)
			group_fsm(group, GRP_EVT_QUERY_RCVD);
	}
}

void
recv_igmp_report(struct iface *iface, struct in_addr src, char *buf,
    u_int16_t len, u_int8_t type)
{
	struct igmp_hdr	 igmp_hdr;
	struct group	*group;

	log_debug("recv_igmp_report: interface %s", iface->name);

	if (len < sizeof(igmp_hdr)) {
		log_debug("recv_igmp_report: invalid IGMP report, interface %s",
		    iface->name);
		return;
	}

	memcpy(&igmp_hdr, buf, sizeof(igmp_hdr));

	/* verify chksum */
	if (igmp_chksum(&igmp_hdr) == -1) {
		log_debug("recv_igmp_report: invalid chksum, interface %s",
		    iface->name);
		return;
	}

	/* validate group id */
	if (!IN_MULTICAST(ntohl(igmp_hdr.grp_addr))) {
		log_debug("recv_igmp_report: invalid group, interface %s",
		    iface->name);
		return;
	}

	if ((group = group_list_add(iface, igmp_hdr.grp_addr)) == NULL)
		return;

	if (iface->state == IF_STA_QUERIER) {
		/* querier */
		switch (type) {
		case PKT_TYPE_MEMBER_REPORTv1:
			group_fsm(group, GRP_EVT_V1_REPORT_RCVD);
			break;
		case PKT_TYPE_MEMBER_REPORTv2:
			group_fsm(group, GRP_EVT_V2_REPORT_RCVD);
			break;
		default:
			fatalx("recv_igmp_report: unknown IGMP report type");
		}
	} else {
		/* non querier */
		group_fsm(group, GRP_EVT_REPORT_RCVD);
	}
}

void
recv_igmp_leave(struct iface *iface, struct in_addr src, char *buf,
    u_int16_t len)
{
	struct igmp_hdr	 igmp_hdr;
	struct group	*group;

	log_debug("recv_igmp_leave: interface %s", iface->name);

	if (iface->state != IF_STA_QUERIER)
		return;

	if (len < sizeof(igmp_hdr)) {
		log_debug("recv_igmp_leave: invalid IGMP leave, interface %s",
		    iface->name);
		return;
	}

	memcpy(&igmp_hdr, buf, sizeof(igmp_hdr));

	/* verify chksum */
	if (igmp_chksum(&igmp_hdr) == -1) {
		log_debug("recv_igmp_leave: invalid chksum, interface %s",
		    iface->name);
		return;
	}

	/* validate group id */
	if (!IN_MULTICAST(ntohl(igmp_hdr.grp_addr))) {
		log_debug("recv_igmp_leave: invalid group, interface %s",
		    iface->name);
		return;
	}

	if ((group = group_list_find(iface, igmp_hdr.grp_addr)) != NULL) {
		group_fsm(group, GRP_EVT_LEAVE_RCVD);
	}
}

int
igmp_chksum(struct igmp_hdr *igmp_hdr)
{
	u_int16_t	chksum;

	chksum = igmp_hdr->chksum;
	igmp_hdr->chksum = 0;

	if (chksum != in_cksum(igmp_hdr, sizeof(*igmp_hdr)))
		return (-1);

	return (0);
}


Generated by: GCOVR (Version 3.3)

Line	Branch	Exec	Source
1			/* $OpenBSD: igmp.c,v 1.4 2015/12/07 19:14:49 mmcc Exp $ */
2
3			/*
4			* Copyright (c) 2005, 2006 Esben Norby <norby@openbsd.org>
5			*
6			* Permission to use, copy, modify, and distribute this software for any
7			* purpose with or without fee is hereby granted, provided that the above
8			* copyright notice and this permission notice appear in all copies.
9			*
10			* THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
11			* WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
12			* MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
13			* ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
14			* WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
15			* ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
16			* OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
17			*/
18
19			#include <sys/types.h>
20			#include <sys/socket.h>
21			#include <netinet/in.h>
22			#include <arpa/inet.h>
23			#include <sys/time.h>
24			#include <stdlib.h>
25			#include <string.h>
26			#include <event.h>
27
28			#include "igmp.h"
29			#include "dvmrpd.h"
30			#include "dvmrp.h"
31			#include "log.h"
32			#include "dvmrpe.h"
33
34			int igmp_chksum(struct igmp_hdr *);
35
36			/* IGMP packet handling */
37			int
38			send_igmp_query(struct iface iface, struct group group)
39			{
40			struct igmp_hdr igmp_hdr;
41			struct sockaddr_in dst;
42			struct ibuf *buf;
43			int ret = 0;
44
45			log_debug("send_igmp_query: interface %s", iface->name);
46
47			if (iface->passive)
48			return (0);
49
50			if ((buf = ibuf_open(iface->mtu - sizeof(struct ip))) == NULL)
51			fatal("send_igmp_query");
52
53			/* IGMP header */
54			memset(&igmp_hdr, 0, sizeof(igmp_hdr));
55			igmp_hdr.type = PKT_TYPE_MEMBER_QUERY;
56
57			if (group == NULL) {
58			/* general query - version is configured */
59			igmp_hdr.grp_addr = 0;
60
61			switch (iface->igmp_version) {
62			case 1:
63			break;
64			case 2:
65			igmp_hdr.max_resp_time = iface->query_resp_interval;
66			break;
67			default:
68			fatal("send_igmp_query: invalid igmp version");
69			}
70			} else {
71			/* group specific query - only version 2 */
72			igmp_hdr.grp_addr = group->addr.s_addr;
73			igmp_hdr.max_resp_time = iface->last_member_query_interval;
74			}
75
76			/* update chksum */
77			igmp_hdr.chksum = in_cksum(&igmp_hdr, sizeof(igmp_hdr));
78
79			ibuf_add(buf, &igmp_hdr, sizeof(igmp_hdr));
80
81			/* set destination address */
82			dst.sin_family = AF_INET;
83			dst.sin_len = sizeof(struct sockaddr_in);
84			inet_aton(AllSystems, &dst.sin_addr);
85
86			ret = send_packet(iface, buf->buf, buf->wpos, &dst);
87			ibuf_free(buf);
88			return (ret);
89			}
90
91			void
92			recv_igmp_query(struct iface iface, struct in_addr src, char buf,
93			u_int16_t len)
94			{
95			struct igmp_hdr igmp_hdr;
96			struct group *group;
97
98			log_debug("recv_igmp_query: interface %s", iface->name);
99
100			if (len < sizeof(igmp_hdr)) {
101			log_debug("recv_igmp_query: invalid IGMP report, interface %s",
102			iface->name);
103			return;
104			}
105
106			memcpy(&igmp_hdr, buf, sizeof(igmp_hdr));
107			iface->recv_query_resp_interval = igmp_hdr.max_resp_time;
108
109			/* verify chksum */
110			if (igmp_chksum(&igmp_hdr) == -1) {
111			log_debug("recv_igmp_query: invalid chksum, interface %s",
112			iface->name);
113			return;
114			}
115
116			if (src.s_addr < iface->addr.s_addr && igmp_hdr.grp_addr == 0) {
117			/* we received a general query and we lost the election */
118			if_fsm(iface, IF_EVT_QRECVD);
119			/* remember who is querier */
120			iface->querier = src;
121			return;
122			}
123
124			if (iface->state == IF_STA_NONQUERIER && igmp_hdr.grp_addr != 0) {
125			/* validate group id */
126			if (!IN_MULTICAST(ntohl(igmp_hdr.grp_addr))) {
127			log_debug("recv_igmp_query: invalid group, "
128			"interface %s", iface->name);
129			return;
130			}
131
132			if ((group = group_list_add(iface, igmp_hdr.grp_addr))
133			!= NULL)
134			group_fsm(group, GRP_EVT_QUERY_RCVD);
135			}
136			}
137
138			void
139			recv_igmp_report(struct iface iface, struct in_addr src, char buf,
140			u_int16_t len, u_int8_t type)
141			{
142			struct igmp_hdr igmp_hdr;
143			struct group *group;
144
145			log_debug("recv_igmp_report: interface %s", iface->name);
146
147			if (len < sizeof(igmp_hdr)) {
148			log_debug("recv_igmp_report: invalid IGMP report, interface %s",
149			iface->name);
150			return;
151			}
152
153			memcpy(&igmp_hdr, buf, sizeof(igmp_hdr));
154
155			/* verify chksum */
156			if (igmp_chksum(&igmp_hdr) == -1) {
157			log_debug("recv_igmp_report: invalid chksum, interface %s",
158			iface->name);
159			return;
160			}
161
162			/* validate group id */
163			if (!IN_MULTICAST(ntohl(igmp_hdr.grp_addr))) {
164			log_debug("recv_igmp_report: invalid group, interface %s",
165			iface->name);
166			return;
167			}
168
169			if ((group = group_list_add(iface, igmp_hdr.grp_addr)) == NULL)
170			return;
171
172			if (iface->state == IF_STA_QUERIER) {
173			/* querier */
174			switch (type) {
175			case PKT_TYPE_MEMBER_REPORTv1:
176			group_fsm(group, GRP_EVT_V1_REPORT_RCVD);
177			break;
178			case PKT_TYPE_MEMBER_REPORTv2:
179			group_fsm(group, GRP_EVT_V2_REPORT_RCVD);
180			break;
181			default:
182			fatalx("recv_igmp_report: unknown IGMP report type");
183			}
184			} else {
185			/* non querier */
186			group_fsm(group, GRP_EVT_REPORT_RCVD);
187			}
188			}
189
190			void
191			recv_igmp_leave(struct iface iface, struct in_addr src, char buf,
192			u_int16_t len)
193			{
194			struct igmp_hdr igmp_hdr;
195			struct group *group;
196
197			log_debug("recv_igmp_leave: interface %s", iface->name);
198
199			if (iface->state != IF_STA_QUERIER)
200			return;
201
202			if (len < sizeof(igmp_hdr)) {
203			log_debug("recv_igmp_leave: invalid IGMP leave, interface %s",
204			iface->name);
205			return;
206			}
207
208			memcpy(&igmp_hdr, buf, sizeof(igmp_hdr));
209
210			/* verify chksum */
211			if (igmp_chksum(&igmp_hdr) == -1) {
212			log_debug("recv_igmp_leave: invalid chksum, interface %s",
213			iface->name);
214			return;
215			}
216
217			/* validate group id */
218			if (!IN_MULTICAST(ntohl(igmp_hdr.grp_addr))) {
219			log_debug("recv_igmp_leave: invalid group, interface %s",
220			iface->name);
221			return;
222			}
223
224			if ((group = group_list_find(iface, igmp_hdr.grp_addr)) != NULL) {
225			group_fsm(group, GRP_EVT_LEAVE_RCVD);
226			}
227			}
228
229			int
230			igmp_chksum(struct igmp_hdr *igmp_hdr)
231			{
232			u_int16_t chksum;
233
234			chksum = igmp_hdr->chksum;
235			igmp_hdr->chksum = 0;
236
237			if (chksum != in_cksum(igmp_hdr, sizeof(*igmp_hdr)))
238			return (-1);
239
240			return (0);
241			}