[vrfmgrd]: Support VNET setting (sonic-net#657)

* [vrfmgrd]: Support VNET setting

Signed-off-by: Marian Pritsak <[email protected]>

* Use VRF/VNET as a tunnel map name

Signed-off-by: Marian Pritsak <[email protected]>

* Handle VNET and VRF the same way

Signed-off-by: Marian Pritsak <[email protected]>

Author: marian-pritsak

cfgmgr/vrfmgr.cpp

@@ -15,6 +15,8 @@ using namespace swss;
 
 VrfMgr::VrfMgr(DBConnector *cfgDb, DBConnector *appDb, DBConnector *stateDb, const vector<string> &tableNames) :
         Orch(cfgDb, tableNames),
+        m_appVrfTableProducer(appDb, APP_VRF_TABLE_NAME),
+        m_appVnetTableProducer(appDb, APP_VNET_TABLE_NAME),
         m_stateVrfTable(stateDb, STATE_VRF_TABLE_NAME)
 {
     for (uint32_t i = VRF_TABLE_START; i < VRF_TABLE_END; i++)
@@ -160,6 +162,14 @@ void VrfMgr::doTask(Consumer &consumer)
             m_stateVrfTable.set(vrfName, fvVector);
 
             SWSS_LOG_NOTICE("Created vrf netdev %s", vrfName.c_str());
+            if (consumer.getTableName() == APP_VRF_TABLE_NAME)
+            {
+                m_appVrfTableProducer.set(vrfName, kfvFieldsValues(t));
+            }
+            else
+            {
+                m_appVnetTableProducer.set(vrfName, kfvFieldsValues(t));
+            }
         }
         else if (op == DEL_COMMAND)
         {
@@ -170,6 +180,15 @@ void VrfMgr::doTask(Consumer &consumer)
 
             m_stateVrfTable.del(vrfName);
 
+            if (consumer.getTableName() == APP_VRF_TABLE_NAME)
+            {
+                m_appVrfTableProducer.del(vrfName);
+            }
+            else
+            {
+                m_appVnetTableProducer.del(vrfName);
+            }
+
             SWSS_LOG_NOTICE("Removed vrf netdev %s", vrfName.c_str());
         }
         else

cfgmgr/vrfmgr.h

@@ -23,12 +23,14 @@ class VrfMgr : public Orch
     bool setLink(const string& vrfName);
     void recycleTable(uint32_t table);
     uint32_t getFreeTable(void);
+    void handleVnetConfigSet(KeyOpFieldsValuesTuple &t);
     void doTask(Consumer &consumer);
 
     map<string, uint32_t> m_vrfTableMap;
     set<uint32_t> m_freeTables;
 
     Table m_stateVrfTable;
+    ProducerStateTable m_appVrfTableProducer, m_appVnetTableProducer;
 };
 
 }

cfgmgr/vrfmgrd.cpp

@@ -42,6 +42,7 @@ int main(int argc, char **argv)
     {
         vector<string> cfg_vrf_tables = {
             CFG_VRF_TABLE_NAME,
+            CFG_VNET_TABLE_NAME,
         };
 
         DBConnector cfgDb(CONFIG_DB, DBConnector::DEFAULT_UNIXSOCKET, 0);