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/trivial/src/main/java/org/onosproject/store/trivial/impl/SimpleIntentStore.java

diff --git a/core/store/trivial/src/main/java/org/onosproject/store/trivial/impl/SimpleIntentStore.java b/core/store/trivial/src/main/java/org/onosproject/store/trivial/impl/SimpleIntentStore.java
index 8fe8a11..186fdd9 100644
--- a/core/store/trivial/src/main/java/org/onosproject/store/trivial/impl/SimpleIntentStore.java
+++ b/core/store/trivial/src/main/java/org/onosproject/store/trivial/impl/SimpleIntentStore.java
@@ -15,6 +15,7 @@
  */
 package org.onosproject.store.trivial.impl;
 
+import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import org.apache.felix.scr.annotations.Activate;
 import org.apache.felix.scr.annotations.Component;
@@ -75,6 +76,16 @@
     }
 
     @Override
+    public Iterable<IntentData> getIntentData(boolean localOnly) {
+        if (localOnly) {
+            return current.values().stream()
+                    .filter(data -> isMaster(data.key()))
+                    .collect(Collectors.toList());
+        }
+        return Lists.newArrayList(current.values());
+    }
+
+    @Override
     public IntentState getIntentState(Key intentKey) {
         IntentData data = current.get(intentKey);
         return (data != null) ? data.state() : null;