X-Git-Url: http://git.megacz.com/?p=sbp.git;a=blobdiff_plain;f=src%2Fedu%2Fberkeley%2Fsbp%2FNode.java;h=6aecefa48260ef50cfeb0f4dbaef01c094b2a389;hp=09718afdce0d970fc521ba769c670ce7025b4460;hb=HEAD;hpb=c404939a6dfed4dcfdca5ede08db99b3e5ef0c91 diff --git a/src/edu/berkeley/sbp/Node.java b/src/edu/berkeley/sbp/Node.java index 09718af..6aecefa 100644 --- a/src/edu/berkeley/sbp/Node.java +++ b/src/edu/berkeley/sbp/Node.java @@ -10,14 +10,104 @@ import java.io.*; import java.util.*; import java.lang.reflect.*; -class Node +abstract class Node implements IntegerMappable, - GraphViz.ToGraphViz { + GraphViz.ToGraphViz, + Iterable { - protected FastSet predecessors = new FastSet(); - protected FastSet successors = new FastSet(); - //private HashSet predecessors = new HashSet(); - //private HashSet successors = new HashSet(); + private final GSS.Phase phase; + private final GSS.Phase predecessorPhase; + protected boolean destroyed = false; + private int numNonDoomedSuccessors = 0; + private boolean hasPathToRoot = false; + + private FastSet predecessors = new FastSet(); + private FastSet successors = new FastSet(); + //protected HashSet predecessors = new HashSet(); + //protected HashSet successors = new HashSet(); + + public GSS.Phase phase() { return phase; } + public GSS.Phase predecessorPhase() { return predecessorPhase; } + public boolean hasPredecessors() { return predecessors.size() > 0; } + public boolean hasSuccessors() { return successors.size() > 0; } + public boolean hasNonDoomedSuccessors() { return numNonDoomedSuccessors > 0; } + + public boolean hasPathToRoot() { return hasPathToRoot; } + public void updatePathsToRootAfterRemoval() { + if (!hasPathToRoot()) return; + for(OtherNode on : predecessors) + if (on.hasPathToRoot()) + return; + hasPathToRoot = false; + for(OtherNode on : successors) + on.updatePathsToRootAfterRemoval(); + } + + /** + * Every Node has a phase; StateNodes belong to the phase in + * which they were shifted, ResultNodes belong to the phase of + * their predecessors. All of the predecessors of a given node + * must belong to the same phase + */ + public Node(GSS.Phase phase, GSS.Phase predecessorPhase) { + this.phase = phase; + this.predecessorPhase = predecessorPhase; + } + + /** only to be invoked (or overridden as public) by the subclass */ + protected void addPred(OtherNode pred) { + if (predecessors.contains(pred)) throw new Error("a predecessor was added twice"); + if (pred.phase() != predecessorPhase()) throw new Error(); + predecessors.add(pred); + pred.addSucc(this); + if (pred.hasPathToRoot()) hasPathToRoot = true; + } + public void addSucc(OtherNode succ) { + if (successors.contains(succ)) throw new Error("a predecessor was added twice"); + successors.add(succ); + numNonDoomedSuccessors += succ.isDoomedState() ? 0 : 1; + if (predecessors.size() > 1 && (((Object)this) instanceof ResultNode)) throw new Error(); + } + + protected void destroy() { + destroyed = true; + while(predecessors.size() > 0) { + OtherNode pred = predecessors.first(); + removePred(pred); + pred.removeSucc(this); + } + predecessors = null; + while(successors.size() > 0) { + OtherNode succ = successors.first(); + removeSucc(succ); + succ.removePred(this); + } + successors = null; + } + public void removeSucc(OtherNode succ) { + if (!successors.contains(succ)) return; + successors.remove(succ); + numNonDoomedSuccessors -= succ.isDoomedState() ? 0 : 1; + check(); + } + public void removePred(OtherNode pred) { + if (!predecessors.contains(pred)) return; + predecessors.remove(pred); + updatePathsToRootAfterRemoval(); + check(); + } + + + public abstract boolean isDoomedState(); + protected abstract void check(); + + public Iterator iterator() { return predecessors.iterator(); } + public Iterable successors() { return successors; } + + public boolean noSuccessors() { return successors.size()==0; } + public boolean predecessorsContains(OtherNode n) { + return predecessors.contains(n); + } // GraphViz //////////////////////////////////////////////////////////////////////////////