neutron-ovsdb/src/main/java/org/opendaylight/groupbasedpolicy/neutron/ovsdb/PortByEndpointListener.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.ovsdb;
   9
  10 import java.util.List;
  11
  12 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  13 import org.opendaylight.controller.md.sal.binding.api.DataObjectModification;
  14 import org.opendaylight.controller.md.sal.binding.api.DataTreeIdentifier;
  15 import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
  16 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  17 import org.opendaylight.groupbasedpolicy.util.DataStoreHelper;
  18 import org.opendaylight.groupbasedpolicy.util.DataTreeChangeHandler;
  19 import org.opendaylight.groupbasedpolicy.util.IidFactory;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.Name;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.UniqueId;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.endpoint.fields.L3Address;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.endpoints.Endpoint;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.endpoints.EndpointKey;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.endpoints.EndpointL3;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.endpoint.rev140421.endpoints.EndpointL3Key;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.Mappings;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.NeutronByGbpMappings;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.neutron.by.gbp.mappings.PortsByEndpoints;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.neutron.by.gbp.mappings.ports.by.endpoints.PortByEndpoint;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.ofoverlay.rev140528.OfOverlayContext;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.ofoverlay.rev140528.OfOverlayContextBuilder;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.ofoverlay.rev140528.OfOverlayL3Context;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.ofoverlay.rev140528.OfOverlayL3ContextBuilder;
  35 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  36 import org.slf4j.Logger;
  37 import org.slf4j.LoggerFactory;
  38
  39 import com.google.common.base.Optional;
  40
  41 /**
  42  * Listens on PortByEndpoint created events. port-name is augmented to endpoint and endpoint-l3 (IFF
  43  * they exist in DS).
  44  */
  45 public class PortByEndpointListener extends DataTreeChangeHandler<PortByEndpoint> {
  46
  47     private static final Logger LOG = LoggerFactory.getLogger(PortByEndpointListener.class);
  48     private static final String TAP = "tap";
  49
  50     public PortByEndpointListener(DataBroker dataProvider) {
  51         super(dataProvider);
  52         registerDataTreeChangeListener(new DataTreeIdentifier<>(LogicalDatastoreType.OPERATIONAL,
  53                 InstanceIdentifier.builder(Mappings.class)
  54                 .child(NeutronByGbpMappings.class)
  55                 .child(PortsByEndpoints.class)
  56                 .child(PortByEndpoint.class)
  57                 .build()));
  58     }
  59
  60     @Override
  61     protected void onWrite(DataObjectModification<PortByEndpoint> rootNode,
  62             InstanceIdentifier<PortByEndpoint> rootIdentifier) {
  63         PortByEndpoint portByEp = rootNode.getDataAfter();
  64         ReadWriteTransaction rwTx = dataProvider.newReadWriteTransaction();
  65
  66         final EndpointKey epKey = new EndpointKey(portByEp.getL2Context(), portByEp.getMacAddress());
  67         InstanceIdentifier<Endpoint> epIid = IidFactory.endpointIid(epKey);
  68         Optional<Endpoint> potentialEp = DataStoreHelper.readFromDs(LogicalDatastoreType.OPERATIONAL, epIid, rwTx);
  69         if (!potentialEp.isPresent()) {
  70             LOG.warn("PortByEndpoint created notification received but endpoint {} does not exist in DS."
  71                     + " port-name was not added.", epKey);
  72             rwTx.cancel();
  73             return;
  74         }
  75         Endpoint ep = potentialEp.get();
  76         Name portName = createTapPortName(portByEp.getPortId());
  77         OfOverlayContext newOfOverlayCtx = new OfOverlayContextBuilder().setPortName(portName).build();
  78         rwTx.merge(LogicalDatastoreType.OPERATIONAL, epIid.augmentation(OfOverlayContext.class), newOfOverlayCtx);
  79
  80         List<L3Address> l3Addresses = ep.getL3Address();
  81         if (l3Addresses == null) {
  82             LOG.warn("PortByEndpoint created notification received but endpoint {} has no L3 address."
  83                     + " port-name was not added.", epKey);
  84             rwTx.cancel();
  85             return;
  86         }
  87         L3Address l3Address = l3Addresses.get(0);
  88
  89         EndpointL3Key l3EpKey = new EndpointL3Key(l3Address.getIpAddress(), l3Address.getL3Context());
  90         InstanceIdentifier<EndpointL3> l3EpIid = IidFactory.l3EndpointIid(l3EpKey);
  91         Optional<EndpointL3> potentialL3Ep =
  92                 DataStoreHelper.readFromDs(LogicalDatastoreType.OPERATIONAL, l3EpIid, rwTx);
  93         if (!potentialL3Ep.isPresent()) {
  94             LOG.warn("PortByEndpoint created notification received but L3 endpoint {} does not exist in DS."
  95                     + " port-name was not added.", l3EpKey);
  96             rwTx.cancel();
  97             return;
  98         }
  99         OfOverlayL3Context newOfOverlayL3Ctx = new OfOverlayL3ContextBuilder().setPortName(portName).build();
 100         rwTx.merge(LogicalDatastoreType.OPERATIONAL, l3EpIid.augmentation(OfOverlayL3Context.class), newOfOverlayL3Ctx);
 101
 102         DataStoreHelper.submitToDs(rwTx);
 103     }
 104
 105     @Override
 106     protected void onDelete(DataObjectModification<PortByEndpoint> rootNode,
 107             InstanceIdentifier<PortByEndpoint> rootIdentifier) {
 108         // NOOP
 109     }
 110
 111     @Override
 112     protected void onSubtreeModified(DataObjectModification<PortByEndpoint> rootNode,
 113             InstanceIdentifier<PortByEndpoint> rootIdentifier) {
 114         // NOOP
 115     }
 116
 117     private static Name createTapPortName(UniqueId portId) {
 118         return new Name(TAP + portId.getValue().substring(0, 11));
 119     }
 120
 121 }