Skip to content


Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

flow/network/DataFlowGraph: add_buffered_connection

  • Loading branch information...
commit 12deaa91d8b1afef7490b8196e983b83b07f8399 1 parent b5b29f6
@sbourdeauducq sbourdeauducq authored
Showing with 7 additions and 0 deletions.
  1. +7 −0 migen/flow/
7 migen/flow/
@@ -38,6 +38,13 @@ def add_connection(self, source_node, sink_node,
source=source_ep, sink=sink_ep,
source_subr=source_subr, sink_subr=sink_subr)
+ def add_buffered_connection(self, source_node, sink_node,
+ source_ep=None, sink_ep=None,
+ source_subr=None, sink_subr=None):
+ buf = AbstractActor(plumbing.Buffer)
+ self.add_connection(source_node, buf, source_ep=source_ep, source_subr=source_subr)
+ self.add_connection(buf, sink_node, sink_ep=sink_ep, sink_subr=sink_subr)
def add_pipeline(self, *nodes):
for n1, n2 in zip(nodes, nodes[1:]):
self.add_connection(n1, n2)
Please sign in to comment.
Something went wrong with that request. Please try again.