From 4bbbd1f6b3465b10e868fbc6fe27a82aea448b4b Mon Sep 17 00:00:00 2001 From: Donald Sharp Date: Tue, 9 Aug 2022 09:22:43 -0400 Subject: [PATCH] zebra: Explicitly call out the correct queue name There were more than a few places where the NHG meta queue was not being explicitly called out. Let's be consistent and use the same nomenclature as much as possible when talking about metaQ's. Signed-off-by: Donald Sharp --- zebra/zebra_rib.c | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/zebra/zebra_rib.c b/zebra/zebra_rib.c index d0babbb9e4..76c7a05119 100644 --- a/zebra/zebra_rib.c +++ b/zebra/zebra_rib.c @@ -119,7 +119,8 @@ static const struct { /* no entry/default: 150 */ }; -/* EVPN/VXLAN subqueue is number 1 */ +/* Meta Q's specific names */ +#define META_QUEUE_NHG 0 #define META_QUEUE_EVPN 1 /* Wrapper struct for nhg workqueue items; a 'ctx' is an incoming update @@ -167,9 +168,9 @@ struct wq_evpn_wrapper { static const char *subqueue2str(uint8_t index) { switch (index) { - case 0: + case META_QUEUE_NHG: return "NHG Objects"; - case 1: + case META_QUEUE_EVPN: return "EVPN/VxLan Objects"; case 2: return "Connected Routes"; @@ -2407,7 +2408,7 @@ static void process_subq_nhg(struct listnode *lnode) struct nhg_ctx *ctx; struct nhg_hash_entry *nhe, *newnhe; struct wq_nhg_wrapper *w; - uint8_t qindex = route_info[ZEBRA_ROUTE_NHG].meta_q_map; + uint8_t qindex = META_QUEUE_NHG; w = listgetdata(lnode); @@ -2505,7 +2506,7 @@ static unsigned int process_subq(struct list *subq, uint8_t qindex) if (qindex == META_QUEUE_EVPN) process_subq_evpn(lnode); - else if (qindex == route_info[ZEBRA_ROUTE_NHG].meta_q_map) + else if (qindex == META_QUEUE_NHG) process_subq_nhg(lnode); else process_subq_route(lnode, qindex); @@ -2613,7 +2614,7 @@ static int rib_meta_queue_add(struct meta_queue *mq, void *data) static int rib_meta_queue_nhg_ctx_add(struct meta_queue *mq, void *data) { struct nhg_ctx *ctx = NULL; - uint8_t qindex = route_info[ZEBRA_ROUTE_NHG].meta_q_map; + uint8_t qindex = META_QUEUE_NHG; struct wq_nhg_wrapper *w; ctx = (struct nhg_ctx *)data; @@ -2639,7 +2640,7 @@ static int rib_meta_queue_nhg_ctx_add(struct meta_queue *mq, void *data) static int rib_meta_queue_nhg_add(struct meta_queue *mq, void *data) { struct nhg_hash_entry *nhe = NULL; - uint8_t qindex = route_info[ZEBRA_ROUTE_NHG].meta_q_map; + uint8_t qindex = META_QUEUE_NHG; struct wq_nhg_wrapper *w; nhe = (struct nhg_hash_entry *)data; @@ -2996,7 +2997,7 @@ void meta_queue_free(struct meta_queue *mq) for (i = 0; i < MQ_SIZE; i++) { /* Some subqueues may need cleanup - nhgs for example */ - if (i == route_info[ZEBRA_ROUTE_NHG].meta_q_map) + if (i == META_QUEUE_NHG) nhg_meta_queue_free(mq->subq[i]); else if (i == META_QUEUE_EVPN) evpn_meta_queue_free(mq->subq[i]); @@ -3027,8 +3028,7 @@ void rib_meta_queue_free_vrf(struct meta_queue *mq, struct zebra_vrf *zvrf) XFREE(MTYPE_WQ_WRAPPER, w); del = true; } - } else if (i == - route_info[ZEBRA_ROUTE_NHG].meta_q_map) { + } else if (i == META_QUEUE_NHG) { struct wq_nhg_wrapper *w = data; if (w->type == WQ_NHG_WRAPPER_TYPE_CTX &&