commit 8abf2fea2726155d578d829b4c9494119e943b12
author Jian Li <pyguni@gmail.com> Tue Jun 12 18:42:30 2018 +0900
committer Jian Li <pyguni@gmail.com> Thu Jun 21 00:24:51 2018 +0000
tree ffd351775ac9fe7a13e8295f8e7ce2bc5971529f
parent c7b3c451c77458271c9fdfb196a5704da26399e1

Extend the SONA pipeline to support gathering vFlow stats

Change-Id: Iee5f5fbcd96fb9d23226e837bebf2c4699c063de

apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackFlowRuleManager.java

diff --git a/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackFlowRuleManager.java b/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackFlowRuleManager.java
index 48983e2..0a060ff 100644
--- a/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackFlowRuleManager.java
+++ b/apps/openstacknetworking/app/src/main/java/org/onosproject/openstacknetworking/impl/OpenstackFlowRuleManager.java
@@ -143,10 +143,12 @@
     }
 
     private void initializePipeline(DeviceId deviceId) {
+        connectTables(deviceId, Constants.STAT_INBOUND_TABLE, Constants.DHCP_ARP_TABLE);
         connectTables(deviceId, Constants.DHCP_ARP_TABLE, Constants.VTAG_TABLE);
         connectTables(deviceId, Constants.VTAG_TABLE, Constants.ACL_TABLE);
         connectTables(deviceId, Constants.ACL_TABLE, Constants.JUMP_TABLE);
         setupJumpTable(deviceId);
+        connectTables(deviceId, Constants.STAT_OUTBOUND_TABLE, Constants.FORWARDING_TABLE);
     }
 
     @Override
@@ -211,7 +213,7 @@
         selector = DefaultTrafficSelector.builder();
         treatment = DefaultTrafficTreatment.builder();
 
-        treatment.transition(Constants.FORWARDING_TABLE);
+        treatment.transition(Constants.STAT_OUTBOUND_TABLE);
 
         flowRule = DefaultFlowRule.builder()
                 .forDevice(deviceId)