neutron-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/mapper/mapping/NeutronNetworkAware.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 java.util.HashSet;
  13 import java.util.Set;
  14
  15 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  16 import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
  17 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
  18 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  19 import org.opendaylight.groupbasedpolicy.domain_extension.l2_l3.util.L2L3IidFactory;
  20 import org.opendaylight.groupbasedpolicy.neutron.gbp.util.NeutronGbpIidFactory;
  21 import org.opendaylight.groupbasedpolicy.neutron.mapper.infrastructure.NetworkClient;
  22 import org.opendaylight.groupbasedpolicy.neutron.mapper.infrastructure.NetworkService;
  23 import org.opendaylight.groupbasedpolicy.neutron.mapper.util.MappingUtils;
  24 import org.opendaylight.groupbasedpolicy.neutron.mapper.util.NetworkUtils;
  25 import org.opendaylight.groupbasedpolicy.util.DataStoreHelper;
  26 import org.opendaylight.groupbasedpolicy.util.IidFactory;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.ContextId;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.L2BridgeDomainId;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.L2FloodDomainId;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.L3ContextId;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.Name;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.TenantId;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.rev160427.forwarding.forwarding.by.tenant.ForwardingContext;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.rev160427.forwarding.forwarding.by.tenant.ForwardingContextBuilder;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.neutron.by.gbp.mappings.provider.networks.as.l2.flood.domains.ProviderPhysicalNetworkAsL2FloodDomain;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.neutron.by.gbp.mappings.provider.networks.as.l2.flood.domains.ProviderPhysicalNetworkAsL2FloodDomainBuilder;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.forwarding.context.L2BridgeDomain;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.forwarding.context.L2BridgeDomainBuilder;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.forwarding.context.L2FloodDomain;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.forwarding.context.L2FloodDomainBuilder;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.forwarding.context.L3Context;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.forwarding.context.L3ContextBuilder;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.networks.attributes.Networks;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.networks.attributes.networks.Network;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
  46 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  47 import org.slf4j.Logger;
  48 import org.slf4j.LoggerFactory;
  49
  50 import com.google.common.base.Optional;
  51 import com.google.common.base.Strings;
  52
  53 public class NeutronNetworkAware implements NeutronAware<Network> {
  54
  55     private static final Logger LOG = LoggerFactory.getLogger(NeutronNetworkAware.class);
  56     public static final InstanceIdentifier<Network> NETWORK_WILDCARD_IID =
  57             InstanceIdentifier.builder(Neutron.class).child(Networks.class).child(Network.class).build();
  58     private final DataBroker dataProvider;
  59     private final Set<TenantId> tenantsWithRouterAndNetworkSeviceEntities = new HashSet<>();
  60
  61     public NeutronNetworkAware(DataBroker dataProvider) {
  62         this.dataProvider = checkNotNull(dataProvider);
  63     }
  64
  65     @Override
  66     public void onCreated(Network network, Neutron neutron) {
  67         LOG.trace("created network - {}", network);
  68         ReadWriteTransaction rwTx = dataProvider.newReadWriteTransaction();
  69         TenantId tenantId = new TenantId(network.getTenantId().getValue());
  70         Name name;
  71         ContextId ctxId = new ContextId(network.getUuid().getValue());
  72         ForwardingContextBuilder fwdCtxBuilder = new ForwardingContextBuilder()
  73         .setContextId(ctxId)
  74         .setContextType(MappingUtils.L3_CONTEXT);
  75         if (!Strings.isNullOrEmpty(network.getName())) {
  76             try {
  77                 name = new Name(network.getName());
  78                 fwdCtxBuilder.setName(name);
  79             } catch (Exception e) {
  80                 LOG.info("Name of Neutron Network '{}' is ignored.", network.getName());
  81                 LOG.debug("Name exception", e);
  82             }
  83         }
  84
  85         ForwardingContext l3Context = fwdCtxBuilder.build();
  86
  87         fwdCtxBuilder.setContextType(MappingUtils.L2_BRDIGE_DOMAIN)
  88
  89         .setParent(MappingUtils.createParent(ctxId, MappingUtils.L3_CONTEXT));
  90         ForwardingContext l2Bd = fwdCtxBuilder.build();
  91
  92         fwdCtxBuilder.setContextType(MappingUtils.L2_FLOOD_DOMAIN).setParent(
  93                 MappingUtils.createParent(ctxId, MappingUtils.L2_BRDIGE_DOMAIN));
  94         ForwardingContext l2Fd = fwdCtxBuilder.build();
  95
  96         rwTx.put(LogicalDatastoreType.CONFIGURATION, L2L3IidFactory.l3ContextIid(tenantId, ctxId), l3Context, true);
  97         rwTx.put(LogicalDatastoreType.CONFIGURATION, L2L3IidFactory.l2BridgeDomainIid(tenantId, ctxId), l2Bd, true);
  98         rwTx.put(LogicalDatastoreType.CONFIGURATION, L2L3IidFactory.l2FloodDomainIid(tenantId, ctxId), l2Fd, true);
  99
 100         createTenantNetworkDomains(network, tenantId, rwTx);
 101
 102         if (!tenantsWithRouterAndNetworkSeviceEntities.contains(tenantId)) {
 103             tenantsWithRouterAndNetworkSeviceEntities.add(tenantId);
 104             NetworkService.writeNetworkServiceEntitiesToTenant(tenantId, rwTx);
 105             NetworkService.writeDhcpClauseWithConsProvEic(tenantId, null, rwTx);
 106             NetworkService.writeDnsClauseWithConsProvEic(tenantId, null, rwTx);
 107             NetworkService.writeMgmtClauseWithConsProvEic(tenantId, null, rwTx);
 108             NetworkClient.writeNetworkClientEntitiesToTenant(tenantId, rwTx);
 109             NetworkClient.writeConsumerNamedSelector(tenantId, NetworkService.DHCP_CONTRACT_CONSUMER_SELECTOR, rwTx);
 110             NetworkClient.writeConsumerNamedSelector(tenantId, NetworkService.DNS_CONTRACT_CONSUMER_SELECTOR, rwTx);
 111             NetworkClient.writeConsumerNamedSelector(tenantId, NetworkService.MGMT_CONTRACT_CONSUMER_SELECTOR, rwTx);
 112         }
 113         if (!NetworkUtils.getPhysicalNetwork(network).isEmpty() && !NetworkUtils.getSegmentationId(network).isEmpty()) {
 114             addProviderPhysicalNetworkMapping(tenantId, ctxId, NetworkUtils.getSegmentationId(network), rwTx);
 115             addProviderPhysicalNetworkMapping(tenantId, new L2FloodDomainId(ctxId.getValue()),
 116                     NetworkUtils.getSegmentationId(network), rwTx);
 117         }
 118         DataStoreHelper.submitToDs(rwTx);
 119     }
 120
 121     @Deprecated
 122     private void createTenantNetworkDomains(Network network, TenantId tenantId, ReadWriteTransaction rwTx) {
 123         Name name;
 124         L3ContextBuilder l3CtxBuilder = new L3ContextBuilder();
 125         L2FloodDomainBuilder l2FdBuilder = new L2FloodDomainBuilder();
 126         L2BridgeDomainBuilder l2BdBuilder = new L2BridgeDomainBuilder();
 127         if (!Strings.isNullOrEmpty(network.getName())) {
 128             try {
 129                 name = new Name(network.getName());
 130                 l3CtxBuilder.setName(name);
 131                 l2FdBuilder.setName(name);
 132                 l2BdBuilder.setName(name);
 133             } catch (Exception e) {
 134                 name = null;
 135                 LOG.info("Name of Neutron Network '{}' is ignored.", network.getName());
 136                 LOG.debug("Name exception", e);
 137             }
 138         }
 139         L2FloodDomainId l2FdId = new L2FloodDomainId(network.getUuid().getValue());
 140         L3ContextId l3ContextId = new L3ContextId(l2FdId);
 141         L3Context l3Context = l3CtxBuilder.setId(l3ContextId).build();
 142         rwTx.put(LogicalDatastoreType.CONFIGURATION, IidFactory.l3ContextIid(tenantId, l3Context.getId()), l3Context, true);
 143
 144         L2BridgeDomainId l2BdId = new L2BridgeDomainId(l2FdId);
 145         L2BridgeDomain l2Bd = l2BdBuilder.setId(l2BdId).setParent(l3Context.getId()).build();
 146         rwTx.put(LogicalDatastoreType.CONFIGURATION, IidFactory.l2BridgeDomainIid(tenantId, l2BdId), l2Bd, true);
 147
 148         L2FloodDomain l2Fd = l2FdBuilder.setId(l2FdId).setParent(l2BdId).build();
 149         rwTx.put(LogicalDatastoreType.CONFIGURATION, IidFactory.l2FloodDomainIid(tenantId, l2FdId), l2Fd, true);
 150     }
 151
 152     private void addProviderPhysicalNetworkMapping(TenantId tenantId, ContextId ctxId, String segmentationId,
 153             WriteTransaction wTx) {
 154         ProviderPhysicalNetworkAsL2FloodDomain provNetAsL2Fd = new ProviderPhysicalNetworkAsL2FloodDomainBuilder().setTenantId(
 155                 tenantId)
 156             .setL2FloodDomainId(ctxId)
 157             .setSegmentationId(segmentationId)
 158             .build();
 159         wTx.put(LogicalDatastoreType.OPERATIONAL,
 160                 NeutronGbpIidFactory.providerPhysicalNetworkAsL2FloodDomainIid(tenantId, ctxId), provNetAsL2Fd);
 161     }
 162
 163     @Deprecated
 164     private void addProviderPhysicalNetworkMapping(TenantId tenantId, L2FloodDomainId l2FdId, String segmentationId,
 165             WriteTransaction wTx) {
 166         org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.neutron.by.gbp.mappings.provider.physical.networks.as.l2.flood.domains.ProviderPhysicalNetworkAsL2FloodDomain provNetAsL2Fd = new org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.neutron.by.gbp.mappings.provider.physical.networks.as.l2.flood.domains.ProviderPhysicalNetworkAsL2FloodDomainBuilder().setTenantId(
 167                 tenantId)
 168             .setL2FloodDomainId(new L2FloodDomainId(l2FdId.getValue()))
 169             .setSegmentationId(segmentationId)
 170             .build();
 171         wTx.put(LogicalDatastoreType.OPERATIONAL,
 172                 NeutronGbpIidFactory.providerPhysicalNetworkAsL2FloodDomainIid(tenantId, l2FdId), provNetAsL2Fd);
 173     }
 174
 175     @Override
 176     public void onUpdated(Network oldItem, Network newItem, Neutron oldNeutron, Neutron newNeutron) {
 177         LOG.trace("updated network - OLD: {} \nNEW: {}", oldItem, newItem);
 178         // TODO only name can be updated
 179     }
 180
 181     @Override
 182     public void onDeleted(Network network, Neutron oldNeutron, Neutron newNeutron) {
 183         LOG.trace("deleted network - {}", network);
 184         ReadWriteTransaction rwTx = dataProvider.newReadWriteTransaction();
 185         TenantId tenantId = new TenantId(network.getTenantId().getValue());
 186         ContextId id = new ContextId(network.getUuid().getValue());
 187         Optional<ForwardingContext> potentialL2Fd = DataStoreHelper.removeIfExists(LogicalDatastoreType.CONFIGURATION,
 188                 L2L3IidFactory.l2FloodDomainIid(tenantId, id), rwTx);
 189         if (!potentialL2Fd.isPresent()) {
 190             LOG.warn("Illegal state - l2-flood-domain {} does not exist.", id.getValue());
 191             return;
 192         }
 193         Optional<ForwardingContext> potentialL2Bd = DataStoreHelper.removeIfExists(LogicalDatastoreType.CONFIGURATION,
 194                 L2L3IidFactory.l2BridgeDomainIid(tenantId, id), rwTx);
 195         if (!potentialL2Bd.isPresent()) {
 196             LOG.warn("Illegal state - l2-bridge-domain {} does not exist.", id.getValue());
 197             return;
 198         }
 199         Optional<ForwardingContext> potentialL3Ctx = DataStoreHelper.removeIfExists(LogicalDatastoreType.CONFIGURATION,
 200                 L2L3IidFactory.l3ContextIid(tenantId, id), rwTx);
 201         if (!potentialL3Ctx.isPresent()) {
 202             LOG.warn("Illegal state - l3-context {} does not exist.", id.getValue());
 203             return;
 204         }
 205         removeTenantNetworkDomains(network, tenantId, rwTx);
 206         DataStoreHelper.submitToDs(rwTx);
 207     }
 208
 209     @Deprecated
 210     private void removeTenantNetworkDomains(Network network, TenantId tenantId, ReadWriteTransaction rwTx) {
 211         L2FloodDomainId l2FdId = new L2FloodDomainId(network.getUuid().getValue());
 212         Optional<L2FloodDomain> potentialL2Fd = DataStoreHelper.removeIfExists(LogicalDatastoreType.CONFIGURATION,
 213                 IidFactory.l2FloodDomainIid(tenantId, l2FdId), rwTx);
 214         if (!potentialL2Fd.isPresent()) {
 215             LOG.warn("Illegal state - l2-flood-domain {} does not exist.", l2FdId.getValue());
 216             return;
 217         }
 218
 219         L2BridgeDomainId l2BdId = new L2BridgeDomainId(l2FdId);
 220         Optional<L2BridgeDomain> potentialL2Bd = DataStoreHelper.removeIfExists(LogicalDatastoreType.CONFIGURATION,
 221                 IidFactory.l2BridgeDomainIid(tenantId, l2BdId), rwTx);
 222         if (!potentialL2Bd.isPresent()) {
 223             LOG.warn("Illegal state - l2-bridge-domain {} does not exist.", l2BdId.getValue());
 224             return;
 225         }
 226         L3ContextId l3CtxId = new L3ContextId(l2FdId);
 227         Optional<L3Context> potentialL3Ctx = DataStoreHelper.removeIfExists(LogicalDatastoreType.CONFIGURATION,
 228                 IidFactory.l3ContextIid(tenantId, l3CtxId), rwTx);
 229         if (!potentialL3Ctx.isPresent()) {
 230             LOG.warn("Illegal state - l3-context {} does not exist.", l3CtxId.getValue());
 231             return;
 232         }
 233     }
 234 }