sonic-buildimage/device/barefoot/x86_64-accton_wedge100bf_32x-r0/plugins/sfputil.py

try:
    import os
    import sys
    import importlib
    import time

    sys.path.append(os.path.dirname(__file__))
    import pltfm_mgr_rpc
    from pltfm_mgr_rpc.ttypes import *

    from thrift.transport import TSocket
    from thrift.transport import TTransport
    from thrift.protocol import TBinaryProtocol
    from thrift.protocol import TMultiplexedProtocol

    from sonic_sfp.sfputilbase import SfpUtilBase
except ImportError as e:
    raise ImportError(str(e) + "- required module not found")

thrift_server = 'localhost'
transport = None
pltfm_mgr = None

SFP_EEPROM_CACHE = "/var/run/platform/sfp/cache"


class SfpUtil(SfpUtilBase):
    """Platform-specific SfpUtil class"""

    PORT_START = 1
    PORT_END = 0
    PORTS_IN_BLOCK = 0
    QSFP_PORT_START = 1
    QSFP_PORT_END = 0
    EEPROM_OFFSET = 0
    QSFP_CHECK_INTERVAL = 4
    THRIFT_RETRIES = 5
    THRIFT_TIMEOUT = 5

    @property
    def port_start(self):
        self.update_port_info()
        return self.PORT_START

    @property
    def port_end(self):
        self.update_port_info()
        return self.PORT_END

    @property
    def qsfp_ports(self):
        self.update_port_info()
        return list(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 __init__(self):
        self.ready = False
        self.phy_port_dict = {'-1': 'system_not_ready'}
        self.phy_port_cur_state = {}
        self.qsfp_interval = self.QSFP_CHECK_INTERVAL

        if not os.path.exists(os.path.dirname(SFP_EEPROM_CACHE)):
            try:
                os.makedirs(os.path.dirname(SFP_EEPROM_CACHE))
            except OSError as e:
                if e.errno != errno.EEXIST:
                    raise

        open(SFP_EEPROM_CACHE, 'ab').close()

        SfpUtilBase.__init__(self)

    def update_port_info(self):
        global pltfm_mgr

        if self.QSFP_PORT_END == 0:
            self.thrift_setup()
            self.QSFP_PORT_END = pltfm_mgr.pltfm_mgr_qsfp_get_max_port()
            self.PORT_END = self.QSFP_PORT_END
            self.PORTS_IN_BLOCK = self.QSFP_PORT_END
            self.thrift_teardown()

    def thrift_setup(self):
        global thrift_server, transport, pltfm_mgr
        transport = TSocket.TSocket(thrift_server, 9090)

        transport = TTransport.TBufferedTransport(transport)
        bprotocol = TBinaryProtocol.TBinaryProtocol(transport)

        pltfm_mgr_client_module = importlib.import_module(".".join(["pltfm_mgr_rpc", "pltfm_mgr_rpc"]))
        pltfm_mgr_protocol = TMultiplexedProtocol.TMultiplexedProtocol(bprotocol, "pltfm_mgr_rpc")
        pltfm_mgr = pltfm_mgr_client_module.Client(pltfm_mgr_protocol)

        for i in range(self.THRIFT_RETRIES):
            try:
                transport.open()
                if i:
                    # The main thrift server is starded without platform api
                    # Platform api is added later during syncd initialization
                    # So we need to wait a little bit before do any platform api call
                    # Just in case when can't connect from the first try (warm-reboot case)
                    time.sleep(self.THRIFT_TIMEOUT)
                break
            except TTransport.TTransportException as e:
                if e.type != TTransport.TTransportException.NOT_OPEN or i >= self.THRIFT_RETRIES - 1:
                    raise e
                time.sleep(self.THRIFT_TIMEOUT)

    def thrift_teardown(self):
        global transport
        transport.close()

    def get_presence(self, port_num):
        # Check for invalid port_num
        if port_num < self.port_start or port_num > self.port_end:
            return False

        presence = False

        try:
            self.thrift_setup()
            presence = pltfm_mgr.pltfm_mgr_qsfp_presence_get(port_num)
            self.thrift_teardown()
        except Exception as e:
            print(e.__doc__)
            print(e.message)

        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

        self.thrift_setup()
        lpmode = pltfm_mgr.pltfm_mgr_qsfp_lpmode_get(port_num)
        self.thrift_teardown()
        return lpmode

    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

        self.thrift_setup()
        status = pltfm_mgr.pltfm_mgr_qsfp_lpmode_set(port_num, lpmode)
        self.thrift_teardown()
        return (status == 0)

    def reset(self, port_num):
        # Check for invalid port_num
        if port_num < self.port_start or port_num > self.port_end:
            return False

        self.thrift_setup()
        status = pltfm_mgr.pltfm_mgr_qsfp_reset(port_num, True)
        status = pltfm_mgr.pltfm_mgr_qsfp_reset(port_num, False)
        self.thrift_teardown()
        return (status == 0)

    def check_transceiver_change(self):
        if not self.ready:
            return

        self.phy_port_dict = {}

        try:
            self.thrift_setup()
        except:
            return

        # Get presence of each SFP
        for port in range(self.port_start, self.port_end + 1):
            try:
                sfp_resent = pltfm_mgr.pltfm_mgr_qsfp_presence_get(port)
            except:
                sfp_resent = False
            sfp_state = '1' if sfp_resent else '0'

            if port in self.phy_port_cur_state:
                if self.phy_port_cur_state[port] != sfp_state:
                    self.phy_port_dict[port] = sfp_state
            else:
                self.phy_port_dict[port] = sfp_state

            # Update port current state
            self.phy_port_cur_state[port] = sfp_state

        self.thrift_teardown()

    def get_transceiver_change_event(self, timeout=0):
        forever = False
        if timeout == 0:
            forever = True
        elif timeout > 0:
            timeout = timeout / float(1000)  # Convert to secs
        else:
            print("get_transceiver_change_event:Invalid timeout value", timeout)
            return False, {}

        while forever or timeout > 0:
            if not self.ready:
                try:
                    self.thrift_setup()
                    self.thrift_teardown()
                except:
                    pass
                else:
                    self.ready = True
                    self.phy_port_dict = {}
                    break
            elif self.qsfp_interval == 0:
                self.qsfp_interval = self.QSFP_CHECK_INTERVAL

                # Process transceiver plug-in/out event
                self.check_transceiver_change()

                # Break if tranceiver state has changed
                if bool(self.phy_port_dict):
                    break

            if timeout:
                timeout -= 1

            if self.qsfp_interval:
                self.qsfp_interval -= 1

            time.sleep(1)

        return self.ready, self.phy_port_dict

    def _get_port_eeprom_path(self, port_num, devid):
        eeprom_path = None

        self.thrift_setup()
        presence = pltfm_mgr.pltfm_mgr_qsfp_presence_get(port_num)
        if presence == True:
            eeprom_cache = open(SFP_EEPROM_CACHE, 'wb')
            eeprom_hex = pltfm_mgr.pltfm_mgr_qsfp_info_get(port_num)
            eeprom_raw = bytearray.fromhex(eeprom_hex)
            eeprom_cache.write(eeprom_raw)
            eeprom_cache.close()
            eeprom_path = SFP_EEPROM_CACHE
        self.thrift_teardown()

        return eeprom_path