DellEMC: S5248F - Platform API 2.0 implementation (#7930)
#### Why I did it Support API 2.0 for S5248F platform #### How I did it Making changes to S5248F platform specific directory Co-authored-by: Arun LK <Arun_L_K@dell.com>
This commit is contained in:
arunlk-dell
Qi Luo
parent
b7344e8ac3
commit
a1268b34f5
@ -19,6 +19,23 @@ def pci_get_value(resource, offset):
|
|||||||
mm.close()
|
mm.close()
|
||||||
return val
|
return val
|
||||||
|
|
||||||
|
def pci_mem_write(memmap, offset, data):
|
||||||
|
""" Write PCI device """
|
||||||
|
memmap.seek(offset)
|
||||||
|
memmap.write(struct.pack('I', data))
|
||||||
|
|
||||||
|
def pci_set_value(resource, val, offset):
|
||||||
|
""" Set a value to PCI device """
|
||||||
|
with open(resource, 'w+b') as filed:
|
||||||
|
memmap = None
|
||||||
|
try:
|
||||||
|
memmap = mmap.mmap(filed.fileno(), 0)
|
||||||
|
pci_mem_write(memmap, offset, val)
|
||||||
|
except EnvironmentError:
|
||||||
|
pass
|
||||||
|
if memmap is not None:
|
||||||
|
memmap.close()
|
||||||
|
|
||||||
# Read I2C device
|
# Read I2C device
|
||||||
|
|
||||||
def i2c_get(bus, i2caddr, ofs):
|
def i2c_get(bus, i2caddr, ofs):
|
||||||
|
|||||||
@ -5,6 +5,7 @@ s5248f/scripts/sensors usr/bin
|
|||||||
s5248f/scripts/qsfp_irq_enable.py usr/bin
|
s5248f/scripts/qsfp_irq_enable.py usr/bin
|
||||||
s5248f/cfg/s5248f-modules.conf etc/modules-load.d
|
s5248f/cfg/s5248f-modules.conf etc/modules-load.d
|
||||||
s5248f/systemd/platform-modules-s5248f.service etc/systemd/system
|
s5248f/systemd/platform-modules-s5248f.service etc/systemd/system
|
||||||
|
s5248f/modules/sonic_platform-1.0-py3-none-any.whl usr/share/sonic/device/x86_64-dellemc_s5248f_c3538-r0
|
||||||
common/platform_reboot usr/share/sonic/device/x86_64-dellemc_s5248f_c3538-r0
|
common/platform_reboot usr/share/sonic/device/x86_64-dellemc_s5248f_c3538-r0
|
||||||
common/fw-updater usr/local/bin
|
common/fw-updater usr/local/bin
|
||||||
common/onie_mode_set usr/local/bin
|
common/onie_mode_set usr/local/bin
|
||||||
|
|||||||
@ -45,6 +45,11 @@ override_dh_auto_build:
|
|||||||
python2.7 setup.py bdist_wheel -d $(MOD_SRC_DIR)/$${mod}/modules; \
|
python2.7 setup.py bdist_wheel -d $(MOD_SRC_DIR)/$${mod}/modules; \
|
||||||
python3 setup.py bdist_wheel -d $(MOD_SRC_DIR)/$${mod}/modules; \
|
python3 setup.py bdist_wheel -d $(MOD_SRC_DIR)/$${mod}/modules; \
|
||||||
cd $(MOD_SRC_DIR); \
|
cd $(MOD_SRC_DIR); \
|
||||||
|
elif [ $$mod = "s5248f" ]; then \
|
||||||
|
cp $(COMMON_DIR)/ipmihelper.py $(MOD_SRC_DIR)/$${mod}/sonic_platform/ipmihelper.py; \
|
||||||
|
cd $(MOD_SRC_DIR)/$${mod}; \
|
||||||
|
python3 setup.py bdist_wheel -d $(MOD_SRC_DIR)/$${mod}/modules; \
|
||||||
|
cd $(MOD_SRC_DIR); \
|
||||||
elif [ $$mod = "z9332f" ]; then \
|
elif [ $$mod = "z9332f" ]; then \
|
||||||
cp $(COMMON_DIR)/ipmihelper.py $(MOD_SRC_DIR)/$${mod}/sonic_platform/ipmihelper.py; \
|
cp $(COMMON_DIR)/ipmihelper.py $(MOD_SRC_DIR)/$${mod}/sonic_platform/ipmihelper.py; \
|
||||||
cd $(MOD_SRC_DIR)/$${mod}; \
|
cd $(MOD_SRC_DIR)/$${mod}; \
|
||||||
@ -103,6 +108,11 @@ override_dh_clean:
|
|||||||
rm -f $(MOD_SRC_DIR)/$${mod}/modules/*.whl; \
|
rm -f $(MOD_SRC_DIR)/$${mod}/modules/*.whl; \
|
||||||
rm -rf $(MOD_SRC_DIR)/$${mod}/build; \
|
rm -rf $(MOD_SRC_DIR)/$${mod}/build; \
|
||||||
rm -rf $(MOD_SRC_DIR)/$${mod}/build/*.egg-info; \
|
rm -rf $(MOD_SRC_DIR)/$${mod}/build/*.egg-info; \
|
||||||
|
elif [ $$mod = "s5248f" ]; then \
|
||||||
|
rm -f $(MOD_SRC_DIR)/$${mod}/sonic_platform/ipmihelper.py; \
|
||||||
|
rm -f $(MOD_SRC_DIR)/$${mod}/modules/*.whl; \
|
||||||
|
rm -rf $(MOD_SRC_DIR)/$${mod}/build; \
|
||||||
|
rm -rf $(MOD_SRC_DIR)/$${mod}/build/*.egg-info; \
|
||||||
elif [ $$mod = "z9332f" ]; then \
|
elif [ $$mod = "z9332f" ]; then \
|
||||||
rm -f $(MOD_SRC_DIR)/$${mod}/sonic_platform/ipmihelper.py; \
|
rm -f $(MOD_SRC_DIR)/$${mod}/sonic_platform/ipmihelper.py; \
|
||||||
rm -f $(MOD_SRC_DIR)/$${mod}/modules/*.whl; \
|
rm -f $(MOD_SRC_DIR)/$${mod}/modules/*.whl; \
|
||||||
|
|||||||
@ -86,6 +86,20 @@ switch_board_modsel() {
|
|||||||
done
|
done
|
||||||
}
|
}
|
||||||
|
|
||||||
|
install_python_api_package() {
|
||||||
|
device="/usr/share/sonic/device"
|
||||||
|
platform=$(/usr/local/bin/sonic-cfggen -H -v DEVICE_METADATA.localhost.platform)
|
||||||
|
|
||||||
|
rv=$(pip3 install $device/$platform/sonic_platform-1.0-py3-none-any.whl)
|
||||||
|
}
|
||||||
|
|
||||||
|
remove_python_api_package() {
|
||||||
|
rv=$(pip3 show sonic-platform > /dev/null 2>/dev/null)
|
||||||
|
if [ $? -eq 0 ]; then
|
||||||
|
rv=$(pip3 uninstall -y sonic-platform > /dev/null 2>/dev/null)
|
||||||
|
fi
|
||||||
|
}
|
||||||
|
|
||||||
platform_firmware_versions() {
|
platform_firmware_versions() {
|
||||||
FIRMWARE_VERSION_FILE=/var/log/firmware_versions
|
FIRMWARE_VERSION_FILE=/var/log/firmware_versions
|
||||||
rm -rf ${FIRMWARE_VERSION_FILE}
|
rm -rf ${FIRMWARE_VERSION_FILE}
|
||||||
@ -146,6 +160,7 @@ if [ "$1" == "init" ]; then
|
|||||||
switch_board_modsel
|
switch_board_modsel
|
||||||
switch_board_led_default
|
switch_board_led_default
|
||||||
#/usr/bin/qsfp_irq_enable.py
|
#/usr/bin/qsfp_irq_enable.py
|
||||||
|
install_python_api_package
|
||||||
platform_firmware_versions
|
platform_firmware_versions
|
||||||
|
|
||||||
elif [ "$1" == "deinit" ]; then
|
elif [ "$1" == "deinit" ]; then
|
||||||
@ -153,6 +168,7 @@ elif [ "$1" == "deinit" ]; then
|
|||||||
switch_board_qsfp "delete_device"
|
switch_board_qsfp "delete_device"
|
||||||
switch_board_qsfp_mux "delete_device"
|
switch_board_qsfp_mux "delete_device"
|
||||||
|
|
||||||
|
remove_python_api_package
|
||||||
modprobe -r i2c-mux-pca954x
|
modprobe -r i2c-mux-pca954x
|
||||||
modprobe -r i2c-dev
|
modprobe -r i2c-dev
|
||||||
else
|
else
|
||||||
|
|||||||
30
platform/broadcom/sonic-platform-modules-dell/s5248f/setup.py
Executable file
30
platform/broadcom/sonic-platform-modules-dell/s5248f/setup.py
Executable file
@ -0,0 +1,30 @@
|
|||||||
|
from setuptools import setup
|
||||||
|
|
||||||
|
setup(
|
||||||
|
name='sonic-platform',
|
||||||
|
version='1.0',
|
||||||
|
description='SONiC platform API implementation on DellEmc Platforms',
|
||||||
|
license='Apache 2.0',
|
||||||
|
author='SONiC Team',
|
||||||
|
author_email='linuxnetdev@microsoft.com',
|
||||||
|
url='https://github.com/Azure/sonic-buildimage',
|
||||||
|
maintainer='DellEMC',
|
||||||
|
maintainer_email='dell-sonic@dell.com',
|
||||||
|
packages=[
|
||||||
|
'sonic_platform',
|
||||||
|
],
|
||||||
|
classifiers=[
|
||||||
|
'Development Status :: 3 - Alpha',
|
||||||
|
'Environment :: Plugins',
|
||||||
|
'Intended Audience :: Developers',
|
||||||
|
'Intended Audience :: Information Technology',
|
||||||
|
'Intended Audience :: System Administrators',
|
||||||
|
'License :: OSI Approved :: Apache Software License',
|
||||||
|
'Natural Language :: English',
|
||||||
|
'Operating System :: POSIX :: Linux',
|
||||||
|
'Programming Language :: Python :: 3.7',
|
||||||
|
'Topic :: Utilities',
|
||||||
|
],
|
||||||
|
keywords='sonic SONiC platform PLATFORM',
|
||||||
|
)
|
||||||
|
|
||||||
@ -0,0 +1,3 @@
|
|||||||
|
__all__ = ["platform", "chassis", "sfp", "eeprom", "component", "thermal", "psu", "fan", "fan_drawer", "watchdog"]
|
||||||
|
from sonic_platform import *
|
||||||
|
|
||||||
@ -0,0 +1,388 @@
|
|||||||
|
#!/usr/bin/env python
|
||||||
|
|
||||||
|
#############################################################################
|
||||||
|
# DELLEMC S5248F
|
||||||
|
#
|
||||||
|
# Module contains an implementation of SONiC Platform Base API and
|
||||||
|
# provides the platform information
|
||||||
|
#
|
||||||
|
#############################################################################
|
||||||
|
|
||||||
|
try:
|
||||||
|
import time
|
||||||
|
import sys
|
||||||
|
from sonic_platform_base.chassis_base import ChassisBase
|
||||||
|
from sonic_platform.sfp import Sfp
|
||||||
|
from sonic_platform.eeprom import Eeprom
|
||||||
|
from sonic_platform.component import Component
|
||||||
|
from sonic_platform.psu import Psu
|
||||||
|
from sonic_platform.thermal import Thermal
|
||||||
|
from sonic_platform.watchdog import Watchdog
|
||||||
|
from sonic_platform.fan import Fan
|
||||||
|
from sonic_platform.fan_drawer import FanDrawer
|
||||||
|
from sonic_platform.hwaccess import pci_get_value, pci_set_value
|
||||||
|
except ImportError as e:
|
||||||
|
raise ImportError(str(e) + "- required module not found")
|
||||||
|
|
||||||
|
MAX_S5248F_COMPONENT = 6 # BIOS,BMC,FPGA,SYSTEM CPLD,2 SLAVE CPLDs
|
||||||
|
MAX_S5248F_FANTRAY =4
|
||||||
|
MAX_S5248F_FAN = 2
|
||||||
|
MAX_S5248F_PSU = 2
|
||||||
|
MAX_S5248F_THERMAL = 8
|
||||||
|
SYSTEM_LED_REG = 0x24
|
||||||
|
SYSTEM_BEACON_LED_SET = 0x8
|
||||||
|
SYSTEM_BEACON_LED_CLEAR = 0xFFFFFFF7
|
||||||
|
|
||||||
|
media_part_num_list = set([ \
|
||||||
|
"8T47V","XTY28","MHVPK","GF76J","J6FGD","F1KMV","9DN5J","H4DHD","6MCNV","0WRX0","X7F70","5R2PT","WTRD1","WTRD1","WTRD1","WTRD1","5250G","WTRD1","C5RNH","C5RNH","FTLX8571D3BCL-FC",
|
||||||
|
"C5RNH","5250G","N8TDR","7D64H","7D64H","RN84N","RN84N","HMTNW","6K3Y6","6K3Y6","TY5FM","50M0R","PGYJT","WP2PP","85Y13","1HCGH","FP9R1","FYD0M","C6Y7M","C6Y7M","V250M","V250M",
|
||||||
|
"5CWK6","5CWK6","53HVN","53HVN","358VV","358VV","MV799","MV799","YJF03","P9GND","T1KCN","1DXKP","MT7R2","K0T7R","W5G04","7TCDN","7TCDN","7TCDN","7TCDN","7TCDN","V3XJK","0MV31",
|
||||||
|
"5FVP7","N6KM9","C41MF","77KC3","XW7J0","V4NJV","2XJHY","H93DH","H93DH","F8CG0","F8CG0","F8CG0","119N6","WFMF5","794RX","288F6","1M31V","1M31V","5NP8R","5NP8R","4TC09","4TC09",
|
||||||
|
"FC6KV","FC6KV","J90VN","J90VN","05RH0","05RH0","YDN52","0C2YV","YDN52","0C2YV","9JT65","D7M6H","6GW14","FYVFW","0VF5H","P4YPY","P4YPY","TCPM2","TCPM2","JNPF8","JNPF8","27GG5",
|
||||||
|
"27GG5","P8T4W","P8T4W","JR54Y","M6N0J","XJYD0","K44H9","035KG","P7C7N","76V43","3CC35","FN4FC","26FN3","YFNDD","YFNDD","7R9N9","035KG","P7C7N","76V43","3CC35","PLRXPLSCS43811",
|
||||||
|
"FN4FC","26FN3","YFNDD","YFNDD","7R9N9","G86YJ","V407F","V407F","9KH6T","G86YJ","V407F","9KH6T","2JVDD","D0R73","VXFJY","9X8JP","2JVDD","D0R73","VXFJY","9X8JP","2JVDD","D0R73","VXFJY",
|
||||||
|
"9X8JP","GMFC5","GMFC5","GMFC5","D7P80","3MFXG","3MFXG","0GWXJ","THPF3","THPF3","THPF3","THPF3","THPF3","PJ62G","3XCX1","JJYKG","RRRTK","16K56","86JM2","K5R6C","7MG2C","WTPPN","9HTT2",
|
||||||
|
"NKM4F","VXGGG","JC9W6","6MR8M","RP3GV","M5PPJ","XKY55","TKCXT","05J8P","5WGKD","XFDRT","NW8DM","YPKH3","5WGKD","XFDRT","NW8DM","YPKH3","71XXK","MVCX6","0XYP6","HPPVW","3GHRT","71XXK",
|
||||||
|
"MVCX6","0XYP6","HPPVW","3GHRT","2X5T6","135V2","KD5MV","2X5T6","KD5MV","HHFK0","3YWG7","5CMT2","RCVP5","X5DH4","HHFK0","3YWG7","5CMT2","RCVP5","X5DH4","3YWG7","5CMT2","RCVP5","X5DH4",
|
||||||
|
"4WJ41","4WJ41","14NV5","14NV5","14NV5","4WGYD","YKMH7","X7CCC","X7CCC","0X9CT","0CY8V","P7D7R","W4GPP","W4GPP","W4GPP","HHHCHC","07RN7","07RN7","0YR96","0YR96","JCYM9","FTLX8571D3BCL",
|
||||||
|
"DDW0X","VPFDJ","229KM","9FC7D","DDW0X","VPFDJ","6FMR5","J7K20","N3K9W","6FMR5","8R4VM","7VN5T","D9YM8","8R4VM","VYXPW","87TPX","WY6FK","VYXPW","87TPX","WY6FK","WG8C4","N8K82","2DV6Y",
|
||||||
|
"77C3C","RC0HM","77C3C","RC0HM","JHXTN","3P3PG","92YVM","4VX5M","4VX5M","6RRGD","W4JWV","22V6R","XR11M","9GMDY","JMCWK","TP2F0","6MGDY","78RHK", "C0TP5","0WDNV","FCLF8522P2BTL"\
|
||||||
|
])
|
||||||
|
|
||||||
|
class Chassis(ChassisBase):
|
||||||
|
"""
|
||||||
|
DELLEMC Platform-specific Chassis class
|
||||||
|
"""
|
||||||
|
|
||||||
|
REBOOT_CAUSE_PATH = "/host/reboot-cause/platform/reboot_reason"
|
||||||
|
oir_fd = -1
|
||||||
|
epoll = -1
|
||||||
|
|
||||||
|
_global_port_pres_dict = {}
|
||||||
|
|
||||||
|
_port_to_i2c_mapping = {
|
||||||
|
1: 2,
|
||||||
|
2: 3,
|
||||||
|
3: 4,
|
||||||
|
4: 5,
|
||||||
|
5: 6,
|
||||||
|
6: 7,
|
||||||
|
7: 8,
|
||||||
|
8: 9,
|
||||||
|
9: 10,
|
||||||
|
10: 11,
|
||||||
|
11: 12,
|
||||||
|
12: 13,
|
||||||
|
13: 14,
|
||||||
|
14: 15,
|
||||||
|
15: 16,
|
||||||
|
16: 17,
|
||||||
|
17: 18,
|
||||||
|
18: 19,
|
||||||
|
19: 20,
|
||||||
|
20: 21,
|
||||||
|
21: 22,
|
||||||
|
22: 23,
|
||||||
|
23: 24,
|
||||||
|
24: 25,
|
||||||
|
25: 26,
|
||||||
|
26: 27,
|
||||||
|
27: 28,
|
||||||
|
28: 29,
|
||||||
|
29: 30,
|
||||||
|
30: 31,
|
||||||
|
31: 32,
|
||||||
|
32: 33,
|
||||||
|
33: 34,
|
||||||
|
34: 35,
|
||||||
|
35: 36,
|
||||||
|
36: 37,
|
||||||
|
37: 38,
|
||||||
|
38: 39,
|
||||||
|
39: 40,
|
||||||
|
40: 41,
|
||||||
|
41: 42,
|
||||||
|
42: 43,
|
||||||
|
43: 44,
|
||||||
|
44: 45,
|
||||||
|
45: 46,
|
||||||
|
46: 47,
|
||||||
|
47: 48,
|
||||||
|
48: 49,
|
||||||
|
# DD + QSFP28
|
||||||
|
49: 50,
|
||||||
|
50: 50,
|
||||||
|
51: 51,
|
||||||
|
52: 51,
|
||||||
|
53: 52,
|
||||||
|
54: 53,
|
||||||
|
55: 54,
|
||||||
|
56: 55,
|
||||||
|
}
|
||||||
|
|
||||||
|
def __init__(self):
|
||||||
|
ChassisBase.__init__(self)
|
||||||
|
# sfp.py will read eeprom contents and retrive the eeprom data.
|
||||||
|
# We pass the eeprom path from chassis.py
|
||||||
|
self.PORT_START = 1
|
||||||
|
self.PORT_END = 56
|
||||||
|
self.PORTS_IN_BLOCK = (self.PORT_END + 1)
|
||||||
|
_sfp_port = range(49, self.PORTS_IN_BLOCK)
|
||||||
|
eeprom_base = "/sys/class/i2c-adapter/i2c-{0}/{0}-0050/eeprom"
|
||||||
|
for index in range(self.PORT_START, self.PORTS_IN_BLOCK):
|
||||||
|
eeprom_path = eeprom_base.format(self._port_to_i2c_mapping[index])
|
||||||
|
port_type = 'QSFP' if index in _sfp_port else 'SFP'
|
||||||
|
sfp_node = Sfp(index, port_type, eeprom_path)
|
||||||
|
self._sfp_list.append(sfp_node)
|
||||||
|
|
||||||
|
self._eeprom = Eeprom()
|
||||||
|
self._watchdog = Watchdog()
|
||||||
|
self._num_sfps = self.PORT_END
|
||||||
|
self._num_fans = MAX_S5248F_FANTRAY * MAX_S5248F_FAN
|
||||||
|
self._fan_list = [Fan(i, j) for i in range(MAX_S5248F_FANTRAY) \
|
||||||
|
for j in range(MAX_S5248F_FAN)]
|
||||||
|
for i in range(MAX_S5248F_FANTRAY):
|
||||||
|
fandrawer = FanDrawer(i)
|
||||||
|
self._fan_drawer_list.append(fandrawer)
|
||||||
|
self._fan_list.extend(fandrawer._fan_list)
|
||||||
|
|
||||||
|
self._psu_list = [Psu(i) for i in range(MAX_S5248F_PSU)]
|
||||||
|
self._thermal_list = [Thermal(i) for i in range(MAX_S5248F_THERMAL)]
|
||||||
|
self._component_list = [Component(i) for i in range(MAX_S5248F_COMPONENT)]
|
||||||
|
for port_num in range(self.PORT_START, self.PORTS_IN_BLOCK):
|
||||||
|
# sfp get uses zero-indexing, but port numbers start from 1
|
||||||
|
presence = self.get_sfp(port_num-1).get_presence()
|
||||||
|
self._global_port_pres_dict[port_num] = '1' if presence else '0'
|
||||||
|
|
||||||
|
#self.LOCATOR_LED_ON = self.STATUS_LED_COLOR_BLUE_BLINK
|
||||||
|
#self.LOCATOR_LED_OFF = self.STATUS_LED_COLOR_OFF
|
||||||
|
|
||||||
|
def __del__(self):
|
||||||
|
if self.oir_fd != -1:
|
||||||
|
self.epoll.unregister(self.oir_fd.fileno())
|
||||||
|
self.epoll.close()
|
||||||
|
self.oir_fd.close()
|
||||||
|
|
||||||
|
# check for this event change for sfp / do we need to handle timeout/sleep
|
||||||
|
|
||||||
|
def get_change_event(self, timeout=0):
|
||||||
|
"""
|
||||||
|
Returns a nested dictionary containing all devices which have
|
||||||
|
experienced a change at chassis level
|
||||||
|
"""
|
||||||
|
start_ms = time.time() * 1000
|
||||||
|
port_dict = {}
|
||||||
|
change_dict = {}
|
||||||
|
change_dict['sfp'] = port_dict
|
||||||
|
while True:
|
||||||
|
time.sleep(0.5)
|
||||||
|
for port_num in range(self.PORT_START, (self.PORT_END + 1)):
|
||||||
|
presence = self.get_sfp(port_num-1).get_presence()
|
||||||
|
if(presence and self._global_port_pres_dict[port_num] == '0'):
|
||||||
|
self._global_port_pres_dict[port_num] = '1'
|
||||||
|
port_dict[port_num] = '1'
|
||||||
|
elif(not presence and
|
||||||
|
self._global_port_pres_dict[port_num] == '1'):
|
||||||
|
self._global_port_pres_dict[port_num] = '0'
|
||||||
|
port_dict[port_num] = '0'
|
||||||
|
|
||||||
|
if(len(port_dict) > 0):
|
||||||
|
return True, change_dict
|
||||||
|
|
||||||
|
if timeout:
|
||||||
|
now_ms = time.time() * 1000
|
||||||
|
if (now_ms - start_ms >= timeout):
|
||||||
|
return True, change_dict
|
||||||
|
|
||||||
|
|
||||||
|
def get_sfp(self, index):
|
||||||
|
"""
|
||||||
|
Retrieves sfp represented by (0-based) index <index>
|
||||||
|
|
||||||
|
Args:
|
||||||
|
index: An integer, the index (0-based) of the sfp to retrieve.
|
||||||
|
The index should be the sequence of a physical port in a chassis,
|
||||||
|
starting from 0.
|
||||||
|
For example, 0 for Ethernet0, 1 for Ethernet1 and so on.
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
An object dervied from SfpBase representing the specified sfp
|
||||||
|
"""
|
||||||
|
sfp = None
|
||||||
|
|
||||||
|
try:
|
||||||
|
# The index will start from 0
|
||||||
|
sfp = self._sfp_list[index-1]
|
||||||
|
except IndexError:
|
||||||
|
sys.stderr.write("SFP index {} out of range (1-{})\n".format(
|
||||||
|
index, len(self._sfp_list)))
|
||||||
|
return sfp
|
||||||
|
|
||||||
|
def get_name(self):
|
||||||
|
"""
|
||||||
|
Retrieves the name of the chassis
|
||||||
|
Returns:
|
||||||
|
string: The name of the chassis
|
||||||
|
"""
|
||||||
|
return self._eeprom.modelstr()
|
||||||
|
|
||||||
|
def get_presence(self):
|
||||||
|
"""
|
||||||
|
Retrieves the presence of the chassis
|
||||||
|
Returns:
|
||||||
|
bool: True if chassis is present, False if not
|
||||||
|
"""
|
||||||
|
return True
|
||||||
|
|
||||||
|
def get_model(self):
|
||||||
|
"""
|
||||||
|
Retrieves the model number (or part number) of the chassis
|
||||||
|
Returns:
|
||||||
|
string: Model/part number of chassis
|
||||||
|
"""
|
||||||
|
return self._eeprom.part_number_str()
|
||||||
|
|
||||||
|
def get_serial(self):
|
||||||
|
"""
|
||||||
|
Retrieves the serial number of the chassis (Service tag)
|
||||||
|
Returns:
|
||||||
|
string: Serial number of chassis
|
||||||
|
"""
|
||||||
|
return self._eeprom.serial_str()
|
||||||
|
|
||||||
|
def get_status(self):
|
||||||
|
"""
|
||||||
|
Retrieves the operational status of the chassis
|
||||||
|
Returns:
|
||||||
|
bool: A boolean value, True if chassis is operating properly
|
||||||
|
False if not
|
||||||
|
"""
|
||||||
|
return True
|
||||||
|
|
||||||
|
def get_base_mac(self):
|
||||||
|
"""
|
||||||
|
Retrieves the base MAC address for the chassis
|
||||||
|
Returns:
|
||||||
|
A string containing the MAC address in the format
|
||||||
|
'XX:XX:XX:XX:XX:XX'
|
||||||
|
"""
|
||||||
|
return self._eeprom.base_mac_addr('')
|
||||||
|
|
||||||
|
def get_serial_number(self):
|
||||||
|
"""
|
||||||
|
Retrieves the hardware serial number for the chassis
|
||||||
|
Returns:
|
||||||
|
A string containing the hardware serial number for this chassis.
|
||||||
|
"""
|
||||||
|
return self._eeprom.serial_number_str()
|
||||||
|
|
||||||
|
def get_system_eeprom_info(self):
|
||||||
|
"""
|
||||||
|
Retrieves the full content of system EEPROM information for the chassis
|
||||||
|
Returns:
|
||||||
|
A dictionary where keys are the type code defined in
|
||||||
|
OCP ONIE TlvInfo EEPROM format and values are their corresponding
|
||||||
|
values.
|
||||||
|
"""
|
||||||
|
return self._eeprom.system_eeprom_info()
|
||||||
|
|
||||||
|
def get_eeprom(self):
|
||||||
|
"""
|
||||||
|
Retrieves the Sys Eeprom instance for the chassis.
|
||||||
|
Returns :
|
||||||
|
The instance of the Sys Eeprom
|
||||||
|
"""
|
||||||
|
return self._eeprom
|
||||||
|
|
||||||
|
def get_num_fans(self):
|
||||||
|
"""
|
||||||
|
Retrives the number of Fans on the chassis.
|
||||||
|
Returns :
|
||||||
|
An integer represents the number of Fans on the chassis.
|
||||||
|
"""
|
||||||
|
return self._num_fans
|
||||||
|
|
||||||
|
def get_num_sfps(self):
|
||||||
|
"""
|
||||||
|
Retrives the numnber of Media on the chassis.
|
||||||
|
Returns:
|
||||||
|
An integer represences the number of SFPs on the chassis.
|
||||||
|
"""
|
||||||
|
return self._num_sfps
|
||||||
|
def get_reboot_cause(self):
|
||||||
|
"""
|
||||||
|
Retrieves the cause of the previous reboot
|
||||||
|
Returns:
|
||||||
|
A tuple (string, string) where the first element is a string
|
||||||
|
containing the cause of the previous reboot. This string must be
|
||||||
|
one of the predefined strings in this class. If the first string
|
||||||
|
is "REBOOT_CAUSE_HARDWARE_OTHER", the second string can be used
|
||||||
|
to pass a description of the reboot cause.
|
||||||
|
"""
|
||||||
|
try:
|
||||||
|
with open(self.REBOOT_CAUSE_PATH) as fd:
|
||||||
|
reboot_cause = int(fd.read(), 16)
|
||||||
|
except EnvironmentError:
|
||||||
|
return (self.REBOOT_CAUSE_NON_HARDWARE, None)
|
||||||
|
|
||||||
|
if reboot_cause & 0x1:
|
||||||
|
return (self.REBOOT_CAUSE_POWER_LOSS, None)
|
||||||
|
elif reboot_cause & 0x2:
|
||||||
|
return (self.REBOOT_CAUSE_NON_HARDWARE, None)
|
||||||
|
elif reboot_cause & 0x4:
|
||||||
|
return (self.REBOOT_CAUSE_HARDWARE_OTHER, "PSU Shutdown")
|
||||||
|
elif reboot_cause & 0x8:
|
||||||
|
return (self.REBOOT_CAUSE_THERMAL_OVERLOAD_CPU, None)
|
||||||
|
elif reboot_cause & 0x10:
|
||||||
|
return (self.REBOOT_CAUSE_WATCHDOG, None)
|
||||||
|
elif reboot_cause & 0x20:
|
||||||
|
return (self.REBOOT_CAUSE_HARDWARE_OTHER, "BMC Shutdown")
|
||||||
|
elif reboot_cause & 0x40:
|
||||||
|
return (self.REBOOT_CAUSE_HARDWARE_OTHER, "Hot-Swap Shutdown")
|
||||||
|
elif reboot_cause & 0x80:
|
||||||
|
return (self.REBOOT_CAUSE_HARDWARE_OTHER, "Reset Button Shutdown")
|
||||||
|
elif reboot_cause & 0x100:
|
||||||
|
return (self.REBOOT_CAUSE_HARDWARE_OTHER, "Reset Button Cold Reboot")
|
||||||
|
else:
|
||||||
|
return (self.REBOOT_CAUSE_NON_HARDWARE, None)
|
||||||
|
|
||||||
|
def get_qualified_media_list(self):
|
||||||
|
return media_part_num_list
|
||||||
|
|
||||||
|
def set_locator_led(self, color):
|
||||||
|
"""
|
||||||
|
Sets the state of the Chassis Locator LED
|
||||||
|
|
||||||
|
Args:
|
||||||
|
color: A string representing the color with which to set the Chassis Locator LED
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
bool: True if the Chassis Locator LED state is set successfully, False if not
|
||||||
|
|
||||||
|
"""
|
||||||
|
resource = "/sys/bus/pci/devices/0000:04:00.0/resource0"
|
||||||
|
val = pci_get_value(resource, SYSTEM_LED_REG)
|
||||||
|
if self.LOCATOR_LED_ON == color:
|
||||||
|
val = int(val) | SYSTEM_BEACON_LED_SET
|
||||||
|
elif self.LOCATOR_LED_OFF == color:
|
||||||
|
val = int(val) & SYSTEM_BEACON_LED_CLEAR
|
||||||
|
else:
|
||||||
|
return False
|
||||||
|
pci_set_value(resource, val, SYSTEM_LED_REG)
|
||||||
|
return True
|
||||||
|
|
||||||
|
def get_locator_led(self):
|
||||||
|
"""
|
||||||
|
Gets the state of the Chassis Locator LED
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
LOCATOR_LED_ON or LOCATOR_LED_OFF
|
||||||
|
"""
|
||||||
|
resource = "/sys/bus/pci/devices/0000:04:00.0/resource0"
|
||||||
|
val = pci_get_value(resource, SYSTEM_LED_REG)
|
||||||
|
val = int(val) & SYSTEM_BEACON_LED_SET
|
||||||
|
if not val:
|
||||||
|
return self.LOCATOR_LED_OFF
|
||||||
|
else:
|
||||||
|
return self.LOCATOR_LED_ON
|
||||||
|
|
||||||
@ -0,0 +1,123 @@
|
|||||||
|
#!/usr/bin/env python
|
||||||
|
|
||||||
|
########################################################################
|
||||||
|
# DELLEMC S5248F
|
||||||
|
#
|
||||||
|
# Module contains an implementation of SONiC Platform Base API and
|
||||||
|
# provides the Components' (e.g., BIOS, CPLD, FPGA, BMC etc.) available in
|
||||||
|
# the platform
|
||||||
|
#
|
||||||
|
########################################################################
|
||||||
|
|
||||||
|
try:
|
||||||
|
import subprocess
|
||||||
|
from sonic_platform_base.component_base import ComponentBase
|
||||||
|
import sonic_platform.hwaccess as hwaccess
|
||||||
|
|
||||||
|
except ImportError as e:
|
||||||
|
raise ImportError(str(e) + "- required module not found")
|
||||||
|
|
||||||
|
|
||||||
|
def get_bios_version():
|
||||||
|
return subprocess.check_output(['dmidecode', '-s', 'system-version']).strip()
|
||||||
|
|
||||||
|
def get_fpga_version():
|
||||||
|
val = hwaccess.pci_get_value('/sys/bus/pci/devices/0000:04:00.0/resource0', 0)
|
||||||
|
return '{}.{}'.format((val >> 8) & 0xff, val & 0xff)
|
||||||
|
|
||||||
|
def get_bmc_version():
|
||||||
|
return subprocess.check_output(
|
||||||
|
['cat', '/sys/class/ipmi/ipmi0/device/bmc/firmware_revision']
|
||||||
|
).strip()
|
||||||
|
|
||||||
|
def get_cpld_version(bus, i2caddr):
|
||||||
|
return '{}.{}'.format(hwaccess.i2c_get(bus, i2caddr, 1),
|
||||||
|
hwaccess.i2c_get(bus, i2caddr, 0)
|
||||||
|
)
|
||||||
|
|
||||||
|
def get_cpld0_version():
|
||||||
|
return get_cpld_version(601, 0x31)
|
||||||
|
|
||||||
|
def get_cpld1_version():
|
||||||
|
return get_cpld_version(600, 0x30)
|
||||||
|
|
||||||
|
def get_cpld2_version():
|
||||||
|
return get_cpld_version(600, 0x31)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
class Component(ComponentBase):
|
||||||
|
"""DellEMC Platform-specific Component class"""
|
||||||
|
|
||||||
|
CHASSIS_COMPONENTS = [
|
||||||
|
['BIOS',
|
||||||
|
'Performs initialization of hardware components during booting',
|
||||||
|
get_bios_version
|
||||||
|
],
|
||||||
|
|
||||||
|
['FPGA',
|
||||||
|
'Used for managing the system LEDs',
|
||||||
|
get_fpga_version
|
||||||
|
],
|
||||||
|
|
||||||
|
['BMC',
|
||||||
|
'Platform management controller for on-board temperature monitoring, in-chassis power, Fan and LED control',
|
||||||
|
get_bmc_version
|
||||||
|
],
|
||||||
|
|
||||||
|
['System CPLD',
|
||||||
|
'Used for managing the CPU power sequence and CPU states',
|
||||||
|
get_cpld0_version
|
||||||
|
],
|
||||||
|
|
||||||
|
['Slave CPLD 1',
|
||||||
|
'Used for managing SFP28/QSFP28 port transceivers (SFP28 1-24, QSFP28 1-4)',
|
||||||
|
get_cpld1_version
|
||||||
|
],
|
||||||
|
|
||||||
|
['Slave CPLD 2',
|
||||||
|
'Used for managing SFP28/QSFP28 port transceivers (SFP28 25-48, QSFP28 5-8)',
|
||||||
|
get_cpld2_version
|
||||||
|
]
|
||||||
|
|
||||||
|
]
|
||||||
|
|
||||||
|
def __init__(self, component_index = 0):
|
||||||
|
self.index = component_index
|
||||||
|
self.name = self.CHASSIS_COMPONENTS[self.index][0]
|
||||||
|
self.description = self.CHASSIS_COMPONENTS[self.index][1]
|
||||||
|
self.version = self.CHASSIS_COMPONENTS[self.index][2]()
|
||||||
|
|
||||||
|
def get_name(self):
|
||||||
|
"""
|
||||||
|
Retrieves the name of the component
|
||||||
|
Returns:
|
||||||
|
A string containing the name of the component
|
||||||
|
"""
|
||||||
|
return self.name
|
||||||
|
|
||||||
|
def get_description(self):
|
||||||
|
"""
|
||||||
|
Retrieves the description of the component
|
||||||
|
Returns:
|
||||||
|
A string containing the description of the component
|
||||||
|
"""
|
||||||
|
return self.description
|
||||||
|
|
||||||
|
def get_firmware_version(self):
|
||||||
|
"""
|
||||||
|
Retrieves the firmware version of the component
|
||||||
|
Returns:
|
||||||
|
A string containing the firmware version of the component
|
||||||
|
"""
|
||||||
|
return self.version
|
||||||
|
|
||||||
|
def install_firmware(self, image_path):
|
||||||
|
"""
|
||||||
|
Installs firmware to the component
|
||||||
|
Args:
|
||||||
|
image_path: A string, path to firmware image
|
||||||
|
Returns:
|
||||||
|
A boolean, True if install was successful, False if not
|
||||||
|
"""
|
||||||
|
return False
|
||||||
@ -0,0 +1,133 @@
|
|||||||
|
#!/usr/bin/env python
|
||||||
|
|
||||||
|
#############################################################################
|
||||||
|
# DellEmc S5248F
|
||||||
|
#
|
||||||
|
# Platform and model specific eeprom subclass, inherits from the base class,
|
||||||
|
# and provides the followings:
|
||||||
|
# - the eeprom format definition
|
||||||
|
# - specific encoder/decoder if there is special need
|
||||||
|
#############################################################################
|
||||||
|
try:
|
||||||
|
import os.path
|
||||||
|
from sonic_eeprom import eeprom_tlvinfo
|
||||||
|
except ImportError as e:
|
||||||
|
raise ImportError(str(e) + "- required module not found")
|
||||||
|
|
||||||
|
|
||||||
|
class Eeprom(eeprom_tlvinfo.TlvInfoDecoder):
|
||||||
|
|
||||||
|
def __init__(self):
|
||||||
|
self.eeprom_path = None
|
||||||
|
for b in (0, 1):
|
||||||
|
f = '/sys/class/i2c-adapter/i2c-{0}/{0}-0050/eeprom'.format(b)
|
||||||
|
if os.path.exists(f):
|
||||||
|
self.eeprom_path = f
|
||||||
|
break
|
||||||
|
if self.eeprom_path is None:
|
||||||
|
return
|
||||||
|
super(Eeprom, self).__init__(self.eeprom_path, 0, '', True)
|
||||||
|
self.eeprom_tlv_dict = dict()
|
||||||
|
try:
|
||||||
|
self.eeprom_data = self.read_eeprom()
|
||||||
|
except:
|
||||||
|
self.eeprom_data = "N/A"
|
||||||
|
raise RuntimeError("Eeprom is not Programmed")
|
||||||
|
|
||||||
|
eeprom = self.eeprom_data
|
||||||
|
|
||||||
|
if not self.is_valid_tlvinfo_header(eeprom):
|
||||||
|
return
|
||||||
|
|
||||||
|
total_length = (eeprom[9] << 8) | eeprom[10]
|
||||||
|
tlv_index = self._TLV_INFO_HDR_LEN
|
||||||
|
tlv_end = self._TLV_INFO_HDR_LEN + total_length
|
||||||
|
|
||||||
|
while (tlv_index + 2) < len(eeprom) and tlv_index < tlv_end:
|
||||||
|
if not self.is_valid_tlv(eeprom[tlv_index:]):
|
||||||
|
break
|
||||||
|
|
||||||
|
tlv = eeprom[tlv_index:tlv_index + 2
|
||||||
|
+ eeprom[tlv_index + 1]]
|
||||||
|
code = "0x%02X" % tlv[0]
|
||||||
|
|
||||||
|
name, value = self.decoder(None, tlv)
|
||||||
|
|
||||||
|
self.eeprom_tlv_dict[code] = value
|
||||||
|
if eeprom[tlv_index] == self._TLV_CODE_CRC_32:
|
||||||
|
break
|
||||||
|
|
||||||
|
tlv_index += eeprom[tlv_index+1] + 2
|
||||||
|
|
||||||
|
def serial_number_str(self):
|
||||||
|
"""
|
||||||
|
Returns the serial number
|
||||||
|
"""
|
||||||
|
(is_valid, results) = self.get_tlv_field(
|
||||||
|
self.eeprom_data, self._TLV_CODE_SERIAL_NUMBER)
|
||||||
|
if not is_valid:
|
||||||
|
return "N/A"
|
||||||
|
return results[2].decode('ascii')
|
||||||
|
|
||||||
|
def base_mac_addr(self, e):
|
||||||
|
"""
|
||||||
|
Returns the base mac address found in the system EEPROM
|
||||||
|
"""
|
||||||
|
(is_valid, t) = self.get_tlv_field(
|
||||||
|
self.eeprom_data, self._TLV_CODE_MAC_BASE)
|
||||||
|
if not is_valid or t[1] != 6:
|
||||||
|
return super(eeprom_tlvinfo.TlvInfoDecoder, self).switchaddrstr(t)
|
||||||
|
|
||||||
|
return ":".join(["{:02x}".format(T) for T in t[2]]).upper()
|
||||||
|
|
||||||
|
def modelstr(self):
|
||||||
|
"""
|
||||||
|
Returns the Model name
|
||||||
|
"""
|
||||||
|
(is_valid, results) = self.get_tlv_field(
|
||||||
|
self.eeprom_data, self._TLV_CODE_PRODUCT_NAME)
|
||||||
|
if not is_valid:
|
||||||
|
return "N/A"
|
||||||
|
|
||||||
|
return results[2].decode('ascii')
|
||||||
|
|
||||||
|
def part_number_str(self):
|
||||||
|
"""
|
||||||
|
Returns the part number
|
||||||
|
"""
|
||||||
|
(is_valid, results) = self.get_tlv_field(
|
||||||
|
self.eeprom_data, self._TLV_CODE_PART_NUMBER)
|
||||||
|
if not is_valid:
|
||||||
|
return "N/A"
|
||||||
|
|
||||||
|
return results[2].decode('ascii')
|
||||||
|
|
||||||
|
def serial_str(self):
|
||||||
|
"""
|
||||||
|
Returns the servicetag number
|
||||||
|
"""
|
||||||
|
(is_valid, results) = self.get_tlv_field(
|
||||||
|
self.eeprom_data, self._TLV_CODE_SERVICE_TAG)
|
||||||
|
if not is_valid:
|
||||||
|
return "N/A"
|
||||||
|
|
||||||
|
return results[2].decode('ascii')
|
||||||
|
|
||||||
|
def revision_str(self):
|
||||||
|
"""
|
||||||
|
Returns the device revision
|
||||||
|
"""
|
||||||
|
(is_valid, results) = self.get_tlv_field(
|
||||||
|
self.eeprom_data, self._TLV_CODE_DEVICE_VERSION)
|
||||||
|
if not is_valid:
|
||||||
|
return "N/A"
|
||||||
|
|
||||||
|
return results[2].decode('ascii')
|
||||||
|
|
||||||
|
def system_eeprom_info(self):
|
||||||
|
"""
|
||||||
|
Returns a dictionary, where keys are the type code defined in
|
||||||
|
ONIE EEPROM format and values are their corresponding values
|
||||||
|
found in the system EEPROM.
|
||||||
|
"""
|
||||||
|
return self.eeprom_tlv_dict
|
||||||
@ -0,0 +1,185 @@
|
|||||||
|
#!/usr/bin/env python
|
||||||
|
|
||||||
|
########################################################################
|
||||||
|
# DellEMC S5248F
|
||||||
|
#
|
||||||
|
# Module contains an implementation of SONiC Platform Base API and
|
||||||
|
# provides the Fans' information which are available in the platform.
|
||||||
|
#
|
||||||
|
########################################################################
|
||||||
|
|
||||||
|
try:
|
||||||
|
from sonic_platform_base.fan_base import FanBase
|
||||||
|
from sonic_platform.ipmihelper import IpmiSensor, IpmiFru
|
||||||
|
except ImportError as e:
|
||||||
|
raise ImportError(str(e) + "- required module not found")
|
||||||
|
|
||||||
|
FAN1_MAX_SPEED_OFFSET = 71
|
||||||
|
FAN2_MAX_SPEED_OFFSET = 73
|
||||||
|
PSU_FAN_MAX_SPEED_OFFSET = 50
|
||||||
|
FAN_DIRECTION_OFFSET = 69
|
||||||
|
PSU_FAN_DIRECTION_OFFSET = 47
|
||||||
|
|
||||||
|
|
||||||
|
class Fan(FanBase):
|
||||||
|
"""DellEMC Platform-specific Fan class"""
|
||||||
|
# { FAN-ID: { Sensor-Name: Sensor-ID } }
|
||||||
|
# System rev X01, BMC firmware rev 1.02
|
||||||
|
FAN_SENSOR_MAPPING = { 1: {"Prsnt": 0x53, "State": 0x57, "Speed": 0x24},
|
||||||
|
2: {"Prsnt": 0x53, "State": 0x5b, "Speed": 0x20},
|
||||||
|
3: {"Prsnt": 0x54, "State": 0x58, "Speed": 0x25},
|
||||||
|
4: {"Prsnt": 0x54, "State": 0x5c, "Speed": 0x21},
|
||||||
|
5: {"Prsnt": 0x55, "State": 0x59, "Speed": 0x26},
|
||||||
|
6: {"Prsnt": 0x55, "State": 0x5d, "Speed": 0x22},
|
||||||
|
7: {"Prsnt": 0x56, "State": 0x5a, "Speed": 0x27},
|
||||||
|
8: {"Prsnt": 0x56, "State": 0x5e, "Speed": 0x23}
|
||||||
|
}
|
||||||
|
PSU_FAN_SENSOR_MAPPING = { 1: {"State": 0x31, "Speed": 0x28},
|
||||||
|
2: {"State": 0x32, "Speed": 0x29} }
|
||||||
|
|
||||||
|
# { FANTRAY-ID: FRU-ID }
|
||||||
|
FAN_FRU_MAPPING = { 1: 3, 2: 4, 3: 5, 4: 6 }
|
||||||
|
PSU_FRU_MAPPING = { 1: 1, 2: 2 }
|
||||||
|
|
||||||
|
def __init__(self, fantray_index=1, fan_index=1, psu_fan=False,
|
||||||
|
dependency=None):
|
||||||
|
FanBase.__init__(self)
|
||||||
|
self.is_psu_fan = psu_fan
|
||||||
|
if not self.is_psu_fan:
|
||||||
|
# API index is starting from 0, DellEMC platform index is
|
||||||
|
# starting from 1
|
||||||
|
self.fantrayindex = fantray_index + 1
|
||||||
|
self.fanindex = fan_index + 1
|
||||||
|
if (self.fanindex == 1):
|
||||||
|
self.max_speed_offset = FAN1_MAX_SPEED_OFFSET
|
||||||
|
else:
|
||||||
|
self.max_speed_offset = FAN2_MAX_SPEED_OFFSET
|
||||||
|
self.fan_direction_offset = FAN_DIRECTION_OFFSET
|
||||||
|
self.index = (self.fantrayindex - 1) * 2 + self.fanindex
|
||||||
|
self.prsnt_sensor = IpmiSensor(self.FAN_SENSOR_MAPPING[self.index]["Prsnt"],
|
||||||
|
is_discrete=True)
|
||||||
|
self.state_sensor = IpmiSensor(self.FAN_SENSOR_MAPPING[self.index]["State"],
|
||||||
|
is_discrete=True)
|
||||||
|
self.speed_sensor = IpmiSensor(self.FAN_SENSOR_MAPPING[self.index]["Speed"])
|
||||||
|
self.fru = IpmiFru(self.FAN_FRU_MAPPING[self.fantrayindex])
|
||||||
|
else:
|
||||||
|
self.dependency = dependency
|
||||||
|
self.fanindex = fan_index
|
||||||
|
self.state_sensor = IpmiSensor(self.PSU_FAN_SENSOR_MAPPING[self.fanindex]["State"],
|
||||||
|
is_discrete=True)
|
||||||
|
self.speed_sensor = IpmiSensor(self.PSU_FAN_SENSOR_MAPPING[self.fanindex]["Speed"])
|
||||||
|
self.fru = IpmiFru(self.PSU_FRU_MAPPING[self.fanindex])
|
||||||
|
self.max_speed_offset = PSU_FAN_MAX_SPEED_OFFSET
|
||||||
|
self.fan_direction_offset = PSU_FAN_DIRECTION_OFFSET
|
||||||
|
self.max_speed = self.fru.get_fru_data(self.max_speed_offset,2)[1]
|
||||||
|
self.max_speed = self.max_speed[1] << 8 | self.max_speed[0]
|
||||||
|
|
||||||
|
def get_name(self):
|
||||||
|
"""
|
||||||
|
Retrieves the name of the device
|
||||||
|
Returns:
|
||||||
|
String: The name of the device
|
||||||
|
"""
|
||||||
|
if self.is_psu_fan:
|
||||||
|
return "PSU{} Fan".format(self.fanindex)
|
||||||
|
else:
|
||||||
|
return "FanTray{}-Fan{}".format(self.fantrayindex, self.fanindex)
|
||||||
|
|
||||||
|
def get_model(self):
|
||||||
|
"""
|
||||||
|
Retrieves the part number of the FAN
|
||||||
|
Returns:
|
||||||
|
String: Part number of FAN
|
||||||
|
"""
|
||||||
|
if self.is_psu_fan:
|
||||||
|
return None
|
||||||
|
else:
|
||||||
|
return self.fru.get_board_part_number()
|
||||||
|
|
||||||
|
def get_serial(self):
|
||||||
|
"""
|
||||||
|
Retrieves the serial number of the FAN
|
||||||
|
Returns:
|
||||||
|
String: Serial number of FAN
|
||||||
|
"""
|
||||||
|
if self.is_psu_fan:
|
||||||
|
return None
|
||||||
|
else:
|
||||||
|
return self.fru.get_board_serial()
|
||||||
|
|
||||||
|
def get_presence(self):
|
||||||
|
"""
|
||||||
|
Retrieves the presence of the FAN
|
||||||
|
Returns:
|
||||||
|
bool: True if fan is present, False if not
|
||||||
|
"""
|
||||||
|
presence = False
|
||||||
|
if self.is_psu_fan:
|
||||||
|
return self.dependency.get_presence()
|
||||||
|
else:
|
||||||
|
is_valid, state = self.prsnt_sensor.get_reading()
|
||||||
|
if is_valid:
|
||||||
|
if (state & 0b1):
|
||||||
|
presence = True
|
||||||
|
return presence
|
||||||
|
|
||||||
|
def get_status(self):
|
||||||
|
"""
|
||||||
|
Retrieves the operational status of the FAN
|
||||||
|
Returns:
|
||||||
|
bool: True if FAN is operating properly, False if not
|
||||||
|
"""
|
||||||
|
status = False
|
||||||
|
is_valid, state = self.state_sensor.get_reading()
|
||||||
|
if is_valid:
|
||||||
|
if not state > 1:
|
||||||
|
status = True
|
||||||
|
return status
|
||||||
|
|
||||||
|
def get_direction(self):
|
||||||
|
"""
|
||||||
|
Retrieves the fan airfow direction
|
||||||
|
Returns:
|
||||||
|
A string, either FAN_DIRECTION_INTAKE or FAN_DIRECTION_EXHAUST
|
||||||
|
depending on fan direction
|
||||||
|
|
||||||
|
Notes:
|
||||||
|
In DellEMC platforms,
|
||||||
|
- Forward/Exhaust : Air flows from Port side to Fan side.
|
||||||
|
- Reverse/Intake : Air flows from Fan side to Port side.
|
||||||
|
"""
|
||||||
|
direction = [self.FAN_DIRECTION_EXHAUST, self.FAN_DIRECTION_INTAKE]
|
||||||
|
fan_status = self.get_presence()
|
||||||
|
if not fan_status:
|
||||||
|
return None
|
||||||
|
is_valid, fan_direction = self.fru.get_fru_data(self.fan_direction_offset)
|
||||||
|
if is_valid and fan_direction[0] < len(direction):
|
||||||
|
return direction[fan_direction[0]]
|
||||||
|
else:
|
||||||
|
return None
|
||||||
|
|
||||||
|
def get_speed(self):
|
||||||
|
"""
|
||||||
|
Retrieves the speed of the fan
|
||||||
|
Returns:
|
||||||
|
int: percentage of the max fan speed
|
||||||
|
"""
|
||||||
|
if self.max_speed == 0:
|
||||||
|
self.max_speed = self.fru.get_fru_data(self.max_speed_offset,2)[1]
|
||||||
|
self.max_speed = self.max_speed[1] << 8 | self.max_speed[0]
|
||||||
|
is_valid, fan_speed = self.speed_sensor.get_reading()
|
||||||
|
if not is_valid or self.max_speed == 0:
|
||||||
|
return None
|
||||||
|
else:
|
||||||
|
speed = (100 * fan_speed)//self.max_speed
|
||||||
|
return speed
|
||||||
|
|
||||||
|
def get_speed_rpm(self):
|
||||||
|
"""
|
||||||
|
Retrieves the speed of the fan
|
||||||
|
Returns:
|
||||||
|
int: percentage of the max fan speed
|
||||||
|
"""
|
||||||
|
fan_speed = 0
|
||||||
|
is_valid, fan_speed = self.speed_sensor.get_reading()
|
||||||
|
return fan_speed if is_valid else None
|
||||||
@ -0,0 +1,37 @@
|
|||||||
|
#!/usr/bin/env python
|
||||||
|
|
||||||
|
########################################################################
|
||||||
|
# DellEMC S5248F
|
||||||
|
#
|
||||||
|
# Module contains an implementation of SONiC Platform Base API and
|
||||||
|
# provides the Fan-Drawers' information available in the platform.
|
||||||
|
#
|
||||||
|
########################################################################
|
||||||
|
|
||||||
|
try:
|
||||||
|
from sonic_platform_base.fan_drawer_base import FanDrawerBase
|
||||||
|
from sonic_platform.fan import Fan
|
||||||
|
except ImportError as e:
|
||||||
|
raise ImportError(str(e) + "- required module not found")
|
||||||
|
|
||||||
|
S5248F_FANS_PER_FANTRAY = 2
|
||||||
|
|
||||||
|
|
||||||
|
class FanDrawer(FanDrawerBase):
|
||||||
|
"""DellEMC Platform-specific Fan class"""
|
||||||
|
|
||||||
|
def __init__(self, fantray_index):
|
||||||
|
|
||||||
|
FanDrawerBase.__init__(self)
|
||||||
|
# FanTray is 1-based in DellEMC platforms
|
||||||
|
self.fantrayindex = fantray_index + 1
|
||||||
|
for i in range(S5248F_FANS_PER_FANTRAY):
|
||||||
|
self._fan_list.append(Fan(fantray_index, i))
|
||||||
|
|
||||||
|
def get_name(self):
|
||||||
|
"""
|
||||||
|
Retrieves the fan drawer name
|
||||||
|
Returns:
|
||||||
|
string: The name of the device
|
||||||
|
"""
|
||||||
|
return "FanTray{}".format(self.fantrayindex)
|
||||||
@ -0,0 +1 @@
|
|||||||
|
../../common/sonic_platform/hwaccess.py
|
||||||
@ -0,0 +1,269 @@
|
|||||||
|
#!/usr/bin/python3
|
||||||
|
|
||||||
|
########################################################################
|
||||||
|
# DellEMC
|
||||||
|
#
|
||||||
|
# Module contains implementation of IpmiSensor and IpmiFru classes that
|
||||||
|
# provide Sensor's and FRU's information respectively.
|
||||||
|
#
|
||||||
|
########################################################################
|
||||||
|
|
||||||
|
import subprocess
|
||||||
|
import re
|
||||||
|
|
||||||
|
# IPMI Request Network Function Codes
|
||||||
|
NetFn_SensorEvent = 0x04
|
||||||
|
NetFn_Storage = 0x0A
|
||||||
|
|
||||||
|
# IPMI Sensor Device Commands
|
||||||
|
Cmd_GetSensorReadingFactors = 0x23
|
||||||
|
Cmd_GetSensorThreshold = 0x27
|
||||||
|
Cmd_GetSensorReading = 0x2D
|
||||||
|
|
||||||
|
# IPMI FRU Device Commands
|
||||||
|
Cmd_ReadFRUData = 0x11
|
||||||
|
|
||||||
|
def get_ipmitool_raw_output(args):
|
||||||
|
"""
|
||||||
|
Returns a list the elements of which are the individual bytes of
|
||||||
|
ipmitool raw <cmd> command output.
|
||||||
|
"""
|
||||||
|
result_bytes = list()
|
||||||
|
result = ""
|
||||||
|
command = "ipmitool raw {}".format(args)
|
||||||
|
try:
|
||||||
|
proc = subprocess.Popen(command.split(), stdout=subprocess.PIPE,
|
||||||
|
universal_newlines=True, stderr=subprocess.STDOUT)
|
||||||
|
stdout = proc.communicate()[0]
|
||||||
|
proc.wait()
|
||||||
|
if not proc.returncode:
|
||||||
|
result = stdout.rstrip('\n')
|
||||||
|
except EnvironmentError:
|
||||||
|
pass
|
||||||
|
|
||||||
|
for i in result.split():
|
||||||
|
result_bytes.append(int(i, 16))
|
||||||
|
|
||||||
|
return result_bytes
|
||||||
|
|
||||||
|
class IpmiSensor(object):
|
||||||
|
|
||||||
|
# Sensor Threshold types and their respective bit masks
|
||||||
|
THRESHOLD_BIT_MASK = {
|
||||||
|
"LowerNonCritical" : 0,
|
||||||
|
"LowerCritical" : 1,
|
||||||
|
"LowerNonRecoverable" : 2,
|
||||||
|
"UpperNonCritical" : 3,
|
||||||
|
"UpperCritical" : 4,
|
||||||
|
"UpperNonRecoverable" : 5
|
||||||
|
}
|
||||||
|
|
||||||
|
def __init__(self, sensor_id, is_discrete=False):
|
||||||
|
self.id = sensor_id
|
||||||
|
self.is_discrete = is_discrete
|
||||||
|
|
||||||
|
def _get_converted_sensor_reading(self, raw_value):
|
||||||
|
"""
|
||||||
|
Returns a 2 element tuple(bool, int) in which first element
|
||||||
|
provides the validity of the reading and the second element is
|
||||||
|
the converted sensor reading
|
||||||
|
"""
|
||||||
|
# Get Sensor Reading Factors
|
||||||
|
cmd_args = "{} {} {} {}".format(NetFn_SensorEvent,
|
||||||
|
Cmd_GetSensorReadingFactors,
|
||||||
|
self.id, raw_value)
|
||||||
|
factors = get_ipmitool_raw_output(cmd_args)
|
||||||
|
|
||||||
|
if len(factors) != 7:
|
||||||
|
return False, 0
|
||||||
|
|
||||||
|
# Compute Twos complement
|
||||||
|
def get_twos_complement(val, bits):
|
||||||
|
if val & (1 << (bits - 1)):
|
||||||
|
val = val - (1 << bits)
|
||||||
|
return val
|
||||||
|
|
||||||
|
# Calculate actual sensor value from the raw sensor value
|
||||||
|
# using the sensor reading factors.
|
||||||
|
M = get_twos_complement(((factors[2] & 0xC0) << 8) | factors[1], 10)
|
||||||
|
B = get_twos_complement(((factors[4] & 0xC0) << 8) | factors[3], 10)
|
||||||
|
R_exp = get_twos_complement((factors[6] & 0xF0) >> 4, 4)
|
||||||
|
B_exp = get_twos_complement(factors[6] & 0x0F, 4)
|
||||||
|
|
||||||
|
converted_reading = ((M * raw_value) + (B * 10**B_exp)) * 10**R_exp
|
||||||
|
|
||||||
|
return True, converted_reading
|
||||||
|
|
||||||
|
def get_reading(self):
|
||||||
|
"""
|
||||||
|
For Threshold sensors, returns the sensor reading.
|
||||||
|
For Discrete sensors, returns the state value.
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A tuple (bool, int) where the first element provides the
|
||||||
|
validity of the reading and the second element provides the
|
||||||
|
sensor reading/state value.
|
||||||
|
"""
|
||||||
|
# Get Sensor Reading
|
||||||
|
cmd_args = "{} {} {}".format(NetFn_SensorEvent, Cmd_GetSensorReading,
|
||||||
|
self.id)
|
||||||
|
output = get_ipmitool_raw_output(cmd_args)
|
||||||
|
if len(output) != 4:
|
||||||
|
return False, 0
|
||||||
|
|
||||||
|
# Check reading/state unavailable
|
||||||
|
if output[1] & 0x20:
|
||||||
|
return False, 0
|
||||||
|
|
||||||
|
if self.is_discrete:
|
||||||
|
state = ((output[3] & 0x7F) << 8) | output[2]
|
||||||
|
return True, state
|
||||||
|
else:
|
||||||
|
return self._get_converted_sensor_reading(output[0])
|
||||||
|
|
||||||
|
def get_threshold(self, threshold_type):
|
||||||
|
"""
|
||||||
|
Returns the sensor's threshold value for a given threshold type.
|
||||||
|
|
||||||
|
Args:
|
||||||
|
threshold_type (str) - one of the below mentioned
|
||||||
|
threshold type strings
|
||||||
|
|
||||||
|
"LowerNonCritical"
|
||||||
|
"LowerCritical"
|
||||||
|
"LowerNonRecoverable"
|
||||||
|
"UpperNonCritical"
|
||||||
|
"UpperCritical"
|
||||||
|
"UpperNonRecoverable"
|
||||||
|
Returns:
|
||||||
|
A tuple (bool, int) where the first element provides the
|
||||||
|
validity of that threshold and second element provides the
|
||||||
|
threshold value.
|
||||||
|
"""
|
||||||
|
# Thresholds are not valid for discrete sensors
|
||||||
|
if self.is_discrete:
|
||||||
|
raise TypeError("Threshold is not applicable for Discrete Sensor")
|
||||||
|
|
||||||
|
if threshold_type not in list(self.THRESHOLD_BIT_MASK.keys()):
|
||||||
|
raise ValueError("Invalid threshold type {} provided. Valid types "
|
||||||
|
"are {}".format(threshold_type,
|
||||||
|
list(self.THRESHOLD_BIT_MASK.keys())))
|
||||||
|
|
||||||
|
bit_mask = self.THRESHOLD_BIT_MASK[threshold_type]
|
||||||
|
|
||||||
|
# Get Sensor Threshold
|
||||||
|
cmd_args = "{} {} {}".format(NetFn_SensorEvent, Cmd_GetSensorThreshold,
|
||||||
|
self.id)
|
||||||
|
thresholds = get_ipmitool_raw_output(cmd_args)
|
||||||
|
if len(thresholds) != 7:
|
||||||
|
return False, 0
|
||||||
|
|
||||||
|
valid_thresholds = thresholds.pop(0)
|
||||||
|
# Check whether particular threshold is readable
|
||||||
|
if valid_thresholds & (1 << bit_mask):
|
||||||
|
return self._get_converted_sensor_reading(thresholds[bit_mask])
|
||||||
|
else:
|
||||||
|
return False, 0
|
||||||
|
|
||||||
|
class IpmiFru(object):
|
||||||
|
|
||||||
|
def __init__(self, fru_id):
|
||||||
|
self.id = fru_id
|
||||||
|
|
||||||
|
def _get_ipmitool_fru_print(self):
|
||||||
|
result = ""
|
||||||
|
command = "ipmitool fru print {}".format(self.id)
|
||||||
|
try:
|
||||||
|
proc = subprocess.Popen(command.split(), stdout=subprocess.PIPE,
|
||||||
|
universal_newlines=True, stderr=subprocess.STDOUT)
|
||||||
|
stdout = proc.communicate()[0]
|
||||||
|
proc.wait()
|
||||||
|
if not proc.returncode:
|
||||||
|
result = stdout.rstrip('\n')
|
||||||
|
except EnvironmentError:
|
||||||
|
pass
|
||||||
|
|
||||||
|
return result
|
||||||
|
|
||||||
|
def _get_from_fru(self, info):
|
||||||
|
"""
|
||||||
|
Returns a string containing the info from FRU
|
||||||
|
"""
|
||||||
|
fru_output = self._get_ipmitool_fru_print()
|
||||||
|
if not fru_output:
|
||||||
|
return "NA"
|
||||||
|
|
||||||
|
info_req = re.search(r"%s\s*:(.*)" % info, fru_output)
|
||||||
|
if not info_req:
|
||||||
|
return "NA"
|
||||||
|
|
||||||
|
return info_req.group(1).strip()
|
||||||
|
|
||||||
|
def get_board_serial(self):
|
||||||
|
"""
|
||||||
|
Returns a string containing the Serial Number of the device.
|
||||||
|
"""
|
||||||
|
return self._get_from_fru('Board Serial')
|
||||||
|
|
||||||
|
def get_board_part_number(self):
|
||||||
|
"""
|
||||||
|
Returns a string containing the Part Number of the device.
|
||||||
|
"""
|
||||||
|
return self._get_from_fru('Board Part Number')
|
||||||
|
|
||||||
|
def get_board_mfr_id(self):
|
||||||
|
"""
|
||||||
|
Returns a string containing the manufacturer id of the FRU.
|
||||||
|
"""
|
||||||
|
return self._get_from_fru('Board Mfg')
|
||||||
|
|
||||||
|
def get_board_product(self):
|
||||||
|
"""
|
||||||
|
Returns a string containing the manufacturer id of the FRU.
|
||||||
|
"""
|
||||||
|
return self._get_from_fru('Board Product')
|
||||||
|
|
||||||
|
def get_fru_data(self, offset, count=1):
|
||||||
|
"""
|
||||||
|
Reads and returns the FRU data at the provided offset.
|
||||||
|
|
||||||
|
Args:
|
||||||
|
offset (int) - FRU offset to read
|
||||||
|
count (int) - Number of bytes to read [optional, default = 1]
|
||||||
|
Returns:
|
||||||
|
A tuple (bool, list(int)) where the first element provides
|
||||||
|
the validity of the data read and the second element is a
|
||||||
|
list, the elements of which are the individual bytes of the
|
||||||
|
FRU data read.
|
||||||
|
"""
|
||||||
|
result_bytes = list()
|
||||||
|
is_valid = True
|
||||||
|
result = ""
|
||||||
|
|
||||||
|
offset_LSB = offset & 0xFF
|
||||||
|
offset_MSB = offset & 0xFF00
|
||||||
|
command = "ipmitool raw {} {} {} {} {} {}".format(NetFn_Storage,
|
||||||
|
Cmd_ReadFRUData,
|
||||||
|
self.id, offset_LSB,
|
||||||
|
offset_MSB, count)
|
||||||
|
try:
|
||||||
|
proc = subprocess.Popen(command.split(), stdout=subprocess.PIPE,
|
||||||
|
universal_newlines=True, stderr=subprocess.STDOUT)
|
||||||
|
stdout = proc.communicate()[0]
|
||||||
|
proc.wait()
|
||||||
|
if not proc.returncode:
|
||||||
|
result = stdout.rstrip('\n')
|
||||||
|
except EnvironmentError:
|
||||||
|
is_valid = False
|
||||||
|
|
||||||
|
if (not result) or (not is_valid):
|
||||||
|
return False, result_bytes
|
||||||
|
|
||||||
|
for i in result.split():
|
||||||
|
result_bytes.append(int(i, 16))
|
||||||
|
|
||||||
|
read_count = result_bytes.pop(0)
|
||||||
|
if read_count != count:
|
||||||
|
return False, result_bytes
|
||||||
|
else:
|
||||||
|
return True, result_bytes
|
||||||
@ -0,0 +1,13 @@
|
|||||||
|
# Media settings key plugin
|
||||||
|
#
|
||||||
|
# Generate keys used for lookup in media_settings,json
|
||||||
|
|
||||||
|
def get_media_settings_key(physical_port, transceiver_dict):
|
||||||
|
d = transceiver_dict[physical_port]
|
||||||
|
media_interface = d['media_interface']
|
||||||
|
generic_key = '{}-{}'.format(d['form_factor'], media_interface)
|
||||||
|
if media_interface == 'CR':
|
||||||
|
generic_key = '{}-{}'.format(generic_key, d['cable_length_detailed'])
|
||||||
|
return ['{}-{}'.format(d['manufacturename'], d['modelname']),
|
||||||
|
generic_key
|
||||||
|
]
|
||||||
@ -0,0 +1,24 @@
|
|||||||
|
#!/usr/bin/env python
|
||||||
|
|
||||||
|
#############################################################################
|
||||||
|
#
|
||||||
|
# Module contains an implementation of SONiC Platform Base API and
|
||||||
|
# provides the platform information
|
||||||
|
#
|
||||||
|
#############################################################################
|
||||||
|
|
||||||
|
try:
|
||||||
|
from sonic_platform_base.platform_base import PlatformBase
|
||||||
|
from sonic_platform.chassis import Chassis
|
||||||
|
except ImportError as e:
|
||||||
|
raise ImportError(str(e) + "- required module not found")
|
||||||
|
|
||||||
|
|
||||||
|
class Platform(PlatformBase):
|
||||||
|
"""
|
||||||
|
DELLEMC Platform-specific class
|
||||||
|
"""
|
||||||
|
|
||||||
|
def __init__(self):
|
||||||
|
PlatformBase.__init__(self)
|
||||||
|
self._chassis = Chassis()
|
||||||
@ -0,0 +1,230 @@
|
|||||||
|
#!/usr/bin/env python
|
||||||
|
|
||||||
|
########################################################################
|
||||||
|
# DellEMC S5248F
|
||||||
|
#
|
||||||
|
# Module contains an implementation of SONiC Platform Base API and
|
||||||
|
# provides the PSUs' information which are available in the platform
|
||||||
|
#
|
||||||
|
########################################################################
|
||||||
|
|
||||||
|
|
||||||
|
try:
|
||||||
|
from sonic_platform_base.psu_base import PsuBase
|
||||||
|
from sonic_platform.ipmihelper import IpmiSensor, IpmiFru
|
||||||
|
from sonic_platform.fan import Fan
|
||||||
|
except ImportError as e:
|
||||||
|
raise ImportError(str(e) + "- required module not found")
|
||||||
|
|
||||||
|
|
||||||
|
class Psu(PsuBase):
|
||||||
|
"""DellEMC Platform-specific PSU class"""
|
||||||
|
|
||||||
|
# { PSU-ID: { Sensor-Name: Sensor-ID } }
|
||||||
|
SENSOR_MAPPING = { 1: { "State": 0x31, "Current": 0x39,
|
||||||
|
"Power": 0x37, "Voltage": 0x38,
|
||||||
|
"InCurrent": 0x36, "InPower": 0x34,
|
||||||
|
"InVoltage": 0x35 },
|
||||||
|
2: { "State": 0x32, "Current": 0x3F,
|
||||||
|
"Power": 0x3D, "Voltage": 0x3E,
|
||||||
|
"InCurrent": 0x3C, "InPower": 0x3A,
|
||||||
|
"InVoltage": 0x3B } }
|
||||||
|
# ( PSU-ID: FRU-ID }
|
||||||
|
FRU_MAPPING = { 1: 1, 2: 2 }
|
||||||
|
|
||||||
|
def __init__(self, psu_index):
|
||||||
|
PsuBase.__init__(self)
|
||||||
|
# PSU is 1-based in DellEMC platforms
|
||||||
|
self.index = psu_index + 1
|
||||||
|
self.state_sensor = IpmiSensor(self.SENSOR_MAPPING[self.index]["State"],
|
||||||
|
is_discrete=True)
|
||||||
|
self.voltage_sensor = IpmiSensor(self.SENSOR_MAPPING[self.index]["Voltage"])
|
||||||
|
self.current_sensor = IpmiSensor(self.SENSOR_MAPPING[self.index]["Current"])
|
||||||
|
self.power_sensor = IpmiSensor(self.SENSOR_MAPPING[self.index]["Power"])
|
||||||
|
self.input_voltage_sensor = IpmiSensor(self.SENSOR_MAPPING[self.index]["InVoltage"])
|
||||||
|
self.input_current_sensor = IpmiSensor(self.SENSOR_MAPPING[self.index]["InCurrent"])
|
||||||
|
self.input_power_sensor = IpmiSensor(self.SENSOR_MAPPING[self.index]["InPower"])
|
||||||
|
self.fru = IpmiFru(self.FRU_MAPPING[self.index])
|
||||||
|
|
||||||
|
self._fan_list.append(Fan(fan_index=self.index, psu_fan=True,
|
||||||
|
dependency=self))
|
||||||
|
|
||||||
|
def get_name(self):
|
||||||
|
"""
|
||||||
|
Retrieves the name of the device
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
string: The name of the device
|
||||||
|
"""
|
||||||
|
return "PSU{}".format(self.index)
|
||||||
|
|
||||||
|
def get_presence(self):
|
||||||
|
"""
|
||||||
|
Retrieves the presence of the Power Supply Unit (PSU)
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
bool: True if PSU is present, False if not
|
||||||
|
"""
|
||||||
|
presence = False
|
||||||
|
is_valid, state = self.state_sensor.get_reading()
|
||||||
|
if is_valid:
|
||||||
|
if (state & 0b1):
|
||||||
|
presence = True
|
||||||
|
|
||||||
|
return presence
|
||||||
|
|
||||||
|
def get_model(self):
|
||||||
|
"""
|
||||||
|
Retrieves the part number of the PSU
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
string: Part number of PSU
|
||||||
|
"""
|
||||||
|
return self.fru.get_board_part_number()
|
||||||
|
|
||||||
|
def get_serial(self):
|
||||||
|
"""
|
||||||
|
Retrieves the serial number of the PSU
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
string: Serial number of PSU
|
||||||
|
"""
|
||||||
|
return self.fru.get_board_serial()
|
||||||
|
|
||||||
|
def get_status(self):
|
||||||
|
"""
|
||||||
|
Retrieves the operational status of the PSU
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
bool: True if PSU is operating properly, False if not
|
||||||
|
"""
|
||||||
|
status = False
|
||||||
|
is_valid, state = self.state_sensor.get_reading()
|
||||||
|
if is_valid:
|
||||||
|
if (state == 0x01):
|
||||||
|
status = True
|
||||||
|
|
||||||
|
return status
|
||||||
|
|
||||||
|
def get_voltage(self):
|
||||||
|
"""
|
||||||
|
Retrieves current PSU voltage output
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A float number, the output voltage in volts,
|
||||||
|
e.g. 12.1
|
||||||
|
"""
|
||||||
|
is_valid, voltage = self.voltage_sensor.get_reading()
|
||||||
|
if not is_valid:
|
||||||
|
return None
|
||||||
|
|
||||||
|
return "{:.1f}".format(voltage)
|
||||||
|
|
||||||
|
def get_current(self):
|
||||||
|
"""
|
||||||
|
Retrieves present electric current supplied by PSU
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A float number, electric current in amperes,
|
||||||
|
e.g. 15.4
|
||||||
|
"""
|
||||||
|
is_valid, current = self.current_sensor.get_reading()
|
||||||
|
if not is_valid:
|
||||||
|
return None
|
||||||
|
|
||||||
|
return "{:.1f}".format(current)
|
||||||
|
|
||||||
|
def get_power(self):
|
||||||
|
"""
|
||||||
|
Retrieves current energy supplied by PSU
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A float number, the power in watts,
|
||||||
|
e.g. 302.6
|
||||||
|
"""
|
||||||
|
is_valid, power = self.power_sensor.get_reading()
|
||||||
|
if not is_valid:
|
||||||
|
return None
|
||||||
|
|
||||||
|
return "{:.1f}".format(power)
|
||||||
|
|
||||||
|
def get_input_voltage(self):
|
||||||
|
"""
|
||||||
|
Retrieves current PSU voltage input
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A float number, the input voltage in volts,
|
||||||
|
e.g. 12.1
|
||||||
|
"""
|
||||||
|
is_valid, input_voltage = self.input_voltage_sensor.get_reading()
|
||||||
|
if not is_valid:
|
||||||
|
return None
|
||||||
|
|
||||||
|
return "{:.1f}".format(input_voltage)
|
||||||
|
|
||||||
|
def get_input_current(self):
|
||||||
|
"""
|
||||||
|
Retrieves present electric current supplied to PSU
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A float number, electric current in amperes,
|
||||||
|
e.g. 15.4
|
||||||
|
"""
|
||||||
|
is_valid, input_current = self.input_current_sensor.get_reading()
|
||||||
|
if not is_valid:
|
||||||
|
return None
|
||||||
|
|
||||||
|
return "{:.1f}".format(input_current)
|
||||||
|
|
||||||
|
def get_input_power(self):
|
||||||
|
"""
|
||||||
|
Retrieves current energy supplied to PSU
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A float number, the power in watts,
|
||||||
|
e.g. 302.6
|
||||||
|
"""
|
||||||
|
is_valid, input_power = self.input_power_sensor.get_reading()
|
||||||
|
if not is_valid:
|
||||||
|
return None
|
||||||
|
|
||||||
|
return "{:.1f}".format(input_power)
|
||||||
|
|
||||||
|
def get_powergood_status(self):
|
||||||
|
"""
|
||||||
|
Retrieves the powergood status of PSU
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A boolean, True if PSU has stablized its output voltages and
|
||||||
|
passed all its internal self-tests, False if not.
|
||||||
|
"""
|
||||||
|
status = False
|
||||||
|
is_valid, state = self.state_sensor.get_reading()
|
||||||
|
if is_valid:
|
||||||
|
if (state == 0x01):
|
||||||
|
status = True
|
||||||
|
|
||||||
|
return status
|
||||||
|
|
||||||
|
def get_mfr_id(self):
|
||||||
|
"""
|
||||||
|
Retrives the Manufacturer Id of PSU
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A string, the manunfacturer id.
|
||||||
|
"""
|
||||||
|
return self.fru.get_board_mfr_id()
|
||||||
|
|
||||||
|
def get_type(self):
|
||||||
|
"""
|
||||||
|
Retrives the Power Type of PSU
|
||||||
|
|
||||||
|
Returns :
|
||||||
|
A string, PSU power type
|
||||||
|
"""
|
||||||
|
board_product = self.fru.get_board_product()
|
||||||
|
if board_product is not None :
|
||||||
|
info = board_product.split(',')
|
||||||
|
if 'AC' in info : return 'AC'
|
||||||
|
if 'DC' in info : return 'DC'
|
||||||
|
return None
|
||||||
File diff suppressed because it is too large
Load Diff
@ -0,0 +1,174 @@
|
|||||||
|
#!/usr/bin/env python
|
||||||
|
|
||||||
|
########################################################################
|
||||||
|
# DellEMC S5248F
|
||||||
|
#
|
||||||
|
# Module contains an implementation of SONiC Platform Base API and
|
||||||
|
# provides the Thermals' information which are available in the platform
|
||||||
|
#
|
||||||
|
########################################################################
|
||||||
|
|
||||||
|
|
||||||
|
try:
|
||||||
|
from sonic_platform_base.thermal_base import ThermalBase
|
||||||
|
from sonic_platform.ipmihelper import IpmiSensor
|
||||||
|
except ImportError as e:
|
||||||
|
raise ImportError(str(e) + "- required module not found")
|
||||||
|
|
||||||
|
|
||||||
|
class Thermal(ThermalBase):
|
||||||
|
"""DellEMC Platform-specific Thermal class"""
|
||||||
|
|
||||||
|
# [ Sensor-Name, Sensor-ID ]
|
||||||
|
SENSOR_MAPPING = [
|
||||||
|
['CPU On-board', 0xe],
|
||||||
|
['ASIC On-board', 0x2],
|
||||||
|
['System Front Left', 0x3],
|
||||||
|
['System Front Middle', 0x1],
|
||||||
|
['System Front Right', 0x4],
|
||||||
|
['Inlet Airflow Sensor', 0x5],
|
||||||
|
['PSU1 Airflow Sensor', 0x7],
|
||||||
|
['PSU2 Airflow Sensor', 0x8]
|
||||||
|
]
|
||||||
|
|
||||||
|
def __init__(self, thermal_index):
|
||||||
|
ThermalBase.__init__(self)
|
||||||
|
self.index = thermal_index + 1
|
||||||
|
self.sensor = IpmiSensor(self.SENSOR_MAPPING[self.index - 1][1])
|
||||||
|
|
||||||
|
def get_name(self):
|
||||||
|
"""
|
||||||
|
Retrieves the name of the thermal
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
string: The name of the thermal
|
||||||
|
"""
|
||||||
|
return self.SENSOR_MAPPING[self.index - 1][0]
|
||||||
|
|
||||||
|
def get_presence(self):
|
||||||
|
"""
|
||||||
|
Retrieves the presence of the thermal
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
bool: True if thermal is present, False if not
|
||||||
|
"""
|
||||||
|
return True
|
||||||
|
|
||||||
|
def get_model(self):
|
||||||
|
"""
|
||||||
|
Retrieves the model number (or part number) of the Thermal
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
string: Model/part number of Thermal
|
||||||
|
"""
|
||||||
|
return 'NA'
|
||||||
|
|
||||||
|
def get_serial(self):
|
||||||
|
"""
|
||||||
|
Retrieves the serial number of the Thermal
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
string: Serial number of Thermal
|
||||||
|
"""
|
||||||
|
return 'NA'
|
||||||
|
|
||||||
|
def get_status(self):
|
||||||
|
"""
|
||||||
|
Retrieves the operational status of the thermal
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A boolean value, True if thermal is operating properly,
|
||||||
|
False if not
|
||||||
|
"""
|
||||||
|
return True
|
||||||
|
|
||||||
|
def get_temperature(self):
|
||||||
|
"""
|
||||||
|
Retrieves current temperature reading from thermal
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A float number of current temperature in Celsius up to
|
||||||
|
nearest thousandth of one degree Celsius, e.g. 30.125
|
||||||
|
"""
|
||||||
|
is_valid, temperature = self.sensor.get_reading()
|
||||||
|
if not is_valid:
|
||||||
|
temperature = 0
|
||||||
|
|
||||||
|
#return "{:.3f}".format(temperature)
|
||||||
|
return float(temperature)
|
||||||
|
|
||||||
|
def get_high_threshold(self):
|
||||||
|
"""
|
||||||
|
Retrieves the high threshold temperature of thermal
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A float number, the high threshold temperature of thermal in
|
||||||
|
Celsius up to nearest thousandth of one degree Celsius,
|
||||||
|
e.g. 30.125
|
||||||
|
"""
|
||||||
|
is_valid, high_threshold = self.sensor.get_threshold("UpperNonCritical")
|
||||||
|
if not is_valid:
|
||||||
|
return super(Thermal, self).get_high_threshold()
|
||||||
|
|
||||||
|
#return "{:.3f}".format(high_threshold)
|
||||||
|
return float(high_threshold)
|
||||||
|
|
||||||
|
def get_high_critical_threshold(self):
|
||||||
|
"""
|
||||||
|
Retrieves the high critical threshold temperature of thermal
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A float number, the high critical threshold temperature of thermal in
|
||||||
|
Celsius up to nearest thousandth of one degree Celsius,
|
||||||
|
e.g. 30.125
|
||||||
|
"""
|
||||||
|
is_valid, high_crit_threshold = self.sensor.get_threshold("UpperCritical")
|
||||||
|
if not is_valid:
|
||||||
|
return super(Thermal, self).get_high_critical_threshold()
|
||||||
|
|
||||||
|
#return "{:.3f}".format(high_crit_threshold)
|
||||||
|
return float(high_crit_threshold)
|
||||||
|
|
||||||
|
def get_low_threshold(self):
|
||||||
|
"""
|
||||||
|
Retrieves the low threshold temperature of thermal
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A float number, the low threshold temperature of thermal in
|
||||||
|
Celsius up to nearest thousandth of one degree Celsius,
|
||||||
|
e.g. 30.125
|
||||||
|
"""
|
||||||
|
is_valid, low_threshold = self.sensor.get_threshold("LowerNonRecoverable")
|
||||||
|
if not is_valid:
|
||||||
|
low_threshold = 0
|
||||||
|
|
||||||
|
#return "{:.3f}".format(low_threshold)
|
||||||
|
return float(low_threshold)
|
||||||
|
|
||||||
|
def set_high_threshold(self, temperature):
|
||||||
|
"""
|
||||||
|
Sets the high threshold temperature of thermal
|
||||||
|
|
||||||
|
Args :
|
||||||
|
temperature: A float number up to nearest thousandth of one
|
||||||
|
degree Celsius, e.g. 30.125
|
||||||
|
Returns:
|
||||||
|
A boolean, True if threshold is set successfully, False if
|
||||||
|
not
|
||||||
|
"""
|
||||||
|
# Thermal threshold values are pre-defined based on HW.
|
||||||
|
return False
|
||||||
|
|
||||||
|
def set_low_threshold(self, temperature):
|
||||||
|
"""
|
||||||
|
Sets the low threshold temperature of thermal
|
||||||
|
|
||||||
|
Args :
|
||||||
|
temperature: A float number up to nearest thousandth of one
|
||||||
|
degree Celsius, e.g. 30.125
|
||||||
|
Returns:
|
||||||
|
A boolean, True if threshold is set successfully, False if
|
||||||
|
not
|
||||||
|
"""
|
||||||
|
# Thermal threshold values are pre-defined based on HW.
|
||||||
|
return False
|
||||||
@ -0,0 +1,212 @@
|
|||||||
|
#!/usr/bin/env python
|
||||||
|
|
||||||
|
########################################################################
|
||||||
|
#
|
||||||
|
# DELLEMC S5248f
|
||||||
|
#
|
||||||
|
# Abstract base class for implementing a platform-specific class with
|
||||||
|
# which to interact with a hardware watchdog module in SONiC
|
||||||
|
#
|
||||||
|
########################################################################
|
||||||
|
|
||||||
|
try:
|
||||||
|
import ctypes
|
||||||
|
import subprocess
|
||||||
|
import syslog
|
||||||
|
import sonic_platform.component as Component
|
||||||
|
from sonic_platform_base.watchdog_base import WatchdogBase
|
||||||
|
except ImportError as e:
|
||||||
|
raise ImportError(str(e) + "- required module not found")
|
||||||
|
|
||||||
|
|
||||||
|
class _timespec(ctypes.Structure):
|
||||||
|
_fields_ = [
|
||||||
|
('tv_sec', ctypes.c_long),
|
||||||
|
('tv_nsec', ctypes.c_long)
|
||||||
|
]
|
||||||
|
|
||||||
|
|
||||||
|
class Watchdog(WatchdogBase):
|
||||||
|
"""
|
||||||
|
Abstract base class for interfacing with a hardware watchdog module
|
||||||
|
"""
|
||||||
|
|
||||||
|
TIMERS = [15,20,30,40,50,60,65,70,80,100,120,140,160,180,210,240]
|
||||||
|
|
||||||
|
armed_time = 0
|
||||||
|
timeout = 0
|
||||||
|
CLOCK_MONOTONIC = 1
|
||||||
|
|
||||||
|
def __init__(self):
|
||||||
|
self._librt = ctypes.CDLL('librt.so.1', use_errno=True)
|
||||||
|
self._clock_gettime = self._librt.clock_gettime
|
||||||
|
self._clock_gettime.argtypes=[ctypes.c_int, ctypes.POINTER(_timespec)]
|
||||||
|
|
||||||
|
def _get_command_result(self, cmdline):
|
||||||
|
try:
|
||||||
|
proc = subprocess.Popen(cmdline.split(), stdout=subprocess.PIPE,
|
||||||
|
stderr=subprocess.STDOUT)
|
||||||
|
stdout = proc.communicate()[0]
|
||||||
|
proc.wait()
|
||||||
|
result = stdout.rstrip('\n'.encode())
|
||||||
|
except OSError:
|
||||||
|
result = None
|
||||||
|
|
||||||
|
return result
|
||||||
|
|
||||||
|
def _get_reg_val(self):
|
||||||
|
# 0x31 = CPLD I2C Base Address
|
||||||
|
# 0x07 = Watchdog Function Register
|
||||||
|
value = self._get_command_result("/usr/sbin/i2cget -y 601 0x31 0x07")
|
||||||
|
if not value:
|
||||||
|
return None
|
||||||
|
else:
|
||||||
|
return int(value, 16)
|
||||||
|
|
||||||
|
def _set_reg_val(self,val):
|
||||||
|
# 0x31 = CPLD I2C Base Address
|
||||||
|
# 0x07 = Watchdog Function Register
|
||||||
|
value = self._get_command_result("/usr/sbin/i2cset -y 601 0x31 0x07 %s"
|
||||||
|
% (val))
|
||||||
|
return value
|
||||||
|
|
||||||
|
def _get_time(self):
|
||||||
|
"""
|
||||||
|
To get clock monotonic time
|
||||||
|
"""
|
||||||
|
ts = _timespec()
|
||||||
|
if self._clock_gettime(self.CLOCK_MONOTONIC, ctypes.pointer(ts)) != 0:
|
||||||
|
self._errno = ctypes.get_errno()
|
||||||
|
return 0
|
||||||
|
return ts.tv_sec + ts.tv_nsec * 1e-9
|
||||||
|
|
||||||
|
def arm(self, seconds):
|
||||||
|
"""
|
||||||
|
Arm the hardware watchdog with a timeout of <seconds> seconds.
|
||||||
|
If the watchdog is currently armed, calling this function will
|
||||||
|
simply reset the timer to the provided value. If the underlying
|
||||||
|
hardware does not support the value provided in <seconds>, this
|
||||||
|
method should arm the watchdog with the *next greater*
|
||||||
|
available value.
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
An integer specifying the *actual* number of seconds the
|
||||||
|
watchdog was armed with. On failure returns -1.
|
||||||
|
"""
|
||||||
|
timer_offset = -1
|
||||||
|
for key,timer_seconds in enumerate(self.TIMERS):
|
||||||
|
if seconds <= timer_seconds:
|
||||||
|
timer_offset = key
|
||||||
|
seconds = timer_seconds
|
||||||
|
break
|
||||||
|
|
||||||
|
if timer_offset == -1:
|
||||||
|
return -1
|
||||||
|
|
||||||
|
cpld_version = Component.get_cpld0_version()
|
||||||
|
wd_enabled_version = "0.8"
|
||||||
|
|
||||||
|
if cpld_version < wd_enabled_version:
|
||||||
|
syslog.syslog(syslog.LOG_ERR,
|
||||||
|
'Older System CPLD ver, Update to 0.8 to support watchdog ')
|
||||||
|
return -1
|
||||||
|
|
||||||
|
# Extracting 5th to 8th bits for WD timer values
|
||||||
|
reg_val = self._get_reg_val()
|
||||||
|
wd_timer_offset = (reg_val >> 4) & 0xf
|
||||||
|
|
||||||
|
if wd_timer_offset != timer_offset:
|
||||||
|
# Setting 5th to 7th bits
|
||||||
|
# value from timer_offset
|
||||||
|
self.disarm()
|
||||||
|
self._set_reg_val((reg_val & 0x07) | (timer_offset << 4))
|
||||||
|
|
||||||
|
if self.is_armed():
|
||||||
|
# Setting last bit to WD Timer punch
|
||||||
|
# Last bit = WD Timer punch
|
||||||
|
self._set_reg_val(reg_val & 0xFE)
|
||||||
|
|
||||||
|
self.armed_time = self._get_time()
|
||||||
|
self.timeout = seconds
|
||||||
|
return seconds
|
||||||
|
else:
|
||||||
|
# Setting 4th bit to enable WD
|
||||||
|
# 4th bit = Enable WD
|
||||||
|
reg_val = self._get_reg_val()
|
||||||
|
self._set_reg_val(reg_val | 0x8)
|
||||||
|
|
||||||
|
self.armed_time = self._get_time()
|
||||||
|
self.timeout = seconds
|
||||||
|
return seconds
|
||||||
|
|
||||||
|
def disarm(self):
|
||||||
|
"""
|
||||||
|
Disarm the hardware watchdog
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A boolean, True if watchdog is disarmed successfully, False
|
||||||
|
if not
|
||||||
|
"""
|
||||||
|
if self.is_armed():
|
||||||
|
# Setting 4th bit to disable WD
|
||||||
|
# 4th bit = Disable WD
|
||||||
|
reg_val = self._get_reg_val()
|
||||||
|
self._set_reg_val(reg_val & 0xF7)
|
||||||
|
|
||||||
|
self.armed_time = 0
|
||||||
|
self.timeout = 0
|
||||||
|
return True
|
||||||
|
|
||||||
|
return False
|
||||||
|
|
||||||
|
def is_armed(self):
|
||||||
|
"""
|
||||||
|
Retrieves the armed state of the hardware watchdog.
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
A boolean, True if watchdog is armed, False if not
|
||||||
|
"""
|
||||||
|
|
||||||
|
# Extracting 4th bit to get WD Enable/Disable status
|
||||||
|
# 0 - Disabled WD
|
||||||
|
# 1 - Enabled WD
|
||||||
|
reg_val = self._get_reg_val()
|
||||||
|
wd_offset = (reg_val >> 3) & 1
|
||||||
|
|
||||||
|
return bool(wd_offset)
|
||||||
|
|
||||||
|
def get_remaining_time(self):
|
||||||
|
"""
|
||||||
|
If the watchdog is armed, retrieve the number of seconds
|
||||||
|
remaining on the watchdog timer
|
||||||
|
|
||||||
|
Returns:
|
||||||
|
An integer specifying the number of seconds remaining on
|
||||||
|
their watchdog timer. If the watchdog is not armed, returns
|
||||||
|
-1.
|
||||||
|
|
||||||
|
S5248f doesnot have hardware support to show remaining time.
|
||||||
|
Due to this limitation, this API is implemented in software.
|
||||||
|
This API would return correct software time difference if it
|
||||||
|
is called from the process which armed the watchdog timer.
|
||||||
|
If this API called from any other process, it would return
|
||||||
|
0. If the watchdog is not armed, this API would return -1.
|
||||||
|
"""
|
||||||
|
if not self.is_armed():
|
||||||
|
return -1
|
||||||
|
|
||||||
|
if self.armed_time > 0 and self.timeout != 0:
|
||||||
|
cur_time = self._get_time()
|
||||||
|
|
||||||
|
if cur_time <= 0:
|
||||||
|
return 0
|
||||||
|
|
||||||
|
diff_time = int(cur_time - self.armed_time)
|
||||||
|
|
||||||
|
if diff_time > self.timeout:
|
||||||
|
return self.timeout
|
||||||
|
else:
|
||||||
|
return self.timeout - diff_time
|
||||||
|
|
||||||
|
return 0
|
||||||
|
|
||||||
Reference in New Issue
Block a user