Annotation of embedaddon/pimdd/igmp_proto.c, revision 1.1.1.1
1.1 misho 1: /*
2: * Copyright (c) 1998 by the University of Oregon.
3: * All rights reserved.
4: *
5: * Permission to use, copy, modify, and distribute this software and
6: * its documentation in source and binary forms for lawful
7: * purposes and without fee is hereby granted, provided
8: * that the above copyright notice appear in all copies and that both
9: * the copyright notice and this permission notice appear in supporting
10: * documentation, and that any documentation, advertising materials,
11: * and other materials related to such distribution and use acknowledge
12: * that the software was developed by the University of Oregon.
13: * The name of the University of Oregon may not be used to endorse or
14: * promote products derived from this software without specific prior
15: * written permission.
16: *
17: * THE UNIVERSITY OF OREGON DOES NOT MAKE ANY REPRESENTATIONS
18: * ABOUT THE SUITABILITY OF THIS SOFTWARE FOR ANY PURPOSE. THIS SOFTWARE IS
19: * PROVIDED "AS IS" AND WITHOUT ANY EXPRESS OR IMPLIED WARRANTIES,
20: * INCLUDING, WITHOUT LIMITATION, THE IMPLIED WARRANTIES OF
21: * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE, TITLE, AND
22: * NON-INFRINGEMENT.
23: *
24: * IN NO EVENT SHALL UO, OR ANY OTHER CONTRIBUTOR BE LIABLE FOR ANY
25: * SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES, WHETHER IN CONTRACT,
26: * TORT, OR OTHER FORM OF ACTION, ARISING OUT OF OR IN CONNECTION WITH,
27: * THE USE OR PERFORMANCE OF THIS SOFTWARE.
28: *
29: * Other copyrights might apply to parts of this software and are so
30: * noted when applicable.
31: */
32: /*
33: * Questions concerning this software should be directed to
34: * Kurt Windisch (kurtw@antc.uoregon.edu)
35: *
36: * $Id: igmp_proto.c,v 1.4 1998/05/29 21:58:22 kurtw Exp $
37: */
38: /*
39: * Part of this program has been derived from PIM sparse-mode pimd.
40: * The pimd program is covered by the license in the accompanying file
41: * named "LICENSE.pimd".
42: *
43: * The pimd program is COPYRIGHT 1998 by University of Southern California.
44: *
45: * Part of this program has been derived from mrouted.
46: * The mrouted program is covered by the license in the accompanying file
47: * named "LICENSE.mrouted".
48: *
49: * The mrouted program is COPYRIGHT 1989 by The Board of Trustees of
50: * Leland Stanford Junior University.
51: *
52: */
53:
54: #include "defs.h"
55:
56:
57: typedef struct {
58: vifi_t vifi;
59: struct listaddr *g;
60: int q_time;
61: } cbk_t;
62:
63:
64: /*
65: * Forward declarations.
66: */
67: static void DelVif __P((void *arg));
68: static int SetTimer __P((int vifi, struct listaddr *g));
69: static int DeleteTimer __P((int id));
70: static void SendQuery __P((void *arg));
71: static int SetQueryTimer __P((struct listaddr *g, vifi_t vifi, int to_expire,
72: int q_time));
73:
74:
75: /*
76: * Send group membership queries on that interface if I am querier.
77: */
78: void
79: query_groups(v)
80: register struct uvif *v;
81: {
82: register struct listaddr *g;
83:
84: v->uv_gq_timer = IGMP_QUERY_INTERVAL;
85: if (v->uv_flags & VIFF_QUERIER)
86: send_igmp(igmp_send_buf, v->uv_lcl_addr, allhosts_group,
87: IGMP_MEMBERSHIP_QUERY,
88: (v->uv_flags & VIFF_IGMPV1) ? 0 :
89: IGMP_MAX_HOST_REPORT_DELAY * IGMP_TIMER_SCALE, 0, 0);
90: /*
91: * Decrement the old-hosts-present timer for each
92: * active group on that vif.
93: */
94: for (g = v->uv_groups; g != NULL; g = g->al_next)
95: if (g->al_old > TIMER_INTERVAL)
96: g->al_old -= TIMER_INTERVAL;
97: else
98: g->al_old = 0;
99: }
100:
101:
102: /*
103: * Process an incoming host membership query
104: */
105: void
106: accept_membership_query(src, dst, group, tmo)
107: u_int32 src, dst, group;
108: int tmo;
109: {
110: register vifi_t vifi;
111: register struct uvif *v;
112:
113: /* Ignore my own membership query */
114: if (local_address(src) != NO_VIF)
115: return;
116:
117: /* TODO: modify for DVMRP?? */
118: if ((vifi = find_vif_direct(src)) == NO_VIF) {
119: IF_DEBUG(DEBUG_IGMP)
120: log(LOG_INFO, 0,
121: "ignoring group membership query from non-adjacent host %s",
122: inet_fmt(src, s1));
123: return;
124: }
125:
126: v = &uvifs[vifi];
127:
128: if ((tmo == 0 && !(v->uv_flags & VIFF_IGMPV1)) ||
129: (tmo != 0 && (v->uv_flags & VIFF_IGMPV1))) {
130: int i;
131:
132: /*
133: * Exponentially back-off warning rate
134: */
135: i = ++v->uv_igmpv1_warn;
136: while (i && !(i & 1))
137: i >>= 1;
138: if (i == 1)
139: log(LOG_WARNING, 0, "%s %s on vif %d, %s",
140: tmo == 0 ? "Received IGMPv1 report from"
141: : "Received IGMPv2 report from",
142: inet_fmt(src, s1),
143: vifi,
144: tmo == 0 ? "please configure vif for IGMPv1"
145: : "but I am configured for IGMPv1");
146: }
147:
148: if (v->uv_querier == NULL || v->uv_querier->al_addr != src) {
149: /*
150: * This might be:
151: * - A query from a new querier, with a lower source address
152: * than the current querier (who might be me)
153: * - A query from a new router that just started up and doesn't
154: * know who the querier is.
155: * - A query from the current querier
156: */
157: if (ntohl(src) < (v->uv_querier ? ntohl(v->uv_querier->al_addr)
158: : ntohl(v->uv_lcl_addr))) {
159: IF_DEBUG(DEBUG_IGMP)
160: log(LOG_DEBUG, 0, "new querier %s (was %s) on vif %d",
161: inet_fmt(src, s1),
162: v->uv_querier ?
163: inet_fmt(v->uv_querier->al_addr, s2) :
164: "me", vifi);
165: if (!v->uv_querier) {
166: v->uv_querier = (struct listaddr *)
167: malloc(sizeof(struct listaddr));
168: v->uv_querier->al_next = (struct listaddr *)NULL;
169: v->uv_querier->al_timer = 0;
170: v->uv_querier->al_genid = 0;
171: /* TODO: write the protocol version */
172: v->uv_querier->al_pv = 0;
173: v->uv_querier->al_mv = 0;
174: v->uv_querier->al_old = 0;
175: v->uv_querier->al_index = 0;
176: v->uv_querier->al_timerid = 0;
177: v->uv_querier->al_query = 0;
178: v->uv_querier->al_flags = 0;
179:
180: v->uv_flags &= ~VIFF_QUERIER;
181: }
182: v->uv_querier->al_addr = src;
183: time(&v->uv_querier->al_ctime);
184: }
185: }
186:
187: /*
188: * Reset the timer since we've received a query.
189: */
190: if (v->uv_querier && src == v->uv_querier->al_addr)
191: v->uv_querier->al_timer = 0;
192:
193: /*
194: * If this is a Group-Specific query which we did not source,
195: * we must set our membership timer to [Last Member Query Count] *
196: * the [Max Response Time] in the packet.
197: */
198: if (!(v->uv_flags & VIFF_IGMPV1) && group != 0 &&
199: src != v->uv_lcl_addr) {
200: register struct listaddr *g;
201:
202: IF_DEBUG(DEBUG_IGMP)
203: log(LOG_DEBUG, 0,
204: "%s for %s from %s on vif %d, timer %d",
205: "Group-specific membership query",
206: inet_fmt(group, s2), inet_fmt(src, s1), vifi, tmo);
207:
208: for (g = v->uv_groups; g != NULL; g = g->al_next) {
209: if (group == g->al_addr && g->al_query == 0) {
210: /* setup a timeout to remove the group membership */
211: if (g->al_timerid)
212: g->al_timerid = DeleteTimer(g->al_timerid);
213: g->al_timer = IGMP_LAST_MEMBER_QUERY_COUNT *
214: tmo / IGMP_TIMER_SCALE;
215: /* use al_query to record our presence in last-member state */
216: g->al_query = -1;
217: g->al_timerid = SetTimer(vifi, g);
218: IF_DEBUG(DEBUG_IGMP)
219: log(LOG_DEBUG, 0,
220: "timer for grp %s on vif %d set to %d",
221: inet_fmt(group, s2), vifi, g->al_timer);
222: break;
223: }
224: }
225: }
226: }
227:
228:
229: /*
230: * Process an incoming group membership report.
231: */
232: void
233: accept_group_report(src, dst, group, igmp_report_type)
234: u_int32 src, dst, group;
235: int igmp_report_type;
236: {
237: register vifi_t vifi;
238: register struct uvif *v;
239: register struct listaddr *g;
240:
241: if ((vifi = find_vif_direct_local(src)) == NO_VIF) {
242: IF_DEBUG(DEBUG_IGMP)
243: log(LOG_INFO, 0,
244: "ignoring group membership report from non-adjacent host %s",
245: inet_fmt(src, s1));
246: return;
247: }
248:
249: IF_DEBUG(DEBUG_IGMP)
250: log(LOG_INFO, 0,
251: "accepting IGMP group membership report: src %s, dst% s, grp %s",
252: inet_fmt(src, s1), inet_fmt(dst, s2), inet_fmt(group, s3));
253:
254: v = &uvifs[vifi];
255:
256: /*
257: * Look for the group in our group list; if found, reset its timer.
258: */
259: for (g = v->uv_groups; g != NULL; g = g->al_next) {
260: if (group == g->al_addr) {
261: if (igmp_report_type == IGMP_V1_MEMBERSHIP_REPORT)
262: g->al_old = DVMRP_OLD_AGE_THRESHOLD;
263:
264: g->al_reporter = src;
265:
266: /** delete old timers, set a timer for expiration **/
267: g->al_timer = IGMP_GROUP_MEMBERSHIP_INTERVAL;
268: if (g->al_query)
269: g->al_query = DeleteTimer(g->al_query);
270: if (g->al_timerid)
271: g->al_timerid = DeleteTimer(g->al_timerid);
272: g->al_timerid = SetTimer(vifi, g);
273: add_leaf(vifi, INADDR_ANY_N, group);
274: break;
275: }
276: }
277:
278: /*
279: * If not found, add it to the list and update kernel cache.
280: */
281: if (g == NULL) {
282: g = (struct listaddr *)malloc(sizeof(struct listaddr));
283: if (g == NULL)
284: log(LOG_ERR, 0, "ran out of memory"); /* fatal */
285:
286: g->al_addr = group;
287: if (igmp_report_type == IGMP_V1_MEMBERSHIP_REPORT)
288: g->al_old = DVMRP_OLD_AGE_THRESHOLD;
289: else
290: g->al_old = 0;
291:
292: /** set a timer for expiration **/
293: g->al_query = 0;
294: g->al_timer = IGMP_GROUP_MEMBERSHIP_INTERVAL;
295: g->al_reporter = src;
296: g->al_timerid = SetTimer(vifi, g);
297: g->al_next = v->uv_groups;
298: v->uv_groups = g;
299: time(&g->al_ctime);
300:
301: add_leaf(vifi, INADDR_ANY_N, group);
302: }
303: }
304:
305:
306: /* TODO: send PIM prune message if the last member? */
307: void
308: accept_leave_message(src, dst, group)
309: u_int32 src, dst, group;
310: {
311: register vifi_t vifi;
312: register struct uvif *v;
313: register struct listaddr *g;
314:
315: /* TODO: modify for DVMRP ??? */
316: if ((vifi = find_vif_direct_local(src)) == NO_VIF) {
317: IF_DEBUG(DEBUG_IGMP)
318: log(LOG_INFO, 0,
319: "ignoring group leave report from non-adjacent host %s",
320: inet_fmt(src, s1));
321: return;
322: }
323:
324: IF_DEBUG(DEBUG_IGMP)
325: log(LOG_INFO, 0,
326: "accepting IGMP leave message: src %s, dst% s, grp %s",
327: inet_fmt(src, s1), inet_fmt(dst, s2), inet_fmt(group, s3));
328:
329: v = &uvifs[vifi];
330:
331: if (!(v->uv_flags & (VIFF_QUERIER | VIFF_DR))
332: || (v->uv_flags & VIFF_IGMPV1))
333: return;
334:
335: /*
336: * Look for the group in our group list in order to set up a short-timeout
337: * query.
338: */
339: for (g = v->uv_groups; g != NULL; g = g->al_next) {
340: if (group == g->al_addr) {
341: IF_DEBUG(DEBUG_IGMP)
342: log(LOG_DEBUG, 0,
343: "[vif.c, _accept_leave_message] %d %d \n",
344: g->al_old, g->al_query);
345:
346: /* Ignore the leave message if there are old hosts present */
347: if (g->al_old)
348: return;
349:
350: /* still waiting for a reply to a query, ignore the leave */
351: if (g->al_query)
352: return;
353:
354: /** delete old timer set a timer for expiration **/
355: if (g->al_timerid)
356: g->al_timerid = DeleteTimer(g->al_timerid);
357:
358: #if IGMP_LAST_MEMBER_QUERY_COUNT != 2
359: /*
360: This code needs to be updated to keep a counter of the number
361: of queries remaining.
362: */
363: #endif
364: /** send a group specific querry **/
365: g->al_timer = IGMP_LAST_MEMBER_QUERY_INTERVAL *
366: (IGMP_LAST_MEMBER_QUERY_COUNT + 1);
367: if (v->uv_flags & VIFF_QUERIER)
368: send_igmp(igmp_send_buf, v->uv_lcl_addr, g->al_addr,
369: IGMP_MEMBERSHIP_QUERY,
370: IGMP_LAST_MEMBER_QUERY_INTERVAL * IGMP_TIMER_SCALE,
371: g->al_addr, 0);
372: g->al_query = SetQueryTimer(g, vifi,
373: IGMP_LAST_MEMBER_QUERY_INTERVAL,
374: IGMP_LAST_MEMBER_QUERY_INTERVAL * IGMP_TIMER_SCALE);
375: g->al_timerid = SetTimer(vifi, g);
376: break;
377: }
378: }
379: }
380:
381:
382: /*
383: * Time out record of a group membership on a vif
384: */
385: static void
386: DelVif(arg)
387: void *arg;
388: {
389: cbk_t *cbk = (cbk_t *)arg;
390: vifi_t vifi = cbk->vifi;
391: struct uvif *v = &uvifs[vifi];
392: struct listaddr *a, **anp, *g = cbk->g;
393:
394: /*
395: * Group has expired
396: * delete all kernel cache entries with this group
397: */
398: if (g->al_query)
399: DeleteTimer(g->al_query);
400:
401: delete_leaf(vifi, INADDR_ANY_N, g->al_addr);
402:
403: anp = &(v->uv_groups);
404: while ((a = *anp) != NULL) {
405: if (a == g) {
406: *anp = a->al_next;
407: free((char *)a);
408: } else {
409: anp = &a->al_next;
410: }
411: }
412:
413: free(cbk);
414: }
415:
416:
417: /*
418: * Set a timer to delete the record of a group membership on a vif.
419: */
420: static int
421: SetTimer(vifi, g)
422: vifi_t vifi;
423: struct listaddr *g;
424: {
425: cbk_t *cbk;
426:
427: cbk = (cbk_t *) malloc(sizeof(cbk_t));
428: cbk->vifi = vifi;
429: cbk->g = g;
430: return timer_setTimer(g->al_timer, DelVif, cbk);
431: }
432:
433:
434: /*
435: * Delete a timer that was set above.
436: */
437: static int
438: DeleteTimer(id)
439: int id;
440: {
441: timer_clearTimer(id);
442: return 0;
443: }
444:
445:
446: /*
447: * Send a group-specific query.
448: */
449: static void
450: SendQuery(arg)
451: void *arg;
452: {
453: cbk_t *cbk = (cbk_t *)arg;
454: register struct uvif *v = &uvifs[cbk->vifi];
455:
456: if (v->uv_flags & VIFF_QUERIER)
457: send_igmp(igmp_send_buf, v->uv_lcl_addr, cbk->g->al_addr,
458: IGMP_MEMBERSHIP_QUERY,
459: cbk->q_time, cbk->g->al_addr, 0);
460: cbk->g->al_query = 0;
461: free(cbk);
462: }
463:
464:
465: /*
466: * Set a timer to send a group-specific query.
467: */
468: static int
469: SetQueryTimer(g, vifi, to_expire, q_time)
470: struct listaddr *g;
471: vifi_t vifi;
472: int to_expire;
473: int q_time;
474: {
475: cbk_t *cbk;
476:
477: cbk = (cbk_t *) malloc(sizeof(cbk_t));
478: cbk->g = g;
479: cbk->q_time = q_time;
480: cbk->vifi = vifi;
481: return timer_setTimer(to_expire, SendQuery, cbk);
482: }
483:
484: /* Checks for IGMP group membership: returns TRUE if there is a receiver for the
485: * group on the given vif, or returns FALSE otherwise.
486: */
487: int check_grp_membership(v, group)
488: struct uvif *v;
489: u_int32 group;
490: {
491: register struct listaddr *g;
492:
493: /*
494: * Look for the group in our group list;
495: */
496: for (g = v->uv_groups; g != NULL; g = g->al_next) {
497: if (group == g->al_addr)
498: return TRUE;
499: }
500: return FALSE;
501: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to igmp_proto.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / pimdd