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.mapper.util.Utils;
17 import org.opendaylight.groupbasedpolicy.util.DataStoreHelper;
18 import org.opendaylight.groupbasedpolicy.util.IidFactory;
19 import org.opendaylight.neutron.spi.INeutronFloatingIPAware;
20 import org.opendaylight.neutron.spi.NeutronFloatingIP;
21 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpAddress;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.L3ContextId;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.l3endpoint.rev151217.NatAddress;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.l3endpoint.rev151217.NatAddressBuilder;
25 import org.slf4j.Logger;
26 import org.slf4j.LoggerFactory;
28 import com.google.common.base.Strings;
30 public class NeutronFloatingIpAware implements INeutronFloatingIPAware {
32 public static final Logger LOG = LoggerFactory.getLogger(NeutronFloatingIpAware.class);
33 private final DataBroker dataProvider;
35 public NeutronFloatingIpAware(DataBroker dataProvider) {
36 this.dataProvider = checkNotNull(dataProvider);
40 public int canCreateFloatingIP(NeutronFloatingIP floatingIP) {
41 LOG.trace("canCreateFloatingIP - {}", floatingIP);
46 public void neutronFloatingIPCreated(NeutronFloatingIP floatingIP) {
47 LOG.trace("neutronFloatingIPCreated - {}", floatingIP);
51 public int canUpdateFloatingIP(NeutronFloatingIP delta, NeutronFloatingIP original) {
52 LOG.trace("canUpdateFloatingIP - delta: {} original: {}", delta, original);
53 String oldFixedIPAddress = Strings.nullToEmpty(original.getFixedIPAddress());
54 String newFixedIPAddress = Strings.nullToEmpty(delta.getFixedIPAddress());
55 if (oldFixedIPAddress.equals(newFixedIPAddress)) {
56 // interesting fields were not changed
60 ReadWriteTransaction rwTx = dataProvider.newReadWriteTransaction();
61 L3ContextId routerL3Context = new L3ContextId(delta.getRouterUUID());
62 String newFloatingIp = Strings.nullToEmpty(delta.getFloatingIPAddress());
63 if (!newFixedIPAddress.isEmpty() && !newFloatingIp.isEmpty()) {
64 IpAddress epIp = Utils.createIpAddress(newFixedIPAddress);
65 IpAddress epNatIp = Utils.createIpAddress(newFloatingIp);
66 NatAddress nat = new NatAddressBuilder().setNatAddress(epNatIp).build();
67 rwTx.put(LogicalDatastoreType.OPERATIONAL,
68 IidFactory.l3EndpointIid(routerL3Context, epIp).augmentation(NatAddress.class), nat, true);
70 if (!oldFixedIPAddress.isEmpty()) {
71 DataStoreHelper.removeIfExists(LogicalDatastoreType.OPERATIONAL,
72 IidFactory.l3EndpointIid(routerL3Context, Utils.createIpAddress(oldFixedIPAddress))
73 .augmentation(NatAddress.class),
77 boolean isSubmitToDsSuccessful = DataStoreHelper.submitToDs(rwTx);
78 if (!isSubmitToDsSuccessful) {
79 return StatusCode.INTERNAL_SERVER_ERROR;
86 public void neutronFloatingIPUpdated(NeutronFloatingIP floatingIP) {
87 LOG.trace("neutronFloatingIPUpdated - {}", floatingIP);
91 public int canDeleteFloatingIP(NeutronFloatingIP floatingIP) {
92 LOG.trace("canDeleteFloatingIP - {}", floatingIP);
97 public void neutronFloatingIPDeleted(NeutronFloatingIP floatingIP) {
98 LOG.trace("neutronFloatingIPDeleted - {}", floatingIP);