bslathi19/cocotbext-axi
1
0
Fork 0
Code Issues Actions Packages Projects Releases 5 Wiki Activity

Handle dropped transmit frames during reset

Browse Source
This commit is contained in:
Alex Forencich
2021-03-21 18:39:35 -07:00
parent bce364eef5
commit 11205bde46
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
cocotbext/axi/axis.py
View File

@@ -277,6 +277,7 @@ class AxiStreamBase(Reset):
self.active = False self.active = False
self.queue = Queue() self.queue = Queue()
self.current_frame = None
self.idle_event = Event() self.idle_event = Event()
self.idle_event.set() self.idle_event.set()
self.active_event = Event() self.active_event = Event()
@@ -459,6 +460,11 @@ class AxiStreamSource(AxiStreamBase, AxiStreamPause):
if hasattr(self.bus, "tuser"): if hasattr(self.bus, "tuser"):
self.bus.tuser <= 0 self.bus.tuser <= 0
if self.current_frame:
self.log.warning("Flushed transmit frame during reset: %s", self.current_frame)
self.current_frame.handle_tx_complete()
self.current_frame = None
async def _run(self): async def _run(self):
frame = None frame = None
self.active = False self.active = False
@@ -475,6 +481,7 @@ class AxiStreamSource(AxiStreamBase, AxiStreamPause):
frame = self.queue.get_nowait() frame = self.queue.get_nowait()
self.queue_occupancy_bytes -= len(frame) self.queue_occupancy_bytes -= len(frame)
self.queue_occupancy_frames -= 1 self.queue_occupancy_frames -= 1
self.current_frame = frame
frame.sim_time_start = get_sim_time() frame.sim_time_start = get_sim_time()
frame.sim_time_end = None frame.sim_time_end = None
self.log.info("TX frame: %s", frame) self.log.info("TX frame: %s", frame)
@@ -501,6 +508,7 @@ class AxiStreamSource(AxiStreamBase, AxiStreamPause):
frame.sim_time_end = get_sim_time() frame.sim_time_end = get_sim_time()
frame.handle_tx_complete() frame.handle_tx_complete()
frame = None frame = None
self.current_frame = None
break break
self.bus.tdata <= tdata_val self.bus.tdata <= tdata_val