Hardware/litex
1
0
Fork 0
mirror of https://github.com/enjoy-digital/litex.git synced 2025-01-04 09:52:26 -05:00
Code Issues Projects Releases Packages Wiki Activity

flow: add AbstractActor busy signals

Browse source
This commit is contained in:
Sebastien Bourdeauducq 2013-10-25 18:50:14 +02:00
parent 99c53ed9e8
commit 892c12bff5
1 changed files with 14 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
migen/flow/network.py
View file

@ -14,6 +14,7 @@ class AbstractActor:
self.actor_class = actor_class
self.parameters = parameters
self.name = name
self.busy = Signal()
def create_instance(self):
return self.actor_class(**self.parameters)
@ -30,6 +31,7 @@ class DataFlowGraph(MultiDiGraph):
def __init__(self):
MultiDiGraph.__init__(self)
self.elaborated = False
self.abstract_busy_signals = dict()
def add_connection(self, source_node, sink_node,
source_ep=None, sink_ep=None, # default: assume nodes have 1 source/sink and use that one
@ -71,7 +73,9 @@ class DataFlowGraph(MultiDiGraph):
self.remove_node(old)
def instantiate(self, actor):
self.replace_actor(actor, actor.create_instance())
inst = actor.create_instance()
self.abstract_busy_signals[id(inst)] = actor.busy
self.replace_actor(actor, inst)
# Returns a dictionary
# source -> [sink1, ..., sinkn]
@ -237,6 +241,15 @@ class CompositeActor(Module):
assert(not hasattr(self, k))
setattr(self, k, v)
# connect abstract busy signals
for node in dfg:
try:
abstract_busy_signal = dfg.abstract_busy_signals[id(node)]
except KeyError:
pass
else:
self.comb += abstract_busy_signal.eq(node.busy)
# generate busy signal
self.busy = Signal()
self.comb += self.busy.eq(optree("|", [node.busy for node in dfg]))