commit 3c58e969208f693c20c45a4151683e6e8f1bf0a9
author Brian O'Connor <bocon@onlab.us> Tue Apr 28 23:21:51 2015 -0700
committer Gerrit Code Review <gerrit@onlab.us> Thu Apr 30 03:44:11 2015 +0000
tree d6ae8cc9c1f580eea2cdbe929e93150672b86250
parent a2ae42256babd89a313de12eae62ffadd38e04cc

Adding IntentCleanup as a component.

Listens for CORRUPT intent events and periodically polls for CORRUPT intents.

Change-Id: I29d8dbe14b46522815dc13e969f259f68b690855

core/store/dist/src/main/java/org/onosproject/store/intent/impl/GossipIntentStore.java

diff --git a/core/store/dist/src/main/java/org/onosproject/store/intent/impl/GossipIntentStore.java b/core/store/dist/src/main/java/org/onosproject/store/intent/impl/GossipIntentStore.java
index fc2e8e3..4f0ad66 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/intent/impl/GossipIntentStore.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/intent/impl/GossipIntentStore.java
@@ -132,6 +132,16 @@
     }
 
     @Override
+    public Iterable<IntentData> getIntentData(boolean localOnly) {
+        if (localOnly) {
+            return currentMap.values().stream()
+                    .filter(data -> isMaster(data.key()))
+                    .collect(Collectors.toList());
+        }
+        return currentMap.values();
+    }
+
+    @Override
     public IntentState getIntentState(Key intentKey) {
         IntentData data = currentMap.get(intentKey);
         if (data != null) {