bmp/bmp-impl/src/main/java/org/opendaylight/protocol/bmp/impl/BmpMonitorConfigFileProcessor.java

   1 /*
   2  * Copyright (c) 2017 AT&T Intellectual Property.  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.protocol.bmp.impl;
   9
  10 import static java.util.Objects.requireNonNull;
  11
  12 import java.util.Collection;
  13 import java.util.Map;
  14 import javax.annotation.concurrent.GuardedBy;
  15 import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException;
  16 import org.opendaylight.mdsal.binding.dom.codec.api.BindingNormalizedNodeSerializer;
  17 import org.opendaylight.protocol.bgp.config.loader.spi.ConfigFileProcessor;
  18 import org.opendaylight.protocol.bgp.config.loader.spi.ConfigLoader;
  19 import org.opendaylight.protocol.bmp.impl.api.BmpDeployer;
  20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.config.rev170517.OdlBmpMonitors;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.monitor.config.rev170517.odl.bmp.monitors.BmpMonitorConfig;
  22 import org.opendaylight.yangtools.concepts.AbstractRegistration;
  23 import org.opendaylight.yangtools.yang.binding.DataObject;
  24 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  25 import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
  26 import org.opendaylight.yangtools.yang.data.api.schema.ContainerNode;
  27 import org.opendaylight.yangtools.yang.data.api.schema.MapEntryNode;
  28 import org.opendaylight.yangtools.yang.data.api.schema.MapNode;
  29 import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
  30 import org.opendaylight.yangtools.yang.model.api.SchemaPath;
  31 import org.slf4j.Logger;
  32 import org.slf4j.LoggerFactory;
  33
  34 public final class BmpMonitorConfigFileProcessor implements ConfigFileProcessor, AutoCloseable {
  35
  36     private static final Logger LOG = LoggerFactory.getLogger(BmpMonitorConfigFileProcessor.class);
  37
  38     private final SchemaPath bmpMonitorsSchemaPath = SchemaPath.create(true, OdlBmpMonitors.QNAME);
  39     private final BmpDeployer deployer;
  40     private final BindingNormalizedNodeSerializer bindingSerializer;
  41     private final YangInstanceIdentifier bmpMonitorsYii;
  42     private final ConfigLoader configLoader;
  43     @GuardedBy("this")
  44     private AbstractRegistration registration;
  45
  46     public BmpMonitorConfigFileProcessor(final ConfigLoader configLoader, final BmpDeployer deployer) {
  47         requireNonNull(configLoader);
  48         this.deployer = requireNonNull(deployer);
  49         this.configLoader = requireNonNull(configLoader);
  50         this.bindingSerializer = configLoader.getBindingNormalizedNodeSerializer();
  51         this.bmpMonitorsYii = this.bindingSerializer.toYangInstanceIdentifier(
  52                 InstanceIdentifier.create(OdlBmpMonitors.class).child(BmpMonitorConfig.class));
  53     }
  54
  55     public synchronized void register() {
  56         this.registration = this.configLoader.registerConfigFile(this);
  57     }
  58
  59     @Override
  60     public synchronized void close() {
  61         if(this.registration != null) {
  62             this.registration.close();
  63             this.registration = null;
  64         }
  65     }
  66
  67     @Override
  68     public SchemaPath getSchemaPath() {
  69         return this.bmpMonitorsSchemaPath;
  70     }
  71
  72     @Override
  73     public void loadConfiguration(final NormalizedNode<?, ?> dto) {
  74         final ContainerNode bmpMonitorsConfigsContainer = (ContainerNode) dto;
  75         final MapNode monitorsList = (MapNode) bmpMonitorsConfigsContainer.getChild(
  76                 this.bmpMonitorsYii.getLastPathArgument()).orNull();
  77         if (monitorsList == null) {
  78             return;
  79         }
  80         final Collection<MapEntryNode> bmpMonitorConfig = monitorsList.getValue();
  81         for (final MapEntryNode topology : bmpMonitorConfig) {
  82             final Map.Entry<InstanceIdentifier<?>, DataObject> bi = this.bindingSerializer
  83                     .fromNormalizedNode(this.bmpMonitorsYii, topology);
  84             if (bi != null) {
  85                 final BmpMonitorConfig config = (BmpMonitorConfig) bi.getValue();
  86                 try {
  87                     this.deployer.writeBmpMonitor(config);
  88                 } catch (final TransactionCommitFailedException e) {
  89                     LOG.error("Failed to create BMP Monitor {}.", config, e);
  90                 }
  91             }
  92         }
  93     }
  94 }