commit 64def641afae1d7a9dda5899d79a550911d9bb22
author alshabib <alshabibi.ali@gmail.com> Tue Dec 02 23:27:37 2014 -0800
committer Gerrit Code Review <gerrit@onlab.us> Wed Dec 03 09:07:40 2014 +0000
tree 7d194b085780ce073bed2742a30f4a062630976f
parent 0d5cb94e42a1ab2fd0eff81396ff9fa0af835dcd

aggregate flow replies on io thread

Change-Id: I622290f213ee830cfab7e4bd4ad7a52f612b475e

core/net/src/main/java/org/onosproject/net/flow/impl/FlowRuleManager.java

diff --git a/core/net/src/main/java/org/onosproject/net/flow/impl/FlowRuleManager.java b/core/net/src/main/java/org/onosproject/net/flow/impl/FlowRuleManager.java
index 2611a6d..d681524 100644
--- a/core/net/src/main/java/org/onosproject/net/flow/impl/FlowRuleManager.java
+++ b/core/net/src/main/java/org/onosproject/net/flow/impl/FlowRuleManager.java
@@ -355,7 +355,7 @@
 
         @Override
         public void pushFlowMetrics(DeviceId deviceId, Iterable<FlowEntry> flowEntries) {
-            List<FlowEntry> storedRules = Lists.newLinkedList(store.getFlowEntries(deviceId));
+            Set<FlowEntry> storedRules = Sets.newHashSet(store.getFlowEntries(deviceId));
 
             for (FlowEntry rule : flowEntries) {
                 if (storedRules.remove(rule)) {