Skip to content

Commit

Permalink
Support for in-band-mgmt via management VRF (#1726)
Browse files Browse the repository at this point in the history
* Support for in-band-mgmt via management VRF.

Signed-off-by: Venkatesan Mahalingam <venkatesan_mahalinga@dell.com>
  • Loading branch information
venkatmahalingam authored Jun 24, 2021
1 parent 1e3a532 commit c37cc1c
Show file tree
Hide file tree
Showing 10 changed files with 281 additions and 6 deletions.
4 changes: 3 additions & 1 deletion cfgmgr/intfmgr.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@ using namespace swss;
#define VNET_PREFIX "Vnet"
#define MTU_INHERITANCE "0"
#define VRF_PREFIX "Vrf"
#define VRF_MGMT "mgmt"

#define LOOPBACK_DEFAULT_MTU_STR "65536"

Expand Down Expand Up @@ -399,7 +400,8 @@ bool IntfMgr::isIntfStateOk(const string &alias)
return true;
}
}
else if (!alias.compare(0, strlen(VRF_PREFIX), VRF_PREFIX))
else if ((!alias.compare(0, strlen(VRF_PREFIX), VRF_PREFIX)) ||
(alias == VRF_MGMT))
{
if (m_stateVrfTable.get(alias, temp))
{
Expand Down
69 changes: 67 additions & 2 deletions cfgmgr/vrfmgr.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,8 @@
#define VRF_TABLE_START 1001
#define VRF_TABLE_END 2000
#define TABLE_LOCAL_PREF 1001 // after l3mdev-table
#define MGMT_VRF_TABLE_ID 5000
#define MGMT_VRF "mgmt"

using namespace swss;

Expand Down Expand Up @@ -143,6 +145,13 @@ bool VrfMgr::delLink(const string& vrfName)
return false;
}

if (vrfName == MGMT_VRF)
{
recycleTable(m_vrfTableMap[vrfName]);
m_vrfTableMap.erase(vrfName);
return true;
}

cmd << IP_CMD << " link del " << shellquote(vrfName);
EXEC_WITH_ERROR_THROW(cmd.str(), res);

Expand All @@ -163,6 +172,15 @@ bool VrfMgr::setLink(const string& vrfName)
{
return true;
}

if (vrfName == MGMT_VRF)
{
// Mgmt VRF is initialised as part of hostcfgd,
// just return the reserved table_id for mgmt VRF from here.
uint32_t table_id = MGMT_VRF_TABLE_ID;
m_vrfTableMap.emplace(vrfName, table_id);
return true;
}

uint32_t table = getFreeTable();
if (table == 0)
Expand Down Expand Up @@ -207,6 +225,51 @@ void VrfMgr::doTask(Consumer &consumer)
auto vrfName = kfvKey(t);

string op = kfvOp(t);
// Mgmt VRF table event handling for in-band management
if (consumer.getTableName() == CFG_MGMT_VRF_CONFIG_TABLE_NAME)
{
SWSS_LOG_DEBUG("Event for mgmt VRF op %s", op.c_str());
if (op == SET_COMMAND)
{
bool in_band_mgmt_enabled = false;
bool mgmt_vrf_enabled = false;
for (auto i : kfvFieldsValues(t))
{
if (fvField(i) == "mgmtVrfEnabled")
{
if (fvValue(i) == "true")
{
mgmt_vrf_enabled = true;
}
SWSS_LOG_DEBUG("Event for mgmt VRF table mgmt_vrf_enabled is set val:%s", fvValue(i).c_str());
}
else if (fvField(i) == "in_band_mgmt_enabled")
{
if (fvValue(i) == "true")
{
in_band_mgmt_enabled = true;
}
SWSS_LOG_DEBUG("Event for mgmt VRF table in_band_mgmt_enabled is set val:%s", fvValue(i).c_str());
}
}
// If mgmt VRF is not enabled or in-band-mgmt is not enabled delete the in-band-mgmt
// related VRF table map information
if ((op == SET_COMMAND) && ((mgmt_vrf_enabled == false) || (in_band_mgmt_enabled == false)))
{
op = DEL_COMMAND;
}
}
vrfName = MGMT_VRF;
if (((op == DEL_COMMAND) && (m_vrfTableMap.find(vrfName) == m_vrfTableMap.end())) ||
((op == SET_COMMAND) && (m_vrfTableMap.find(vrfName) != m_vrfTableMap.end())))
{
// If the mgmt VRF is not populated already, return
it = consumer.m_toSync.erase(it);
continue;
}
SWSS_LOG_DEBUG("Event for mgmt VRF op %s", op.c_str());
}
SWSS_LOG_DEBUG("Event for table %s vrf netdev %s id %s", consumer.getTableName().c_str(), vrfName.c_str(), op.c_str());
if (op == SET_COMMAND)
{
if (consumer.getTableName() == CFG_VXLAN_EVPN_NVO_TABLE_NAME)
Expand All @@ -226,7 +289,8 @@ void VrfMgr::doTask(Consumer &consumer)
m_stateVrfTable.set(vrfName, fvVector);

SWSS_LOG_NOTICE("Created vrf netdev %s", vrfName.c_str());
if (consumer.getTableName() == CFG_VRF_TABLE_NAME)
if ((consumer.getTableName() == CFG_VRF_TABLE_NAME) ||
(consumer.getTableName() == CFG_MGMT_VRF_CONFIG_TABLE_NAME))
{
status = doVrfVxlanTableCreateTask (t);
if (status == false)
Expand Down Expand Up @@ -256,7 +320,8 @@ void VrfMgr::doTask(Consumer &consumer)
{
doVrfEvpnNvoDelTask (t);
}
else if (consumer.getTableName() == CFG_VRF_TABLE_NAME)
else if ((consumer.getTableName() == CFG_VRF_TABLE_NAME) ||
(consumer.getTableName() == CFG_MGMT_VRF_CONFIG_TABLE_NAME))
{
vector<FieldValueTuple> temp;

Expand Down
1 change: 1 addition & 0 deletions cfgmgr/vrfmgrd.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,7 @@ int main(int argc, char **argv)
CFG_VRF_TABLE_NAME,
CFG_VNET_TABLE_NAME,
CFG_VXLAN_EVPN_NVO_TABLE_NAME,
CFG_MGMT_VRF_CONFIG_TABLE_NAME
};

DBConnector cfgDb("CONFIG_DB", 0);
Expand Down
13 changes: 12 additions & 1 deletion fpmsyncd/routesync.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@ using namespace swss;
#define VXLAN_IF_NAME_PREFIX "Brvxlan"
#define VNET_PREFIX "Vnet"
#define VRF_PREFIX "Vrf"
#define MGMT_VRF_PREFIX "mgmt"

#ifndef ETH_ALEN
#define ETH_ALEN 6
Expand Down Expand Up @@ -625,7 +626,17 @@ void RouteSync::onRouteMsg(int nlmsg_type, struct nl_object *obj, char *vrf)
*/
if (memcmp(vrf, VRF_PREFIX, strlen(VRF_PREFIX)))
{
SWSS_LOG_ERROR("Invalid VRF name %s (ifindex %u)", vrf, rtnl_route_get_table(route_obj));
if(memcmp(vrf, MGMT_VRF_PREFIX, strlen(MGMT_VRF_PREFIX)))
{
SWSS_LOG_ERROR("Invalid VRF name %s (ifindex %u)", vrf, rtnl_route_get_table(route_obj));
}
else
{
dip = rtnl_route_get_dst(route_obj);
nl_addr2str(dip, destipprefix, MAX_ADDR_SIZE);
SWSS_LOG_INFO("Skip routes for Mgmt VRF name %s (ifindex %u) prefix: %s", vrf,
rtnl_route_get_table(route_obj), destipprefix);
}
return;
}
memcpy(destipprefix, vrf, strlen(vrf));
Expand Down
18 changes: 18 additions & 0 deletions orchagent/intfsorch.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -42,6 +42,7 @@ const int intfsorch_pri = 35;
#define RIF_FLEX_STAT_COUNTER_POLL_MSECS "1000"
#define UPDATE_MAPS_SEC 1

#define MGMT_VRF "mgmt"

static const vector<sai_router_interface_stat_t> rifStatIds =
{
Expand Down Expand Up @@ -159,6 +160,23 @@ string IntfsOrch::getRouterIntfsAlias(const IpAddress &ip, const string &vrf_nam
return string();
}

bool IntfsOrch::isInbandIntfInMgmtVrf(const string& alias)
{
if (m_syncdIntfses.find(alias) == m_syncdIntfses.end())
{
return false;
}

string vrf_name = "";
vrf_name = m_vrfOrch->getVRFname(m_syncdIntfses[alias].vrf_id);
if ((!vrf_name.empty()) && (vrf_name == MGMT_VRF))
{
return true;
}

return false;
}

void IntfsOrch::increaseRouterIntfsRefCount(const string &alias)
{
SWSS_LOG_ENTER();
Expand Down
1 change: 1 addition & 0 deletions orchagent/intfsorch.h
Original file line number Diff line number Diff line change
Expand Up @@ -36,6 +36,7 @@ class IntfsOrch : public Orch

sai_object_id_t getRouterIntfsId(const string&);
bool isPrefixSubnet(const IpPrefix&, const string&);
bool isInbandIntfInMgmtVrf(const string& alias);
string getRouterIntfsAlias(const IpAddress &ip, const string &vrf_name = "");
string getRifRateFlexCounterTableKey(string key);
void increaseRouterIntfsRefCount(const string&);
Expand Down
3 changes: 2 additions & 1 deletion orchagent/neighorch.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -551,7 +551,8 @@ void NeighOrch::doTask(Consumer &consumer)

string alias = key.substr(0, found);

if (alias == "eth0" || alias == "lo" || alias == "docker0")
if (alias == "eth0" || alias == "lo" || alias == "docker0"
|| ((op == SET_COMMAND) && m_intfsOrch->isInbandIntfInMgmtVrf(alias)))
{
it = consumer.m_toSync.erase(it);
continue;
Expand Down
5 changes: 5 additions & 0 deletions orchagent/vrforch.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -68,6 +68,11 @@ bool VRFOrch::addOperation(const Request& request)
vni = static_cast<uint32_t>(request.getAttrUint(name));
continue;
}
else if ((name == "mgmtVrfEnabled") || (name == "in_band_mgmt_enabled"))
{
SWSS_LOG_INFO("MGMT VRF field: %s ignored", name.c_str());
continue;
}
else
{
SWSS_LOG_ERROR("Logic error: Unknown attribute: %s", name.c_str());
Expand Down
4 changes: 3 additions & 1 deletion orchagent/vrforch.h
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,9 @@ const request_description_t request_description = {
{ "ip_opt_action", REQ_T_PACKET_ACTION },
{ "l3_mc_action", REQ_T_PACKET_ACTION },
{ "fallback", REQ_T_BOOL },
{ "vni", REQ_T_UINT }
{ "vni", REQ_T_UINT },
{ "mgmtVrfEnabled", REQ_T_BOOL },
{ "in_band_mgmt_enabled", REQ_T_BOOL }
},
{ } // no mandatory attributes
};
Expand Down
Loading

0 comments on commit c37cc1c

Please sign in to comment.