interconnect/stream: Fix #1736.

enjoy-digital · Aug 28, 2023 · 82602f6 · 82602f6
1 parent 70e52b7
commit 82602f6
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/litex/soc/interconnect/stream.py b/litex/soc/interconnect/stream.py
@@ -987,6 +987,8 @@ def do_finalize(self):
 class BufferizeEndpoints(ModuleTransformer):
     def __init__(self, endpoint_dict, pipe_valid=True, pipe_ready=False):
         self.endpoint_dict = endpoint_dict
+        self.pipe_valid    = pipe_valid
+        self.pipe_ready    = pipe_ready
 
     def transform_instance(self, submodule):
         for name, direction in self.endpoint_dict.items():
@@ -995,8 +997,8 @@ def transform_instance(self, submodule):
             if direction == DIR_SINK:
                 buf = Buffer(
                     layout     = endpoint.description,
-                    pipe_valid = pipe_valid,
-                    pipe_ready = pipe_ready,
+                    pipe_valid = self.pipe_valid,
+                    pipe_ready = self.pipe_ready,
                 )
                 submodule.submodules += buf
                 setattr(submodule, name, buf.sink)
@@ -1005,8 +1007,8 @@ def transform_instance(self, submodule):
             elif direction == DIR_SOURCE:
                 buf = Buffer(
                     layout     = endpoint.description,
-                    pipe_valid = pipe_valid,
-                    pipe_ready = pipe_ready,
+                    pipe_valid = self.pipe_valid,
+                    pipe_ready = self.pipe_ready,
                 )
                 submodule.submodules += buf
                 submodule.comb += endpoint.connect(buf.sink)