Minor reorganization
This commit is contained in:
@@ -320,17 +320,17 @@ class AxiStreamSource(object):
|
|||||||
self.bus.tuser <= 0
|
self.bus.tuser <= 0
|
||||||
continue
|
continue
|
||||||
|
|
||||||
if frame is None and self.queue:
|
|
||||||
frame = self.queue.popleft()
|
|
||||||
self.queue_occupancy_bytes -= len(frame)
|
|
||||||
self.queue_occupancy_frames -= 1
|
|
||||||
self.log.info(f"TX frame: {frame}")
|
|
||||||
frame.normalize()
|
|
||||||
self.active = True
|
|
||||||
|
|
||||||
await RisingEdge(self.clock)
|
await RisingEdge(self.clock)
|
||||||
|
|
||||||
if (tready_sample and tvalid_sample) or not tvalid_sample:
|
if (tready_sample and tvalid_sample) or not tvalid_sample:
|
||||||
|
if frame is None and self.queue:
|
||||||
|
frame = self.queue.popleft()
|
||||||
|
self.queue_occupancy_bytes -= len(frame)
|
||||||
|
self.queue_occupancy_frames -= 1
|
||||||
|
self.log.info(f"TX frame: {frame}")
|
||||||
|
frame.normalize()
|
||||||
|
self.active = True
|
||||||
|
|
||||||
if frame and not self.pause:
|
if frame and not self.pause:
|
||||||
tdata_val = 0
|
tdata_val = 0
|
||||||
tlast_val = 0
|
tlast_val = 0
|
||||||
@@ -339,8 +339,6 @@ class AxiStreamSource(object):
|
|||||||
tdest_val = 0
|
tdest_val = 0
|
||||||
tuser_val = 0
|
tuser_val = 0
|
||||||
|
|
||||||
offset = 0
|
|
||||||
|
|
||||||
for offset in range(self.byte_width):
|
for offset in range(self.byte_width):
|
||||||
tdata_val |= (frame.tdata.pop(0) & self.byte_mask) << (offset * self.byte_size)
|
tdata_val |= (frame.tdata.pop(0) & self.byte_mask) << (offset * self.byte_size)
|
||||||
tkeep_val |= (frame.tkeep.pop(0) & 1) << offset
|
tkeep_val |= (frame.tkeep.pop(0) & 1) << offset
|
||||||
|
|||||||
Reference in New Issue
Block a user