2 * Copyright (c) 2015 Intel, Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.groupbasedpolicy.neutron.mapper.mapping;
11 import static com.google.common.base.Preconditions.checkNotNull;
13 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
14 import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
15 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
16 import org.opendaylight.groupbasedpolicy.neutron.gbp.util.NeutronGbpIidFactory;
17 import org.opendaylight.groupbasedpolicy.neutron.mapper.util.Utils;
18 import org.opendaylight.groupbasedpolicy.util.DataStoreHelper;
19 import org.opendaylight.neutron.spi.INeutronFloatingIPAware;
20 import org.opendaylight.neutron.spi.INeutronPortCRUD;
21 import org.opendaylight.neutron.spi.NeutronCRUDInterfaces;
22 import org.opendaylight.neutron.spi.NeutronFloatingIP;
23 import org.opendaylight.neutron.spi.NeutronPort;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.UniqueId;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.EndpointService;
26 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;
27 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;
28 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;
29 import org.slf4j.Logger;
30 import org.slf4j.LoggerFactory;
32 import com.google.common.base.Strings;
34 public class NeutronFloatingIpAware implements INeutronFloatingIPAware {
36 public static final Logger LOG = LoggerFactory.getLogger(NeutronFloatingIpAware.class);
37 private final DataBroker dataProvider;
38 private final EndpointService epService;
40 public NeutronFloatingIpAware(DataBroker dataProvider, EndpointService epService) {
41 this.dataProvider = checkNotNull(dataProvider);
42 this.epService = checkNotNull(epService);
46 public int canCreateFloatingIP(NeutronFloatingIP floatingIP) {
47 LOG.trace("canCreateFloatingIP - {}", floatingIP);
52 public void neutronFloatingIPCreated(NeutronFloatingIP floatingIP) {
53 LOG.trace("neutronFloatingIPCreated - {}", floatingIP);
57 public int canUpdateFloatingIP(NeutronFloatingIP delta, NeutronFloatingIP original) {
58 LOG.trace("canUpdateFloatingIP - delta: {} original: {}", delta, original);
59 // floating IP UUID is same as device ID of a port representing floating IP
60 UniqueId floatingIpPortId = NeutronPortAware.getFloatingIpPortIdByDeviceId(original.getFloatingIPUUID());
61 if (floatingIpPortId == null) {
62 LOG.warn("Illegal state - Port representing floating ip where floating IP uuid is {} does not exist.",
63 original.getFloatingIPUUID());
64 return StatusCode.INTERNAL_SERVER_ERROR;
67 ReadWriteTransaction rwTx = dataProvider.newReadWriteTransaction();
68 String oldFixedIPAddress = Strings.nullToEmpty(original.getFixedIPAddress());
69 String oldPortUUID = Strings.nullToEmpty(original.getPortUUID());
70 String newFixedIPAddress = Strings.nullToEmpty(delta.getFixedIPAddress());
71 String newPortUUID = Strings.nullToEmpty(delta.getPortUUID());
72 if (oldFixedIPAddress.equals(newFixedIPAddress) && oldPortUUID.equals(newPortUUID)) {
73 // interesting fields were not changed
77 if ((!oldFixedIPAddress.isEmpty() && newFixedIPAddress.isEmpty())
78 || (!oldPortUUID.isEmpty() && newPortUUID.isEmpty())) {
79 DataStoreHelper.removeIfExists(LogicalDatastoreType.OPERATIONAL,
80 NeutronGbpIidFactory.internalPortByFloatingIpPortIid(floatingIpPortId), rwTx);
81 DataStoreHelper.removeIfExists(LogicalDatastoreType.OPERATIONAL,
82 NeutronGbpIidFactory.floatingIpPortByInternalPortIid(new UniqueId(oldPortUUID)), rwTx);
83 // TODO unregister EP representing floating ip port
84 } else if (!newFixedIPAddress.isEmpty() && !newPortUUID.isEmpty()) {
85 // workaround for https://bugs.opendaylight.org/show_bug.cgi?id=3368
86 // otherwise we will create port representing floating IP in NeutronPortAware
87 Integer errorCode = registerFloatingIpPort(original.getTenantUUID(), floatingIpPortId.getValue(), rwTx);
88 if (errorCode != null) {
93 UniqueId internalPortId = new UniqueId(newPortUUID);
94 InternalPortByFloatingIpPort internalPortByFloatingIpPort = new InternalPortByFloatingIpPortBuilder().setFloatingIpPortId(
96 .setFloatingIpPortIpAddress(Utils.createIpAddress(original.getFloatingIPAddress()))
97 .setInternalPortId(internalPortId)
98 .setInternalPortIpAddress(Utils.createIpAddress(newFixedIPAddress))
100 rwTx.put(LogicalDatastoreType.OPERATIONAL, NeutronGbpIidFactory.internalPortByFloatingIpPortIid(floatingIpPortId),
101 internalPortByFloatingIpPort, true);
102 rwTx.put(LogicalDatastoreType.OPERATIONAL, NeutronGbpIidFactory.floatingIpPortByInternalPortIid(internalPortId),
103 new FloatingIpPortByInternalPortBuilder(internalPortByFloatingIpPort).build(), true);
105 boolean isSubmitToDsSuccessful = DataStoreHelper.submitToDs(rwTx);
106 if (!isSubmitToDsSuccessful) {
107 return StatusCode.INTERNAL_SERVER_ERROR;
110 return StatusCode.OK;
113 private Integer registerFloatingIpPort(String tenantUUID, String floatingIpPortUUID, ReadWriteTransaction rwTx) {
114 NeutronCRUDInterfaces neutronCRUDInterface = new NeutronCRUDInterfaces().fetchINeutronPortCRUD(this);
115 INeutronPortCRUD portInterface = neutronCRUDInterface.getPortInterface();
116 if (portInterface == null) {
117 LOG.warn("Illegal state - No provider for {}", INeutronPortCRUD.class.getName());
118 return StatusCode.INTERNAL_SERVER_ERROR;
120 NeutronPort floatingIpPort = portInterface.getPort(floatingIpPortUUID);
121 // TenantId tenantId = new TenantId(Utils.normalizeUuid());
122 floatingIpPort.setTenantID(tenantUUID);
123 boolean isNeutronPortCreated = NeutronPortAware.addNeutronPort(floatingIpPort, rwTx, epService);
124 if (!isNeutronPortCreated) {
126 return StatusCode.INTERNAL_SERVER_ERROR;
132 public void neutronFloatingIPUpdated(NeutronFloatingIP floatingIP) {
133 LOG.trace("neutronFloatingIPUpdated - {}", floatingIP);
137 public int canDeleteFloatingIP(NeutronFloatingIP floatingIP) {
138 LOG.trace("canDeleteFloatingIP - {}", floatingIP);
139 return StatusCode.OK;
143 public void neutronFloatingIPDeleted(NeutronFloatingIP floatingIP) {
144 LOG.trace("neutronFloatingIPDeleted - {}", floatingIP);