applications/topology-manager/src/main/java/org/opendaylight/openflowplugin/applications/topology/manager/DataTreeChangeListenerImpl.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.openflowplugin.applications.topology.manager;
   9
  10 import static java.util.Objects.requireNonNull;
  11
  12 import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
  13 import org.opendaylight.mdsal.binding.api.DataBroker;
  14 import org.opendaylight.mdsal.binding.api.DataTreeChangeListener;
  15 import org.opendaylight.mdsal.binding.api.DataTreeIdentifier;
  16 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
  19 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
  20 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
  21 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
  22 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
  23 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
  24 import org.opendaylight.yangtools.concepts.Registration;
  25 import org.opendaylight.yangtools.yang.binding.DataObject;
  26 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  27
  28 public abstract class DataTreeChangeListenerImpl<T extends DataObject> implements DataTreeChangeListener<T>,
  29         AutoCloseable {
  30     static final InstanceIdentifier<Topology> II_TO_TOPOLOGY = InstanceIdentifier.create(NetworkTopology.class)
  31         .child(Topology.class, new TopologyKey(new TopologyId(FlowCapableTopologyProvider.TOPOLOGY_ID)));
  32
  33     protected final Registration listenerRegistration;
  34     protected OperationProcessor operationProcessor;
  35
  36     @SuppressFBWarnings(value = "MC_OVERRIDABLE_METHOD_CALL_IN_CONSTRUCTOR",
  37         justification = "'this' passed to registerDataTreeChangeListener")
  38     protected DataTreeChangeListenerImpl(final OperationProcessor operationProcessor, final DataBroker dataBroker,
  39             final InstanceIdentifier<T> ii) {
  40         this.operationProcessor = requireNonNull(operationProcessor);
  41         listenerRegistration = dataBroker.registerDataTreeChangeListener(
  42             DataTreeIdentifier.of(LogicalDatastoreType.OPERATIONAL, ii), this);
  43     }
  44
  45     @Override
  46     public void close() {
  47         listenerRegistration.close();
  48     }
  49
  50     <O extends DataObject> void sendToTransactionChain(final O node, final InstanceIdentifier<O> iiToTopologyNode) {
  51         operationProcessor.enqueueOperation(
  52             manager -> manager.mergeToTransaction(LogicalDatastoreType.OPERATIONAL, iiToTopologyNode, node, true));
  53     }
  54
  55     InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network
  56             .topology.topology.Node> provideIIToTopologyNode(
  57             final NodeId nodeIdInTopology) {
  58         org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology
  59                 .NodeKey
  60                 nodeKeyInTopology
  61                 = new org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network
  62                 .topology.topology.NodeKey(
  63                 nodeIdInTopology);
  64         return II_TO_TOPOLOGY.builder()
  65                 .child(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network
  66                                .topology.topology.Node.class,
  67                        nodeKeyInTopology).build();
  68     }
  69
  70     NodeId provideTopologyNodeId(final InstanceIdentifier<T> iiToNodeInInventory) {
  71         final NodeKey inventoryNodeKey = iiToNodeInInventory.firstKeyOf(Node.class);
  72         if (inventoryNodeKey != null) {
  73             return new NodeId(inventoryNodeKey.getId().getValue());
  74         }
  75         return null;
  76     }
  77 }