IntentStores: only post Parking states
Change-Id: I7ed3f2e38d71b5a5f83a47d582326576b7da52f1
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 cbb385b..17b4430 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
@@ -451,10 +451,10 @@
builder.put(STATES_TABLE, strIntentId(intent.id()), serializer.encode(newState));
if (PARKING.contains(newState)) {
transitionedToParking.add(intent.id());
+ events.add(IntentEvent.getEvent(newState, intent));
} else {
transitionedToParking.remove(intent.id());
}
- events.add(IntentEvent.getEvent(newState, intent));
break;
case SET_INSTALLABLE:
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/intent/impl/HazelcastIntentStore.java b/core/store/dist/src/main/java/org/onlab/onos/store/intent/impl/HazelcastIntentStore.java
index f09a968..25a7bc0 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/intent/impl/HazelcastIntentStore.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/intent/impl/HazelcastIntentStore.java
@@ -490,8 +490,8 @@
if (PARKING.contains(newState)) {
transientStates.remove(intentId);
+ events.add(IntentEvent.getEvent(newState, intent));
}
- events.add(IntentEvent.getEvent(newState, intent));
log.trace("{} - {} -> {}", intentId, prevIntentState, newState);
// TODO sanity check and log?