removed halisteners
[netvirt.git] / 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.PostConstruct;
12 import javax.inject.Inject;
13 import javax.inject.Singleton;
14
15 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
16 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
17 import org.opendaylight.genius.datastoreutils.AsyncClusteredDataTreeChangeListenerBase;
18 import org.opendaylight.genius.utils.hwvtep.HwvtepHACache;
19 import org.opendaylight.genius.utils.hwvtep.HwvtepSouthboundUtils;
20 import org.opendaylight.netvirt.elan.l2gw.ha.HwvtepHAUtil;
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 AsyncClusteredDataTreeChangeListenerBase<Managers, ManagerListener> {
30
31     private static final Logger LOG = LoggerFactory.getLogger(HAOpClusteredListener.class);
32
33     private final DataBroker dataBroker;
34
35     @Inject
36     public ManagerListener(DataBroker dataBroker) {
37         this.dataBroker = dataBroker;
38     }
39
40     @PostConstruct
41     public void init() {
42         registerListener(LogicalDatastoreType.CONFIGURATION, dataBroker);
43     }
44
45     @Override
46     protected InstanceIdentifier<Managers> getWildCardPath() {
47         return HwvtepSouthboundUtils.createHwvtepTopologyInstanceIdentifier()
48                 .child(Node.class)
49                 .augmentation(HwvtepGlobalAugmentation.class)
50                 .child(Managers.class);
51     }
52
53     @Override
54     protected void remove(InstanceIdentifier<Managers> key, Managers managers) {
55     }
56
57     @Override
58     protected void update(InstanceIdentifier<Managers> key, Managers before, Managers after) {
59     }
60
61     @Override
62     protected void add(InstanceIdentifier<Managers> key, Managers managers) {
63         InstanceIdentifier<Node> parent = key.firstIdentifierOf(Node.class);
64         if (managers.getKey().getTarget().getValue().contains(HwvtepHAUtil.MANAGER_KEY)
65                 && managers.getManagerOtherConfigs() != null) {
66             managers.getManagerOtherConfigs().stream()
67                 .filter(otherConfig -> otherConfig.getKey().getOtherConfigKey().contains(HwvtepHAUtil.HA_CHILDREN))
68                 .flatMap(otherConfig -> Arrays.asList(otherConfig.getOtherConfigValue().split(",")).stream())
69                 .map(HwvtepHAUtil::convertToInstanceIdentifier)
70                 .forEach(childIid -> HwvtepHACache.getInstance().addChild(parent, childIid));
71         }
72     }
73
74     @Override
75     protected ManagerListener getDataTreeChangeListener() {
76         return this;
77     }
78 }