2 * This is an implementation of RFC7684 OSPFv2 Prefix/Link Attribute
5 * Module name: Extended Prefix/Link Opaque LSA
7 * Author: Olivier Dugeon <olivier.dugeon@orange.com>
8 * Author: Anselme Sawadogo <anselmesawadogo@gmail.com>
10 * Copyright (C) 2016 - 2018 Orange Labs http://www.orange.com
12 * This program is free software; you can redistribute it and/or modify it
13 * under the terms of the GNU General Public License as published by the Free
14 * Software Foundation; either version 2 of the License, or (at your option)
17 * This program is distributed in the hope that it will be useful, but WITHOUT
18 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
19 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
22 * You should have received a copy of the GNU General Public License along
23 * with this program; see the file COPYING; if not, write to the Free Software
24 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
43 #include "sockunion.h" /* for inet_aton() */
46 #include "libospf.h" /* for ospf interface types */
48 #include "ospfd/ospfd.h"
49 #include "ospfd/ospf_interface.h"
50 #include "ospfd/ospf_ism.h"
51 #include "ospfd/ospf_asbr.h"
52 #include "ospfd/ospf_lsa.h"
53 #include "ospfd/ospf_lsdb.h"
54 #include "ospfd/ospf_neighbor.h"
55 #include "ospfd/ospf_nsm.h"
56 #include "ospfd/ospf_flood.h"
57 #include "ospfd/ospf_packet.h"
58 #include "ospfd/ospf_spf.h"
59 #include "ospfd/ospf_dump.h"
60 #include "ospfd/ospf_route.h"
61 #include "ospfd/ospf_ase.h"
62 #include "ospfd/ospf_zebra.h"
63 #include "ospfd/ospf_sr.h"
64 #include "ospfd/ospf_ext.h"
66 /* Following structure are internal use only. */
69 * Global variable to manage Extended Prefix/Link Opaque LSA on this node.
70 * Note that all parameter values are stored in network byte order.
72 static struct ospf_ext_lp OspfEXT
;
75 * -----------------------------------------------------------------------
76 * Followings are initialize/terminate functions for Extended Prefix/Link
77 * Opaque LSA handling.
78 * -----------------------------------------------------------------------
81 /* Extended Prefix Opaque LSA related callback functions */
82 static void ospf_ext_pref_ism_change(struct ospf_interface
*oi
, int old_status
);
83 static void ospf_ext_pref_show_info(struct vty
*vty
, struct ospf_lsa
*lsa
);
84 static int ospf_ext_pref_lsa_originate(void *arg
);
85 static struct ospf_lsa
*ospf_ext_pref_lsa_refresh(struct ospf_lsa
*lsa
);
86 static void ospf_ext_pref_lsa_schedule(struct ext_itf
*exti
,
87 enum lsa_opcode opcode
);
88 /* Extended Link Opaque LSA related callback functions */
89 static int ospf_ext_link_new_if(struct interface
*ifp
);
90 static int ospf_ext_link_del_if(struct interface
*ifp
);
91 static void ospf_ext_link_ism_change(struct ospf_interface
*oi
, int old_status
);
92 static void ospf_ext_link_nsm_change(struct ospf_neighbor
*nbr
, int old_status
);
93 static void ospf_ext_link_show_info(struct vty
*vty
, struct ospf_lsa
*lsa
);
94 static int ospf_ext_link_lsa_originate(void *arg
);
95 static struct ospf_lsa
*ospf_ext_link_lsa_refresh(struct ospf_lsa
*lsa
);
96 static void ospf_ext_link_lsa_schedule(struct ext_itf
*exti
,
97 enum lsa_opcode opcode
);
98 static void ospf_ext_lsa_schedule(struct ext_itf
*exti
, enum lsa_opcode op
);
99 static int ospf_ext_link_lsa_update(struct ospf_lsa
*lsa
);
100 static int ospf_ext_pref_lsa_update(struct ospf_lsa
*lsa
);
101 static void del_ext_info(void *val
);
104 * Extended Link/Prefix initialization
108 * @return - 0 if OK, <> 0 otherwise
110 int ospf_ext_init(void)
114 memset(&OspfEXT
, 0, sizeof(struct ospf_ext_lp
));
115 OspfEXT
.enabled
= false;
116 /* Only Area flooding is supported yet */
117 OspfEXT
.scope
= OSPF_OPAQUE_AREA_LSA
;
118 /* Initialize interface list */
119 OspfEXT
.iflist
= list_new();
120 OspfEXT
.iflist
->del
= del_ext_info
;
122 zlog_info("EXT (%s): Register Extended Link Opaque LSA", __func__
);
123 rc
= ospf_register_opaque_functab(
124 OSPF_OPAQUE_AREA_LSA
, OPAQUE_TYPE_EXTENDED_LINK_LSA
,
125 ospf_ext_link_new_if
, /* new if */
126 ospf_ext_link_del_if
, /* del if */
127 ospf_ext_link_ism_change
, /* ism change */
128 ospf_ext_link_nsm_change
, /* nsm change */
129 NULL
, /* Write router config. */
130 NULL
, /* Write interface conf. */
131 NULL
, /* Write debug config. */
132 ospf_ext_link_show_info
, /* Show LSA info */
133 ospf_ext_link_lsa_originate
, /* Originate LSA */
134 ospf_ext_link_lsa_refresh
, /* Refresh LSA */
135 ospf_ext_link_lsa_update
, /* new_lsa_hook */
136 NULL
); /* del_lsa_hook */
139 zlog_warn("EXT (%s): Failed to register Extended Link LSA",
144 zlog_info("EXT (%s): Register Extended Prefix Opaque LSA", __func__
);
145 rc
= ospf_register_opaque_functab(
146 OspfEXT
.scope
, OPAQUE_TYPE_EXTENDED_PREFIX_LSA
,
147 NULL
, /* new if handle by link */
148 NULL
, /* del if handle by link */
149 ospf_ext_pref_ism_change
, /* ism change */
150 NULL
, /* nsm change */
151 ospf_sr_config_write_router
, /* Write router config. */
152 NULL
, /* Write interface conf. */
153 NULL
, /* Write debug config. */
154 ospf_ext_pref_show_info
, /* Show LSA info */
155 ospf_ext_pref_lsa_originate
, /* Originate LSA */
156 ospf_ext_pref_lsa_refresh
, /* Refresh LSA */
157 ospf_ext_pref_lsa_update
, /* new_lsa_hook */
158 NULL
); /* del_lsa_hook */
160 zlog_warn("EXT (%s): Failed to register Extended Prefix LSA",
169 * Extended Link/Prefix termination function
174 void ospf_ext_term(void)
177 if ((OspfEXT
.scope
!= OSPF_OPAQUE_AREA_LSA
)
178 && (OspfEXT
.scope
!= OSPF_OPAQUE_AS_LSA
))
180 "EXT: Unable to unregister Extended Prefix "
181 "Opaque LSA functions: Wrong scope!");
183 ospf_delete_opaque_functab(OspfEXT
.scope
,
184 OPAQUE_TYPE_EXTENDED_PREFIX_LSA
);
186 ospf_delete_opaque_functab(OSPF_OPAQUE_AREA_LSA
,
187 OPAQUE_TYPE_EXTENDED_LINK_LSA
);
189 list_delete_and_null(&OspfEXT
.iflist
);
191 OspfEXT
.enabled
= false;
197 * Extended Link/Prefix finish function
202 void ospf_ext_finish(void)
204 // list_delete_all_node(OspfEXT.iflist);
205 OspfEXT
.enabled
= false;
209 * ---------------------------------------------------------------------
210 * Followings are control functions for Extended Prefix/Link Opaque LSA
211 * parameters management.
212 * ---------------------------------------------------------------------
215 /* Functions to free memory space */
216 static void del_ext_info(void *val
)
218 XFREE(MTYPE_OSPF_EXT_PARAMS
, val
);
221 /* Increment instance value for Extended Prefix Opaque LSAs Opaque ID field */
222 static uint32_t get_ext_pref_instance_value(void)
224 static uint32_t seqno
= 0;
226 if (seqno
< MAX_LEGAL_EXT_INSTANCE_NUM
)
229 seqno
= 1; /* Avoid zero. */
234 /* Increment instance value for Extended Link Opaque LSAs Opaque ID field */
235 static uint32_t get_ext_link_instance_value(void)
237 static uint32_t seqno
= 0;
239 if (seqno
< MAX_LEGAL_EXT_INSTANCE_NUM
)
242 seqno
= 1; /* Avoid zero. */
247 /* Lookup Extended Prefix/Links by ifp from OspfEXT struct iflist */
248 static struct ext_itf
*lookup_ext_by_ifp(struct interface
*ifp
)
250 struct listnode
*node
, *nnode
;
251 struct ext_itf
*exti
;
253 for (ALL_LIST_ELEMENTS(OspfEXT
.iflist
, node
, nnode
, exti
))
254 if (exti
->ifp
== ifp
)
260 /* Lookup Extended Prefix/Links by LSA ID from OspfEXT struct iflist */
261 static struct ext_itf
*lookup_ext_by_instance(struct ospf_lsa
*lsa
)
263 struct listnode
*node
;
264 struct ext_itf
*exti
;
265 uint32_t key
= GET_OPAQUE_ID(ntohl(lsa
->data
->id
.s_addr
));
266 uint8_t type
= GET_OPAQUE_TYPE(ntohl(lsa
->data
->id
.s_addr
));
269 for (ALL_LIST_ELEMENTS_RO(OspfEXT
.iflist
, node
, exti
))
270 if ((exti
->instance
== key
) && (exti
->type
== type
))
277 * ----------------------------------------------------------------------
278 * The underlying subsection defines setters and unsetters to create and
279 * delete tlvs and subtlvs
280 * ----------------------------------------------------------------------
283 /* Extended Prefix TLV - RFC7684 section 2.1 */
284 static void set_ext_prefix(struct ext_itf
*exti
, uint8_t route_type
,
285 uint8_t flags
, struct prefix_ipv4 p
)
288 TLV_TYPE(exti
->prefix
) = htons(EXT_TLV_PREFIX
);
289 /* Warning: Size must be adjust depending of subTLV's */
290 TLV_LEN(exti
->prefix
) = htons(EXT_TLV_PREFIX_SIZE
);
291 exti
->prefix
.route_type
= route_type
;
292 exti
->prefix
.flags
= flags
;
293 /* Only Address Family Ipv4 (0) is defined in RFC 7684 */
295 exti
->prefix
.pref_length
= p
.prefixlen
;
296 exti
->prefix
.address
= p
.prefix
;
299 /* Extended Link TLV - RFC7684 section 3.1 */
300 static void set_ext_link(struct ext_itf
*exti
, uint8_t type
, struct in_addr id
,
304 TLV_TYPE(exti
->link
) = htons(EXT_TLV_LINK
);
305 /* Warning: Size must be adjust depending of subTLV's */
306 TLV_LEN(exti
->link
) = htons(EXT_TLV_LINK_SIZE
);
307 exti
->link
.link_type
= type
;
308 exti
->link
.link_id
= id
;
309 exti
->link
.link_data
= data
;
312 /* Prefix SID SubTLV - section 5 */
313 static void set_prefix_sid(struct ext_itf
*exti
, uint8_t algorithm
,
314 uint32_t value
, int value_type
, uint8_t flags
)
317 if ((algorithm
!= SR_ALGORITHM_SPF
)
318 && (algorithm
!= SR_ALGORITHM_STRICT_SPF
)) {
320 "EXT (%s): unrecognized algorithm, not SPF or S-SPF",
325 /* Update flags according to the type of value field: label or index */
326 if (value_type
== SID_LABEL
)
327 SET_FLAG(flags
, EXT_SUBTLV_PREFIX_SID_VFLG
);
329 /* set prefix sid subtlv for an extended prefix tlv */
330 TLV_TYPE(exti
->node_sid
) = htons(EXT_SUBTLV_PREFIX_SID
);
331 exti
->node_sid
.algorithm
= algorithm
;
332 exti
->node_sid
.flags
= flags
;
333 exti
->node_sid
.mtid
= 0; /* Multi-Topology is not supported */
335 /* Set Label or Index value */
336 if (value_type
== SID_LABEL
) {
337 TLV_LEN(exti
->node_sid
) =
338 htons(SID_LABEL_SIZE(EXT_SUBTLV_PREFIX_SID_SIZE
));
339 exti
->node_sid
.value
= htonl(SET_LABEL(value
));
341 TLV_LEN(exti
->node_sid
) =
342 htons(SID_INDEX_SIZE(EXT_SUBTLV_PREFIX_SID_SIZE
));
343 exti
->node_sid
.value
= htonl(value
);
348 /* Adjacency SID SubTLV - section 6.1 */
349 static void set_adj_sid(struct ext_itf
*exti
, bool backup
, uint32_t value
,
355 /* Determine which ADJ_SID must be set: nominal or backup */
357 flags
= EXT_SUBTLV_LINK_ADJ_SID_BFLG
;
365 TLV_TYPE(exti
->adj_sid
[index
]) = htons(EXT_SUBTLV_ADJ_SID
);
367 /* Only Local ADJ-SID is supported for the moment */
368 SET_FLAG(flags
, EXT_SUBTLV_LINK_ADJ_SID_LFLG
);
370 exti
->adj_sid
[index
].mtid
= 0; /* Multi-Topology is not supported */
372 /* Adjust Length, Flags and Value depending on the type of Label */
373 if (value_type
== SID_LABEL
) {
374 SET_FLAG(flags
, EXT_SUBTLV_LINK_ADJ_SID_VFLG
);
375 TLV_LEN(exti
->adj_sid
[index
]) =
376 htons(SID_LABEL_SIZE(EXT_SUBTLV_ADJ_SID_SIZE
));
377 exti
->adj_sid
[index
].value
= htonl(SET_LABEL(value
));
379 UNSET_FLAG(flags
, EXT_SUBTLV_LINK_ADJ_SID_VFLG
);
380 TLV_LEN(exti
->adj_sid
[index
]) =
381 htons(SID_INDEX_SIZE(EXT_SUBTLV_ADJ_SID_SIZE
));
382 exti
->adj_sid
[index
].value
= htonl(value
);
385 exti
->adj_sid
[index
].flags
= flags
; /* Set computed flags */
386 exti
->adj_sid
[index
].mtid
= 0; /* Multi-Topology is not supported */
387 exti
->adj_sid
[index
].weight
= 0; /* Load-Balancing is not supported */
391 /* LAN Adjacency SID SubTLV - section 6.2 */
392 static void set_lan_adj_sid(struct ext_itf
*exti
, bool backup
, uint32_t value
,
393 int value_type
, struct in_addr neighbor_id
)
399 /* Determine which ADJ_SID must be set: nominal or backup */
401 flags
= EXT_SUBTLV_LINK_ADJ_SID_BFLG
;
409 TLV_TYPE(exti
->lan_sid
[index
]) = htons(EXT_SUBTLV_LAN_ADJ_SID
);
411 /* Only Local ADJ-SID is supported for the moment */
412 SET_FLAG(flags
, EXT_SUBTLV_LINK_ADJ_SID_LFLG
);
414 /* Adjust Length, Flags and Value depending on the type of Label */
415 if (value_type
== SID_LABEL
) {
416 SET_FLAG(flags
, EXT_SUBTLV_LINK_ADJ_SID_VFLG
);
417 TLV_LEN(exti
->lan_sid
[index
]) =
418 htons(SID_LABEL_SIZE(EXT_SUBTLV_PREFIX_RANGE_SIZE
));
419 exti
->lan_sid
[index
].value
= htonl(SET_LABEL(value
));
421 UNSET_FLAG(flags
, EXT_SUBTLV_LINK_ADJ_SID_VFLG
);
422 TLV_LEN(exti
->lan_sid
[index
]) =
423 htons(SID_INDEX_SIZE(EXT_SUBTLV_PREFIX_RANGE_SIZE
));
424 exti
->lan_sid
[index
].value
= htonl(value
);
427 exti
->lan_sid
[index
].flags
= flags
; /* Set computed flags */
428 exti
->lan_sid
[index
].mtid
= 0; /* Multi-Topology is not supported */
429 exti
->lan_sid
[index
].weight
= 0; /* Load-Balancing is not supported */
430 exti
->lan_sid
[index
].neighbor_id
= neighbor_id
;
434 /* Experimental SubTLV from Cisco */
435 static void set_rmt_itf_addr(struct ext_itf
*exti
, struct in_addr rmtif
)
438 TLV_TYPE(exti
->rmt_itf_addr
) = htons(EXT_SUBTLV_RMT_ITF_ADDR
);
439 TLV_LEN(exti
->rmt_itf_addr
) = htons(sizeof(struct in_addr
));
440 exti
->rmt_itf_addr
.value
= rmtif
;
445 * Update Extended prefix SID index for Loopback interface type
447 * @param ifname - Loopback interface name
448 * @param index - new value for the prefix SID of this interface
449 * @param p - prefix for this interface or NULL if Extended Prefix
452 * @return instance number if update is OK, 0 otherwise
454 uint32_t ospf_ext_schedule_prefix_index(struct interface
*ifp
, uint32_t index
,
455 struct prefix_ipv4
*p
, uint8_t flags
)
458 struct ext_itf
*exti
;
460 /* Find Extended Prefix interface */
461 exti
= lookup_ext_by_ifp(ifp
);
466 if (IS_DEBUG_OSPF_SR
)
468 "EXT (%s): Schedule new prefix %s/%u with "
469 "index %u on interface %s",
470 __func__
, inet_ntoa(p
->prefix
), p
->prefixlen
,
473 /* Set first Extended Prefix then the Prefix SID information */
474 set_ext_prefix(exti
, OSPF_PATH_INTRA_AREA
, EXT_TLV_PREF_NFLG
,
476 set_prefix_sid(exti
, SR_ALGORITHM_SPF
, index
, SID_INDEX
, flags
);
478 /* Try to Schedule LSA */
479 SET_FLAG(exti
->flags
, EXT_LPFLG_LSA_ACTIVE
);
480 if (CHECK_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
))
481 ospf_ext_pref_lsa_schedule(exti
, REFRESH_THIS_LSA
);
483 ospf_ext_pref_lsa_schedule(exti
, REORIGINATE_THIS_LSA
);
485 if (IS_DEBUG_OSPF_SR
)
487 "EXT (%s): Remove prefix for interface %s",
488 __func__
, ifp
->name
);
490 if (CHECK_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
)) {
491 ospf_ext_pref_lsa_schedule(exti
, FLUSH_THIS_LSA
);
492 UNSET_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
);
493 UNSET_FLAG(exti
->flags
, EXT_LPFLG_LSA_ACTIVE
);
497 return SET_OPAQUE_LSID(exti
->type
, exti
->instance
);
501 * Used by Segment Routing to activate/deactivate Extended Link/Prefix flooding
503 * @param enable To activate or not Segment Routing Extended LSA flooding
507 void ospf_ext_update_sr(bool enable
)
509 struct listnode
*node
;
510 struct ext_itf
*exti
;
512 if (IS_DEBUG_OSPF_SR
)
514 "EXT (%s): %s Extended LSAs for Segment Routing ",
515 __func__
, enable
? "Enable" : "Disable");
518 OspfEXT
.enabled
= true;
519 /* Refresh LSAs if already engaged or originate */
520 for (ALL_LIST_ELEMENTS_RO(OspfEXT
.iflist
, node
, exti
))
521 if (CHECK_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
))
522 ospf_ext_lsa_schedule(exti
, REFRESH_THIS_LSA
);
524 ospf_ext_lsa_schedule(exti
,
525 REORIGINATE_THIS_LSA
);
527 /* Start by Flushing engaged LSAs */
528 for (ALL_LIST_ELEMENTS_RO(OspfEXT
.iflist
, node
, exti
))
529 if (CHECK_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
))
530 ospf_ext_lsa_schedule(exti
, FLUSH_THIS_LSA
);
531 /* And then disable Extended Link/Prefix */
532 OspfEXT
.enabled
= false;
536 * -----------------------------------------------------------------------
537 * Followings are callback functions against generic Opaque-LSAs handling
538 * -----------------------------------------------------------------------
541 /* Add new Interface in Extended Interface List */
542 static int ospf_ext_link_new_if(struct interface
*ifp
)
547 if (lookup_ext_by_ifp(ifp
) != NULL
) {
549 "EXT (%s): interface %s is already in use",
550 __func__
, ifp
? ifp
->name
: "-");
551 rc
= 0; /* Do nothing here. */
555 new = XCALLOC(MTYPE_OSPF_EXT_PARAMS
, sizeof(struct ext_itf
));
557 zlog_warn("EXT (%s): XCALLOC: %s", __func__
,
558 safe_strerror(errno
));
562 /* initialize new information and link back the interface */
564 new->flags
= EXT_LPFLG_LSA_INACTIVE
;
566 listnode_add(OspfEXT
.iflist
, new);
572 /* Remove existing Interface from Extended Interface List */
573 static int ospf_ext_link_del_if(struct interface
*ifp
)
575 struct ext_itf
*exti
;
578 exti
= lookup_ext_by_ifp(ifp
);
580 struct list
*iflist
= OspfEXT
.iflist
;
582 /* Dequeue listnode entry from the list. */
583 listnode_delete(iflist
, exti
);
585 XFREE(MTYPE_OSPF_EXT_PARAMS
, exti
);
590 "EXT (%s): interface %s is not found",
591 __func__
, ifp
? ifp
->name
: "-");
598 * Determine if an Interface belongs to an Extended Link Adjacency or LAN Adj.
599 * type and allocate new instance value accordingly
601 static void ospf_ext_link_ism_change(struct ospf_interface
*oi
, int old_status
)
603 struct ext_itf
*exti
;
605 /* Get interface information for Segment Routing */
606 exti
= lookup_ext_by_ifp(oi
->ifp
);
609 "EXT (%s): Cannot get Extended info. from OI(%s)",
610 __func__
, IF_NAME(oi
));
614 /* Determine if interface is related to Adjacency or LAN Adj. SID */
615 if (oi
->type
!= OSPF_IFTYPE_LOOPBACK
) {
616 if (oi
->state
== ISM_DR
)
617 exti
->stype
= LAN_ADJ_SID
;
619 exti
->stype
= ADJ_SID
;
621 exti
->instance
= get_ext_link_instance_value();
622 exti
->type
= OPAQUE_TYPE_EXTENDED_LINK_LSA
;
625 "EXT (%s): Set %s SID to interface %s ", __func__
,
626 exti
->stype
== ADJ_SID
? "Adj." : "LAN Adj.",
632 * Determine if an Interface belongs to an Extended Prefix and
633 * allocate new instance value accordingly
635 static void ospf_ext_pref_ism_change(struct ospf_interface
*oi
, int old_status
)
637 struct ext_itf
*exti
;
639 /* Get interface information for Segment Routing */
640 exti
= lookup_ext_by_ifp(oi
->ifp
);
643 "EXT (%s): Cannot get Extended info. from OI(%s)",
644 __func__
, IF_NAME(oi
));
648 /* Determine if interface is related to a Node SID */
649 if (oi
->type
== OSPF_IFTYPE_LOOPBACK
) {
650 exti
->stype
= PREF_SID
;
651 exti
->instance
= get_ext_pref_instance_value();
652 exti
->type
= OPAQUE_TYPE_EXTENDED_PREFIX_LSA
;
655 "EXT (%s): Set Node SID to interface %s ", __func__
,
658 /* Complete SRDB if the interface belongs to a Prefix */
660 ospf_sr_update_prefix(oi
->ifp
, oi
->address
);
665 * Finish Extended Link configuration and flood corresponding LSA
666 * when OSPF adjacency on this link fire up
668 static void ospf_ext_link_nsm_change(struct ospf_neighbor
*nbr
, int old_status
)
670 struct ospf_interface
*oi
= nbr
->oi
;
671 struct ext_itf
*exti
;
674 /* Process Neighbor only when its state is NSM Full */
675 if (nbr
->state
!= NSM_Full
)
678 /* Get interface information for Segment Routing */
679 exti
= lookup_ext_by_ifp(oi
->ifp
);
682 "EXT (%s): Cannot get Extended info. from OI(%s)",
683 __func__
, IF_NAME(oi
));
687 if (oi
->area
== NULL
|| oi
->area
->ospf
== NULL
) {
689 "EXT (%s): Cannot refer to OSPF from OI(%s)",
690 __func__
, IF_NAME(oi
));
694 /* Keep Area information in combination with SR info. */
695 exti
->area
= oi
->area
;
696 OspfEXT
.area
= oi
->area
;
698 /* Process only Adjacency/LAN SID */
699 if (exti
->stype
== PREF_SID
)
703 case ISM_PointToPoint
:
704 /* Segment ID is an Adjacency one */
705 exti
->stype
= ADJ_SID
;
707 /* Set Extended Link TLV with link_id == Nbr Router ID */
708 set_ext_link(exti
, OSPF_IFTYPE_POINTOPOINT
, nbr
->router_id
,
709 oi
->address
->u
.prefix4
);
711 /* Set Extended Link Adjacency SubTLVs, backup first */
712 label
= get_ext_link_label_value();
713 set_adj_sid(exti
, true, label
, SID_LABEL
);
714 label
= get_ext_link_label_value();
715 set_adj_sid(exti
, false, label
, SID_LABEL
);
716 /* And Remote Interface address */
717 set_rmt_itf_addr(exti
, nbr
->address
.u
.prefix4
);
722 /* Segment ID is a LAN Adjacency for the DR only */
723 exti
->stype
= LAN_ADJ_SID
;
725 /* Set Extended Link TLV with link_id == DR */
726 set_ext_link(exti
, OSPF_IFTYPE_BROADCAST
, DR(oi
),
727 oi
->address
->u
.prefix4
);
729 /* Set Extended Link Adjacency SubTLVs, backup first */
730 label
= get_ext_link_label_value();
731 set_lan_adj_sid(exti
, true, label
, SID_LABEL
, nbr
->router_id
);
732 label
= get_ext_link_label_value();
733 set_lan_adj_sid(exti
, false, label
, SID_LABEL
, nbr
->router_id
);
739 /* Segment ID is an Adjacency if not the DR */
740 exti
->stype
= ADJ_SID
;
742 /* Set Extended Link TLV with link_id == DR */
743 set_ext_link(exti
, OSPF_IFTYPE_BROADCAST
, DR(oi
),
744 oi
->address
->u
.prefix4
);
746 /* Set Extended Link Adjacency SubTLVs, backup first */
747 label
= get_ext_link_label_value();
748 set_adj_sid(exti
, true, label
, SID_LABEL
);
749 label
= get_ext_link_label_value();
750 set_adj_sid(exti
, false, label
, SID_LABEL
);
755 if (CHECK_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
)) {
756 ospf_ext_link_lsa_schedule(exti
, FLUSH_THIS_LSA
);
757 UNSET_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
);
758 UNSET_FLAG(exti
->flags
, EXT_LPFLG_LSA_ACTIVE
);
763 if (IS_DEBUG_OSPF_SR
)
765 "EXT (%s): Complete %s SID to interface %s ", __func__
,
766 exti
->stype
== ADJ_SID
? "Adj." : "LAN Adj.",
769 /* flood this links params if everything is ok */
770 SET_FLAG(exti
->flags
, EXT_LPFLG_LSA_ACTIVE
);
771 if (OspfEXT
.enabled
) {
772 if (CHECK_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
))
773 ospf_ext_link_lsa_schedule(exti
, REFRESH_THIS_LSA
);
775 ospf_ext_link_lsa_schedule(exti
, REORIGINATE_THIS_LSA
);
780 /* Callbacks to handle Extended Link Segment Routing LSA information */
781 static int ospf_ext_link_lsa_update(struct ospf_lsa
*lsa
)
785 zlog_warn("EXT (%s): Abort! LSA is NULL", __func__
);
789 /* Process only Opaque LSA */
790 if ((lsa
->data
->type
!= OSPF_OPAQUE_AREA_LSA
)
791 && (lsa
->data
->type
!= OSPF_OPAQUE_AS_LSA
))
794 /* Process only Extended Link LSA */
795 if (GET_OPAQUE_TYPE(ntohl(lsa
->data
->id
.s_addr
))
796 != OPAQUE_TYPE_EXTENDED_LINK_LSA
)
799 /* Check if Extended is enable */
800 if (!OspfEXT
.enabled
)
803 /* Call Segment Routing LSA update or deletion */
804 if (!IS_LSA_MAXAGE(lsa
))
805 ospf_sr_ext_link_lsa_update(lsa
);
807 ospf_sr_ext_link_lsa_delete(lsa
);
812 /* Callbacks to handle Extended Prefix Segment Routing LSA information */
813 static int ospf_ext_pref_lsa_update(struct ospf_lsa
*lsa
)
818 zlog_warn("EXT (%s): Abort! LSA is NULL", __func__
);
822 /* Process only Opaque LSA */
823 if ((lsa
->data
->type
!= OSPF_OPAQUE_AREA_LSA
)
824 && (lsa
->data
->type
!= OSPF_OPAQUE_AS_LSA
))
827 /* Process only Extended Prefix LSA */
828 if (GET_OPAQUE_TYPE(ntohl(lsa
->data
->id
.s_addr
))
829 != OPAQUE_TYPE_EXTENDED_PREFIX_LSA
)
832 /* Check if it is not my LSA */
833 if (IS_LSA_SELF(lsa
))
836 /* Check if Extended is enable */
837 if (!OspfEXT
.enabled
)
840 /* Call Segment Routing LSA update or deletion */
841 if (!IS_LSA_MAXAGE(lsa
))
842 ospf_sr_ext_prefix_lsa_update(lsa
);
844 ospf_sr_ext_prefix_lsa_delete(lsa
);
850 * -------------------------------------------------------
851 * Followings are OSPF protocol processing functions for
852 * Extended Prefix/Link Opaque LSA
853 * -------------------------------------------------------
856 static void build_tlv_header(struct stream
*s
, struct tlv_header
*tlvh
)
858 stream_put(s
, tlvh
, sizeof(struct tlv_header
));
862 static void build_tlv(struct stream
*s
, struct tlv_header
*tlvh
)
865 if ((tlvh
!= NULL
) && (ntohs(tlvh
->type
) != 0)) {
866 build_tlv_header(s
, tlvh
);
867 stream_put(s
, TLV_DATA(tlvh
), TLV_BODY_SIZE(tlvh
));
872 /* Build an Extended Prefix Opaque LSA body for extended prefix TLV */
873 static void ospf_ext_pref_lsa_body_set(struct stream
*s
, struct ext_itf
*exti
)
877 if ((exti
== NULL
) || (exti
->stype
!= PREF_SID
))
880 /* Adjust Extended Prefix TLV size */
881 TLV_LEN(exti
->prefix
) =
882 htons(ntohs(TLV_LEN(exti
->node_sid
)) + EXT_TLV_PREFIX_SIZE
885 /* Build LSA body for an Extended Prefix TLV */
886 build_tlv_header(s
, &exti
->prefix
.header
);
887 stream_put(s
, TLV_DATA(&exti
->prefix
.header
), EXT_TLV_PREFIX_SIZE
);
888 /* Then add Prefix SID SubTLV */
889 build_tlv(s
, &exti
->node_sid
.header
);
893 /* Build an Extended Link Opaque LSA body for extended link TLV */
894 static void ospf_ext_link_lsa_body_set(struct stream
*s
, struct ext_itf
*exti
)
900 || ((exti
->stype
!= ADJ_SID
) && (exti
->stype
!= LAN_ADJ_SID
)))
903 if (exti
->stype
== ADJ_SID
) {
904 /* Adjust Extended Link TLV size for Adj. SID */
905 size
= EXT_TLV_LINK_SIZE
+ 2 * EXT_SUBTLV_ADJ_SID_SIZE
907 if (ntohs(TLV_TYPE(exti
->rmt_itf_addr
)) != 0)
908 size
= size
+ EXT_SUBTLV_RMT_ITF_ADDR_SIZE
910 TLV_LEN(exti
->link
) = htons(size
);
912 /* Build LSA body for an Extended Link TLV with Adj. SID */
913 build_tlv_header(s
, &exti
->link
.header
);
914 stream_put(s
, TLV_DATA(&exti
->link
.header
), EXT_TLV_LINK_SIZE
);
915 /* then add Adjacency SubTLVs */
916 build_tlv(s
, &exti
->adj_sid
[1].header
);
917 build_tlv(s
, &exti
->adj_sid
[0].header
);
919 /* Add Cisco experimental SubTLV if interface is PtoP */
920 if (ntohs(TLV_TYPE(exti
->rmt_itf_addr
)) != 0)
921 build_tlv(s
, &exti
->rmt_itf_addr
.header
);
923 /* Adjust Extended Link TLV size for LAN SID */
924 size
= EXT_TLV_LINK_SIZE
925 + 2 * (EXT_SUBTLV_LAN_ADJ_SID_SIZE
+ TLV_HDR_SIZE
);
926 TLV_LEN(exti
->link
) = htons(size
);
928 /* Build LSA body for an Extended Link TLV with LAN SID */
929 build_tlv_header(s
, &exti
->link
.header
);
930 stream_put(s
, TLV_DATA(&exti
->link
.header
), EXT_TLV_LINK_SIZE
);
931 /* then add LAN-Adjacency SubTLVs */
932 build_tlv(s
, &exti
->lan_sid
[1].header
);
933 build_tlv(s
, &exti
->lan_sid
[0].header
);
938 /* Create new Extended Prefix opaque-LSA for every extended prefix */
939 static struct ospf_lsa
*ospf_ext_pref_lsa_new(struct ospf_area
*area
,
940 struct ext_itf
*exti
)
943 struct lsa_header
*lsah
;
944 struct ospf_lsa
*new = NULL
;
946 u_char options
, lsa_type
;
947 struct in_addr lsa_id
;
948 struct in_addr router_id
;
956 /* Create a stream for LSA. */
957 s
= stream_new(OSPF_MAX_LSA_SIZE
);
959 zlog_warn("EXT (%s): stream_new() error", __func__
);
963 /* Prepare LSA Header */
964 lsah
= (struct lsa_header
*)STREAM_DATA(s
);
966 lsa_type
= OspfEXT
.scope
;
969 * LSA ID is a variable number identifying different instances of
970 * Extended Prefix Opaque LSA from the same router see RFC 7684
972 tmp
= SET_OPAQUE_LSID(OPAQUE_TYPE_EXTENDED_PREFIX_LSA
, exti
->instance
);
973 lsa_id
.s_addr
= htonl(tmp
);
975 options
= OSPF_OPTION_O
; /* Don't forget this :-) */
977 /* Fix Options and Router ID depending of the flooding scope */
978 if ((OspfEXT
.scope
== OSPF_OPAQUE_AS_LSA
) || (area
== NULL
)) {
979 options
= OSPF_OPTION_E
;
980 top
= ospf_lookup_by_vrf_id(VRF_DEFAULT
);
981 router_id
.s_addr
= top
? top
->router_id
.s_addr
: 0;
983 options
|= LSA_OPTIONS_GET(area
); /* Get area default option */
984 options
|= LSA_OPTIONS_NSSA_GET(area
);
985 router_id
= area
->ospf
->router_id
;
988 /* Set opaque-LSA header fields. */
989 lsa_header_set(s
, options
, lsa_type
, lsa_id
, router_id
);
991 if (IS_DEBUG_OSPF(lsa
, LSA_GENERATE
))
993 "EXT (%s): LSA[Type%u:%s]: Create an Opaque-LSA "
994 "Extended Prefix Opaque LSA instance",
995 __func__
, lsa_type
, inet_ntoa(lsa_id
));
998 /* Set opaque-LSA body fields. */
999 ospf_ext_pref_lsa_body_set(s
, exti
);
1002 length
= stream_get_endp(s
);
1003 lsah
->length
= htons(length
);
1005 /* Now, create an OSPF LSA instance. */
1006 new = ospf_lsa_new();
1008 zlog_warn("EXT (%s): ospf_lsa_new() error", __func__
);
1012 new->data
= ospf_lsa_data_new(length
);
1013 if (new->data
== NULL
) {
1014 zlog_warn("EXT (%s): ospf_lsa_data_new() error", __func__
);
1015 ospf_lsa_unlock(&new);
1021 /* Segment Routing belongs only to default VRF */
1022 new->vrf_id
= VRF_DEFAULT
;
1024 SET_FLAG(new->flags
, OSPF_LSA_SELF
);
1025 memcpy(new->data
, lsah
, length
);
1031 /* Create new Extended Link opaque-LSA for every extended link TLV */
1032 static struct ospf_lsa
*ospf_ext_link_lsa_new(struct ospf_area
*area
,
1033 struct ext_itf
*exti
)
1036 struct lsa_header
*lsah
;
1037 struct ospf_lsa
*new = NULL
;
1038 u_char options
, lsa_type
;
1039 struct in_addr lsa_id
;
1047 /* Create a stream for LSA. */
1048 s
= stream_new(OSPF_MAX_LSA_SIZE
);
1050 zlog_warn("EXT (%s): stream_new() error", __func__
);
1053 lsah
= (struct lsa_header
*)STREAM_DATA(s
);
1055 options
= OSPF_OPTION_O
; /* Don't forget this :-) */
1056 options
|= LSA_OPTIONS_GET(area
); /* Get area default option */
1057 options
|= LSA_OPTIONS_NSSA_GET(area
);
1058 /* Extended Link Opaque LSA are only flooded within an area */
1059 lsa_type
= OSPF_OPAQUE_AREA_LSA
;
1062 * LSA ID is a variable number identifying different instances of
1063 * Extended Link Opaque LSA from the same router see RFC 7684
1065 tmp
= SET_OPAQUE_LSID(OPAQUE_TYPE_EXTENDED_LINK_LSA
, exti
->instance
);
1066 lsa_id
.s_addr
= htonl(tmp
);
1068 if (IS_DEBUG_OSPF(lsa
, LSA_GENERATE
))
1070 "EXT (%s) LSA[Type%u:%s]: Create an Opaque-LSA "
1071 "Extended Link Opaque LSA instance",
1072 __func__
, lsa_type
, inet_ntoa(lsa_id
));
1074 /* Set opaque-LSA header fields. */
1075 lsa_header_set(s
, options
, lsa_type
, lsa_id
, area
->ospf
->router_id
);
1077 /* Set opaque-LSA body fields. */
1078 ospf_ext_link_lsa_body_set(s
, exti
);
1081 length
= stream_get_endp(s
);
1082 lsah
->length
= htons(length
);
1084 /* Now, create an OSPF LSA instance. */
1085 new = ospf_lsa_new();
1087 zlog_warn("EXT (%s): ospf_lsa_new() error", __func__
);
1091 new->data
= ospf_lsa_data_new(length
);
1092 if (new->data
== NULL
) {
1093 zlog_warn("EXT (%s): ospf_lsa_data_new() error", __func__
);
1094 ospf_lsa_unlock(&new);
1100 /* Segment Routing belongs only to default VRF */
1101 new->vrf_id
= VRF_DEFAULT
;
1103 SET_FLAG(new->flags
, OSPF_LSA_SELF
);
1104 memcpy(new->data
, lsah
, length
);
1111 * Process the origination of an Extended Prefix Opaque LSA
1112 * for every extended prefix TLV
1114 static int ospf_ext_pref_lsa_originate1(struct ospf_area
*area
,
1115 struct ext_itf
*exti
)
1117 struct ospf_lsa
*new;
1121 /* Create new Opaque-LSA/Extended Prefix Opaque LSA instance. */
1122 new = ospf_ext_pref_lsa_new(area
, exti
);
1124 zlog_warn("EXT (%s): ospf_ext_pref_lsa_new() error", __func__
);
1128 /* Install this LSA into LSDB. */
1129 if (ospf_lsa_install(area
->ospf
, NULL
/*oi */, new) == NULL
) {
1130 zlog_warn("EXT (%s): ospf_lsa_install() error", __func__
);
1131 ospf_lsa_unlock(&new);
1135 /* Now this Extended Prefix Opaque LSA info parameter entry has
1138 SET_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
);
1140 /* Update new LSA origination count. */
1141 area
->ospf
->lsa_originate_count
++;
1143 /* Flood new LSA through area. */
1144 ospf_flood_through_area(area
, NULL
/*nbr */, new);
1146 if (IS_DEBUG_OSPF(lsa
, LSA_GENERATE
)) {
1147 char area_id
[INET_ADDRSTRLEN
];
1149 strncpy(area_id
, inet_ntoa(area
->area_id
), INET_ADDRSTRLEN
);
1151 "EXT (%s): LSA[Type%u:%s]: Originate Opaque-LSA "
1152 "Extended Prefix Opaque LSA: Area(%s), Link(%s)",
1153 __func__
, new->data
->type
, inet_ntoa(new->data
->id
),
1154 area_id
, exti
->ifp
->name
);
1155 ospf_lsa_header_dump(new->data
);
1164 * Process the origination of an Extended Link Opaque LSA
1165 * for every extended link TLV
1167 static int ospf_ext_link_lsa_originate1(struct ospf_area
*area
,
1168 struct ext_itf
*exti
)
1170 struct ospf_lsa
*new;
1173 /* Create new Opaque-LSA/Extended Link Opaque LSA instance. */
1174 new = ospf_ext_link_lsa_new(area
, exti
);
1176 zlog_warn("EXT (%s): ospf_ext_link_lsa_new() error", __func__
);
1180 /* Install this LSA into LSDB. */
1181 if (ospf_lsa_install(area
->ospf
, NULL
/*oi */, new) == NULL
) {
1182 zlog_warn("EXT (%s): ospf_lsa_install() error", __func__
);
1183 ospf_lsa_unlock(&new);
1187 /* Now this link-parameter entry has associated LSA. */
1188 SET_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
);
1190 /* Update new LSA origination count. */
1191 area
->ospf
->lsa_originate_count
++;
1193 /* Flood new LSA through area. */
1194 ospf_flood_through_area(area
, NULL
/*nbr */, new);
1196 if (IS_DEBUG_OSPF(lsa
, LSA_GENERATE
)) {
1197 char area_id
[INET_ADDRSTRLEN
];
1199 strncpy(area_id
, inet_ntoa(area
->area_id
), INET_ADDRSTRLEN
);
1201 "EXT (%s): LSA[Type%u:%s]: Originate Opaque-LSA "
1202 "Extended Link Opaque LSA: Area(%s), Link(%s)",
1203 __func__
, new->data
->type
, inet_ntoa(new->data
->id
),
1204 area_id
, exti
->ifp
->name
);
1205 ospf_lsa_header_dump(new->data
);
1213 /* Trigger the origination of Extended Prefix Opaque LSAs */
1214 static int ospf_ext_pref_lsa_originate(void *arg
)
1216 struct ospf_area
*area
= (struct ospf_area
*)arg
;
1217 struct listnode
*node
;
1218 struct ext_itf
*exti
;
1221 if (!OspfEXT
.enabled
) {
1223 "EXT (%s): Segment Routing "
1224 "functionality is Disabled now", __func__
);
1225 rc
= 0; /* This is not an error case. */
1228 if (IS_DEBUG_OSPF_SR
)
1230 "EXT (%s): Start Originate Prefix LSA for area %s",
1231 __func__
, inet_ntoa(area
->area_id
));
1233 /* Check if Extended Prefix Opaque LSA is already engaged */
1234 for (ALL_LIST_ELEMENTS_RO(OspfEXT
.iflist
, node
, exti
)) {
1236 /* Process only Prefix SID */
1237 if (exti
->stype
!= PREF_SID
)
1240 /* Process only Extended Prefix with valid Area ID */
1241 if ((exti
->area
== NULL
)
1242 || (!IPV4_ADDR_SAME(&exti
->area
->area_id
, &area
->area_id
)))
1245 if (CHECK_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
)) {
1246 if (CHECK_FLAG(exti
->flags
,
1247 EXT_LPFLG_LSA_FORCED_REFRESH
)) {
1249 "EXT (%s): Refresh instead of "
1250 "Originate", __func__
);
1251 UNSET_FLAG(exti
->flags
,
1252 EXT_LPFLG_LSA_FORCED_REFRESH
);
1253 ospf_ext_pref_lsa_schedule(exti
,
1259 /* Ok, let's try to originate an LSA */
1260 if (IS_DEBUG_OSPF_SR
)
1262 "EXT (%s): Let's finally reoriginate the "
1263 "LSA 7.0.0.%u for Itf %s",
1264 __func__
, exti
->instance
,
1265 exti
->ifp
? exti
->ifp
->name
: "");
1266 ospf_ext_pref_lsa_originate1(area
, exti
);
1273 /* Trigger the origination of Extended Link Opaque LSAs */
1274 static int ospf_ext_link_lsa_originate(void *arg
)
1276 struct ospf_area
*area
= (struct ospf_area
*)arg
;
1277 struct listnode
*node
;
1278 struct ext_itf
*exti
;
1281 if (!OspfEXT
.enabled
) {
1283 "EXT (%s): Segment Routing "
1284 "functionality is Disabled now", __func__
);
1285 rc
= 0; /* This is not an error case. */
1289 /* Check if Extended Prefix Opaque LSA is already engaged */
1290 for (ALL_LIST_ELEMENTS_RO(OspfEXT
.iflist
, node
, exti
)) {
1291 /* Process only Adjacency or LAN SID */
1292 if (exti
->stype
== PREF_SID
)
1295 /* Process only Extended Link with valid Area ID */
1296 if ((exti
->area
== NULL
)
1297 || (!IPV4_ADDR_SAME(&exti
->area
->area_id
, &area
->area_id
)))
1300 /* Check if LSA not already engaged */
1301 if (CHECK_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
)) {
1302 if (CHECK_FLAG(exti
->flags
,
1303 EXT_LPFLG_LSA_FORCED_REFRESH
)) {
1305 "EXT (%s): Refresh instead of "
1306 "Originate", __func__
);
1307 UNSET_FLAG(exti
->flags
,
1308 EXT_LPFLG_LSA_FORCED_REFRESH
);
1309 ospf_ext_link_lsa_schedule(exti
,
1315 /* Ok, let's try to originate an LSA */
1316 if (IS_DEBUG_OSPF_SR
)
1318 "EXT (%s): Let's finally reoriginate the "
1319 "LSA 8.0.0.%u for Itf %s through the Area %s",
1320 __func__
, exti
->instance
,
1321 exti
->ifp
? exti
->ifp
->name
: "-",
1322 inet_ntoa(area
->area_id
));
1323 ospf_ext_link_lsa_originate1(area
, exti
);
1330 /* Refresh an Extended Prefix Opaque LSA */
1331 static struct ospf_lsa
*ospf_ext_pref_lsa_refresh(struct ospf_lsa
*lsa
)
1333 struct ospf_lsa
*new = NULL
;
1334 struct ospf_area
*area
= lsa
->area
;
1336 struct ext_itf
*exti
;
1338 if (!OspfEXT
.enabled
) {
1340 * This LSA must have flushed before due to Extended Prefix
1341 * Opaque LSA status change.
1342 * It seems a slip among routers in the routing domain.
1345 "EXT (%s): Segment Routing functionality is "
1346 "Disabled", __func__
);
1347 /* Flush it anyway. */
1348 lsa
->data
->ls_age
= htons(OSPF_LSA_MAXAGE
);
1351 /* Lookup this lsa corresponding Extended parameters */
1352 exti
= lookup_ext_by_instance(lsa
);
1354 zlog_warn("EXT (%s): Invalid parameter LSA ID", __func__
);
1355 /* Flush it anyway. */
1356 lsa
->data
->ls_age
= htons(OSPF_LSA_MAXAGE
);
1359 /* Check if Interface was not disable in the interval */
1360 if ((exti
!= NULL
) && !CHECK_FLAG(exti
->flags
, EXT_LPFLG_LSA_ACTIVE
)) {
1361 zlog_warn("EXT (%s): Interface was Disabled: Flush it!",
1363 /* Flush it anyway. */
1364 lsa
->data
->ls_age
= htons(OSPF_LSA_MAXAGE
);
1367 /* If the lsa's age reached to MaxAge, start flushing procedure. */
1368 if (IS_LSA_MAXAGE(lsa
)) {
1370 UNSET_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
);
1371 ospf_opaque_lsa_flush_schedule(lsa
);
1375 /* Create new Opaque-LSA/Extended Prefix Opaque LSA instance. */
1376 new = ospf_ext_pref_lsa_new(area
, exti
);
1379 zlog_warn("EXT (%s): ospf_ext_pref_lsa_new() error", __func__
);
1382 new->data
->ls_seqnum
= lsa_seqnum_increment(lsa
);
1385 * Install this LSA into LSDB
1386 * Given "lsa" will be freed in the next function
1387 * As area could be NULL i.e. when using OPAQUE_LSA_AS, we prefer to use
1388 * ospf_lookup() to get ospf instance
1393 top
= ospf_lookup_by_vrf_id(VRF_DEFAULT
);
1395 if (ospf_lsa_install(top
, NULL
/*oi */, new) == NULL
) {
1396 zlog_warn("EXT (%s): ospf_lsa_install() error", __func__
);
1397 ospf_lsa_unlock(&new);
1401 /* Flood updated LSA through the Prefix Area according to the RFC7684 */
1402 ospf_flood_through_area(area
, NULL
/*nbr */, new);
1404 /* Debug logging. */
1405 if (IS_DEBUG_OSPF(lsa
, LSA_GENERATE
)) {
1407 "EXT (%s): LSA[Type%u:%s] Refresh Extended Prefix LSA",
1408 __func__
, new->data
->type
, inet_ntoa(new->data
->id
));
1409 ospf_lsa_header_dump(new->data
);
1415 /* Refresh an Extended Link Opaque LSA */
1416 static struct ospf_lsa
*ospf_ext_link_lsa_refresh(struct ospf_lsa
*lsa
)
1418 struct ext_itf
*exti
;
1419 struct ospf_area
*area
= lsa
->area
;
1420 struct ospf
*top
= area
->ospf
;
1421 struct ospf_lsa
*new = NULL
;
1423 if (!OspfEXT
.enabled
) {
1425 * This LSA must have flushed before due to OSPF-SR status
1426 * change. It seems a slip among routers in the routing domain.
1429 "EXT (%s): Segment Routing functionality is Disabled",
1431 /* Flush it anyway. */
1432 lsa
->data
->ls_age
= htons(OSPF_LSA_MAXAGE
);
1435 /* Lookup this LSA corresponding Extended parameters */
1436 exti
= lookup_ext_by_instance(lsa
);
1438 zlog_warn("EXT (%s): Invalid parameter LSA ID", __func__
);
1439 /* Flush it anyway. */
1440 lsa
->data
->ls_age
= htons(OSPF_LSA_MAXAGE
);
1443 /* Check if Interface was not disable in the interval */
1444 if ((exti
!= NULL
) && !CHECK_FLAG(exti
->flags
, EXT_LPFLG_LSA_ACTIVE
)) {
1446 "EXT (%s): Interface was Disabled: Flush it!",
1448 lsa
->data
->ls_age
= htons(OSPF_LSA_MAXAGE
);
1451 /* If the lsa's age reached to MaxAge, start flushing procedure */
1452 if (IS_LSA_MAXAGE(lsa
)) {
1454 UNSET_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
);
1455 ospf_opaque_lsa_flush_schedule(lsa
);
1459 /* Create new Opaque-LSA/Extended Link instance */
1460 new = ospf_ext_link_lsa_new(area
, exti
);
1462 zlog_warn("EXT (%s): Error creating new LSA", __func__
);
1465 new->data
->ls_seqnum
= lsa_seqnum_increment(lsa
);
1467 /* Install this LSA into LSDB. */
1468 /* Given "lsa" will be freed in the next function */
1469 if (ospf_lsa_install(top
, NULL
/*oi */, new) == NULL
) {
1470 zlog_warn("EXT (%s): Error installing new LSA", __func__
);
1471 ospf_lsa_unlock(&new);
1475 /* Flood updated LSA through the link Area according to the RFC7684 */
1476 ospf_flood_through_area(area
, NULL
/*nbr */, new);
1478 /* Debug logging. */
1479 if (IS_DEBUG_OSPF(lsa
, LSA_GENERATE
)) {
1481 "EXT (%s): LSA[Type%u:%s]: Refresh Extended Link LSA",
1482 __func__
, new->data
->type
, inet_ntoa(new->data
->id
));
1483 ospf_lsa_header_dump(new->data
);
1489 /* Schedule Extended Prefix Opaque LSA origination/refreshment/flushing */
1490 static void ospf_ext_pref_lsa_schedule(struct ext_itf
*exti
,
1491 enum lsa_opcode opcode
)
1493 struct ospf_lsa lsa
;
1494 struct lsa_header lsah
;
1498 memset(&lsa
, 0, sizeof(lsa
));
1499 memset(&lsah
, 0, sizeof(lsah
));
1505 /* Check if the corresponding link is ready to be flooded */
1506 if (!(CHECK_FLAG(exti
->flags
, EXT_LPFLG_LSA_ACTIVE
)))
1510 "EXT (%s): Schedule %s%s%s LSA for interface %s", __func__
,
1511 opcode
== REORIGINATE_THIS_LSA
? "Re-Originate" : "",
1512 opcode
== REFRESH_THIS_LSA
? "Refresh" : "",
1513 opcode
== FLUSH_THIS_LSA
? "Flush" : "",
1514 exti
->ifp
? exti
->ifp
->name
: "-");
1516 /* Set LSA header information */
1517 if (exti
->area
== NULL
) {
1519 "EXT (%s): Flooding is Area scope but area is not yet "
1521 if (OspfEXT
.area
== NULL
) {
1522 top
= ospf_lookup_by_vrf_id(VRF_DEFAULT
);
1523 OspfEXT
.area
= ospf_area_lookup_by_area_id(
1524 top
, OspfEXT
.area_id
);
1526 exti
->area
= OspfEXT
.area
;
1528 lsa
.area
= exti
->area
;
1530 lsah
.type
= OSPF_OPAQUE_AREA_LSA
;
1531 tmp
= SET_OPAQUE_LSID(OPAQUE_TYPE_EXTENDED_PREFIX_LSA
, exti
->instance
);
1532 lsah
.id
.s_addr
= htonl(tmp
);
1535 case REORIGINATE_THIS_LSA
:
1536 ospf_opaque_lsa_reoriginate_schedule(
1537 (void *)exti
->area
, OSPF_OPAQUE_AREA_LSA
,
1538 OPAQUE_TYPE_EXTENDED_PREFIX_LSA
);
1540 case REFRESH_THIS_LSA
:
1541 ospf_opaque_lsa_refresh_schedule(&lsa
);
1543 case FLUSH_THIS_LSA
:
1544 UNSET_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
);
1545 ospf_opaque_lsa_flush_schedule(&lsa
);
1548 zlog_warn("EXT (%s): Unknown opcode", __func__
);
1554 /* Schedule Extended Link Opaque LSA origination/refreshment/flushing */
1555 static void ospf_ext_link_lsa_schedule(struct ext_itf
*exti
,
1556 enum lsa_opcode opcode
)
1558 struct ospf_lsa lsa
;
1559 struct lsa_header lsah
;
1563 memset(&lsa
, 0, sizeof(lsa
));
1564 memset(&lsah
, 0, sizeof(lsah
));
1570 /* Check if the corresponding link is ready to be flooded */
1571 if (!(CHECK_FLAG(exti
->flags
, EXT_LPFLG_LSA_ACTIVE
)))
1575 "EXT (%s): Schedule %s%s%s LSA for interface %s", __func__
,
1576 opcode
== REORIGINATE_THIS_LSA
? "Re-Originate" : "",
1577 opcode
== REFRESH_THIS_LSA
? "Refresh" : "",
1578 opcode
== FLUSH_THIS_LSA
? "Flush" : "",
1579 exti
->ifp
? exti
->ifp
->name
: "-");
1581 /* Set LSA header information */
1582 if (exti
->area
== NULL
) {
1584 "EXT (%s): Flooding is Area scope but area is not "
1585 "yet set", __func__
);
1586 if (OspfEXT
.area
== NULL
) {
1587 top
= ospf_lookup_by_vrf_id(VRF_DEFAULT
);
1588 OspfEXT
.area
= ospf_area_lookup_by_area_id(
1589 top
, OspfEXT
.area_id
);
1591 exti
->area
= OspfEXT
.area
;
1593 lsa
.area
= exti
->area
;
1595 lsah
.type
= OSPF_OPAQUE_AREA_LSA
;
1596 tmp
= SET_OPAQUE_LSID(OPAQUE_TYPE_EXTENDED_LINK_LSA
, exti
->instance
);
1597 lsah
.id
.s_addr
= htonl(tmp
);
1600 case REORIGINATE_THIS_LSA
:
1601 ospf_opaque_lsa_reoriginate_schedule(
1602 (void *)exti
->area
, OSPF_OPAQUE_AREA_LSA
,
1603 OPAQUE_TYPE_EXTENDED_LINK_LSA
);
1605 case REFRESH_THIS_LSA
:
1606 ospf_opaque_lsa_refresh_schedule(&lsa
);
1608 case FLUSH_THIS_LSA
:
1609 UNSET_FLAG(exti
->flags
, EXT_LPFLG_LSA_ENGAGED
);
1610 ospf_opaque_lsa_flush_schedule(&lsa
);
1613 zlog_warn("EXT (%s): Unknown opcode", __func__
);
1619 /* Schedule Extended Link or Prefix depending of the Type of LSA */
1620 static void ospf_ext_lsa_schedule(struct ext_itf
*exti
, enum lsa_opcode op
)
1623 if (exti
->stype
== PREF_SID
)
1624 ospf_ext_pref_lsa_schedule(exti
, op
);
1626 ospf_ext_link_lsa_schedule(exti
, op
);
1630 * ------------------------------------
1631 * Followings are vty show functions.
1632 * ------------------------------------
1635 /* Cisco experimental SubTLV */
1636 static uint16_t show_vty_ext_link_rmt_itf_addr(struct vty
*vty
,
1637 struct tlv_header
*tlvh
)
1639 struct ext_subtlv_rmt_itf_addr
*top
;
1641 top
= (struct ext_subtlv_rmt_itf_addr
*)tlvh
;
1644 " Remote Interface Address Sub-TLV: Length %u\n "
1646 ntohs(top
->header
.length
), inet_ntoa(top
->value
));
1648 return TLV_SIZE(tlvh
);
1651 /* Adjacency SID SubTLV */
1652 static uint16_t show_vty_ext_link_adj_sid(struct vty
*vty
,
1653 struct tlv_header
*tlvh
)
1655 struct ext_subtlv_adj_sid
*top
= (struct ext_subtlv_adj_sid
*)tlvh
;
1658 " Adj-SID Sub-TLV: Length %u\n\tFlags: "
1659 "0x%x\n\tMT-ID:0x%x\n\tWeight: 0x%x\n\t%s: %u\n",
1660 ntohs(top
->header
.length
), top
->flags
, top
->mtid
, top
->weight
,
1661 CHECK_FLAG(top
->flags
, EXT_SUBTLV_LINK_ADJ_SID_VFLG
) ? "Label"
1663 CHECK_FLAG(top
->flags
, EXT_SUBTLV_LINK_ADJ_SID_VFLG
)
1664 ? GET_LABEL(ntohl(top
->value
))
1665 : ntohl(top
->value
));
1667 return TLV_SIZE(tlvh
);
1670 /* LAN Adjacency SubTLV */
1671 static uint16_t show_vty_ext_link_lan_adj_sid(struct vty
*vty
,
1672 struct tlv_header
*tlvh
)
1674 struct ext_subtlv_lan_adj_sid
*top
=
1675 (struct ext_subtlv_lan_adj_sid
*)tlvh
;
1678 " LAN-Adj-SID Sub-TLV: Length %u\n\tFlags: "
1679 "0x%x\n\tMT-ID:0x%x\n\tWeight: 0x%x\n\tNeighbor ID: "
1681 ntohs(top
->header
.length
), top
->flags
, top
->mtid
, top
->weight
,
1682 inet_ntoa(top
->neighbor_id
),
1683 CHECK_FLAG(top
->flags
, EXT_SUBTLV_LINK_ADJ_SID_VFLG
) ? "Label"
1685 CHECK_FLAG(top
->flags
, EXT_SUBTLV_LINK_ADJ_SID_VFLG
)
1686 ? GET_LABEL(ntohl(top
->value
))
1687 : ntohl(top
->value
));
1689 return TLV_SIZE(tlvh
);
1692 static uint16_t show_vty_unknown_tlv(struct vty
*vty
, struct tlv_header
*tlvh
)
1694 vty_out(vty
, " Unknown TLV: [type(0x%x), length(0x%x)]\n",
1695 ntohs(tlvh
->type
), ntohs(tlvh
->length
));
1697 return TLV_SIZE(tlvh
);
1700 /* Extended Link Sub TLVs */
1701 static uint16_t show_vty_link_info(struct vty
*vty
, struct tlv_header
*ext
)
1703 struct ext_tlv_link
*top
= (struct ext_tlv_link
*)ext
;
1704 struct tlv_header
*tlvh
;
1705 uint16_t length
= ntohs(top
->header
.length
) - 3 * sizeof(uint32_t);
1709 " Extended Link TLV: Length %u\n Link Type: 0x%x\n"
1711 ntohs(top
->header
.length
), top
->link_type
,
1712 inet_ntoa(top
->link_id
));
1713 vty_out(vty
, " Link data: %s\n", inet_ntoa(top
->link_data
));
1715 tlvh
= (struct tlv_header
*)((char *)(ext
) + TLV_HDR_SIZE
1716 + EXT_TLV_LINK_SIZE
);
1717 for (; sum
< length
; tlvh
= TLV_HDR_NEXT(tlvh
)) {
1718 switch (ntohs(tlvh
->type
)) {
1719 case EXT_SUBTLV_ADJ_SID
:
1720 sum
+= show_vty_ext_link_adj_sid(vty
, tlvh
);
1722 case EXT_SUBTLV_LAN_ADJ_SID
:
1723 sum
+= show_vty_ext_link_lan_adj_sid(vty
, tlvh
);
1725 case EXT_SUBTLV_RMT_ITF_ADDR
:
1726 sum
+= show_vty_ext_link_rmt_itf_addr(vty
, tlvh
);
1729 sum
+= show_vty_unknown_tlv(vty
, tlvh
);
1734 return sum
+ sizeof(struct ext_tlv_link
);
1737 /* Extended Link TLVs */
1738 static void ospf_ext_link_show_info(struct vty
*vty
, struct ospf_lsa
*lsa
)
1740 struct lsa_header
*lsah
= (struct lsa_header
*)lsa
->data
;
1741 struct tlv_header
*tlvh
;
1742 uint16_t length
= 0, sum
= 0;
1744 /* Initialize TLV browsing */
1745 length
= ntohs(lsah
->length
) - OSPF_LSA_HEADER_SIZE
;
1747 for (tlvh
= TLV_HDR_TOP(lsah
); sum
< length
;
1748 tlvh
= TLV_HDR_NEXT(tlvh
)) {
1749 switch (ntohs(tlvh
->type
)) {
1751 sum
+= show_vty_link_info(vty
, tlvh
);
1754 sum
+= show_vty_unknown_tlv(vty
, tlvh
);
1761 /* Prefix SID SubTLV */
1762 static uint16_t show_vty_ext_pref_pref_sid(struct vty
*vty
,
1763 struct tlv_header
*tlvh
)
1765 struct ext_subtlv_prefix_sid
*top
=
1766 (struct ext_subtlv_prefix_sid
*)tlvh
;
1769 " Prefix SID Sub-TLV: Length %u\n\tAlgorithm: "
1770 "%u\n\tFlags: 0x%x\n\tMT-ID:0x%x\n\t%s: %u\n",
1771 ntohs(top
->header
.length
), top
->algorithm
, top
->flags
,
1773 CHECK_FLAG(top
->flags
, EXT_SUBTLV_PREFIX_SID_VFLG
) ? "Label"
1775 CHECK_FLAG(top
->flags
, EXT_SUBTLV_PREFIX_SID_VFLG
)
1776 ? GET_LABEL(ntohl(top
->value
))
1777 : ntohl(top
->value
));
1779 return TLV_SIZE(tlvh
);
1782 /* Extended Prefix SubTLVs */
1783 static uint16_t show_vty_pref_info(struct vty
*vty
, struct tlv_header
*ext
)
1785 struct ext_tlv_prefix
*top
= (struct ext_tlv_prefix
*)ext
;
1786 struct tlv_header
*tlvh
;
1787 uint16_t length
= ntohs(top
->header
.length
) - 2 * sizeof(uint32_t);
1791 " Extended Prefix TLV: Length %u\n\tRoute Type: %u\n"
1792 "\tAddress Family: 0x%x\n\tFlags: 0x%x\n\tAddress: %s/%u\n",
1793 ntohs(top
->header
.length
), top
->route_type
, top
->af
, top
->flags
,
1794 inet_ntoa(top
->address
), top
->pref_length
);
1796 tlvh
= (struct tlv_header
*)((char *)(ext
) + TLV_HDR_SIZE
1797 + EXT_TLV_PREFIX_SIZE
);
1798 for (; sum
< length
; tlvh
= TLV_HDR_NEXT(tlvh
)) {
1799 switch (ntohs(tlvh
->type
)) {
1800 case EXT_SUBTLV_PREFIX_SID
:
1801 sum
+= show_vty_ext_pref_pref_sid(vty
, tlvh
);
1804 sum
+= show_vty_unknown_tlv(vty
, tlvh
);
1809 return sum
+ sizeof(struct ext_tlv_prefix
);
1812 /* Extended Prefix TLVs */
1813 static void ospf_ext_pref_show_info(struct vty
*vty
, struct ospf_lsa
*lsa
)
1815 struct lsa_header
*lsah
= (struct lsa_header
*)lsa
->data
;
1816 struct tlv_header
*tlvh
;
1817 uint16_t length
= 0, sum
= 0;
1819 /* Initialize TLV browsing */
1820 length
= ntohs(lsah
->length
) - OSPF_LSA_HEADER_SIZE
;
1822 for (tlvh
= TLV_HDR_TOP(lsah
); sum
< length
;
1823 tlvh
= TLV_HDR_NEXT(tlvh
)) {
1824 switch (ntohs(tlvh
->type
)) {
1825 case EXT_TLV_PREFIX
:
1826 sum
+= show_vty_pref_info(vty
, tlvh
);
1829 sum
+= show_vty_unknown_tlv(vty
, tlvh
);