From: Sebastien Bourdeauducq <sebastien@milkymist.org>
Date: Tue, 10 Jan 2012 16:10:18 +0000 (+0100)
Subject: actorlib: Wishbone DMA read master (WIP)
X-Git-Tag: 24jan2021_ls180~2099^2~1082
X-Git-Url: https://git.libre-soc.org/?a=commitdiff_plain;h=077fd9fdbc401c777747a16b0396b24418e3a530;p=litex.git

actorlib: Wishbone DMA read master (WIP)
---

diff --git a/migen/actorlib/__init__.py b/migen/actorlib/__init__.py
new file mode 100644
index 00000000..e69de29b
diff --git a/migen/actorlib/dma_wishbone.py b/migen/actorlib/dma_wishbone.py
new file mode 100644
index 00000000..c3ad3af1
--- /dev/null
+++ b/migen/actorlib/dma_wishbone.py
@@ -0,0 +1,75 @@
+from migen.fhdl.structure import *
+from migen.corelogic.record import *
+from migen.corelogic.fsm import *
+from migen.bus import wishbone
+from migen.flow.actor import *
+
+class Reader(Actor):
+	def __init__(self, layout):
+		self.address = Record([("a", BV(30))])
+		self.data = Record(layout)
+		self.bus = wishbone.Master()
+		Actor.__init__(self,
+			SchedulingModel(SchedulingModel.DYNAMIC),
+			self.address, self.data)
+	
+	def get_fragment(self):
+		components, length = self.data.flatten(align=True, return_offset=True)
+		nwords = (length + 31)//32
+		
+		# Address generator
+		ag_stb = Signal()
+		ag_sync = [If(ag_stb, self.bus.adr_o.eq(self.address.a))]
+		if nwords > 1:
+			ag_inc = Signal()
+			sync.append(If(ag_inc, self.bus.adr_o.eq(self.bus.adr_o + 1)))
+		address_generator = Fragment(sync=ag_sync)
+		
+		# Output buffer
+		ob_reg = Signal(BV(length))
+		ob_stbs = Signal(BV(nwords))
+		ob_sync = [If(ob_stbs[w], ob_reg[32*w:32*(w+1)].eq(self.bus.dat_i))
+			for w in range(nwords)]
+		ob_comb = []
+		offset = 0
+		for s in components:
+			w = s.bv.width
+			if isinstance(s, Signal):
+				comb.append(s.eq(ob_reg[length-offset-w:length-offset]))
+			offset += w
+		output_buffer = Fragment(ob_comb, ob_sync)
+		
+		# Controller
+		fetch_states = ["FETCH{0}".format(w) for w in range(nwords)]
+		states = ["IDLE"] + fetch_states + ["STROBE"]
+		fsm = FSM(*states)
+		self.busy.reset = Constant(1)
+		fsm.act(fsm.IDLE,
+			self.busy.eq(0),
+			ag_stb.eq(1),
+			self.endpoints["address"].ack.eq(1),
+			If(self.endpoints["address"].stb, fsm.next_state(fsm.FETCH0))
+		)
+		for w in range(nwords):
+			state = getattr(fsm, fetch_states[w])
+			if w == nwords - 1:
+				next_state = fsm.STROBE
+			else:
+				state = getattr(fsm, fetch_states[w+1])
+			fsm.act(state,
+				self.bus.cyc_o.eq(1),
+				self.bus.stb_o.eq(1),
+				If(self.bus.ack_i,
+					ob_stbs[nwords-w-1].eq(1),
+					fsm.next_state(next_state)
+				)
+			)
+			if nwords > 1:
+				fsm.act(state, If(self.bus.ack_i, ag_inc.eq(1)))
+		fsm.act(fsm.STROBE,
+			self.endpoints["data"].stb.eq(1),
+			If(self.endpoints["data"].ack, fsm.next_state(fsm.IDLE))
+		)
+		controller = fsm.get_fragment()
+
+		return address_generator + output_buffer + controller