neutron-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/mapper/mapping/NeutronSubnetAware.java

   1 /*
   2  * Copyright (c) 2015 Cisco Systems, Inc. and others. All rights reserved.
   3  *
   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
   7  */
   8 package org.opendaylight.groupbasedpolicy.neutron.mapper.mapping;
   9
  10 import static com.google.common.base.Preconditions.checkNotNull;
  11
  12 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  13 import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
  14 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  15 import org.opendaylight.groupbasedpolicy.neutron.mapper.EndpointRegistrator;
  16 import org.opendaylight.groupbasedpolicy.neutron.mapper.util.MappingUtils;
  17 import org.opendaylight.groupbasedpolicy.neutron.mapper.util.NetworkUtils;
  18 import org.opendaylight.groupbasedpolicy.neutron.mapper.util.Utils;
  19 import org.opendaylight.groupbasedpolicy.util.DataStoreHelper;
  20 import org.opendaylight.groupbasedpolicy.util.IidFactory;
  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.ContextId;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.L3ContextId;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.Name;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.SubnetId;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.TenantId;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.forwarding.context.Subnet;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.forwarding.context.SubnetBuilder;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.networks.attributes.networks.Network;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.subnets.rev150712.subnets.attributes.Subnets;
  32 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  33 import org.slf4j.Logger;
  34 import org.slf4j.LoggerFactory;
  35
  36 import com.google.common.base.Optional;
  37 import com.google.common.base.Strings;
  38
  39 public class NeutronSubnetAware implements
  40         NeutronAware<org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.subnets.rev150712.subnets.attributes.subnets.Subnet> {
  41
  42     private final static Logger LOG = LoggerFactory.getLogger(NeutronSubnetAware.class);
  43     public static final InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.subnets.rev150712.subnets.attributes.subnets.Subnet> SUBNET_WILDCARD_IID =
  44             InstanceIdentifier.builder(Neutron.class)
  45                 .child(Subnets.class)
  46                 .child(org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.subnets.rev150712.subnets.attributes.subnets.Subnet.class)
  47                 .build();
  48     private final DataBroker dataProvider;
  49     private final EndpointRegistrator epRegistrator;
  50
  51     public NeutronSubnetAware(DataBroker dataProvider, EndpointRegistrator epRegistrator) {
  52         this.dataProvider = checkNotNull(dataProvider);
  53         this.epRegistrator = checkNotNull(epRegistrator);
  54     }
  55
  56     @Override
  57     public void onCreated(
  58             org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.subnets.rev150712.subnets.attributes.subnets.Subnet neutronSubnet,
  59             Neutron neutron) {
  60         LOG.trace("created subnet - {}", neutronSubnet);
  61         ReadWriteTransaction rwTx = dataProvider.newReadWriteTransaction();
  62         TenantId tenantId = new TenantId(neutronSubnet.getTenantId().getValue());
  63
  64         Optional<Network> potentialNetwork =
  65                 NetworkUtils.findNetwork(neutronSubnet.getNetworkId(), neutron.getNetworks());
  66         if (!potentialNetwork.isPresent()) {
  67             LOG.warn("Illegal state - network {} does not exist for subnet {}.",
  68                     neutronSubnet.getNetworkId().getValue(), neutronSubnet);
  69             rwTx.cancel();
  70             return;
  71         }
  72
  73         Network networkOfSubnet = potentialNetwork.get();
  74         Subnet subnet = null;
  75         if (NetworkUtils.isProviderPhysicalNetwork(networkOfSubnet)) {
  76             // add virtual router IP only in case it is provider physical network
  77             subnet = createSubnet(neutronSubnet, neutronSubnet.getGatewayIp());
  78             IpAddress gatewayIp = neutronSubnet.getGatewayIp();
  79             boolean registeredDefaultRoute = epRegistrator.registerExternalL3PrefixEndpoint(MappingUtils.DEFAULT_ROUTE,
  80                     new L3ContextId(neutronSubnet.getNetworkId().getValue()), gatewayIp, tenantId);
  81             if (!registeredDefaultRoute) {
  82                 LOG.warn("Could not add EndpointL3Prefix as default route. Subnet within provider physical network {}",
  83                         neutronSubnet);
  84                 rwTx.cancel();
  85                 return;
  86             }
  87         } else if (NetworkUtils.isRouterExternal(networkOfSubnet)) {
  88             // virtual router IP is not set and it will be set when router gateway port is set
  89             subnet = createSubnet(neutronSubnet, null);
  90         } else {
  91             // virtual router IP is not set and it will be set when router port is attached to
  92             // network
  93             subnet = createSubnet(neutronSubnet, null);
  94         }
  95         rwTx.put(LogicalDatastoreType.CONFIGURATION, IidFactory.subnetIid(tenantId, subnet.getId()), subnet, true);
  96
  97         DataStoreHelper.submitToDs(rwTx);
  98     }
  99
 100     public static Subnet createSubnet(
 101             org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.subnets.rev150712.subnets.attributes.subnets.Subnet neutronSubnet,
 102             IpAddress virtualRouterIp) {
 103         SubnetBuilder subnetBuilder = new SubnetBuilder();
 104         subnetBuilder.setId(new SubnetId(neutronSubnet.getUuid().getValue()));
 105         subnetBuilder.setParent(new ContextId(neutronSubnet.getNetworkId().getValue()));
 106         if (!Strings.isNullOrEmpty(neutronSubnet.getName())) {
 107             try {
 108                 subnetBuilder.setName(new Name(neutronSubnet.getName()));
 109             } catch (Exception e) {
 110                 LOG.info("Name '{}' of Neutron Subnet '{}' is ignored.", neutronSubnet.getName(),
 111                         neutronSubnet.getUuid().getValue());
 112                 LOG.debug("Name exception", e);
 113             }
 114         }
 115         subnetBuilder.setIpPrefix(Utils.createIpPrefix(neutronSubnet.getCidr()));
 116         subnetBuilder.setVirtualRouterIp(virtualRouterIp);
 117         return subnetBuilder.build();
 118     }
 119
 120     @Override
 121     public void onUpdated(
 122             org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.subnets.rev150712.subnets.attributes.subnets.Subnet oldItem,
 123             org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.subnets.rev150712.subnets.attributes.subnets.Subnet newItem,
 124             Neutron oldNeutron, Neutron newNeutron) {
 125         LOG.trace("updated subnet - {}", newItem);
 126         onCreated(newItem, newNeutron);
 127     }
 128
 129     @Override
 130     public void onDeleted(
 131             org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.subnets.rev150712.subnets.attributes.subnets.Subnet neutronSubnet,
 132             Neutron oldNeutron, Neutron newNeutron) {
 133         LOG.trace("deleted subnet - {}", neutronSubnet);
 134         ReadWriteTransaction rwTx = dataProvider.newReadWriteTransaction();
 135         SubnetId subnetId = new SubnetId(neutronSubnet.getUuid().getValue());
 136         TenantId tenantId = new TenantId(neutronSubnet.getTenantId().getValue());
 137         Optional<Subnet> potentialSubnet = DataStoreHelper.removeIfExists(LogicalDatastoreType.CONFIGURATION,
 138                 IidFactory.subnetIid(tenantId, subnetId), rwTx);
 139         if (!potentialSubnet.isPresent()) {
 140             LOG.warn("Illegal state - subnet {} does not exist.", subnetId.getValue());
 141             rwTx.cancel();
 142             return;
 143         }
 144
 145         // TODO remove default gateway EP in case when subnet is in provider physical network
 146
 147         DataStoreHelper.submitToDs(rwTx);
 148     }
 149
 150 }