add example ready for adding delay (data_ready) to pipeline API

diff --git a/src/add/singlepipe.py b/src/add/singlepipe.py
index 9dc0ee5eb56432a81fa41609f4bcedce923a69b3..9459eb09c4f8d97b8601ed11fff421709ec44f25 100644 (file)
--- a/src/add/singlepipe.py
+++ b/src/add/singlepipe.py
@@ -257,7 +257,7 @@ def eq(o, i):
     if not isinstance(o, Sequence):
         o, i = [o], [i]
     for (ao, ai) in zip(o, i):
-        print ("eq", ao, ai)
+        #print ("eq", ao, ai)
         if isinstance(ao, Record):
             for idx, (field_name, field_shape, _) in enumerate(ao.layout):
                 if isinstance(field_shape, Layout):

diff --git a/src/add/test_buf_pipe.py b/src/add/test_buf_pipe.py
index fce4ff67b788b07b064f9a85d083f6e5f15d0f6f..3f3cce2190a971b2e56dd8b3cbc4ba3a88827bcf 100644 (file)
--- a/src/add/test_buf_pipe.py
+++ b/src/add/test_buf_pipe.py
@@ -576,6 +576,61 @@ def data_2op():
         return data
 
 
+######################################################################
+# Test 12
+######################################################################
+
+class ExampleStageDelayCls(StageCls):
+    """ an example of how to use the buffered pipeline, in a static class
+        fashion
+    """
+
+    def __init__(self):
+        self.count = Signal(3)
+
+    def ispec(self):
+        return Signal(16, name="example_input_signal")
+
+    def ospec(self):
+        return Signal(16, name="example_output_signal")
+
+    def data_ready(self, i):
+        pass
+
+    def process(self, i):
+        """ process the input data and returns it (adds 1)
+        """
+        return i + 1
+
+
+class ExampleBufDelayedPipe(BufferedPipeline):
+    """ an example of how to use the buffered pipeline.
+    """
+
+    def __init__(self):
+        BufferedPipeline.__init__(self, ExampleStageDelayCls())
+
+
+class ExampleBufPipe3(ControlBase):
+    """ Example of how to do delayed pipeline, where the stage signals
+        whether it is ready.
+    """
+
+    def elaborate(self, platform):
+        m = Module()
+
+        pipe1 = ExampleBufPipe()
+        pipe2 = ExampleBufDelayedPipe()
+
+        m.submodules.pipe1 = pipe1
+        m.submodules.pipe2 = pipe2
+
+        m.d.comb += self.connect([pipe1, pipe2])
+
+        return m
+
+
+
 num_tests = 100
 
 if __name__ == '__main__':
@@ -674,3 +729,13 @@ if __name__ == '__main__':
     run_simulation(dut, [test.send, test.rcv], vcd_name="test_addrecord.vcd")
 
 
+    print ("test 12")
+    dut = ExampleBufPipe3()
+    run_simulation(dut, testbench2(dut), vcd_name="test_bufpipe12.vcd")
+    ports = [dut.p.i_valid, dut.n.i_ready,
+             dut.n.o_valid, dut.p.o_ready] + \
+             [dut.p.i_data] + [dut.n.o_data]
+    vl = rtlil.convert(dut, ports=ports)
+    with open("test_bufpipe12.il", "w") as f:
+        f.write(vl)
+