bslathi19/taxi
1
0
Fork 0
mirror of https://github.com/fpganinja/taxi.git synced 2026-04-07 04:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

cndm: Rework driver model to support multiple queues

Browse Source 
Signed-off-by: Alex Forencich <alex@alexforencich.com>
This commit is contained in:
Alex Forencich
2026-03-05 16:50:33 -08:00
parent 39c9dce0fa
commit 8f1c082174
1 changed files with 24 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
src/cndm/tb/cndm.py
View File

@@ -543,11 +543,11 @@ class Port:
self.index = index
self.hw_regs = driver.hw_regs
self.rxq = None
self.rxcq = None
self.rxq_count = 1
self.rxq = []
self.txq = None
self.txcq = None
self.txq_count = 1
self.txq = []
self.rx_queue = Queue()
@@ -555,20 +555,26 @@ class Port:
await self.open()
async def open(self):
self.rxcq = Cq(self.driver, self)
await self.rxcq.open(self.index, 256)
for k in range(self.rxq_count):
cq = Cq(self.driver, self)
await cq.open(self.index, 256)
self.rxq = Rq(self.driver, self)
await self.rxq.open(self.rxcq, 256)
q = Rq(self.driver, self)
await q.open(cq, 256)
self.txcq = Cq(self.driver, self)
await self.txcq.open(self.index, 256)
self.rxq.append(q)
self.txq = Sq(self.driver, self)
await self.txq.open(self.txcq, 256)
for k in range(self.txq_count):
cq = Cq(self.driver, self)
await cq.open(self.index, 256)
async def start_xmit(self, data):
await self.txq.start_xmit(data)
q = Sq(self.driver, self)
await q.open(cq, 256)
self.txq.append(q)
async def start_xmit(self, data, tx_ring=0):
await self.txq[tx_ring].start_xmit(data)
async def recv(self):
return await self.rx_queue.get()
@@ -578,8 +584,10 @@ class Port:
async def interrupt_handler(self):
self.log.info("Interrupt")
await self.rxcq.handler(self.rxcq)
await self.txcq.handler(self.txcq)
for q in self.rxq:
await q.cq.handler(q.cq)
for q in self.txq:
await q.cq.handler(q.cq)
class Driver: