From b4216ae5c6c9148f0f1fc7eae627777fad2856df Mon Sep 17 00:00:00 2001
From: Luke Kenneth Casson Leighton <lkcl@lkcl.net>
Date: Sat, 6 Apr 2019 03:52:49 +0100
Subject: [PATCH] add unbuffered delay-pipe unit test

---
 src/add/test_buf_pipe.py | 33 ++++++++++++++++++++++++++++++---
 1 file changed, 30 insertions(+), 3 deletions(-)

diff --git a/src/add/test_buf_pipe.py b/src/add/test_buf_pipe.py
index 82c8ff79..93732cb4 100644
--- a/src/add/test_buf_pipe.py
+++ b/src/add/test_buf_pipe.py
@@ -598,8 +598,8 @@ class ExampleStageDelayCls(StageCls):
 
     @property
     def d_ready(self):
-        return Const(1)
         return self.count == 2
+        return Const(1)
 
     @property
     def d_valid(self):
@@ -618,8 +618,6 @@ class ExampleStageDelayCls(StageCls):
 
 
 class ExampleBufDelayedPipe(BufferedPipeline):
-    """ an example of how to use the buffered pipeline.
-    """
 
     def __init__(self):
         stage = ExampleStageDelayCls()
@@ -664,6 +662,22 @@ def test12_resultfn(o_data, expected, i, o):
                 % (i, o, o_data, res)
 
 
+######################################################################
+# Test 13
+######################################################################
+
+class ExampleUnBufDelayedPipe(UnbufferedPipeline):
+
+    def __init__(self):
+        stage = ExampleStageDelayCls()
+        UnbufferedPipeline.__init__(self, stage, stage_ctl=True)
+
+    def elaborate(self, platform):
+        m = UnbufferedPipeline.elaborate(self, platform)
+        m.submodules.stage = self.stage
+        return m
+
+
 ######################################################################
 # Unit Tests
 ######################################################################
@@ -779,3 +793,16 @@ if __name__ == '__main__':
     with open("test_bufpipe12.il", "w") as f:
         f.write(vl)
 
+    print ("test 13")
+    #dut = ExampleBufPipe3()
+    dut = ExampleUnBufDelayedPipe()
+    data = data_chain1()
+    test = Test5(dut, test12_resultfn, data=data)
+    run_simulation(dut, [test.send, test.rcv], vcd_name="test_unbufpipe13.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_unbufpipe13.il", "w") as f:
+        f.write(vl)
+
-- 
2.30.2