Annotation of embedaddon/pimdd/trace.c, revision 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>