1 package edu.berkeley.fleet.dataflow;
3 import edu.berkeley.fleet.loops.*;
4 import edu.berkeley.fleet.api.*;
8 // public class ReplaceNode extends Node { }
9 // public class CountMergeNode extends Node { }
10 // public class SortMergeNode extends Node { }
11 // public class FanOutNode extends Node { }
12 // public class DoneNode extends Node { }
14 public class DataFlowGraph {
16 public final Fleet fleet;
17 public final ShipPool pool;
18 private HashSet<Node> nodes = new HashSet<Node>();
20 public DataFlowGraph(Fleet fleet) { this(fleet, new ShipPool(fleet)); }
21 public DataFlowGraph(Fleet fleet, ShipPool pool) {
26 public void addNode(Node node) { this.nodes.add(node); }
28 public void build(Context ctx) {
32 public int reset(Context ctx, int phase, Destination ackDestination, HashSet<Dock> sendTorpedoesTo) {
35 ret += mod.reset(ctx, phase, ackDestination, sendTorpedoesTo);