elanmanager/impl/src/main/java/org/opendaylight/netvirt/elan/l2gw/ha/listeners/ManagerListener.java

   1 /*
   2  * Copyright (c) 2018 Ericsson India Global Services Pvt Ltd. 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.netvirt.elan.l2gw.ha.listeners;
   9
  10 import java.util.Arrays;
  11 import javax.annotation.PreDestroy;
  12 import javax.inject.Inject;
  13 import javax.inject.Singleton;
  14 import org.opendaylight.genius.utils.hwvtep.HwvtepHACache;
  15 import org.opendaylight.genius.utils.hwvtep.HwvtepSouthboundUtils;
  16 import org.opendaylight.infrautils.utils.concurrent.Executors;
  17 import org.opendaylight.mdsal.binding.api.DataBroker;
  18 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
  19 import org.opendaylight.netvirt.elan.l2gw.ha.HwvtepHAUtil;
  20 import org.opendaylight.serviceutils.tools.listener.AbstractClusteredAsyncDataTreeChangeListener;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.HwvtepGlobalAugmentation;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.hwvtep.rev150901.hwvtep.global.attributes.Managers;
  23 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
  24 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  25 import org.slf4j.Logger;
  26 import org.slf4j.LoggerFactory;
  27
  28 @Singleton
  29 public final class ManagerListener extends AbstractClusteredAsyncDataTreeChangeListener<Managers> {
  30
  31     private static final Logger LOG = LoggerFactory.getLogger(ManagerListener.class);
  32     private final DataBroker dataBroker;
  33
  34     @Inject
  35     public ManagerListener(DataBroker dataBroker) {
  36         super(dataBroker, LogicalDatastoreType.CONFIGURATION,
  37                 HwvtepSouthboundUtils.createHwvtepTopologyInstanceIdentifier().child(Node.class)
  38                     .augmentation(HwvtepGlobalAugmentation.class).child(Managers.class),
  39                 Executors.newListeningSingleThreadExecutor("ManagerListener", LOG));
  40         this.dataBroker = dataBroker;
  41     }
  42
  43     public void init() {
  44         LOG.info("{} init", getClass().getSimpleName());
  45     }
  46
  47     @Override
  48     @PreDestroy
  49     public void close() {
  50         super.close();
  51         Executors.shutdownAndAwaitTermination(getExecutorService());
  52     }
  53
  54     @Override
  55     public void remove(InstanceIdentifier<Managers> key, Managers managers) {
  56     }
  57
  58     @Override
  59     public void update(InstanceIdentifier<Managers> key, Managers before, Managers after) {
  60     }
  61
  62     @Override
  63     public void add(InstanceIdentifier<Managers> key, Managers managers) {
  64         InstanceIdentifier<Node> parent = key.firstIdentifierOf(Node.class);
  65         if (managers.key().getTarget().getValue().contains(HwvtepHAUtil.MANAGER_KEY)
  66             && managers.getManagerOtherConfigs() != null) {
  67             managers.nonnullManagerOtherConfigs().values().stream()
  68                 .filter(otherConfig -> otherConfig.key().getOtherConfigKey().contains(HwvtepHAUtil.HA_CHILDREN))
  69                 .flatMap(otherConfig -> Arrays.stream(otherConfig.getOtherConfigValue().split(",")))
  70                 .map(HwvtepHAUtil::convertToInstanceIdentifier)
  71                 .forEach(childIid -> HwvtepHACache.getInstance().addChild(parent, childIid));
  72         }
  73     }
  74 }