renderers/ofoverlay/src/main/java/org/opendaylight/groupbasedpolicy/renderer/ofoverlay/node/OfOverlayNodeListener.java

   1 package org.opendaylight.groupbasedpolicy.renderer.ofoverlay.node;
   2
   3 import static com.google.common.base.Preconditions.checkNotNull;
   4
   5 import java.util.Map.Entry;
   6
   7 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
   8 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
   9 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker.DataChangeScope;
  10 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
  11 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.ofoverlay.rev140528.OfOverlayNodeConfig;
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
  15 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
  16 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
  17 import org.opendaylight.yangtools.concepts.ListenerRegistration;
  18 import org.opendaylight.yangtools.yang.binding.DataObject;
  19 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  20 import org.slf4j.Logger;
  21 import org.slf4j.LoggerFactory;
  22
  23 public class OfOverlayNodeListener implements DataChangeListener, AutoCloseable {
  24
  25     private static final Logger LOG = LoggerFactory.getLogger(OfOverlayNodeListener.class);
  26
  27     private final static InstanceIdentifier<OfOverlayNodeConfig> ofOverlayNodeIid = InstanceIdentifier.builder(
  28             Nodes.class)
  29         .child(Node.class)
  30         .augmentation(OfOverlayNodeConfig.class)
  31         .build();
  32     private final SwitchManager switchManager;
  33     private final ListenerRegistration<DataChangeListener> listenerRegistration;
  34
  35     public OfOverlayNodeListener(DataBroker dataProvider, SwitchManager switchManager) {
  36         this.switchManager = checkNotNull(switchManager);
  37         listenerRegistration = checkNotNull(dataProvider).registerDataChangeListener(
  38                 LogicalDatastoreType.CONFIGURATION, ofOverlayNodeIid, this, DataChangeScope.ONE);
  39     }
  40
  41     @Override
  42     public void onDataChanged(AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> change) {
  43         for (Entry<InstanceIdentifier<?>, DataObject> nodeConfigEntry : change.getCreatedData().entrySet()) {
  44             if (OfOverlayNodeConfig.class.equals(nodeConfigEntry.getKey().getTargetType())) {
  45                 NodeId nodeId = nodeConfigEntry.getKey().firstKeyOf(Node.class, NodeKey.class).getId();
  46                 OfOverlayNodeConfig nodeConfig = (OfOverlayNodeConfig) nodeConfigEntry.getValue();
  47                 LOG.trace("OfOverlayNodeConfig created. NodeId: {} OfOverlayNodeConfig: {}", nodeId.getValue(),
  48                         nodeConfig);
  49                 switchManager.updateSwitchConfig(nodeId, nodeConfig);
  50             }
  51         }
  52         for (Entry<InstanceIdentifier<?>, DataObject> nodeConfigEntry : change.getUpdatedData().entrySet()) {
  53             if (OfOverlayNodeConfig.class.equals(nodeConfigEntry.getKey().getTargetType())) {
  54                 NodeId nodeId = nodeConfigEntry.getKey().firstKeyOf(Node.class, NodeKey.class).getId();
  55                 OfOverlayNodeConfig nodeConfig = (OfOverlayNodeConfig) nodeConfigEntry.getValue();
  56                 LOG.trace("OfOverlayNodeConfig updated. NodeId: {} OfOverlayNodeConfig: {}", nodeId.getValue(),
  57                         nodeConfig);
  58                 switchManager.updateSwitchConfig(nodeId, nodeConfig);
  59             }
  60         }
  61         for (InstanceIdentifier<?> removedNodeConfigIid : change.getRemovedPaths()) {
  62             if (OfOverlayNodeConfig.class.equals(removedNodeConfigIid.getTargetType())) {
  63                 NodeId nodeId = removedNodeConfigIid.firstKeyOf(Node.class, NodeKey.class).getId();
  64                 LOG.trace("OfOverlayNodeConfig removed. NodeId: {}", nodeId.getValue());
  65                 switchManager.updateSwitchConfig(nodeId, null);
  66             }
  67         }
  68     }
  69
  70     @Override
  71     public void close() throws Exception {
  72         if (listenerRegistration != null) {
  73             listenerRegistration.close();
  74         }
  75     }
  76
  77 }