[sonic-platform-daemons] Add more physical entity information to DB for physical entity mib

sonic-ledd/scripts/ledd

@@ -10,6 +10,8 @@ try:
     import sys
 
     from sonic_py_common import daemon_base
+    from sonic_py_common import multi_asic
+    from sonic_py_common.interface import backplane_prefix
     from swsscommon import swsscommon
 except ImportError as e:
     raise ImportError (str(e) + " - required module not found")
@@ -35,6 +37,9 @@ SELECT_TIMEOUT = 1000
 
 LEDUTIL_LOAD_ERROR = 1
 
+# The empty namespace refers to linux host namespace.
+EMPTY_NAMESPACE = ''
+
 class DaemonLedd(daemon_base.DaemonBase):
 
     # Run daemon
@@ -65,19 +70,28 @@ class DaemonLedd(daemon_base.DaemonBase):
             self.log_error("Failed to load ledutil: %s" % (str(e)), True)
             sys.exit(LEDUTIL_LOAD_ERROR)
 
-        # Open a handle to the Application database
-        appl_db = daemon_base.db_connect("APPL_DB")
+        # Load the namespace details first from the database_global.json file.
+        swsscommon.SonicDBConfig.initializeGlobalConfig()
+
+        # Get the namespaces in the platform. For multi-asic devices we get the namespaces
+        # of front-end ascis which have front-panel interfaces.
+        namespaces = multi_asic.get_front_end_namespaces()
 
         # Subscribe to PORT table notifications in the Application DB
+        appl_db, sst = {}, {}
         sel = swsscommon.Select()
-        sst = swsscommon.SubscriberStateTable(appl_db, swsscommon.APP_PORT_TABLE_NAME)
-        sel.addSelectable(sst)
 
-        # Listen indefinitely for changes to the PORT table in the Application DB
+        for namespace in namespaces:
+            # Open a handle to the Application database, in all namespaces
+            appl_db[namespace] = daemon_base.db_connect("APPL_DB", namespace=namespace)
+            sst[namespace] = swsscommon.SubscriberStateTable(appl_db[namespace], swsscommon.APP_PORT_TABLE_NAME)
+            sel.addSelectable(sst[namespace])
+
+        # Listen indefinitely for changes to the PORT table in the Application DB's
         while True:
             # Use timeout to prevent ignoring the signals we want to handle
             # in signal_handler() (e.g. SIGTERM for graceful shutdown)
-            (state, c) = sel.select(SELECT_TIMEOUT)
+            (state, selectableObj) = sel.select(SELECT_TIMEOUT)
 
             if state == swsscommon.Select.TIMEOUT:
                 # Do not flood log when select times out
@@ -86,17 +100,23 @@ class DaemonLedd(daemon_base.DaemonBase):
                 self.log_warning("sel.select() did not  return swsscommon.Select.OBJECT")
                 continue
 
-            (key, op, fvp) = sst.pop()
+            # Get the redisselect object  from selectable object
+            redisSelectObj = swsscommon.CastSelectableToRedisSelectObj(selectableObj)
+            # Get the corresponding namespace from redisselect db connector object
+            namespace = redisSelectObj.getDbConnector().getNamespace()
 
-            # TODO: Once these flag entries have been removed from the DB,
-            # we can remove this check
-            if key in ["PortConfigDone", "PortInitDone"]:
-                continue
+            (key, op, fvp) = sst[namespace].pop()
+            if fvp:
+                # TODO: Once these flag entries have been removed from the DB,
+                # we can remove this check
+                if key in ["PortConfigDone", "PortInitDone"]:
+                    continue
 
-            fvp_dict = dict(fvp)
+                fvp_dict = dict(fvp)
 
-            if op == "SET" and "oper_status" in fvp_dict:
-                led_control.port_link_state_change(key, fvp_dict["oper_status"])
+                if op == "SET" and "oper_status" in fvp_dict:
+                    if not key.startswith(backplane_prefix()):
+                        led_control.port_link_state_change(key, fvp_dict["oper_status"])
 
         return 1
 

sonic-ledd/setup.py

@@ -13,6 +13,9 @@
     scripts=[
         'scripts/ledd',
     ],
+    setup_requires= [
+        'wheel'
+    ],
     classifiers=[
         'Development Status :: 4 - Beta',
         'Environment :: No Input/Output (Daemon)',

sonic-pcied/scripts/pcied

@@ -53,20 +53,36 @@ class DaemonPcied(DaemonBase):
         self.state_db = swsssdk.SonicV2Connector(host=REDIS_HOSTIP)
         self.state_db.connect("STATE_DB")
 
+    # Check the PCIe devices
     def check_pcie_devices(self):
-        cmd = [ 'sudo', 'pcieutil', 'pcie-check' ]
-        p = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
-        resultInfo, err = p.communicate()
-        pcie_db_state = self.read_state_db("PCIE_STATUS|", "PCIE_DEVICES")
-
-        for line in resultInfo.splitlines():
-            if PCIE_RESULT_REGEX in line:
-                if "PASSED" in line and "PASSED" not in pcie_db_state:
-                    self.update_state_db("PCIE_STATUS|", "PCIE_DEVICES", "PASSED")
-                    self.log_info("PCIe device status check : PASSED")
-                elif "FAILED" in line and "PASSED" in pcie_db_state:
-                    self.update_state_db("PCIE_STATUS|", "PCIE_DEVICES", "FAILED")
-                    self.log_info("PCIe device status check : FAILED")
+        try:
+            platform_path, _ = device_info.get_paths_to_platform_and_hwsku_dirs()
+            platform_plugins_path = os.path.join(platform_path, "plugins")
+            sys.path.append(os.path.abspath(platform_plugins_path))
+            from pcieutil import PcieUtil
+        except ImportError as e:
+            self.log_warning("Failed to load platform-specific PcieUtil module. Falling back to the common implementation")
+            try:
+                from sonic_platform_base.sonic_pcie.pcie_common import PcieUtil
+                platform_pcieutil = PcieUtil(platform_plugins_path)
+            except ImportError as e:
+                self.log_error("Failed to load default PcieUtil module. Error : {}".format(str(e)), True)
+                raise e
+
+        resultInfo = platform_pcieutil.get_pcie_check()
+        err = 0
+
+        for item in resultInfo:
+            if item["result"] == "Failed":
+                self.log_warning("PCIe Device: " + item["name"] + " Not Found")
+                err += 1
+
+        if err:
+            self.update_state_db("PCIE_DEVICES", "status", "FAILED")
+            self.log_error("PCIe device status check : FAILED")
+        else:
+            self.update_state_db("PCIE_DEVICES", "status", "PASSED")
+            self.log_info("PCIe device status check : PASSED")
 
     def read_state_db(self, key1, key2):
         return self.state_db.get('STATE_DB', key1, key2)

sonic-pcied/setup.py

@@ -13,6 +13,9 @@
     scripts=[
         'scripts/pcied',
     ],
+    setup_requires= [
+        'wheel'
+    ],
     classifiers=[
         'Development Status :: 4 - Beta',
         'Environment :: No Input/Output (Daemon)',