2 * EIGRP Sending and Receiving EIGRP Query Packets.
3 * Copyright (C) 2013-2014
11 * This file is part of GNU Zebra.
13 * GNU Zebra is free software; you can redistribute it and/or modify it
14 * under the terms of the GNU General Public License as published by the
15 * Free Software Foundation; either version 2, or (at your option) any
18 * GNU Zebra is distributed in the hope that it will be useful, but
19 * WITHOUT ANY WARRANTY; without even the implied warranty of
20 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
21 * General Public License for more details.
23 * You should have received a copy of the GNU General Public License along
24 * with this program; see the file COPYING; if not, write to the Free Software
25 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
36 #include "sockunion.h"
44 #include "eigrpd/eigrp_structs.h"
45 #include "eigrpd/eigrpd.h"
46 #include "eigrpd/eigrp_interface.h"
47 #include "eigrpd/eigrp_neighbor.h"
48 #include "eigrpd/eigrp_packet.h"
49 #include "eigrpd/eigrp_zebra.h"
50 #include "eigrpd/eigrp_vty.h"
51 #include "eigrpd/eigrp_dump.h"
52 #include "eigrpd/eigrp_macros.h"
53 #include "eigrpd/eigrp_topology.h"
54 #include "eigrpd/eigrp_fsm.h"
56 uint32_t eigrp_query_send_all(struct eigrp
*eigrp
)
58 struct eigrp_interface
*iface
;
59 struct listnode
*node
, *node2
, *nnode2
;
60 struct eigrp_prefix_descriptor
*pe
;
64 zlog_debug("EIGRP Routing Process not enabled");
69 for (ALL_LIST_ELEMENTS_RO(eigrp
->eiflist
, node
, iface
)) {
70 eigrp_send_query(iface
);
74 for (ALL_LIST_ELEMENTS(eigrp
->topology_changes_internalIPV4
, node2
,
76 if (pe
->req_action
& EIGRP_FSM_NEED_QUERY
) {
77 pe
->req_action
&= ~EIGRP_FSM_NEED_QUERY
;
78 listnode_delete(eigrp
->topology_changes_internalIPV4
,
86 /*EIGRP QUERY read function*/
87 void eigrp_query_receive(struct eigrp
*eigrp
, struct ip
*iph
,
88 struct eigrp_header
*eigrph
, struct stream
*s
,
89 struct eigrp_interface
*ei
, int size
)
91 struct eigrp_neighbor
*nbr
;
92 struct TLV_IPv4_Internal_type
*tlv
;
93 struct prefix dest_addr
;
98 /* increment statistics. */
101 /* get neighbor struct */
102 nbr
= eigrp_nbr_get(ei
, eigrph
, iph
);
104 /* neighbor must be valid, eigrp_nbr_get creates if none existed */
107 nbr
->recv_sequence_number
= ntohl(eigrph
->sequence
);
109 while (s
->endp
> s
->getp
) {
110 type
= stream_getw(s
);
112 case EIGRP_TLV_IPv4_INT
:
113 stream_set_getp(s
, s
->getp
- sizeof(uint16_t));
115 tlv
= eigrp_read_ipv4_tlv(s
);
117 dest_addr
.family
= AF_INET
;
118 dest_addr
.u
.prefix4
= tlv
->destination
;
119 dest_addr
.prefixlen
= tlv
->prefix_length
;
120 struct eigrp_prefix_descriptor
*dest
=
121 eigrp_topology_table_lookup_ipv4(
122 eigrp
->topology_table
, &dest_addr
);
124 /* If the destination exists (it should, but one never
127 struct eigrp_fsm_action_message msg
;
128 struct eigrp_route_descriptor
*entry
=
129 eigrp_route_descriptor_lookup(
131 msg
.packet_type
= EIGRP_OPC_QUERY
;
133 msg
.data_type
= EIGRP_INT
;
134 msg
.adv_router
= nbr
;
135 msg
.metrics
= tlv
->metric
;
138 eigrp_fsm_event(&msg
);
140 eigrp_IPv4_InternalTLV_free(tlv
);
143 case EIGRP_TLV_IPv4_EXT
:
144 /* DVS: processing of external routes needs packet and fsm work.
145 * for now, lets just not creash the box
148 length
= stream_getw(s
);
149 // -2 for type, -2 for len
150 for (length
-= 4; length
; length
--) {
151 (void)stream_getc(s
);
155 eigrp_hello_send_ack(nbr
);
156 eigrp_query_send_all(eigrp
);
157 eigrp_update_send_all(eigrp
, nbr
->ei
);
160 void eigrp_send_query(struct eigrp_interface
*ei
)
162 struct eigrp_packet
*ep
= NULL
;
163 uint16_t length
= EIGRP_HEADER_LEN
;
164 struct listnode
*node
, *nnode
, *node2
, *nnode2
;
165 struct eigrp_neighbor
*nbr
;
166 struct eigrp_prefix_descriptor
*pe
;
167 bool has_tlv
= false;
168 bool new_packet
= true;
169 uint16_t eigrp_mtu
= EIGRP_PACKET_MTU(ei
->ifp
->mtu
);
171 for (ALL_LIST_ELEMENTS(ei
->eigrp
->topology_changes_internalIPV4
, node
,
173 if (!(pe
->req_action
& EIGRP_FSM_NEED_QUERY
))
177 ep
= eigrp_packet_new(eigrp_mtu
, NULL
);
179 /* Prepare EIGRP INIT UPDATE header */
180 eigrp_packet_header_init(EIGRP_OPC_QUERY
, ei
->eigrp
,
182 ei
->eigrp
->sequence_number
, 0);
184 // encode Authentication TLV, if needed
185 if ((ei
->params
.auth_type
== EIGRP_AUTH_TYPE_MD5
)
186 && (ei
->params
.auth_keychain
!= NULL
)) {
187 length
+= eigrp_add_authTLV_MD5_to_stream(ep
->s
,
193 length
+= eigrp_add_internalTLV_to_stream(ep
->s
, pe
);
195 for (ALL_LIST_ELEMENTS(ei
->nbrs
, node2
, nnode2
, nbr
)) {
196 if (nbr
->state
== EIGRP_NEIGHBOR_UP
)
197 listnode_add(pe
->rij
, nbr
);
200 if (length
+ EIGRP_TLV_MAX_IPV4_BYTE
> eigrp_mtu
) {
201 if ((ei
->params
.auth_type
== EIGRP_AUTH_TYPE_MD5
)
202 && ei
->params
.auth_keychain
!= NULL
) {
203 eigrp_make_md5_digest(ei
, ep
->s
,
204 EIGRP_AUTH_UPDATE_FLAG
);
207 eigrp_packet_checksum(ei
, ep
->s
, length
);
210 ep
->dst
.s_addr
= htonl(EIGRP_MULTICAST_ADDRESS
);
212 ep
->sequence_number
= ei
->eigrp
->sequence_number
;
213 ei
->eigrp
->sequence_number
++;
215 for (ALL_LIST_ELEMENTS(ei
->nbrs
, node2
, nnode2
, nbr
)) {
216 struct eigrp_packet
*dup
;
218 if (nbr
->state
!= EIGRP_NEIGHBOR_UP
)
221 dup
= eigrp_packet_duplicate(ep
, nbr
);
222 /*Put packet to retransmission queue*/
223 eigrp_fifo_push(nbr
->retrans_queue
, dup
);
225 if (nbr
->retrans_queue
->count
== 1)
226 eigrp_send_packet_reliably(nbr
);
231 eigrp_packet_free(ep
);
240 if ((ei
->params
.auth_type
== EIGRP_AUTH_TYPE_MD5
)
241 && ei
->params
.auth_keychain
!= NULL
)
242 eigrp_make_md5_digest(ei
, ep
->s
, EIGRP_AUTH_UPDATE_FLAG
);
246 eigrp_packet_checksum(ei
, ep
->s
, length
);
249 ep
->dst
.s_addr
= htonl(EIGRP_MULTICAST_ADDRESS
);
251 /*This ack number we await from neighbor*/
252 ep
->sequence_number
= ei
->eigrp
->sequence_number
;
253 ei
->eigrp
->sequence_number
++;
255 for (ALL_LIST_ELEMENTS(ei
->nbrs
, node2
, nnode2
, nbr
)) {
256 struct eigrp_packet
*dup
;
258 if (nbr
->state
!= EIGRP_NEIGHBOR_UP
)
261 dup
= eigrp_packet_duplicate(ep
, nbr
);
262 /*Put packet to retransmission queue*/
263 eigrp_fifo_push(nbr
->retrans_queue
, dup
);
265 if (nbr
->retrans_queue
->count
== 1)
266 eigrp_send_packet_reliably(nbr
);
269 eigrp_packet_free(ep
);