commit 51b8f6acba09abb2e4a9c54953b8eaad51bbf0a3
author Yuta HIGUCHI <y-higuchi@onlab.us> Sat Nov 22 03:05:51 2014 -0800
committer Yuta HIGUCHI <y-higuchi@onlab.us> Sat Nov 22 11:34:44 2014 -0800
tree 63411b159f5c840d135dfd107ea5d527c281734c
parent f84c3a27df2ec0792ae0e97ca3381d07809e6156

DistributedIntentStore: remove transient state, after transition to parking state

Change-Id: Id0a5bf6a94c03c7eb15d399fd85bf00f4322f6d4

core/store/dist/src/main/java/org/onlab/onos/store/intent/impl/DistributedIntentStore.java

diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/intent/impl/DistributedIntentStore.java b/core/store/dist/src/main/java/org/onlab/onos/store/intent/impl/DistributedIntentStore.java
index d777a45..27c1284 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/intent/impl/DistributedIntentStore.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/intent/impl/DistributedIntentStore.java
@@ -168,9 +168,9 @@
     @Override
     public IntentEvent setState(Intent intent, IntentState state) {
         final IntentId id = intent.id();
-        IntentEvent.Type type = null;
+        IntentEvent.Type evtType = null;
         final IntentState prevParking;
-        boolean transientStateChangeOnly = false;
+        boolean transitionedToParking = true;
         boolean updated;
 
         // parking state transition
@@ -187,7 +187,7 @@
                 updated = states.replace(id, prevParking, SUBMITTED);
                 verify(updated, "Conditional replace %s => %s failed", prevParking, SUBMITTED);
             }
-            type = IntentEvent.Type.SUBMITTED;
+            evtType = IntentEvent.Type.SUBMITTED;
             break;
 
         case INSTALLED:
@@ -197,14 +197,14 @@
                    prevParking);
             updated = states.replace(id, prevParking, INSTALLED);
             verify(updated, "Conditional replace %s => %s failed", prevParking, INSTALLED);
-            type = IntentEvent.Type.INSTALLED;
+            evtType = IntentEvent.Type.INSTALLED;
             break;
 
         case FAILED:
             prevParking = states.get(id);
             updated = states.replace(id, prevParking, FAILED);
             verify(updated, "Conditional replace %s => %s failed", prevParking, FAILED);
-            type = IntentEvent.Type.FAILED;
+            evtType = IntentEvent.Type.FAILED;
             break;
 
         case WITHDRAWN:
@@ -214,25 +214,28 @@
                    prevParking);
             updated = states.replace(id, prevParking, WITHDRAWN);
             verify(updated, "Conditional replace %s => %s failed", prevParking, WITHDRAWN);
-            type = IntentEvent.Type.WITHDRAWN;
+            evtType = IntentEvent.Type.WITHDRAWN;
             break;
 
         default:
-            transientStateChangeOnly = true;
+            transitionedToParking = false;
             prevParking = null;
             break;
         }
-        if (!transientStateChangeOnly) {
+        if (transitionedToParking) {
             log.debug("Parking State change: {} {}=>{}",  id, prevParking, state);
+            // remove instance local state
+            transientStates.remove(id);
+        } else {
+            // Update instance local state, which includes non-parking state transition
+            final IntentState prevTransient = transientStates.put(id, state);
+            log.debug("Transient State change: {} {}=>{}", id, prevTransient, state);
         }
-        // Update instance local state, which includes non-parking state transition
-        final IntentState prevTransient = transientStates.put(id, state);
-        log.debug("Transient State change: {} {}=>{}", id, prevTransient, state);
 
-        if (type == null) {
+        if (evtType == null) {
             return null;
         }
-        return new IntentEvent(type, intent);
+        return new IntentEvent(evtType, intent);
     }
 
     @Override