Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[device/celestica]: Add support for xcvrd daemon in silverstone #91

Open
wants to merge 13 commits into
base: 201811-TH3
Choose a base branch
from
Open

[device/celestica]: Add support for xcvrd daemon in silverstone #91

Changes from all commits
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
f98ba0e
[platform/cel-silverstone]: Add sysfs for XCVR interrupt event status
Oct 28, 2020
e9f3fb1
[device/celestica]: implement get_transceiver_change_event in sfutil …
Oct 28, 2020
3d1b648
[device/silverstone]: add cmis init script
Oct 29, 2020
8400496
[device/celestica-silverstone]: update perssion for cmis-init script
Oct 30, 2020
1c4e42f
[device/celestica-silverstone]: clean cmis init code
Oct 30, 2020
3e5c896
[device/celestica-silverstone]: clean sfputil code
Oct 30, 2020
1f49835
[device/celestica]: update retry condition for cmis init
Nov 17, 2020
4f8dbca
[device/celestica]: add error detection to cmis init script
Nov 17, 2020
3614955
[device/celestica]: update script to avoid error
Nov 19, 2020
504e2a1
update code follow an update from brcm
Jan 12, 2021
0226ded
clean sfputil
Jan 12, 2021
d6d0e5c
remove unused files
Jan 12, 2021
5241e6a
remove unused files2
Jan 12, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
112 changes: 75 additions & 37 deletions device/celestica/x86_64-cel_silverstone-r0/plugins/sfputil.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@

SYSLOG_IDENTIFIER = "sfputil.py"


def log_info(msg, also_print_to_console=False):
syslog.openlog(SYSLOG_IDENTIFIER)
syslog.syslog(syslog.LOG_INFO, msg)
Expand All @@ -41,6 +42,7 @@ def log_info(msg, also_print_to_console=False):
if also_print_to_console:
print msg


class QSFPDDDomPaser(qsfp_dd_Dom):

def __init__(self, eeprom_raw_data):
Expand Down Expand Up @@ -199,6 +201,7 @@ def __init__(self, eeprom_raw_data):
def get_data_pretty(self):
return sffbase.get_data_pretty(self, self.dom_data)


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

Expand Down Expand Up @@ -396,7 +399,7 @@ def reset(self, port_num):

return True

def _page_to_flat(self, addr, page = -1):
def _page_to_flat(self, addr, page=-1):
flat = 0
if addr < 128:
flat = addr
Expand All @@ -412,7 +415,8 @@ def _write_byte(self, port_num, devid, page, off, val):
f.seek(addr)
f.write(chr(val))
except Exception as ex:
log_info("PORT {0}: pg={1}, ofs={2}: write failed: {3}".format(port_num, page, off, ex))
log_info("PORT {0}: pg={1}, ofs={2}: write failed: {3}".format(
port_num, page, off, ex))
finally:
f.close()

Expand All @@ -428,7 +432,8 @@ def _get_application_advertisements(self, eeprom_ifraw=None, offset=85):
app = 1
hid = int(eeprom_ifraw[1 + offset], 16)
while (app <= 8) and (hid != 0) and (hid != 0xff):
(ht, mt) = self.parse_application(tbl, eeprom_ifraw[1 + offset], eeprom_ifraw[2 + offset])
(ht, mt) = self.parse_application(
tbl, eeprom_ifraw[1 + offset], eeprom_ifraw[2 + offset])
adv[app] = "{0} | {1}".format(ht, mt)
app += 1
offset += 4
Expand All @@ -437,7 +442,8 @@ def _get_application_advertisements(self, eeprom_ifraw=None, offset=85):
return adv

def _get_application_code(self, port_num, host_intf):
buf = self._read_eeprom_devid(port_num, self.IDENTITY_EEPROM_ADDR, 85, 36)
buf = self._read_eeprom_devid(
port_num, self.IDENTITY_EEPROM_ADDR, 85, 36)
if buf is None:
return 1

Expand All @@ -447,7 +453,8 @@ def _get_application_code(self, port_num, host_intf):
h = dict[k].split('|')[0].strip()
if h in host_intf:
app = k
log_info("PORT {0}: selecting {1}#{2}".format(port_num, app, h))
log_info("PORT {0}: selecting {1}#{2}".format(
port_num, app, h))
break
return app

Expand All @@ -466,25 +473,42 @@ def _init_cmis4_module(self, port_num, xcvr, hwsku):
# Application selection
app = 1
if '128x100' in hwsku:
app = self._get_application_code(port_num, '100GAUI-2 C2M (Annex 135G),100GBASE-CR2 (Clause 136)')
app = self._get_application_code(
port_num, '100GAUI-2 C2M (Annex 135G),100GBASE-CR2 (Clause 136)')
if app != 1:
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 145, (app << 4) | 0x01)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 146, (app << 4) | 0x01)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 147, (app << 4) | 0x05)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 148, (app << 4) | 0x05)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 149, (app << 4) | 0x09)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 150, (app << 4) | 0x09)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 151, (app << 4) | 0x0d)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 152, (app << 4) | 0x0d)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR,
0x10, 145, (app << 4) | 0x01)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR,
0x10, 146, (app << 4) | 0x01)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR,
0x10, 147, (app << 4) | 0x05)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR,
0x10, 148, (app << 4) | 0x05)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR,
0x10, 149, (app << 4) | 0x09)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR,
0x10, 150, (app << 4) | 0x09)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR,
0x10, 151, (app << 4) | 0x0d)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR,
0x10, 152, (app << 4) | 0x0d)
else:
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 145, 0x11)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 146, 0x11)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 147, 0x11)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 148, 0x11)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 149, 0x11)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 150, 0x11)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 151, 0x11)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 152, 0x11)
self._write_byte(
port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 145, 0x11)
self._write_byte(
port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 146, 0x11)
self._write_byte(
port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 147, 0x11)
self._write_byte(
port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 148, 0x11)
self._write_byte(
port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 149, 0x11)
self._write_byte(
port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 150, 0x11)
self._write_byte(
port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 151, 0x11)
self._write_byte(
port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 152, 0x11)
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 143, 0xff)
# Initialize datapath
self._write_byte(port_num, self.IDENTITY_EEPROM_ADDR, 0x10, 128, 0x00)
Expand All @@ -493,10 +517,12 @@ def _init_cmis4_module(self, port_num, xcvr, hwsku):
err = '00000000'
for t in range(10):
time.sleep(1)
buf = self._read_eeprom_devid(port_num, self.IDENTITY_EEPROM_ADDR, self._page_to_flat(202, 0x11), 4)
buf = self._read_eeprom_devid(
port_num, self.IDENTITY_EEPROM_ADDR, self._page_to_flat(202, 0x11), 4)
err = "".join(buf)
if err == '11111111':
log_info("PORT {0}: it took {1} secs for config ready".format(port_num, t + 1))
log_info("PORT {0}: it took {1} secs for config ready".format(
port_num, t + 1))
break
if err != '11111111':
log_info("PORT {0}: ConfigErr={1}".format(port_num, err))
Expand All @@ -505,7 +531,8 @@ def _init_cmis4_module(self, port_num, xcvr, hwsku):
return True

def _init_cmis_module(self, port_num):
buf = self._read_eeprom_devid(port_num, self.IDENTITY_EEPROM_ADDR, 0x80, 48)
buf = self._read_eeprom_devid(
port_num, self.IDENTITY_EEPROM_ADDR, 0x80, 48)
if buf is None:
log_info("PORT {0}: unable to read PAGE0".format(port_num))
return False
Expand All @@ -516,13 +543,16 @@ def _init_cmis_module(self, port_num):
return True

# Decode the transceiver ids
name = self.inf8628.parse_vendor_name(buf, 1)['data']['Vendor Name']['value']
part = self.inf8628.parse_vendor_pn(buf, 20)['data']['Vendor PN']['value']
name = self.inf8628.parse_vendor_name(
buf, 1)['data']['Vendor Name']['value']
part = self.inf8628.parse_vendor_pn(
buf, 20)['data']['Vendor PN']['value']
#log_info("_init_cmis_module: p={0}, id='{1}', name='{2}', part='{3}'".format(port_num, buf[0], name, part))
xcvr = name.upper() + " " + part.upper()

# Dispatch as per the CMIS revision id
buf = self._read_eeprom_devid(port_num, self.IDENTITY_EEPROM_ADDR, 0x0, 4)
buf = self._read_eeprom_devid(
port_num, self.IDENTITY_EEPROM_ADDR, 0x0, 4)
rev = 0x30
if buf is not None:
rev = int(buf[1], 16)
Expand Down Expand Up @@ -562,7 +592,8 @@ def get_transceiver_change_event(self, timeout=0):
continue

# monitor the QSFP-DD module state, and initiate software reset when failure count > 5
buf = self._read_eeprom_devid(x, self.IDENTITY_EEPROM_ADDR, 0x0, 4)
buf = self._read_eeprom_devid(
x, self.IDENTITY_EEPROM_ADDR, 0x0, 4)
if buf is None:
log_info("PORT {0}: unable to get module state".format(x))
continue
Expand All @@ -579,9 +610,11 @@ def get_transceiver_change_event(self, timeout=0):
# advance the failure counter if state == ModuleLowPwr and CMIS < v4.0
if (cmis < 0x40) and (((int(buf[3], 16) >> 1) & 0x7) == 1):
# fetch the module media type
buf = self._read_eeprom_devid(x, self.IDENTITY_EEPROM_ADDR, 85, 1)
buf = self._read_eeprom_devid(
x, self.IDENTITY_EEPROM_ADDR, 85, 1)
if buf is None:
log_info("PORT {0}: unable to get module media type".format(x))
log_info(
"PORT {0}: unable to get module media type".format(x))
# perform a software reset only if it's not a DAC (Passive Copper)
elif int(buf[0], 16) != 0x03:
self.mod_failure[x] += 1
Expand All @@ -594,19 +627,22 @@ def get_transceiver_change_event(self, timeout=0):
# its module state could get stuck at ModuleLowPwr upon reinsertion, and a software
# reset is necessary to get it recovered.
log_info("PORT {0}: issuing a software reset".format(x))
self._write_byte(x, self.IDENTITY_EEPROM_ADDR, -1, 26, 0x08)
self._write_byte(
x, self.IDENTITY_EEPROM_ADDR, -1, 26, 0x08)
time.sleep(1)

# monitor the QSFP-DD initialization state, and reinitiate it if necessary
if self.mod_inited[x]:
continue
buf = self._read_eeprom_devid(x, self.IDENTITY_EEPROM_ADDR, self._page_to_flat(202, 0x11), 4)
buf = self._read_eeprom_devid(
x, self.IDENTITY_EEPROM_ADDR, self._page_to_flat(202, 0x11), 4)
if buf is None:
continue
err = "".join(buf)
if err != '11111111':
if not self._init_cmis_module(x):
log_info("PORT {0}: Unable to initialize the module".format(x))
log_info(
"PORT {0}: Unable to initialize the module".format(x))
else:
self.mod_inited[x] = True

Expand Down Expand Up @@ -640,7 +676,7 @@ def parse_media_type(self, eeprom_data, offset):
elif dict_name == "base_t_media_interface":
return base_t_media_interface
else:
return None
return None

def parse_application(self, sfp_media_type_dict, host_interface, media_interface):
host_result = host_electrical_interface[host_interface]
Expand Down Expand Up @@ -680,12 +716,14 @@ def get_eeprom_dict(self, port_num):

# decode the running application code
sel = 1
eeprom_data = self._read_eeprom_devid(port_num, self.IDENTITY_EEPROM_ADDR, 0x880, 32)
eeprom_data = self._read_eeprom_devid(
port_num, self.IDENTITY_EEPROM_ADDR, 0x880, 32)
if eeprom_data is not None:
sel = int(eeprom_data[145 - 128], 16) >> 4
if sel < 1 or sel > len(dict):
sel = 1
sfp_data['interface']['data']['Application Selected'] = "{0}".format(sel)
sfp_data['interface']['data']['Application Selected'] = "{0}".format(
sel)

sfpd_obj = QSFPDDDomPaser(
eeprom_ifraw + eeprom_domraw) if eeprom_domraw else None
Expand Down