commit b4f850812ec57895282b06d5834289f35f77e000
author Hyunsun Moon <hyunsun.moon@gmail.com> Fri Jan 15 20:11:41 2016 -0800
committer Gerrit Code Review <gerrit@onlab.us> Mon Jan 18 22:16:26 2016 +0000
tree 1326f5c9fd44a99de58287fa09e6f7e8fc96bf4a
parent b3fa42c01984389b5d9eec61133e5457164b3743

CORD-472 Added additional flow rules for physical connection

Change-Id: Ic6d37024e4407182a440fbe68460e7688ecb6305

apps/cordvtn/src/main/java/org/onosproject/cordvtn/CordVtnRuleInstaller.java

diff --git a/apps/cordvtn/src/main/java/org/onosproject/cordvtn/CordVtnRuleInstaller.java b/apps/cordvtn/src/main/java/org/onosproject/cordvtn/CordVtnRuleInstaller.java
index ef310c7..36767ea 100644
--- a/apps/cordvtn/src/main/java/org/onosproject/cordvtn/CordVtnRuleInstaller.java
+++ b/apps/cordvtn/src/main/java/org/onosproject/cordvtn/CordVtnRuleInstaller.java
@@ -441,6 +441,51 @@
 
         processFlowRule(true, flowRule);
 
+        // take a packet to the local ip through Linux stack
+        selector = DefaultTrafficSelector.builder()
+                .matchInPort(phyPort)
+                .matchEthType(Ethernet.TYPE_IPV4)
+                .matchIPDst(localIp.toIpPrefix())
+                .build();
+
+        treatment = DefaultTrafficTreatment.builder()
+                .setOutput(PortNumber.LOCAL)
+                .build();
+
+        flowRule = DefaultFlowRule.builder()
+                .fromApp(appId)
+                .withSelector(selector)
+                .withTreatment(treatment)
+                .withPriority(HIGHER_PRIORITY)
+                .forDevice(deviceId)
+                .forTable(TABLE_FIRST)
+                .makePermanent()
+                .build();
+
+        processFlowRule(true, flowRule);
+
+        // take an arp packet from physical through Linux stack
+        selector = DefaultTrafficSelector.builder()
+                .matchInPort(phyPort)
+                .matchEthType(Ethernet.TYPE_ARP)
+                .build();
+
+        treatment = DefaultTrafficTreatment.builder()
+                .setOutput(PortNumber.LOCAL)
+                .build();
+
+        flowRule = DefaultFlowRule.builder()
+                .fromApp(appId)
+                .withSelector(selector)
+                .withTreatment(treatment)
+                .withPriority(HIGHER_PRIORITY)
+                .forDevice(deviceId)
+                .forTable(TABLE_FIRST)
+                .makePermanent()
+                .build();
+
+        processFlowRule(true, flowRule);
+
         // take all else to the next table
         selector = DefaultTrafficSelector.builder()
                 .build();