commit 1b6f5688d094e39cdeb9af91d59f515541274dd7
author Yuta HIGUCHI <y-higuchi@onlab.us> Sat Oct 25 21:33:59 2014 -0700
committer Yuta HIGUCHI <y-higuchi@onlab.us> Sun Oct 26 19:44:55 2014 -0700
tree 765c317de7648579e34ecc6a7b0af7cda1dafa04
parent 00b476fadb4e2534498a37d3329b76eb0bcd7ec8

FlowStatsCollector: collect FlowStats on MASTER sw only

Change-Id: I4a7e808cceeaee209aaf22d85c9fa4dc069d8acc

providers/openflow/flow/src/main/java/org/onlab/onos/provider/of/flow/impl/FlowStatsCollector.java

diff --git a/providers/openflow/flow/src/main/java/org/onlab/onos/provider/of/flow/impl/FlowStatsCollector.java b/providers/openflow/flow/src/main/java/org/onlab/onos/provider/of/flow/impl/FlowStatsCollector.java
index 6c2997f..bd33884 100644
--- a/providers/openflow/flow/src/main/java/org/onlab/onos/provider/of/flow/impl/FlowStatsCollector.java
+++ b/providers/openflow/flow/src/main/java/org/onlab/onos/provider/of/flow/impl/FlowStatsCollector.java
@@ -8,6 +8,7 @@
 import org.jboss.netty.util.Timeout;
 import org.jboss.netty.util.TimerTask;
 import org.onlab.onos.openflow.controller.OpenFlowSwitch;
+import org.onlab.onos.openflow.controller.RoleState;
 import org.onlab.util.Timer;
 import org.projectfloodlight.openflow.protocol.OFFlowStatsRequest;
 import org.projectfloodlight.openflow.types.OFPort;
@@ -48,6 +49,13 @@
     }
 
     private void sendFlowStatistics() {
+        if (log.isTraceEnabled()) {
+            log.trace("sendFlowStatistics {}:{}", sw.getStringId(), sw.getRole());
+        }
+        if (sw.getRole() != RoleState.MASTER) {
+            // Switch not master.
+            return;
+        }
         OFFlowStatsRequest request = sw.factory().buildFlowStatsRequest()
                 .setMatch(sw.factory().matchWildcardAll())
                 .setTableId(TableId.ALL)