[fpmsyncd]: Add unit tests for SRv6 local SIDs

* Added a unit test to check that fpmsyncd updates the APP_DB correctly
when it receives an SRv6 Local SID bound to the End.DT4 behavior
(`RecevingRouteWithSRv6LocalSIDEndDT4`).
* Added a unit test to check that fpmsyncd updates the APP_DB correctly
when it receives an SRv6 Local SID bound to the End.DT6 behavior
(`RecevingRouteWithSRv6LocalSIDEndDT6`).
* Added a unit test to check that fpmsyncd updates the APP_DB correctly
when it receives an SRv6 Local SID bound to the End.DT46 behavior
(`RecevingRouteWithSRv6LocalSIDEndDT46`).
* Added a unit test to check that fpmsyncd updates the APP_DB correctly
when it receives an SRv6 Local SID bound to the uDT4 behavior
(`RecevingRouteWithSRv6LocalSIDUDT4`).
* Added a unit test to check that fpmsyncd updates the APP_DB correctly
when it receives an SRv6 Local SID bound to the uDT6 behavior
(`RecevingRouteWithSRv6LocalSIDUDT6`).
* Added a unit test to check that fpmsyncd updates the APP_DB correctly
when it receives an SRv6 Local SID bound to the uDT46 behavior
(`RecevingRouteWithSRv6LocalSIDUDT46`).

Signed-off-by: Carmine Scarpitta <carmine.scarpitta@uniroma2.it>

tests/mock_tests/Makefile.am

@@ -170,6 +170,7 @@ tests_intfmgrd_LDADD = $(LDADD_GTEST) $(LDADD_SAI) -lnl-genl-3 -lhiredis -lhired
 ## fpmsyncd unit tests
 
 tests_fpmsyncd_SOURCES = fpmsyncd/receive_srv6_steer_routes_ut.cpp \
+                         fpmsyncd/receive_srv6_localsids_ut.cpp \
                          fpmsyncd/ut_helpers_fpmsyncd.cpp \
                          $(top_srcdir)/fpmsyncd/routesync.cpp \
                          $(top_srcdir)/fpmsyncd/fpmlink.cpp \

tests/mock_tests/fpmsyncd/receive_srv6_localsids_ut.cpp

@@ -0,0 +1,357 @@
+#include "ut_helpers_fpmsyncd.h"
+#include "gtest/gtest.h"
+#include <gmock/gmock.h>
+#include "mock_table.h"
+#include <net/if.h>
+#include <linux/netlink.h>
+#include <linux/rtnetlink.h>
+#include "ipaddress.h"
+
+#define private public // Need to modify internal cache
+#include "fpmlink.h"
+#include "routesync.h"
+#undef private
+
+using namespace swss;
+using namespace testing;
+
+/*
+Test Fixture 
+*/
+namespace ut_fpmsyncd
+{
+    struct FpmSyncdSRv6LocalSIDsTest : public ::testing::Test
+    {
+        std::shared_ptr<swss::DBConnector> m_app_db;
+        std::shared_ptr<swss::RedisPipeline> pipeline;
+        std::shared_ptr<RouteSync> m_routeSync;
+        std::shared_ptr<FpmLink> m_fpmLink;
+        std::shared_ptr<swss::Table> m_srv6LocalSidTable;
+
+        virtual void SetUp() override
+        {
+            testing_db::reset();
+
+            m_app_db = std::make_shared<swss::DBConnector>("APPL_DB", 0);
+
+            /* Construct dependencies */
+
+            /*  1) RouteSync */
+            pipeline = std::make_shared<swss::RedisPipeline>(m_app_db.get());
+            m_routeSync = std::make_shared<RouteSync>(pipeline.get());
+
+            /* 2) FpmLink */
+            m_fpmLink = std::make_shared<FpmLink>(m_routeSync.get());
+
+            /* 3) SRV6_MY_SID_TABLE in APP_DB */
+            m_srv6LocalSidTable = std::make_shared<swss::Table>(m_app_db.get(), APP_SRV6_MY_SID_TABLE_NAME);
+        }
+
+        virtual void TearDown() override
+        {
+        }
+    };
+}
+
+namespace ut_fpmsyncd
+{
+    /* Test Receiving a route containing an SRv6 Local SID nexthop bound to the End.DT4 behavior */
+    TEST_F(FpmSyncdSRv6LocalSIDsTest, RecevingRouteWithSRv6LocalSIDEndDT4)
+    {
+        ASSERT_NE(m_routeSync, nullptr);
+
+        /* Create a Netlink object containing an SRv6 Local SID */
+        IpAddress _localsid = IpAddress("fc00:0:1:1::");
+        uint8_t _block_len = 32;
+        uint8_t _node_len = 16;
+        uint8_t _func_len = 16;
+        uint8_t _arg_len = 0;
+        uint32_t _action = SRV6_LOCALSID_ACTION_END_DT4;
+        char *_vrf = "Vrf10";
+
+        struct nlmsg *nl_obj = create_srv6_localsid_nlmsg(RTM_NEWROUTE, &_localsid, _block_len, _node_len, _func_len, _arg_len, _action, _vrf);
+        if (!nl_obj)
+            printf("Error\n\n");
+
+        /* Send the Netlink object to the FpmLink */
+        m_fpmLink->processRawMsg(&nl_obj->n);
+
+        /* Check that fpmsyncd created the correct entries in APP_DB */
+        std::string block_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "block_len", block_len), true);
+        ASSERT_EQ(block_len, "32");
+
+        std::string node_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "node_len", node_len), true);
+        ASSERT_EQ(node_len, "16");
+
+        std::string func_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "func_len", func_len), true);
+        ASSERT_EQ(func_len, "16");
+
+        std::string arg_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "arg_len", arg_len), true);
+        ASSERT_EQ(arg_len, "0");
+
+        std::string action;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "action", action), true);
+        ASSERT_EQ(action, "end.dt4");
+
+        std::string vrf;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "vrf", vrf), true);
+        ASSERT_EQ(vrf, "Vrf10");
+
+        /* Destroy the Netlink object and free the memory */
+        free_nlobj(nl_obj);
+    }
+
+    /* Test Receiving a route containing an SRv6 Local SID nexthop bound to the End.DT6 behavior */
+    TEST_F(FpmSyncdSRv6LocalSIDsTest, RecevingRouteWithSRv6LocalSIDEndDT6)
+    {
+        ASSERT_NE(m_routeSync, nullptr);
+
+        /* Create a Netlink object containing an SRv6 Local SID */
+        IpAddress _localsid = IpAddress("fc00:0:1:1::");
+        uint8_t _block_len = 32;
+        uint8_t _node_len = 16;
+        uint8_t _func_len = 16;
+        uint8_t _arg_len = 0;
+        uint32_t _action = SRV6_LOCALSID_ACTION_END_DT6;
+        char *_vrf = "Vrf10";
+
+        struct nlmsg *nl_obj = create_srv6_localsid_nlmsg(RTM_NEWROUTE, &_localsid, _block_len, _node_len, _func_len, _arg_len, _action, _vrf);
+        if (!nl_obj)
+            printf("Error\n\n");
+
+        /* Send the Netlink object to the FpmLink */
+        m_fpmLink->processRawMsg(&nl_obj->n);
+
+        /* Check that fpmsyncd created the correct entries in APP_DB */
+        std::string block_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "block_len", block_len), true);
+        ASSERT_EQ(block_len, "32");
+
+        std::string node_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "node_len", node_len), true);
+        ASSERT_EQ(node_len, "16");
+
+        std::string func_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "func_len", func_len), true);
+        ASSERT_EQ(func_len, "16");
+
+        std::string arg_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "arg_len", arg_len), true);
+        ASSERT_EQ(arg_len, "0");
+
+        std::string action;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "action", action), true);
+        ASSERT_EQ(action, "end.dt6");
+
+        std::string vrf;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "vrf", vrf), true);
+        ASSERT_EQ(vrf, "Vrf10");
+
+        /* Destroy the Netlink object and free the memory */
+        free_nlobj(nl_obj);
+    }
+
+    /* Test Receiving a route containing an SRv6 Local SID nexthop bound to the End.DT46 behavior */
+    TEST_F(FpmSyncdSRv6LocalSIDsTest, RecevingRouteWithSRv6LocalSIDEndDT46)
+    {
+        ASSERT_NE(m_routeSync, nullptr);
+
+        /* Create a Netlink object containing an SRv6 Local SID */
+        IpAddress _localsid = IpAddress("fc00:0:1:1::");
+        uint8_t _block_len = 32;
+        uint8_t _node_len = 16;
+        uint8_t _func_len = 16;
+        uint8_t _arg_len = 0;
+        uint32_t _action = SRV6_LOCALSID_ACTION_END_DT46;
+        char *_vrf = "Vrf10";
+
+        struct nlmsg *nl_obj = create_srv6_localsid_nlmsg(RTM_NEWROUTE, &_localsid, _block_len, _node_len, _func_len, _arg_len, _action, _vrf);
+        if (!nl_obj)
+            printf("Error\n\n");
+
+        /* Send the Netlink object to the FpmLink */
+        m_fpmLink->processRawMsg(&nl_obj->n);
+
+        /* Check that fpmsyncd created the correct entries in APP_DB */
+        std::string block_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "block_len", block_len), true);
+        ASSERT_EQ(block_len, "32");
+
+        std::string node_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "node_len", node_len), true);
+        ASSERT_EQ(node_len, "16");
+
+        std::string func_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "func_len", func_len), true);
+        ASSERT_EQ(func_len, "16");
+
+        std::string arg_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "arg_len", arg_len), true);
+        ASSERT_EQ(arg_len, "0");
+
+        std::string action;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "action", action), true);
+        ASSERT_EQ(action, "end.dt46");
+
+        std::string vrf;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "vrf", vrf), true);
+        ASSERT_EQ(vrf, "Vrf10");
+
+        /* Destroy the Netlink object and free the memory */
+        free_nlobj(nl_obj);
+    }
+
+    /* Test Receiving a route containing an SRv6 Local SID nexthop bound to the uDT4 behavior */
+    TEST_F(FpmSyncdSRv6LocalSIDsTest, RecevingRouteWithSRv6LocalSIDUDT4)
+    {
+        ASSERT_NE(m_routeSync, nullptr);
+
+        /* Create a Netlink object containing an SRv6 Local SID */
+        IpAddress _localsid = IpAddress("fc00:0:1:1::");
+        uint8_t _block_len = 32;
+        uint8_t _node_len = 16;
+        uint8_t _func_len = 16;
+        uint8_t _arg_len = 0;
+        uint32_t _action = SRV6_LOCALSID_ACTION_UDT4;
+        char *_vrf = "Vrf10";
+
+        struct nlmsg *nl_obj = create_srv6_localsid_nlmsg(RTM_NEWROUTE, &_localsid, _block_len, _node_len, _func_len, _arg_len, _action, _vrf);
+        if (!nl_obj)
+            printf("Error\n\n");
+
+        /* Send the Netlink object to the FpmLink */
+        m_fpmLink->processRawMsg(&nl_obj->n);
+
+        /* Check that fpmsyncd created the correct entries in APP_DB */
+        std::string block_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "block_len", block_len), true);
+        ASSERT_EQ(block_len, "32");
+
+        std::string node_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "node_len", node_len), true);
+        ASSERT_EQ(node_len, "16");
+
+        std::string func_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "func_len", func_len), true);
+        ASSERT_EQ(func_len, "16");
+
+        std::string arg_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "arg_len", arg_len), true);
+        ASSERT_EQ(arg_len, "0");
+
+        std::string action;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "action", action), true);
+        ASSERT_EQ(action, "udt4");
+
+        std::string vrf;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "vrf", vrf), true);
+        ASSERT_EQ(vrf, "Vrf10");
+
+        /* Destroy the Netlink object and free the memory */
+        free_nlobj(nl_obj);
+    }
+
+    /* Test Receiving a route containing an SRv6 Local SID nexthop bound to the uDT6 behavior */
+    TEST_F(FpmSyncdSRv6LocalSIDsTest, RecevingRouteWithSRv6LocalSIDUDT6)
+    {
+        ASSERT_NE(m_routeSync, nullptr);
+
+        /* Create a Netlink object containing an SRv6 Local SID */
+        IpAddress _localsid = IpAddress("fc00:0:1:1::");
+        uint8_t _block_len = 32;
+        uint8_t _node_len = 16;
+        uint8_t _func_len = 16;
+        uint8_t _arg_len = 0;
+        uint32_t _action = SRV6_LOCALSID_ACTION_UDT6;
+        char *_vrf = "Vrf10";
+
+        struct nlmsg *nl_obj = create_srv6_localsid_nlmsg(RTM_NEWROUTE, &_localsid, _block_len, _node_len, _func_len, _arg_len, _action, _vrf);
+        if (!nl_obj)
+            printf("Error\n\n");
+
+        /* Send the Netlink object to the FpmLink */
+        m_fpmLink->processRawMsg(&nl_obj->n);
+
+        /* Check that fpmsyncd created the correct entries in APP_DB */
+        std::string block_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "block_len", block_len), true);
+        ASSERT_EQ(block_len, "32");
+
+        std::string node_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "node_len", node_len), true);
+        ASSERT_EQ(node_len, "16");
+
+        std::string func_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "func_len", func_len), true);
+        ASSERT_EQ(func_len, "16");
+
+        std::string arg_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "arg_len", arg_len), true);
+        ASSERT_EQ(arg_len, "0");
+
+        std::string action;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "action", action), true);
+        ASSERT_EQ(action, "udt6");
+
+        std::string vrf;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "vrf", vrf), true);
+        ASSERT_EQ(vrf, "Vrf10");
+
+        /* Destroy the Netlink object and free the memory */
+        free_nlobj(nl_obj);
+    }
+
+    /* Test Receiving a route containing an SRv6 Local SID nexthop bound to the uDT46 behavior */
+    TEST_F(FpmSyncdSRv6LocalSIDsTest, RecevingRouteWithSRv6LocalSIDUDT46)
+    {
+        ASSERT_NE(m_routeSync, nullptr);
+
+        /* Create a Netlink object containing an SRv6 Local SID */
+        IpAddress _localsid = IpAddress("fc00:0:1:1::");
+        uint8_t _block_len = 32;
+        uint8_t _node_len = 16;
+        uint8_t _func_len = 16;
+        uint8_t _arg_len = 0;
+        uint32_t _action = SRV6_LOCALSID_ACTION_UDT46;
+        char *_vrf = "Vrf10";
+
+        struct nlmsg *nl_obj = create_srv6_localsid_nlmsg(RTM_NEWROUTE, &_localsid, _block_len, _node_len, _func_len, _arg_len, _action, _vrf);
+        if (!nl_obj)
+            printf("Error\n\n");
+
+        /* Send the Netlink object to the FpmLink */
+        m_fpmLink->processRawMsg(&nl_obj->n);
+
+        /* Check that fpmsyncd created the correct entries in APP_DB */
+        std::string block_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "block_len", block_len), true);
+        ASSERT_EQ(block_len, "32");
+
+        std::string node_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "node_len", node_len), true);
+        ASSERT_EQ(node_len, "16");
+
+        std::string func_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "func_len", func_len), true);
+        ASSERT_EQ(func_len, "16");
+
+        std::string arg_len;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "arg_len", arg_len), true);
+        ASSERT_EQ(arg_len, "0");
+
+        std::string action;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "action", action), true);
+        ASSERT_EQ(action, "udt46");
+
+        std::string vrf;
+        ASSERT_EQ(m_srv6LocalSidTable->hget("fc00:0:1:1::", "vrf", vrf), true);
+        ASSERT_EQ(vrf, "Vrf10");
+
+        /* Destroy the Netlink object and free the memory */
+        free_nlobj(nl_obj);
+    }
+}