239 lines
7.4 KiB
Python
239 lines
7.4 KiB
Python
|
#!/usr/bin/env python
|
||
|
|
|
||
|
|
try:
|
||
|
|
import os
|
||
|
|
import re
|
||
|
|
import time
|
||
|
|
from sonic_sfp.sfputilbase import SfpUtilBase
|
||
|
|
except ImportError, e:
|
||
|
|
raise ImportError (str(e) + "- required module not found")
|
||
|
|
|
||
|
|
|
||
|
|
class SfpUtil(SfpUtilBase):
|
||
|
|
"""Platform specific sfputil class"""
|
||
|
|
|
||
|
|
port_start = 0
|
||
|
|
port_end = 53
|
||
|
|
ports_in_block = 54
|
||
|
|
cplda_sfp_num = 24
|
||
|
|
cpldb_sfp_num = 12
|
||
|
|
cpldc_sfp_num = 18
|
||
|
|
|
||
|
|
port_to_eeprom_mapping = {}
|
||
|
|
port_to_i2c_mapping = {}
|
||
|
|
sfp_ports = range(0, ports_in_block)
|
||
|
|
qsfp_ports = range(ports_in_block - 6, ports_in_block)
|
||
|
|
|
||
|
|
|
||
|
|
def __init__(self):
|
||
|
|
for x in range(self.port_start, self.port_end + 1):
|
||
|
|
if x < self.cpldb_sfp_num:
|
||
|
|
self.port_to_i2c_mapping.update({x:7})
|
||
|
|
elif x < self.cplda_sfp_num + self.cpldb_sfp_num:
|
||
|
|
self.port_to_i2c_mapping.update({x:6})
|
||
|
|
else:
|
||
|
|
self.port_to_i2c_mapping.update({x:8})
|
||
|
|
|
||
|
|
for x in range(self.port_start, self.port_end+1):
|
||
|
|
eeprom_path = '/sys/bus/i2c/devices/{0}-0050/sfp'+str(x+1)+'_eeprom'
|
||
|
|
port_eeprom_path = eeprom_path.format(self.port_to_i2c_mapping[x])
|
||
|
|
self.port_to_eeprom_mapping[x] = port_eeprom_path
|
||
|
|
SfpUtilBase.__init__(self)
|
||
|
|
|
||
|
|
|
||
|
|
def get_presence(self, port_num):
|
||
|
|
if port_num < self.port_start or port_num > self.port_end:
|
||
|
|
return False
|
||
|
|
|
||
|
|
if port_num < self.cpldb_sfp_num:
|
||
|
|
presence_path = '/sys/bus/i2c/devices/7-0075/sfp'+str(port_num+1)+'_present'
|
||
|
|
elif port_num < self.cpldb_sfp_num + self.cplda_sfp_num:
|
||
|
|
presence_path = '/sys/bus/i2c/devices/6-0074/sfp'+str(port_num+1)+'_present'
|
||
|
|
else:
|
||
|
|
presence_path = '/sys/bus/i2c/devices/8-0076/sfp'+str(port_num+1)+'_present'
|
||
|
|
|
||
|
|
try:
|
||
|
|
file = open(presence_path)
|
||
|
|
except IOError as e:
|
||
|
|
print "Error: unable to open file: %s" % str(e)
|
||
|
|
return False
|
||
|
|
|
||
|
|
value = int(file.readline().rstrip())
|
||
|
|
|
||
|
|
file.close()
|
||
|
|
if value == 0:
|
||
|
|
return True
|
||
|
|
|
||
|
|
return False
|
||
|
|
|
||
|
|
def get_low_power_mode(self, port_num):
|
||
|
|
if port_num not in self.qsfp_ports:
|
||
|
|
return False
|
||
|
|
|
||
|
|
lowpower_path = '/sys/bus/i2c/devices/8-0076/sfp'+str(port_num+1)+'_lowpower'
|
||
|
|
|
||
|
|
try:
|
||
|
|
file = open(lowpower_path)
|
||
|
|
except IOError as e:
|
||
|
|
print "Error: unable to open file: %s" % str(e)
|
||
|
|
return False
|
||
|
|
|
||
|
|
value = int(file.readline().rstrip())
|
||
|
|
|
||
|
|
file.close()
|
||
|
|
if value == 1:
|
||
|
|
return True
|
||
|
|
|
||
|
|
return False
|
||
|
|
|
||
|
|
def set_low_power_mode(self, port_num, lpmode):
|
||
|
|
if port_num not in self.qsfp_ports:
|
||
|
|
return False
|
||
|
|
|
||
|
|
lowpower_path = '/sys/bus/i2c/devices/8-0076/sfp'+str(port_num+1)+'_lowpower'
|
||
|
|
|
||
|
|
# LPMode is active high; set or clear the bit accordingly
|
||
|
|
if lpmode is True:
|
||
|
|
value = 1
|
||
|
|
else:
|
||
|
|
value = 0
|
||
|
|
|
||
|
|
try:
|
||
|
|
file = open(lowpower_path, "r+")
|
||
|
|
except IOError as e:
|
||
|
|
print "Error: unable to open file: %s" % str(e)
|
||
|
|
return False
|
||
|
|
|
||
|
|
file.seek(0)
|
||
|
|
file.write(str(value))
|
||
|
|
file.close()
|
||
|
|
|
||
|
|
return True
|
||
|
|
|
||
|
|
def reset(self, port_num):
|
||
|
|
if port_num not in self.qsfp_ports:
|
||
|
|
return False
|
||
|
|
reset_path = '/sys/bus/i2c/devices/8-0076/sfp'+str(port_num+1)+'_reset'
|
||
|
|
|
||
|
|
try:
|
||
|
|
file = open(reset_path, "r+")
|
||
|
|
except IOError as e:
|
||
|
|
print "Error: unable to open file: %s" % str(e)
|
||
|
|
return False
|
||
|
|
|
||
|
|
file.seek(0)
|
||
|
|
file.write(str(2))
|
||
|
|
file.close()
|
||
|
|
|
||
|
|
# Sleep 1 second to allow it to settle
|
||
|
|
time.sleep(1)
|
||
|
|
|
||
|
|
try:
|
||
|
|
file = open(reset_path, "r+")
|
||
|
|
except IOError as e:
|
||
|
|
print "Error: unable to open file: %s" % str(e)
|
||
|
|
return False
|
||
|
|
|
||
|
|
file.seek(0)
|
||
|
|
file.write(str(1))
|
||
|
|
file.close()
|
||
|
|
|
||
|
|
return True
|
||
|
|
|
||
|
|
def read_porttab_mappings(self, porttabfile):
|
||
|
|
logical = []
|
||
|
|
logical_to_bcm = {}
|
||
|
|
logical_to_physical = {}
|
||
|
|
physical_to_logical = {}
|
||
|
|
last_fp_port_index = 0
|
||
|
|
last_portname = ""
|
||
|
|
first = 1
|
||
|
|
port_pos_in_file = 0
|
||
|
|
parse_fmt_port_config_ini = False
|
||
|
|
|
||
|
|
try:
|
||
|
|
f = open(porttabfile)
|
||
|
|
except:
|
||
|
|
raise
|
||
|
|
|
||
|
|
parse_fmt_port_config_ini = (os.path.basename(porttabfile) == "port_config.ini")
|
||
|
|
|
||
|
|
# Read the porttab file and generate dicts
|
||
|
|
# with mapping for future reference.
|
||
|
|
# XXX: move the porttab
|
||
|
|
# parsing stuff to a separate module, or reuse
|
||
|
|
# if something already exists
|
||
|
|
for line in f:
|
||
|
|
line.strip()
|
||
|
|
if re.search("^#", line) is not None:
|
||
|
|
continue
|
||
|
|
|
||
|
|
# Parsing logic for 'port_config.ini' file
|
||
|
|
if (parse_fmt_port_config_ini):
|
||
|
|
# bcm_port is not explicitly listed in port_config.ini format
|
||
|
|
# Currently we assume ports are listed in numerical order according to bcm_port
|
||
|
|
# so we use the port's position in the file (zero-based) as bcm_port
|
||
|
|
portname = line.split()[0]
|
||
|
|
|
||
|
|
bcm_port = str(port_pos_in_file)
|
||
|
|
|
||
|
|
if len(line.split()) >= 4:
|
||
|
|
fp_port_index = int(line.split()[3])
|
||
|
|
else:
|
||
|
|
fp_port_index = portname.split("Ethernet").pop()
|
||
|
|
fp_port_index = int(fp_port_index.split("s").pop(0))/4
|
||
|
|
else: # Parsing logic for older 'portmap.ini' file
|
||
|
|
(portname, bcm_port) = line.split("=")[1].split(",")[:2]
|
||
|
|
|
||
|
|
fp_port_index = portname.split("Ethernet").pop()
|
||
|
|
fp_port_index = int(fp_port_index.split("s").pop(0))/4
|
||
|
|
|
||
|
|
if ((len(self.sfp_ports) > 0) and (fp_port_index not in self.sfp_ports)):
|
||
|
|
continue
|
||
|
|
|
||
|
|
if first == 1:
|
||
|
|
# Initialize last_[physical|logical]_port
|
||
|
|
# to the first valid port
|
||
|
|
last_fp_port_index = fp_port_index
|
||
|
|
last_portname = portname
|
||
|
|
first = 0
|
||
|
|
|
||
|
|
logical.append(portname)
|
||
|
|
|
||
|
|
logical_to_bcm[portname] = "xe" + bcm_port
|
||
|
|
logical_to_physical[portname] = [fp_port_index]
|
||
|
|
if physical_to_logical.get(fp_port_index) is None:
|
||
|
|
physical_to_logical[fp_port_index] = [portname]
|
||
|
|
else:
|
||
|
|
physical_to_logical[fp_port_index].append(
|
||
|
|
portname)
|
||
|
|
|
||
|
|
if (fp_port_index - last_fp_port_index) > 1:
|
||
|
|
# last port was a gang port
|
||
|
|
for p in range(last_fp_port_index+1, fp_port_index):
|
||
|
|
logical_to_physical[last_portname].append(p)
|
||
|
|
if physical_to_logical.get(p) is None:
|
||
|
|
physical_to_logical[p] = [last_portname]
|
||
|
|
else:
|
||
|
|
physical_to_logical[p].append(last_portname)
|
||
|
|
|
||
|
|
last_fp_port_index = fp_port_index
|
||
|
|
last_portname = portname
|
||
|
|
|
||
|
|
port_pos_in_file += 1
|
||
|
|
|
||
|
|
self.logical = logical
|
||
|
|
self.logical_to_bcm = logical_to_bcm
|
||
|
|
self.logical_to_physical = logical_to_physical
|
||
|
|
self.physical_to_logical = physical_to_logical
|
||
|
|
|
||
|
|
"""
|
||
|
|
print "logical: " + self.logical
|
||
|
|
print "logical to bcm: " + self.logical_to_bcm
|
||
|
|
print "logical to physical: " + self.logical_to_physical
|
||
|
|
print "physical to logical: " + self.physical_to_logical
|
||
|
|
"""
|
||
|
|
|
||
|
|
|
||
|
|
|