2 * This is an implementation of RFC3630
3 * Copyright (C) 2001 KDD R&D Laboratories, Inc.
4 * http://www.kddlabs.co.jp/
6 * Copyright (C) 2012 Orange Labs
7 * http://www.orange.com
9 * This file is part of GNU Zebra.
11 * GNU Zebra is free software; you can redistribute it and/or modify it
12 * under the terms of the GNU General Public License as published by the
13 * Free Software Foundation; either version 2, or (at your option) any
16 * GNU Zebra is distributed in the hope that it will be useful, but
17 * WITHOUT ANY WARRANTY; without even the implied warranty of
18 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
19 * General Public License for more details.
21 * You should have received a copy of the GNU General Public License along
22 * with this program; see the file COPYING; if not, write to the Free Software
23 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
26 /* Add support of RFC7471 */
27 /* Add support of RFC5392, RFC6827 */
44 #include "sockunion.h" /* for inet_aton() */
47 #include "ospfd/ospfd.h"
48 #include "ospfd/ospf_interface.h"
49 #include "ospfd/ospf_ism.h"
50 #include "ospfd/ospf_asbr.h"
51 #include "ospfd/ospf_lsa.h"
52 #include "ospfd/ospf_lsdb.h"
53 #include "ospfd/ospf_neighbor.h"
54 #include "ospfd/ospf_nsm.h"
55 #include "ospfd/ospf_flood.h"
56 #include "ospfd/ospf_packet.h"
57 #include "ospfd/ospf_spf.h"
58 #include "ospfd/ospf_dump.h"
59 #include "ospfd/ospf_route.h"
60 #include "ospfd/ospf_ase.h"
61 #include "ospfd/ospf_zebra.h"
62 #include "ospfd/ospf_te.h"
63 #include "ospfd/ospf_vty.h"
66 * Global variable to manage Opaque-LSA/MPLS-TE on this node.
67 * Note that all parameter values are stored in network byte order.
69 struct ospf_mpls_te OspfMplsTE
;
71 const char *mode2text
[] = {"Off", "AS", "Area"};
73 /*------------------------------------------------------------------------*
74 * Followings are initialize/terminate functions for MPLS-TE handling.
75 *------------------------------------------------------------------------*/
77 static int ospf_mpls_te_new_if(struct interface
*ifp
);
78 static int ospf_mpls_te_del_if(struct interface
*ifp
);
79 static void ospf_mpls_te_ism_change(struct ospf_interface
*oi
, int old_status
);
80 static void ospf_mpls_te_nsm_change(struct ospf_neighbor
*nbr
, int old_status
);
81 static void ospf_mpls_te_config_write_router(struct vty
*vty
);
82 static void ospf_mpls_te_show_info(struct vty
*vty
, struct ospf_lsa
*lsa
);
83 static int ospf_mpls_te_lsa_originate_area(void *arg
);
84 static int ospf_mpls_te_lsa_originate_as(void *arg
);
85 static struct ospf_lsa
*ospf_mpls_te_lsa_refresh(struct ospf_lsa
*lsa
);
87 static void del_mpls_te_link(void *val
);
88 static void ospf_mpls_te_register_vty(void);
90 int ospf_mpls_te_init(void)
94 rc
= ospf_register_opaque_functab(
95 OSPF_OPAQUE_AREA_LSA
, OPAQUE_TYPE_TRAFFIC_ENGINEERING_LSA
,
96 ospf_mpls_te_new_if
, ospf_mpls_te_del_if
,
97 ospf_mpls_te_ism_change
, ospf_mpls_te_nsm_change
,
98 ospf_mpls_te_config_write_router
,
99 NULL
, /*ospf_mpls_te_config_write_if */
100 NULL
, /* ospf_mpls_te_config_write_debug */
101 ospf_mpls_te_show_info
, ospf_mpls_te_lsa_originate_area
,
102 ospf_mpls_te_lsa_refresh
, NULL
, /* ospf_mpls_te_new_lsa_hook */
103 NULL
/* ospf_mpls_te_del_lsa_hook */);
106 "ospf_mpls_te_init: Failed to register Traffic Engineering functions");
110 memset(&OspfMplsTE
, 0, sizeof(struct ospf_mpls_te
));
111 OspfMplsTE
.enabled
= false;
112 OspfMplsTE
.inter_as
= Off
;
113 OspfMplsTE
.iflist
= list_new();
114 OspfMplsTE
.iflist
->del
= del_mpls_te_link
;
116 ospf_mpls_te_register_vty();
121 /* Additional register for RFC5392 support */
122 static int ospf_mpls_te_register(enum inter_as_mode mode
)
127 if (OspfMplsTE
.inter_as
!= Off
)
131 scope
= OSPF_OPAQUE_AS_LSA
;
133 scope
= OSPF_OPAQUE_AREA_LSA
;
135 rc
= ospf_register_opaque_functab(scope
, OPAQUE_TYPE_INTER_AS_LSA
, NULL
,
136 NULL
, NULL
, NULL
, NULL
, NULL
, NULL
,
137 ospf_mpls_te_show_info
,
138 ospf_mpls_te_lsa_originate_as
,
139 ospf_mpls_te_lsa_refresh
, NULL
, NULL
);
143 "ospf_router_info_init: Failed to register Inter-AS functions");
150 static int ospf_mpls_te_unregister()
154 if (OspfMplsTE
.inter_as
== Off
)
157 if (OspfMplsTE
.inter_as
== AS
)
158 scope
= OSPF_OPAQUE_AS_LSA
;
160 scope
= OSPF_OPAQUE_AREA_LSA
;
162 ospf_delete_opaque_functab(scope
, OPAQUE_TYPE_INTER_AS_LSA
);
167 void ospf_mpls_te_term(void)
169 list_delete_and_null(&OspfMplsTE
.iflist
);
171 ospf_delete_opaque_functab(OSPF_OPAQUE_AREA_LSA
,
172 OPAQUE_TYPE_TRAFFIC_ENGINEERING_LSA
);
174 OspfMplsTE
.enabled
= false;
176 ospf_mpls_te_unregister();
177 OspfMplsTE
.inter_as
= Off
;
182 void ospf_mpls_te_finish(void)
184 // list_delete_all_node(OspfMplsTE.iflist);
186 OspfMplsTE
.enabled
= false;
187 OspfMplsTE
.inter_as
= Off
;
190 /*------------------------------------------------------------------------*
191 * Followings are control functions for MPLS-TE parameters management.
192 *------------------------------------------------------------------------*/
194 static void del_mpls_te_link(void *val
)
196 XFREE(MTYPE_OSPF_MPLS_TE
, val
);
200 static u_int32_t
get_mpls_te_instance_value(void)
202 static u_int32_t seqno
= 0;
204 if (seqno
< MAX_LEGAL_TE_INSTANCE_NUM
)
207 seqno
= 1; /* Avoid zero. */
212 static struct mpls_te_link
*lookup_linkparams_by_ifp(struct interface
*ifp
)
214 struct listnode
*node
, *nnode
;
215 struct mpls_te_link
*lp
;
217 for (ALL_LIST_ELEMENTS(OspfMplsTE
.iflist
, node
, nnode
, lp
))
224 static struct mpls_te_link
*lookup_linkparams_by_instance(struct ospf_lsa
*lsa
)
226 struct listnode
*node
;
227 struct mpls_te_link
*lp
;
228 unsigned int key
= GET_OPAQUE_ID(ntohl(lsa
->data
->id
.s_addr
));
230 for (ALL_LIST_ELEMENTS_RO(OspfMplsTE
.iflist
, node
, lp
))
231 if (lp
->instance
== key
)
234 zlog_warn("lookup_linkparams_by_instance: Entry not found: key(%x)",
239 static void ospf_mpls_te_foreach_area(
240 void (*func
)(struct mpls_te_link
*lp
, enum lsa_opcode sched_opcode
),
241 enum lsa_opcode sched_opcode
)
243 struct listnode
*node
, *nnode
;
244 struct listnode
*node2
;
245 struct mpls_te_link
*lp
;
246 struct ospf_area
*area
;
248 for (ALL_LIST_ELEMENTS(OspfMplsTE
.iflist
, node
, nnode
, lp
)) {
249 /* Skip Inter-AS TEv2 Links */
250 if (IS_INTER_AS(lp
->type
))
252 if ((area
= lp
->area
) == NULL
)
254 if (CHECK_FLAG(lp
->flags
, LPFLG_LOOKUP_DONE
))
258 (*func
)(lp
, sched_opcode
);
260 for (node2
= listnextnode(node
); node2
;
261 node2
= listnextnode(node2
))
262 if ((lp
= listgetdata(node2
)) != NULL
)
263 if (lp
->area
!= NULL
)
264 if (IPV4_ADDR_SAME(&lp
->area
->area_id
,
270 for (ALL_LIST_ELEMENTS_RO(OspfMplsTE
.iflist
, node
, lp
))
271 if (lp
->area
!= NULL
)
272 UNSET_FLAG(lp
->flags
, LPFLG_LOOKUP_DONE
);
277 static void set_mpls_te_router_addr(struct in_addr ipv4
)
279 OspfMplsTE
.router_addr
.header
.type
= htons(TE_TLV_ROUTER_ADDR
);
280 OspfMplsTE
.router_addr
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
281 OspfMplsTE
.router_addr
.value
= ipv4
;
285 static void set_linkparams_link_header(struct mpls_te_link
*lp
)
287 u_int16_t length
= 0;
289 /* TE_LINK_SUBTLV_LINK_TYPE */
290 if (ntohs(lp
->link_type
.header
.type
) != 0)
291 length
+= TLV_SIZE(&lp
->link_type
.header
);
293 /* TE_LINK_SUBTLV_LINK_ID */
294 if (ntohs(lp
->link_id
.header
.type
) != 0)
295 length
+= TLV_SIZE(&lp
->link_id
.header
);
297 /* TE_LINK_SUBTLV_LCLIF_IPADDR */
298 if (lp
->lclif_ipaddr
.header
.type
!= 0)
299 length
+= TLV_SIZE(&lp
->lclif_ipaddr
.header
);
301 /* TE_LINK_SUBTLV_RMTIF_IPADDR */
302 if (lp
->rmtif_ipaddr
.header
.type
!= 0)
303 length
+= TLV_SIZE(&lp
->rmtif_ipaddr
.header
);
305 /* TE_LINK_SUBTLV_TE_METRIC */
306 if (ntohs(lp
->te_metric
.header
.type
) != 0)
307 length
+= TLV_SIZE(&lp
->te_metric
.header
);
309 /* TE_LINK_SUBTLV_MAX_BW */
310 if (ntohs(lp
->max_bw
.header
.type
) != 0)
311 length
+= TLV_SIZE(&lp
->max_bw
.header
);
313 /* TE_LINK_SUBTLV_MAX_RSV_BW */
314 if (ntohs(lp
->max_rsv_bw
.header
.type
) != 0)
315 length
+= TLV_SIZE(&lp
->max_rsv_bw
.header
);
317 /* TE_LINK_SUBTLV_UNRSV_BW */
318 if (ntohs(lp
->unrsv_bw
.header
.type
) != 0)
319 length
+= TLV_SIZE(&lp
->unrsv_bw
.header
);
321 /* TE_LINK_SUBTLV_RSC_CLSCLR */
322 if (ntohs(lp
->rsc_clsclr
.header
.type
) != 0)
323 length
+= TLV_SIZE(&lp
->rsc_clsclr
.header
);
325 /* TE_LINK_SUBTLV_LLRI */
326 if (ntohs(lp
->llri
.header
.type
) != 0)
327 length
+= TLV_SIZE(&lp
->llri
.header
);
329 /* TE_LINK_SUBTLV_RIP */
330 if (ntohs(lp
->rip
.header
.type
) != 0)
331 length
+= TLV_SIZE(&lp
->rip
.header
);
333 /* TE_LINK_SUBTLV_RAS */
334 if (ntohs(lp
->ras
.header
.type
) != 0)
335 length
+= TLV_SIZE(&lp
->ras
.header
);
337 /* TE_LINK_SUBTLV_LRRID */
338 if (ntohs(lp
->lrrid
.header
.type
) != 0)
339 length
+= TLV_SIZE(&lp
->lrrid
.header
);
341 /* TE_LINK_SUBTLV_AV_DELAY */
342 if (ntohs(lp
->av_delay
.header
.type
) != 0)
343 length
+= TLV_SIZE(&lp
->av_delay
.header
);
345 /* TE_LINK_SUBTLV_MM_DELAY */
346 if (ntohs(lp
->mm_delay
.header
.type
) != 0)
347 length
+= TLV_SIZE(&lp
->mm_delay
.header
);
349 /* TE_LINK_SUBTLV_DELAY_VAR */
350 if (ntohs(lp
->delay_var
.header
.type
) != 0)
351 length
+= TLV_SIZE(&lp
->delay_var
.header
);
353 /* TE_LINK_SUBTLV_PKT_LOSS */
354 if (ntohs(lp
->pkt_loss
.header
.type
) != 0)
355 length
+= TLV_SIZE(&lp
->pkt_loss
.header
);
357 /* TE_LINK_SUBTLV_RES_BW */
358 if (ntohs(lp
->res_bw
.header
.type
) != 0)
359 length
+= TLV_SIZE(&lp
->res_bw
.header
);
361 /* TE_LINK_SUBTLV_AVA_BW */
362 if (ntohs(lp
->ava_bw
.header
.type
) != 0)
363 length
+= TLV_SIZE(&lp
->ava_bw
.header
);
365 /* TE_LINK_SUBTLV_USE_BW */
366 if (ntohs(lp
->use_bw
.header
.type
) != 0)
367 length
+= TLV_SIZE(&lp
->use_bw
.header
);
369 lp
->link_header
.header
.type
= htons(TE_TLV_LINK
);
370 lp
->link_header
.header
.length
= htons(length
);
375 static void set_linkparams_link_type(struct ospf_interface
*oi
,
376 struct mpls_te_link
*lp
)
378 lp
->link_type
.header
.type
= htons(TE_LINK_SUBTLV_LINK_TYPE
);
379 lp
->link_type
.header
.length
= htons(TE_LINK_SUBTLV_TYPE_SIZE
);
382 case OSPF_IFTYPE_POINTOPOINT
:
383 lp
->link_type
.link_type
.value
= LINK_TYPE_SUBTLV_VALUE_PTP
;
385 case OSPF_IFTYPE_BROADCAST
:
386 case OSPF_IFTYPE_NBMA
:
387 lp
->link_type
.link_type
.value
= LINK_TYPE_SUBTLV_VALUE_MA
;
390 /* Not supported yet. */ /* XXX */
391 lp
->link_type
.header
.type
= htons(0);
397 static void set_linkparams_link_id(struct ospf_interface
*oi
,
398 struct mpls_te_link
*lp
)
400 struct ospf_neighbor
*nbr
;
403 lp
->link_id
.header
.type
= htons(TE_LINK_SUBTLV_LINK_ID
);
404 lp
->link_id
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
407 * The Link ID is identical to the contents of the Link ID field
408 * in the Router LSA for these link types.
411 case OSPF_IFTYPE_POINTOPOINT
:
412 /* Take the router ID of the neighbor. */
413 if ((nbr
= ospf_nbr_lookup_ptop(oi
))
414 && nbr
->state
== NSM_Full
) {
415 lp
->link_id
.value
= nbr
->router_id
;
419 case OSPF_IFTYPE_BROADCAST
:
420 case OSPF_IFTYPE_NBMA
:
421 /* Take the interface address of the designated router. */
422 if ((nbr
= ospf_nbr_lookup_by_addr(oi
->nbrs
, &DR(oi
))) == NULL
)
425 if (nbr
->state
== NSM_Full
426 || (IPV4_ADDR_SAME(&oi
->address
->u
.prefix4
, &DR(oi
))
427 && ospf_nbr_count(oi
, NSM_Full
) > 0)) {
428 lp
->link_id
.value
= DR(oi
);
433 /* Not supported yet. */ /* XXX */
434 lp
->link_id
.header
.type
= htons(0);
440 masklen2ip(oi
->address
->prefixlen
, &mask
);
441 lp
->link_id
.value
.s_addr
=
442 oi
->address
->u
.prefix4
.s_addr
& mask
.s_addr
;
447 static void set_linkparams_lclif_ipaddr(struct mpls_te_link
*lp
,
448 struct in_addr lclif
)
451 lp
->lclif_ipaddr
.header
.type
= htons(TE_LINK_SUBTLV_LCLIF_IPADDR
);
452 lp
->lclif_ipaddr
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
453 lp
->lclif_ipaddr
.value
[0] = lclif
;
457 static void set_linkparams_rmtif_ipaddr(struct mpls_te_link
*lp
,
458 struct in_addr rmtif
)
461 lp
->rmtif_ipaddr
.header
.type
= htons(TE_LINK_SUBTLV_RMTIF_IPADDR
);
462 lp
->rmtif_ipaddr
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
463 lp
->rmtif_ipaddr
.value
[0] = rmtif
;
467 static void set_linkparams_te_metric(struct mpls_te_link
*lp
,
470 lp
->te_metric
.header
.type
= htons(TE_LINK_SUBTLV_TE_METRIC
);
471 lp
->te_metric
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
472 lp
->te_metric
.value
= htonl(te_metric
);
476 static void set_linkparams_max_bw(struct mpls_te_link
*lp
, float fp
)
478 lp
->max_bw
.header
.type
= htons(TE_LINK_SUBTLV_MAX_BW
);
479 lp
->max_bw
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
480 lp
->max_bw
.value
= htonf(fp
);
484 static void set_linkparams_max_rsv_bw(struct mpls_te_link
*lp
, float fp
)
486 lp
->max_rsv_bw
.header
.type
= htons(TE_LINK_SUBTLV_MAX_RSV_BW
);
487 lp
->max_rsv_bw
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
488 lp
->max_rsv_bw
.value
= htonf(fp
);
492 static void set_linkparams_unrsv_bw(struct mpls_te_link
*lp
, int priority
,
495 /* Note that TLV-length field is the size of array. */
496 lp
->unrsv_bw
.header
.type
= htons(TE_LINK_SUBTLV_UNRSV_BW
);
497 lp
->unrsv_bw
.header
.length
= htons(TE_LINK_SUBTLV_UNRSV_SIZE
);
498 lp
->unrsv_bw
.value
[priority
] = htonf(fp
);
502 static void set_linkparams_rsc_clsclr(struct mpls_te_link
*lp
,
503 u_int32_t classcolor
)
505 lp
->rsc_clsclr
.header
.type
= htons(TE_LINK_SUBTLV_RSC_CLSCLR
);
506 lp
->rsc_clsclr
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
507 lp
->rsc_clsclr
.value
= htonl(classcolor
);
511 static void set_linkparams_inter_as(struct mpls_te_link
*lp
,
512 struct in_addr addr
, u_int32_t as
)
515 /* Set the Remote ASBR IP address and then the associated AS number */
516 lp
->rip
.header
.type
= htons(TE_LINK_SUBTLV_RIP
);
517 lp
->rip
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
518 lp
->rip
.value
= addr
;
520 lp
->ras
.header
.type
= htons(TE_LINK_SUBTLV_RAS
);
521 lp
->ras
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
522 lp
->ras
.value
= htonl(as
);
525 static void unset_linkparams_inter_as(struct mpls_te_link
*lp
)
528 /* Reset the Remote ASBR IP address and then the associated AS number */
529 lp
->rip
.header
.type
= htons(0);
530 lp
->rip
.header
.length
= htons(0);
531 lp
->rip
.value
.s_addr
= htonl(0);
533 lp
->ras
.header
.type
= htons(0);
534 lp
->ras
.header
.length
= htons(0);
535 lp
->ras
.value
= htonl(0);
538 void set_linkparams_llri(struct mpls_te_link
*lp
, u_int32_t local
,
542 lp
->llri
.header
.type
= htons(TE_LINK_SUBTLV_LLRI
);
543 lp
->llri
.header
.length
= htons(TE_LINK_SUBTLV_LLRI_SIZE
);
544 lp
->llri
.local
= htonl(local
);
545 lp
->llri
.remote
= htonl(remote
);
548 void set_linkparams_lrrid(struct mpls_te_link
*lp
, struct in_addr local
,
549 struct in_addr remote
)
552 lp
->lrrid
.header
.type
= htons(TE_LINK_SUBTLV_LRRID
);
553 lp
->lrrid
.header
.length
= htons(TE_LINK_SUBTLV_LRRID_SIZE
);
554 lp
->lrrid
.local
.s_addr
= local
.s_addr
;
555 lp
->lrrid
.remote
.s_addr
= remote
.s_addr
;
558 static void set_linkparams_av_delay(struct mpls_te_link
*lp
, u_int32_t delay
,
562 /* Note that TLV-length field is the size of array. */
563 lp
->av_delay
.header
.type
= htons(TE_LINK_SUBTLV_AV_DELAY
);
564 lp
->av_delay
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
565 tmp
= delay
& TE_EXT_MASK
;
567 tmp
|= TE_EXT_ANORMAL
;
568 lp
->av_delay
.value
= htonl(tmp
);
572 static void set_linkparams_mm_delay(struct mpls_te_link
*lp
, u_int32_t low
,
573 u_int32_t high
, u_char anormal
)
576 /* Note that TLV-length field is the size of array. */
577 lp
->mm_delay
.header
.type
= htons(TE_LINK_SUBTLV_MM_DELAY
);
578 lp
->mm_delay
.header
.length
= htons(TE_LINK_SUBTLV_MM_DELAY_SIZE
);
579 tmp
= low
& TE_EXT_MASK
;
581 tmp
|= TE_EXT_ANORMAL
;
582 lp
->mm_delay
.low
= htonl(tmp
);
583 lp
->mm_delay
.high
= htonl(high
);
587 static void set_linkparams_delay_var(struct mpls_te_link
*lp
, u_int32_t jitter
)
589 /* Note that TLV-length field is the size of array. */
590 lp
->delay_var
.header
.type
= htons(TE_LINK_SUBTLV_DELAY_VAR
);
591 lp
->delay_var
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
592 lp
->delay_var
.value
= htonl(jitter
& TE_EXT_MASK
);
596 static void set_linkparams_pkt_loss(struct mpls_te_link
*lp
, u_int32_t loss
,
600 /* Note that TLV-length field is the size of array. */
601 lp
->pkt_loss
.header
.type
= htons(TE_LINK_SUBTLV_PKT_LOSS
);
602 lp
->pkt_loss
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
603 tmp
= loss
& TE_EXT_MASK
;
605 tmp
|= TE_EXT_ANORMAL
;
606 lp
->pkt_loss
.value
= htonl(tmp
);
610 static void set_linkparams_res_bw(struct mpls_te_link
*lp
, float fp
)
612 /* Note that TLV-length field is the size of array. */
613 lp
->res_bw
.header
.type
= htons(TE_LINK_SUBTLV_RES_BW
);
614 lp
->res_bw
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
615 lp
->res_bw
.value
= htonf(fp
);
619 static void set_linkparams_ava_bw(struct mpls_te_link
*lp
, float fp
)
621 /* Note that TLV-length field is the size of array. */
622 lp
->ava_bw
.header
.type
= htons(TE_LINK_SUBTLV_AVA_BW
);
623 lp
->ava_bw
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
624 lp
->ava_bw
.value
= htonf(fp
);
628 static void set_linkparams_use_bw(struct mpls_te_link
*lp
, float fp
)
630 /* Note that TLV-length field is the size of array. */
631 lp
->use_bw
.header
.type
= htons(TE_LINK_SUBTLV_USE_BW
);
632 lp
->use_bw
.header
.length
= htons(TE_LINK_SUBTLV_DEF_SIZE
);
633 lp
->use_bw
.value
= htonf(fp
);
637 /* Update TE parameters from Interface */
638 static void update_linkparams(struct mpls_te_link
*lp
)
641 struct interface
*ifp
;
643 /* Get the Interface structure */
644 if ((ifp
= lp
->ifp
) == NULL
) {
645 if (IS_DEBUG_OSPF_TE
)
647 "OSPF MPLS-TE: Abort update TE parameters: no interface associated to Link Parameters");
650 if (!HAS_LINK_PARAMS(ifp
)) {
651 if (IS_DEBUG_OSPF_TE
)
653 "OSPF MPLS-TE: Abort update TE parameters: no Link Parameters for interface");
657 /* RFC3630 metrics */
658 if (IS_PARAM_SET(ifp
->link_params
, LP_ADM_GRP
))
659 set_linkparams_rsc_clsclr(lp
, ifp
->link_params
->admin_grp
);
661 TLV_TYPE(lp
->rsc_clsclr
) = 0;
663 if (IS_PARAM_SET(ifp
->link_params
, LP_MAX_BW
))
664 set_linkparams_max_bw(lp
, ifp
->link_params
->max_bw
);
666 TLV_TYPE(lp
->max_bw
) = 0;
668 if (IS_PARAM_SET(ifp
->link_params
, LP_MAX_RSV_BW
))
669 set_linkparams_max_rsv_bw(lp
, ifp
->link_params
->max_rsv_bw
);
671 TLV_TYPE(lp
->max_rsv_bw
) = 0;
673 if (IS_PARAM_SET(ifp
->link_params
, LP_UNRSV_BW
))
674 for (i
= 0; i
< MAX_CLASS_TYPE
; i
++)
675 set_linkparams_unrsv_bw(lp
, i
,
676 ifp
->link_params
->unrsv_bw
[i
]);
678 TLV_TYPE(lp
->unrsv_bw
) = 0;
680 if (IS_PARAM_SET(ifp
->link_params
, LP_TE_METRIC
))
681 set_linkparams_te_metric(lp
, ifp
->link_params
->te_metric
);
683 TLV_TYPE(lp
->te_metric
) = 0;
685 /* TE metric Extensions */
686 if (IS_PARAM_SET(ifp
->link_params
, LP_DELAY
))
687 set_linkparams_av_delay(lp
, ifp
->link_params
->av_delay
, 0);
689 TLV_TYPE(lp
->av_delay
) = 0;
691 if (IS_PARAM_SET(ifp
->link_params
, LP_MM_DELAY
))
692 set_linkparams_mm_delay(lp
, ifp
->link_params
->min_delay
,
693 ifp
->link_params
->max_delay
, 0);
695 TLV_TYPE(lp
->mm_delay
) = 0;
697 if (IS_PARAM_SET(ifp
->link_params
, LP_DELAY_VAR
))
698 set_linkparams_delay_var(lp
, ifp
->link_params
->delay_var
);
700 TLV_TYPE(lp
->delay_var
) = 0;
702 if (IS_PARAM_SET(ifp
->link_params
, LP_PKT_LOSS
))
703 set_linkparams_pkt_loss(lp
, ifp
->link_params
->pkt_loss
, 0);
705 TLV_TYPE(lp
->pkt_loss
) = 0;
707 if (IS_PARAM_SET(ifp
->link_params
, LP_RES_BW
))
708 set_linkparams_res_bw(lp
, ifp
->link_params
->res_bw
);
710 TLV_TYPE(lp
->res_bw
) = 0;
712 if (IS_PARAM_SET(ifp
->link_params
, LP_AVA_BW
))
713 set_linkparams_ava_bw(lp
, ifp
->link_params
->ava_bw
);
715 TLV_TYPE(lp
->ava_bw
) = 0;
717 if (IS_PARAM_SET(ifp
->link_params
, LP_USE_BW
))
718 set_linkparams_use_bw(lp
, ifp
->link_params
->use_bw
);
720 TLV_TYPE(lp
->use_bw
) = 0;
723 if (IS_PARAM_SET(ifp
->link_params
, LP_RMT_AS
)) {
724 /* Flush LSA if it engaged and was previously a STD_TE one */
725 if (IS_STD_TE(lp
->type
)
726 && CHECK_FLAG(lp
->flags
, LPFLG_LSA_ENGAGED
)) {
727 if (IS_DEBUG_OSPF_TE
)
729 "OSPF MPLS-TE Update IF: Switch from Standard LSA to INTER-AS for %s[%d/%d]",
730 ifp
->name
, lp
->flags
, lp
->type
);
732 ospf_mpls_te_lsa_schedule(lp
, FLUSH_THIS_LSA
);
733 /* Then, switch it to INTER-AS */
734 if (OspfMplsTE
.inter_as
== AS
)
735 lp
->flags
= INTER_AS
| FLOOD_AS
;
737 lp
->flags
= INTER_AS
| FLOOD_AREA
;
738 lp
->area
= ospf_area_lookup_by_area_id(
739 ospf_lookup_by_vrf_id(VRF_DEFAULT
),
740 OspfMplsTE
.interas_areaid
);
743 set_linkparams_inter_as(lp
, ifp
->link_params
->rmt_ip
,
744 ifp
->link_params
->rmt_as
);
746 if (IS_DEBUG_OSPF_TE
)
748 "OSPF MPLS-TE Update IF: Switch from INTER-AS LSA to Standard for %s[%d/%d]",
749 ifp
->name
, lp
->flags
, lp
->type
);
751 /* reset inter-as TE params */
752 /* Flush LSA if it engaged and was previously an INTER_AS one */
753 if (IS_INTER_AS(lp
->type
)
754 && CHECK_FLAG(lp
->flags
, LPFLG_LSA_ENGAGED
)) {
755 ospf_mpls_te_lsa_schedule(lp
, FLUSH_THIS_LSA
);
756 /* Then, switch it to Standard TE */
757 lp
->flags
= STD_TE
| FLOOD_AREA
;
759 unset_linkparams_inter_as(lp
);
763 static void initialize_linkparams(struct mpls_te_link
*lp
)
765 struct interface
*ifp
= lp
->ifp
;
766 struct ospf_interface
*oi
= NULL
;
767 struct route_node
*rn
;
769 if (IS_DEBUG_OSPF_TE
)
771 "MPLS-TE(initialize_linkparams) Initialize Link Parameters for interface %s",
774 /* Search OSPF Interface parameters for this interface */
775 for (rn
= route_top(IF_OIFS(ifp
)); rn
; rn
= route_next(rn
)) {
777 if ((oi
= rn
->info
) == NULL
)
784 if ((oi
== NULL
) || (oi
->ifp
!= ifp
)) {
785 if (IS_DEBUG_OSPF_TE
)
787 "MPLS-TE(initialize_linkparams) Could not find corresponding OSPF Interface for %s",
793 * Try to set initial values those can be derived from
794 * zebra-interface information.
796 set_linkparams_link_type(oi
, lp
);
798 /* Set local IP addr */
799 set_linkparams_lclif_ipaddr(lp
, oi
->address
->u
.prefix4
);
801 /* Set Remote IP addr if Point to Point Interface */
802 if (oi
->type
== OSPF_IFTYPE_POINTOPOINT
) {
803 struct prefix
*pref
= CONNECTED_PREFIX(oi
->connected
);
805 set_linkparams_rmtif_ipaddr(lp
, pref
->u
.prefix4
);
808 /* Keep Area information in combination with link parameters. */
814 static int is_mandated_params_set(struct mpls_te_link
*lp
)
818 if (ntohs(OspfMplsTE
.router_addr
.header
.type
) == 0) {
820 "MPLS-TE(is_mandated_params_set) Missing Router Address");
824 if (ntohs(lp
->link_type
.header
.type
) == 0) {
825 zlog_warn("MPLS-TE(is_mandated_params_set) Missing Link Type");
829 if (!IS_INTER_AS(lp
->type
) && (ntohs(lp
->link_id
.header
.type
) == 0)) {
830 zlog_warn("MPLS-TE(is_mandated_params_set) Missing Link ID");
838 /*------------------------------------------------------------------------*
839 * Followings are callback functions against generic Opaque-LSAs handling.
840 *------------------------------------------------------------------------*/
842 static int ospf_mpls_te_new_if(struct interface
*ifp
)
844 struct mpls_te_link
*new;
847 if (IS_DEBUG_OSPF_TE
)
849 "MPLS-TE(ospf_mpls_te_new_if) Add new %s interface %s to MPLS-TE list",
850 ifp
->link_params
? "Active" : "Inactive", ifp
->name
);
852 if (lookup_linkparams_by_ifp(ifp
) != NULL
) {
853 zlog_warn("ospf_mpls_te_new_if: ifp(%p) already in use?",
855 rc
= 0; /* Do nothing here. */
859 new = XCALLOC(MTYPE_OSPF_MPLS_TE
, sizeof(struct mpls_te_link
));
861 zlog_warn("ospf_mpls_te_new_if: XMALLOC: %s",
862 safe_strerror(errno
));
866 new->instance
= get_mpls_te_instance_value();
868 /* By default TE-Link is RFC3630 compatible flooding in Area and not
870 /* This default behavior will be adapted with call to
871 * ospf_mpls_te_update_if() */
872 new->type
= STD_TE
| FLOOD_AREA
;
873 new->flags
= LPFLG_LSA_INACTIVE
;
875 /* Initialize Link Parameters from Interface */
876 initialize_linkparams(new);
878 /* Set TE Parameters from Interface */
879 update_linkparams(new);
881 /* Add Link Parameters structure to the list */
882 listnode_add(OspfMplsTE
.iflist
, new);
884 if (IS_DEBUG_OSPF_TE
)
886 "OSPF MPLS-TE New IF: Add new LP context for %s[%d/%d]",
887 ifp
->name
, new->flags
, new->type
);
889 /* Schedule Opaque-LSA refresh. */ /* XXX */
895 static int ospf_mpls_te_del_if(struct interface
*ifp
)
897 struct mpls_te_link
*lp
;
900 if ((lp
= lookup_linkparams_by_ifp(ifp
)) != NULL
) {
901 struct list
*iflist
= OspfMplsTE
.iflist
;
903 /* Dequeue listnode entry from the list. */
904 listnode_delete(iflist
, lp
);
906 /* Avoid misjudgement in the next lookup. */
907 if (listcount(iflist
) == 0)
908 iflist
->head
= iflist
->tail
= NULL
;
910 XFREE(MTYPE_OSPF_MPLS_TE
, lp
);
913 /* Schedule Opaque-LSA refresh. */ /* XXX */
919 /* Main initialization / update function of the MPLS TE Link context */
921 /* Call when interface TE Link parameters are modified */
922 void ospf_mpls_te_update_if(struct interface
*ifp
)
924 struct mpls_te_link
*lp
;
926 if (IS_DEBUG_OSPF_TE
)
928 "OSPF MPLS-TE: Update LSA parameters for interface %s [%s]",
929 ifp
->name
, HAS_LINK_PARAMS(ifp
) ? "ON" : "OFF");
931 /* Get Link context from interface */
932 if ((lp
= lookup_linkparams_by_ifp(ifp
)) == NULL
) {
934 "OSPF MPLS-TE Update: Did not find Link Parameters context for interface %s",
939 /* Fulfill MPLS-TE Link TLV from Interface TE Link parameters */
940 if (HAS_LINK_PARAMS(ifp
)) {
941 SET_FLAG(lp
->flags
, LPFLG_LSA_ACTIVE
);
943 /* Update TE parameters */
944 update_linkparams(lp
);
946 /* Finally Re-Originate or Refresh Opaque LSA if MPLS_TE is
948 if (OspfMplsTE
.enabled
)
949 if (lp
->area
!= NULL
) {
950 if (CHECK_FLAG(lp
->flags
, LPFLG_LSA_ENGAGED
))
951 ospf_mpls_te_lsa_schedule(
952 lp
, REFRESH_THIS_LSA
);
954 ospf_mpls_te_lsa_schedule(
955 lp
, REORIGINATE_THIS_LSA
);
958 /* If MPLS TE is disable on this interface, flush LSA if it is
960 if (CHECK_FLAG(lp
->flags
, LPFLG_LSA_ENGAGED
))
961 ospf_mpls_te_lsa_schedule(lp
, FLUSH_THIS_LSA
);
963 /* Reset Activity flag */
964 lp
->flags
= LPFLG_LSA_INACTIVE
;
970 static void ospf_mpls_te_ism_change(struct ospf_interface
*oi
, int old_state
)
972 struct te_link_subtlv_link_type old_type
;
973 struct te_link_subtlv_link_id old_id
;
974 struct mpls_te_link
*lp
;
976 if ((lp
= lookup_linkparams_by_ifp(oi
->ifp
)) == NULL
) {
978 "ospf_mpls_te_ism_change: Cannot get linkparams from OI(%s)?",
983 if (oi
->area
== NULL
|| oi
->area
->ospf
== NULL
) {
985 "ospf_mpls_te_ism_change: Cannot refer to OSPF from OI(%s)?",
990 if ((lp
->area
!= NULL
991 && !IPV4_ADDR_SAME(&lp
->area
->area_id
, &oi
->area
->area_id
))
992 || (lp
->area
!= NULL
&& oi
->area
== NULL
)) {
993 /* How should we consider this case? */
995 "MPLS-TE: Area for OI(%s) has changed to [%s], flush previous LSAs",
997 oi
->area
? inet_ntoa(oi
->area
->area_id
) : "N/A");
998 ospf_mpls_te_lsa_schedule(lp
, FLUSH_THIS_LSA
);
1001 /* Keep Area information in combination with linkparams. */
1002 lp
->area
= oi
->area
;
1004 /* Keep interface MPLS-TE status */
1005 lp
->flags
= HAS_LINK_PARAMS(oi
->ifp
);
1007 switch (oi
->state
) {
1008 case ISM_PointToPoint
:
1012 old_type
= lp
->link_type
;
1013 old_id
= lp
->link_id
;
1015 /* Set Link type, Link ID, Local and Remote IP addr */
1016 set_linkparams_link_type(oi
, lp
);
1017 set_linkparams_link_id(oi
, lp
);
1018 set_linkparams_lclif_ipaddr(lp
, oi
->address
->u
.prefix4
);
1020 if (oi
->type
== LINK_TYPE_SUBTLV_VALUE_PTP
) {
1021 struct prefix
*pref
= CONNECTED_PREFIX(oi
->connected
);
1023 set_linkparams_rmtif_ipaddr(lp
,
1027 /* Update TE parameters */
1028 update_linkparams(lp
);
1030 /* Try to Schedule LSA */
1031 if ((ntohs(old_type
.header
.type
)
1032 != ntohs(lp
->link_type
.header
.type
)
1033 || old_type
.link_type
.value
1034 != lp
->link_type
.link_type
.value
)
1035 || (ntohs(old_id
.header
.type
)
1036 != ntohs(lp
->link_id
.header
.type
)
1037 || ntohl(old_id
.value
.s_addr
)
1038 != ntohl(lp
->link_id
.value
.s_addr
))) {
1039 if (CHECK_FLAG(lp
->flags
, LPFLG_LSA_ENGAGED
))
1040 ospf_mpls_te_lsa_schedule(lp
, REFRESH_THIS_LSA
);
1042 ospf_mpls_te_lsa_schedule(lp
,
1043 REORIGINATE_THIS_LSA
);
1047 lp
->link_type
.header
.type
= htons(0);
1048 lp
->link_id
.header
.type
= htons(0);
1050 if (CHECK_FLAG(lp
->flags
, LPFLG_LSA_ENGAGED
))
1051 ospf_mpls_te_lsa_schedule(lp
, FLUSH_THIS_LSA
);
1058 static void ospf_mpls_te_nsm_change(struct ospf_neighbor
*nbr
, int old_state
)
1060 /* Nothing to do here */
1064 /*------------------------------------------------------------------------*
1065 * Followings are OSPF protocol processing functions for MPLS-TE.
1066 *------------------------------------------------------------------------*/
1068 static void build_tlv_header(struct stream
*s
, struct tlv_header
*tlvh
)
1070 stream_put(s
, tlvh
, sizeof(struct tlv_header
));
1074 static void build_router_tlv(struct stream
*s
)
1076 struct tlv_header
*tlvh
= &OspfMplsTE
.router_addr
.header
;
1077 if (ntohs(tlvh
->type
) != 0) {
1078 build_tlv_header(s
, tlvh
);
1079 stream_put(s
, TLV_DATA(tlvh
), TLV_BODY_SIZE(tlvh
));
1084 static void build_link_subtlv(struct stream
*s
, struct tlv_header
*tlvh
)
1087 if ((tlvh
!= NULL
) && (ntohs(tlvh
->type
) != 0)) {
1088 build_tlv_header(s
, tlvh
);
1089 stream_put(s
, TLV_DATA(tlvh
), TLV_BODY_SIZE(tlvh
));
1094 static void build_link_tlv(struct stream
*s
, struct mpls_te_link
*lp
)
1096 set_linkparams_link_header(lp
);
1097 build_tlv_header(s
, &lp
->link_header
.header
);
1099 build_link_subtlv(s
, &lp
->link_type
.header
);
1100 build_link_subtlv(s
, &lp
->link_id
.header
);
1101 build_link_subtlv(s
, &lp
->lclif_ipaddr
.header
);
1102 build_link_subtlv(s
, &lp
->rmtif_ipaddr
.header
);
1103 build_link_subtlv(s
, &lp
->te_metric
.header
);
1104 build_link_subtlv(s
, &lp
->max_bw
.header
);
1105 build_link_subtlv(s
, &lp
->max_rsv_bw
.header
);
1106 build_link_subtlv(s
, &lp
->unrsv_bw
.header
);
1107 build_link_subtlv(s
, &lp
->rsc_clsclr
.header
);
1108 build_link_subtlv(s
, &lp
->lrrid
.header
);
1109 build_link_subtlv(s
, &lp
->llri
.header
);
1110 build_link_subtlv(s
, &lp
->rip
.header
);
1111 build_link_subtlv(s
, &lp
->ras
.header
);
1112 build_link_subtlv(s
, &lp
->av_delay
.header
);
1113 build_link_subtlv(s
, &lp
->mm_delay
.header
);
1114 build_link_subtlv(s
, &lp
->delay_var
.header
);
1115 build_link_subtlv(s
, &lp
->pkt_loss
.header
);
1116 build_link_subtlv(s
, &lp
->res_bw
.header
);
1117 build_link_subtlv(s
, &lp
->ava_bw
.header
);
1118 build_link_subtlv(s
, &lp
->use_bw
.header
);
1123 static void ospf_mpls_te_lsa_body_set(struct stream
*s
, struct mpls_te_link
*lp
)
1126 * The router address TLV is type 1, and ...
1127 * It must appear in exactly one
1128 * Traffic Engineering LSA originated by a router.
1130 build_router_tlv(s
);
1133 * Only one Link TLV shall be carried in each LSA, allowing for fine
1134 * granularity changes in topology.
1136 build_link_tlv(s
, lp
);
1140 /* Create new opaque-LSA. */
1141 static struct ospf_lsa
*ospf_mpls_te_lsa_new(struct ospf
*ospf
,
1142 struct ospf_area
*area
,
1143 struct mpls_te_link
*lp
)
1146 struct lsa_header
*lsah
;
1147 struct ospf_lsa
*new = NULL
;
1148 u_char options
, lsa_type
= 0;
1149 struct in_addr lsa_id
;
1153 /* Create a stream for LSA. */
1154 if ((s
= stream_new(OSPF_MAX_LSA_SIZE
)) == NULL
) {
1155 zlog_warn("ospf_mpls_te_lsa_new: stream_new() ?");
1158 lsah
= (struct lsa_header
*)STREAM_DATA(s
);
1160 options
= OSPF_OPTION_O
; /* Don't forget this :-) */
1162 /* Set opaque-LSA header fields depending of the type of RFC */
1163 if (IS_INTER_AS(lp
->type
)) {
1165 IS_FLOOD_AS(lp
->type
)
1167 options
|= OSPF_OPTION_E
; /* Enable AS external
1171 lsa_type
= OSPF_OPAQUE_AS_LSA
;
1174 options
|= LSA_OPTIONS_GET(
1175 area
); /* Get area default option */
1176 options
|= LSA_OPTIONS_NSSA_GET(area
);
1177 lsa_type
= OSPF_OPAQUE_AREA_LSA
;
1179 tmp
= SET_OPAQUE_LSID(OPAQUE_TYPE_INTER_AS_LSA
, lp
->instance
);
1180 lsa_id
.s_addr
= htonl(tmp
);
1187 lsa_header_set(s
, options
, lsa_type
, lsa_id
, ospf
->router_id
);
1189 options
|= LSA_OPTIONS_GET(area
); /* Get area default option */
1190 options
|= LSA_OPTIONS_NSSA_GET(area
);
1191 lsa_type
= OSPF_OPAQUE_AREA_LSA
;
1192 tmp
= SET_OPAQUE_LSID(OPAQUE_TYPE_TRAFFIC_ENGINEERING_LSA
,
1194 lsa_id
.s_addr
= htonl(tmp
);
1195 lsa_header_set(s
, options
, lsa_type
, lsa_id
,
1196 area
->ospf
->router_id
);
1199 if (IS_DEBUG_OSPF(lsa
, LSA_GENERATE
))
1201 "LSA[Type%d:%s]: Create an Opaque-LSA/MPLS-TE instance",
1202 lsa_type
, inet_ntoa(lsa_id
));
1204 /* Set opaque-LSA body fields. */
1205 ospf_mpls_te_lsa_body_set(s
, lp
);
1208 length
= stream_get_endp(s
);
1209 lsah
->length
= htons(length
);
1211 /* Now, create an OSPF LSA instance. */
1212 if ((new = ospf_lsa_new()) == NULL
) {
1213 zlog_warn("ospf_mpls_te_lsa_new: ospf_lsa_new() ?");
1217 if ((new->data
= ospf_lsa_data_new(length
)) == NULL
) {
1218 zlog_warn("ospf_mpls_te_lsa_new: ospf_lsa_data_new() ?");
1219 ospf_lsa_unlock(&new);
1225 new->vrf_id
= ospf
->vrf_id
;
1226 if (area
&& area
->ospf
)
1227 new->vrf_id
= area
->ospf
->vrf_id
;
1229 SET_FLAG(new->flags
, OSPF_LSA_SELF
);
1230 memcpy(new->data
, lsah
, length
);
1236 static int ospf_mpls_te_lsa_originate1(struct ospf_area
*area
,
1237 struct mpls_te_link
*lp
)
1239 struct ospf_lsa
*new = NULL
;
1242 /* Create new Opaque-LSA/MPLS-TE instance. */
1243 new = ospf_mpls_te_lsa_new(area
->ospf
, area
, lp
);
1246 "ospf_mpls_te_lsa_originate1: ospf_mpls_te_lsa_new() ?");
1250 /* Install this LSA into LSDB. */
1251 if (ospf_lsa_install(area
->ospf
, NULL
/*oi*/, new) == NULL
) {
1252 zlog_warn("ospf_mpls_te_lsa_originate1: ospf_lsa_install() ?");
1253 ospf_lsa_unlock(&new);
1257 /* Now this link-parameter entry has associated LSA. */
1258 SET_FLAG(lp
->flags
, LPFLG_LSA_ENGAGED
);
1259 /* Update new LSA origination count. */
1260 area
->ospf
->lsa_originate_count
++;
1262 /* Flood new LSA through area. */
1263 ospf_flood_through_area(area
, NULL
/*nbr*/, new);
1265 if (IS_DEBUG_OSPF(lsa
, LSA_GENERATE
)) {
1266 char area_id
[INET_ADDRSTRLEN
];
1267 strlcpy(area_id
, inet_ntoa(area
->area_id
), sizeof(area_id
));
1269 "LSA[Type%d:%s]: Originate Opaque-LSA/MPLS-TE: Area(%s), Link(%s)",
1270 new->data
->type
, inet_ntoa(new->data
->id
), area_id
,
1272 ospf_lsa_header_dump(new->data
);
1279 static int ospf_mpls_te_lsa_originate_area(void *arg
)
1281 struct ospf_area
*area
= (struct ospf_area
*)arg
;
1282 struct listnode
*node
, *nnode
;
1283 struct mpls_te_link
*lp
;
1286 if (!OspfMplsTE
.enabled
) {
1288 "ospf_mpls_te_lsa_originate_area: MPLS-TE is disabled now.");
1289 rc
= 0; /* This is not an error case. */
1293 for (ALL_LIST_ELEMENTS(OspfMplsTE
.iflist
, node
, nnode
, lp
)) {
1294 /* Process only enabled LSA with area scope flooding */
1295 if (!CHECK_FLAG(lp
->flags
, LPFLG_LSA_ACTIVE
)
1296 || IS_FLOOD_AS(lp
->type
))
1299 if (lp
->area
== NULL
)
1302 if (!IPV4_ADDR_SAME(&lp
->area
->area_id
, &area
->area_id
))
1305 if (CHECK_FLAG(lp
->flags
, LPFLG_LSA_ENGAGED
)) {
1306 if (CHECK_FLAG(lp
->flags
, LPFLG_LSA_FORCED_REFRESH
)) {
1307 UNSET_FLAG(lp
->flags
, LPFLG_LSA_FORCED_REFRESH
);
1309 "OSPF MPLS-TE (ospf_mpls_te_lsa_originate_area): Refresh instead of Originate");
1310 ospf_mpls_te_lsa_schedule(lp
, REFRESH_THIS_LSA
);
1315 if (!is_mandated_params_set(lp
)) {
1317 "ospf_mpls_te_lsa_originate_area: Link(%s) lacks some mandated MPLS-TE parameters.",
1318 lp
->ifp
? lp
->ifp
->name
: "?");
1322 /* Ok, let's try to originate an LSA for this area and Link. */
1323 if (IS_DEBUG_OSPF_TE
)
1325 "MPLS-TE(ospf_mpls_te_lsa_originate_area) Let's finally reoriginate the LSA %d through the Area %s for Link %s",
1326 lp
->instance
, inet_ntoa(area
->area_id
),
1327 lp
->ifp
? lp
->ifp
->name
: "?");
1328 if (ospf_mpls_te_lsa_originate1(area
, lp
) != 0)
1336 static int ospf_mpls_te_lsa_originate2(struct ospf
*top
,
1337 struct mpls_te_link
*lp
)
1339 struct ospf_lsa
*new;
1342 /* Create new Opaque-LSA/Inter-AS instance. */
1343 new = ospf_mpls_te_lsa_new(top
, NULL
, lp
);
1346 "ospf_mpls_te_lsa_originate2: ospf_router_info_lsa_new() ?");
1349 new->vrf_id
= top
->vrf_id
;
1351 /* Install this LSA into LSDB. */
1352 if (ospf_lsa_install(top
, NULL
/*oi */, new) == NULL
) {
1353 zlog_warn("ospf_mpls_te_lsa_originate2: ospf_lsa_install() ?");
1354 ospf_lsa_unlock(&new);
1358 /* Now this Router Info parameter entry has associated LSA. */
1359 SET_FLAG(lp
->flags
, LPFLG_LSA_ENGAGED
);
1360 /* Update new LSA origination count. */
1361 top
->lsa_originate_count
++;
1363 /* Flood new LSA through AS. */
1364 ospf_flood_through_as(top
, NULL
/*nbr */, new);
1366 if (IS_DEBUG_OSPF(lsa
, LSA_GENERATE
)) {
1368 "LSA[Type%d:%s]: Originate Opaque-LSA/MPLS-TE Inter-AS",
1369 new->data
->type
, inet_ntoa(new->data
->id
));
1370 ospf_lsa_header_dump(new->data
);
1377 static int ospf_mpls_te_lsa_originate_as(void *arg
)
1380 struct ospf_area
*area
;
1381 struct listnode
*node
, *nnode
;
1382 struct mpls_te_link
*lp
;
1385 if ((!OspfMplsTE
.enabled
) || (OspfMplsTE
.inter_as
== Off
)) {
1387 "ospf_mpls_te_lsa_originate_as: MPLS-TE Inter-AS is disabled for now.");
1388 rc
= 0; /* This is not an error case. */
1392 for (ALL_LIST_ELEMENTS(OspfMplsTE
.iflist
, node
, nnode
, lp
)) {
1393 /* Process only enabled INTER_AS Links or Pseudo-Links */
1394 if (!CHECK_FLAG(lp
->flags
, LPFLG_LSA_ACTIVE
)
1395 || !IS_INTER_AS(lp
->type
))
1398 if (CHECK_FLAG(lp
->flags
, LPFLG_LSA_ENGAGED
)) {
1399 if (CHECK_FLAG(lp
->flags
, LPFLG_LSA_FORCED_REFRESH
)) {
1400 UNSET_FLAG(lp
->flags
, LPFLG_LSA_FORCED_REFRESH
);
1401 ospf_mpls_te_lsa_schedule(lp
, REFRESH_THIS_LSA
);
1406 if (!is_mandated_params_set(lp
)) {
1408 "ospf_mpls_te_lsa_originate_as: Link(%s) lacks some mandated MPLS-TE parameters.",
1409 lp
->ifp
? lp
->ifp
->name
: "?");
1413 /* Ok, let's try to originate an LSA for this AS and Link. */
1414 if (IS_DEBUG_OSPF_TE
)
1416 "MPLS-TE(ospf_mpls_te_lsa_originate_as) Let's finally re-originate the Inter-AS LSA %d through the %s for Link %s",
1418 IS_FLOOD_AS(lp
->type
) ? "AS" : "Area",
1419 lp
->ifp
? lp
->ifp
->name
: "Unknown");
1421 if (IS_FLOOD_AS(lp
->type
)) {
1422 top
= (struct ospf
*)arg
;
1423 ospf_mpls_te_lsa_originate2(top
, lp
);
1425 area
= (struct ospf_area
*)arg
;
1426 ospf_mpls_te_lsa_originate1(area
, lp
);
1434 static struct ospf_lsa
*ospf_mpls_te_lsa_refresh(struct ospf_lsa
*lsa
)
1436 struct mpls_te_link
*lp
;
1437 struct ospf_area
*area
= lsa
->area
;
1439 struct ospf_lsa
*new = NULL
;
1441 if (!OspfMplsTE
.enabled
) {
1443 * This LSA must have flushed before due to MPLS-TE status
1445 * It seems a slip among routers in the routing domain.
1447 zlog_info("ospf_mpls_te_lsa_refresh: MPLS-TE is disabled now.");
1449 htons(OSPF_LSA_MAXAGE
); /* Flush it anyway. */
1452 /* At first, resolve lsa/lp relationship. */
1453 if ((lp
= lookup_linkparams_by_instance(lsa
)) == NULL
) {
1454 zlog_warn("ospf_mpls_te_lsa_refresh: Invalid parameter?");
1456 htons(OSPF_LSA_MAXAGE
); /* Flush it anyway. */
1459 /* Check if lp was not disable in the interval */
1460 if (!CHECK_FLAG(lp
->flags
, LPFLG_LSA_ACTIVE
)) {
1462 "ospf_mpls_te_lsa_refresh: lp was disabled: Flush it!");
1464 htons(OSPF_LSA_MAXAGE
); /* Flush it anyway. */
1467 /* If the lsa's age reached to MaxAge, start flushing procedure. */
1468 if (IS_LSA_MAXAGE(lsa
)) {
1470 UNSET_FLAG(lp
->flags
, LPFLG_LSA_ENGAGED
);
1471 ospf_opaque_lsa_flush_schedule(lsa
);
1474 top
= ospf_lookup_by_vrf_id(lsa
->vrf_id
);
1475 /* Create new Opaque-LSA/MPLS-TE instance. */
1476 new = ospf_mpls_te_lsa_new(top
, area
, lp
);
1478 zlog_warn("ospf_mpls_te_lsa_refresh: ospf_mpls_te_lsa_new() ?");
1481 new->data
->ls_seqnum
= lsa_seqnum_increment(lsa
);
1483 /* Install this LSA into LSDB. */
1484 /* Given "lsa" will be freed in the next function. */
1485 /* As area could be NULL i.e. when using OPAQUE_LSA_AS, we prefer to use
1486 * ospf_lookup() to get ospf instance */
1490 if (ospf_lsa_install(top
, NULL
/*oi */, new) == NULL
) {
1491 zlog_warn("ospf_mpls_te_lsa_refresh: ospf_lsa_install() ?");
1492 ospf_lsa_unlock(&new);
1496 /* Flood updated LSA through AS or Area depending of the RFC of the link
1498 if (IS_FLOOD_AS(lp
->type
))
1499 ospf_flood_through_as(top
, NULL
, new);
1501 ospf_flood_through_area(area
, NULL
/*nbr*/, new);
1503 /* Debug logging. */
1504 if (IS_DEBUG_OSPF(lsa
, LSA_GENERATE
)) {
1505 zlog_debug("LSA[Type%d:%s]: Refresh Opaque-LSA/MPLS-TE",
1506 new->data
->type
, inet_ntoa(new->data
->id
));
1507 ospf_lsa_header_dump(new->data
);
1513 void ospf_mpls_te_lsa_schedule(struct mpls_te_link
*lp
, enum lsa_opcode opcode
)
1515 struct ospf_lsa lsa
;
1516 struct lsa_header lsah
;
1520 memset(&lsa
, 0, sizeof(lsa
));
1521 memset(&lsah
, 0, sizeof(lsah
));
1522 top
= ospf_lookup_by_vrf_id(VRF_DEFAULT
);
1524 /* Check if the pseudo link is ready to flood */
1525 if (!(CHECK_FLAG(lp
->flags
, LPFLG_LSA_ACTIVE
))
1526 || !(IS_FLOOD_AREA(lp
->type
) || IS_FLOOD_AS(lp
->type
))) {
1530 lsa
.area
= lp
->area
;
1532 if (IS_FLOOD_AS(lp
->type
)) {
1533 lsah
.type
= OSPF_OPAQUE_AS_LSA
;
1534 tmp
= SET_OPAQUE_LSID(OPAQUE_TYPE_INTER_AS_LSA
, lp
->instance
);
1535 lsah
.id
.s_addr
= htonl(tmp
);
1537 lsah
.type
= OSPF_OPAQUE_AREA_LSA
;
1538 if (IS_INTER_AS(lp
->type
)) {
1539 /* Set the area context if not know */
1540 if (lp
->area
== NULL
)
1541 lp
->area
= ospf_area_lookup_by_area_id(
1542 top
, OspfMplsTE
.interas_areaid
);
1543 /* Unable to set the area context. Abort! */
1544 if (lp
->area
== NULL
) {
1546 "MPLS-TE(ospf_mpls_te_lsa_schedule) Area context is null. Abort !");
1549 tmp
= SET_OPAQUE_LSID(OPAQUE_TYPE_INTER_AS_LSA
,
1552 tmp
= SET_OPAQUE_LSID(
1553 OPAQUE_TYPE_TRAFFIC_ENGINEERING_LSA
,
1555 lsah
.id
.s_addr
= htonl(tmp
);
1559 case REORIGINATE_THIS_LSA
:
1560 if (IS_FLOOD_AS(lp
->type
)) {
1561 ospf_opaque_lsa_reoriginate_schedule(
1562 (void *)top
, OSPF_OPAQUE_AS_LSA
,
1563 OPAQUE_TYPE_INTER_AS_LSA
);
1567 if (IS_FLOOD_AREA(lp
->type
)) {
1568 if (IS_INTER_AS(lp
->type
))
1569 ospf_opaque_lsa_reoriginate_schedule(
1570 (void *)lp
->area
, OSPF_OPAQUE_AREA_LSA
,
1571 OPAQUE_TYPE_INTER_AS_LSA
);
1573 ospf_opaque_lsa_reoriginate_schedule(
1574 (void *)lp
->area
, OSPF_OPAQUE_AREA_LSA
,
1575 OPAQUE_TYPE_TRAFFIC_ENGINEERING_LSA
);
1579 case REFRESH_THIS_LSA
:
1580 ospf_opaque_lsa_refresh_schedule(&lsa
);
1582 case FLUSH_THIS_LSA
:
1583 /* Reset Activity flag */
1584 lp
->flags
= LPFLG_LSA_INACTIVE
;
1585 ospf_opaque_lsa_flush_schedule(&lsa
);
1588 zlog_warn("ospf_mpls_te_lsa_schedule: Unknown opcode (%u)",
1597 /*------------------------------------------------------------------------*
1598 * Followings are vty session control functions.
1599 *------------------------------------------------------------------------*/
1601 static u_int16_t
show_vty_router_addr(struct vty
*vty
, struct tlv_header
*tlvh
)
1603 struct te_tlv_router_addr
*top
= (struct te_tlv_router_addr
*)tlvh
;
1606 vty_out(vty
, " Router-Address: %s\n", inet_ntoa(top
->value
));
1608 zlog_debug(" Router-Address: %s", inet_ntoa(top
->value
));
1610 return TLV_SIZE(tlvh
);
1613 static u_int16_t
show_vty_link_header(struct vty
*vty
, struct tlv_header
*tlvh
)
1615 struct te_tlv_link
*top
= (struct te_tlv_link
*)tlvh
;
1618 vty_out(vty
, " Link: %u octets of data\n",
1619 ntohs(top
->header
.length
));
1621 zlog_debug(" Link: %u octets of data",
1622 ntohs(top
->header
.length
));
1624 return TLV_HDR_SIZE
; /* Here is special, not "TLV_SIZE". */
1627 static u_int16_t
show_vty_link_subtlv_link_type(struct vty
*vty
,
1628 struct tlv_header
*tlvh
)
1630 struct te_link_subtlv_link_type
*top
;
1631 const char *cp
= "Unknown";
1633 top
= (struct te_link_subtlv_link_type
*)tlvh
;
1634 switch (top
->link_type
.value
) {
1635 case LINK_TYPE_SUBTLV_VALUE_PTP
:
1636 cp
= "Point-to-point";
1638 case LINK_TYPE_SUBTLV_VALUE_MA
:
1646 vty_out(vty
, " Link-Type: %s (%u)\n", cp
,
1647 top
->link_type
.value
);
1649 zlog_debug(" Link-Type: %s (%u)", cp
, top
->link_type
.value
);
1651 return TLV_SIZE(tlvh
);
1654 static u_int16_t
show_vty_link_subtlv_link_id(struct vty
*vty
,
1655 struct tlv_header
*tlvh
)
1657 struct te_link_subtlv_link_id
*top
;
1659 top
= (struct te_link_subtlv_link_id
*)tlvh
;
1661 vty_out(vty
, " Link-ID: %s\n", inet_ntoa(top
->value
));
1663 zlog_debug(" Link-ID: %s", inet_ntoa(top
->value
));
1665 return TLV_SIZE(tlvh
);
1668 static u_int16_t
show_vty_link_subtlv_lclif_ipaddr(struct vty
*vty
,
1669 struct tlv_header
*tlvh
)
1671 struct te_link_subtlv_lclif_ipaddr
*top
;
1674 top
= (struct te_link_subtlv_lclif_ipaddr
*)tlvh
;
1675 n
= ntohs(tlvh
->length
) / sizeof(top
->value
[0]);
1678 vty_out(vty
, " Local Interface IP Address(es): %d\n", n
);
1680 zlog_debug(" Local Interface IP Address(es): %d", n
);
1682 for (i
= 0; i
< n
; i
++) {
1684 vty_out(vty
, " #%d: %s\n", i
,
1685 inet_ntoa(top
->value
[i
]));
1687 zlog_debug(" #%d: %s", i
,
1688 inet_ntoa(top
->value
[i
]));
1690 return TLV_SIZE(tlvh
);
1693 static u_int16_t
show_vty_link_subtlv_rmtif_ipaddr(struct vty
*vty
,
1694 struct tlv_header
*tlvh
)
1696 struct te_link_subtlv_rmtif_ipaddr
*top
;
1699 top
= (struct te_link_subtlv_rmtif_ipaddr
*)tlvh
;
1700 n
= ntohs(tlvh
->length
) / sizeof(top
->value
[0]);
1702 vty_out(vty
, " Remote Interface IP Address(es): %d\n", n
);
1704 zlog_debug(" Remote Interface IP Address(es): %d", n
);
1706 for (i
= 0; i
< n
; i
++) {
1708 vty_out(vty
, " #%d: %s\n", i
,
1709 inet_ntoa(top
->value
[i
]));
1711 zlog_debug(" #%d: %s", i
,
1712 inet_ntoa(top
->value
[i
]));
1714 return TLV_SIZE(tlvh
);
1717 static u_int16_t
show_vty_link_subtlv_te_metric(struct vty
*vty
,
1718 struct tlv_header
*tlvh
)
1720 struct te_link_subtlv_te_metric
*top
;
1722 top
= (struct te_link_subtlv_te_metric
*)tlvh
;
1724 vty_out(vty
, " Traffic Engineering Metric: %u\n",
1725 (u_int32_t
)ntohl(top
->value
));
1727 zlog_debug(" Traffic Engineering Metric: %u",
1728 (u_int32_t
)ntohl(top
->value
));
1730 return TLV_SIZE(tlvh
);
1733 static u_int16_t
show_vty_link_subtlv_max_bw(struct vty
*vty
,
1734 struct tlv_header
*tlvh
)
1736 struct te_link_subtlv_max_bw
*top
;
1739 top
= (struct te_link_subtlv_max_bw
*)tlvh
;
1740 fval
= ntohf(top
->value
);
1743 vty_out(vty
, " Maximum Bandwidth: %g (Bytes/sec)\n", fval
);
1745 zlog_debug(" Maximum Bandwidth: %g (Bytes/sec)", fval
);
1747 return TLV_SIZE(tlvh
);
1750 static u_int16_t
show_vty_link_subtlv_max_rsv_bw(struct vty
*vty
,
1751 struct tlv_header
*tlvh
)
1753 struct te_link_subtlv_max_rsv_bw
*top
;
1756 top
= (struct te_link_subtlv_max_rsv_bw
*)tlvh
;
1757 fval
= ntohf(top
->value
);
1760 vty_out(vty
, " Maximum Reservable Bandwidth: %g (Bytes/sec)\n",
1763 zlog_debug(" Maximum Reservable Bandwidth: %g (Bytes/sec)",
1766 return TLV_SIZE(tlvh
);
1769 static u_int16_t
show_vty_link_subtlv_unrsv_bw(struct vty
*vty
,
1770 struct tlv_header
*tlvh
)
1772 struct te_link_subtlv_unrsv_bw
*top
;
1776 top
= (struct te_link_subtlv_unrsv_bw
*)tlvh
;
1779 " Unreserved Bandwidth per Class Type in Byte/s:\n");
1782 " Unreserved Bandwidth per Class Type in Byte/s:");
1783 for (i
= 0; i
< MAX_CLASS_TYPE
; i
+= 2) {
1784 fval1
= ntohf(top
->value
[i
]);
1785 fval2
= ntohf(top
->value
[i
+ 1]);
1789 " [%d]: %g (Bytes/sec),\t[%d]: %g (Bytes/sec)\n",
1790 i
, fval1
, i
+ 1, fval2
);
1793 " [%d]: %g (Bytes/sec),\t[%d]: %g (Bytes/sec)",
1794 i
, fval1
, i
+ 1, fval2
);
1797 return TLV_SIZE(tlvh
);
1800 static u_int16_t
show_vty_link_subtlv_rsc_clsclr(struct vty
*vty
,
1801 struct tlv_header
*tlvh
)
1803 struct te_link_subtlv_rsc_clsclr
*top
;
1805 top
= (struct te_link_subtlv_rsc_clsclr
*)tlvh
;
1807 vty_out(vty
, " Resource class/color: 0x%x\n",
1808 (u_int32_t
)ntohl(top
->value
));
1810 zlog_debug(" Resource Class/Color: 0x%x",
1811 (u_int32_t
)ntohl(top
->value
));
1813 return TLV_SIZE(tlvh
);
1816 static u_int16_t
show_vty_link_subtlv_lrrid(struct vty
*vty
,
1817 struct tlv_header
*tlvh
)
1819 struct te_link_subtlv_lrrid
*top
;
1821 top
= (struct te_link_subtlv_lrrid
*)tlvh
;
1824 vty_out(vty
, " Local TE Router ID: %s\n",
1825 inet_ntoa(top
->local
));
1826 vty_out(vty
, " Remote TE Router ID: %s\n",
1827 inet_ntoa(top
->remote
));
1829 zlog_debug(" Local TE Router ID: %s",
1830 inet_ntoa(top
->local
));
1831 zlog_debug(" Remote TE Router ID: %s",
1832 inet_ntoa(top
->remote
));
1835 return TLV_SIZE(tlvh
);
1838 static u_int16_t
show_vty_link_subtlv_llri(struct vty
*vty
,
1839 struct tlv_header
*tlvh
)
1841 struct te_link_subtlv_llri
*top
;
1843 top
= (struct te_link_subtlv_llri
*)tlvh
;
1846 vty_out(vty
, " Link Local ID: %d\n",
1847 (u_int32_t
)ntohl(top
->local
));
1848 vty_out(vty
, " Link Remote ID: %d\n",
1849 (u_int32_t
)ntohl(top
->remote
));
1851 zlog_debug(" Link Local ID: %d",
1852 (u_int32_t
)ntohl(top
->local
));
1853 zlog_debug(" Link Remote ID: %d",
1854 (u_int32_t
)ntohl(top
->remote
));
1857 return TLV_SIZE(tlvh
);
1860 static u_int16_t
show_vty_link_subtlv_rip(struct vty
*vty
,
1861 struct tlv_header
*tlvh
)
1863 struct te_link_subtlv_rip
*top
;
1865 top
= (struct te_link_subtlv_rip
*)tlvh
;
1868 vty_out(vty
, " Inter-AS TE Remote ASBR IP address: %s\n",
1869 inet_ntoa(top
->value
));
1871 zlog_debug(" Inter-AS TE Remote ASBR IP address: %s",
1872 inet_ntoa(top
->value
));
1874 return TLV_SIZE(tlvh
);
1877 static u_int16_t
show_vty_link_subtlv_ras(struct vty
*vty
,
1878 struct tlv_header
*tlvh
)
1880 struct te_link_subtlv_ras
*top
;
1882 top
= (struct te_link_subtlv_ras
*)tlvh
;
1885 vty_out(vty
, " Inter-AS TE Remote AS number: %u\n",
1888 zlog_debug(" Inter-AS TE Remote AS number: %u",
1891 return TLV_SIZE(tlvh
);
1894 static u_int16_t
show_vty_link_subtlv_av_delay(struct vty
*vty
,
1895 struct tlv_header
*tlvh
)
1897 struct te_link_subtlv_av_delay
*top
;
1899 u_int32_t anomalous
;
1901 top
= (struct te_link_subtlv_av_delay
*)tlvh
;
1902 delay
= (u_int32_t
)ntohl(top
->value
) & TE_EXT_MASK
;
1903 anomalous
= (u_int32_t
)ntohl(top
->value
) & TE_EXT_ANORMAL
;
1906 vty_out(vty
, " %s Average Link Delay: %d (micro-sec)\n",
1907 anomalous
? "Anomalous" : "Normal", delay
);
1909 zlog_debug(" %s Average Link Delay: %d (micro-sec)",
1910 anomalous
? "Anomalous" : "Normal", delay
);
1912 return TLV_SIZE(tlvh
);
1915 static u_int16_t
show_vty_link_subtlv_mm_delay(struct vty
*vty
,
1916 struct tlv_header
*tlvh
)
1918 struct te_link_subtlv_mm_delay
*top
;
1919 u_int32_t low
, high
;
1920 u_int32_t anomalous
;
1922 top
= (struct te_link_subtlv_mm_delay
*)tlvh
;
1923 low
= (u_int32_t
)ntohl(top
->low
) & TE_EXT_MASK
;
1924 anomalous
= (u_int32_t
)ntohl(top
->low
) & TE_EXT_ANORMAL
;
1925 high
= (u_int32_t
)ntohl(top
->high
);
1928 vty_out(vty
, " %s Min/Max Link Delay: %d/%d (micro-sec)\n",
1929 anomalous
? "Anomalous" : "Normal", low
, high
);
1931 zlog_debug(" %s Min/Max Link Delay: %d/%d (micro-sec)",
1932 anomalous
? "Anomalous" : "Normal", low
, high
);
1934 return TLV_SIZE(tlvh
);
1937 static u_int16_t
show_vty_link_subtlv_delay_var(struct vty
*vty
,
1938 struct tlv_header
*tlvh
)
1940 struct te_link_subtlv_delay_var
*top
;
1943 top
= (struct te_link_subtlv_delay_var
*)tlvh
;
1944 jitter
= (u_int32_t
)ntohl(top
->value
) & TE_EXT_MASK
;
1947 vty_out(vty
, " Delay Variation: %d (micro-sec)\n", jitter
);
1949 zlog_debug(" Delay Variation: %d (micro-sec)", jitter
);
1951 return TLV_SIZE(tlvh
);
1954 static u_int16_t
show_vty_link_subtlv_pkt_loss(struct vty
*vty
,
1955 struct tlv_header
*tlvh
)
1957 struct te_link_subtlv_pkt_loss
*top
;
1959 u_int32_t anomalous
;
1962 top
= (struct te_link_subtlv_pkt_loss
*)tlvh
;
1963 loss
= (u_int32_t
)ntohl(top
->value
) & TE_EXT_MASK
;
1964 fval
= (float)(loss
* LOSS_PRECISION
);
1965 anomalous
= (u_int32_t
)ntohl(top
->value
) & TE_EXT_ANORMAL
;
1968 vty_out(vty
, " %s Link Loss: %g (%%)\n",
1969 anomalous
? "Anomalous" : "Normal", fval
);
1971 zlog_debug(" %s Link Loss: %g (%%)",
1972 anomalous
? "Anomalous" : "Normal", fval
);
1974 return TLV_SIZE(tlvh
);
1977 static u_int16_t
show_vty_link_subtlv_res_bw(struct vty
*vty
,
1978 struct tlv_header
*tlvh
)
1980 struct te_link_subtlv_res_bw
*top
;
1983 top
= (struct te_link_subtlv_res_bw
*)tlvh
;
1984 fval
= ntohf(top
->value
);
1988 " Unidirectional Residual Bandwidth: %g (Bytes/sec)\n",
1992 " Unidirectional Residual Bandwidth: %g (Bytes/sec)",
1995 return TLV_SIZE(tlvh
);
1998 static u_int16_t
show_vty_link_subtlv_ava_bw(struct vty
*vty
,
1999 struct tlv_header
*tlvh
)
2001 struct te_link_subtlv_ava_bw
*top
;
2004 top
= (struct te_link_subtlv_ava_bw
*)tlvh
;
2005 fval
= ntohf(top
->value
);
2009 " Unidirectional Available Bandwidth: %g (Bytes/sec)\n",
2013 " Unidirectional Available Bandwidth: %g (Bytes/sec)",
2016 return TLV_SIZE(tlvh
);
2019 static u_int16_t
show_vty_link_subtlv_use_bw(struct vty
*vty
,
2020 struct tlv_header
*tlvh
)
2022 struct te_link_subtlv_use_bw
*top
;
2025 top
= (struct te_link_subtlv_use_bw
*)tlvh
;
2026 fval
= ntohf(top
->value
);
2030 " Unidirectional Utilized Bandwidth: %g (Bytes/sec)\n",
2034 " Unidirectional Utilized Bandwidth: %g (Bytes/sec)",
2037 return TLV_SIZE(tlvh
);
2040 static u_int16_t
show_vty_unknown_tlv(struct vty
*vty
, struct tlv_header
*tlvh
)
2043 vty_out(vty
, " Unknown TLV: [type(0x%x), length(0x%x)]\n",
2044 ntohs(tlvh
->type
), ntohs(tlvh
->length
));
2046 zlog_debug(" Unknown TLV: [type(0x%x), length(0x%x)]",
2047 ntohs(tlvh
->type
), ntohs(tlvh
->length
));
2049 return TLV_SIZE(tlvh
);
2052 static u_int16_t
ospf_mpls_te_show_link_subtlv(struct vty
*vty
,
2053 struct tlv_header
*tlvh0
,
2057 struct tlv_header
*tlvh
, *next
;
2058 u_int16_t sum
= subtotal
;
2060 for (tlvh
= tlvh0
; sum
< total
;
2061 tlvh
= (next
? next
: TLV_HDR_NEXT(tlvh
))) {
2063 switch (ntohs(tlvh
->type
)) {
2064 case TE_LINK_SUBTLV_LINK_TYPE
:
2065 sum
+= show_vty_link_subtlv_link_type(vty
, tlvh
);
2067 case TE_LINK_SUBTLV_LINK_ID
:
2068 sum
+= show_vty_link_subtlv_link_id(vty
, tlvh
);
2070 case TE_LINK_SUBTLV_LCLIF_IPADDR
:
2071 sum
+= show_vty_link_subtlv_lclif_ipaddr(vty
, tlvh
);
2073 case TE_LINK_SUBTLV_RMTIF_IPADDR
:
2074 sum
+= show_vty_link_subtlv_rmtif_ipaddr(vty
, tlvh
);
2076 case TE_LINK_SUBTLV_TE_METRIC
:
2077 sum
+= show_vty_link_subtlv_te_metric(vty
, tlvh
);
2079 case TE_LINK_SUBTLV_MAX_BW
:
2080 sum
+= show_vty_link_subtlv_max_bw(vty
, tlvh
);
2082 case TE_LINK_SUBTLV_MAX_RSV_BW
:
2083 sum
+= show_vty_link_subtlv_max_rsv_bw(vty
, tlvh
);
2085 case TE_LINK_SUBTLV_UNRSV_BW
:
2086 sum
+= show_vty_link_subtlv_unrsv_bw(vty
, tlvh
);
2088 case TE_LINK_SUBTLV_RSC_CLSCLR
:
2089 sum
+= show_vty_link_subtlv_rsc_clsclr(vty
, tlvh
);
2091 case TE_LINK_SUBTLV_LRRID
:
2092 sum
+= show_vty_link_subtlv_lrrid(vty
, tlvh
);
2094 case TE_LINK_SUBTLV_LLRI
:
2095 sum
+= show_vty_link_subtlv_llri(vty
, tlvh
);
2097 case TE_LINK_SUBTLV_RIP
:
2098 sum
+= show_vty_link_subtlv_rip(vty
, tlvh
);
2100 case TE_LINK_SUBTLV_RAS
:
2101 sum
+= show_vty_link_subtlv_ras(vty
, tlvh
);
2103 case TE_LINK_SUBTLV_AV_DELAY
:
2104 sum
+= show_vty_link_subtlv_av_delay(vty
, tlvh
);
2106 case TE_LINK_SUBTLV_MM_DELAY
:
2107 sum
+= show_vty_link_subtlv_mm_delay(vty
, tlvh
);
2109 case TE_LINK_SUBTLV_DELAY_VAR
:
2110 sum
+= show_vty_link_subtlv_delay_var(vty
, tlvh
);
2112 case TE_LINK_SUBTLV_PKT_LOSS
:
2113 sum
+= show_vty_link_subtlv_pkt_loss(vty
, tlvh
);
2115 case TE_LINK_SUBTLV_RES_BW
:
2116 sum
+= show_vty_link_subtlv_res_bw(vty
, tlvh
);
2118 case TE_LINK_SUBTLV_AVA_BW
:
2119 sum
+= show_vty_link_subtlv_ava_bw(vty
, tlvh
);
2121 case TE_LINK_SUBTLV_USE_BW
:
2122 sum
+= show_vty_link_subtlv_use_bw(vty
, tlvh
);
2125 sum
+= show_vty_unknown_tlv(vty
, tlvh
);
2132 static void ospf_mpls_te_show_info(struct vty
*vty
, struct ospf_lsa
*lsa
)
2134 struct lsa_header
*lsah
= (struct lsa_header
*)lsa
->data
;
2135 struct tlv_header
*tlvh
, *next
;
2136 u_int16_t sum
, total
;
2137 u_int16_t (*subfunc
)(struct vty
* vty
, struct tlv_header
* tlvh
,
2138 u_int16_t subtotal
, u_int16_t total
) = NULL
;
2141 total
= ntohs(lsah
->length
) - OSPF_LSA_HEADER_SIZE
;
2143 for (tlvh
= TLV_HDR_TOP(lsah
); sum
< total
;
2144 tlvh
= (next
? next
: TLV_HDR_NEXT(tlvh
))) {
2145 if (subfunc
!= NULL
) {
2146 sum
= (*subfunc
)(vty
, tlvh
, sum
, total
);
2147 next
= (struct tlv_header
*)((char *)tlvh
+ sum
);
2153 switch (ntohs(tlvh
->type
)) {
2154 case TE_TLV_ROUTER_ADDR
:
2155 sum
+= show_vty_router_addr(vty
, tlvh
);
2158 sum
+= show_vty_link_header(vty
, tlvh
);
2159 subfunc
= ospf_mpls_te_show_link_subtlv
;
2160 next
= TLV_DATA(tlvh
);
2163 sum
+= show_vty_unknown_tlv(vty
, tlvh
);
2170 static void ospf_mpls_te_config_write_router(struct vty
*vty
)
2173 if (OspfMplsTE
.enabled
) {
2174 vty_out(vty
, " mpls-te on\n");
2175 vty_out(vty
, " mpls-te router-address %s\n",
2176 inet_ntoa(OspfMplsTE
.router_addr
.value
));
2179 if (OspfMplsTE
.inter_as
== AS
)
2180 vty_out(vty
, " mpls-te inter-as as\n");
2181 if (OspfMplsTE
.inter_as
== Area
)
2182 vty_out(vty
, " mpls-te inter-as area %s \n",
2183 inet_ntoa(OspfMplsTE
.interas_areaid
));
2188 /*------------------------------------------------------------------------*
2189 * Followings are vty command functions.
2190 *------------------------------------------------------------------------*/
2192 DEFUN (ospf_mpls_te_on
,
2193 ospf_mpls_te_on_cmd
,
2196 "Enable the MPLS-TE functionality\n")
2198 VTY_DECLVAR_INSTANCE_CONTEXT(ospf
, ospf
);
2199 struct listnode
*node
;
2200 struct mpls_te_link
*lp
;
2202 if (OspfMplsTE
.enabled
)
2205 if (IS_DEBUG_OSPF_EVENT
)
2206 zlog_debug("MPLS-TE: OFF -> ON");
2208 OspfMplsTE
.enabled
= true;
2210 /* Reoriginate RFC3630 & RFC6827 Links */
2211 ospf_mpls_te_foreach_area(ospf_mpls_te_lsa_schedule
,
2212 REORIGINATE_THIS_LSA
);
2214 /* Reoriginate LSA if INTER-AS is always on */
2215 if (OspfMplsTE
.inter_as
!= Off
) {
2216 for (ALL_LIST_ELEMENTS_RO(OspfMplsTE
.iflist
, node
, lp
)) {
2217 if (IS_INTER_AS(lp
->type
)) {
2218 ospf_mpls_te_lsa_schedule(lp
,
2219 REORIGINATE_THIS_LSA
);
2227 DEFUN (no_ospf_mpls_te
,
2228 no_ospf_mpls_te_cmd
,
2232 "Disable the MPLS-TE functionality\n")
2234 VTY_DECLVAR_INSTANCE_CONTEXT(ospf
, ospf
);
2235 struct listnode
*node
, *nnode
;
2236 struct mpls_te_link
*lp
;
2238 if (!OspfMplsTE
.enabled
)
2241 if (IS_DEBUG_OSPF_EVENT
)
2242 zlog_debug("MPLS-TE: ON -> OFF");
2244 OspfMplsTE
.enabled
= false;
2246 for (ALL_LIST_ELEMENTS(OspfMplsTE
.iflist
, node
, nnode
, lp
))
2247 if (CHECK_FLAG(lp
->flags
, LPFLG_LSA_ENGAGED
))
2248 ospf_mpls_te_lsa_schedule(lp
, FLUSH_THIS_LSA
);
2254 DEFUN (ospf_mpls_te_router_addr
,
2255 ospf_mpls_te_router_addr_cmd
,
2256 "mpls-te router-address A.B.C.D",
2258 "Stable IP address of the advertising router\n"
2259 "MPLS-TE router address in IPv4 address format\n")
2261 VTY_DECLVAR_INSTANCE_CONTEXT(ospf
, ospf
);
2263 struct te_tlv_router_addr
*ra
= &OspfMplsTE
.router_addr
;
2264 struct in_addr value
;
2266 if (!inet_aton(argv
[idx_ipv4
]->arg
, &value
)) {
2267 vty_out(vty
, "Please specify Router-Addr by A.B.C.D\n");
2271 if (ntohs(ra
->header
.type
) == 0
2272 || ntohl(ra
->value
.s_addr
) != ntohl(value
.s_addr
)) {
2273 struct listnode
*node
, *nnode
;
2274 struct mpls_te_link
*lp
;
2275 int need_to_reoriginate
= 0;
2277 set_mpls_te_router_addr(value
);
2279 if (!OspfMplsTE
.enabled
)
2282 for (ALL_LIST_ELEMENTS(OspfMplsTE
.iflist
, node
, nnode
, lp
)) {
2283 if ((lp
->area
== NULL
) || IS_FLOOD_AS(lp
->type
))
2286 if (!CHECK_FLAG(lp
->flags
, LPFLG_LSA_ENGAGED
)) {
2287 need_to_reoriginate
= 1;
2292 for (ALL_LIST_ELEMENTS(OspfMplsTE
.iflist
, node
, nnode
, lp
)) {
2293 if ((lp
->area
== NULL
) || IS_FLOOD_AS(lp
->type
))
2296 if (need_to_reoriginate
)
2297 SET_FLAG(lp
->flags
, LPFLG_LSA_FORCED_REFRESH
);
2299 ospf_mpls_te_lsa_schedule(lp
, REFRESH_THIS_LSA
);
2302 if (need_to_reoriginate
)
2303 ospf_mpls_te_foreach_area(ospf_mpls_te_lsa_schedule
,
2304 REORIGINATE_THIS_LSA
);
2310 static int set_inter_as_mode(struct vty
*vty
, const char *mode_name
,
2311 const char *area_id
)
2313 enum inter_as_mode mode
;
2314 struct listnode
*node
;
2315 struct mpls_te_link
*lp
;
2318 if (OspfMplsTE
.enabled
) {
2320 /* Read and Check inter_as mode */
2321 if (strcmp(mode_name
, "as") == 0)
2323 else if (strcmp(mode_name
, "area") == 0) {
2325 VTY_GET_OSPF_AREA_ID(OspfMplsTE
.interas_areaid
, format
,
2329 "Unknown mode. Please choose between as or area\n");
2333 if (IS_DEBUG_OSPF_EVENT
)
2335 "MPLS-TE: Inter-AS enable with %s flooding support",
2338 /* Register new callbacks regarding the flooding scope (AS or
2340 if (ospf_mpls_te_register(mode
) < 0) {
2342 "Internal error: Unable to register Inter-AS functions\n");
2346 /* Enable mode and re-originate LSA if needed */
2347 if ((OspfMplsTE
.inter_as
== Off
)
2348 && (mode
!= OspfMplsTE
.inter_as
)) {
2349 OspfMplsTE
.inter_as
= mode
;
2350 /* Re-originate all InterAS-TEv2 LSA */
2351 for (ALL_LIST_ELEMENTS_RO(OspfMplsTE
.iflist
, node
,
2353 if (IS_INTER_AS(lp
->type
)) {
2355 lp
->type
|= FLOOD_AS
;
2357 lp
->type
|= FLOOD_AREA
;
2358 ospf_mpls_te_lsa_schedule(
2359 lp
, REORIGINATE_THIS_LSA
);
2364 "Please change Inter-AS support to disable first before going to mode %s\n",
2369 vty_out(vty
, "mpls-te has not been turned on\n");
2376 DEFUN (ospf_mpls_te_inter_as_as
,
2377 ospf_mpls_te_inter_as_cmd
,
2378 "mpls-te inter-as as",
2380 "Configure MPLS-TE Inter-AS support\n"
2381 "AS native mode self originate INTER_AS LSA with Type 11 (as flooding scope)\n")
2383 return set_inter_as_mode(vty
, "as", "");
2386 DEFUN (ospf_mpls_te_inter_as_area
,
2387 ospf_mpls_te_inter_as_area_cmd
,
2388 "mpls-te inter-as area <A.B.C.D|(0-4294967295)>",
2390 "Configure MPLS-TE Inter-AS support\n"
2391 "AREA native mode self originate INTER_AS LSA with Type 10 (area flooding scope)\n"
2392 "OSPF area ID in IP format\n"
2393 "OSPF area ID as decimal value\n")
2395 int idx_ipv4_number
= 3;
2396 return set_inter_as_mode(vty
, "area", argv
[idx_ipv4_number
]->arg
);
2399 DEFUN (no_ospf_mpls_te_inter_as
,
2400 no_ospf_mpls_te_inter_as_cmd
,
2401 "no mpls-te inter-as",
2404 "Disable MPLS-TE Inter-AS support\n")
2407 struct listnode
*node
, *nnode
;
2408 struct mpls_te_link
*lp
;
2410 if (IS_DEBUG_OSPF_EVENT
)
2411 zlog_debug("MPLS-TE: Inter-AS support OFF");
2413 if ((OspfMplsTE
.enabled
) && (OspfMplsTE
.inter_as
!= Off
)) {
2414 OspfMplsTE
.inter_as
= Off
;
2415 /* Flush all Inter-AS LSA */
2416 for (ALL_LIST_ELEMENTS(OspfMplsTE
.iflist
, node
, nnode
, lp
))
2417 if (IS_INTER_AS(lp
->type
)
2418 && CHECK_FLAG(lp
->flags
, LPFLG_LSA_ENGAGED
))
2419 ospf_mpls_te_lsa_schedule(lp
, FLUSH_THIS_LSA
);
2422 /* Deregister the Callbacks for Inter-AS suport */
2423 ospf_mpls_te_unregister();
2428 DEFUN (show_ip_ospf_mpls_te_router
,
2429 show_ip_ospf_mpls_te_router_cmd
,
2430 "show ip ospf mpls-te router",
2434 "MPLS-TE information\n"
2435 "MPLS-TE Router parameters\n")
2437 if (OspfMplsTE
.enabled
) {
2438 vty_out(vty
, "--- MPLS-TE router parameters ---\n");
2440 if (ntohs(OspfMplsTE
.router_addr
.header
.type
) != 0)
2441 show_vty_router_addr(vty
,
2442 &OspfMplsTE
.router_addr
.header
);
2444 vty_out(vty
, " N/A\n");
2449 static void show_mpls_te_link_sub(struct vty
*vty
, struct interface
*ifp
)
2451 struct mpls_te_link
*lp
;
2453 if ((OspfMplsTE
.enabled
) && HAS_LINK_PARAMS(ifp
) && !if_is_loopback(ifp
)
2455 && ((lp
= lookup_linkparams_by_ifp(ifp
)) != NULL
)) {
2456 /* Continue only if interface is not passive or support Inter-AS
2458 if (!(ospf_oi_count(ifp
) > 0)) {
2459 if (IS_INTER_AS(lp
->type
)) {
2461 "-- Inter-AS TEv2 link parameters for %s --\n",
2464 /* MPLS-TE is not activate on this interface */
2465 /* or this interface is passive and Inter-AS
2466 * TEv2 is not activate */
2468 " %s: MPLS-TE is disabled on this interface\n",
2473 vty_out(vty
, "-- MPLS-TE link parameters for %s --\n",
2477 if (TLV_TYPE(lp
->link_type
) != 0)
2478 show_vty_link_subtlv_link_type(vty
,
2479 &lp
->link_type
.header
);
2480 if (TLV_TYPE(lp
->link_id
) != 0)
2481 show_vty_link_subtlv_link_id(vty
, &lp
->link_id
.header
);
2482 if (TLV_TYPE(lp
->lclif_ipaddr
) != 0)
2483 show_vty_link_subtlv_lclif_ipaddr(
2484 vty
, &lp
->lclif_ipaddr
.header
);
2485 if (TLV_TYPE(lp
->rmtif_ipaddr
) != 0)
2486 show_vty_link_subtlv_rmtif_ipaddr(
2487 vty
, &lp
->rmtif_ipaddr
.header
);
2488 if (TLV_TYPE(lp
->rip
) != 0)
2489 show_vty_link_subtlv_rip(vty
, &lp
->rip
.header
);
2490 if (TLV_TYPE(lp
->ras
) != 0)
2491 show_vty_link_subtlv_ras(vty
, &lp
->ras
.header
);
2492 if (TLV_TYPE(lp
->te_metric
) != 0)
2493 show_vty_link_subtlv_te_metric(vty
,
2494 &lp
->te_metric
.header
);
2495 if (TLV_TYPE(lp
->max_bw
) != 0)
2496 show_vty_link_subtlv_max_bw(vty
, &lp
->max_bw
.header
);
2497 if (TLV_TYPE(lp
->max_rsv_bw
) != 0)
2498 show_vty_link_subtlv_max_rsv_bw(vty
,
2499 &lp
->max_rsv_bw
.header
);
2500 if (TLV_TYPE(lp
->unrsv_bw
) != 0)
2501 show_vty_link_subtlv_unrsv_bw(vty
,
2502 &lp
->unrsv_bw
.header
);
2503 if (TLV_TYPE(lp
->rsc_clsclr
) != 0)
2504 show_vty_link_subtlv_rsc_clsclr(vty
,
2505 &lp
->rsc_clsclr
.header
);
2506 if (TLV_TYPE(lp
->av_delay
) != 0)
2507 show_vty_link_subtlv_av_delay(vty
,
2508 &lp
->av_delay
.header
);
2509 if (TLV_TYPE(lp
->mm_delay
) != 0)
2510 show_vty_link_subtlv_mm_delay(vty
,
2511 &lp
->mm_delay
.header
);
2512 if (TLV_TYPE(lp
->delay_var
) != 0)
2513 show_vty_link_subtlv_delay_var(vty
,
2514 &lp
->delay_var
.header
);
2515 if (TLV_TYPE(lp
->pkt_loss
) != 0)
2516 show_vty_link_subtlv_pkt_loss(vty
,
2517 &lp
->pkt_loss
.header
);
2518 if (TLV_TYPE(lp
->res_bw
) != 0)
2519 show_vty_link_subtlv_res_bw(vty
, &lp
->res_bw
.header
);
2520 if (TLV_TYPE(lp
->ava_bw
) != 0)
2521 show_vty_link_subtlv_ava_bw(vty
, &lp
->ava_bw
.header
);
2522 if (TLV_TYPE(lp
->use_bw
) != 0)
2523 show_vty_link_subtlv_use_bw(vty
, &lp
->use_bw
.header
);
2524 vty_out(vty
, "---------------\n\n");
2526 vty_out(vty
, " %s: MPLS-TE is disabled on this interface\n",
2533 DEFUN (show_ip_ospf_mpls_te_link
,
2534 show_ip_ospf_mpls_te_link_cmd
,
2535 "show ip ospf [vrf <NAME|all>] mpls-te interface [INTERFACE]",
2541 "MPLS-TE information\n"
2542 "Interface information\n"
2546 int idx_interface
= 5;
2547 struct interface
*ifp
;
2548 struct listnode
*node
;
2549 char *vrf_name
= NULL
;
2553 struct ospf
*ospf
= NULL
;
2555 if (argv_find(argv
, argc
, "vrf", &idx_vrf
)) {
2556 vrf_name
= argv
[idx_vrf
+ 1]->arg
;
2557 all_vrf
= strmatch(vrf_name
, "all");
2560 /* vrf input is provided could be all or specific vrf*/
2563 for (ALL_LIST_ELEMENTS_RO(om
->ospf
, node
, ospf
)) {
2564 if (!ospf
->oi_running
)
2566 vrf
= vrf_lookup_by_id(ospf
->vrf_id
);
2567 FOR_ALL_INTERFACES (vrf
, ifp
)
2568 show_mpls_te_link_sub(vty
, ifp
);
2572 ospf
= ospf_lookup_by_inst_name(inst
, vrf_name
);
2573 if (ospf
== NULL
|| !ospf
->oi_running
)
2575 vrf
= vrf_lookup_by_id(ospf
->vrf_id
);
2576 FOR_ALL_INTERFACES (vrf
, ifp
)
2577 show_mpls_te_link_sub(vty
, ifp
);
2580 /* Show All Interfaces. */
2582 for (ALL_LIST_ELEMENTS_RO(om
->ospf
, node
, ospf
)) {
2583 if (!ospf
->oi_running
)
2585 vrf
= vrf_lookup_by_id(ospf
->vrf_id
);
2586 FOR_ALL_INTERFACES (vrf
, ifp
)
2587 show_mpls_te_link_sub(vty
, ifp
);
2590 /* Interface name is specified. */
2592 ifp
= if_lookup_by_name_all_vrf(argv
[idx_interface
]->arg
);
2594 vty_out(vty
, "No such interface name\n");
2596 show_mpls_te_link_sub(vty
, ifp
);
2602 static void ospf_mpls_te_register_vty(void)
2604 install_element(VIEW_NODE
, &show_ip_ospf_mpls_te_router_cmd
);
2605 install_element(VIEW_NODE
, &show_ip_ospf_mpls_te_link_cmd
);
2607 install_element(OSPF_NODE
, &ospf_mpls_te_on_cmd
);
2608 install_element(OSPF_NODE
, &no_ospf_mpls_te_cmd
);
2609 install_element(OSPF_NODE
, &ospf_mpls_te_router_addr_cmd
);
2610 install_element(OSPF_NODE
, &ospf_mpls_te_inter_as_cmd
);
2611 install_element(OSPF_NODE
, &ospf_mpls_te_inter_as_area_cmd
);
2612 install_element(OSPF_NODE
, &no_ospf_mpls_te_inter_as_cmd
);