From: Sebastien Bourdeauducq <sebastien@milkymist.org>
Date: Sat, 11 May 2013 09:48:21 +0000 (+0200)
Subject: genlib/record: match_by_position -> connect_flat
X-Git-Tag: 24jan2021_ls180~2099^2~580
X-Git-Url: https://git.libre-soc.org/?a=commitdiff_plain;h=0ec6a7eb4e0e0cd275f5597ba4a8be0d0fc73085;p=litex.git

genlib/record: match_by_position -> connect_flat
---

diff --git a/migen/flow/network.py b/migen/flow/network.py
index 5bc6847c..deaacd32 100644
--- a/migen/flow/network.py
+++ b/migen/flow/network.py
@@ -247,4 +247,4 @@ class CompositeActor(Module):
 		for u, v, d in dfg.edges_iter(data=True):
 			ep_src = getattr(u, d["source"])
 			ep_dst = getattr(v, d["sink"])
-			self.comb += ep_src.connect(ep_dst, match_by_position=True)
+			self.comb += ep_src.connect_flat(ep_dst)
diff --git a/migen/genlib/record.py b/migen/genlib/record.py
index 4d790647..13b730fb 100644
--- a/migen/genlib/record.py
+++ b/migen/genlib/record.py
@@ -80,18 +80,22 @@ class Record:
 	def eq(self, other):
 		return [getattr(self, f[0]).eq(getattr(other, f[0]))
 		  for f in self.layout if hasattr(other, f[0])]
-	
-	def flatten(self):
-		r = []
-		for f in self.layout:			
+
+	def iter_flat(self):
+		for f in self.layout:
 			e = getattr(self, f[0])
 			if isinstance(e, Signal):
-				r.append(e)
+				if len(f) == 3:
+					yield e, f[2]
+				else:
+					yield e, DIR_NONE
 			elif isinstance(e, Record):
-				r += e.flatten()
+				yield from e.iter_flat()
 			else:
 				raise TypeError
-		return r
+	
+	def flatten(self):
+		return [signal for signal, direction in self.iter_flat()]
 
 	def raw_bits(self):
 		return Cat(*self.flatten())
@@ -114,6 +118,26 @@ class Record:
 					r += self_e.connect(getattr(slave, field))
 		return r
 
+	def connect_flat(self, *slaves):
+		r = []
+		iter_slaves = [slave.iter_flat() for slave in slaves]
+		for m_signal, m_direction in self.iter_flat():
+			if m_direction == DIR_M_TO_S:
+				for iter_slave in iter_slaves:
+					s_signal, s_direction = next(iter_slave)
+					assert(s_direction == DIR_M_TO_S)
+					r.append(s_signal.eq(m_signal))
+			elif m_direction == DIR_S_TO_M:
+				s_signals = []
+				for iter_slave in iter_slaves:
+					s_signal, s_direction = next(iter_slave)
+					assert(s_direction == DIR_S_TO_M)
+					s_signals.append(s_signal)
+				r.append(m_signal.eq(optree("|", s_signals)))
+			else:
+				raise TypeError
+		return r
+
 	def __len__(self):
 		return layout_len(self.layout)