examples/sim/dataflow: use new dataflow API (thanks Ross Manyika for reporting)

This commit is contained in:
Sebastien Bourdeauducq 2012-06-22 13:22:36 +02:00
parent 956d1257c2
commit 67dc911788
1 changed files with 3 additions and 3 deletions

View File

@ -17,13 +17,13 @@ def sink_gen():
print("Received: " + str(t.value["value"]))
def main():
source = SimActor(source_gen(), ("source", Source, [("value", BV(32))]))
sink = SimActor(sink_gen(), ("sink", Sink, [("value", BV(32))]))
source = ActorNode(SimActor(source_gen(), ("source", Source, [("value", BV(32))])))
sink = ActorNode(SimActor(sink_gen(), ("sink", Sink, [("value", BV(32))])))
g = DataFlowGraph()
g.add_connection(source, sink)
comp = CompositeActor(g)
def end_simulation(s):
s.interrupt = source.done
s.interrupt = source.actor.done
fragment = comp.get_fragment() + Fragment(sim=[end_simulation])
sim = Simulator(fragment, Runner())
sim.run()