package edu.berkeley.fleet.dataflow;
+import java.util.*;
import edu.berkeley.fleet.loops.*;
import edu.berkeley.fleet.api.*;
import edu.berkeley.fleet.fpga.*;
ctx2 = new Context(fp.getFleet());
Destination ackDestination = counter.getDock("in2").getDataDestination();
- int expected_tokens = proc.reset(ctx2, phase, ackDestination);
+ HashSet<Dock> sendTorpedoesTo = new HashSet<Dock>();
+ int expected_tokens = proc.reset(ctx2, phase, ackDestination, sendTorpedoesTo);
Context ctx3 = new Context(fp.getFleet());
lf = new LoopFactory(ctx3, counter.getDock("inOp"), 1);
lf.sendToken(debugIn.getDataDestination());
ctx3.dispatch(fp); // HACK: we don't check to make sure that this is "firmly in place"
- for(Dock dock : DataFlowGraph.torpedoes) fp.sendToken(dock.getInstructionDestination());
+ for(Dock dock : sendTorpedoesTo) fp.sendToken(dock.getInstructionDestination());
ctx2.dispatch(fp);
fp.flush();
System.out.println("flushed");