flow/network/DataFlowGraph: add_buffered_connection

m-labs · May 2, 2013 · 12deaa9 · 12deaa9
1 parent b5b29f6
commit 12deaa9
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/migen/flow/network.py b/migen/flow/network.py
@@ -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)