opendaylight/md-sal/inventory-manager/src/main/java/org/opendaylight/controller/md/inventory/manager/NodeChangeCommiter.java

   1 /**
   2  * Copyright (c) 2013 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.controller.md.inventory.manager;
   9
  10 import com.google.common.base.Preconditions;
  11 import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
  12 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnector;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeConnectorUpdated;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNodeUpdated;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRef;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRemoved;
  19 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorUpdated;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRemoved;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeUpdated;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.OpendaylightInventoryListener;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnector;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnectorBuilder;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnectorKey;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeBuilder;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
  30 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  31 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier.InstanceIdentifierBuilder;
  32 import org.slf4j.Logger;
  33 import org.slf4j.LoggerFactory;
  34
  35 class NodeChangeCommiter implements OpendaylightInventoryListener {
  36     private static final Logger LOG = LoggerFactory.getLogger(NodeChangeCommiter.class);
  37
  38     private final FlowCapableInventoryProvider manager;
  39
  40     public NodeChangeCommiter(final FlowCapableInventoryProvider manager) {
  41         this.manager = Preconditions.checkNotNull(manager);
  42     }
  43
  44     @Override
  45     public synchronized void onNodeConnectorRemoved(final NodeConnectorRemoved connector) {
  46         LOG.debug("Node connector removed notification received.");
  47         manager.enqueue(new InventoryOperation() {
  48             @Override
  49             public void applyOperation(final ReadWriteTransaction tx) {
  50                 final NodeConnectorRef ref = connector.getNodeConnectorRef();
  51                 LOG.debug("removing node connector {} ", ref.getValue());
  52                 tx.delete(LogicalDatastoreType.OPERATIONAL, ref.getValue());
  53             }
  54         });
  55     }
  56
  57     @Override
  58     public synchronized void onNodeConnectorUpdated(final NodeConnectorUpdated connector) {
  59         LOG.debug("Node connector updated notification received.");
  60         manager.enqueue(new InventoryOperation() {
  61             @Override
  62             public void applyOperation(final ReadWriteTransaction tx) {
  63                 final NodeConnectorRef ref = connector.getNodeConnectorRef();
  64                 final NodeConnectorBuilder data = new NodeConnectorBuilder(connector);
  65                 data.setKey(new NodeConnectorKey(connector.getId()));
  66
  67                 final FlowCapableNodeConnectorUpdated flowConnector = connector
  68                         .getAugmentation(FlowCapableNodeConnectorUpdated.class);
  69                 if (flowConnector != null) {
  70                     final FlowCapableNodeConnector augment = InventoryMapping.toInventoryAugment(flowConnector);
  71                     data.addAugmentation(FlowCapableNodeConnector.class, augment);
  72                 }
  73                 InstanceIdentifier<NodeConnector> value = (InstanceIdentifier<NodeConnector>) ref.getValue();
  74                 LOG.debug("updating node connector : {}.", value);
  75                 NodeConnector build = data.build();
  76                 tx.put(LogicalDatastoreType.OPERATIONAL, value, build);
  77             }
  78         });
  79     }
  80
  81     @Override
  82     public synchronized void onNodeRemoved(final NodeRemoved node) {
  83         LOG.debug("Node removed notification received.");
  84         manager.enqueue(new InventoryOperation() {
  85             @Override
  86             public void applyOperation(final ReadWriteTransaction tx) {
  87                 final NodeRef ref = node.getNodeRef();
  88                 LOG.debug("removing node : {}", ref.getValue());
  89                 tx.delete(LogicalDatastoreType.OPERATIONAL, ref.getValue());
  90             }
  91         });
  92     }
  93
  94     @Override
  95     public synchronized void onNodeUpdated(final NodeUpdated node) {
  96         final FlowCapableNodeUpdated flowNode = node.getAugmentation(FlowCapableNodeUpdated.class);
  97         if (flowNode == null) {
  98             return;
  99         }
 100         LOG.debug("Node updated notification received.");
 101         manager.enqueue(new InventoryOperation() {
 102             @Override
 103             public void applyOperation(final ReadWriteTransaction tx) {
 104                 final NodeRef ref = node.getNodeRef();
 105                 final NodeBuilder nodeBuilder = new NodeBuilder(node);
 106                 nodeBuilder.setKey(new NodeKey(node.getId()));
 107
 108                 final FlowCapableNode augment = InventoryMapping.toInventoryAugment(flowNode);
 109                 nodeBuilder.addAugmentation(FlowCapableNode.class, augment);
 110
 111                 @SuppressWarnings("unchecked")
 112                 InstanceIdentifierBuilder<Node> builder = ((InstanceIdentifier<Node>) ref.getValue()).builder();
 113                 InstanceIdentifierBuilder<FlowCapableNode> augmentation = builder.augmentation(FlowCapableNode.class);
 114                 final InstanceIdentifier<FlowCapableNode> path = augmentation.build();
 115                 LOG.debug("updating node :{} ", path);
 116                 tx.put(LogicalDatastoreType.OPERATIONAL, path, augment);
 117             }
 118         });
 119     }
 120 }