]> git.proxmox.com Git - mirror_frr.git/blob - ospfd/ospf_flood.c
Merge pull request #8214 from chiragshah6/mdev
[mirror_frr.git] / ospfd / ospf_flood.c
1 /*
2 * OSPF Flooding -- RFC2328 Section 13.
3 * Copyright (C) 1999, 2000 Toshiaki Takada
4 *
5 * This file is part of GNU Zebra.
6 *
7 * GNU Zebra is free software; you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License as published
9 * by the Free Software Foundation; either version 2, or (at your
10 * option) any later version.
11 *
12 * GNU Zebra is distributed in the hope that it will be useful, but
13 * WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * General Public License for more details.
16 *
17 * You should have received a copy of the GNU General Public License along
18 * with this program; see the file COPYING; if not, write to the Free Software
19 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
20 */
21
22 #include <zebra.h>
23
24 #include "monotime.h"
25 #include "linklist.h"
26 #include "prefix.h"
27 #include "if.h"
28 #include "command.h"
29 #include "table.h"
30 #include "thread.h"
31 #include "memory.h"
32 #include "log.h"
33 #include "zclient.h"
34
35 #include "ospfd/ospfd.h"
36 #include "ospfd/ospf_interface.h"
37 #include "ospfd/ospf_ism.h"
38 #include "ospfd/ospf_asbr.h"
39 #include "ospfd/ospf_lsa.h"
40 #include "ospfd/ospf_lsdb.h"
41 #include "ospfd/ospf_neighbor.h"
42 #include "ospfd/ospf_nsm.h"
43 #include "ospfd/ospf_spf.h"
44 #include "ospfd/ospf_flood.h"
45 #include "ospfd/ospf_packet.h"
46 #include "ospfd/ospf_abr.h"
47 #include "ospfd/ospf_route.h"
48 #include "ospfd/ospf_zebra.h"
49 #include "ospfd/ospf_dump.h"
50
51 extern struct zclient *zclient;
52
53 /* Do the LSA acking specified in table 19, Section 13.5, row 2
54 * This get called from ospf_flood_out_interface. Declared inline
55 * for speed. */
56 static void ospf_flood_delayed_lsa_ack(struct ospf_neighbor *inbr,
57 struct ospf_lsa *lsa)
58 {
59 /* LSA is more recent than database copy, but was not
60 flooded back out receiving interface. Delayed
61 acknowledgment sent. If interface is in Backup state
62 delayed acknowledgment sent only if advertisement
63 received from Designated Router, otherwise do nothing See
64 RFC 2328 Section 13.5 */
65
66 /* Whether LSA is more recent or not, and whether this is in
67 response to the LSA being sent out recieving interface has been
68 worked out previously */
69
70 /* Deal with router as BDR */
71 if (inbr->oi->state == ISM_Backup && !NBR_IS_DR(inbr))
72 return;
73
74 /* Schedule a delayed LSA Ack to be sent */
75 listnode_add(inbr->oi->ls_ack,
76 ospf_lsa_lock(lsa)); /* delayed LSA Ack */
77 }
78
79 /* Check LSA is related to external info. */
80 struct external_info *ospf_external_info_check(struct ospf *ospf,
81 struct ospf_lsa *lsa)
82 {
83 struct as_external_lsa *al;
84 struct prefix_ipv4 p;
85 struct route_node *rn;
86 struct list *ext_list;
87 struct listnode *node;
88 struct ospf_external *ext;
89 int type;
90
91 al = (struct as_external_lsa *)lsa->data;
92
93 p.family = AF_INET;
94 p.prefix = lsa->data->id;
95 p.prefixlen = ip_masklen(al->mask);
96
97 for (type = 0; type < ZEBRA_ROUTE_MAX; type++) {
98 int redist_on = 0;
99
100 redist_on =
101 is_prefix_default(&p)
102 ? vrf_bitmap_check(
103 zclient->default_information[AFI_IP],
104 ospf->vrf_id)
105 : (zclient->mi_redist[AFI_IP][type].enabled
106 || vrf_bitmap_check(
107 zclient->redist[AFI_IP][type],
108 ospf->vrf_id));
109 // Pending: check for MI above.
110 if (redist_on) {
111 ext_list = ospf->external[type];
112 if (!ext_list)
113 continue;
114
115 for (ALL_LIST_ELEMENTS_RO(ext_list, node, ext)) {
116 rn = NULL;
117 if (ext->external_info)
118 rn = route_node_lookup(
119 ext->external_info,
120 (struct prefix *)&p);
121 if (rn) {
122 route_unlock_node(rn);
123 if (rn->info != NULL)
124 return (struct external_info *)
125 rn->info;
126 }
127 }
128 }
129 }
130
131 if (is_prefix_default(&p) && ospf->external[DEFAULT_ROUTE]) {
132 ext_list = ospf->external[DEFAULT_ROUTE];
133
134 for (ALL_LIST_ELEMENTS_RO(ext_list, node, ext)) {
135 if (!ext->external_info)
136 continue;
137
138 rn = route_node_lookup(ext->external_info,
139 (struct prefix *)&p);
140 if (!rn)
141 continue;
142 route_unlock_node(rn);
143 if (rn->info != NULL)
144 return (struct external_info *)rn->info;
145 }
146 }
147 return NULL;
148 }
149
150 static void ospf_process_self_originated_lsa(struct ospf *ospf,
151 struct ospf_lsa *new,
152 struct ospf_area *area)
153 {
154 struct ospf_interface *oi;
155 struct external_info *ei;
156 struct listnode *node;
157 struct as_external_lsa *al;
158 struct prefix_ipv4 p;
159 struct ospf_external_aggr_rt *aggr;
160
161 if (IS_DEBUG_OSPF_EVENT)
162 zlog_debug(
163 "%s:LSA[Type%d:%pI4]: Process self-originated LSA seq 0x%x",
164 ospf_get_name(ospf), new->data->type,
165 &new->data->id, ntohl(new->data->ls_seqnum));
166
167 /* If we're here, we installed a self-originated LSA that we received
168 from a neighbor, i.e. it's more recent. We must see whether we want
169 to originate it.
170 If yes, we should use this LSA's sequence number and reoriginate
171 a new instance.
172 if not --- we must flush this LSA from the domain. */
173 switch (new->data->type) {
174 case OSPF_ROUTER_LSA:
175 /* Originate a new instance and schedule flooding */
176 if (area->router_lsa_self)
177 area->router_lsa_self->data->ls_seqnum =
178 new->data->ls_seqnum;
179 ospf_router_lsa_update_area(area);
180 return;
181 case OSPF_NETWORK_LSA:
182 case OSPF_OPAQUE_LINK_LSA:
183 /* We must find the interface the LSA could belong to.
184 If the interface is no more a broadcast type or we are no
185 more
186 the DR, we flush the LSA otherwise -- create the new instance
187 and
188 schedule flooding. */
189
190 /* Look through all interfaces, not just area, since interface
191 could be moved from one area to another. */
192 for (ALL_LIST_ELEMENTS_RO(ospf->oiflist, node, oi))
193 /* These are sanity check. */
194 if (IPV4_ADDR_SAME(&oi->address->u.prefix4,
195 &new->data->id)) {
196 if (oi->area != area
197 || oi->type != OSPF_IFTYPE_BROADCAST
198 || !IPV4_ADDR_SAME(&oi->address->u.prefix4,
199 &DR(oi))) {
200 ospf_schedule_lsa_flush_area(area, new);
201 return;
202 }
203
204 if (new->data->type == OSPF_OPAQUE_LINK_LSA) {
205 ospf_opaque_lsa_refresh(new);
206 return;
207 }
208
209 if (oi->network_lsa_self)
210 oi->network_lsa_self->data->ls_seqnum =
211 new->data->ls_seqnum;
212 /* Schedule network-LSA origination. */
213 ospf_network_lsa_update(oi);
214 return;
215 }
216 break;
217 case OSPF_SUMMARY_LSA:
218 case OSPF_ASBR_SUMMARY_LSA:
219 ospf_schedule_abr_task(ospf);
220 break;
221 case OSPF_AS_EXTERNAL_LSA:
222 case OSPF_AS_NSSA_LSA:
223 if ((new->data->type == OSPF_AS_EXTERNAL_LSA)
224 && CHECK_FLAG(new->flags, OSPF_LSA_LOCAL_XLT)) {
225 ospf_translated_nssa_refresh(ospf, NULL, new);
226 return;
227 }
228
229 al = (struct as_external_lsa *)new->data;
230 p.family = AF_INET;
231 p.prefixlen = ip_masklen(al->mask);
232 p.prefix = new->data->id;
233
234 ei = ospf_external_info_check(ospf, new);
235 if (ei) {
236 if (ospf_external_aggr_match(ospf, &ei->p)) {
237 if (IS_DEBUG_OSPF(lsa, EXTNL_LSA_AGGR))
238 zlog_debug(
239 "%s, Matching external aggregate route found for %pI4, so don't refresh it.",
240 __func__,
241 &ei->p.prefix);
242
243 /* Aggregated external route shouldn't
244 * be in LSDB.
245 */
246 if (!IS_LSA_MAXAGE(new))
247 ospf_lsa_flush_as(ospf, new);
248
249 return;
250 }
251
252 ospf_external_lsa_refresh(ospf, new, ei,
253 LSA_REFRESH_FORCE, false);
254 } else {
255 aggr = (struct ospf_external_aggr_rt *)
256 ospf_extrenal_aggregator_lookup(ospf, &p);
257 if (aggr) {
258 struct external_info ei_aggr;
259
260 memset(&ei_aggr, 0,
261 sizeof(struct external_info));
262 ei_aggr.p = aggr->p;
263 ei_aggr.tag = aggr->tag;
264 ei_aggr.instance = ospf->instance;
265 ei_aggr.route_map_set.metric = -1;
266 ei_aggr.route_map_set.metric_type = -1;
267
268 ospf_external_lsa_refresh(ospf, new, &ei_aggr,
269 LSA_REFRESH_FORCE, true);
270 } else
271 ospf_lsa_flush_as(ospf, new);
272 }
273 break;
274 case OSPF_OPAQUE_AREA_LSA:
275 ospf_opaque_lsa_refresh(new);
276 break;
277 case OSPF_OPAQUE_AS_LSA:
278 ospf_opaque_lsa_refresh(new);
279 /* Reconsideration may needed. */ /* XXX */
280 break;
281 default:
282 break;
283 }
284 }
285
286 /* OSPF LSA flooding -- RFC2328 Section 13.(5). */
287
288 /* Now Updated for NSSA operation, as follows:
289
290
291 Type-5's have no change. Blocked to STUB or NSSA.
292
293 Type-7's can be received, and if a DR
294 they will also flood the local NSSA Area as Type-7's
295
296 If a Self-Originated LSA (now an ASBR),
297 The LSDB will be updated as Type-5's, (for continual re-fresh)
298
299 If an NSSA-IR it is installed/flooded as Type-7, P-bit on.
300 if an NSSA-ABR it is installed/flooded as Type-7, P-bit off.
301
302 Later, during the ABR TASK, if the ABR is the Elected NSSA
303 translator, then All Type-7s (with P-bit ON) are Translated to
304 Type-5's and flooded to all non-NSSA/STUB areas.
305
306 During ASE Calculations,
307 non-ABRs calculate external routes from Type-7's
308 ABRs calculate external routes from Type-5's and non-self Type-7s
309 */
310 int ospf_flood(struct ospf *ospf, struct ospf_neighbor *nbr,
311 struct ospf_lsa *current, struct ospf_lsa *new)
312 {
313 struct ospf_interface *oi;
314 int lsa_ack_flag;
315
316 /* Type-7 LSA's will be flooded throughout their native NSSA area,
317 but will also be flooded as Type-5's into ABR capable links. */
318
319 if (IS_DEBUG_OSPF_EVENT)
320 zlog_debug(
321 "%s:LSA[Flooding]: start, NBR %pI4 (%s), cur(%p), New-LSA[%s]",
322 ospf_get_name(ospf), &nbr->router_id,
323 lookup_msg(ospf_nsm_state_msg, nbr->state, NULL),
324 (void *)current, dump_lsa_key(new));
325
326 oi = nbr->oi;
327
328 /* If there is already a database copy, and if the
329 database copy was received via flooding and installed less
330 than MinLSArrival seconds ago, discard the new LSA
331 (without acknowledging it). */
332 if (current != NULL) /* -- endo. */
333 {
334 if (IS_LSA_SELF(current)
335 && (ntohs(current->data->ls_age) == 0
336 && ntohl(current->data->ls_seqnum)
337 == OSPF_INITIAL_SEQUENCE_NUMBER)) {
338 if (IS_DEBUG_OSPF_EVENT)
339 zlog_debug(
340 "%s:LSA[Flooding]: Got a self-originated LSA, while local one is initial instance.",
341 ospf_get_name(ospf));
342 ; /* Accept this LSA for quick LSDB resynchronization.
343 */
344 } else if (monotime_since(&current->tv_recv, NULL)
345 < ospf->min_ls_arrival * 1000LL) {
346 if (IS_DEBUG_OSPF_EVENT)
347 zlog_debug(
348 "%s:LSA[Flooding]: LSA is received recently.",
349 ospf_get_name(ospf));
350 return -1;
351 }
352 }
353
354 /* Flood the new LSA out some subset of the router's interfaces.
355 In some cases (e.g., the state of the receiving interface is
356 DR and the LSA was received from a router other than the
357 Backup DR) the LSA will be flooded back out the receiving
358 interface. */
359 lsa_ack_flag = ospf_flood_through(ospf, nbr, new);
360
361 /* Remove the current database copy from all neighbors' Link state
362 retransmission lists. AS_EXTERNAL and AS_EXTERNAL_OPAQUE does
363 ^^^^^^^^^^^^^^^^^^^^^^^
364 not have area ID.
365 All other (even NSSA's) do have area ID. */
366 if (current) {
367 switch (current->data->type) {
368 case OSPF_AS_EXTERNAL_LSA:
369 case OSPF_OPAQUE_AS_LSA:
370 ospf_ls_retransmit_delete_nbr_as(ospf, current);
371 break;
372 default:
373 ospf_ls_retransmit_delete_nbr_area(oi->area, current);
374 break;
375 }
376 }
377
378 /* Do some internal house keeping that is needed here */
379 SET_FLAG(new->flags, OSPF_LSA_RECEIVED);
380 (void)ospf_lsa_is_self_originated(ospf, new); /* Let it set the flag */
381
382 /* Received Grace LSA */
383 if (IS_GRACE_LSA(new)) {
384
385 if (IS_LSA_MAXAGE(new)) {
386
387 /* Handling Max age grace LSA.*/
388 if (IS_DEBUG_OSPF_GR_HELPER)
389 zlog_debug(
390 "%s, Received a maxage GRACE-LSA from router %pI4",
391 __PRETTY_FUNCTION__,
392 &new->data->adv_router);
393
394 if (current) {
395 ospf_process_maxage_grace_lsa(ospf, new, nbr);
396 } else {
397 if (IS_DEBUG_OSPF_GR_HELPER)
398 zlog_debug(
399 "%s, Grace LSA doesn't exist in lsdb, so discarding grace lsa",
400 __PRETTY_FUNCTION__);
401 return -1;
402 }
403 } else {
404 if (IS_DEBUG_OSPF_GR_HELPER)
405 zlog_debug(
406 "%s, Received a GRACE-LSA from router %pI4",
407 __PRETTY_FUNCTION__,
408 &new->data->adv_router);
409
410 if (ospf_process_grace_lsa(ospf, new, nbr)
411 == OSPF_GR_NOT_HELPER) {
412 if (IS_DEBUG_OSPF_GR_HELPER)
413 zlog_debug(
414 "%s, Not moving to HELPER role, So discarding grace LSA",
415 __PRETTY_FUNCTION__);
416 return -1;
417 }
418 }
419 }
420
421 /* Install the new LSA in the link state database
422 (replacing the current database copy). This may cause the
423 routing table calculation to be scheduled. In addition,
424 timestamp the new LSA with the current time. The flooding
425 procedure cannot overwrite the newly installed LSA until
426 MinLSArrival seconds have elapsed. */
427
428 if (!(new = ospf_lsa_install(ospf, oi, new)))
429 return -1; /* unknown LSA type or any other error condition */
430
431 /* Acknowledge the receipt of the LSA by sending a Link State
432 Acknowledgment packet back out the receiving interface. */
433 if (lsa_ack_flag)
434 ospf_flood_delayed_lsa_ack(nbr, new);
435
436 /* If this new LSA indicates that it was originated by the
437 receiving router itself, the router must take special action,
438 either updating the LSA or in some cases flushing it from
439 the routing domain. */
440 if (ospf_lsa_is_self_originated(ospf, new))
441 ospf_process_self_originated_lsa(ospf, new, oi->area);
442 else
443 /* Update statistics value for OSPF-MIB. */
444 ospf->rx_lsa_count++;
445
446 return 0;
447 }
448
449 /* OSPF LSA flooding -- RFC2328 Section 13.3. */
450 static int ospf_flood_through_interface(struct ospf_interface *oi,
451 struct ospf_neighbor *inbr,
452 struct ospf_lsa *lsa)
453 {
454 struct ospf_neighbor *onbr;
455 struct route_node *rn;
456 int retx_flag;
457 char buf[PREFIX_STRLEN];
458
459 if (IS_DEBUG_OSPF_EVENT)
460 zlog_debug(
461 "%s: considering int %s (%s), INBR(%s), LSA[%s] AGE %u",
462 __func__, IF_NAME(oi), ospf_get_name(oi->ospf),
463 inbr ? inet_ntop(AF_INET, &inbr->router_id, buf,
464 sizeof(buf))
465 : "NULL",
466 dump_lsa_key(lsa), ntohs(lsa->data->ls_age));
467
468 if (!ospf_if_is_enable(oi))
469 return 0;
470
471 /* Remember if new LSA is added to a retransmit list. */
472 retx_flag = 0;
473
474 /* Each of the neighbors attached to this interface are examined,
475 to determine whether they must receive the new LSA. The following
476 steps are executed for each neighbor: */
477 for (rn = route_top(oi->nbrs); rn; rn = route_next(rn)) {
478 struct ospf_lsa *ls_req;
479
480 if (rn->info == NULL)
481 continue;
482
483 onbr = rn->info;
484 if (IS_DEBUG_OSPF_EVENT)
485 zlog_debug(
486 "%s: considering nbr %pI4 via %s (%s), state: %s",
487 __func__, &onbr->router_id, IF_NAME(oi),
488 ospf_get_name(oi->ospf),
489 lookup_msg(ospf_nsm_state_msg, onbr->state,
490 NULL));
491
492 /* If the neighbor is in a lesser state than Exchange, it
493 does not participate in flooding, and the next neighbor
494 should be examined. */
495 if (onbr->state < NSM_Exchange)
496 continue;
497
498 /* If the adjacency is not yet full (neighbor state is
499 Exchange or Loading), examine the Link state request
500 list associated with this adjacency. If there is an
501 instance of the new LSA on the list, it indicates that
502 the neighboring router has an instance of the LSA
503 already. Compare the new LSA to the neighbor's copy: */
504 if (onbr->state < NSM_Full) {
505 if (IS_DEBUG_OSPF_EVENT)
506 zlog_debug(
507 "%s: adj to onbr %pI4 is not Full (%s)",
508 __func__, &onbr->router_id,
509 lookup_msg(ospf_nsm_state_msg,
510 onbr->state, NULL));
511 ls_req = ospf_ls_request_lookup(onbr, lsa);
512 if (ls_req != NULL) {
513 int ret;
514
515 ret = ospf_lsa_more_recent(ls_req, lsa);
516 /* The new LSA is less recent. */
517 if (ret > 0)
518 continue;
519 /* The two copies are the same instance, then
520 delete
521 the LSA from the Link state request list. */
522 else if (ret == 0) {
523 ospf_ls_request_delete(onbr, ls_req);
524 ospf_check_nbr_loading(onbr);
525 continue;
526 }
527 /* The new LSA is more recent. Delete the LSA
528 from the Link state request list. */
529 else {
530 ospf_ls_request_delete(onbr, ls_req);
531 ospf_check_nbr_loading(onbr);
532 }
533 }
534 }
535
536 if (IS_OPAQUE_LSA(lsa->data->type)) {
537 if (!CHECK_FLAG(onbr->options, OSPF_OPTION_O)) {
538 if (IS_DEBUG_OSPF(lsa, LSA_FLOODING))
539 zlog_debug(
540 "%s: Skipping neighbor %s via %pI4 -- Not Opaque-capable.",
541 __func__, IF_NAME(oi),
542 &onbr->router_id);
543 continue;
544 }
545 }
546
547 /* If the new LSA was received from this neighbor,
548 examine the next neighbor. */
549 if (inbr) {
550 /*
551 * Triggered by LSUpd message parser "ospf_ls_upd ()".
552 * E.g., all LSAs handling here is received via network.
553 */
554 if (IPV4_ADDR_SAME(&inbr->router_id,
555 &onbr->router_id)) {
556 if (IS_DEBUG_OSPF(lsa, LSA_FLOODING))
557 zlog_debug(
558 "%s: Skipping neighbor %s via %pI4 -- inbr == onbr.",
559 __func__, IF_NAME(oi),
560 &inbr->router_id);
561 continue;
562 }
563 } else {
564 /*
565 * Triggered by MaxAge remover, so far.
566 * NULL "inbr" means flooding starts from this node.
567 */
568 if (IPV4_ADDR_SAME(&lsa->data->adv_router,
569 &onbr->router_id)) {
570 if (IS_DEBUG_OSPF(lsa, LSA_FLOODING))
571 zlog_debug(
572 "%s: Skipping neighbor %s via %pI4 -- lsah->adv_router == onbr.",
573 __func__, IF_NAME(oi),
574 &onbr->router_id);
575 continue;
576 }
577 }
578
579 /* Add the new LSA to the Link state retransmission list
580 for the adjacency. The LSA will be retransmitted
581 at intervals until an acknowledgment is seen from
582 the neighbor. */
583 ospf_ls_retransmit_add(onbr, lsa);
584 retx_flag = 1;
585 }
586
587 /* If in the previous step, the LSA was NOT added to any of
588 the Link state retransmission lists, there is no need to
589 flood the LSA out the interface. */
590 if (retx_flag == 0) {
591 return (inbr && inbr->oi == oi);
592 }
593
594 /* if we've received the lsa on this interface we need to perform
595 additional checking */
596 if (inbr && (inbr->oi == oi)) {
597 /* If the new LSA was received on this interface, and it was
598 received from either the Designated Router or the Backup
599 Designated Router, chances are that all the neighbors have
600 received the LSA already. */
601 if (NBR_IS_DR(inbr) || NBR_IS_BDR(inbr)) {
602 if (IS_DEBUG_OSPF_NSSA)
603 zlog_debug("%s: DR/BDR NOT SEND to int %s (%s)",
604 __func__, IF_NAME(oi),
605 ospf_get_name(oi->ospf));
606 return 1;
607 }
608
609 /* If the new LSA was received on this interface, and the
610 interface state is Backup, examine the next interface. The
611 Designated Router will do the flooding on this interface.
612 However, if the Designated Router fails the router will
613 end up retransmitting the updates. */
614
615 if (oi->state == ISM_Backup) {
616 if (IS_DEBUG_OSPF_NSSA)
617 zlog_debug(
618 "%s: ISM_Backup NOT SEND to int %s (%s)",
619 __func__, IF_NAME(oi),
620 ospf_get_name(oi->ospf));
621 return 1;
622 }
623 }
624
625 /* The LSA must be flooded out the interface. Send a Link State
626 Update packet (including the new LSA as contents) out the
627 interface. The LSA's LS age must be incremented by InfTransDelay
628 (which must be > 0) when it is copied into the outgoing Link
629 State Update packet (until the LS age field reaches the maximum
630 value of MaxAge). */
631 /* XXX HASSO: Is this IS_DEBUG_OSPF_NSSA really correct? */
632 if (IS_DEBUG_OSPF_NSSA)
633 zlog_debug("%s: DR/BDR sending upd to int %s (%s)", __func__,
634 IF_NAME(oi), ospf_get_name(oi->ospf));
635
636 /* RFC2328 Section 13.3
637 On non-broadcast networks, separate Link State Update
638 packets must be sent, as unicasts, to each adjacent neighbor
639 (i.e., those in state Exchange or greater). The destination
640 IP addresses for these packets are the neighbors' IP
641 addresses. */
642 if (oi->type == OSPF_IFTYPE_NBMA) {
643 struct ospf_neighbor *nbr;
644
645 for (rn = route_top(oi->nbrs); rn; rn = route_next(rn))
646 if ((nbr = rn->info) != NULL)
647 if (nbr != oi->nbr_self
648 && nbr->state >= NSM_Exchange)
649 ospf_ls_upd_send_lsa(
650 nbr, lsa,
651 OSPF_SEND_PACKET_DIRECT);
652 } else
653 ospf_ls_upd_send_lsa(oi->nbr_self, lsa,
654 OSPF_SEND_PACKET_INDIRECT);
655
656 return 0;
657 }
658
659 int ospf_flood_through_area(struct ospf_area *area, struct ospf_neighbor *inbr,
660 struct ospf_lsa *lsa)
661 {
662 struct listnode *node, *nnode;
663 struct ospf_interface *oi;
664 int lsa_ack_flag = 0;
665
666 assert(area);
667 /* All other types are specific to a single area (Area A). The
668 eligible interfaces are all those interfaces attaching to the
669 Area A. If Area A is the backbone, this includes all the virtual
670 links. */
671 for (ALL_LIST_ELEMENTS(area->oiflist, node, nnode, oi)) {
672 if (area->area_id.s_addr != OSPF_AREA_BACKBONE
673 && oi->type == OSPF_IFTYPE_VIRTUALLINK)
674 continue;
675
676 if ((lsa->data->type == OSPF_OPAQUE_LINK_LSA)
677 && (lsa->oi != oi)) {
678 /*
679 * Link local scoped Opaque-LSA should only be flooded
680 * for the link on which the LSA has received.
681 */
682 if (IS_DEBUG_OSPF(lsa, LSA_FLOODING))
683 zlog_debug(
684 "Type-9 Opaque-LSA: lsa->oi(%p) != oi(%p)",
685 (void *)lsa->oi, (void *)oi);
686 continue;
687 }
688
689 if (ospf_flood_through_interface(oi, inbr, lsa))
690 lsa_ack_flag = 1;
691 }
692
693 return (lsa_ack_flag);
694 }
695
696 int ospf_flood_through_as(struct ospf *ospf, struct ospf_neighbor *inbr,
697 struct ospf_lsa *lsa)
698 {
699 struct listnode *node;
700 struct ospf_area *area;
701 int lsa_ack_flag;
702
703 lsa_ack_flag = 0;
704
705 /* The incoming LSA is type 5 or type 7 (AS-EXTERNAL or AS-NSSA )
706
707 Divert the Type-5 LSA's to all non-NSSA/STUB areas
708
709 Divert the Type-7 LSA's to all NSSA areas
710
711 AS-external-LSAs are flooded throughout the entire AS, with the
712 exception of stub areas (see Section 3.6). The eligible
713 interfaces are all the router's interfaces, excluding virtual
714 links and those interfaces attaching to stub areas. */
715
716 if (CHECK_FLAG(lsa->flags, OSPF_LSA_LOCAL_XLT)) /* Translated from 7 */
717 if (IS_DEBUG_OSPF_NSSA)
718 zlog_debug("Flood/AS: NSSA TRANSLATED LSA");
719
720 for (ALL_LIST_ELEMENTS_RO(ospf->areas, node, area)) {
721 int continue_flag = 0;
722 struct listnode *if_node;
723 struct ospf_interface *oi;
724
725 switch (area->external_routing) {
726 /* Don't send AS externals into stub areas. Various types
727 of support for partial stub areas can be implemented
728 here. NSSA's will receive Type-7's that have areas
729 matching the originl LSA. */
730 case OSPF_AREA_NSSA: /* Sending Type 5 or 7 into NSSA area */
731 /* Type-7, flood NSSA area */
732 if (lsa->data->type == OSPF_AS_NSSA_LSA
733 && area == lsa->area)
734 /* We will send it. */
735 continue_flag = 0;
736 else
737 continue_flag = 1; /* Skip this NSSA area for
738 Type-5's et al */
739 break;
740
741 case OSPF_AREA_TYPE_MAX:
742 case OSPF_AREA_STUB:
743 continue_flag = 1; /* Skip this area. */
744 break;
745
746 case OSPF_AREA_DEFAULT:
747 default:
748 /* No Type-7 into normal area */
749 if (lsa->data->type == OSPF_AS_NSSA_LSA)
750 continue_flag = 1; /* skip Type-7 */
751 else
752 continue_flag = 0; /* Do this area. */
753 break;
754 }
755
756 /* Do continue for above switch. Saves a big if then mess */
757 if (continue_flag)
758 continue; /* main for-loop */
759
760 /* send to every interface in this area */
761
762 for (ALL_LIST_ELEMENTS_RO(area->oiflist, if_node, oi)) {
763 /* Skip virtual links */
764 if (oi->type != OSPF_IFTYPE_VIRTUALLINK)
765 if (ospf_flood_through_interface(oi, inbr,
766 lsa)) /* lsa */
767 lsa_ack_flag = 1;
768 }
769 } /* main area for-loop */
770
771 return (lsa_ack_flag);
772 }
773
774 int ospf_flood_through(struct ospf *ospf, struct ospf_neighbor *inbr,
775 struct ospf_lsa *lsa)
776 {
777 int lsa_ack_flag = 0;
778
779 /* Type-7 LSA's for NSSA are flooded throughout the AS here, and
780 upon return are updated in the LSDB for Type-7's. Later,
781 re-fresh will re-send them (and also, if ABR, packet code will
782 translate to Type-5's)
783
784 As usual, Type-5 LSA's (if not DISCARDED because we are STUB or
785 NSSA) are flooded throughout the AS, and are updated in the
786 global table. */
787 /*
788 * At the common sub-sub-function "ospf_flood_through_interface()",
789 * a parameter "inbr" will be used to distinguish the called context
790 * whether the given LSA was received from the neighbor, or the
791 * flooding for the LSA starts from this node (e.g. the LSA was self-
792 * originated, or the LSA is going to be flushed from routing domain).
793 *
794 * So, for consistency reasons, this function "ospf_flood_through()"
795 * should also allow the usage that the given "inbr" parameter to be
796 * NULL. If we do so, corresponding AREA parameter should be referred
797 * by "lsa->area", instead of "inbr->oi->area".
798 */
799 switch (lsa->data->type) {
800 case OSPF_AS_EXTERNAL_LSA: /* Type-5 */
801 case OSPF_OPAQUE_AS_LSA:
802 lsa_ack_flag = ospf_flood_through_as(ospf, inbr, lsa);
803 break;
804 /* Type-7 Only received within NSSA, then flooded */
805 case OSPF_AS_NSSA_LSA:
806 /* Any P-bit was installed with the Type-7. */
807
808 if (IS_DEBUG_OSPF_NSSA)
809 zlog_debug(
810 "ospf_flood_through: LOCAL NSSA FLOOD of Type-7.");
811 /* Fallthrough */
812 default:
813 lsa_ack_flag = ospf_flood_through_area(lsa->area, inbr, lsa);
814 break;
815 }
816
817 return (lsa_ack_flag);
818 }
819
820
821 /* Management functions for neighbor's Link State Request list. */
822 void ospf_ls_request_add(struct ospf_neighbor *nbr, struct ospf_lsa *lsa)
823 {
824 /*
825 * We cannot make use of the newly introduced callback function
826 * "lsdb->new_lsa_hook" to replace debug output below, just because
827 * it seems no simple and smart way to pass neighbor information to
828 * the common function "ospf_lsdb_add()" -- endo.
829 */
830 if (IS_DEBUG_OSPF(lsa, LSA_FLOODING))
831 zlog_debug("RqstL(%lu)++, NBR(%pI4(%s)), LSA[%s]",
832 ospf_ls_request_count(nbr),
833 &nbr->router_id,
834 ospf_get_name(nbr->oi->ospf), dump_lsa_key(lsa));
835
836 ospf_lsdb_add(&nbr->ls_req, lsa);
837 }
838
839 unsigned long ospf_ls_request_count(struct ospf_neighbor *nbr)
840 {
841 return ospf_lsdb_count_all(&nbr->ls_req);
842 }
843
844 int ospf_ls_request_isempty(struct ospf_neighbor *nbr)
845 {
846 return ospf_lsdb_isempty(&nbr->ls_req);
847 }
848
849 /* Remove LSA from neighbor's ls-request list. */
850 void ospf_ls_request_delete(struct ospf_neighbor *nbr, struct ospf_lsa *lsa)
851 {
852 if (nbr->ls_req_last == lsa) {
853 ospf_lsa_unlock(&nbr->ls_req_last);
854 nbr->ls_req_last = NULL;
855 }
856
857 if (IS_DEBUG_OSPF(lsa, LSA_FLOODING)) /* -- endo. */
858 zlog_debug("RqstL(%lu)--, NBR(%pI4(%s)), LSA[%s]",
859 ospf_ls_request_count(nbr),
860 &nbr->router_id,
861 ospf_get_name(nbr->oi->ospf), dump_lsa_key(lsa));
862
863 ospf_lsdb_delete(&nbr->ls_req, lsa);
864 }
865
866 /* Remove all LSA from neighbor's ls-requenst list. */
867 void ospf_ls_request_delete_all(struct ospf_neighbor *nbr)
868 {
869 ospf_lsa_unlock(&nbr->ls_req_last);
870 nbr->ls_req_last = NULL;
871 ospf_lsdb_delete_all(&nbr->ls_req);
872 }
873
874 /* Lookup LSA from neighbor's ls-request list. */
875 struct ospf_lsa *ospf_ls_request_lookup(struct ospf_neighbor *nbr,
876 struct ospf_lsa *lsa)
877 {
878 return ospf_lsdb_lookup(&nbr->ls_req, lsa);
879 }
880
881 struct ospf_lsa *ospf_ls_request_new(struct lsa_header *lsah)
882 {
883 struct ospf_lsa *new;
884
885 new = ospf_lsa_new_and_data(OSPF_LSA_HEADER_SIZE);
886 memcpy(new->data, lsah, OSPF_LSA_HEADER_SIZE);
887
888 return new;
889 }
890
891
892 /* Management functions for neighbor's ls-retransmit list. */
893 unsigned long ospf_ls_retransmit_count(struct ospf_neighbor *nbr)
894 {
895 return ospf_lsdb_count_all(&nbr->ls_rxmt);
896 }
897
898 unsigned long ospf_ls_retransmit_count_self(struct ospf_neighbor *nbr,
899 int lsa_type)
900 {
901 return ospf_lsdb_count_self(&nbr->ls_rxmt, lsa_type);
902 }
903
904 int ospf_ls_retransmit_isempty(struct ospf_neighbor *nbr)
905 {
906 return ospf_lsdb_isempty(&nbr->ls_rxmt);
907 }
908
909 /* Add LSA to be retransmitted to neighbor's ls-retransmit list. */
910 void ospf_ls_retransmit_add(struct ospf_neighbor *nbr, struct ospf_lsa *lsa)
911 {
912 struct ospf_lsa *old;
913
914 old = ospf_ls_retransmit_lookup(nbr, lsa);
915
916 if (ospf_lsa_more_recent(old, lsa) < 0) {
917 if (old) {
918 old->retransmit_counter--;
919 if (IS_DEBUG_OSPF(lsa, LSA_FLOODING))
920 zlog_debug("RXmtL(%lu)--, NBR(%pI4(%s)), LSA[%s]",
921 ospf_ls_retransmit_count(nbr),
922 &nbr->router_id,
923 ospf_get_name(nbr->oi->ospf),
924 dump_lsa_key(old));
925 ospf_lsdb_delete(&nbr->ls_rxmt, old);
926 }
927 lsa->retransmit_counter++;
928 /*
929 * We cannot make use of the newly introduced callback function
930 * "lsdb->new_lsa_hook" to replace debug output below, just
931 * because
932 * it seems no simple and smart way to pass neighbor information
933 * to
934 * the common function "ospf_lsdb_add()" -- endo.
935 */
936 if (IS_DEBUG_OSPF(lsa, LSA_FLOODING))
937 zlog_debug("RXmtL(%lu)++, NBR(%pI4(%s)), LSA[%s]",
938 ospf_ls_retransmit_count(nbr),
939 &nbr->router_id,
940 ospf_get_name(nbr->oi->ospf),
941 dump_lsa_key(lsa));
942 ospf_lsdb_add(&nbr->ls_rxmt, lsa);
943 }
944 }
945
946 /* Remove LSA from neibghbor's ls-retransmit list. */
947 void ospf_ls_retransmit_delete(struct ospf_neighbor *nbr, struct ospf_lsa *lsa)
948 {
949 if (ospf_ls_retransmit_lookup(nbr, lsa)) {
950 lsa->retransmit_counter--;
951 if (IS_DEBUG_OSPF(lsa, LSA_FLOODING)) /* -- endo. */
952 zlog_debug("RXmtL(%lu)--, NBR(%pI4(%s)), LSA[%s]",
953 ospf_ls_retransmit_count(nbr),
954 &nbr->router_id,
955 ospf_get_name(nbr->oi->ospf),
956 dump_lsa_key(lsa));
957 ospf_lsdb_delete(&nbr->ls_rxmt, lsa);
958 }
959 }
960
961 /* Clear neighbor's ls-retransmit list. */
962 void ospf_ls_retransmit_clear(struct ospf_neighbor *nbr)
963 {
964 struct ospf_lsdb *lsdb;
965 int i;
966
967 lsdb = &nbr->ls_rxmt;
968
969 for (i = OSPF_MIN_LSA; i < OSPF_MAX_LSA; i++) {
970 struct route_table *table = lsdb->type[i].db;
971 struct route_node *rn;
972 struct ospf_lsa *lsa;
973
974 for (rn = route_top(table); rn; rn = route_next(rn))
975 if ((lsa = rn->info) != NULL)
976 ospf_ls_retransmit_delete(nbr, lsa);
977 }
978
979 ospf_lsa_unlock(&nbr->ls_req_last);
980 nbr->ls_req_last = NULL;
981 }
982
983 /* Lookup LSA from neighbor's ls-retransmit list. */
984 struct ospf_lsa *ospf_ls_retransmit_lookup(struct ospf_neighbor *nbr,
985 struct ospf_lsa *lsa)
986 {
987 return ospf_lsdb_lookup(&nbr->ls_rxmt, lsa);
988 }
989
990 static void ospf_ls_retransmit_delete_nbr_if(struct ospf_interface *oi,
991 struct ospf_lsa *lsa)
992 {
993 struct route_node *rn;
994 struct ospf_neighbor *nbr;
995 struct ospf_lsa *lsr;
996
997 if (ospf_if_is_enable(oi))
998 for (rn = route_top(oi->nbrs); rn; rn = route_next(rn))
999 /* If LSA find in LS-retransmit list, then remove it. */
1000 if ((nbr = rn->info) != NULL) {
1001 lsr = ospf_ls_retransmit_lookup(nbr, lsa);
1002
1003 /* If LSA find in ls-retransmit list, remove it.
1004 */
1005 if (lsr != NULL
1006 && lsr->data->ls_seqnum
1007 == lsa->data->ls_seqnum)
1008 ospf_ls_retransmit_delete(nbr, lsr);
1009 }
1010 }
1011
1012 void ospf_ls_retransmit_delete_nbr_area(struct ospf_area *area,
1013 struct ospf_lsa *lsa)
1014 {
1015 struct listnode *node, *nnode;
1016 struct ospf_interface *oi;
1017
1018 for (ALL_LIST_ELEMENTS(area->oiflist, node, nnode, oi))
1019 ospf_ls_retransmit_delete_nbr_if(oi, lsa);
1020 }
1021
1022 void ospf_ls_retransmit_delete_nbr_as(struct ospf *ospf, struct ospf_lsa *lsa)
1023 {
1024 struct listnode *node, *nnode;
1025 struct ospf_interface *oi;
1026
1027 for (ALL_LIST_ELEMENTS(ospf->oiflist, node, nnode, oi))
1028 ospf_ls_retransmit_delete_nbr_if(oi, lsa);
1029 }
1030
1031
1032 /* Sets ls_age to MaxAge and floods throu the area.
1033 When we implement ASE routing, there will be another function
1034 flushing an LSA from the whole domain. */
1035 void ospf_lsa_flush_area(struct ospf_lsa *lsa, struct ospf_area *area)
1036 {
1037 /* Reset the lsa origination time such that it gives
1038 more time for the ACK to be received and avoid
1039 retransmissions */
1040 lsa->data->ls_age = htons(OSPF_LSA_MAXAGE);
1041 if (IS_DEBUG_OSPF_EVENT)
1042 zlog_debug("%s: MAXAGE set to LSA %pI4", __func__,
1043 &lsa->data->id);
1044 monotime(&lsa->tv_recv);
1045 lsa->tv_orig = lsa->tv_recv;
1046 ospf_flood_through_area(area, NULL, lsa);
1047 ospf_lsa_maxage(area->ospf, lsa);
1048 }
1049
1050 void ospf_lsa_flush_as(struct ospf *ospf, struct ospf_lsa *lsa)
1051 {
1052 /* Reset the lsa origination time such that it gives
1053 more time for the ACK to be received and avoid
1054 retransmissions */
1055 lsa->data->ls_age = htons(OSPF_LSA_MAXAGE);
1056 monotime(&lsa->tv_recv);
1057 lsa->tv_orig = lsa->tv_recv;
1058 ospf_flood_through_as(ospf, NULL, lsa);
1059 ospf_lsa_maxage(ospf, lsa);
1060 }
1061
1062 void ospf_lsa_flush(struct ospf *ospf, struct ospf_lsa *lsa)
1063 {
1064 lsa->data->ls_age = htons(OSPF_LSA_MAXAGE);
1065
1066 switch (lsa->data->type) {
1067 case OSPF_ROUTER_LSA:
1068 case OSPF_NETWORK_LSA:
1069 case OSPF_SUMMARY_LSA:
1070 case OSPF_ASBR_SUMMARY_LSA:
1071 case OSPF_AS_NSSA_LSA:
1072 case OSPF_OPAQUE_LINK_LSA:
1073 case OSPF_OPAQUE_AREA_LSA:
1074 ospf_lsa_flush_area(lsa, lsa->area);
1075 break;
1076 case OSPF_AS_EXTERNAL_LSA:
1077 case OSPF_OPAQUE_AS_LSA:
1078 ospf_lsa_flush_as(ospf, lsa);
1079 break;
1080 default:
1081 zlog_info("%s: Unknown LSA type %u", __func__, lsa->data->type);
1082 break;
1083 }
1084 }