Layer 2 Forwarding Enhancements

cfgmgr/vlanmgr.cpp

@@ -13,6 +13,7 @@ using namespace swss;
 
 #define DOT1Q_BRIDGE_NAME   "Bridge"
 #define VLAN_PREFIX         "Vlan"
+#define SWITCH_STR          "switch"
 #define LAG_PREFIX          "PortChannel"
 #define DEFAULT_VLAN_ID     "1"
 #define DEFAULT_MTU_STR     "9100"
@@ -28,6 +29,8 @@ VlanMgr::VlanMgr(DBConnector *cfgDb, DBConnector *appDb, DBConnector *stateDb, c
         m_stateLagTable(stateDb, STATE_LAG_TABLE_NAME),
         m_stateVlanTable(stateDb, STATE_VLAN_TABLE_NAME),
         m_stateVlanMemberTable(stateDb, STATE_VLAN_MEMBER_TABLE_NAME),
+        m_appFdbTableProducer(appDb, APP_FDB_TABLE_NAME),
+        m_appSwitchTableProducer(appDb, APP_SWITCH_TABLE_NAME),
         m_appVlanTableProducer(appDb, APP_VLAN_TABLE_NAME),
         m_appVlanMemberTableProducer(appDb, APP_VLAN_MEMBER_TABLE_NAME)
 {
@@ -86,6 +89,10 @@ VlanMgr::VlanMgr(DBConnector *cfgDb, DBConnector *appDb, DBConnector *stateDb, c
 
         EXEC_WITH_ERROR_THROW(echo_cmd_backup, res);
     }
+    /* vlan state notification from portsorch */
+    m_VlanStateNotificationConsumer = new swss::NotificationConsumer(appDb, "VLANSTATE");
+    auto vlanStatusNotificatier = new Notifier(m_VlanStateNotificationConsumer, this, "VLANSTATE");
+    Orch::addExecutor(vlanStatusNotificatier);
 }
 
 bool VlanMgr::addHostVlan(int vlan_id)
@@ -99,7 +106,7 @@ bool VlanMgr::addHostVlan(int vlan_id)
       + BASH_CMD + " -c \""
       + BRIDGE_CMD + " vlan add vid " + std::to_string(vlan_id) + " dev " + DOT1Q_BRIDGE_NAME + " self && "
       + IP_CMD + " link add link " + DOT1Q_BRIDGE_NAME
-               + " up"
+               + " down"
                + " name " + VLAN_PREFIX + std::to_string(vlan_id)
                + " address " + gMacAddress.to_string()
                + " type vlan id " + std::to_string(vlan_id) + "\"";
@@ -177,14 +184,27 @@ bool VlanMgr::addHostVlanMember(int vlan_id, const string &port_alias, const str
     // /bin/bash -c "/sbin/ip link set {{port_alias}} master Bridge &&
     //               /sbin/bridge vlan del vid 1 dev {{ port_alias }} &&
     //               /sbin/bridge vlan add vid {{vlan_id}} dev {{port_alias}} {{tagging_mode}}"
-    const std::string cmds = std::string("")
-      + BASH_CMD + " -c \""
-      + IP_CMD + " link set " + port_alias + " master " + DOT1Q_BRIDGE_NAME + " && "
-      + BRIDGE_CMD + " vlan del vid " + DEFAULT_VLAN_ID + " dev " + port_alias + " && "
-      + BRIDGE_CMD + " vlan add vid " + std::to_string(vlan_id) + " dev " + port_alias + " " + tagging_cmd + "\"";
+
+    const std::string key = std::string("") + "Vlan1|" + port_alias;
 
-    std::string res;
-    EXEC_WITH_ERROR_THROW(cmds, res);
+    if (isVlanMemberStateOk(key)) {
+        const std::string cmds = std::string("")
+          + BASH_CMD + " -c \""
+          + IP_CMD + " link set " + port_alias + " master " + DOT1Q_BRIDGE_NAME + " && "
+          + BRIDGE_CMD + " vlan add vid " + std::to_string(vlan_id) + " dev " + port_alias + " " + tagging_cmd + "\"";
+        std::string res;
+        EXEC_WITH_ERROR_THROW(cmds, res);
+    }
+    else
+    {
+         const std::string cmds = std::string("")
+          + BASH_CMD + " -c \""
+          + IP_CMD + " link set " + port_alias + " master " + DOT1Q_BRIDGE_NAME + " && "
+          + BRIDGE_CMD + " vlan del vid " + DEFAULT_VLAN_ID + " dev " + port_alias + " && "
+          + BRIDGE_CMD + " vlan add vid " + std::to_string(vlan_id) + " dev " + port_alias + " " + tagging_cmd + "\"";
+        std::string res;
+        EXEC_WITH_ERROR_THROW(cmds, res);
+    }
 
     return true;
 }
@@ -222,6 +242,144 @@ bool VlanMgr::isVlanMacOk()
     return !!gMacAddress;
 }
 
+void VlanMgr::doSwitchTask(Consumer &consumer)
+{
+    SWSS_LOG_ENTER();
+    auto it = consumer.m_toSync.begin();
+
+    while (it != consumer.m_toSync.end())
+    {
+        KeyOpFieldsValuesTuple t = it->second;
+
+        string key = kfvKey(t);
+        string op = kfvOp(t);
+
+        /* Ensure the key starts with "switch" otherwise ignore */
+        if (key != SWITCH_STR)
+        {
+            SWSS_LOG_INFO("Ignoring SWITCH key %s", key.c_str());
+            it = consumer.m_toSync.erase(it);
+            continue;
+        }
+
+        SWSS_LOG_DEBUG("key:switch");
+
+        for (auto i : kfvFieldsValues(t))
+        {
+            if (fvField(i) == "fdb_aging_time")
+            {
+                int agingTime = 0;
+                SWSS_LOG_DEBUG("attribute:fdb_aging_time");
+                if (op == SET_COMMAND)
+                {
+                    SWSS_LOG_DEBUG("operation:set");
+                    agingTime = atoi(fvValue(i).c_str());
+                    if(agingTime < 0)
+                    {
+                        SWSS_LOG_ERROR("Invalid fdb_aging_time %s", fvValue(i).c_str());
+                        break;
+                    }
+                    SWSS_LOG_DEBUG("value:%s",fvValue(i).c_str());
+                }
+                else if (op == DEL_COMMAND)
+                {
+                    SWSS_LOG_DEBUG("operation:del");
+                    agingTime=0;
+                }
+                else
+                {
+                    SWSS_LOG_ERROR("Unknown operation type %s", op.c_str());
+                    break;
+                }
+
+                vector<FieldValueTuple> fvVector;
+                FieldValueTuple aging_time("fdb_aging_time", to_string(agingTime));
+                fvVector.push_back(aging_time);
+                m_appSwitchTableProducer.set(key, fvVector);
+                break;
+            }
+        }
+
+        it = consumer.m_toSync.erase(it);
+    }
+}
+
+void VlanMgr::doFdbTask(Consumer &consumer)
+{
+    if (!isVlanMacOk())
+    {
+        SWSS_LOG_DEBUG("VLAN mac not ready, delaying FDB task");
+        SWSS_LOG_DEBUG("VLAN mac not ready, delaying VLAN task");
+        return;
+    }
+
+    auto it = consumer.m_toSync.begin();
+
+    while (it != consumer.m_toSync.end())
+    {
+        KeyOpFieldsValuesTuple t = it->second;
+
+        /* format: <VLAN_name>|<MAC_address> */
+        vector<string> keys = tokenize(kfvKey(t), config_db_key_delimiter, 1);
+        /* keys[0] is vlan as (Vlan10) and keys[1] is mac as (00-00-00-00-00-00) */
+        string op = kfvOp(t);
+
+        /* Ensure the key starts with "Vlan" otherwise ignore */
+        if (strncmp(keys[0].c_str(), VLAN_PREFIX, 4))
+        {
+            SWSS_LOG_ERROR("Invalid key format. No 'Vlan' prefix: %s", keys[0].c_str());
+            it = consumer.m_toSync.erase(it);
+            continue;
+        }
+
+        int vlan_id;
+        vlan_id = stoi(keys[0].substr(4));
+
+        if ((vlan_id <= 0) || (vlan_id > 4095))
+        {
+            SWSS_LOG_ERROR("Invalid key format. Vlan is out of range: %s", keys[0].c_str());
+            it = consumer.m_toSync.erase(it);
+            continue;
+        }
+
+        MacAddress mac = MacAddress(keys[1]);
+
+        string key = VLAN_PREFIX + to_string(vlan_id);
+        key += DEFAULT_KEY_SEPARATOR;
+        key += mac.to_string();
+
+        if (op == SET_COMMAND)
+        {
+            string port;
+            for (auto i : kfvFieldsValues(t))
+            {
+                if (fvField(i) == "port")
+                {
+                    port = fvValue(i);
+                    break;
+                }
+            }
+
+            vector<FieldValueTuple> fvVector;
+            FieldValueTuple p("port", port);
+            fvVector.push_back(p);
+            FieldValueTuple t("type", "static");
+            fvVector.push_back(t);
+
+            m_appFdbTableProducer.set(key, fvVector);
+        }
+        else if (op == DEL_COMMAND)
+        {
+            m_appFdbTableProducer.del(key);
+        }
+        else
+        {
+            SWSS_LOG_ERROR("Unknown operation type %s", op.c_str());
+        }
+        it = consumer.m_toSync.erase(it);
+    }
+}
+
 void VlanMgr::doVlanTask(Consumer &consumer)
 {
     if (!isVlanMacOk())
@@ -292,15 +450,7 @@ void VlanMgr::doVlanTask(Consumer &consumer)
             /* set up host env .... */
             for (auto i : kfvFieldsValues(t))
             {
-                /* Set vlan admin status */
-                if (fvField(i) == "admin_status")
-                {
-                    admin_status = fvValue(i);
-                    setHostVlanAdminState(vlan_id, admin_status);
-                    fvVector.push_back(i);
-                }
-                /* Set vlan mtu */
-                else if (fvField(i) == "mtu")
+                if (fvField(i) == "mtu")
                 {
                     mtu = fvValue(i);
                     /*
@@ -590,9 +740,45 @@ void VlanMgr::doTask(Consumer &consumer)
     {
         doVlanMemberTask(consumer);
     }
+    else if (table_name == CFG_FDB_TABLE_NAME)
+    {
+        doFdbTask(consumer);
+    }
+    else if (table_name == CFG_SWITCH_TABLE_NAME)
+    {
+        SWSS_LOG_DEBUG("Table:SWITCH");
+        doSwitchTask(consumer);
+    }
     else
     {
         SWSS_LOG_ERROR("Unknown config table %s ", table_name.c_str());
         throw runtime_error("VlanMgr doTask failure.");
     }
 }
+
+void VlanMgr::doTask(NotificationConsumer &consumer)
+{
+    std::string op;
+    std::string data;
+    std::vector<swss::FieldValueTuple> values;
+
+    if (&consumer != m_VlanStateNotificationConsumer)
+    {
+        return;
+    }
+
+    consumer.pop(op, data, values);
+
+    int vlan_id = stoi(data.substr(4));
+
+    SWSS_LOG_NOTICE("vlanmgr received port status notification state %s vlan %s id %d",
+        op.c_str(), data.c_str(), vlan_id);
+
+    if (isVlanStateOk(data)) {
+        setHostVlanAdminState(vlan_id, op);
+    }
+    else
+    {
+        SWSS_LOG_ERROR("received state update for vlan %s not existing", data.c_str());
+    }
+}

cfgmgr/vlanmgr.h

@@ -4,6 +4,7 @@
 #include "dbconnector.h"
 #include "producerstatetable.h"
 #include "orch.h"
+#include "notifier.h"
 
 #include <set>
 #include <map>
@@ -19,14 +20,20 @@ class VlanMgr : public Orch
 
 private:
     ProducerStateTable m_appVlanTableProducer, m_appVlanMemberTableProducer;
+    ProducerStateTable m_appFdbTableProducer;
+    ProducerStateTable m_appSwitchTableProducer;
     Table m_cfgVlanTable, m_cfgVlanMemberTable;
     Table m_statePortTable, m_stateLagTable;
     Table m_stateVlanTable, m_stateVlanMemberTable;
     std::set<std::string> m_vlans;
+    NotificationConsumer* m_VlanStateNotificationConsumer;
 
     void doTask(Consumer &consumer);
+    void doTask(NotificationConsumer &consumer);
     void doVlanTask(Consumer &consumer);
     void doVlanMemberTask(Consumer &consumer);
+    void doFdbTask(Consumer &consumer);
+    void doSwitchTask(Consumer &consumer);
     void processUntaggedVlanMembers(std::string vlan, const std::string &members);
 
     bool addHostVlan(int vlan_id);

cfgmgr/vlanmgrd.cpp

@@ -51,6 +51,8 @@ int main(int argc, char **argv)
         vector<string> cfg_vlan_tables = {
             CFG_VLAN_TABLE_NAME,
             CFG_VLAN_MEMBER_TABLE_NAME,
+            CFG_FDB_TABLE_NAME,
+            CFG_SWITCH_TABLE_NAME,
         };
 
         DBConnector cfgDb(CONFIG_DB, DBConnector::DEFAULT_UNIXSOCKET, 0);