[sairedis] Record create, remove and set response in sync mode (sonic…

…-net#869) Start recording CRS operations response to sairedis.rec but only when response is not success.
oleksandrivantsiv · Jul 30, 2021 · f56a39e · f56a39e
1 parent f50dba7
commit f56a39e
Show file tree

Hide file tree

Showing 3 changed files with 48 additions and 0 deletions.
diff --git a/lib/inc/Recorder.h b/lib/inc/Recorder.h
@@ -157,6 +157,9 @@ namespace sairedis
                     _In_ sai_status_t status,
                     _In_ const std::vector<swss::FieldValueTuple>& arguments);
 
+            void recordGenericResponse(
+                    _In_ sai_status_t status);
+
         public: // create ENTRY
 
             SAI_REDIS_RECORDER_DECLARE_RECORD_CREATE(fdb_entry);
@@ -263,6 +266,11 @@ namespace sairedis
                     _In_ uint32_t objectCount,
                     _In_ const sai_status_t *objectStatuses);
 
+            void recordBulkGenericResponse(
+                    _In_ sai_status_t status,
+                    _In_ uint32_t objectCount,
+                    _In_ const sai_status_t *objectStatuses);
+
         public: // SAI query interface API
 
             void recordFlushFdbEntries(

diff --git a/lib/src/Recorder.cpp b/lib/src/Recorder.cpp
@@ -1117,3 +1117,39 @@ void Recorder::recordStats(
 
     m_recordStats = enable;
 }
+
+
+void Recorder::recordGenericResponse(
+        _In_ sai_status_t status)
+{
+    SWSS_LOG_ENTER();
+
+    if (status != SAI_STATUS_SUCCESS)
+    {
+        // record only when response is not success
+
+        recordLine("E|" + sai_serialize_status(status));
+    }
+}
+
+void Recorder::recordBulkGenericResponse(
+        _In_ sai_status_t status,
+        _In_ uint32_t objectCount,
+        _In_ const sai_status_t *objectStatuses)
+{
+    SWSS_LOG_ENTER();
+
+    if (status != SAI_STATUS_SUCCESS)
+    {
+        // record only when response is not success
+
+        std::string statuses = "";
+
+        for (uint32_t i = 0; i < objectCount; i++)
+        {
+            statuses += "|" + sai_serialize_status(objectStatuses[i]);
+        }
+
+        recordLine("E|" + sai_serialize_status(status) + "|" + statuses);
+    }
+}
diff --git a/lib/src/RedisRemoteSaiInterface.cpp b/lib/src/RedisRemoteSaiInterface.cpp
@@ -742,6 +742,8 @@ sai_status_t RedisRemoteSaiInterface::waitForResponse(
 
         auto status = m_communicationChannel->wait(REDIS_ASIC_STATE_COMMAND_GETRESPONSE, kco);
 
+        m_recorder->recordGenericResponse(status);
+
         return status;
     }
 
@@ -1347,6 +1349,8 @@ sai_status_t RedisRemoteSaiInterface::waitForBulkResponse(
             sai_deserialize_status(fvField(values[idx]), object_statuses[idx]);
         }
 
+        m_recorder->recordBulkGenericResponse(status, object_count, object_statuses);
+
         return status;
     }