Permalink
Browse files

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

…reporting)
  • Loading branch information...
1 parent 956d125 commit 67dc911788a76722aea383c8ce6da07757a82e79 @sbourdeauducq sbourdeauducq committed Jun 22, 2012
Showing with 3 additions and 3 deletions.
  1. +3 −3 examples/sim/dataflow.py
View
@@ -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()

0 comments on commit 67dc911

Please sign in to comment.