-
Notifications
You must be signed in to change notification settings - Fork 516
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[fpmsyncd]: Add unit tests for SRv6 steer routes
* Added a unit test to check that fpmsyncd updates the APP_DB correctly when it receives an SRv6 steer route with an IPv4 destination prefix (`RecevingSRv6SteerRoutesWithIPv4Prefix`). * Added a unit test to check that fpmsyncd updates the APP_DB correctly when it receives an SRv6 steer route with an IPv6 destination prefix (`RecevingSRv6SteerRoutesWithIPv6Prefix`). Signed-off-by: Carmine Scarpitta <carmine.scarpitta@uniroma2.it>
- Loading branch information
1 parent
f50814e
commit f9a7cdf
Showing
2 changed files
with
139 additions
and
2 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
118 changes: 118 additions & 0 deletions
118
tests/mock_tests/fpmsyncd/receive_srv6_steer_routes_ut.cpp
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,118 @@ | ||
| #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" | ||
| #include "ipprefix.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 FpmSyncdSRv6RoutesTest : 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_routeTable; | ||
|
|
||
| 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) ROUTE_TABLE in APP_DB */ | ||
| m_routeTable = std::make_shared<swss::Table>(m_app_db.get(), APP_ROUTE_TABLE_NAME); | ||
| } | ||
|
|
||
| virtual void TearDown() override | ||
| { | ||
| } | ||
| }; | ||
| } | ||
|
|
||
| namespace ut_fpmsyncd | ||
| { | ||
| /* Test Receiving an SRv6 Steer Route (with an IPv4 prefix) */ | ||
| TEST_F(FpmSyncdSRv6RoutesTest, RecevingSRv6SteerRoutesWithIPv4Prefix) | ||
| { | ||
| ASSERT_NE(m_routeSync, nullptr); | ||
|
|
||
| /* Create a Netlink object containing an SRv6 Steer Route */ | ||
| IpPrefix _dst = IpPrefix("192.168.6.0/24"); | ||
| IpAddress _vpn_sid = IpAddress("fc00:0:2:1::"); | ||
| IpAddress _encap_src_addr = IpAddress("fc00:0:1:1::1"); | ||
|
|
||
| struct nlmsg *nl_obj = create_srv6_steer_route_nlmsg(RTM_NEWROUTE, &_dst, &_encap_src_addr, &_vpn_sid); | ||
| if (!nl_obj) | ||
| throw std::runtime_error("SRv6 Steer Route creation failed"); | ||
|
|
||
| /* 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 vpn_sid; | ||
| ASSERT_EQ(m_routeTable->hget("Vrf10:192.168.6.0/24", "vpn_sid", vpn_sid), true); | ||
| ASSERT_EQ(vpn_sid, "fc00:0:2:1::"); | ||
|
|
||
| std::string seg_src; | ||
| ASSERT_EQ(m_routeTable->hget("Vrf10:192.168.6.0/24", "seg_src", seg_src), true); | ||
| ASSERT_EQ(seg_src, "fc00:0:1:1::1"); | ||
|
|
||
| /* Destroy the Netlink object and free the memory */ | ||
| free_nlobj(nl_obj); | ||
| } | ||
|
|
||
| /* Test Receiving an SRv6 Steer Route (with an IPv6 prefix) */ | ||
| TEST_F(FpmSyncdSRv6RoutesTest, RecevingSRv6SteerRoutesWithIPv6Prefix) | ||
| { | ||
| ASSERT_NE(m_routeSync, nullptr); | ||
|
|
||
| /* Create a Netlink object containing an SRv6 Steer Route */ | ||
| IpPrefix _dst = IpPrefix("fd00:0:21::/64"); | ||
| IpAddress _vpn_sid = IpAddress("fc00:0:2:1::"); | ||
| IpAddress _encap_src_addr = IpAddress("fc00:0:1:1::1"); | ||
|
|
||
| struct nlmsg *nl_obj = create_srv6_steer_route_nlmsg(RTM_NEWROUTE, &_dst, &_encap_src_addr, &_vpn_sid); | ||
| if (!nl_obj) | ||
| throw std::runtime_error("SRv6 Steer Route creation failed"); | ||
|
|
||
| /* 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 vpn_sid; | ||
| ASSERT_EQ(m_routeTable->hget("Vrf10:fd00:0:21::/64", "vpn_sid", vpn_sid), true); | ||
| ASSERT_EQ(vpn_sid, "fc00:0:2:1::"); | ||
|
|
||
| std::string seg_src; | ||
| ASSERT_EQ(m_routeTable->hget("Vrf10:fd00:0:21::/64", "seg_src", seg_src), true); | ||
| ASSERT_EQ(seg_src, "fc00:0:1:1::1"); | ||
|
|
||
| /* Destroy the Netlink object and free the memory */ | ||
| free_nlobj(nl_obj); | ||
| } | ||
| } |