diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/buffers.json.j2 b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/buffers.json.j2
new file mode 120000
index 0000000000..add8bf8bb7
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/buffers.json.j2
@@ -0,0 +1 @@
+../../x86_64-mlnx_msn2700-r0/ACS-MSN2700/buffers.json.j2
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/buffers_defaults_t0.j2 b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/buffers_defaults_t0.j2
new file mode 120000
index 0000000000..ddb883a1da
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/buffers_defaults_t0.j2
@@ -0,0 +1 @@
+../../x86_64-mlnx_msn4700-r0/ACS-MSN4700/buffers_defaults_t0.j2
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/buffers_defaults_t1.j2 b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/buffers_defaults_t1.j2
new file mode 120000
index 0000000000..f8bbb6e631
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/buffers_defaults_t1.j2
@@ -0,0 +1 @@
+../../x86_64-mlnx_msn4700-r0/ACS-MSN4700/buffers_defaults_t1.j2
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/pg_profile_lookup.ini b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/pg_profile_lookup.ini
new file mode 120000
index 0000000000..88e51ceae0
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/pg_profile_lookup.ini
@@ -0,0 +1 @@
+../../x86_64-mlnx_msn4700-r0/ACS-MSN4700/pg_profile_lookup.ini
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/port_config.ini b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/port_config.ini
new file mode 120000
index 0000000000..606b074c20
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/port_config.ini
@@ -0,0 +1 @@
+../../x86_64-mlnx_msn4700-r0/ACS-MSN4700/port_config.ini
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/qos.json.j2 b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/qos.json.j2
new file mode 120000
index 0000000000..eccf286dc8
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/qos.json.j2
@@ -0,0 +1 @@
+../../x86_64-mlnx_msn2700-r0/ACS-MSN2700/qos.json.j2
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/sai.profile b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/sai.profile
new file mode 100644
index 0000000000..be729cb4e0
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/sai.profile
@@ -0,0 +1 @@
+SAI_INIT_CONFIG_FILE=/usr/share/sonic/hwsku/sai_4410.xml
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/sai_4410.xml b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/sai_4410.xml
new file mode 100644
index 0000000000..5e5b01cad6
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/ACS-MSN4410/sai_4410.xml
@@ -0,0 +1,247 @@
+
+
+
+
+
+ 00:02:03:04:05:00
+
+
+ 1
+
+
+ 32
+
+
+
+
+ 1
+ 8
+ 17
+ 3
+ 1536
+
+
+ 5
+ 8
+ 16
+ 3
+ 1536
+
+
+ 9
+ 8
+ 19
+ 3
+ 1536
+
+
+ 13
+ 8
+ 18
+ 3
+ 1536
+
+
+ 17
+ 8
+ 21
+ 3
+ 1536
+
+
+ 21
+ 8
+ 20
+ 3
+ 1536
+
+
+ 25
+ 8
+ 23
+ 3
+ 1536
+
+
+ 29
+ 8
+ 22
+ 3
+ 1536
+
+
+ 33
+ 8
+ 29
+ 3
+ 1536
+
+
+ 37
+ 8
+ 28
+ 3
+ 1536
+
+
+ 41
+ 8
+ 31
+ 3
+ 1536
+
+
+ 45
+ 8
+ 30
+ 3
+ 1536
+
+
+ 49
+ 8
+ 25
+ 3
+ 1536
+
+
+ 53
+ 8
+ 24
+ 3
+ 1536
+
+
+ 57
+ 8
+ 27
+ 3
+ 1536
+
+
+ 61
+ 8
+ 26
+ 3
+ 1536
+
+
+ 65
+ 8
+ 14
+ 3
+ 1536
+
+
+ 69
+ 8
+ 15
+ 3
+ 1536
+
+
+ 73
+ 8
+ 12
+ 3
+ 1536
+
+
+ 77
+ 8
+ 13
+ 3
+ 1536
+
+
+ 81
+ 8
+ 10
+ 3
+ 1536
+
+
+ 85
+ 8
+ 11
+ 3
+ 1536
+
+
+ 89
+ 8
+ 8
+ 3
+ 1536
+
+
+ 93
+ 8
+ 9
+ 3
+ 1536
+
+
+ 97
+ 8
+ 2
+ 3
+ 1536
+
+
+ 101
+ 8
+ 3
+ 3
+ 1536
+
+
+ 105
+ 8
+ 0
+
+
+ 3
+
+
+ 1536
+
+
+ 109
+ 8
+ 1
+ 3
+ 1536
+
+
+ 113
+ 8
+ 6
+ 3
+ 1536
+
+
+ 117
+ 8
+ 7
+ 3
+ 1536
+
+
+ 121
+ 8
+ 4
+ 3
+ 1536
+
+
+ 125
+ 8
+ 5
+ 3
+ 1536
+
+
+
+
+
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/default_sku b/device/mellanox/x86_64-mlnx_msn4410-r0/default_sku
new file mode 100644
index 0000000000..d175094cfe
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/default_sku
@@ -0,0 +1 @@
+ACS-MSN4410 t1
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/pcie.yaml b/device/mellanox/x86_64-mlnx_msn4410-r0/pcie.yaml
new file mode 120000
index 0000000000..187649f4b8
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/pcie.yaml
@@ -0,0 +1 @@
+../x86_64-mlnx_msn4600c-r0/pcie.yaml
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/platform_components.json b/device/mellanox/x86_64-mlnx_msn4410-r0/platform_components.json
new file mode 100644
index 0000000000..bb1afce801
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/platform_components.json
@@ -0,0 +1,14 @@
+{
+ "chassis": {
+ "x86_64-mlnx_msn4410-r0": {
+ "component": {
+ "ONIE": { },
+ "SSD": { },
+ "BIOS": { },
+ "CPLD1": { },
+ "CPLD2": { },
+ "CPLD3": { }
+ }
+ }
+ }
+}
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/platform_reboot b/device/mellanox/x86_64-mlnx_msn4410-r0/platform_reboot
new file mode 120000
index 0000000000..43c8ea5674
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/platform_reboot
@@ -0,0 +1 @@
+../x86_64-mlnx_msn2700-r0/platform_reboot
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/platform_wait b/device/mellanox/x86_64-mlnx_msn4410-r0/platform_wait
new file mode 120000
index 0000000000..4b30bd4298
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/platform_wait
@@ -0,0 +1 @@
+../x86_64-mlnx_msn2700-r0/platform_wait
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/eeprom.py b/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/eeprom.py
new file mode 120000
index 0000000000..b4e2a6a616
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/eeprom.py
@@ -0,0 +1 @@
+../../x86_64-mlnx_msn2700-r0/plugins/eeprom.py
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/psuutil.py b/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/psuutil.py
new file mode 120000
index 0000000000..9f724238a8
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/psuutil.py
@@ -0,0 +1 @@
+../../x86_64-mlnx_msn2700-r0/plugins/psuutil.py
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/sfplpmget.py b/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/sfplpmget.py
new file mode 120000
index 0000000000..2e84f435ab
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/sfplpmget.py
@@ -0,0 +1 @@
+../../x86_64-mlnx_msn2700-r0/plugins/sfplpmget.py
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/sfplpmset.py b/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/sfplpmset.py
new file mode 120000
index 0000000000..6a88bac304
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/sfplpmset.py
@@ -0,0 +1 @@
+../../x86_64-mlnx_msn2700-r0/plugins/sfplpmset.py
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/sfpreset.py b/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/sfpreset.py
new file mode 120000
index 0000000000..fef2063e34
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/sfpreset.py
@@ -0,0 +1 @@
+../../x86_64-mlnx_msn2700-r0/plugins/sfpreset.py
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/sfputil.py b/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/sfputil.py
new file mode 100644
index 0000000000..336d729e95
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/plugins/sfputil.py
@@ -0,0 +1,655 @@
+# sfputil.py
+#
+# Platform-specific SFP transceiver interface for SONiC
+#
+
+try:
+ import subprocess
+ from sonic_sfp.sfputilbase import *
+ import syslog
+except ImportError as e:
+ raise ImportError("%s - required module not found" % str(e))
+
+# sfp supports dom
+XCVR_DOM_CAPABILITY_DOM_SUPPORT_BIT = 0x40
+
+# sfp module threshold offset and width
+SFP_MODULE_THRESHOLD_OFFSET = 0
+SFP_MODULE_THRESHOLD_WIDTH = 56
+
+# I2C page size for sfp
+SFP_I2C_PAGE_SIZE = 256
+
+# parameters for DB connection
+REDIS_TIMEOUT_USECS = 0
+
+# parameters for SFP presence
+SFP_STATUS_INSERTED = '1'
+
+# system level event/error
+EVENT_ON_ALL_SFP = '-1'
+SYSTEM_NOT_READY = 'system_not_ready'
+SYSTEM_READY = 'system_become_ready'
+SYSTEM_FAIL = 'system_fail'
+
+GET_PLATFORM_CMD = "sonic-cfggen -d -v DEVICE_METADATA.localhost.platform"
+
+# Ethernet <=> sfp
+SFP_PORT_NAME_OFFSET = 0
+SFP_PORT_NAME_CONVENTION = "sfp{}"
+
+# magic code defnition for port number, qsfp port position of each platform
+# port_position_tuple = (PORT_START, QSFP_PORT_START, PORT_END, PORT_IN_BLOCK, EEPROM_OFFSET)
+platform_dict = {'x86_64-mlnx_msn2700-r0': 0, 'x86_64-mlnx_msn2740-r0': 0, 'x86_64-mlnx_msn2100-r0': 1, 'x86_64-mlnx_msn2410-r0': 2, 'x86_64-mlnx_msn2010-r0': 3, 'x86_64-mlnx_msn3420-r0':5, 'x86_64-mlnx_msn3700-r0': 0, 'x86_64-mlnx_msn3700c-r0': 0, 'x86_64-mlnx_msn3800-r0': 4, 'x86_64-mlnx_msn4410-r0': 0, 'x86_64-mlnx_msn4600c':4, 'x86_64-mlnx_msn4700-r0': 0}
+port_position_tuple_list = [(0, 0, 31, 32, 1), (0, 0, 15, 16, 1), (0, 48, 55, 56, 1), (0, 18, 21, 22, 1), (0, 0, 63, 64, 1), (0, 48, 59, 60, 1)]
+
+def log_info(msg, also_print_to_console=False):
+ syslog.openlog("sfputil")
+ syslog.syslog(syslog.LOG_INFO, msg)
+ syslog.closelog()
+
+def log_err(msg, also_print_to_console=False):
+ syslog.openlog("sfputil")
+ syslog.syslog(syslog.LOG_ERR, msg)
+ syslog.closelog()
+
+class SfpUtil(SfpUtilBase):
+ """Platform-specific SfpUtil class"""
+ PORT_START = 0
+ QSFP_PORT_START = 0
+ PORT_END = 0
+ PORTS_IN_BLOCK = 0
+ EEPROM_OFFSET = 0
+
+ db_sel = None
+ db_sel_timeout = None
+ db_sel_object = None
+ db_sel_tbl = None
+ state_db = None
+ sfpd_status_tbl = None
+
+ @property
+ def port_start(self):
+ return self.PORT_START
+
+ @property
+ def port_end(self):
+ return self.PORT_END
+
+ @property
+ def qsfp_ports(self):
+ return range(self.QSFP_PORT_START, self.PORTS_IN_BLOCK + 1)
+
+ @property
+ def port_to_eeprom_mapping(self):
+ print "dependency on sysfs has been removed"
+ raise Exception()
+
+ def get_port_position_tuple_by_platform_name(self):
+ p = subprocess.Popen(GET_PLATFORM_CMD, shell=True, stdout=subprocess.PIPE)
+ out, err = p.communicate()
+ position_tuple = port_position_tuple_list[platform_dict[out.rstrip('\n')]]
+ return position_tuple
+
+ def __init__(self):
+ port_position_tuple = self.get_port_position_tuple_by_platform_name()
+ self.PORT_START = port_position_tuple[0] + 1
+ self.QSFP_PORT_START = port_position_tuple[1] + 1
+ self.PORT_END = port_position_tuple[2] + 1
+ self.PORTS_IN_BLOCK = port_position_tuple[3]
+ self.EEPROM_OFFSET = port_position_tuple[4]
+ self.mlnx_sfpd_started = False
+
+ SfpUtilBase.__init__(self)
+
+ def get_presence(self, port_num):
+ presence = False
+
+ # Check for invalid port_num
+ if port_num < self.port_start or port_num > self.port_end:
+ return presence
+
+ port_num += SFP_PORT_NAME_OFFSET
+ sfpname = SFP_PORT_NAME_CONVENTION.format(port_num)
+
+ ethtool_cmd = "ethtool -m {} 2>/dev/null".format(sfpname)
+ try:
+ proc = subprocess.Popen(ethtool_cmd, stdout=subprocess.PIPE, shell=True, stderr=subprocess.STDOUT)
+ stdout = proc.communicate()[0]
+ proc.wait()
+ result = stdout.rstrip('\n')
+ if result != '':
+ presence = True
+
+ except OSError, e:
+ return presence
+
+ return presence
+
+ def get_low_power_mode(self, port_num):
+ # Check for invalid port_num
+ if port_num < self.port_start or port_num > self.port_end:
+ return False
+
+ lpm_cmd = "docker exec syncd python /usr/share/sonic/platform/plugins/sfplpmget.py {}".format(port_num)
+
+ try:
+ output = subprocess.check_output(lpm_cmd, shell=True)
+ if 'LPM ON' in output:
+ return True
+ except subprocess.CalledProcessError as e:
+ print "Error! Unable to get LPM for {}, rc = {}, err msg: {}".format(port_num, e.returncode, e.output)
+ return False
+
+ return False
+
+ def set_low_power_mode(self, port_num, lpmode):
+ # Check for invalid port_num
+ if port_num < self.port_start or port_num > self.port_end:
+ return False
+
+ curr_lpmode = self.get_low_power_mode(port_num)
+ if curr_lpmode == lpmode:
+ return True
+
+ # Compose LPM command
+ lpm = 'on' if lpmode else 'off'
+ lpm_cmd = "docker exec syncd python /usr/share/sonic/platform/plugins/sfplpmset.py {} {}".format(port_num, lpm)
+
+ # Set LPM
+ try:
+ subprocess.check_output(lpm_cmd, shell=True)
+ except subprocess.CalledProcessError as e:
+ print "Error! Unable to set LPM for {}, rc = {}, err msg: {}".format(port_num, e.returncode, e.output)
+ return False
+
+ return True
+
+ def reset(self, port_num):
+ # Check for invalid port_num
+ if port_num < self.port_start or port_num > self.port_end:
+ return False
+
+ lpm_cmd = "docker exec syncd python /usr/share/sonic/platform/plugins/sfpreset.py {}".format(port_num)
+
+ try:
+ subprocess.check_output(lpm_cmd, shell=True)
+ return True
+ except subprocess.CalledProcessError as e:
+ print "Error! Unable to set LPM for {}, rc = {}, err msg: {}".format(port_num, e.returncode, e.output)
+ return False
+
+ def get_transceiver_change_event(self, timeout=0):
+ phy_port_dict = {}
+ status = True
+
+ if self.db_sel is None:
+ from swsscommon import swsscommon
+ self.state_db = swsscommon.DBConnector("STATE_DB",
+ REDIS_TIMEOUT_USECS,
+ True)
+
+ # Subscribe to state table for SFP change notifications
+ self.db_sel = swsscommon.Select()
+ self.db_sel_tbl = swsscommon.NotificationConsumer(self.state_db, 'TRANSCEIVER_NOTIFY')
+ self.db_sel.addSelectable(self.db_sel_tbl)
+ self.db_sel_timeout = swsscommon.Select.TIMEOUT
+ self.db_sel_object = swsscommon.Select.OBJECT
+ self.sfpd_status_tbl = swsscommon.Table(self.state_db, 'MLNX_SFPD_TASK')
+
+ # Check the liveness of mlnx-sfpd, if it failed, return system_fail event
+ # If mlnx-sfpd not started, return system_not_ready event
+ keys = self.sfpd_status_tbl.getKeys()
+ if 'LIVENESS' not in keys:
+ if self.mlnx_sfpd_started:
+ log_err("mlnx-sfpd exited, return false to notify xcvrd.")
+ phy_port_dict[EVENT_ON_ALL_SFP] = SYSTEM_FAIL
+ return False, phy_port_dict
+ else:
+ log_info("mlnx-sfpd not ready, return false to notify xcvrd.")
+ phy_port_dict[EVENT_ON_ALL_SFP] = SYSTEM_NOT_READY
+ return False, phy_port_dict
+ else:
+ if not self.mlnx_sfpd_started:
+ self.mlnx_sfpd_started = True
+ log_info("mlnx-sfpd is running")
+ phy_port_dict[EVENT_ON_ALL_SFP] = SYSTEM_READY
+ return False, phy_port_dict
+
+ if timeout:
+ (state, c) = self.db_sel.select(timeout)
+ else:
+ (state, c) = self.db_sel.select()
+
+ if state == self.db_sel_timeout:
+ status = True
+ elif state != self.db_sel_object:
+ status = False
+ else:
+ (key, op, fvp) = self.db_sel_tbl.pop()
+ phy_port_dict[key] = op
+
+ return status, phy_port_dict
+
+ def _read_eeprom_specific_bytes(self, sysfsfile_eeprom, offset, num_bytes):
+ print("_read_eeprom_specific_bytes should not be called since the sysfs it dependents on will no longer exist.")
+ print("_read_eeprom_specific_bytes_via_ethtool should be called instead")
+ raise Exception()
+
+ # Read out any bytes from any offset
+ def _read_eeprom_specific_bytes_via_ethtool(self, port_num, offset, num_bytes):
+ port_num += SFP_PORT_NAME_OFFSET
+ sfpname = SFP_PORT_NAME_CONVENTION.format(port_num)
+
+ eeprom_raw = []
+ ethtool_cmd = "ethtool -m {} hex on offset {} length {}".format(sfpname, offset, num_bytes)
+ try:
+ output = subprocess.check_output(ethtool_cmd, shell=True)
+ output_lines = output.splitlines()
+ first_line_raw = output_lines[0]
+ if "Offset" in first_line_raw:
+ for line in output_lines[2:]:
+ line_split = line.split()
+ eeprom_raw = eeprom_raw + line_split[1:]
+ except subprocess.CalledProcessError as e:
+ return None
+
+ return eeprom_raw
+
+ # Read eeprom
+ def _read_eeprom_devid(self, port_num, devid, offset, num_bytes = 512):
+ if port_num in self.osfp_ports:
+ pass
+ elif port_num in self.qsfp_ports:
+ pass
+ elif (self.DOM_EEPROM_ADDR == devid):
+ offset += 256
+
+ eeprom_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, offset, num_bytes)
+
+ return eeprom_raw
+
+ # Read out SFP type, vendor name, PN, REV, SN from eeprom.
+ def get_transceiver_info_dict(self, port_num):
+ transceiver_info_dict = {}
+ compliance_code_dict = {}
+
+ # ToDo: OSFP tranceiver info parsing not fully supported.
+ # in inf8628.py lack of some memory map definition
+ # will be implemented when the inf8628 memory map ready
+ if port_num in self.osfp_ports:
+ offset = 0
+ vendor_rev_width = XCVR_HW_REV_WIDTH_OSFP
+
+ sfpi_obj = inf8628InterfaceId()
+ if sfpi_obj is None:
+ print("Error: sfp_object open failed")
+ return None
+
+ sfp_type_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + OSFP_TYPE_OFFSET), XCVR_TYPE_WIDTH)
+ if sfp_type_raw is not None:
+ sfp_type_data = sfpi_obj.parse_sfp_type(sfp_type_raw, 0)
+ else:
+ return None
+
+ sfp_vendor_name_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + OSFP_VENDOR_NAME_OFFSET), XCVR_VENDOR_NAME_WIDTH)
+ if sfp_vendor_name_raw is not None:
+ sfp_vendor_name_data = sfpi_obj.parse_vendor_name(sfp_vendor_name_raw, 0)
+ else:
+ return None
+
+ sfp_vendor_pn_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + OSFP_VENDOR_PN_OFFSET), XCVR_VENDOR_PN_WIDTH)
+ if sfp_vendor_pn_raw is not None:
+ sfp_vendor_pn_data = sfpi_obj.parse_vendor_pn(sfp_vendor_pn_raw, 0)
+ else:
+ return None
+
+ sfp_vendor_rev_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + OSFP_HW_REV_OFFSET), vendor_rev_width)
+ if sfp_vendor_rev_raw is not None:
+ sfp_vendor_rev_data = sfpi_obj.parse_vendor_rev(sfp_vendor_rev_raw, 0)
+ else:
+ return None
+
+ sfp_vendor_sn_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + OSFP_VENDOR_SN_OFFSET), XCVR_VENDOR_SN_WIDTH)
+ if sfp_vendor_sn_raw is not None:
+ sfp_vendor_sn_data = sfpi_obj.parse_vendor_sn(sfp_vendor_sn_raw, 0)
+ else:
+ return None
+
+ transceiver_info_dict['type'] = sfp_type_data['data']['type']['value']
+ transceiver_info_dict['manufacturer'] = sfp_vendor_name_data['data']['Vendor Name']['value']
+ transceiver_info_dict['model'] = sfp_vendor_pn_data['data']['Vendor PN']['value']
+ transceiver_info_dict['hardware_rev'] = sfp_vendor_rev_data['data']['Vendor Rev']['value']
+ transceiver_info_dict['serial'] = sfp_vendor_sn_data['data']['Vendor SN']['value']
+ # Below part is added to avoid fail the xcvrd, shall be implemented later
+ transceiver_info_dict['vendor_oui'] = 'N/A'
+ transceiver_info_dict['vendor_date'] = 'N/A'
+ transceiver_info_dict['connector'] = 'N/A'
+ transceiver_info_dict['encoding'] = 'N/A'
+ transceiver_info_dict['ext_identifier'] = 'N/A'
+ transceiver_info_dict['ext_rateselect_compliance'] = 'N/A'
+ transceiver_info_dict['cable_type'] = 'N/A'
+ transceiver_info_dict['cable_length'] = 'N/A'
+ transceiver_info_dict['specification_compliance'] = 'N/A'
+ transceiver_info_dict['nominal_bit_rate'] = 'N/A'
+
+ else:
+ if port_num in self.qsfp_ports:
+ offset = 128
+ vendor_rev_width = XCVR_HW_REV_WIDTH_QSFP
+ interface_info_bulk_width = XCVR_INTFACE_BULK_WIDTH_QSFP
+ sfp_type = 'QSFP'
+
+ sfpi_obj = sff8436InterfaceId()
+ if sfpi_obj is None:
+ print("Error: sfp_object open failed")
+ return None
+
+ else:
+ offset = 0
+ vendor_rev_width = XCVR_HW_REV_WIDTH_SFP
+ interface_info_bulk_width = XCVR_INTFACE_BULK_WIDTH_SFP
+ sfp_type = 'SFP'
+
+ sfpi_obj = sff8472InterfaceId()
+ if sfpi_obj is None:
+ print("Error: sfp_object open failed")
+ return None
+
+ sfp_interface_bulk_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + XCVR_INTFACE_BULK_OFFSET), interface_info_bulk_width)
+ if sfp_interface_bulk_raw is not None:
+ sfp_interface_bulk_data = sfpi_obj.parse_sfp_info_bulk(sfp_interface_bulk_raw, 0)
+ else:
+ return None
+
+ sfp_vendor_name_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + XCVR_VENDOR_NAME_OFFSET), XCVR_VENDOR_NAME_WIDTH)
+ if sfp_vendor_name_raw is not None:
+ sfp_vendor_name_data = sfpi_obj.parse_vendor_name(sfp_vendor_name_raw, 0)
+ else:
+ return None
+
+ sfp_vendor_pn_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + XCVR_VENDOR_PN_OFFSET), XCVR_VENDOR_PN_WIDTH)
+ if sfp_vendor_pn_raw is not None:
+ sfp_vendor_pn_data = sfpi_obj.parse_vendor_pn(sfp_vendor_pn_raw, 0)
+ else:
+ return None
+
+ sfp_vendor_rev_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + XCVR_HW_REV_OFFSET), vendor_rev_width)
+ if sfp_vendor_rev_raw is not None:
+ sfp_vendor_rev_data = sfpi_obj.parse_vendor_rev(sfp_vendor_rev_raw, 0)
+ else:
+ return None
+
+ sfp_vendor_sn_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + XCVR_VENDOR_SN_OFFSET), XCVR_VENDOR_SN_WIDTH)
+ if sfp_vendor_sn_raw is not None:
+ sfp_vendor_sn_data = sfpi_obj.parse_vendor_sn(sfp_vendor_sn_raw, 0)
+ else:
+ return None
+
+ sfp_vendor_oui_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + XCVR_VENDOR_OUI_OFFSET), XCVR_VENDOR_OUI_WIDTH)
+ if sfp_vendor_oui_raw is not None:
+ sfp_vendor_oui_data = sfpi_obj.parse_vendor_oui(sfp_vendor_oui_raw, 0)
+ else:
+ return None
+
+ sfp_vendor_date_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + XCVR_VENDOR_DATE_OFFSET), XCVR_VENDOR_DATE_WIDTH)
+ if sfp_vendor_date_raw is not None:
+ sfp_vendor_date_data = sfpi_obj.parse_vendor_date(sfp_vendor_date_raw, 0)
+ else:
+ return None
+
+ transceiver_info_dict['type'] = sfp_interface_bulk_data['data']['type']['value']
+ transceiver_info_dict['manufacturer'] = sfp_vendor_name_data['data']['Vendor Name']['value']
+ transceiver_info_dict['model'] = sfp_vendor_pn_data['data']['Vendor PN']['value']
+ transceiver_info_dict['hardware_rev'] = sfp_vendor_rev_data['data']['Vendor Rev']['value']
+ transceiver_info_dict['serial'] = sfp_vendor_sn_data['data']['Vendor SN']['value']
+ transceiver_info_dict['vendor_oui'] = sfp_vendor_oui_data['data']['Vendor OUI']['value']
+ transceiver_info_dict['vendor_date'] = sfp_vendor_date_data['data']['VendorDataCode(YYYY-MM-DD Lot)']['value']
+ transceiver_info_dict['connector'] = sfp_interface_bulk_data['data']['Connector']['value']
+ transceiver_info_dict['encoding'] = sfp_interface_bulk_data['data']['EncodingCodes']['value']
+ transceiver_info_dict['ext_identifier'] = sfp_interface_bulk_data['data']['Extended Identifier']['value']
+ transceiver_info_dict['ext_rateselect_compliance'] = sfp_interface_bulk_data['data']['RateIdentifier']['value']
+ if sfp_type == 'QSFP':
+ for key in qsfp_cable_length_tup:
+ if key in sfp_interface_bulk_data['data']:
+ transceiver_info_dict['cable_type'] = key
+ transceiver_info_dict['cable_length'] = str(sfp_interface_bulk_data['data'][key]['value'])
+
+ for key in qsfp_compliance_code_tup:
+ if key in sfp_interface_bulk_data['data']['Specification compliance']['value']:
+ compliance_code_dict[key] = sfp_interface_bulk_data['data']['Specification compliance']['value'][key]['value']
+ transceiver_info_dict['specification_compliance'] = str(compliance_code_dict)
+
+ transceiver_info_dict['nominal_bit_rate'] = str(sfp_interface_bulk_data['data']['Nominal Bit Rate(100Mbs)']['value'])
+ else:
+ for key in sfp_cable_length_tup:
+ if key in sfp_interface_bulk_data['data']:
+ transceiver_info_dict['cable_type'] = key
+ transceiver_info_dict['cable_length'] = str(sfp_interface_bulk_data['data'][key]['value'])
+
+ for key in sfp_compliance_code_tup:
+ if key in sfp_interface_bulk_data['data']['Specification compliance']['value']:
+ compliance_code_dict[key] = sfp_interface_bulk_data['data']['Specification compliance']['value'][key]['value']
+ transceiver_info_dict['specification_compliance'] = str(compliance_code_dict)
+
+ transceiver_info_dict['nominal_bit_rate'] = str(sfp_interface_bulk_data['data']['NominalSignallingRate(UnitsOf100Mbd)']['value'])
+
+ return transceiver_info_dict
+
+ def get_transceiver_dom_info_dict(self, port_num):
+ transceiver_dom_info_dict = {}
+
+ # Below part is added to avoid failing xcvrd
+ # Currently, the way in which dom data is read has been changed from
+ # using sysfs to using ethtool.
+ # The ethtool returns None for ports without dom support, resulting in
+ # None being returned. However, this fails xcvrd to add the
+ # TRANSCEIVER_DOM_SENSOR table entry of associated port to CONFIG_DB
+ # and then causes SNMP fail.
+ # To address this issue a default dict is initialized with all data set to
+ # 'N/A' and is returned is the above case.
+ # BTW, in the original implementation which sysfs is used to read dom data,
+ # even though non-None data is returned for ports without dom support,
+ # it does not contain valid data. This can result in wrong data in
+ # TRANSCEIVER_DOM_SENSOR table.
+ transceiver_dom_info_dict['temperature'] = 'N/A'
+ transceiver_dom_info_dict['voltage'] = 'N/A'
+ transceiver_dom_info_dict['rx1power'] = 'N/A'
+ transceiver_dom_info_dict['rx2power'] = 'N/A'
+ transceiver_dom_info_dict['rx3power'] = 'N/A'
+ transceiver_dom_info_dict['rx4power'] = 'N/A'
+ transceiver_dom_info_dict['tx1bias'] = 'N/A'
+ transceiver_dom_info_dict['tx2bias'] = 'N/A'
+ transceiver_dom_info_dict['tx3bias'] = 'N/A'
+ transceiver_dom_info_dict['tx4bias'] = 'N/A'
+ transceiver_dom_info_dict['tx1power'] = 'N/A'
+ transceiver_dom_info_dict['tx2power'] = 'N/A'
+ transceiver_dom_info_dict['tx3power'] = 'N/A'
+ transceiver_dom_info_dict['tx4power'] = 'N/A'
+
+ if port_num in self.osfp_ports:
+ pass
+ elif port_num in self.qsfp_ports:
+ offset = 0
+ offset_xcvr = 128
+
+ sfpd_obj = sff8436Dom()
+ if sfpd_obj is None:
+ return None
+
+ sfpi_obj = sff8436InterfaceId()
+ if sfpi_obj is None:
+ return None
+
+
+ # QSFP capability byte parse, through this byte can know whether it support tx_power or not.
+ # TODO: in the future when decided to migrate to support SFF-8636 instead of SFF-8436,
+ # need to add more code for determining the capability and version compliance
+ # in SFF-8636 dom capability definitions evolving with the versions.
+ qsfp_dom_capability_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset_xcvr + XCVR_DOM_CAPABILITY_OFFSET), XCVR_DOM_CAPABILITY_WIDTH)
+ if qsfp_dom_capability_raw is not None:
+ qspf_dom_capability_data = sfpi_obj.parse_qsfp_dom_capability(qsfp_dom_capability_raw, 0)
+ else:
+ return transceiver_dom_info_dict
+
+ dom_temperature_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + QSFP_TEMPE_OFFSET), QSFP_TEMPE_WIDTH)
+ if dom_temperature_raw is not None:
+ dom_temperature_data = sfpd_obj.parse_temperature(dom_temperature_raw, 0)
+ else:
+ return transceiver_dom_info_dict
+
+ dom_voltage_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + QSFP_VOLT_OFFSET), QSFP_VOLT_WIDTH)
+ if dom_voltage_raw is not None:
+ dom_voltage_data = sfpd_obj.parse_voltage(dom_voltage_raw, 0)
+ else:
+ return transceiver_dom_info_dict
+
+ qsfp_dom_rev_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + QSFP_DOM_REV_OFFSET), QSFP_DOM_REV_WIDTH)
+ if qsfp_dom_rev_raw is not None:
+ qsfp_dom_rev_data = sfpd_obj.parse_sfp_dom_rev(qsfp_dom_rev_raw, 0)
+ else:
+ return transceiver_dom_info_dict
+
+ transceiver_dom_info_dict['temperature'] = dom_temperature_data['data']['Temperature']['value']
+ transceiver_dom_info_dict['voltage'] = dom_voltage_data['data']['Vcc']['value']
+
+ # The tx_power monitoring is only available on QSFP which compliant with SFF-8636
+ # and claimed that it support tx_power with one indicator bit.
+ dom_channel_monitor_data = {}
+ qsfp_dom_rev = qsfp_dom_rev_data['data']['dom_rev']['value']
+ qsfp_tx_power_support = qspf_dom_capability_data['data']['Tx_power_support']['value']
+ if (qsfp_dom_rev[0:8] != 'SFF-8636' or (qsfp_dom_rev[0:8] == 'SFF-8636' and qsfp_tx_power_support != 'on')):
+ dom_channel_monitor_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + QSFP_CHANNL_MON_OFFSET), QSFP_CHANNL_MON_WIDTH)
+ if dom_channel_monitor_raw is not None:
+ dom_channel_monitor_data = sfpd_obj.parse_channel_monitor_params(dom_channel_monitor_raw, 0)
+ else:
+ return transceiver_dom_info_dict
+ else:
+ dom_channel_monitor_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num, (offset + QSFP_CHANNL_MON_OFFSET), QSFP_CHANNL_MON_WITH_TX_POWER_WIDTH)
+ if dom_channel_monitor_raw is not None:
+ dom_channel_monitor_data = sfpd_obj.parse_channel_monitor_params_with_tx_power(dom_channel_monitor_raw, 0)
+ else:
+ return transceiver_dom_info_dict
+
+ transceiver_dom_info_dict['tx1power'] = dom_channel_monitor_data['data']['TX1Power']['value']
+ transceiver_dom_info_dict['tx2power'] = dom_channel_monitor_data['data']['TX2Power']['value']
+ transceiver_dom_info_dict['tx3power'] = dom_channel_monitor_data['data']['TX3Power']['value']
+ transceiver_dom_info_dict['tx4power'] = dom_channel_monitor_data['data']['TX4Power']['value']
+
+ transceiver_dom_info_dict['temperature'] = dom_temperature_data['data']['Temperature']['value']
+ transceiver_dom_info_dict['voltage'] = dom_voltage_data['data']['Vcc']['value']
+ transceiver_dom_info_dict['rx1power'] = dom_channel_monitor_data['data']['RX1Power']['value']
+ transceiver_dom_info_dict['rx2power'] = dom_channel_monitor_data['data']['RX2Power']['value']
+ transceiver_dom_info_dict['rx3power'] = dom_channel_monitor_data['data']['RX3Power']['value']
+ transceiver_dom_info_dict['rx4power'] = dom_channel_monitor_data['data']['RX4Power']['value']
+ transceiver_dom_info_dict['tx1bias'] = dom_channel_monitor_data['data']['TX1Bias']['value']
+ transceiver_dom_info_dict['tx2bias'] = dom_channel_monitor_data['data']['TX2Bias']['value']
+ transceiver_dom_info_dict['tx3bias'] = dom_channel_monitor_data['data']['TX3Bias']['value']
+ transceiver_dom_info_dict['tx4bias'] = dom_channel_monitor_data['data']['TX4Bias']['value']
+
+ else:
+ offset = SFP_I2C_PAGE_SIZE
+
+ eeprom_raw = ['0'] * SFP_I2C_PAGE_SIZE
+ eeprom_raw[XCVR_DOM_CAPABILITY_OFFSET : XCVR_DOM_CAPABILITY_OFFSET + XCVR_DOM_CAPABILITY_WIDTH] = \
+ self._read_eeprom_specific_bytes_via_ethtool(port_num, XCVR_DOM_CAPABILITY_OFFSET, XCVR_DOM_CAPABILITY_WIDTH)
+ sfp_obj = sff8472InterfaceId()
+ calibration_type = sfp_obj._get_calibration_type(eeprom_raw)
+
+ dom_supported = (int(eeprom_raw[XCVR_DOM_CAPABILITY_OFFSET], 16) & XCVR_DOM_CAPABILITY_DOM_SUPPORT_BIT != 0)
+ if not dom_supported:
+ return transceiver_dom_info_dict
+
+ eeprom_domraw = self._read_eeprom_specific_bytes_via_ethtool(port_num, offset, SFP_I2C_PAGE_SIZE)
+ if eeprom_domraw is None:
+ return transceiver_dom_info_dict
+
+ sfpd_obj = sff8472Dom(None, calibration_type)
+ if sfpd_obj is None:
+ print "no sff8472Dom"
+ return None
+
+ dom_temperature_raw = eeprom_domraw[SFP_TEMPE_OFFSET:SFP_TEMPE_OFFSET+SFP_TEMPE_WIDTH]
+ dom_temperature_data = sfpd_obj.parse_temperature(dom_temperature_raw, 0)
+
+ dom_voltage_raw = eeprom_domraw[SFP_VOLT_OFFSET:SFP_VOLT_OFFSET+SFP_VOLT_WIDTH]
+ dom_voltage_data = sfpd_obj.parse_voltage(dom_voltage_raw, 0)
+
+ dom_channel_monitor_raw = eeprom_domraw[SFP_CHANNL_MON_OFFSET:SFP_CHANNL_MON_OFFSET+SFP_CHANNL_MON_WIDTH]
+ dom_channel_monitor_data = sfpd_obj.parse_channel_monitor_params(dom_channel_monitor_raw, 0)
+
+ transceiver_dom_info_dict['temperature'] = dom_temperature_data['data']['Temperature']['value']
+ transceiver_dom_info_dict['voltage'] = dom_voltage_data['data']['Vcc']['value']
+ transceiver_dom_info_dict['rx1power'] = dom_channel_monitor_data['data']['RXPower']['value']
+ transceiver_dom_info_dict['tx1bias'] = dom_channel_monitor_data['data']['TXBias']['value']
+ transceiver_dom_info_dict['tx1power'] = dom_channel_monitor_data['data']['TXPower']['value']
+
+ return transceiver_dom_info_dict
+
+ def get_transceiver_dom_threshold_info_dict(self, port_num):
+ transceiver_dom_threshold_info_dict = {}
+
+ dom_info_dict_keys = ['temphighalarm', 'temphighwarning',
+ 'templowalarm', 'templowwarning',
+ 'vcchighalarm', 'vcchighwarning',
+ 'vcclowalarm', 'vcclowwarning',
+ 'rxpowerhighalarm', 'rxpowerhighwarning',
+ 'rxpowerlowalarm', 'rxpowerlowwarning',
+ 'txpowerhighalarm', 'txpowerhighwarning',
+ 'txpowerlowalarm', 'txpowerlowwarning',
+ 'txbiashighalarm', 'txbiashighwarning',
+ 'txbiaslowalarm', 'txbiaslowwarning'
+ ]
+ transceiver_dom_threshold_info_dict = dict.fromkeys(dom_info_dict_keys, 'N/A')
+
+ if port_num in self.qsfp_ports:
+ # current we don't support qsfp since threshold data is on page 3 and the way to read this page is under discussion.
+ return transceiver_dom_threshold_info_dict
+ else:
+ offset = SFP_I2C_PAGE_SIZE
+
+ eeprom_raw = ['0'] * SFP_I2C_PAGE_SIZE
+ eeprom_raw[XCVR_DOM_CAPABILITY_OFFSET : XCVR_DOM_CAPABILITY_OFFSET + XCVR_DOM_CAPABILITY_WIDTH] = \
+ self._read_eeprom_specific_bytes_via_ethtool(port_num, XCVR_DOM_CAPABILITY_OFFSET, XCVR_DOM_CAPABILITY_WIDTH)
+ sfp_obj = sff8472InterfaceId()
+ calibration_type = sfp_obj._get_calibration_type(eeprom_raw)
+
+ dom_supported = (int(eeprom_raw[XCVR_DOM_CAPABILITY_OFFSET], 16) & XCVR_DOM_CAPABILITY_DOM_SUPPORT_BIT != 0)
+ if not dom_supported:
+ return transceiver_dom_threshold_info_dict
+
+ sfpd_obj = sff8472Dom(None, calibration_type)
+ if sfpd_obj is None:
+ return transceiver_dom_threshold_info_dict
+
+ dom_module_threshold_raw = self._read_eeprom_specific_bytes_via_ethtool(port_num,
+ (offset + SFP_MODULE_THRESHOLD_OFFSET),
+ SFP_MODULE_THRESHOLD_WIDTH)
+ if dom_module_threshold_raw is not None:
+ dom_module_threshold_data = sfpd_obj.parse_alarm_warning_threshold(dom_module_threshold_raw, 0)
+ else:
+ return transceiver_dom_threshold_info_dict
+
+ # Threshold Data
+ transceiver_dom_threshold_info_dict['temphighalarm'] = dom_module_threshold_data['data']['TempHighAlarm']['value']
+ transceiver_dom_threshold_info_dict['templowalarm'] = dom_module_threshold_data['data']['TempLowAlarm']['value']
+ transceiver_dom_threshold_info_dict['temphighwarning'] = dom_module_threshold_data['data']['TempHighWarning']['value']
+ transceiver_dom_threshold_info_dict['templowwarning'] = dom_module_threshold_data['data']['TempLowWarning']['value']
+ transceiver_dom_threshold_info_dict['vcchighalarm'] = dom_module_threshold_data['data']['VoltageHighAlarm']['value']
+ transceiver_dom_threshold_info_dict['vcclowalarm'] = dom_module_threshold_data['data']['VoltageLowAlarm']['value']
+ transceiver_dom_threshold_info_dict['vcchighwarning'] = dom_module_threshold_data['data']['VoltageHighWarning']['value']
+ transceiver_dom_threshold_info_dict['vcclowwarning'] = dom_module_threshold_data['data']['VoltageLowWarning']['value']
+ transceiver_dom_threshold_info_dict['txbiashighalarm'] = dom_module_threshold_data['data']['BiasHighAlarm']['value']
+ transceiver_dom_threshold_info_dict['txbiaslowalarm'] = dom_module_threshold_data['data']['BiasLowAlarm']['value']
+ transceiver_dom_threshold_info_dict['txbiashighwarning'] = dom_module_threshold_data['data']['BiasHighWarning']['value']
+ transceiver_dom_threshold_info_dict['txbiaslowwarning'] = dom_module_threshold_data['data']['BiasLowWarning']['value']
+ transceiver_dom_threshold_info_dict['txpowerhighalarm'] = dom_module_threshold_data['data']['TXPowerHighAlarm']['value']
+ transceiver_dom_threshold_info_dict['txpowerlowalarm'] = dom_module_threshold_data['data']['TXPowerLowAlarm']['value']
+ transceiver_dom_threshold_info_dict['txpowerhighwarning'] = dom_module_threshold_data['data']['TXPowerHighWarning']['value']
+ transceiver_dom_threshold_info_dict['txpowerlowwarning'] = dom_module_threshold_data['data']['TXPowerLowWarning']['value']
+ transceiver_dom_threshold_info_dict['rxpowerhighalarm'] = dom_module_threshold_data['data']['RXPowerHighAlarm']['value']
+ transceiver_dom_threshold_info_dict['rxpowerlowalarm'] = dom_module_threshold_data['data']['RXPowerLowAlarm']['value']
+ transceiver_dom_threshold_info_dict['rxpowerhighwarning'] = dom_module_threshold_data['data']['RXPowerHighWarning']['value']
+ transceiver_dom_threshold_info_dict['rxpowerlowwarning'] = dom_module_threshold_data['data']['RXPowerLowWarning']['value']
+
+ return transceiver_dom_threshold_info_dict
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/pmon_daemon_control.json b/device/mellanox/x86_64-mlnx_msn4410-r0/pmon_daemon_control.json
new file mode 120000
index 0000000000..435a2ce7c0
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/pmon_daemon_control.json
@@ -0,0 +1 @@
+../x86_64-mlnx_msn2700-r0/pmon_daemon_control.json
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/sensors.conf b/device/mellanox/x86_64-mlnx_msn4410-r0/sensors.conf
new file mode 120000
index 0000000000..e484524c16
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/sensors.conf
@@ -0,0 +1 @@
+../x86_64-mlnx_msn4700-r0/sensors.conf
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/system_health_monitoring_config.json b/device/mellanox/x86_64-mlnx_msn4410-r0/system_health_monitoring_config.json
new file mode 120000
index 0000000000..98df66c27c
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/system_health_monitoring_config.json
@@ -0,0 +1 @@
+../x86_64-mlnx_msn2700-r0/system_health_monitoring_config.json
\ No newline at end of file
diff --git a/device/mellanox/x86_64-mlnx_msn4410-r0/thermal_policy.json b/device/mellanox/x86_64-mlnx_msn4410-r0/thermal_policy.json
new file mode 120000
index 0000000000..5a25cd87f7
--- /dev/null
+++ b/device/mellanox/x86_64-mlnx_msn4410-r0/thermal_policy.json
@@ -0,0 +1 @@
+../x86_64-mlnx_msn2700-r0/thermal_policy.json
\ No newline at end of file
diff --git a/platform/mellanox/mlnx-platform-api/sonic_platform/chassis.py b/platform/mellanox/mlnx-platform-api/sonic_platform/chassis.py
index 77cf27da2d..84c4ac5ea9 100644
--- a/platform/mellanox/mlnx-platform-api/sonic_platform/chassis.py
+++ b/platform/mellanox/mlnx-platform-api/sonic_platform/chassis.py
@@ -45,7 +45,7 @@ logger = Logger()
# magic code defnition for port number, qsfp port position of each Platform
# port_position_tuple = (PORT_START, QSFP_PORT_START, PORT_END, PORT_IN_BLOCK, EEPROM_OFFSET)
-platform_dict_port = {'x86_64-mlnx_msn2010-r0': 3, 'x86_64-mlnx_msn2100-r0': 1, 'x86_64-mlnx_msn2410-r0': 2, 'x86_64-mlnx_msn2700-r0': 0, 'x86_64-mlnx_lssn2700':0, 'x86_64-mlnx_msn2740-r0': 0, 'x86_64-mlnx_msn3420-r0':5, 'x86_64-mlnx_msn3700-r0': 0, 'x86_64-mlnx_msn3700c-r0': 0, 'x86_64-mlnx_msn3800-r0': 4, 'x86_64-mlnx_msn4600c-r0':4, 'x86_64-mlnx_msn4700-r0': 0}
+platform_dict_port = {'x86_64-mlnx_msn2010-r0': 3, 'x86_64-mlnx_msn2100-r0': 1, 'x86_64-mlnx_msn2410-r0': 2, 'x86_64-mlnx_msn2700-r0': 0, 'x86_64-mlnx_lssn2700':0, 'x86_64-mlnx_msn2740-r0': 0, 'x86_64-mlnx_msn3420-r0':5, 'x86_64-mlnx_msn3700-r0': 0, 'x86_64-mlnx_msn3700c-r0': 0, 'x86_64-mlnx_msn3800-r0': 4, 'x86_64-mlnx_msn4600c-r0':4, 'x86_64-mlnx_msn4700-r0': 0, 'x86_64-mlnx_msn4410-r0': 0}
port_position_tuple_list = [(0, 0, 31, 32, 1), (0, 0, 15, 16, 1), (0, 48, 55, 56, 1), (0, 18, 21, 22, 1), (0, 0, 63, 64, 1), (0, 48, 59, 60, 1)]
class Chassis(ChassisBase):
diff --git a/platform/mellanox/mlnx-platform-api/sonic_platform/device_data.py b/platform/mellanox/mlnx-platform-api/sonic_platform/device_data.py
index 7b86f7db9d..3853cac3f7 100644
--- a/platform/mellanox/mlnx-platform-api/sonic_platform/device_data.py
+++ b/platform/mellanox/mlnx-platform-api/sonic_platform/device_data.py
@@ -188,6 +188,27 @@ DEVICE_DATA = {
'led_num': 1
}
},
+ 'x86_64-mlnx_msn4410-r0': {
+ 'thermal': {
+ 'minimum_table': {
+ "unk_trust": {"-127:120":16},
+ "unk_untrust": {"-127:120":16},
+ }
+ },
+ 'fans': {
+ 'drawer_num': 6,
+ 'drawer_type': 'real',
+ 'fan_num_per_drawer': 2,
+ 'support_fan_direction': True,
+ 'hot_swappable': True
+ },
+ 'psus': {
+ 'psu_num': 2,
+ 'fan_num_per_psu': 1,
+ 'hot_swappable': True,
+ 'led_num': 1
+ }
+ },
'x86_64-mlnx_msn3420-r0': {
'thermal': {
'minimum_table': {
diff --git a/platform/mellanox/mlnx-platform-api/sonic_platform/psu.py b/platform/mellanox/mlnx-platform-api/sonic_platform/psu.py
index 897555ed80..7b73b7196c 100644
--- a/platform/mellanox/mlnx-platform-api/sonic_platform/psu.py
+++ b/platform/mellanox/mlnx-platform-api/sonic_platform/psu.py
@@ -31,7 +31,7 @@ PSU_POWER = "power"
# in most platforms the file psuX_curr, psuX_volt and psuX_power contain current, voltage and power data respectively.
# but there are exceptions which will be handled by the following dictionary
-platform_dict_psu = {'x86_64-mlnx_msn3420-r0':1, 'x86_64-mlnx_msn3700-r0': 1, 'x86_64-mlnx_msn3700c-r0': 1, 'x86_64-mlnx_msn3800-r0': 1, 'x86_64-mlnx_msn4600c-r0':1, 'x86_64-mlnx_msn4700-r0': 1}
+platform_dict_psu = {'x86_64-mlnx_msn3420-r0':1, 'x86_64-mlnx_msn3700-r0': 1, 'x86_64-mlnx_msn3700c-r0': 1, 'x86_64-mlnx_msn3800-r0': 1, 'x86_64-mlnx_msn4600c-r0':1, 'x86_64-mlnx_msn4700-r0': 1, 'x86_64-mlnx_msn4410-r0': 1}
psu_profile_list = [
# default filename convention
diff --git a/platform/mellanox/mlnx-platform-api/sonic_platform/thermal.py b/platform/mellanox/mlnx-platform-api/sonic_platform/thermal.py
index 48b277345b..c860edf838 100644
--- a/platform/mellanox/mlnx-platform-api/sonic_platform/thermal.py
+++ b/platform/mellanox/mlnx-platform-api/sonic_platform/thermal.py
@@ -128,7 +128,7 @@ thermal_api_names = [
THERMAL_API_GET_HIGH_THRESHOLD
]
-platform_dict_thermal = {'x86_64-mlnx_msn2700-r0': 0, 'x86_64-mlnx_lssn2700-r0':0, 'x86_64-mlnx_msn2740-r0': 3, 'x86_64-mlnx_msn2100-r0': 1, 'x86_64-mlnx_msn2410-r0': 2, 'x86_64-mlnx_msn2010-r0': 4, 'x86_64-mlnx_msn3420-r0':9, 'x86_64-mlnx_msn3700-r0': 5, 'x86_64-mlnx_msn3700c-r0': 6, 'x86_64-mlnx_msn3800-r0': 7, 'x86_64-mlnx_msn4600c-r0':9, 'x86_64-mlnx_msn4700-r0': 8}
+platform_dict_thermal = {'x86_64-mlnx_msn2700-r0': 0, 'x86_64-mlnx_lssn2700-r0':0, 'x86_64-mlnx_msn2740-r0': 3, 'x86_64-mlnx_msn2100-r0': 1, 'x86_64-mlnx_msn2410-r0': 2, 'x86_64-mlnx_msn2010-r0': 4, 'x86_64-mlnx_msn3420-r0':9, 'x86_64-mlnx_msn3700-r0': 5, 'x86_64-mlnx_msn3700c-r0': 6, 'x86_64-mlnx_msn3800-r0': 7, 'x86_64-mlnx_msn4600c-r0':9, 'x86_64-mlnx_msn4700-r0': 8, 'x86_64-mlnx_msn4410-r0': 8}
thermal_profile_list = [
# 2700
{
@@ -300,6 +300,22 @@ thermal_profile_list = [
THERMAL_DEV_FAN_AMBIENT
]
)
+ },
+ # 4410
+ {
+ THERMAL_DEV_CATEGORY_CPU_CORE:(0, 4),
+ THERMAL_DEV_CATEGORY_MODULE:(1, 32),
+ THERMAL_DEV_CATEGORY_PSU:(1, 2),
+ THERMAL_DEV_CATEGORY_CPU_PACK:(0,1),
+ THERMAL_DEV_CATEGORY_GEARBOX:(0,0),
+ THERMAL_DEV_CATEGORY_AMBIENT:(0,
+ [
+ THERMAL_DEV_ASIC_AMBIENT,
+ THERMAL_DEV_COMEX_AMBIENT,
+ THERMAL_DEV_PORT_AMBIENT,
+ THERMAL_DEV_FAN_AMBIENT
+ ]
+ )
}
]