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

Fix active state tracking for AXI stream sink/monitor

Browse Source
This commit is contained in:
Alex Forencich
2021-09-15 00:46:01 -07:00
parent 44da562db9
commit b6870716ed
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
cocotbext/axi/axis.py
View File

@@ -629,9 +629,9 @@ class AxiStreamMonitor(AxiStreamBase):
else: else:
frame = AxiStreamFrame([], [], [], [], []) frame = AxiStreamFrame([], [], [], [], [])
frame.sim_time_start = get_sim_time() frame.sim_time_start = get_sim_time()
self.active = True
for offset in range(self.byte_lanes): for offset in range(self.byte_lanes):
frame.tdata.append((self.bus.tdata.value.integer >> (offset * self.byte_size)) & self.byte_mask) frame.tdata.append((self.bus.tdata.value.integer >> (offset * self.byte_size)) & self.byte_mask)
if hasattr(self.bus, "tkeep"): if hasattr(self.bus, "tkeep"):
frame.tkeep.append((self.bus.tkeep.value.integer >> offset) & 1) frame.tkeep.append((self.bus.tkeep.value.integer >> offset) & 1)
@@ -653,6 +653,8 @@ class AxiStreamMonitor(AxiStreamBase):
self.active_event.set() self.active_event.set()
frame = None frame = None
else:
self.active = bool(frame)
class AxiStreamSink(AxiStreamMonitor, AxiStreamPause): class AxiStreamSink(AxiStreamMonitor, AxiStreamPause):
@@ -705,9 +707,9 @@ class AxiStreamSink(AxiStreamMonitor, AxiStreamPause):
else: else:
frame = AxiStreamFrame([], [], [], [], []) frame = AxiStreamFrame([], [], [], [], [])
frame.sim_time_start = get_sim_time() frame.sim_time_start = get_sim_time()
self.active = True
for offset in range(self.byte_lanes): for offset in range(self.byte_lanes):
frame.tdata.append((self.bus.tdata.value.integer >> (offset * self.byte_size)) & self.byte_mask) frame.tdata.append((self.bus.tdata.value.integer >> (offset * self.byte_size)) & self.byte_mask)
if hasattr(self.bus, "tkeep"): if hasattr(self.bus, "tkeep"):
frame.tkeep.append((self.bus.tkeep.value.integer >> offset) & 1) frame.tkeep.append((self.bus.tkeep.value.integer >> offset) & 1)
@@ -729,6 +731,8 @@ class AxiStreamSink(AxiStreamMonitor, AxiStreamPause):
self.active_event.set() self.active_event.set()
frame = None frame = None
else:
self.active = bool(frame)
if hasattr(self.bus, "tready"): if hasattr(self.bus, "tready"):
self.bus.tready <= (not self.full() and not self.pause) self.bus.tready <= (not self.full() and not self.pause)