third-party/cocotbext-eth
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Trigger transmit complete events when flushing queue to prevent deadlocks

Browse Source
This commit is contained in:
Alex Forencich
2021-03-21 18:46:41 -07:00
parent 63e6eafc07
commit f52f6dbe33
4 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
cocotbext/eth/gmii.py
View File

@@ -203,7 +203,9 @@ class GmiiSource(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.queue_occupancy_bytes = 0 self.queue_occupancy_bytes = 0
self.queue_occupancy_frames = 0 self.queue_occupancy_frames = 0

4
cocotbext/eth/mii.py
View File

@@ -104,7 +104,9 @@ class MiiSource(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.queue_occupancy_bytes = 0 self.queue_occupancy_bytes = 0
self.queue_occupancy_frames = 0 self.queue_occupancy_frames = 0

4
cocotbext/eth/rgmii.py
View File

@@ -104,7 +104,9 @@ class RgmiiSource(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.queue_occupancy_bytes = 0 self.queue_occupancy_bytes = 0
self.queue_occupancy_frames = 0 self.queue_occupancy_frames = 0

4
cocotbext/eth/xgmii.py
View File

@@ -209,7 +209,9 @@ class XgmiiSource(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.queue_occupancy_bytes = 0 self.queue_occupancy_bytes = 0
self.queue_occupancy_frames = 0 self.queue_occupancy_frames = 0