Switch Capability support

Signed-off-by: Prabhu Sreenivasan <[email protected]>

Author: Prabhu Sreenivasan

orchagent/main.cpp

@@ -46,6 +46,8 @@ sai_object_id_t gUnderlayIfId;
 sai_object_id_t gSwitchId = SAI_NULL_OBJECT_ID;
 MacAddress gMacAddress;
 MacAddress gVxlanMacAddress;
+extern int32_t gSupportedObjectTypeList[SAI_OBJECT_TYPE_MAX];
+extern uint32_t gSupportedObjectTypeListCount;
 
 #define DEFAULT_BATCH_SIZE  128
 int gBatchSize = DEFAULT_BATCH_SIZE;
@@ -364,6 +366,27 @@ int main(int argc, char **argv)
 
     SWSS_LOG_NOTICE("Created underlay router interface ID %" PRIx64, gUnderlayIfId);
 
+    sai_attribute_t obj_attr_get;
+    obj_attr_get.id = SAI_SWITCH_ATTR_SUPPORTED_OBJECT_TYPE_LIST;
+    obj_attr_get.value.s32list.count = SAI_OBJECT_TYPE_MAX;
+    obj_attr_get.value.s32list.list= gSupportedObjectTypeList;
+
+    status = sai_switch_api->get_switch_attribute(gSwitchId, 1, &obj_attr_get);
+    if (SAI_STATUS_SUCCESS != status)
+    {
+        SWSS_LOG_ERROR("get_switch_attribute failed with error %d\n", status);
+        exit(EXIT_FAILURE);
+    }
+
+    gSupportedObjectTypeListCount = obj_attr_get.value.s32list.count;
+
+    SWSS_LOG_DEBUG("Adapter supports %d object types\n", obj_attr_get.value.s32list.count);
+
+    for (uint32_t iter = 0; iter < gSupportedObjectTypeListCount; iter++)
+    {
+        SWSS_LOG_DEBUG("gSupportedObjectTypeList[%d] = %d\n", iter, gSupportedObjectTypeList[iter]);
+    }
+
     /* Initialize orchestration components */
     DBConnector appl_db("APPL_DB", 0);
     DBConnector config_db("CONFIG_DB", 0);

orchagent/orch.h

@@ -42,6 +42,10 @@ const char state_db_key_delimiter  = '|';
 #define DEFAULT_KEY_SEPARATOR  ":"
 #define VLAN_SUB_INTERFACE_SEPARATOR "."
 
+#define SNAPSHOT_SUPPORTED_FIELD "snapshot_supported"
+
+#define THRESHOLD_SUPPORTED_FIELD "threshold_supported"
+
 const int default_orch_pri = 0;
 
 typedef enum

orchagent/orchdaemon.cpp

@@ -17,11 +17,27 @@ using namespace swss;
 #define SELECT_TIMEOUT 1000
 #define PFC_WD_POLL_MSECS 100
 
+/* Switch table key */
+#define SWITCH_TABLE_KEY    "switch"
+
 extern sai_switch_api_t*           sai_switch_api;
 extern sai_object_id_t             gSwitchId;
 extern bool                        gSaiRedisLogRotate;
 
 extern void syncd_apply_view();
+
+/*
+ * Global supported objects variables
+ */
+int32_t  gSupportedObjectTypeList[SAI_OBJECT_TYPE_MAX];
+uint32_t gSupportedObjectTypeListCount;
+
+/* Global Snapshot support flag */
+bool gIsSnapshotSupported = false;
+
+/* Global Threshold support flag */
+bool gIsThresholdSupported = false;
+
 /*
  * Global orch daemon variables
  */
@@ -46,6 +62,94 @@ OrchDaemon::OrchDaemon(DBConnector *applDb, DBConnector *configDb, DBConnector *
         m_stateDb(stateDb)
 {
     SWSS_LOG_ENTER();
+
+    SWSS_LOG_DEBUG("gSupportedObjectTypeListCount %d object types\n", gSupportedObjectTypeListCount);
+    if (gSupportedObjectTypeListCount)
+    {
+        bool isTamCollectorSupported = false;
+        bool isTamReportSupported = false;
+        bool isTamTransportSupported = false;
+        bool isTamSupported = false;
+        bool isTamTelemetrySupported = false;
+        bool isTamEventThresholdSupported = false;
+
+        /* Run through supported objects and check if all objects needed for IFA feature are supported or not */
+        for (uint32_t iter = 0; iter < gSupportedObjectTypeListCount; iter++)
+        {
+            switch (gSupportedObjectTypeList[iter])
+            {
+                case SAI_OBJECT_TYPE_TAM_COLLECTOR:
+                {
+                    isTamCollectorSupported = true;
+                    break;
+                }
+                case SAI_OBJECT_TYPE_TAM_REPORT:
+                {
+                    isTamReportSupported = true;
+                    break;
+                }
+                case SAI_OBJECT_TYPE_TAM_TRANSPORT:
+                {
+                    isTamTransportSupported = true;
+                    break;
+                }
+                case SAI_OBJECT_TYPE_TAM:
+                {
+                    isTamSupported = true;
+                    break;
+                }
+                case SAI_OBJECT_TYPE_TAM_TELEMETRY:
+                {
+                    isTamTelemetrySupported = true;
+                    break;
+                }
+                case SAI_OBJECT_TYPE_TAM_EVENT_THRESHOLD:
+                {
+                    isTamEventThresholdSupported = true;
+                    break;
+                }
+            }
+        }
+
+        /* Snapshot support */
+        if (isTamCollectorSupported && isTamSupported && isTamTelemetrySupported &&
+            isTamReportSupported && isTamTransportSupported)
+        {
+            if (isTamSupported && isTamTelemetrySupported)
+                SWSS_LOG_DEBUG("TAM and telemetry objects supported.");
+
+            /* Added snapshot supported field in APP DB's switch table */
+            Table m_appSwitchTable(m_applDb, APP_SWITCH_TABLE_NAME);
+            string key = SWITCH_TABLE_KEY;
+            vector<FieldValueTuple> fvVector;
+            FieldValueTuple snapshot_supported(SNAPSHOT_SUPPORTED_FIELD, "True");
+            fvVector.push_back(snapshot_supported);
+
+            m_appSwitchTable.set(key, fvVector);
+
+            SWSS_LOG_DEBUG("APP Switch Table updated with snapshot supported entry\n");
+
+            gIsSnapshotSupported = true;
+        }
+
+        /* Threshold support */
+        if (isTamCollectorSupported && isTamSupported && isTamTelemetrySupported &&
+            isTamReportSupported && isTamTransportSupported && isTamEventThresholdSupported)
+        {
+            /* Added threshold_supported field in APP DB's switch table */
+            Table m_appSwitchTable(m_applDb, APP_SWITCH_TABLE_NAME);
+            string key = SWITCH_TABLE_KEY;
+            vector<FieldValueTuple> fvVector;
+            FieldValueTuple threshold_supported(THRESHOLD_SUPPORTED_FIELD, "True");
+            fvVector.push_back(threshold_supported);
+
+            m_appSwitchTable.set(key, fvVector);
+
+            SWSS_LOG_DEBUG("APP Switch Table updated with threshold_supported entry\n");
+
+            gIsThresholdSupported = true;
+        }
+    }
 }
 
 OrchDaemon::~OrchDaemon()