BgpRouter: Added treatment to delete flows

Deleting routes now works.

Change-Id: I7ed682474e571aa2f402a1762a2037190c2d9284

@@ -211,18 +211,7 @@ public class BgpRouter {
     }
     }
 
 
     private void installFlow(FibEntry entry, Group group) {
     private void installFlow(FibEntry entry, Group group) {
-        TrafficSelector selector = DefaultTrafficSelector.builder()
-                .matchEthType(Ethernet.TYPE_IPV4)
-                .matchIPDst(entry.prefix())
-                .build();
-
-        TrafficTreatment treatment = DefaultTrafficTreatment.builder()
-                .group(group.id())
-                .build();
-
-        FlowRule flowRule = new DefaultFlowRule(deviceId, selector, treatment,
-                                                PRIORITY, appId, 0, true,
-                                                FlowRule.Type.IP);
+        FlowRule flowRule = generateRibFlowRule(entry.prefix(), group);
 
 
         flowService.applyFlowRules(flowRule);
         flowService.applyFlowRules(flowRule);
     }
     }
@@ -231,19 +220,31 @@ public class BgpRouter {
         for (FibUpdate update : withdraws) {
         for (FibUpdate update : withdraws) {
             FibEntry entry = update.entry();
             FibEntry entry = update.entry();
 
 
-            deleteNextHop(entry.prefix());
+            Group group = deleteNextHop(entry.prefix());
+            if (group == null) {
+                log.warn("Group not found when deleting {}", entry);
+                return;
+            }
+
+            FlowRule flowRule = generateRibFlowRule(entry.prefix(), group);
 
 
+            flowService.removeFlowRules(flowRule);
+        }
+    }
+
+    private FlowRule generateRibFlowRule(IpPrefix prefix, Group group) {
         TrafficSelector selector = DefaultTrafficSelector.builder()
         TrafficSelector selector = DefaultTrafficSelector.builder()
                 .matchEthType(Ethernet.TYPE_IPV4)
                 .matchEthType(Ethernet.TYPE_IPV4)
-                    .matchIPDst(update.entry().prefix())
+                .matchIPDst(prefix)
+                .build();
+
+        TrafficTreatment treatment = DefaultTrafficTreatment.builder()
+                .group(group.id())
                 .build();
                 .build();
 
 
-            FlowRule flowRule = new DefaultFlowRule(deviceId, selector, null,
+        return new DefaultFlowRule(deviceId, selector, treatment,
                                    PRIORITY, appId, 0, true,
                                    PRIORITY, appId, 0, true,
                                    FlowRule.Type.IP);
                                    FlowRule.Type.IP);
-
-            flowService.removeFlowRules(flowRule);
-        }
     }
     }
 
 
     private synchronized void addNextHop(FibEntry entry) {
     private synchronized void addNextHop(FibEntry entry) {
@@ -288,14 +289,16 @@ public class BgpRouter {
         nextHopsCount.add(entry.nextHopIp());
         nextHopsCount.add(entry.nextHopIp());
     }
     }
 
 
-    private synchronized void deleteNextHop(IpPrefix prefix) {
+    private synchronized Group deleteNextHop(IpPrefix prefix) {
         IpAddress nextHopIp = prefixToNextHop.remove(prefix);
         IpAddress nextHopIp = prefixToNextHop.remove(prefix);
         NextHop nextHop = nextHops.get(nextHopIp);
         NextHop nextHop = nextHops.get(nextHopIp);
         if (nextHop == null) {
         if (nextHop == null) {
             log.warn("No next hop found when removing prefix {}", prefix);
             log.warn("No next hop found when removing prefix {}", prefix);
-            return;
+            return null;
         }
         }
 
 
+        Group group = groupService.getGroup(deviceId, nextHop.group());
+
         if (nextHopsCount.remove(nextHopIp, 1) <= 1) {
         if (nextHopsCount.remove(nextHopIp, 1) <= 1) {
             // There was one or less next hops, so there are now none
             // There was one or less next hops, so there are now none
 
 
@@ -305,6 +308,8 @@ public class BgpRouter {
 
 
             groupService.removeGroup(deviceId, nextHop.group(), appId);
             groupService.removeGroup(deviceId, nextHop.group(), appId);
         }
         }
+
+        return group;
     }
     }
 
 
     private class InternalFibListener implements FibListener {
     private class InternalFibListener implements FibListener {

@@ -180,6 +180,7 @@ public class FlowModBuilderVer13 extends FlowModBuilder {
                 .setMatch(match)
                 .setMatch(match)
                 .setFlags(Collections.singleton(OFFlowModFlags.SEND_FLOW_REM))
                 .setFlags(Collections.singleton(OFFlowModFlags.SEND_FLOW_REM))
                 .setPriority(flowRule().priority())
                 .setPriority(flowRule().priority())
+                .setTableId(TableId.of(flowRule().type().ordinal()))
                 .build();
                 .build();
 
 
         return fm;
         return fm;