interfacemgr/interfacemgr-impl/src/main/java/org/opendaylight/vpnservice/interfacemgr/IfmNodeConnectorListener.java

   1 package org.opendaylight.vpnservice.interfacemgr;
   2
   3 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
   4
   5 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnector;
   6 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
   7 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
   8 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
   9 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker.DataChangeScope;
  10 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  11 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
  12 import org.opendaylight.yangtools.concepts.ListenerRegistration;
  13 import org.slf4j.Logger;
  14 import org.slf4j.LoggerFactory;
  15 import org.opendaylight.vpnservice.AbstractDataChangeListener;
  16
  17 public class IfmNodeConnectorListener extends AbstractDataChangeListener<NodeConnector> implements AutoCloseable{
  18     private static final Logger LOG = LoggerFactory.getLogger(IfmNodeConnectorListener.class);
  19     private ListenerRegistration<DataChangeListener> listenerRegistration;
  20     private final DataBroker broker;
  21     private InterfaceManager ifManager;
  22
  23     public IfmNodeConnectorListener(final DataBroker db) {
  24         super(NodeConnector.class);
  25         broker = db;
  26         registerListener(db);
  27     }
  28
  29     public IfmNodeConnectorListener(final DataBroker dataBroker, InterfaceManager interfaceManager) {
  30         this(dataBroker);
  31         ifManager = interfaceManager;
  32     }
  33
  34     private void registerListener(final DataBroker db) {
  35         try {
  36             listenerRegistration = db.registerDataChangeListener(LogicalDatastoreType.OPERATIONAL,
  37                     getWildCardPath(), IfmNodeConnectorListener.this, DataChangeScope.SUBTREE);
  38         } catch (final Exception e) {
  39             LOG.error("IfmNodeConnectorListener: DataChange listener registration fail!", e);
  40             throw new IllegalStateException("IfmNodeConnectorListener: registration Listener failed.", e);
  41         }
  42     }
  43
  44     private InstanceIdentifier<NodeConnector> getWildCardPath() {
  45         return InstanceIdentifier.create(Nodes.class).child(Node.class).child(NodeConnector.class);
  46     }
  47
  48     @Override
  49     public void close() throws Exception {
  50         if (listenerRegistration != null) {
  51             try {
  52                 listenerRegistration.close();
  53             } catch (final Exception e) {
  54                 LOG.error("Error when cleaning up DataChangeListener.", e);
  55             }
  56             listenerRegistration = null;
  57         }
  58         LOG.info("IfmNodeConnectorListener Closed");
  59     }
  60
  61     @Override
  62     protected void add(InstanceIdentifier<NodeConnector> identifier, NodeConnector node) {
  63         LOG.trace("NodeConnectorAdded: key: " + identifier + ", value=" + node );
  64         ifManager.processPortAdd(node);
  65     }
  66
  67     @Override
  68     protected void remove(InstanceIdentifier<NodeConnector> identifier, NodeConnector del) {
  69         LOG.trace("NodeConnectorRemoved: key: " + identifier + ", value=" + del );
  70         ifManager.processPortDelete(del);
  71     }
  72
  73     @Override
  74     protected void update(InstanceIdentifier<NodeConnector> identifier, NodeConnector original, NodeConnector update) {
  75         ifManager.processPortUpdate(original, update);
  76     }
  77
  78 }