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

Remove callbacks

Browse Source
This commit is contained in:
Alex Forencich
2021-01-07 18:10:33 -08:00
parent 6654c707b2
commit 3caa343845
1 changed files with 4 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
cocotbext/axi/stream.py
View File

@@ -248,10 +248,6 @@ class StreamSink(StreamBase, StreamPause):
else: else:
await self.queue_sync.wait() await self.queue_sync.wait()
def callback(self, obj):
self.queue.append(obj)
self.queue_sync.set()
async def _run_sink(self): async def _run_sink(self):
while True: while True:
await RisingEdge(self.clock) await RisingEdge(self.clock)
@@ -269,7 +265,8 @@ class StreamSink(StreamBase, StreamPause):
if ready_sample and valid_sample: if ready_sample and valid_sample:
obj = self._transaction_obj() obj = self._transaction_obj()
self.bus.sample(obj) self.bus.sample(obj)
self.callback(obj) self.queue.append(obj)
self.queue_sync.set()
if self.ready is not None: if self.ready is not None:
self.ready <= (not self.pause) self.ready <= (not self.pause)
@@ -313,10 +310,6 @@ class StreamMonitor(StreamBase):
else: else:
await self.queue_sync.wait() await self.queue_sync.wait()
def callback(self, obj):
self.queue.append(obj)
self.queue_sync.set()
async def _run_monitor(self): async def _run_monitor(self):
while True: while True:
await RisingEdge(self.clock) await RisingEdge(self.clock)
@@ -332,7 +325,8 @@ class StreamMonitor(StreamBase):
if ready_sample and valid_sample: if ready_sample and valid_sample:
obj = self._transaction_obj() obj = self._transaction_obj()
self.bus.sample(obj) self.bus.sample(obj)
self.callback(obj) self.queue.append(obj)
self.queue_sync.set()
def define_stream(name, signals, optional_signals=None, valid_signal=None, ready_signal=None, signal_widths=None): def define_stream(name, signals, optional_signals=None, valid_signal=None, ready_signal=None, signal_widths=None):