A minor change in ConflictTracker.java
[jpf-core.git] / src / main / gov / nasa / jpf / listener / ConflictTracker.java
index ca405b25dacf78abaec4f885cbef1ef0c7852956..a0ecc4bb6721597ba8631d83deeb8929feb207f8 100644 (file)
@@ -172,11 +172,14 @@ public class ConflictTracker extends ListenerAdapter {
   boolean updateEdge(Node parentNode, Node currentNode) {
        ArrayList<NameValuePair> setSet = currentNode.getSetSetMap().get(parentNode);
        HashSet<String> updatedVarNames = new HashSet<String>();
+       HashMap<Integer, String> writerLastValue = new HashMap<Integer, String>();
+
        boolean isChanged = false;
        
        if (setSet != null) {
                for (int i = 0;i < setSet.size();i++) {
                        updatedVarNames.add(setSet.get(i).getVarName());
+                       writerLastValue.put(setSet.get(i).getAppNum(), setSet.get(i).getValue());
                }
        }
 
@@ -187,9 +190,9 @@ public class ConflictTracker extends ListenerAdapter {
 
        if (setSet != null) {
                for (int i = 0;i < setSet.size();i++) {
-                       if (currentNode.getOutSet().contains(setSet.get(i)))
-                               currentNode.getOutSet().remove(setSet.get(i));
-                       isChanged |= currentNode.getOutSet().add(setSet.get(i));
+                       if (setSet.get(i).getValue().equals(writerLastValue.get(setSet.get(i).getAppNum()))) {
+                               isChanged |= currentNode.getOutSet().add(setSet.get(i));
+                       }
                }
        }
 
@@ -201,9 +204,8 @@ public class ConflictTracker extends ListenerAdapter {
        HashSet<Node> predecessors = new HashSet<Node>();
        HashSet<Node> successors = new HashSet<Node>();
        HashSet<NameValuePair> outSet = new HashSet<NameValuePair>();
+        ArrayList<NameValuePair> setSet = new ArrayList<NameValuePair>();
        HashMap<Node, ArrayList<NameValuePair>> setSetMap = new HashMap<Node, ArrayList<NameValuePair>>();
-       ArrayList<NameValuePair> setSet = new ArrayList<NameValuePair>();
-
 
        Node(Integer id) {
          this.id = id;
@@ -217,16 +219,6 @@ public class ConflictTracker extends ListenerAdapter {
          successors.add(node);
        }
 
-       void setSetSet(ArrayList<NameValuePair> setSet, boolean isManual) {
-         if (isManual)
-           this.setSet = new ArrayList<NameValuePair>();
-
-         for (int i = 0;i < setSet.size();i++) {
-           this.setSet.add(new NameValuePair(setSet.get(i).getAppNum(), setSet.get(i).getValue(), 
-                                             setSet.get(i).getVarName(), setSet.get(i).getIsManual()));
-           }
-       }
-
        Integer getId() {
                return id;
        }
@@ -239,14 +231,14 @@ public class ConflictTracker extends ListenerAdapter {
                return successors;
        }
 
-       ArrayList<NameValuePair> getSetSet() {
-               return setSet;
-       }
-
        HashSet<NameValuePair> getOutSet() {
                return outSet;
        }
 
+        ArrayList<NameValuePair> getSetSet() {
+               return setSet;
+        }
+
        HashMap<Node, ArrayList<NameValuePair>> getSetSetMap() {
                return setSetMap;
        }
@@ -277,7 +269,7 @@ public class ConflictTracker extends ListenerAdapter {
                this.varName = varName;
        }
 
-    void setIsManual(String varName) {
+        void setIsManual(String varName) {
                this.isManual = isManual;
        }
 
@@ -349,11 +341,18 @@ public class ConflictTracker extends ListenerAdapter {
 
     Node currentNode = nodes.get(id);
 
-    // Update the setSet for this new node
-    currentNode.setSetSet(tempSetSet, manual);
-    tempSetSet = new ArrayList<NameValuePair>(); 
+    if ((currentNode.getSetSetMap().get(parentNode) == null) || manual)
+       currentNode.getSetSetMap().put(parentNode, new ArrayList<NameValuePair>());
+
+    // Update the setSet for the edge
+    currentNode.getSetSetMap().get(parentNode).addAll(tempSetSet);
+    parentNode.getSetSet().addAll(tempSetSet);
+    tempSetSet = new ArrayList<NameValuePair>();
     manual = false;
 
+    // Check for the conflict in this edge
+    conflictFound = checkForConflict(parentNode);
+
     if (search.isNewState()) {
       detail = "new";
     } else {
@@ -377,17 +376,8 @@ public class ConflictTracker extends ListenerAdapter {
     if (!(parentNode.getSuccessors().contains(currentNode)))
         parentNode.addSuccessor(currentNode);
 
-
-    // Update the setSetMap of the current node
-    for (Node i : currentNode.getPredecessors()) {
-       currentNode.getSetSetMap().put(i, i.getSetSet());
-    }
-
     // Update the edge and check if the outset of the current node is changed or not to propagate the change
     boolean isChanged = updateEdge(parentNode, currentNode);
-
-    // Check for the conflict in this edge
-    conflictFound = checkForConflict(currentNode);
     
     // Check if the outSet of this state has changed, update all of its successors' sets if any
     if (isChanged)