[sonic-sairedis] Add support for PoE

Add SwitchPoe to vslib Add a python script to spawn the PoE syncd process Signed-off-by: Serhiy Boiko <[email protected]>
sonic-net · Jul 22, 2024 · e6bb293 · e6bb293
1 parent a988dd1
commit e6bb293
Show file tree

Hide file tree

Showing 15 changed files with 620 additions and 5 deletions.
diff --git a/meta/Meta.cpp b/meta/Meta.cpp
@@ -1937,6 +1937,10 @@ void Meta::meta_generic_validation_post_remove(
                 // no special action required
                 break;
 
+            case SAI_ATTR_VALUE_TYPE_POE_PORT_POWER_CONSUMPTION:
+                // no special action required
+                break;
+
             default:
                 META_LOG_THROW(md, "serialization type is not supported yet FIXME");
         }
@@ -3573,6 +3577,9 @@ sai_status_t Meta::meta_generic_validation_create(
                 VALIDATION_LIST(md, value.ipprefixlist);
                 break;
 
+            case SAI_ATTR_VALUE_TYPE_POE_PORT_POWER_CONSUMPTION:
+                break;
+
             default:
 
                 META_LOG_THROW(md, "serialization type is not supported yet FIXME");
@@ -4248,6 +4255,9 @@ sai_status_t Meta::meta_generic_validation_set(
             VALIDATION_LIST(md, value.ipprefixlist);
             break;
 
+        case SAI_ATTR_VALUE_TYPE_POE_PORT_POWER_CONSUMPTION:
+            break;
+
         default:
 
             META_LOG_THROW(md, "serialization type is not supported yet FIXME");
@@ -4635,6 +4645,9 @@ sai_status_t Meta::meta_generic_validation_get(
                 VALIDATION_LIST(md, value.ipprefixlist);
                 break;
 
+            case SAI_ATTR_VALUE_TYPE_POE_PORT_POWER_CONSUMPTION:
+                break;
+
             default:
 
                 // acl capability will is more complex since is in/out we need to check stage
@@ -4908,6 +4921,9 @@ void Meta::meta_generic_validation_post_get(
                 VALIDATION_LIST_GET(md, value.ipprefixlist);
                 break;
 
+            case SAI_ATTR_VALUE_TYPE_POE_PORT_POWER_CONSUMPTION:
+                break;
+
             default:
 
                 META_LOG_THROW(md, "serialization type is not supported yet FIXME");
@@ -5802,6 +5818,10 @@ void Meta::meta_generic_validation_post_create(
                 // no special action required
                 break;
 
+            case SAI_ATTR_VALUE_TYPE_POE_PORT_POWER_CONSUMPTION:
+                // no special action required
+                break;
+
             default:
 
                 META_LOG_THROW(md, "serialization type is not supported yet FIXME");
@@ -6041,6 +6061,10 @@ void Meta::meta_generic_validation_post_set(
             // no special action required
             break;
 
+        case SAI_ATTR_VALUE_TYPE_POE_PORT_POWER_CONSUMPTION:
+            // no special action required
+            break;
+
         default:
             META_LOG_THROW(md, "serialization type is not supported yet FIXME");
     }

diff --git a/meta/SaiSerialize.cpp b/meta/SaiSerialize.cpp
@@ -784,6 +784,14 @@ std::string sai_serialize_object_type(
     return sai_serialize_enum(object_type, &sai_metadata_enum_sai_object_type_t);
 }
 
+std::string sai_serialize_switch_type(
+        _In_ const sai_switch_type_t switch_type)
+{
+    SWSS_LOG_ENTER();
+
+    return sai_serialize_enum(switch_type, &sai_metadata_enum_sai_switch_type_t);
+}
+
 std::string sai_serialize_log_level(
         _In_ sai_log_level_t log_level)
 {

diff --git a/meta/sai_serialize.h b/meta/sai_serialize.h
@@ -75,6 +75,9 @@ std::string sai_serialize_vlan_id(
 std::string sai_serialize_object_type(
         _In_ const sai_object_type_t object_type);
 
+std::string sai_serialize_switch_type(
+        _In_ const sai_switch_type_t switch_type);
+
 std::string sai_serialize_object_id(
         _In_ const sai_object_id_t object_id);
 

diff --git a/syncd/SaiSwitch.cpp b/syncd/SaiSwitch.cpp
@@ -135,24 +135,28 @@ void SaiSwitch::getDefaultMacAddress(
 sai_switch_type_t SaiSwitch::getSwitchType() const
 {
     SWSS_LOG_ENTER();
+    sai_switch_type_t switch_type;
     sai_attribute_t attr;
 
     attr.id = SAI_SWITCH_ATTR_TYPE;
 
     sai_status_t status = m_vendorSai->get(SAI_OBJECT_TYPE_SWITCH, m_switch_rid, 1, &attr);
-
     if (status != SAI_STATUS_SUCCESS)
     {
         SWSS_LOG_WARN("failed to get switch type with status: %s, assume default SAI_SWITCH_TYPE_NPU",
                 sai_serialize_status(status).c_str());
 
         // Set to SAI_SWITCH_TYPE_NPU and move on
-        attr.value.s32 = SAI_SWITCH_TYPE_NPU;
+        switch_type = SAI_SWITCH_TYPE_NPU;
+    }
+    else
+    {
+        switch_type = (sai_switch_type_t) attr.value.s32;
     }
 
-    SWSS_LOG_INFO("switch type: '%s'", (attr.value.s32 == SAI_SWITCH_TYPE_NPU ? "SAI_SWITCH_TYPE_NPU" : "SAI_SWITCH_TYPE_PHY"));
+    SWSS_LOG_INFO("switch type: '%s'", sai_serialize_switch_type(switch_type).c_str());
 
-    return (sai_switch_type_t) attr.value.s32;
+    return switch_type;
 }
 
 #define MAX_HARDWARE_INFO_LENGTH 0x1000

diff --git a/syncd/scripts/poesyncdmgrd b/syncd/scripts/poesyncdmgrd
@@ -0,0 +1,76 @@
+#!/usr/bin/env python3
+
+import os
+import signal
+import subprocess
+import sys
+import syslog
+import time
+
+
+SYSLOG_IDENTIFIER = os.path.basename(__file__)
+
+EXIT_SUCCESS = 0
+EXIT_INSUFFICIENT_PERMISSIONS = 1
+EXIT_UNKNOWN = 2
+
+running = True
+exit_code = EXIT_UNKNOWN
+
+
+def fatal_signal_handler(sig, frame):
+    global running
+
+    signal_name = signal.Signals(sig).name
+
+    syslog.syslog(syslog.LOG_NOTICE, 'Caught signal {} - exiting...'.format(signal_name))
+    exit_code = sig + 128
+    running = False
+
+
+def main():
+    # Only privileged users can run this daemon
+    if os.geteuid() != 0:
+        print('Root privileges required for this operation')
+        return EXIT_INSUFFICIENT_PERMISSIONS
+
+    syslog.openlog(SYSLOG_IDENTIFIER)
+
+    # Register our signal handlers
+    signal.signal(signal.SIGTERM, fatal_signal_handler)
+
+    # Check if a poe config exists
+    if not os.path.isfile('/usr/share/sonic/hwsku/poe_config.json'):
+        syslog.syslog(syslog.LOG_NOTICE, 'PoE is not supported on this platform. Exiting ...')
+        syslog.closelog()
+        time.sleep(2)
+        return EXIT_SUCCESS
+
+    # Spawn poe syncd process
+    cmd = '/usr/bin/syncd -s -p /etc/sai.d/poe.profile -x /usr/share/sonic/hwsku/context_config.json -g 1'
+    proc = subprocess.Popen(cmd.split(), close_fds=True)
+
+    global running
+
+    # Check all of our subprocesses. If any exit, we should too.
+    while running:
+        proc.poll()
+        if proc.returncode is not None:
+            syslog.syslog(syslog.LOG_NOTICE, 'Subprocess PID {} exited. Shutting down ...'.format(proc.pid))
+            running = False
+            break
+        time.sleep(1)
+
+    # If we get here, either the subprocess exited or we recieved a signal to exit
+    # so we send SIGTERM to the subprocesses (if it is still running) before exiting
+    if proc.returncode is None:
+        syslog.syslog(syslog.LOG_INFO, 'Terminating PID {} ...'.format(proc.pid))
+        proc.terminate()
+
+    syslog.closelog()
+
+    return exit_code
+
+
+if __name__ == '__main__':
+    sys.exit(main())
diff --git a/unittest/vslib/TestSwitchConfig.cpp b/unittest/vslib/TestSwitchConfig.cpp
@@ -19,6 +19,9 @@ TEST(SwitchConfig, parseSaiSwitchType)
 
     EXPECT_TRUE(SwitchConfig::parseSaiSwitchType(SAI_VALUE_SAI_SWITCH_TYPE_PHY, type));
     EXPECT_EQ(type, SAI_SWITCH_TYPE_PHY);
+
+    EXPECT_TRUE(SwitchConfig::parseSaiSwitchType(SAI_VALUE_SAI_SWITCH_TYPE_POE, type));
+    EXPECT_EQ(type, SAI_SWITCH_TYPE_POE);
 }
 
 TEST(SwitchConfig, parseSwitchType)
@@ -36,6 +39,9 @@ TEST(SwitchConfig, parseSwitchType)
 
     EXPECT_TRUE(SwitchConfig::parseSwitchType(SAI_VALUE_VS_SWITCH_TYPE_MLNX2700, type));
     EXPECT_EQ(type, SAI_VS_SWITCH_TYPE_MLNX2700);
+
+    EXPECT_TRUE(SwitchConfig::parseSwitchType(SAI_VALUE_VS_SWITCH_TYPE_POE, type));
+    EXPECT_EQ(type, SAI_VS_SWITCH_TYPE_POE);
 }
 
 

diff --git a/vslib/Makefile.am b/vslib/Makefile.am
@@ -49,6 +49,7 @@ libSaiVS_a_SOURCES = \
 					  SwitchContainer.cpp \
 					  Switch.cpp \
 					  SwitchMLNX2700.cpp \
+					  SwitchPoE.cpp \
 					  SwitchNvdaMBF2H536C.cpp \
 					  SwitchStateBase.cpp \
 					  SwitchStateBaseFdb.cpp \

diff --git a/vslib/SwitchConfig.cpp b/vslib/SwitchConfig.cpp
@@ -40,11 +40,16 @@ bool SwitchConfig::parseSaiSwitchType(
     {
         saiSwitchType = SAI_SWITCH_TYPE_PHY;
     }
+    else if (st == SAI_VALUE_SAI_SWITCH_TYPE_POE)
+    {
+        saiSwitchType = SAI_SWITCH_TYPE_POE;
+    }
     else
     {
-        SWSS_LOG_ERROR("unknown SAI switch type: '%s', expected (%s|%s)",
+        SWSS_LOG_ERROR("unknown SAI switch type: '%s', expected (%s|%s|%s)",
                 saiSwitchTypeStr,
                 SAI_VALUE_SAI_SWITCH_TYPE_NPU,
+                SAI_VALUE_SAI_SWITCH_TYPE_POE,
                 SAI_VALUE_SAI_SWITCH_TYPE_PHY);
 
         return false;
@@ -73,6 +78,10 @@ bool SwitchConfig::parseSwitchType(
     {
         switchType = SAI_VS_SWITCH_TYPE_BCM81724;
     }
+    else if (st == SAI_VALUE_VS_SWITCH_TYPE_POE)
+    {
+        switchType = SAI_VS_SWITCH_TYPE_POE;
+    }
     else if (st == SAI_VALUE_VS_SWITCH_TYPE_MLNX2700)
     {
         switchType = SAI_VS_SWITCH_TYPE_MLNX2700;
@@ -96,6 +105,7 @@ bool SwitchConfig::parseSwitchType(
                 SAI_VALUE_VS_SWITCH_TYPE_BCM81724,
                 SAI_VALUE_VS_SWITCH_TYPE_BCM56850,
                 SAI_VALUE_VS_SWITCH_TYPE_BCM56971B0,
+                SAI_VALUE_VS_SWITCH_TYPE_POE,
                 SAI_VALUE_VS_SWITCH_TYPE_MLNX2700,
                 SAI_VALUE_VS_SWITCH_TYPE_NVDA_MBF2H536C,
                 SAI_VALUE_VS_SWITCH_TYPE_DPU_SIMU_2P

diff --git a/vslib/SwitchConfig.h b/vslib/SwitchConfig.h
@@ -28,6 +28,8 @@ namespace saivs
 
         SAI_VS_SWITCH_TYPE_NVDA_MBF2H536C,
 
+        SAI_VS_SWITCH_TYPE_POE,
+
     } sai_vs_switch_type_t;
 
     typedef enum _sai_vs_boot_type_t