Annotation of embedaddon/bird2/proto/ospf/dbdes.c, revision 1.1
1.1 ! misho 1: /*
! 2: * BIRD -- OSPF
! 3: *
! 4: * (c) 1999--2004 Ondrej Filip <feela@network.cz>
! 5: * (c) 2009--2014 Ondrej Zajicek <santiago@crfreenet.org>
! 6: * (c) 2009--2014 CZ.NIC z.s.p.o.
! 7: *
! 8: * Can be freely distributed and used under the terms of the GNU GPL.
! 9: */
! 10:
! 11: #include "ospf.h"
! 12:
! 13:
! 14: struct ospf_dbdes2_packet
! 15: {
! 16: struct ospf_packet hdr;
! 17: union ospf_auth2 auth;
! 18:
! 19: u16 iface_mtu;
! 20: u8 options;
! 21: u8 imms; /* I, M, MS bits */
! 22: u32 ddseq;
! 23:
! 24: struct ospf_lsa_header lsas[];
! 25: };
! 26:
! 27: struct ospf_dbdes3_packet
! 28: {
! 29: struct ospf_packet hdr;
! 30:
! 31: u32 options;
! 32: u16 iface_mtu;
! 33: u8 padding;
! 34: u8 imms; /* I, M, MS bits */
! 35: u32 ddseq;
! 36:
! 37: struct ospf_lsa_header lsas[];
! 38: };
! 39:
! 40:
! 41: uint
! 42: ospf_dbdes3_options(struct ospf_packet *pkt)
! 43: {
! 44: struct ospf_dbdes3_packet *ps = (void *) pkt;
! 45: return ntohl(ps->options);
! 46: }
! 47:
! 48: static inline uint
! 49: ospf_dbdes_hdrlen(struct ospf_proto *p)
! 50: {
! 51: return ospf_is_v2(p) ?
! 52: sizeof(struct ospf_dbdes2_packet) : sizeof(struct ospf_dbdes3_packet);
! 53: }
! 54:
! 55: static void
! 56: ospf_dbdes_body(struct ospf_proto *p, struct ospf_packet *pkt,
! 57: struct ospf_lsa_header **body, uint *count)
! 58: {
! 59: uint plen = ntohs(pkt->length);
! 60: uint hlen = ospf_dbdes_hdrlen(p);
! 61:
! 62: *body = ((void *) pkt) + hlen;
! 63: *count = (plen - hlen) / sizeof(struct ospf_lsa_header);
! 64: }
! 65:
! 66: static void
! 67: ospf_dump_dbdes(struct ospf_proto *p, struct ospf_packet *pkt)
! 68: {
! 69: struct ospf_lsa_header *lsas;
! 70: uint i, lsa_count;
! 71: u32 pkt_ddseq;
! 72: u16 pkt_iface_mtu;
! 73: u8 pkt_imms;
! 74:
! 75: ASSERT(pkt->type == DBDES_P);
! 76: ospf_dump_common(p, pkt);
! 77:
! 78: if (ospf_is_v2(p))
! 79: {
! 80: struct ospf_dbdes2_packet *ps = (void *) pkt;
! 81: pkt_iface_mtu = ntohs(ps->iface_mtu);
! 82: pkt_imms = ps->imms;
! 83: pkt_ddseq = ntohl(ps->ddseq);
! 84: }
! 85: else /* OSPFv3 */
! 86: {
! 87: struct ospf_dbdes3_packet *ps = (void *) pkt;
! 88: pkt_iface_mtu = ntohs(ps->iface_mtu);
! 89: pkt_imms = ps->imms;
! 90: pkt_ddseq = ntohl(ps->ddseq);
! 91: }
! 92:
! 93: log(L_TRACE "%s: mtu %u", p->p.name, pkt_iface_mtu);
! 94: log(L_TRACE "%s: imms %s%s%s", p->p.name,
! 95: (pkt_imms & DBDES_I) ? "I " : "",
! 96: (pkt_imms & DBDES_M) ? "M " : "",
! 97: (pkt_imms & DBDES_MS) ? "MS" : "");
! 98: log(L_TRACE "%s: ddseq %u", p->p.name, pkt_ddseq);
! 99:
! 100: ospf_dbdes_body(p, pkt, &lsas, &lsa_count);
! 101: for (i = 0; i < lsa_count; i++)
! 102: ospf_dump_lsahdr(p, lsas + i);
! 103: }
! 104:
! 105:
! 106: static void
! 107: ospf_prepare_dbdes(struct ospf_proto *p, struct ospf_neighbor *n)
! 108: {
! 109: struct ospf_iface *ifa = n->ifa;
! 110: struct ospf_packet *pkt;
! 111: uint length;
! 112:
! 113: u16 iface_mtu = (ifa->type == OSPF_IT_VLINK) ? 0 : ifa->iface->mtu;
! 114:
! 115: /* Update DBDES buffer */
! 116: if (n->ldd_bsize != ifa->tx_length)
! 117: {
! 118: mb_free(n->ldd_buffer);
! 119: n->ldd_buffer = mb_allocz(n->pool, ifa->tx_length);
! 120: n->ldd_bsize = ifa->tx_length;
! 121: }
! 122:
! 123: pkt = n->ldd_buffer;
! 124: ospf_pkt_fill_hdr(ifa, pkt, DBDES_P);
! 125:
! 126: if (ospf_is_v2(p))
! 127: {
! 128: struct ospf_dbdes2_packet *ps = (void *) pkt;
! 129: ps->iface_mtu = htons(iface_mtu);
! 130: ps->options = ifa->oa->options & DBDES2_OPT_MASK;
! 131: ps->imms = 0; /* Will be set later */
! 132: ps->ddseq = htonl(n->dds);
! 133: length = sizeof(struct ospf_dbdes2_packet);
! 134: }
! 135: else /* OSPFv3 */
! 136: {
! 137: struct ospf_dbdes3_packet *ps = (void *) pkt;
! 138: u32 options = ifa->oa->options | (ifa->autype == OSPF_AUTH_CRYPT ? OPT_AT : 0);
! 139: ps->options = htonl(options & DBDES3_OPT_MASK);
! 140: ps->iface_mtu = htons(iface_mtu);
! 141: ps->padding = 0;
! 142: ps->imms = 0; /* Will be set later */
! 143: ps->ddseq = htonl(n->dds);
! 144: length = sizeof(struct ospf_dbdes3_packet);
! 145: }
! 146:
! 147: /* Prepare DBDES body */
! 148: if (!(n->myimms & DBDES_I) && (n->myimms & DBDES_M))
! 149: {
! 150: struct ospf_lsa_header *lsas;
! 151: struct top_hash_entry *en;
! 152: uint i = 0, lsa_max;
! 153:
! 154: ospf_dbdes_body(p, pkt, &lsas, &lsa_max);
! 155: en = (void *) s_get(&(n->dbsi));
! 156:
! 157: while (i < lsa_max)
! 158: {
! 159: if (!SNODE_VALID(en))
! 160: {
! 161: n->myimms &= ~DBDES_M; /* Unset More bit */
! 162: break;
! 163: }
! 164:
! 165: if ((en->lsa.age < LSA_MAXAGE) &&
! 166: lsa_flooding_allowed(en->lsa_type, en->domain, ifa) &&
! 167: lsa_is_acceptable(en->lsa_type, n, p))
! 168: {
! 169: lsa_hton_hdr(&(en->lsa), lsas + i);
! 170: i++;
! 171: }
! 172:
! 173: en = SNODE_NEXT(en);
! 174: }
! 175:
! 176: s_put(&(n->dbsi), SNODE en);
! 177:
! 178: length += i * sizeof(struct ospf_lsa_header);
! 179: }
! 180:
! 181: if (ospf_is_v2(p))
! 182: ((struct ospf_dbdes2_packet *) pkt)->imms = n->myimms;
! 183: else
! 184: ((struct ospf_dbdes3_packet *) pkt)->imms = n->myimms;
! 185:
! 186: pkt->length = htons(length);
! 187: }
! 188:
! 189: static void
! 190: ospf_do_send_dbdes(struct ospf_proto *p, struct ospf_neighbor *n)
! 191: {
! 192: struct ospf_iface *ifa = n->ifa;
! 193:
! 194: OSPF_PACKET(ospf_dump_dbdes, n->ldd_buffer,
! 195: "DBDES packet sent to nbr %R on %s", n->rid, ifa->ifname);
! 196: sk_set_tbuf(ifa->sk, n->ldd_buffer);
! 197: ospf_send_to(ifa, n->ip);
! 198: sk_set_tbuf(ifa->sk, NULL);
! 199: }
! 200:
! 201: /**
! 202: * ospf_send_dbdes - transmit database description packet
! 203: * @p: OSPF protocol instance
! 204: * @n: neighbor
! 205: *
! 206: * Sending of a database description packet is described in 10.8 of RFC 2328.
! 207: * Reception of each packet is acknowledged in the sequence number of another.
! 208: * When I send a packet to a neighbor I keep a copy in a buffer. If the neighbor
! 209: * does not reply, I don't create a new packet but just send the content
! 210: * of the buffer.
! 211: */
! 212: void
! 213: ospf_send_dbdes(struct ospf_proto *p, struct ospf_neighbor *n)
! 214: {
! 215: /* RFC 2328 10.8 */
! 216:
! 217: ASSERT((n->state == NEIGHBOR_EXSTART) || (n->state == NEIGHBOR_EXCHANGE));
! 218:
! 219: if (!n->ifa->oa->rt && !p->gr_recovery)
! 220: return;
! 221:
! 222: ospf_prepare_dbdes(p, n);
! 223: ospf_do_send_dbdes(p, n);
! 224: }
! 225:
! 226: void
! 227: ospf_rxmt_dbdes(struct ospf_proto *p, struct ospf_neighbor *n)
! 228: {
! 229: ASSERT(n->state > NEIGHBOR_EXSTART);
! 230:
! 231: if (!n->ldd_buffer)
! 232: {
! 233: log(L_WARN "%s: No DBDES packet for retransmit", p->p.name);
! 234: ospf_neigh_sm(n, INM_SEQMIS);
! 235: return;
! 236: }
! 237:
! 238: /* Send last packet */
! 239: ospf_do_send_dbdes(p, n);
! 240: }
! 241:
! 242: void
! 243: ospf_reset_ldd(struct ospf_proto *p UNUSED, struct ospf_neighbor *n)
! 244: {
! 245: mb_free(n->ldd_buffer);
! 246: n->ldd_buffer = NULL;
! 247: n->ldd_bsize = 0;
! 248: }
! 249:
! 250: static int
! 251: ospf_process_dbdes(struct ospf_proto *p, struct ospf_packet *pkt, struct ospf_neighbor *n)
! 252: {
! 253: struct ospf_iface *ifa = n->ifa;
! 254: struct ospf_lsa_header *lsas, lsa;
! 255: struct top_hash_entry *en, *req;
! 256: const char *err_dsc = NULL;
! 257: u32 lsa_type, lsa_domain;
! 258: uint i, lsa_count;
! 259:
! 260: ospf_dbdes_body(p, pkt, &lsas, &lsa_count);
! 261:
! 262: for (i = 0; i < lsa_count; i++)
! 263: {
! 264: lsa_ntoh_hdr(lsas + i, &lsa);
! 265: lsa_get_type_domain(&lsa, ifa, &lsa_type, &lsa_domain);
! 266:
! 267: /* RFC 2328 10.6 and RFC 5340 4.2.2 */
! 268:
! 269: if (!lsa_type)
! 270: DROP1("LSA of unknown type");
! 271:
! 272: if (!oa_is_ext(ifa->oa) && (LSA_SCOPE(lsa_type) == LSA_SCOPE_AS))
! 273: DROP1("LSA with AS scope in stub area");
! 274:
! 275: /* Errata 3746 to RFC 2328 - rt-summary-LSAs forbidden in stub areas */
! 276: if (!oa_is_ext(ifa->oa) && (lsa_type == LSA_T_SUM_RT))
! 277: DROP1("rt-summary-LSA in stub area");
! 278:
! 279: /* Not explicitly mentioned in RFC 5340 4.2.2 but makes sense */
! 280: if (LSA_SCOPE(lsa_type) == LSA_SCOPE_RES)
! 281: DROP1("LSA with invalid scope");
! 282:
! 283: /* RFC 3623 2.2 (2) special case - check for my router-LSA (GR recovery) */
! 284: if ((lsa_type == LSA_T_RT) && (lsa.rt == p->router_id))
! 285: n->got_my_rt_lsa = 1;
! 286:
! 287: en = ospf_hash_find(p->gr, lsa_domain, lsa.id, lsa.rt, lsa_type);
! 288: if (!en || (lsa_comp(&lsa, &(en->lsa)) == CMP_NEWER))
! 289: {
! 290: /* This should be splitted to ospf_lsa_lsrq_up() */
! 291: req = ospf_hash_get(n->lsrqh, lsa_domain, lsa.id, lsa.rt, lsa_type);
! 292:
! 293: if (!SNODE_VALID(req))
! 294: s_add_tail(&n->lsrql, SNODE req);
! 295:
! 296: if (!SNODE_VALID(n->lsrqi))
! 297: n->lsrqi = req;
! 298:
! 299: req->lsa = lsa;
! 300: req->lsa_body = LSA_BODY_DUMMY;
! 301:
! 302: if (!tm_active(n->lsrq_timer))
! 303: tm_start(n->lsrq_timer, 0);
! 304: }
! 305: }
! 306:
! 307: return 0;
! 308:
! 309: drop:
! 310: LOG_LSA1("Bad LSA (Type: %04x, Id: %R, Rt: %R) in DBDES", lsa_type, lsa.id, lsa.rt);
! 311: LOG_LSA2(" received from nbr %R on %s - %s", n->rid, ifa->ifname, err_dsc);
! 312:
! 313: ospf_neigh_sm(n, INM_SEQMIS);
! 314: return -1;
! 315: }
! 316:
! 317: void
! 318: ospf_receive_dbdes(struct ospf_packet *pkt, struct ospf_iface *ifa,
! 319: struct ospf_neighbor *n)
! 320: {
! 321: struct ospf_proto *p = ifa->oa->po;
! 322: const char *err_dsc = NULL;
! 323: u32 rcv_ddseq, rcv_options;
! 324: u16 rcv_iface_mtu;
! 325: u8 rcv_imms;
! 326: uint plen, err_val = 0;
! 327:
! 328: /* RFC 2328 10.6 */
! 329:
! 330: plen = ntohs(pkt->length);
! 331: if (plen < ospf_dbdes_hdrlen(p))
! 332: {
! 333: LOG_PKT("Bad DBDES packet from nbr %R on %s - %s (%u)", n->rid, ifa->ifname, "too short", plen);
! 334: return;
! 335: }
! 336:
! 337: OSPF_PACKET(ospf_dump_dbdes, pkt, "DBDES packet received from nbr %R on %s", n->rid, ifa->ifname);
! 338:
! 339: ospf_neigh_sm(n, INM_HELLOREC);
! 340:
! 341: if (ospf_is_v2(p))
! 342: {
! 343: struct ospf_dbdes2_packet *ps = (void *) pkt;
! 344: rcv_iface_mtu = ntohs(ps->iface_mtu);
! 345: rcv_options = ps->options;
! 346: rcv_imms = ps->imms;
! 347: rcv_ddseq = ntohl(ps->ddseq);
! 348: }
! 349: else /* OSPFv3 */
! 350: {
! 351: struct ospf_dbdes3_packet *ps = (void *) pkt;
! 352: rcv_options = ntohl(ps->options);
! 353: rcv_iface_mtu = ntohs(ps->iface_mtu);
! 354: rcv_imms = ps->imms;
! 355: rcv_ddseq = ntohl(ps->ddseq);
! 356: }
! 357:
! 358: /* Reject packets with non-matching MTU */
! 359: if ((ifa->type != OSPF_IT_VLINK) &&
! 360: (rcv_iface_mtu != ifa->iface->mtu) &&
! 361: (rcv_iface_mtu != 0) && (ifa->iface->mtu != 0))
! 362: {
! 363: LOG_PKT("MTU mismatch with nbr %R on %s (remote %d, local %d)",
! 364: n->rid, ifa->ifname, rcv_iface_mtu, ifa->iface->mtu);
! 365: return;
! 366: }
! 367:
! 368: switch (n->state)
! 369: {
! 370: case NEIGHBOR_DOWN:
! 371: case NEIGHBOR_ATTEMPT:
! 372: case NEIGHBOR_2WAY:
! 373: OSPF_TRACE(D_PACKETS, "DBDES packet ignored - lesser state than ExStart");
! 374: return;
! 375:
! 376: case NEIGHBOR_INIT:
! 377: ospf_neigh_sm(n, INM_2WAYREC);
! 378: if (n->state != NEIGHBOR_EXSTART)
! 379: return;
! 380: /* fallthrough */
! 381:
! 382: case NEIGHBOR_EXSTART:
! 383: if (((rcv_imms & DBDES_IMMS) == DBDES_IMMS) &&
! 384: (n->rid > p->router_id) &&
! 385: (plen == ospf_dbdes_hdrlen(p)))
! 386: {
! 387: /* I'm slave! */
! 388: n->dds = rcv_ddseq;
! 389: n->ddr = rcv_ddseq;
! 390: n->options = rcv_options;
! 391: n->myimms &= ~DBDES_MS;
! 392: n->imms = rcv_imms;
! 393: tm_stop(n->dbdes_timer);
! 394: ospf_neigh_sm(n, INM_NEGDONE);
! 395: ospf_send_dbdes(p, n);
! 396: break;
! 397: }
! 398:
! 399: if (!(rcv_imms & DBDES_I) &&
! 400: !(rcv_imms & DBDES_MS) &&
! 401: (n->rid < p->router_id) &&
! 402: (n->dds == rcv_ddseq))
! 403: {
! 404: /* I'm master! */
! 405: n->options = rcv_options;
! 406: n->ddr = rcv_ddseq - 1; /* It will be set corectly a few lines down */
! 407: n->imms = rcv_imms;
! 408: ospf_neigh_sm(n, INM_NEGDONE);
! 409: /* Continue to the NEIGHBOR_EXCHANGE case */
! 410: }
! 411: else
! 412: {
! 413: DBG("%s: Nothing happend to %I (imms=%d)\n", p->name, n->ip, rcv_imms);
! 414: break;
! 415: }
! 416:
! 417: case NEIGHBOR_EXCHANGE:
! 418: if ((rcv_imms == n->imms) &&
! 419: (rcv_options == n->options) &&
! 420: (rcv_ddseq == n->ddr))
! 421: goto duplicate;
! 422:
! 423: if ((rcv_imms & DBDES_MS) != (n->imms & DBDES_MS))
! 424: DROP("MS-bit mismatch", rcv_imms);
! 425:
! 426: if (rcv_imms & DBDES_I)
! 427: DROP("I-bit mismatch", rcv_imms);
! 428:
! 429: if (rcv_options != n->options)
! 430: DROP("options mismatch", rcv_options);
! 431:
! 432: n->ddr = rcv_ddseq;
! 433: n->imms = rcv_imms;
! 434:
! 435: if (n->myimms & DBDES_MS)
! 436: {
! 437: /* MASTER */
! 438:
! 439: if (rcv_ddseq != n->dds)
! 440: DROP("DD sequence number mismatch", rcv_ddseq);
! 441:
! 442: n->dds++;
! 443:
! 444: if (ospf_process_dbdes(p, pkt, n) < 0)
! 445: return;
! 446:
! 447: if (!(n->myimms & DBDES_M) && !(n->imms & DBDES_M))
! 448: {
! 449: tm_stop(n->dbdes_timer);
! 450: ospf_reset_ldd(p, n);
! 451: ospf_neigh_sm(n, INM_EXDONE);
! 452: break;
! 453: }
! 454:
! 455: ospf_send_dbdes(p, n);
! 456: tm_start(n->dbdes_timer, n->ifa->rxmtint S);
! 457: }
! 458: else
! 459: {
! 460: /* SLAVE */
! 461:
! 462: if (rcv_ddseq != (n->dds + 1))
! 463: DROP("DD sequence number mismatch", rcv_ddseq);
! 464:
! 465: n->ddr = rcv_ddseq;
! 466: n->dds = rcv_ddseq;
! 467:
! 468: if (ospf_process_dbdes(p, pkt, n) < 0)
! 469: return;
! 470:
! 471: ospf_send_dbdes(p, n);
! 472:
! 473: if (!(n->myimms & DBDES_M) && !(n->imms & DBDES_M))
! 474: {
! 475: /* Use dbdes timer to postpone freeing of Last DBDES packet buffer */
! 476: tm_start(n->dbdes_timer, n->ifa->deadint S);
! 477: ospf_neigh_sm(n, INM_EXDONE);
! 478: }
! 479: }
! 480: break;
! 481:
! 482: case NEIGHBOR_LOADING:
! 483: case NEIGHBOR_FULL:
! 484: if ((rcv_imms == n->imms) &&
! 485: (rcv_options == n->options) &&
! 486: (rcv_ddseq == n->ddr))
! 487: goto duplicate;
! 488:
! 489: DROP("too late for DD exchange", n->state);
! 490:
! 491: default:
! 492: bug("Undefined interface state");
! 493: }
! 494: return;
! 495:
! 496: duplicate:
! 497: OSPF_TRACE(D_PACKETS, "DBDES packet is duplicate");
! 498:
! 499: /* Slave should retransmit DBDES packet */
! 500: if (!(n->myimms & DBDES_MS))
! 501: ospf_rxmt_dbdes(p, n);
! 502: return;
! 503:
! 504: drop:
! 505: LOG_PKT("Bad DBDES packet from nbr %R on %s - %s (%u)",
! 506: n->rid, ifa->ifname, err_dsc, err_val);
! 507:
! 508: ospf_neigh_sm(n, INM_SEQMIS);
! 509: return;
! 510: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to dbdes.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / bird2 / proto / ospf