| commit | 075e3e75f622a9cca8f3ea1bcf9c50fac8dc322d | [log] [tgz] |
|---|---|---|
| author | sanghoshin <sangho@onlab.us> | Wed Nov 25 16:34:29 2015 +0900 |
| committer | Gerrit Code Review <gerrit@onlab.us> | Tue Dec 08 05:26:22 2015 +0000 |
| tree | 0ac755bec24a497ef47ab6b414d99028cbace2cd | |
| parent | 11d1609a5f6b284474c98ec5ea43fdac54dc6ac2 [diff] [blame] |
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
diff --git a/apps/openstackswitching/app/src/main/java/org/onosproject/openstackswitching/OpenstackSwitchingRulePopulator.java b/apps/openstackswitching/app/src/main/java/org/onosproject/openstackswitching/OpenstackSwitchingRulePopulator.java index 38c0363..3d1e3fb 100644 --- a/apps/openstackswitching/app/src/main/java/org/onosproject/openstackswitching/OpenstackSwitchingRulePopulator.java +++ b/apps/openstackswitching/app/src/main/java/org/onosproject/openstackswitching/OpenstackSwitchingRulePopulator.java
@@ -99,6 +99,18 @@ } /** + * 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. * * @param device device to put the rules