eigrpd/eigrp_siaquery.c

   1 // SPDX-License-Identifier: GPL-2.0-or-later
   2 /*
   3  * EIGRP Sending and Receiving EIGRP SIA-Query Packets.
   4  * Copyright (C) 2013-2014
   5  * Authors:
   6  *   Donnie Savage
   7  *   Jan Janovic
   8  *   Matej Perina
   9  *   Peter Orsag
  10  *   Peter Paluch
  11  */
  12
  13 #include <zebra.h>
  14
  15 #include "frrevent.h"
  16 #include "memory.h"
  17 #include "linklist.h"
  18 #include "prefix.h"
  19 #include "if.h"
  20 #include "table.h"
  21 #include "sockunion.h"
  22 #include "stream.h"
  23 #include "log.h"
  24 #include "sockopt.h"
  25 #include "checksum.h"
  26 #include "md5.h"
  27 #include "vty.h"
  28
  29 #include "eigrpd/eigrp_structs.h"
  30 #include "eigrpd/eigrpd.h"
  31 #include "eigrpd/eigrp_interface.h"
  32 #include "eigrpd/eigrp_neighbor.h"
  33 #include "eigrpd/eigrp_packet.h"
  34 #include "eigrpd/eigrp_zebra.h"
  35 #include "eigrpd/eigrp_vty.h"
  36 #include "eigrpd/eigrp_dump.h"
  37 #include "eigrpd/eigrp_macros.h"
  38 #include "eigrpd/eigrp_topology.h"
  39 #include "eigrpd/eigrp_fsm.h"
  40
  41 /*EIGRP SIA-QUERY read function*/
  42 void eigrp_siaquery_receive(struct eigrp *eigrp, struct ip *iph,
  43                             struct eigrp_header *eigrph, struct stream *s,
  44                             struct eigrp_interface *ei, int size)
  45 {
  46         struct eigrp_neighbor *nbr;
  47         struct TLV_IPv4_Internal_type *tlv;
  48
  49         uint16_t type;
  50
  51         /* increment statistics. */
  52         ei->siaQuery_in++;
  53
  54         /* get neighbor struct */
  55         nbr = eigrp_nbr_get(ei, eigrph, iph);
  56
  57         /* neighbor must be valid, eigrp_nbr_get creates if none existed */
  58         assert(nbr);
  59
  60         nbr->recv_sequence_number = ntohl(eigrph->sequence);
  61
  62         while (s->endp > s->getp) {
  63                 type = stream_getw(s);
  64                 if (type == EIGRP_TLV_IPv4_INT) {
  65                         struct prefix dest_addr;
  66
  67                         stream_set_getp(s, s->getp - sizeof(uint16_t));
  68
  69                         tlv = eigrp_read_ipv4_tlv(s);
  70
  71                         dest_addr.family = AFI_IP;
  72                         dest_addr.u.prefix4 = tlv->destination;
  73                         dest_addr.prefixlen = tlv->prefix_length;
  74                         struct eigrp_prefix_descriptor *dest =
  75                                 eigrp_topology_table_lookup_ipv4(
  76                                         eigrp->topology_table, &dest_addr);
  77
  78                         /* If the destination exists (it should, but one never
  79                          * know)*/
  80                         if (dest != NULL) {
  81                                 struct eigrp_fsm_action_message msg;
  82                                 struct eigrp_route_descriptor *entry =
  83                                         eigrp_route_descriptor_lookup(
  84                                                 dest->entries, nbr);
  85                                 msg.packet_type = EIGRP_OPC_SIAQUERY;
  86                                 msg.eigrp = eigrp;
  87                                 msg.data_type = EIGRP_INT;
  88                                 msg.adv_router = nbr;
  89                                 msg.metrics = tlv->metric;
  90                                 msg.entry = entry;
  91                                 msg.prefix = dest;
  92                                 eigrp_fsm_event(&msg);
  93                         }
  94                         eigrp_IPv4_InternalTLV_free(tlv);
  95                 }
  96         }
  97         eigrp_hello_send_ack(nbr);
  98 }
  99
 100 void eigrp_send_siaquery(struct eigrp_neighbor *nbr,
 101                          struct eigrp_prefix_descriptor *pe)
 102 {
 103         struct eigrp_packet *ep;
 104         uint16_t length = EIGRP_HEADER_LEN;
 105
 106         ep = eigrp_packet_new(EIGRP_PACKET_MTU(nbr->ei->ifp->mtu), nbr);
 107
 108         /* Prepare EIGRP INIT UPDATE header */
 109         eigrp_packet_header_init(EIGRP_OPC_SIAQUERY, nbr->ei->eigrp, ep->s, 0,
 110                                  nbr->ei->eigrp->sequence_number, 0);
 111
 112         // encode Authentication TLV, if needed
 113         if ((nbr->ei->params.auth_type == EIGRP_AUTH_TYPE_MD5)
 114             && (nbr->ei->params.auth_keychain != NULL)) {
 115                 length += eigrp_add_authTLV_MD5_to_stream(ep->s, nbr->ei);
 116         }
 117
 118         length += eigrp_add_internalTLV_to_stream(ep->s, pe);
 119
 120         if ((nbr->ei->params.auth_type == EIGRP_AUTH_TYPE_MD5)
 121             && (nbr->ei->params.auth_keychain != NULL)) {
 122                 eigrp_make_md5_digest(nbr->ei, ep->s, EIGRP_AUTH_UPDATE_FLAG);
 123         }
 124
 125         /* EIGRP Checksum */
 126         eigrp_packet_checksum(nbr->ei, ep->s, length);
 127
 128         ep->length = length;
 129         ep->dst.s_addr = nbr->src.s_addr;
 130
 131         /*This ack number we await from neighbor*/
 132         ep->sequence_number = nbr->ei->eigrp->sequence_number;
 133
 134         if (nbr->state == EIGRP_NEIGHBOR_UP) {
 135                 /*Put packet to retransmission queue*/
 136                 eigrp_fifo_push(nbr->retrans_queue, ep);
 137
 138                 if (nbr->retrans_queue->count == 1) {
 139                         eigrp_send_packet_reliably(nbr);
 140                 }
 141         } else
 142                 eigrp_packet_free(ep);
 143 }