Trigger transmit complete events when flushing queue to prevent deadlocks

This commit is contained in:
Alex Forencich
2021-03-21 18:46:30 -07:00
parent 11205bde46
commit f1a89e6c12

View File

@@ -354,7 +354,9 @@ class AxiStreamBase(Reset):
def clear(self): def clear(self):
while not self.queue.empty(): while not self.queue.empty():
self.queue.get_nowait() frame = self.queue.get_nowait()
frame.sim_time_end = None
frame.handle_tx_complete()
self.idle_event.set() self.idle_event.set()
self.active_event.clear() self.active_event.clear()
self.queue_occupancy_bytes = 0 self.queue_occupancy_bytes = 0