neutron-vpp-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/vpp/mapper/processors/PortAware.java

   1 /*
   2  * Copyright (c) 2016 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
   9 package org.opendaylight.groupbasedpolicy.neutron.vpp.mapper.processors;
  10
  11 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  12 import org.opendaylight.controller.md.sal.binding.api.DataObjectModification;
  13 import org.opendaylight.controller.md.sal.binding.api.DataTreeIdentifier;
  14 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  15 import org.opendaylight.groupbasedpolicy.util.DataTreeChangeHandler;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.Mappings;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.GbpByNeutronMappings;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.gbp.by.neutron.mappings.BaseEndpointsByPorts;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.neutron.gbp.mapper.rev150513.mappings.gbp.by.neutron.mappings.base.endpoints.by.ports.BaseEndpointByPort;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.ports.rev150712.ports.attributes.ports.Port;
  21 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  22 import org.slf4j.Logger;
  23 import org.slf4j.LoggerFactory;
  24
  25 public class PortAware extends DataTreeChangeHandler<BaseEndpointByPort> implements
  26         MappingProvider<Port> {
  27
  28     private static final Logger LOG = LoggerFactory.getLogger(PortAware.class);
  29     private final PortHandler portHandler;
  30
  31     protected PortAware(PortHandler portHandler, DataBroker dataProvider) {
  32         super(dataProvider);
  33         this.portHandler = portHandler;
  34         registerDataTreeChangeListener(new DataTreeIdentifier<>(LogicalDatastoreType.OPERATIONAL,
  35                 InstanceIdentifier.builder(Mappings.class)
  36                     .child(GbpByNeutronMappings.class)
  37                     .child(BaseEndpointsByPorts.class)
  38                     .child(BaseEndpointByPort.class)
  39                     .build()));
  40     }
  41
  42     @Override
  43     public InstanceIdentifier<Port> getNeutronDtoIid() {
  44         return portHandler.createWildcartedPortIid();
  45     }
  46
  47     @Override
  48     public void processCreatedNeutronDto(Port port) {
  49         LOG.trace("Neutron port created: {}", port);
  50         portHandler.processCreated(port);
  51     }
  52
  53     @Override
  54     public void processUpdatedNeutronDto(Port original, Port delta) {
  55         LOG.trace("Neutron port updated: {}, delta {}", original, delta);
  56         portHandler.processUpdated(original, delta);
  57     }
  58
  59     @Override
  60     public void processDeletedNeutronDto(Port port) {
  61         LOG.trace("Neutron port deleted: {}", port);
  62         // handled by BaseEndpointByPort removal
  63     }
  64
  65     @Override
  66     protected void onWrite(DataObjectModification<BaseEndpointByPort> rootNode,
  67             InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {
  68         if (rootNode.getDataBefore() == null) {
  69             portHandler.processCreated(rootNode.getDataAfter());
  70         }
  71     }
  72
  73     @Override
  74     protected void onDelete(DataObjectModification<BaseEndpointByPort> rootNode,
  75             InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {
  76         portHandler.processDeleted(rootNode.getDataBefore());
  77     }
  78
  79     @Override
  80     protected void onSubtreeModified(DataObjectModification<BaseEndpointByPort> rootNode,
  81             InstanceIdentifier<BaseEndpointByPort> rootIdentifier) {
  82         // update should not happen
  83     }
  84 }