rte_rib_get_nxt() and rte_rib6_get_nxt() skip the exact match
top-level route when iterating subroutes. This is the expected behavior
in most cases but some users need the full subtree including the root.

Add a RTE_RIB_GET_NXT_ALL_TOP (and RTE_RIB6_GET_NXT_ALL_TOP) mode
that uses >= instead of > when comparing depths so that the top-level
route is returned as well.

Signed-off-by: Robin Jarry <[email protected]>
---
 app/test/test_rib.c                    | 16 ++++++++++++++++
 app/test/test_rib6.c                   | 16 ++++++++++++++++
 doc/guides/rel_notes/release_26_11.rst |  6 ++++++
 lib/rib/rte_rib.c                      | 16 ++++++++++++----
 lib/rib/rte_rib.h                      |  5 +++++
 lib/rib/rte_rib6.c                     | 16 ++++++++++++----
 lib/rib/rte_rib6.h                     |  6 ++++++
 7 files changed, 73 insertions(+), 8 deletions(-)

diff --git a/app/test/test_rib.c b/app/test/test_rib.c
index a4a683140df3..f56490e67ec0 100644
--- a/app/test/test_rib.c
+++ b/app/test/test_rib.c
@@ -300,6 +300,7 @@ test_tree_traversal(void)
        uint32_t ip1 = RTE_IPV4(10, 10, 10, 0);
        uint32_t ip2 = RTE_IPV4(10, 10, 130, 80);
        uint8_t depth = 30;
+       unsigned int num;
 
        config.max_nodes = MAX_RULES;
        config.ext_sz = 0;
@@ -313,11 +314,26 @@ test_tree_traversal(void)
        node = rte_rib_insert(rib, ip2, depth);
        RTE_TEST_ASSERT(node != NULL, "Failed to insert rule\n");
 
+       node = rte_rib_insert(rib, 0, 0);
+       RTE_TEST_ASSERT(node != NULL, "Failed to insert default rule\n");
+
        node = NULL;
        node = rte_rib_get_nxt(rib, RTE_IPV4(10, 10, 130, 0), 24, node,
                        RTE_RIB_GET_NXT_ALL);
        RTE_TEST_ASSERT(node != NULL, "Failed to get rib_node\n");
 
+       num = 0;
+       node = NULL;
+       while ((node = rte_rib_get_nxt(rib, 0, 0, node, RTE_RIB_GET_NXT_ALL)) 
!= NULL)
+               num++;
+       RTE_TEST_ASSERT(num == 2, "Invalid number of routes\n");
+
+       num = 0;
+       node = NULL;
+       while ((node = rte_rib_get_nxt(rib, 0, 0, node, 
RTE_RIB_GET_NXT_ALL_TOP)) != NULL)
+               num++;
+       RTE_TEST_ASSERT(num == 3, "Default route not returned by 
rte_rib_get_nxt\n");
+
        rte_rib_free(rib);
 
        return TEST_SUCCESS;
diff --git a/app/test/test_rib6.c b/app/test/test_rib6.c
index 0295a9640cfa..e97d2f49df1d 100644
--- a/app/test/test_rib6.c
+++ b/app/test/test_rib6.c
@@ -300,7 +300,9 @@ test_tree_traversal(void)
        struct rte_ipv6_addr ip = RTE_IPV6(0x0a00, 0x0282, 0, 0, 0, 0, 0, 0);
        struct rte_ipv6_addr ip1 = RTE_IPV6(0x0a00, 0x0200, 0, 0, 0, 0, 0, 0);
        struct rte_ipv6_addr ip2 = RTE_IPV6(0x0a00, 0x0282, 0, 0, 0, 0, 0, 
0x0050);
+       struct rte_ipv6_addr unspec = RTE_IPV6(0, 0, 0, 0, 0, 0, 0, 0);
        uint8_t depth = 126;
+       unsigned int num;
 
        config.max_nodes = MAX_RULES;
        config.ext_sz = 0;
@@ -312,11 +314,25 @@ test_tree_traversal(void)
        RTE_TEST_ASSERT(node != NULL, "Failed to insert rule\n");
        node = rte_rib6_insert(rib, &ip2, depth);
        RTE_TEST_ASSERT(node != NULL, "Failed to insert rule\n");
+       node = rte_rib6_insert(rib, &unspec, 0);
+       RTE_TEST_ASSERT(node != NULL, "Failed to insert default route\n");
 
        node = NULL;
        node = rte_rib6_get_nxt(rib, &ip, 32, node, RTE_RIB6_GET_NXT_ALL);
        RTE_TEST_ASSERT(node != NULL, "Failed to get rib_node\n");
 
+       num = 0;
+       node = NULL;
+       while ((node = rte_rib6_get_nxt(rib, &unspec, 0, node, 
RTE_RIB6_GET_NXT_ALL)) != NULL)
+               num++;
+       RTE_TEST_ASSERT(num == 2, "Invalid number of routes\n");
+
+       num = 0;
+       node = NULL;
+       while ((node = rte_rib6_get_nxt(rib, &unspec, 0, node, 
RTE_RIB6_GET_NXT_ALL_TOP)) != NULL)
+               num++;
+       RTE_TEST_ASSERT(num == 3, "Default route not returned by 
rte_rib6_get_nxt\n");
+
        rte_rib6_free(rib);
 
        return TEST_SUCCESS;
diff --git a/doc/guides/rel_notes/release_26_11.rst 
b/doc/guides/rel_notes/release_26_11.rst
index 030bd84cea04..5976db81157c 100644
--- a/doc/guides/rel_notes/release_26_11.rst
+++ b/doc/guides/rel_notes/release_26_11.rst
@@ -138,6 +138,12 @@ New Features
   Added ``rte_bbdev_queue_stats_get()`` function to retrieve statistics
   for a specific queue, complementing the existing device-level statistics API.
 
+* **Added a new mode for RIB and RIB6 traversal.**
+
+  ``rte_rib{,6}_get_nxt()`` now accept a new mode of traversal: 
``RTE_RIB{,6}_GET_NXT_ALL_TOP``
+  which behaves like ``RTE_RIB{,6}_GET_NXT_ALL`` but also returns the 
top-level exact-match
+  route, if any.
+
 
 Removed Items
 -------------
diff --git a/lib/rib/rte_rib.c b/lib/rib/rte_rib.c
index c1dcb054d4e5..e15196f01954 100644
--- a/lib/rib/rte_rib.c
+++ b/lib/rib/rte_rib.c
@@ -167,6 +167,14 @@ rte_rib_lookup_exact(struct rte_rib *rib, uint32_t ip, 
uint8_t depth)
        return __rib_lookup_exact(rib, ip, depth);
 }
 
+static bool
+depth_match(struct rte_rib_node *node, uint8_t depth, enum 
rte_rib_get_nxt_mode mode)
+{
+       if (mode == RTE_RIB_GET_NXT_ALL_TOP)
+               return node->depth >= depth;
+       return node->depth > depth;
+}
+
 /*
  *  Traverses on subtree and retrieves more specific routes
  *  for a given in args ip/depth prefix
@@ -194,16 +202,16 @@ rte_rib_get_nxt(struct rte_rib *rib, uint32_t ip,
                                (tmp->parent->right == NULL))) {
                        tmp = tmp->parent;
                        if (is_valid_node(tmp) &&
-                                       (is_covered(tmp->ip, ip, depth) &&
-                                       (tmp->depth > depth)))
+                                       is_covered(tmp->ip, ip, depth) &&
+                                       depth_match(tmp, depth, mode))
                                return tmp;
                }
                tmp = (tmp->parent) ? tmp->parent->right : NULL;
        }
        while (tmp) {
                if (is_valid_node(tmp) &&
-                               (is_covered(tmp->ip, ip, depth) &&
-                               (tmp->depth > depth))) {
+                               is_covered(tmp->ip, ip, depth) &&
+                               depth_match(tmp, depth, mode)) {
                        prev = tmp;
                        if (mode == RTE_RIB_GET_NXT_COVER)
                                return prev;
diff --git a/lib/rib/rte_rib.h b/lib/rib/rte_rib.h
index bba9ad98823f..e23624ae39a0 100644
--- a/lib/rib/rte_rib.h
+++ b/lib/rib/rte_rib.h
@@ -31,6 +31,8 @@ enum rte_rib_get_nxt_mode {
        RTE_RIB_GET_NXT_ALL,
        /** get first matched subroutes in a RIB tree, excluding any exact 
match top-level route */
        RTE_RIB_GET_NXT_COVER,
+       /** get all subroutes in a RIB tree, including the exact match 
top-level route, if any */
+       RTE_RIB_GET_NXT_ALL_TOP,
 };
 
 struct rte_rib;
@@ -125,6 +127,9 @@ rte_rib_lookup_exact(struct rte_rib *rib, uint32_t ip, 
uint8_t depth);
  *   get all prefixes from subtrie
  *  -RTE_RIB_GET_NXT_COVER
  *   get only first more specific prefix even if it have more specifics
+ *  -RTE_RIB_GET_NXT_ALL_TOP
+ *   get all prefixes from subtrie including the ip/depth prefix itself
+ *   if present. Top prefix is returned last.
  * @return
  *  pointer to the next more specific prefix
  *  NULL if there is no prefixes left
diff --git a/lib/rib/rte_rib6.c b/lib/rib/rte_rib6.c
index 41561c4291e3..8384bc58cd63 100644
--- a/lib/rib/rte_rib6.c
+++ b/lib/rib/rte_rib6.c
@@ -187,6 +187,14 @@ rte_rib6_lookup_exact(struct rte_rib6 *rib,
        return NULL;
 }
 
+static bool
+depth_match(struct rte_rib6_node *node, uint8_t depth, enum 
rte_rib6_get_nxt_mode mode)
+{
+       if (mode == RTE_RIB6_GET_NXT_ALL_TOP)
+               return node->depth >= depth;
+       return node->depth > depth;
+}
+
 /*
  *  Traverses on subtree and retrieves more specific routes
  *  for a given in args ip/depth prefix
@@ -219,16 +227,16 @@ rte_rib6_get_nxt(struct rte_rib6 *rib,
                                (tmp->parent->right == NULL))) {
                        tmp = tmp->parent;
                        if (is_valid_node(tmp) &&
-                                       (rte_ipv6_addr_eq_prefix(&tmp->ip, 
&tmp_ip, depth) &&
-                                       (tmp->depth > depth)))
+                                       rte_ipv6_addr_eq_prefix(&tmp->ip, 
&tmp_ip, depth) &&
+                                       depth_match(tmp, depth, mode))
                                return tmp;
                }
                tmp = (tmp->parent != NULL) ? tmp->parent->right : NULL;
        }
        while (tmp) {
                if (is_valid_node(tmp) &&
-                               (rte_ipv6_addr_eq_prefix(&tmp->ip, &tmp_ip, 
depth) &&
-                               (tmp->depth > depth))) {
+                               rte_ipv6_addr_eq_prefix(&tmp->ip, &tmp_ip, 
depth) &&
+                               depth_match(tmp, depth, mode)) {
                        prev = tmp;
                        if (mode == RTE_RIB6_GET_NXT_COVER)
                                return prev;
diff --git a/lib/rib/rte_rib6.h b/lib/rib/rte_rib6.h
index 1a013e8fb4aa..a0a3ae98dc47 100644
--- a/lib/rib/rte_rib6.h
+++ b/lib/rib/rte_rib6.h
@@ -29,6 +29,8 @@ enum rte_rib6_get_nxt_mode {
        RTE_RIB6_GET_NXT_ALL,
        /** get first matched subroutes in a RIB tree, excluding any exact 
match top-level route */
        RTE_RIB6_GET_NXT_COVER,
+       /** get all subroutes in a RIB tree, including the exact match 
top-level route, if any */
+       RTE_RIB6_GET_NXT_ALL_TOP,
 };
 
 struct rte_rib6;
@@ -110,6 +112,10 @@ rte_rib6_lookup_exact(struct rte_rib6 *rib,
  *   get all prefixes from subtrie
  *  -RTE_RIB6_GET_NXT_COVER
  *   get only first more specific prefix even if it have more specifics
+ *  -RTE_RIB6_GET_NXT_ALL_TOP
+ *   get all prefixes from the subtrie, including the ip/depth prefix itself
+ *   if present. Top prefix is returned last.
+ *
  * @return
  *  pointer to the next more specific prefix
  *  NULL if there is no prefixes left
-- 
2.55.0

Reply via email to