rename pipes
authorLuke Kenneth Casson Leighton <lkcl@lkcl.net>
Thu, 28 Mar 2019 03:28:04 +0000 (03:28 +0000)
committerLuke Kenneth Casson Leighton <lkcl@lkcl.net>
Thu, 28 Mar 2019 03:28:04 +0000 (03:28 +0000)
src/add/test_inout_mux_pipe.py

index 57b5676a018ac6835e763800da9ba0ec7b77d375..36c4d991ffd51c63595da6b60765f062ad6a7e42 100644 (file)
@@ -16,7 +16,7 @@ from multipipe import CombMultiInPipeline, InputPriorityArbiter
 from singlepipe import UnbufferedPipeline
 
 
-class PriorityUnbufferedPipeline(CombMultiInPipeline):
+class PriorityCombPipeline(CombMultiInPipeline):
     def __init__(self, stage, p_len):
         p_mux = InputPriorityArbiter(self, p_len)
         CombMultiInPipeline.__init__(self, stage, p_len=p_len, p_mux=p_mux)
@@ -26,7 +26,7 @@ class PriorityUnbufferedPipeline(CombMultiInPipeline):
         #return UnbufferedPipeline.ports(self) + self.p_mux.ports()
 
 
-class MuxUnbufferedPipeline(CombMultiOutPipeline):
+class MuxCombPipeline(CombMultiOutPipeline):
     def __init__(self, stage, n_len):
         # HACK: stage is also the n-way multiplexer
         CombMultiOutPipeline.__init__(self, stage, n_len=n_len, n_mux=stage)
@@ -160,11 +160,11 @@ class InputTest:
         print ("recv ended", mid)
 
 
-class TestPriorityMuxPipe(PriorityUnbufferedPipeline):
+class TestPriorityMuxPipe(PriorityCombPipeline):
     def __init__(self, num_rows):
         self.num_rows = num_rows
         stage = PassThroughStage()
-        PriorityUnbufferedPipeline.__init__(self, stage, p_len=self.num_rows)
+        PriorityCombPipeline.__init__(self, stage, p_len=self.num_rows)
 
     def ports(self):
         res = []
@@ -214,11 +214,11 @@ class OutputTest:
         yield rs.i_valid.eq(0)
 
 
-class TestMuxOutPipe(MuxUnbufferedPipeline):
+class TestMuxOutPipe(MuxCombPipeline):
     def __init__(self, num_rows):
         self.num_rows = num_rows
         stage = PassThroughStage()
-        MuxUnbufferedPipeline.__init__(self, stage, n_len=self.num_rows)
+        MuxCombPipeline.__init__(self, stage, n_len=self.num_rows)
 
     def ports(self):
         res = [self.p.i_valid, self.p.o_ready] + \