orchagent: Adding remove LAG member logic using linkup status (sonic-net#108)

Author: Shuotian Cheng

orchagent/intfsorch.cpp

@@ -110,10 +110,11 @@ void IntfsOrch::doTask(Consumer &consumer)
             }
 
             Port port;
+            /* Cannot locate interface */
             if (!gPortsOrch->getPort(alias, port))
             {
-                SWSS_LOG_ERROR("Failed to locate interface %s", alias.c_str());
-                throw logic_error("Failed to locate interface.");
+                it = consumer.m_toSync.erase(it);
+                continue;
             }
 
             if (m_syncdIntfses.find(alias) != m_syncdIntfses.end())

orchagent/portsorch.cpp

@@ -517,7 +517,12 @@ void PortsOrch::doLagTask(Consumer &consumer)
             else if (op == DEL_COMMAND)
             {
                 Port lag;
-                getPort(lag_alias, lag);
+                /* Cannot locate LAG */
+                if (!getPort(lag_alias, lag))
+                {
+                    it = consumer.m_toSync.erase(it);
+                    continue;
+                }
 
                 if (removeLag(lag))
                     it = consumer.m_toSync.erase(it);
@@ -540,20 +545,52 @@ void PortsOrch::doLagTask(Consumer &consumer)
 
             if (op == SET_COMMAND)
             {
-                /* Duplicate entry */
-                if (lag.m_members.find(port_alias) != lag.m_members.end())
+                string linkup_status;
+                for (auto i : kfvFieldsValues(t))
                 {
-                    it = consumer.m_toSync.erase(it);
-                    continue;
+                    if (fvField(i) == "linkup")
+                        linkup_status = fvValue(i);
                 }
 
-                /* Assert the port doesn't belong to any LAG */
-                assert(!port.m_lag_id && !port.m_lag_member_id);
+                /* Add LAG member */
+                if (linkup_status == "up")
+                {
+                    /* Duplicate entry */
+                    if (lag.m_members.find(port_alias) != lag.m_members.end())
+                    {
+                        it = consumer.m_toSync.erase(it);
+                        continue;
+                    }
+
+                    /* Assert the port doesn't belong to any LAG */
+                    assert(!port.m_lag_id && !port.m_lag_member_id);
+
+                    if (addLagMember(lag, port))
+                        it = consumer.m_toSync.erase(it);
+                    else
+                        it++;
+                }
+                /* Remove LAG member */
+                else /* linkup_status == "down" */
+                {
+                    assert(lag.m_members.find(port_alias) != lag.m_members.end());
+
+                    /* Cannot locate LAG or LAG member
+                     * This happens at the time when teamd starts. The linkup
+                     * is set to down in the beginning.
+                     */
+                    if (!port.m_lag_id || !port.m_lag_member_id)
+                    {
+                        it = consumer.m_toSync.erase(it);
+                        continue;
+                    }
+
+                    if (removeLagMember(lag, port))
+                        it = consumer.m_toSync.erase(it);
+                    else
+                        it++;
+                }
 
-                if (addLagMember(lag, port))
-                    it = consumer.m_toSync.erase(it);
-                else
-                    it++;
             }
             else if (op == DEL_COMMAND)
             {