commit 7e40c011188aed1520c306df112931d4bd36a46d
author Patryk Konopka <p.konopka2@samsung.com> Tue Jun 06 13:38:06 2017 +0200
committer Yuta HIGUCHI <y-higuchi@opennetworking.org> Tue Jun 20 15:43:27 2017 +0000
tree a2be7af224a4f007c5c4108c2be9649f2affab58
parent 644472eaf9294f909c937cf99393856adee84fee

 [ONOS-6607] Get active flow entries count in FlowRuleService

Change-Id: I68b4d916f92427c06a82d3622fcc05738f64541c

core/store/dist/src/main/java/org/onosproject/store/flow/impl/DistributedFlowRuleStore.java

diff --git a/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DistributedFlowRuleStore.java b/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DistributedFlowRuleStore.java
index af388bab..0f7e980 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DistributedFlowRuleStore.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/flow/impl/DistributedFlowRuleStore.java
@@ -31,6 +31,7 @@
  import java.util.concurrent.atomic.AtomicReference;
  import java.util.stream.Collectors;
 
+ import com.google.common.collect.Streams;
  import org.apache.felix.scr.annotations.Activate;
  import org.apache.felix.scr.annotations.Component;
  import org.apache.felix.scr.annotations.Deactivate;
@@ -926,6 +927,13 @@
         return ImmutableList.copyOf(tableStats);
     }
 
+    @Override
+    public long getActiveFlowRuleCount(DeviceId deviceId) {
+        return Streams.stream(getTableStatistics(deviceId))
+                .mapToLong(TableStatisticsEntry::activeFlowEntries)
+                .sum();
+    }
+
     private class InternalTableStatsListener
         implements EventuallyConsistentMapListener<DeviceId, List<TableStatisticsEntry>> {
         @Override