SONA: OpenstackSwitching - init flow rules

 - Populates flow rules when the app is initialized for existing VMs
 - Add the IP mappings for the existing VMs to DHCP service.

Change-Id: Ie73c2532c83b0c0df21261616d7af81744c0aa32

@@ -214,6 +214,30 @@ public class OpenstackSwitchingManager implements OpenstackSwitchingService {
         log.debug("port {} is removed", port.toString());
         log.debug("port {} is removed", port.toString());
     }
     }
 
 
+    private void initializeFlowRules() {
+        OpenstackSwitchingRulePopulator rulePopulator =
+                new OpenstackSwitchingRulePopulator(appId, flowObjectiveService,
+                        deviceService, restHandler, driverService);
+
+        deviceService.getDevices().forEach(device -> {
+                    log.debug("device {} num of ports {} ", device.id(),
+                            deviceService.getPorts(device.id()).size());
+                    deviceService.getPorts(device.id()).stream()
+                            .filter(port -> port.annotations().value("portName").startsWith("tap"))
+                            .forEach(vmPort -> {
+                                        OpenstackPort osPort = rulePopulator.openstackPort(vmPort);
+                                        if (osPort != null) {
+                                            rulePopulator.populateSwitchingRules(device, vmPort);
+                                            registerDhcpInfo(osPort);
+                                        } else {
+                                            log.warn("No openstackPort information for port {}", vmPort);
+                                        }
+                                    }
+                            );
+                }
+        );
+    }
+
     private void registerDhcpInfo(OpenstackPort openstackPort) {
     private void registerDhcpInfo(OpenstackPort openstackPort) {
         Ip4Address ip4Address;
         Ip4Address ip4Address;
         Ip4Address subnetMask;
         Ip4Address subnetMask;
@@ -343,6 +367,7 @@ public class OpenstackSwitchingManager implements OpenstackSwitchingService {
             doNotPushFlows = cfg.doNotPushFlows();
             doNotPushFlows = cfg.doNotPushFlows();
             restHandler = new OpenstackRestHandler(cfg);
             restHandler = new OpenstackRestHandler(cfg);
             arpHandler = new OpenstackArpHandler(restHandler, packetService);
             arpHandler = new OpenstackArpHandler(restHandler, packetService);
+            initializeFlowRules();
         }
         }
 
 
         @Override
         @Override

@@ -99,6 +99,18 @@ public class OpenstackSwitchingRulePopulator {
     }
     }
 
 
     /**
     /**
+     * Returns OpenstackPort object for the Port reference given.
+     *
+     * @param port Port object
+     * @return OpenstackPort reference, or null when not found
+     */
+    public OpenstackPort openstackPort(Port port) {
+        String uuid = port.annotations().value("portName").substring(3);
+        return openstackPortList.stream().filter(p -> p.id().startsWith(uuid))
+                .findAny().orElse(null);
+    }
+
+    /**
      * Populates the flow rules for traffic to VMs in the same Cnode as the sender.
      * Populates the flow rules for traffic to VMs in the same Cnode as the sender.
      *
      *
      * @param device device to put the rules
      * @param device device to put the rules