Inline init
This commit is contained in:
@@ -484,12 +484,7 @@ class AxiStreamSink(object):
|
|||||||
self.set_pause_generator(None)
|
self.set_pause_generator(None)
|
||||||
|
|
||||||
async def _run(self):
|
async def _run(self):
|
||||||
frame = AxiStreamFrame()
|
frame = AxiStreamFrame([], [], [], [], [])
|
||||||
frame.tdata = []
|
|
||||||
frame.tkeep = []
|
|
||||||
frame.tid = []
|
|
||||||
frame.tdest = []
|
|
||||||
frame.tuser = []
|
|
||||||
self.active = False
|
self.active = False
|
||||||
|
|
||||||
while True:
|
while True:
|
||||||
@@ -501,12 +496,7 @@ class AxiStreamSink(object):
|
|||||||
|
|
||||||
if self.reset is not None and self.reset.value:
|
if self.reset is not None and self.reset.value:
|
||||||
await RisingEdge(self.clock)
|
await RisingEdge(self.clock)
|
||||||
frame = AxiStreamFrame()
|
frame = AxiStreamFrame([], [], [], [], [])
|
||||||
frame.tdata = []
|
|
||||||
frame.tkeep = []
|
|
||||||
frame.tid = []
|
|
||||||
frame.tdest = []
|
|
||||||
frame.tuser = []
|
|
||||||
self.active = False
|
self.active = False
|
||||||
if hasattr(self.bus, "tready"):
|
if hasattr(self.bus, "tready"):
|
||||||
self.bus.tready <= 0
|
self.bus.tready <= 0
|
||||||
@@ -537,12 +527,7 @@ class AxiStreamSink(object):
|
|||||||
self.queue.append(frame)
|
self.queue.append(frame)
|
||||||
self.sync.set()
|
self.sync.set()
|
||||||
|
|
||||||
frame = AxiStreamFrame()
|
frame = AxiStreamFrame([], [], [], [], [])
|
||||||
frame.tdata = []
|
|
||||||
frame.tkeep = []
|
|
||||||
frame.tid = []
|
|
||||||
frame.tdest = []
|
|
||||||
frame.tuser = []
|
|
||||||
|
|
||||||
await RisingEdge(self.clock)
|
await RisingEdge(self.clock)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user