Annotation of embedaddon/pimdd/trace.c, revision 1.1.1.1
1.1 misho 1: /*
2: * Copyright (c) 1998 by the University of Southern California.
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: * non-commercial 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 Southern
13: * California and/or Information Sciences Institute.
14: * The name of the University of Southern California may not
15: * be used to endorse or promote products derived from this software
16: * without specific prior written permission.
17: *
18: * THE UNIVERSITY OF SOUTHERN CALIFORNIA DOES NOT MAKE ANY REPRESENTATIONS
19: * ABOUT THE SUITABILITY OF THIS SOFTWARE FOR ANY PURPOSE. THIS SOFTWARE IS
20: * PROVIDED "AS IS" AND WITHOUT ANY EXPRESS OR IMPLIED WARRANTIES,
21: * INCLUDING, WITHOUT LIMITATION, THE IMPLIED WARRANTIES OF
22: * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE, TITLE, AND
23: * NON-INFRINGEMENT.
24: *
25: * IN NO EVENT SHALL USC, OR ANY OTHER CONTRIBUTOR BE LIABLE FOR ANY
26: * SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES, WHETHER IN CONTRACT,
27: * TORT, OR OTHER FORM OF ACTION, ARISING OUT OF OR IN CONNECTION WITH,
28: * THE USE OR PERFORMANCE OF THIS SOFTWARE.
29: *
30: * Other copyrights might apply to parts of this software and are so
31: * noted when applicable.
32: */
33: /*
34: * Questions concerning this software should be directed to
35: * Pavlin Ivanov Radoslavov (pavlin@catarina.usc.edu)
36: *
37: * $Id: trace.c,v 1.3 1998/06/01 22:27:15 kurtw Exp $
38: */
39: /*
40: * Part of this program has been derived from mrouted.
41: * The mrouted program is covered by the license in the accompanying file
42: * named "LICENSE.mrouted".
43: *
44: * The mrouted program is COPYRIGHT 1989 by The Board of Trustees of
45: * Leland Stanford Junior University.
46: *
47: */
48:
49:
50: #include "defs.h"
51: #include "trace.h"
52:
53:
54: /* TODO */
55: /*
56: * Traceroute function which returns traceroute replies to the requesting
57: * router. Also forwards the request to downstream routers.
58: */
59: void
60: accept_mtrace(src, dst, group, data, no, datalen)
61: u_int32 src;
62: u_int32 dst;
63: u_int32 group;
64: char *data;
65: u_int no; /* promoted u_char */
66: int datalen;
67: {
68: u_char type;
69: mrtentry_t *mrt;
70: struct tr_query *qry;
71: struct tr_resp *resp;
72: int vifi;
73: char *p;
74: int rcount;
75: int errcode = TR_NO_ERR;
76: int resptype;
77: struct timeval tp;
78: struct sioc_vif_req v_req;
79: u_int32 parent_address;
80:
81: /* Remember qid across invocations */
82: static u_int32 oqid = 0;
83:
84: /* timestamp the request/response */
85: gettimeofday(&tp, 0);
86:
87: /*
88: * Check if it is a query or a response
89: */
90: if (datalen == QLEN) {
91: type = QUERY;
92: IF_DEBUG(DEBUG_TRACE)
93: log(LOG_DEBUG, 0, "Initial traceroute query rcvd from %s to %s",
94: inet_fmt(src, s1), inet_fmt(dst, s2));
95: }
96: else if ((datalen - QLEN) % RLEN == 0) {
97: type = RESP;
98: IF_DEBUG(DEBUG_TRACE)
99: log(LOG_DEBUG, 0, "In-transit traceroute query rcvd from %s to %s",
100: inet_fmt(src, s1), inet_fmt(dst, s2));
101: if (IN_MULTICAST(ntohl(dst))) {
102: IF_DEBUG(DEBUG_TRACE)
103: log(LOG_DEBUG, 0, "Dropping multicast response");
104: return;
105: }
106: }
107: else {
108: log(LOG_WARNING, 0, "%s from %s to %s",
109: "Non decipherable traceroute request recieved",
110: inet_fmt(src, s1), inet_fmt(dst, s2));
111: return;
112: }
113:
114: qry = (struct tr_query *)data;
115:
116: /*
117: * if it is a packet with all reports filled, drop it
118: */
119: if ((rcount = (datalen - QLEN)/RLEN) == no) {
120: IF_DEBUG(DEBUG_TRACE)
121: log(LOG_DEBUG, 0, "packet with all reports filled in");
122: return;
123: }
124:
125: IF_DEBUG(DEBUG_TRACE) {
126: log(LOG_DEBUG, 0, "s: %s g: %s d: %s ", inet_fmt(qry->tr_src, s1),
127: inet_fmt(group, s2), inet_fmt(qry->tr_dst, s3));
128: log(LOG_DEBUG, 0, "rttl: %d rd: %s", qry->tr_rttl,
129: inet_fmt(qry->tr_raddr, s1));
130: log(LOG_DEBUG, 0, "rcount:%d, qid:%06x", rcount, qry->tr_qid);
131: }
132:
133: /* determine the routing table entry for this traceroute */
134: mrt = find_route(qry->tr_src, group, MRTF_SG | MRTF_WC | MRTF_PMBR,
135: DONT_CREATE);
136: IF_DEBUG(DEBUG_TRACE)
137: if (mrt != (mrtentry_t *)NULL) {
138: if (mrt->upstream != (pim_nbr_entry_t *)NULL)
139: parent_address = mrt->upstream->address;
140: else
141: parent_address = INADDR_ANY;
142: log(LOG_DEBUG, 0, "mrt parent vif: %d rtr: %s metric: %d",
143: mrt->incoming, inet_fmt(parent_address, s1), mrt->metric);
144: /* TODO
145: log(LOG_DEBUG, 0, "mrt origin %s",
146: RT_FMT(rt, s1));
147: */
148: } else
149: log(LOG_DEBUG, 0, "...no route");
150:
151: /*
152: * Query type packet - check if rte exists
153: * Check if the query destination is a vif connected to me.
154: * and if so, whether I should start response back
155: */
156: if (type == QUERY) {
157: if (oqid == qry->tr_qid) {
158: /*
159: * If the multicast router is a member of the group being
160: * queried, and the query is multicasted, then the router can
161: * recieve multiple copies of the same query. If we have already
162: * replied to this traceroute, just ignore it this time.
163: *
164: * This is not a total solution, but since if this fails you
165: * only get N copies, N <= the number of interfaces on the router,
166: * it is not fatal.
167: */
168: IF_DEBUG(DEBUG_TRACE)
169: log(LOG_DEBUG, 0, "ignoring duplicate traceroute packet");
170: return;
171: }
172:
173: if (mrt == (mrtentry_t *)NULL) {
174: IF_DEBUG(DEBUG_TRACE)
175: log(LOG_DEBUG, 0, "Mcast traceroute: no route entry %s",
176: inet_fmt(qry->tr_src, s1));
177: if (IN_MULTICAST(ntohl(dst)))
178: return;
179: }
180: vifi = find_vif_direct(qry->tr_dst);
181:
182: if (vifi == NO_VIF) {
183: /* The traceroute destination is not on one of my subnet vifs. */
184: IF_DEBUG(DEBUG_TRACE)
185: log(LOG_DEBUG, 0, "Destination %s not an interface",
186: inet_fmt(qry->tr_dst, s1));
187: if (IN_MULTICAST(ntohl(dst)))
188: return;
189: errcode = TR_WRONG_IF;
190: } else if (mrt != (mrtentry_t *)NULL && !VIFM_ISSET(vifi, mrt->oifs)) {
191: IF_DEBUG(DEBUG_TRACE)
192: log(LOG_DEBUG, 0,
193: "Destination %s not on forwarding tree for src %s",
194: inet_fmt(qry->tr_dst, s1), inet_fmt(qry->tr_src, s2));
195: if (IN_MULTICAST(ntohl(dst)))
196: return;
197: errcode = TR_WRONG_IF;
198: }
199: }
200: else {
201: /*
202: * determine which interface the packet came in on
203: * RESP packets travel hop-by-hop so this either traversed
204: * a tunnel or came from a directly attached mrouter.
205: */
206: if ((vifi = find_vif_direct(src)) == NO_VIF) {
207: IF_DEBUG(DEBUG_TRACE)
208: log(LOG_DEBUG, 0, "Wrong interface for packet");
209: errcode = TR_WRONG_IF;
210: }
211: }
212:
213: /* Now that we've decided to send a response, save the qid */
214: oqid = qry->tr_qid;
215:
216: IF_DEBUG(DEBUG_TRACE)
217: log(LOG_DEBUG, 0, "Sending traceroute response");
218:
219: /* copy the packet to the sending buffer */
220: p = igmp_send_buf + MIN_IP_HEADER_LEN + IGMP_MINLEN;
221:
222: bcopy(data, p, datalen);
223:
224: p += datalen;
225:
226: /*
227: * If there is no room to insert our reply, coopt the previous hop
228: * error indication to relay this fact.
229: */
230: if (p + sizeof(struct tr_resp) > igmp_send_buf + RECV_BUF_SIZE) {
231: resp = (struct tr_resp *)p - 1;
232: resp->tr_rflags = TR_NO_SPACE;
233: mrt = NULL;
234: goto sendit;
235: }
236:
237: /*
238: * fill in initial response fields
239: */
240: resp = (struct tr_resp *)p;
241: bzero(resp, sizeof(struct tr_resp));
242: datalen += RLEN;
243:
244: resp->tr_qarr = htonl(((tp.tv_sec + JAN_1970) << 16) +
245: ((tp.tv_usec << 10) / 15625));
246:
247: resp->tr_rproto = PROTO_PIM;
248: resp->tr_outaddr = (vifi == NO_VIF) ? dst : uvifs[vifi].uv_lcl_addr;
249: resp->tr_fttl = (vifi == NO_VIF) ? 0 : uvifs[vifi].uv_threshold;
250: resp->tr_rflags = errcode;
251:
252: /*
253: * obtain # of packets out on interface
254: */
255: v_req.vifi = vifi;
256: if (vifi != NO_VIF && ioctl(udp_socket, SIOCGETVIFCNT, (char *)&v_req) >= 0)
257: resp->tr_vifout = htonl(v_req.ocount);
258: else
259: resp->tr_vifout = 0xffffffff;
260:
261: /*
262: * fill in scoping & pruning information
263: */
264: /* TODO */
265: #if 0
266: if (mrt != (mrtentry_t *)NULL)
267: for (gt = rt->rt_groups; gt; gt = gt->gt_next) {
268: if (gt->gt_mcastgrp >= group)
269: break;
270: }
271: else
272: gt = NULL;
273:
274: if (gt && gt->gt_mcastgrp == group) {
275: struct stable *st;
276:
277: for (st = gt->gt_srctbl; st; st = st->st_next)
278: if (qry->tr_src == st->st_origin)
279: break;
280:
281: sg_req.src.s_addr = qry->tr_src;
282: sg_req.grp.s_addr = group;
283: if (st && st->st_ctime != 0 &&
284: ioctl(udp_socket, SIOCGETSGCNT, (char *)&sg_req) >= 0)
285: resp->tr_pktcnt = htonl(sg_req.pktcnt + st->st_savpkt);
286: else
287: resp->tr_pktcnt = htonl(st ? st->st_savpkt : 0xffffffff);
288:
289: if (VIFM_ISSET(vifi, gt->gt_scope))
290: resp->tr_rflags = TR_SCOPED;
291: else if (gt->gt_prsent_timer)
292: resp->tr_rflags = TR_PRUNED;
293: else if (!VIFM_ISSET(vifi, gt->gt_grpmems))
294: if (VIFM_ISSET(vifi, rt->rt_children) &&
295: NBRM_ISSETMASK(uvifs[vifi].uv_nbrmap, rt->rt_subordinates)) /*XXX*/
296: resp->tr_rflags = TR_OPRUNED;
297: else
298: resp->tr_rflags = TR_NO_FWD;
299: } else {
300: if (scoped_addr(vifi, group))
301: resp->tr_rflags = TR_SCOPED;
302: else if (rt && !VIFM_ISSET(vifi, rt->rt_children))
303: resp->tr_rflags = TR_NO_FWD;
304: }
305: #endif /* 0 */
306:
307: /*
308: * if no rte exists, set NO_RTE error
309: */
310: if (mrt == (mrtentry_t *)NULL) {
311: src = dst; /* the dst address of resp. pkt */
312: resp->tr_inaddr = 0;
313: resp->tr_rflags = TR_NO_RTE;
314: resp->tr_rmtaddr = 0;
315: } else {
316: /* get # of packets in on interface */
317: v_req.vifi = mrt->incoming;
318: if (ioctl(udp_socket, SIOCGETVIFCNT, (char *)&v_req) >= 0)
319: resp->tr_vifin = htonl(v_req.icount);
320: else
321: resp->tr_vifin = 0xffffffff;
322:
323: /* TODO
324: MASK_TO_VAL(rt->rt_originmask, resp->tr_smask);
325: */
326: src = uvifs[mrt->incoming].uv_lcl_addr;
327: resp->tr_inaddr = src;
328: if (mrt->upstream != (pim_nbr_entry_t *)NULL)
329: parent_address = mrt->upstream->address;
330: else
331: parent_address = INADDR_ANY;
332:
333: resp->tr_rmtaddr = parent_address;
334: if (!VIFM_ISSET(vifi, mrt->oifs)) {
335: IF_DEBUG(DEBUG_TRACE)
336: log(LOG_DEBUG, 0, "Destination %s not on forwarding tree for src %s",
337: inet_fmt(qry->tr_dst, s1), inet_fmt(qry->tr_src, s2));
338: resp->tr_rflags = TR_WRONG_IF;
339: }
340: #if 0
341: if (rt->rt_metric >= UNREACHABLE) {
342: resp->tr_rflags = TR_NO_RTE;
343: /* Hack to send reply directly */
344: rt = NULL;
345: }
346: #endif /* 0 */
347: }
348:
349: sendit:
350: /*
351: * if metric is 1 or no. of reports is 1, send response to requestor
352: * else send to upstream router. If the upstream router can't handle
353: * mtrace, set an error code and send to requestor anyway.
354: */
355: IF_DEBUG(DEBUG_TRACE)
356: log(LOG_DEBUG, 0, "rcount:%d, no:%d", rcount, no);
357:
358: if ((rcount + 1 == no) || (mrt == NULL) || (mrt->metric == 1)) {
359: resptype = IGMP_MTRACE_RESP;
360: dst = qry->tr_raddr;
361: } else
362: /* TODO */
363: {
364: #if 0
365: if (!can_mtrace(rt->rt_parent, rt->rt_gateway)) {
366: dst = qry->tr_raddr;
367: resp->tr_rflags = TR_OLD_ROUTER;
368: resptype = IGMP_MTRACE_RESP;
369: } else {
370: #endif /* 0 */
371: if (mrt->upstream != (pim_nbr_entry_t *)NULL)
372: parent_address = mrt->upstream->address;
373: else
374: parent_address = INADDR_ANY;
375: dst = parent_address;
376: resptype = IGMP_MTRACE;
377: }
378:
379: if (IN_MULTICAST(ntohl(dst))) {
380: /*
381: * Send the reply on a known multicast capable vif.
382: * If we don't have one, we can't source any multicasts anyway.
383: */
384: if (phys_vif != -1) {
385: IF_DEBUG(DEBUG_TRACE)
386: log(LOG_DEBUG, 0, "Sending reply to %s from %s",
387: inet_fmt(dst, s1),
388: inet_fmt(uvifs[phys_vif].uv_lcl_addr, s2));
389: k_set_ttl(igmp_socket, qry->tr_rttl);
390: send_igmp(igmp_send_buf, uvifs[phys_vif].uv_lcl_addr, dst,
391: resptype, no, group, datalen);
392: k_set_ttl(igmp_socket, 1);
393: } else
394: log(LOG_INFO, 0, "No enabled phyints -- %s",
395: "dropping traceroute reply");
396: } else {
397: IF_DEBUG(DEBUG_TRACE)
398: log(LOG_DEBUG, 0, "Sending %s to %s from %s",
399: resptype == IGMP_MTRACE_RESP ? "reply" : "request on",
400: inet_fmt(dst, s1), inet_fmt(src, s2));
401:
402: send_igmp(igmp_send_buf, src, dst, resptype, no, group, datalen);
403: }
404: return;
405: }
406:
407:
408: /*
409: * accept_neighbor_request() supports some old DVMRP messages from mrinfo.
410: * Haven't tested it, because I have only the new mrinfo.
411: */
412: void
413: accept_neighbor_request(src, dst)
414: u_int32 src;
415: u_int32 dst;
416: {
417: vifi_t vifi;
418: struct uvif *v;
419: u_char *p, *ncount;
420: /* struct listaddr *la; */
421: pim_nbr_entry_t *pim_nbr;
422: int datalen;
423: u_int32 temp_addr, them = src;
424:
425: #define PUT_ADDR(a) temp_addr = ntohl(a); \
426: *p++ = temp_addr >> 24; \
427: *p++ = (temp_addr >> 16) & 0xFF; \
428: *p++ = (temp_addr >> 8) & 0xFF; \
429: *p++ = temp_addr & 0xFF;
430:
431: p = (u_char *) (igmp_send_buf + MIN_IP_HEADER_LEN + IGMP_MINLEN);
432: datalen = 0;
433:
434: for (vifi = 0, v = uvifs; vifi < numvifs; vifi++, v++) {
435: if (v->uv_flags & VIFF_DISABLED)
436: continue;
437:
438: ncount = 0;
439:
440: /* TODO: XXX: if we are PMBR, then check the DVMRP interfaces too */
441: for (pim_nbr = v->uv_pim_neighbors; pim_nbr != (pim_nbr_entry_t *)NULL;
442: pim_nbr = pim_nbr->next) {
443: /* Make sure that there's room for this neighbor... */
444: if (datalen + (ncount == 0 ? 4 + 3 + 4 : 4) > MAX_DVMRP_DATA_LEN) {
445: send_igmp(igmp_send_buf, INADDR_ANY, them, IGMP_DVMRP,
446: DVMRP_NEIGHBORS, htonl(PIMD_LEVEL), datalen);
447: p = (u_char *) (igmp_send_buf + MIN_IP_HEADER_LEN + IGMP_MINLEN);
448: datalen = 0;
449: ncount = 0;
450: }
451:
452: /* Put out the header for this neighbor list... */
453: if (ncount == 0) {
454: PUT_ADDR(v->uv_lcl_addr);
455: *p++ = v->uv_metric;
456: *p++ = v->uv_threshold;
457: ncount = p;
458: *p++ = 0;
459: datalen += 4 + 3;
460: }
461:
462: PUT_ADDR(pim_nbr->address);
463: datalen += 4;
464: (*ncount)++;
465: }
466: }
467:
468: if (datalen != 0)
469: send_igmp(igmp_send_buf, INADDR_ANY, them, IGMP_DVMRP, DVMRP_NEIGHBORS,
470: htonl(PIMD_LEVEL), datalen);
471: }
472:
473:
474: /*
475: * Send a list of all of our neighbors to the requestor, `src'.
476: * Used for mrinfo support.
477: * XXX: currently, we cannot specify the used multicast routing protocol;
478: * only a protocol version is returned.
479: */
480: void
481: accept_neighbor_request2(src, dst)
482: u_int32 src;
483: u_int32 dst;
484: {
485: vifi_t vifi;
486: struct uvif *v;
487: u_char *p, *ncount;
488: /* struct listaddr *la; */
489: pim_nbr_entry_t *pim_nbr;
490: int datalen;
491: u_int32 them = src;
492:
493: p = (u_char *) (igmp_send_buf + MIN_IP_HEADER_LEN + IGMP_MINLEN);
494: datalen = 0;
495:
496: for (vifi = 0, v = uvifs; vifi < numvifs; vifi++, v++) {
497: register u_int32 vflags = v->uv_flags;
498: register u_char rflags = 0;
499: if (vflags & VIFF_TUNNEL)
500: rflags |= DVMRP_NF_TUNNEL;
501: if (vflags & VIFF_SRCRT)
502: rflags |= DVMRP_NF_SRCRT;
503: if (vflags & VIFF_PIM_NBR)
504: rflags |= DVMRP_NF_PIM;
505: if (vflags & VIFF_DOWN)
506: rflags |= DVMRP_NF_DOWN;
507: if (vflags & VIFF_DISABLED)
508: rflags |= DVMRP_NF_DISABLED;
509: if (vflags & VIFF_QUERIER)
510: rflags |= DVMRP_NF_QUERIER;
511: if (vflags & VIFF_LEAF)
512: rflags |= DVMRP_NF_LEAF;
513: ncount = 0;
514: pim_nbr = v->uv_pim_neighbors;
515: if (pim_nbr == (pim_nbr_entry_t *)NULL) {
516: /*
517: * include down & disabled interfaces and interfaces on
518: * leaf nets.
519: */
520: if (rflags & DVMRP_NF_TUNNEL)
521: rflags |= DVMRP_NF_DOWN;
522: if (datalen > MAX_DVMRP_DATA_LEN - 12) {
523: send_igmp(igmp_send_buf, INADDR_ANY, them, IGMP_DVMRP,
524: DVMRP_NEIGHBORS2, htonl(PIMD_LEVEL), datalen);
525: p = (u_char *) (igmp_send_buf + MIN_IP_HEADER_LEN + IGMP_MINLEN);
526: datalen = 0;
527: }
528: *(u_int*)p = v->uv_lcl_addr;
529: p += 4;
530: *p++ = v->uv_metric;
531: *p++ = v->uv_threshold;
532: *p++ = rflags;
533: *p++ = 1;
534: *(u_int*)p = v->uv_rmt_addr;
535: p += 4;
536: datalen += 12;
537: } else {
538: for ( ; pim_nbr; pim_nbr = pim_nbr->next) {
539: /* Make sure that there's room for this neighbor... */
540: if (datalen + (ncount == 0 ? 4+4+4 : 4) > MAX_DVMRP_DATA_LEN) {
541: send_igmp(igmp_send_buf, INADDR_ANY, them, IGMP_DVMRP,
542: DVMRP_NEIGHBORS2, htonl(PIMD_LEVEL), datalen);
543: p = (u_char *) (igmp_send_buf + MIN_IP_HEADER_LEN + IGMP_MINLEN);
544: datalen = 0;
545: ncount = 0;
546: }
547: /* Put out the header for this neighbor list... */
548: if (ncount == 0) {
549: *(u_int*)p = v->uv_lcl_addr;
550: p += 4;
551: *p++ = v->uv_metric;
552: *p++ = v->uv_threshold;
553: *p++ = rflags;
554: ncount = p;
555: *p++ = 0;
556: datalen += 4 + 4;
557: }
558: *(u_int*)p = pim_nbr->address;
559: p += 4;
560: datalen += 4;
561: (*ncount)++;
562: }
563: }
564: }
565: if (datalen != 0)
566: send_igmp(igmp_send_buf, INADDR_ANY, them, IGMP_DVMRP,
567: DVMRP_NEIGHBORS2, htonl(PIMD_LEVEL), datalen);
568: }
569:
570:
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to trace.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