Return to lsreq.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / bird / proto / ospf

Annotation of embedaddon/bird/proto/ospf/lsreq.c, revision 1.1

1.1     ! misho       1: /*
        !             2:  *     BIRD -- OSPF
        !             3:  *
        !             4:  *     (c) 2000--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: /*
        !            15: struct ospf_lsreq_packet
        !            16: {
        !            17:   struct ospf_packet hdr;
        !            18:   // union ospf_auth auth;
        !            19: 
        !            20:   struct ospf_lsreq_header lsrs[];
        !            21: };
        !            22: */
        !            23: 
        !            24: 
        !            25: static inline void
        !            26: ospf_lsreq_body(struct ospf_proto *p, struct ospf_packet *pkt,
        !            27:                struct ospf_lsreq_header **body, uint *count)
        !            28: {
        !            29:   uint plen = ntohs(pkt->length);
        !            30:   uint hlen = ospf_pkt_hdrlen(p);
        !            31: 
        !            32:   *body = ((void *) pkt) + hlen;
        !            33:   *count = (plen - hlen) / sizeof(struct ospf_lsreq_header);
        !            34: }
        !            35: 
        !            36: static void
        !            37: ospf_dump_lsreq(struct ospf_proto *p, struct ospf_packet *pkt)
        !            38: {
        !            39:   struct ospf_lsreq_header *lsrs;
        !            40:   uint i, lsr_count;
        !            41: 
        !            42:   ASSERT(pkt->type == LSREQ_P);
        !            43:   ospf_dump_common(p, pkt);
        !            44: 
        !            45:   ospf_lsreq_body(p, pkt, &lsrs, &lsr_count);
        !            46:   for (i = 0; i < lsr_count; i++)
        !            47:     log(L_TRACE "%s:     LSR      Type: %04x, Id: %R, Rt: %R", p->p.name,
        !            48:        ntohl(lsrs[i].type), ntohl(lsrs[i].id), ntohl(lsrs[i].rt));
        !            49: }
        !            50: 
        !            51: 
        !            52: void
        !            53: ospf_send_lsreq(struct ospf_proto *p, struct ospf_neighbor *n)
        !            54: {
        !            55:   struct ospf_iface *ifa = n->ifa;
        !            56:   struct ospf_lsreq_header *lsrs;
        !            57:   struct top_hash_entry *req;
        !            58:   struct ospf_packet *pkt;
        !            59:   uint i, lsr_max, length;
        !            60: 
        !            61:   /* RFC 2328 10.9 */
        !            62: 
        !            63:   /* ASSERT((n->state >= NEIGHBOR_EXCHANGE) && !EMPTY_SLIST(n->lsrql)); */
        !            64: 
        !            65:   pkt = ospf_tx_buffer(ifa);
        !            66:   ospf_pkt_fill_hdr(ifa, pkt, LSREQ_P);
        !            67:   ospf_lsreq_body(p, pkt, &lsrs, &lsr_max);
        !            68: 
        !            69:   i = 0;
        !            70:   WALK_SLIST(req, n->lsrql)
        !            71:   {
        !            72:     if (i == lsr_max)
        !            73:       break;
        !            74: 
        !            75:     DBG("Requesting %uth LSA: Type: %04u, ID: %R, RT: %R, SN: 0x%x, Age %u\n",
        !            76:        i, req->lsa_type, req->lsa.id, req->lsa.rt, req->lsa.sn, req->lsa.age);
        !            77: 
        !            78:     u32 etype = lsa_get_etype(&req->lsa, p);
        !            79:     lsrs[i].type = htonl(etype);
        !            80:     lsrs[i].rt = htonl(req->lsa.rt);
        !            81:     lsrs[i].id = htonl(req->lsa.id);
        !            82:     i++;
        !            83:   }
        !            84: 
        !            85:   /* We store the position to see whether requested LSAs have been received */
        !            86:   n->lsrqi = req;
        !            87: 
        !            88:   length = ospf_pkt_hdrlen(p) + i * sizeof(struct ospf_lsreq_header);
        !            89:   pkt->length = htons(length);
        !            90: 
        !            91:   OSPF_PACKET(ospf_dump_lsreq, pkt, "LSREQ packet sent to nbr %R on %s", n->rid, ifa->ifname);
        !            92:   ospf_send_to(ifa, n->ip);
        !            93: }
        !            94: 
        !            95: 
        !            96: void
        !            97: ospf_receive_lsreq(struct ospf_packet *pkt, struct ospf_iface *ifa,
        !            98:                   struct ospf_neighbor *n)
        !            99: {
        !           100:   struct ospf_proto *p = ifa->oa->po;
        !           101:   struct ospf_lsreq_header *lsrs;
        !           102:   uint i, lsr_count;
        !           103: 
        !           104:   /* RFC 2328 10.7 */
        !           105: 
        !           106:   /* No need to check length, lsreq has only basic header */
        !           107: 
        !           108:   OSPF_PACKET(ospf_dump_lsreq, pkt, "LSREQ packet received from nbr %R on %s", n->rid, ifa->ifname);
        !           109: 
        !           110:   if (n->state < NEIGHBOR_EXCHANGE)
        !           111:   {
        !           112:     OSPF_TRACE(D_PACKETS, "LSREQ packet ignored - lesser state than Exchange");
        !           113:     return;
        !           114:   }
        !           115: 
        !           116:   ospf_neigh_sm(n, INM_HELLOREC);      /* Not in RFC */
        !           117: 
        !           118:   ospf_lsreq_body(p, pkt, &lsrs, &lsr_count);
        !           119: 
        !           120:   struct top_hash_entry *en, *entries[lsr_count];
        !           121: 
        !           122:   for (i = 0; i < lsr_count; i++)
        !           123:   {
        !           124:     u32 id, rt, type, domain;
        !           125: 
        !           126:     id = ntohl(lsrs[i].id);
        !           127:     rt = ntohl(lsrs[i].rt);
        !           128:     lsa_get_type_domain_(ntohl(lsrs[i].type), ifa, &type, &domain);
        !           129: 
        !           130:     DBG("Processing requested LSA: Type: %04x, Id: %R, Rt: %R\n", type, id, rt);
        !           131: 
        !           132:     en = ospf_hash_find(p->gr, domain, id, rt, type);
        !           133:     if (!en)
        !           134:     {
        !           135:       LOG_LSA1("Bad LSR (Type: %04x, Id: %R, Rt: %R) in LSREQ", type, id, rt);
        !           136:       LOG_LSA2("  received from nbr %R on %s - LSA is missing", n->rid, ifa->ifname);
        !           137: 
        !           138:       ospf_neigh_sm(n, INM_BADLSREQ);
        !           139:       return;
        !           140:     }
        !           141: 
        !           142:     entries[i] = en;
        !           143:   }
        !           144: 
        !           145:   ospf_send_lsupd(p, entries, lsr_count, n);
        !           146: }