neutron-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/mapper/util/MappingUtils.java

   1 package org.opendaylight.groupbasedpolicy.neutron.mapper.util;
   2
   3 import org.opendaylight.controller.md.sal.binding.api.ReadTransaction;
   4 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
   5 import org.opendaylight.groupbasedpolicy.renderer.ofoverlay.sf.AllowAction;
   6 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.ActionName;
   7 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.EndpointGroupId;
   8 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.L2BridgeDomainId;
   9 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.L2FloodDomainId;
  10 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.L3ContextId;
  11 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.TenantId;
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.L2BridgeDomain;
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.L2FloodDomain;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.L3Context;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.subject.feature.instances.ActionInstance;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.subject.feature.instances.ActionInstanceBuilder;
  17
  18 import com.google.common.base.Optional;
  19
  20 public final class MappingUtils {
  21
  22     public static final String NEUTRON_RULE__ = "neutron_rule__";
  23     public static final String NEUTRON_NETWORK__ = "neutron_network__";
  24     public static final String NEUTRON_ROUTER__ = "neutron_router__";
  25     public static final String NEUTRON_GROUP__ = "neutron_group__";
  26     public static final ActionInstance ACTION_ALLOW = new ActionInstanceBuilder().setName(
  27             new ActionName(NEUTRON_RULE__ + "allow"))
  28         .setActionDefinitionId(AllowAction.DEFINITION.getId())
  29         .build();
  30     public static final EndpointGroupId EPG_ANY_ID = new EndpointGroupId("aaaec0ce-dd5a-11e4-b9d6-1681e6b88ec1");
  31     public static final EndpointGroupId EPG_DHCP_ID = new EndpointGroupId("ddd6cfe6-dfe5-11e4-8a00-1681e6b88ec1");
  32     public static final EndpointGroupId EPG_ROUTER_ID = new EndpointGroupId("1118172e-cd84-4933-a35f-749f9a651de9");
  33
  34     private MappingUtils() {
  35         throw new UnsupportedOperationException("Cannot create an instance.");
  36     }
  37
  38     public static ForwardingCtx createForwardingContext(TenantId tenantId, L2FloodDomainId l2FdId, ReadTransaction rTx) {
  39         Optional<L2FloodDomain> potentialL2Fd = DataStoreHelper.readFromDs(LogicalDatastoreType.CONFIGURATION,
  40                 IidFactory.l2FloodDomainIid(tenantId, l2FdId), rTx);
  41         if (!potentialL2Fd.isPresent()) {
  42             return new ForwardingCtx(null, null, null);
  43         }
  44         L2BridgeDomainId l2BdId = potentialL2Fd.get().getParent();
  45         if (l2BdId == null) {
  46             return new ForwardingCtx(potentialL2Fd.get(), null, null);
  47         }
  48         Optional<L2BridgeDomain> potentialL2Bd = DataStoreHelper.readFromDs(LogicalDatastoreType.CONFIGURATION,
  49                 IidFactory.l2BridgeDomainIid(tenantId, l2BdId), rTx);
  50         if (!potentialL2Bd.isPresent()) {
  51             return new ForwardingCtx(potentialL2Fd.get(), null, null);
  52         }
  53         L3ContextId l3ContextId = potentialL2Bd.get().getParent();
  54         if (l3ContextId == null) {
  55             return new ForwardingCtx(potentialL2Fd.get(), potentialL2Bd.get(), null);
  56         }
  57         Optional<L3Context> potentialL3Context = DataStoreHelper.readFromDs(LogicalDatastoreType.CONFIGURATION,
  58                 IidFactory.l3ContextIid(tenantId, l3ContextId), rTx);
  59         if (!potentialL3Context.isPresent()) {
  60             return new ForwardingCtx(potentialL2Fd.get(), potentialL2Bd.get(), null);
  61         }
  62         return new ForwardingCtx(potentialL2Fd.get(), potentialL2Bd.get(), potentialL3Context.get());
  63     }
  64
  65     public static final class ForwardingCtx {
  66
  67         private final L2FloodDomain l2FloodDomain;
  68         private final L2BridgeDomain l2BridgeDomain;
  69         private final L3Context l3Context;
  70
  71         private ForwardingCtx(L2FloodDomain l2Fd, L2BridgeDomain l2Bd, L3Context l3Context) {
  72             this.l2FloodDomain = l2Fd;
  73             this.l2BridgeDomain = l2Bd;
  74             this.l3Context = l3Context;
  75         }
  76
  77         public L2FloodDomain getL2FloodDomain() {
  78             return l2FloodDomain;
  79         }
  80
  81         public L2BridgeDomain getL2BridgeDomain() {
  82             return l2BridgeDomain;
  83         }
  84
  85         public L3Context getL3Context() {
  86             return l3Context;
  87         }
  88
  89     }
  90 }