def ports(self):
res = []
for i in range(len(self.p)):
- res += [self.p[i].i_valid, self.p[i].o_ready,
- self.p[i].i_data]# XXX need flattening!]
- res += [self.n.i_ready, self.n.o_valid,
- self.n.o_data] # XXX need flattening!]
+ p = self.p[i]
+ res += [p.i_valid, p.o_ready]
+ if hasattr(p.i_data, "ports"):
+ res += p.i_data.ports()
+ else:
+ rres = p.i_data
+ if not isinstance(rres, Sequence):
+ rres = [rres]
+ res += rres
+ n = self.n
+ res += [n.i_ready, n.o_valid]
+ if hasattr(n.o_data, "ports"):
+ res += n.o_data.ports()
+ else:
+ rres = n.o_data
+ if not isinstance(rres, Sequence):
+ rres = [rres]
+ res += rres
return res
from nmigen.compat.sim import run_simulation
from nmigen.cli import verilog, rtlil
-from multipipe import CombMultiInPipeline, InputPriorityArbiter
-
-
-class PriorityUnbufferedPipeline(CombMultiInPipeline):
- def __init__(self, stage, p_len=4):
- p_mux = InputPriorityArbiter(self, p_len)
- CombMultiInPipeline.__init__(self, stage, p_len=p_len, p_mux=p_mux)
-
- def ports(self):
- return self.p_mux.ports()
- #return UnbufferedPipeline.ports(self) + self.p_mux.ports()
+from multipipe import (CombMultiInPipeline, PriorityCombMuxInPipe)
class PassData:
def ports(self):
return [self.mid, self.idx, self.data]
+
class PassThroughStage:
def ispec(self):
return PassData()
def ospec(self):
return self.ispec() # same as ospec
-
def process(self, i):
return i # pass-through
break
-class TestPriorityMuxPipe(PriorityUnbufferedPipeline):
+class TestPriorityMuxPipe(PriorityCombMuxInPipe):
def __init__(self):
self.num_rows = 4
stage = PassThroughStage()
- PriorityUnbufferedPipeline.__init__(self, stage, p_len=self.num_rows)
-
- def ports(self):
- res = []
- for i in range(len(self.p)):
- res += [self.p[i].i_valid, self.p[i].o_ready] + \
- self.p[i].i_data.ports()
- res += [self.n.i_ready, self.n.o_valid] + \
- self.n.o_data.ports()
- return res
+ PriorityCombMuxInPipe.__init__(self, stage, p_len=self.num_rows)
if __name__ == '__main__':