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

Jump to bottom

[202311] PoC - retry on i2c busy #168

Draft
wants to merge 3 commits into
base: 202311
Choose a base branch
from
Draft

[202311] PoC - retry on i2c busy #168

Changes from 1 commit
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
09a83f5
PoC: Retry on I2C busy in platform
stephenxs Sep 25, 2024
89de86a
Retry on both exception and non-zero return code
stephenxs Sep 25, 2024
d9f154f
Fix unit test failure
stephenxs Sep 25, 2024
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
25 changes: 23 additions & 2 deletions platform/mellanox/mlnx-platform-api/sonic_platform/sfp.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -525,9 +525,9 @@ def read_eeprom(self, offset, num_bytes):
bytearray, if raw sequence of bytes are read correctly from the offset of size num_bytes
None, if the read_eeprom fails
"""
return self._read_eeprom(offset, num_bytes)
return self._read_eeprom(offset, num_bytes, log_on_error=True, max_retry=2)

def _read_eeprom(self, offset, num_bytes, log_on_error=True):
def _read_eeprom(self, offset, num_bytes, log_on_error=True, max_retry=0):
"""Read eeprom specfic bytes beginning from a random offset with size as num_bytes

Args:
Expand All @@ -539,6 +539,7 @@ def _read_eeprom(self, offset, num_bytes, log_on_error=True):
bytearray: the content of EEPROM
"""
result = bytearray(0)
retry = 0
while num_bytes > 0:
_, page, page_offset = self._get_page_and_page_offset(offset)
if not page:
Expand All @@ -562,6 +563,12 @@ def _read_eeprom(self, offset, num_bytes, log_on_error=True):
# Indicate read finished
num_bytes = 0
if ctypes.get_errno() != 0:
if retry < max_retry:
stephenxs marked this conversation as resolved.
Show resolved Hide resolved
retry = retry + 1
logger.log_warning(f'reading EEPROM sfp={self.sdk_index}, page={page}, page_offset={page_offset}, '\
f'size={read_length}, data={content} did not succeed, retry {retry}')
time.sleep(0.05)
continue
raise IOError(f'errno = {os.strerror(ctypes.get_errno())}')
logger.log_debug(f'read EEPROM sfp={self.sdk_index}, page={page}, page_offset={page_offset}, '\
f'size={read_length}, data={content}')
Expand All @@ -583,6 +590,8 @@ def write_eeprom(self, offset, num_bytes, write_buffer):
Example:
mlxreg -d /dev/mst/mt52100_pciconf0 --reg_name MCIA --indexes slot_index=0,module=1,device_address=154,page_number=5,i2c_device_address=0x50,size=1,bank_number=0 --set dword[0]=0x01000000 -y
"""
max_retry = 2
retry = 0
if num_bytes != len(write_buffer):
logger.log_error("Error mismatch between buffer length and number of bytes to be written")
return False
Expand All @@ -606,10 +615,22 @@ def write_eeprom(self, offset, num_bytes, write_buffer):
# Move to next page
write_buffer = write_buffer[ret:num_bytes]
offset += ret
elif retry < max_retry:
retry = retry + 1
logger.log_debug(f'writing EEPROM sfp={self.sdk_index}, page={page}, page_offset={page_offset}, '\
f'size={ret}, left={num_bytes}, data={written_buffer} did not succeed, retry {retry}')
time.sleep(0.05)
continue
else:
raise IOError(f'write return code = {ret}')
num_bytes -= ret
if ctypes.get_errno() != 0:
if retry < max_retry:
retry = retry + 1
logger.log_debug(f'writing EEPROM sfp={self.sdk_index}, page={page}, page_offset={page_offset}, '\
f'size={ret}, left={num_bytes}, data={written_buffer} did not succeed, retry {retry}')
time.sleep(0.05)
continue
raise IOError(f'errno = {os.strerror(ctypes.get_errno())}')
logger.log_debug(f'write EEPROM sfp={self.sdk_index}, page={page}, page_offset={page_offset}, '\
f'size={ret}, left={num_bytes}, data={written_buffer}')
Expand Down