Sonic sairedis changes for SAI SRV6 and SAI refpoint update to v1.9.0 (sonic-net#937)

Update SAI SEGMENTROUTE object to SAI SRV6 object
Serialize and deserialize APIs for SRV6 MY_SID_ENTRY object
SAI refpoint update to V1.9.0

Author: Kumaresh Perumal

SAI

@@ -1179,6 +1179,38 @@ sai_status_t ClientSai::bulkCreate(
             object_statuses);
 }
 
+sai_status_t ClientSai::bulkCreate(
+        _In_ uint32_t object_count,
+        _In_ const sai_my_sid_entry_t* my_sid_entry,
+        _In_ const uint32_t *attr_count,
+        _In_ const sai_attribute_t **attr_list,
+        _In_ sai_bulk_op_error_mode_t mode,
+        _Out_ sai_status_t *object_statuses)
+{
+    MUTEX();
+    SWSS_LOG_ENTER();
+    REDIS_CHECK_API_INITIALIZED();
+
+    // TODO support mode
+
+    std::vector<std::string> serialized_object_ids;
+
+    // on create vid is put in db by syncd
+    for (uint32_t idx = 0; idx < object_count; idx++)
+    {
+        std::string str_object_id = sai_serialize_my_sid_entry(my_sid_entry[idx]);
+        serialized_object_ids.push_back(str_object_id);
+    }
+
+    return bulkCreate(
+            SAI_OBJECT_TYPE_MY_SID_ENTRY,
+            serialized_object_ids,
+            attr_count,
+            attr_list,
+            mode,
+            object_statuses);
+}
+
 // BULK CREATE HELPERS
 
 sai_status_t ClientSai::bulkCreate(
@@ -1335,6 +1367,26 @@ sai_status_t ClientSai::bulkRemove(
     return bulkRemove(SAI_OBJECT_TYPE_FDB_ENTRY, serializedObjectIds, mode, object_statuses);
 }
 
+sai_status_t ClientSai::bulkRemove(
+        _In_ uint32_t object_count,
+        _In_ const sai_my_sid_entry_t *my_sid_entry,
+        _In_ sai_bulk_op_error_mode_t mode,
+        _Out_ sai_status_t *object_statuses)
+{
+    MUTEX();
+    SWSS_LOG_ENTER();
+    REDIS_CHECK_API_INITIALIZED();
+
+    std::vector<std::string> serializedObjectIds;
+
+    for (uint32_t idx = 0; idx < object_count; idx++)
+    {
+        serializedObjectIds.emplace_back(sai_serialize_my_sid_entry(my_sid_entry[idx]));
+    }
+
+    return bulkRemove(SAI_OBJECT_TYPE_MY_SID_ENTRY, serializedObjectIds, mode, object_statuses);
+}
+
 // BULK REMOVE HELPERS
 
 sai_status_t ClientSai::bulkRemove(
@@ -1485,6 +1537,27 @@ sai_status_t ClientSai::bulkSet(
     return bulkSet(SAI_OBJECT_TYPE_FDB_ENTRY, serializedObjectIds, attr_list, mode, object_statuses);
 }
 
+sai_status_t ClientSai::bulkSet(
+        _In_ uint32_t object_count,
+        _In_ const sai_my_sid_entry_t *my_sid_entry,
+        _In_ const sai_attribute_t *attr_list,
+        _In_ sai_bulk_op_error_mode_t mode,
+        _Out_ sai_status_t *object_statuses)
+{
+    MUTEX();
+    SWSS_LOG_ENTER();
+    REDIS_CHECK_API_INITIALIZED();
+
+    std::vector<std::string> serializedObjectIds;
+
+    for (uint32_t idx = 0; idx < object_count; idx++)
+    {
+        serializedObjectIds.emplace_back(sai_serialize_my_sid_entry(my_sid_entry[idx]));
+    }
+
+    return bulkSet(SAI_OBJECT_TYPE_MY_SID_ENTRY, serializedObjectIds, attr_list, mode, object_statuses);
+}
+
 // BULK SET HELPERS
 
 sai_status_t ClientSai::bulkSet(

lib/ClientSai.cpp

@@ -65,7 +65,7 @@ libsairedis_la_SOURCES = \
 						 sai_redis_samplepacket.cpp \
 						 sai_redis_scheduler.cpp \
 						 sai_redis_schedulergroup.cpp \
-						 sai_redis_segmentroute.cpp \
+						 sai_redis_srv6.cpp \
 						 sai_redis_stp.cpp \
 						 sai_redis_switch.cpp \
 						 sai_redis_system_port.cpp \
@@ -74,7 +74,9 @@ libsairedis_la_SOURCES = \
 						 sai_redis_udf.cpp \
 						 sai_redis_virtual_router.cpp \
 						 sai_redis_vlan.cpp \
-						 sai_redis_wred.cpp
+						 sai_redis_wred.cpp \
+						 sai_redis_ipsec.cpp \
+						 sai_redis_my_mac.cpp
 
 libSaiRedis_a_CPPFLAGS = $(CODE_COVERAGE_CPPFLAGS)
 libSaiRedis_a_CXXFLAGS = $(DBGFLAGS) $(AM_CXXFLAGS) $(CXXFLAGS_COMMON) $(CODE_COVERAGE_CXXFLAGS)

lib/Makefile.am

@@ -170,6 +170,7 @@ namespace sairedis
             SAI_REDIS_RECORDER_DECLARE_RECORD_CREATE(neighbor_entry);
             SAI_REDIS_RECORDER_DECLARE_RECORD_CREATE(route_entry);
             SAI_REDIS_RECORDER_DECLARE_RECORD_CREATE(nat_entry);
+            SAI_REDIS_RECORDER_DECLARE_RECORD_CREATE(my_sid_entry);
 
         public: // remove ENTRY
 
@@ -181,6 +182,7 @@ namespace sairedis
             SAI_REDIS_RECORDER_DECLARE_RECORD_REMOVE(neighbor_entry);
             SAI_REDIS_RECORDER_DECLARE_RECORD_REMOVE(route_entry);
             SAI_REDIS_RECORDER_DECLARE_RECORD_REMOVE(nat_entry);
+            SAI_REDIS_RECORDER_DECLARE_RECORD_REMOVE(my_sid_entry);
 
         public: // set ENTRY
 
@@ -192,6 +194,7 @@ namespace sairedis
             SAI_REDIS_RECORDER_DECLARE_RECORD_SET(neighbor_entry);
             SAI_REDIS_RECORDER_DECLARE_RECORD_SET(route_entry);
             SAI_REDIS_RECORDER_DECLARE_RECORD_SET(nat_entry);
+            SAI_REDIS_RECORDER_DECLARE_RECORD_SET(my_sid_entry);
 
         public: // get ENTRY
 
@@ -203,7 +206,7 @@ namespace sairedis
             SAI_REDIS_RECORDER_DECLARE_RECORD_GET(neighbor_entry);
             SAI_REDIS_RECORDER_DECLARE_RECORD_GET(route_entry);
             SAI_REDIS_RECORDER_DECLARE_RECORD_GET(nat_entry);
-
+            SAI_REDIS_RECORDER_DECLARE_RECORD_GET(my_sid_entry);
 
         public: // SAI stats API
 

lib/Recorder.h

@@ -1390,6 +1390,24 @@ sai_status_t RedisRemoteSaiInterface::bulkRemove(
     return bulkRemove(SAI_OBJECT_TYPE_FDB_ENTRY, serializedObjectIds, mode, object_statuses);
 }
 
+sai_status_t RedisRemoteSaiInterface::bulkRemove(
+        _In_ uint32_t object_count,
+        _In_ const sai_my_sid_entry_t *my_sid_entry,
+        _In_ sai_bulk_op_error_mode_t mode,
+        _Out_ sai_status_t *object_statuses)
+{
+    SWSS_LOG_ENTER();
+
+    std::vector<std::string> serializedObjectIds;
+
+    for (uint32_t idx = 0; idx < object_count; idx++)
+    {
+        serializedObjectIds.emplace_back(sai_serialize_my_sid_entry(my_sid_entry[idx]));
+    }
+
+    return bulkRemove(SAI_OBJECT_TYPE_MY_SID_ENTRY, serializedObjectIds, mode, object_statuses);
+}
+
 sai_status_t RedisRemoteSaiInterface::bulkSet(
         _In_ sai_object_type_t object_type,
         _In_ uint32_t object_count,
@@ -1486,6 +1504,25 @@ sai_status_t RedisRemoteSaiInterface::bulkSet(
     return bulkSet(SAI_OBJECT_TYPE_FDB_ENTRY, serializedObjectIds, attr_list, mode, object_statuses);
 }
 
+sai_status_t RedisRemoteSaiInterface::bulkSet(
+        _In_ uint32_t object_count,
+        _In_ const sai_my_sid_entry_t *my_sid_entry,
+        _In_ const sai_attribute_t *attr_list,
+        _In_ sai_bulk_op_error_mode_t mode,
+        _Out_ sai_status_t *object_statuses)
+{
+    SWSS_LOG_ENTER();
+
+    std::vector<std::string> serializedObjectIds;
+
+    for (uint32_t idx = 0; idx < object_count; idx++)
+    {
+        serializedObjectIds.emplace_back(sai_serialize_my_sid_entry(my_sid_entry[idx]));
+    }
+
+    return bulkSet(SAI_OBJECT_TYPE_MY_SID_ENTRY, serializedObjectIds, attr_list, mode, object_statuses);
+}
+
 sai_status_t RedisRemoteSaiInterface::bulkSet(
         _In_ sai_object_type_t object_type,
         _In_ const std::vector<std::string> &serialized_object_ids,
@@ -1765,6 +1802,36 @@ sai_status_t RedisRemoteSaiInterface::bulkCreate(
             object_statuses);
 }
 
+sai_status_t RedisRemoteSaiInterface::bulkCreate(
+        _In_ uint32_t object_count,
+        _In_ const sai_my_sid_entry_t* my_sid_entry,
+        _In_ const uint32_t *attr_count,
+        _In_ const sai_attribute_t **attr_list,
+        _In_ sai_bulk_op_error_mode_t mode,
+        _Out_ sai_status_t *object_statuses)
+{
+    SWSS_LOG_ENTER();
+
+    // TODO support mode
+
+    std::vector<std::string> serialized_object_ids;
+
+    // on create vid is put in db by syncd
+    for (uint32_t idx = 0; idx < object_count; idx++)
+    {
+        std::string str_object_id = sai_serialize_my_sid_entry(my_sid_entry[idx]);
+        serialized_object_ids.push_back(str_object_id);
+    }
+
+    return bulkCreate(
+            SAI_OBJECT_TYPE_MY_SID_ENTRY,
+            serialized_object_ids,
+            attr_count,
+            attr_list,
+            mode,
+            object_statuses);
+}
+
 sai_status_t RedisRemoteSaiInterface::notifySyncd(
         _In_ sai_object_id_t switchId,
         _In_ sai_redis_notify_syncd_t redisNotifySyncd)

lib/RedisRemoteSaiInterface.cpp

@@ -1255,6 +1255,25 @@ sai_status_t ServerSai::processBulkCreateEntry(
         }
         break;
 
+        case SAI_OBJECT_TYPE_MY_SID_ENTRY:
+        {
+            std::vector<sai_my_sid_entry_t> entries(object_count);
+
+            for (uint32_t it = 0; it < object_count; it++)
+            {
+                sai_deserialize_my_sid_entry(objectIds[it], entries[it]);
+            }
+
+            status = m_sai->bulkCreate(
+                    object_count,
+                    entries.data(),
+                    attr_counts.data(),
+                    attr_lists.data(),
+                    mode,
+                    statuses.data());
+        }
+        break;
+
         default:
             return SAI_STATUS_NOT_SUPPORTED;
     }
@@ -1345,6 +1364,23 @@ sai_status_t ServerSai::processBulkRemoveEntry(
         }
         break;
 
+        case SAI_OBJECT_TYPE_MY_SID_ENTRY:
+        {
+            std::vector<sai_my_sid_entry_t> entries(object_count);
+
+            for (uint32_t it = 0; it < object_count; it++)
+            {
+                sai_deserialize_my_sid_entry(objectIds[it], entries[it]);
+            }
+
+            status = m_sai->bulkRemove(
+                    object_count,
+                    entries.data(),
+                    mode,
+                    statuses.data());
+        }
+        break;
+
         default:
             return SAI_STATUS_NOT_SUPPORTED;
     }
@@ -1447,6 +1483,24 @@ sai_status_t ServerSai::processBulkSetEntry(
         }
         break;
 
+        case SAI_OBJECT_TYPE_MY_SID_ENTRY:
+        {
+            std::vector<sai_my_sid_entry_t> entries(object_count);
+
+            for (uint32_t it = 0; it < object_count; it++)
+            {
+                sai_deserialize_my_sid_entry(objectIds[it], entries[it]);
+            }
+
+            status = m_sai->bulkSet(
+                    object_count,
+                    entries.data(),
+                    attr_lists.data(),
+                    mode,
+                    statuses.data());
+        }
+        break;
+
         default:
             return SAI_STATUS_NOT_SUPPORTED;
     }

lib/ServerSai.cpp

@@ -48,7 +48,7 @@ PRIVATE extern const sai_rpf_group_api_t        redis_rpf_group_api;
 PRIVATE extern const sai_samplepacket_api_t     redis_samplepacket_api;
 PRIVATE extern const sai_scheduler_api_t        redis_scheduler_api;
 PRIVATE extern const sai_scheduler_group_api_t  redis_scheduler_group_api;
-PRIVATE extern const sai_segmentroute_api_t     redis_segmentroute_api;
+PRIVATE extern const sai_srv6_api_t             redis_srv6_api;
 PRIVATE extern const sai_stp_api_t              redis_stp_api;
 PRIVATE extern const sai_switch_api_t           redis_switch_api;
 PRIVATE extern const sai_system_port_api_t      redis_system_port_api;
@@ -58,6 +58,8 @@ PRIVATE extern const sai_udf_api_t              redis_udf_api;
 PRIVATE extern const sai_virtual_router_api_t   redis_virtual_router_api;
 PRIVATE extern const sai_vlan_api_t             redis_vlan_api;
 PRIVATE extern const sai_wred_api_t             redis_wred_api;
+PRIVATE extern const sai_my_mac_api_t           redis_my_mac_api;
+PRIVATE extern const sai_ipsec_api_t            redis_ipsec_api;
 
 PRIVATE extern std::shared_ptr<sairedis::SaiInterface>   redis_sai;
 

lib/sai_redis.h

@@ -67,7 +67,7 @@ static sai_apis_t redis_apis = {
     API(mcast_fdb),
     API(bridge),
     API(tam),
-    API(segmentroute),
+    API(srv6),
     API(mpls),
     API(dtel),
     API(bfd),
@@ -77,6 +77,8 @@ static sai_apis_t redis_apis = {
     API(debug_counter),
     API(macsec),
     API(system_port),
+    API(my_mac),
+    API(ipsec),
     API(bmtor),
 };
 

lib/sai_redis_interfacequery.cpp

@@ -0,0 +1,16 @@
+#include "sai_redis.h"
+
+REDIS_GENERIC_QUAD(IPSEC,ipsec);
+REDIS_GENERIC_QUAD(IPSEC_PORT,ipsec_port);
+REDIS_GENERIC_QUAD(IPSEC_SA,ipsec_sa);
+REDIS_GENERIC_STATS(IPSEC_PORT,ipsec_port);
+REDIS_GENERIC_STATS(IPSEC_SA,ipsec_sa);
+
+const sai_ipsec_api_t redis_ipsec_api = {
+
+    REDIS_GENERIC_QUAD_API(ipsec)
+    REDIS_GENERIC_QUAD_API(ipsec_port)
+    REDIS_GENERIC_STATS_API(ipsec_port)
+    REDIS_GENERIC_QUAD_API(ipsec_sa)
+    REDIS_GENERIC_STATS_API(ipsec_sa)
+};

lib/sai_redis_ipsec.cpp

@@ -0,0 +1,8 @@
+#include "sai_redis.h"
+
+REDIS_GENERIC_QUAD(MY_MAC,my_mac);
+
+const sai_my_mac_api_t redis_my_mac_api = {
+
+    REDIS_GENERIC_QUAD_API(my_mac)
+};

lib/sai_redis_my_mac.cpp

@@ -4,6 +4,7 @@ REDIS_BULK_CREATE(NEXT_HOP_GROUP_MEMBER,next_hop_group_members);
 REDIS_BULK_REMOVE(NEXT_HOP_GROUP_MEMBER,next_hop_group_members);
 REDIS_GENERIC_QUAD(NEXT_HOP_GROUP,next_hop_group);
 REDIS_GENERIC_QUAD(NEXT_HOP_GROUP_MEMBER,next_hop_group_member);
+REDIS_GENERIC_QUAD(NEXT_HOP_GROUP_MAP,next_hop_group_map);
 
 const sai_next_hop_group_api_t redis_next_hop_group_api = {
 
@@ -12,4 +13,5 @@ const sai_next_hop_group_api_t redis_next_hop_group_api = {
 
     redis_bulk_create_next_hop_group_members,
     redis_bulk_remove_next_hop_group_members,
+    REDIS_GENERIC_QUAD_API(next_hop_group_map)
 };