Fix copyright header

[groupbasedpolicy.git] / neutron-mapper / src / main / java / org / opendaylight / groupbasedpolicy / neutron / mapper / mapping / NeutronFloatingIpAware.java

diff --git a/neutron-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/mapper/mapping/NeutronFloatingIpAware.java b/neutron-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/mapper/mapping/NeutronFloatingIpAware.java
index ffecbb38ad06af45a8183f42e23683ae191e8a73..f71c3b68b6c3c57ace409b68cb15424aec099e99 100644 (file)
--- a/neutron-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/mapper/mapping/NeutronFloatingIpAware.java
+++ b/neutron-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/mapper/mapping/NeutronFloatingIpAware.java
@@ -1,21 +1,45 @@
+/*
+ * Copyright (c) 2015 Intel, Cisco Systems, Inc. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
 package org.opendaylight.groupbasedpolicy.neutron.mapper.mapping;
 
+import static com.google.common.base.Preconditions.checkNotNull;
+
 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
+import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
+import org.opendaylight.groupbasedpolicy.neutron.gbp.util.NeutronGbpIidFactory;
+import org.opendaylight.groupbasedpolicy.neutron.mapper.util.Utils;
+import org.opendaylight.groupbasedpolicy.util.DataStoreHelper;
 import org.opendaylight.neutron.spi.INeutronFloatingIPAware;
+import org.opendaylight.neutron.spi.INeutronPortCRUD;
+import org.opendaylight.neutron.spi.NeutronCRUDInterfaces;
 import org.opendaylight.neutron.spi.NeutronFloatingIP;
+import org.opendaylight.neutron.spi.NeutronPort;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.UniqueId;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.EndpointService;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.floating.ip.association.mappings.floating.ip.ports.by.internal.ports.FloatingIpPortByInternalPortBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.floating.ip.association.mappings.internal.ports.by.floating.ip.ports.InternalPortByFloatingIpPort;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.floating.ip.association.mappings.internal.ports.by.floating.ip.ports.InternalPortByFloatingIpPortBuilder;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import com.google.common.base.Preconditions;
-
+import com.google.common.base.Strings;
 
 public class NeutronFloatingIpAware implements INeutronFloatingIPAware {
 
     public static final Logger LOG = LoggerFactory.getLogger(NeutronFloatingIpAware.class);
     private final DataBroker dataProvider;
+    private final EndpointService epService;
 
-    public NeutronFloatingIpAware(DataBroker dataProvider) {
-        this.dataProvider = Preconditions.checkNotNull(dataProvider);
+    public NeutronFloatingIpAware(DataBroker dataProvider, EndpointService epService) {
+        this.dataProvider = checkNotNull(dataProvider);
+        this.epService = checkNotNull(epService);
     }
 
     @Override
@@ -32,9 +56,78 @@ public class NeutronFloatingIpAware implements INeutronFloatingIPAware {
     @Override
     public int canUpdateFloatingIP(NeutronFloatingIP delta, NeutronFloatingIP original) {
         LOG.trace("canUpdateFloatingIP - delta: {} original: {}", delta, original);
+        // floating IP UUID is same as device ID of a port representing floating IP
+        UniqueId floatingIpPortId = NeutronPortAware.getFloatingIpPortIdByDeviceId(original.getFloatingIPUUID());
+        if (floatingIpPortId == null) {
+            LOG.warn("Illegal state - Port representing floating ip where floating IP uuid is {} does not exist.",
+                    original.getFloatingIPUUID());
+            return StatusCode.INTERNAL_SERVER_ERROR;
+        }
+
+        ReadWriteTransaction rwTx = dataProvider.newReadWriteTransaction();
+        String oldFixedIPAddress = Strings.nullToEmpty(original.getFixedIPAddress());
+        String oldPortUUID = Strings.nullToEmpty(original.getPortUUID());
+        String newFixedIPAddress = Strings.nullToEmpty(delta.getFixedIPAddress());
+        String newPortUUID = Strings.nullToEmpty(delta.getPortUUID());
+        if (oldFixedIPAddress.equals(newFixedIPAddress) && oldPortUUID.equals(newPortUUID)) {
+            // interesting fields were not changed
+            return StatusCode.OK;
+        }
+
+        if ((!oldFixedIPAddress.isEmpty() && newFixedIPAddress.isEmpty())
+                || (!oldPortUUID.isEmpty() && newPortUUID.isEmpty())) {
+            DataStoreHelper.removeIfExists(LogicalDatastoreType.OPERATIONAL,
+                    NeutronGbpIidFactory.internalPortByFloatingIpPortIid(floatingIpPortId), rwTx);
+            DataStoreHelper.removeIfExists(LogicalDatastoreType.OPERATIONAL,
+                    NeutronGbpIidFactory.floatingIpPortByInternalPortIid(new UniqueId(oldPortUUID)), rwTx);
+            // TODO unregister EP representing floating ip port
+        } else if (!newFixedIPAddress.isEmpty() && !newPortUUID.isEmpty()) {
+            // workaround for https://bugs.opendaylight.org/show_bug.cgi?id=3368
+            // otherwise we will create port representing floating IP in NeutronPortAware
+            Integer errorCode = registerFloatingIpPort(original.getTenantUUID(), floatingIpPortId.getValue(), rwTx);
+            if (errorCode != null) {
+                rwTx.cancel();
+                return errorCode;
+            }
+
+            UniqueId internalPortId = new UniqueId(newPortUUID);
+            InternalPortByFloatingIpPort internalPortByFloatingIpPort = new InternalPortByFloatingIpPortBuilder().setFloatingIpPortId(
+                    floatingIpPortId)
+                .setFloatingIpPortIpAddress(Utils.createIpAddress(original.getFloatingIPAddress()))
+                .setInternalPortId(internalPortId)
+                .setInternalPortIpAddress(Utils.createIpAddress(newFixedIPAddress))
+                .build();
+            rwTx.put(LogicalDatastoreType.OPERATIONAL, NeutronGbpIidFactory.internalPortByFloatingIpPortIid(floatingIpPortId),
+                    internalPortByFloatingIpPort, true);
+            rwTx.put(LogicalDatastoreType.OPERATIONAL, NeutronGbpIidFactory.floatingIpPortByInternalPortIid(internalPortId),
+                    new FloatingIpPortByInternalPortBuilder(internalPortByFloatingIpPort).build(), true);
+        }
+        boolean isSubmitToDsSuccessful = DataStoreHelper.submitToDs(rwTx);
+        if (!isSubmitToDsSuccessful) {
+            return StatusCode.INTERNAL_SERVER_ERROR;
+        }
+
         return StatusCode.OK;
     }
 
+    private Integer registerFloatingIpPort(String tenantUUID, String floatingIpPortUUID, ReadWriteTransaction rwTx) {
+        NeutronCRUDInterfaces neutronCRUDInterface = new NeutronCRUDInterfaces().fetchINeutronPortCRUD(this);
+        INeutronPortCRUD portInterface = neutronCRUDInterface.getPortInterface();
+        if (portInterface == null) {
+            LOG.warn("Illegal state - No provider for {}", INeutronPortCRUD.class.getName());
+            return StatusCode.INTERNAL_SERVER_ERROR;
+        }
+        NeutronPort floatingIpPort = portInterface.getPort(floatingIpPortUUID);
+        // TenantId tenantId = new TenantId(Utils.normalizeUuid());
+        floatingIpPort.setTenantID(tenantUUID);
+        boolean isNeutronPortCreated = NeutronPortAware.addNeutronPort(floatingIpPort, rwTx, epService);
+        if (!isNeutronPortCreated) {
+            rwTx.cancel();
+            return StatusCode.INTERNAL_SERVER_ERROR;
+        }
+        return null;
+    }
+
     @Override
     public void neutronFloatingIPUpdated(NeutronFloatingIP floatingIP) {
         LOG.trace("neutronFloatingIPUpdated - {}", floatingIP);