1 /*******************************************************************************
2 * ============LICENSE_START=======================================================
3 * ONAP : ccsdk feature sdnr wt
4 * ================================================================================
5 * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property.
7 * ================================================================================
8 * Licensed under the Apache License, Version 2.0 (the "License");
9 * you may not use this file except in compliance with the License.
10 * You may obtain a copy of the License at
12 * http://www.apache.org/licenses/LICENSE-2.0
14 * Unless required by applicable law or agreed to in writing, software
15 * distributed under the License is distributed on an "AS IS" BASIS,
16 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17 * See the License for the specific language governing permissions and
18 * limitations under the License.
19 * ============LICENSE_END=========================================================
20 ******************************************************************************/
21 package org.onap.ccsdk.features.sdnr.wt.devicemanager.housekeeping;
23 import java.util.ArrayList;
24 import java.util.List;
25 import java.util.Optional;
26 import org.eclipse.jdt.annotation.NonNull;
27 import org.eclipse.jdt.annotation.Nullable;
28 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.DataProvider;
29 import org.onap.ccsdk.features.sdnr.wt.devicemanager.NetworkElement;
30 import org.onap.ccsdk.features.sdnr.wt.devicemanager.devicemonitor.impl.DeviceMonitor;
31 import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.DeviceManagerImpl;
32 import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.handler.ODLEventListenerHandler;
33 import org.opendaylight.mdsal.binding.api.MountPoint;
34 import org.opendaylight.mdsal.binding.api.MountPointService;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev150114.network.topology.topology.topology.types.TopologyNetconf;
36 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
37 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
38 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
39 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
40 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
41 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
42 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey;
43 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
44 import org.slf4j.Logger;
45 import org.slf4j.LoggerFactory;
47 public class ResyncNetworkElementHouskeepingService implements ResyncNetworkElementsListener {
49 private static final Logger LOG = LoggerFactory.getLogger(ResyncNetworkElementHouskeepingService.class);
51 private static final InstanceIdentifier<Topology> NETCONF_TOPO_IID =
52 InstanceIdentifier.create(NetworkTopology.class).child(Topology.class,
53 new TopologyKey(new TopologyId(TopologyNetconf.QNAME.getLocalName())));
56 private final MountPointService mountPointService;
57 private final ODLEventListenerHandler odlEventListenerHandler;
58 private final DataProvider databaseClientEvents;
59 private @Nullable final DeviceMonitor deviceMonitor;
60 private final DeviceManagerImpl deviceManager;
62 /** Thread is started to du the clean up action **/
63 private Thread threadDoClearCurrentFaultByNodename;
64 /** Indicate number of refresh activities for log **/
65 private int refreshCounter = 0;
68 * @param deviceManager to provide devices information
69 * @param mountPointService service
70 * @param odlEventListenerHandler handler for events
71 * @param databaseClientEvents database to clean
72 * @param deviceMonitor devicemonitor
74 public ResyncNetworkElementHouskeepingService(
75 DeviceManagerImpl deviceManager,
76 MountPointService mountPointService, ODLEventListenerHandler odlEventListenerHandler,
77 DataProvider databaseClientEvents, DeviceMonitor deviceMonitor) {
79 this.deviceManager = deviceManager;
80 this.mountPointService = mountPointService;
81 this.odlEventListenerHandler = odlEventListenerHandler;
82 this.databaseClientEvents = databaseClientEvents;
83 this.deviceMonitor = deviceMonitor;
87 * Async RPC Interface implementation
90 public @NonNull List<String> doClearCurrentFaultByNodename(@Nullable List<String> nodeNamesInput)
91 throws IllegalStateException {
93 if (this.databaseClientEvents == null) {
94 throw new IllegalStateException("dbEvents service not instantiated");
97 if (threadDoClearCurrentFaultByNodename != null && threadDoClearCurrentFaultByNodename.isAlive()) {
98 throw new IllegalStateException("A clear task is already active");
101 // Create list of mountpoints if input is empty, using the content in ES
102 if (nodeNamesInput == null || nodeNamesInput.size() <= 0) {
103 nodeNamesInput = this.databaseClientEvents.getAllNodesWithCurrentAlarms();
106 // Filter all mountpoints from input that were found and are known to this Cluster-node instance of
108 final List<String> nodeNamesHandled = new ArrayList<>();
109 for (String mountpointName : nodeNamesInput) {
110 LOG.info("Work with mountpoint {}", mountpointName);
112 if (odlEventListenerHandler != null && mountpointName.equals(odlEventListenerHandler.getOwnKeyName())) {
114 // SDN Controller related alarms
115 // -- can not be recreated on all nodes in connected state
116 // -- would result in a DCAE/AAI Notification
117 // Conclusion for 1810 Delivery ... not covered by RPC function (See issue #43)
118 LOG.info("Ignore SDN Controller related alarms for {}", mountpointName);
119 // this.databaseClientEvents.clearFaultsCurrentOfNode(mountpointName);
120 // nodeNamesHandled.add(mountpointName);
124 if (mountPointService != null) {
125 InstanceIdentifier<Node> instanceIdentifier =
126 NETCONF_TOPO_IID.child(Node.class, new NodeKey(new NodeId(mountpointName)));
127 Optional<MountPoint> optionalMountPoint = mountPointService.getMountPoint(instanceIdentifier);
129 if (!optionalMountPoint.isPresent()) {
130 LOG.info("Remove Alarms for unknown mountpoint {}", mountpointName);
131 this.databaseClientEvents.clearFaultsCurrentOfNode(mountpointName);
132 nodeNamesHandled.add(mountpointName);
134 if (deviceManager.getNeByMountpoint(mountpointName) != null) {
135 LOG.info("At node known mountpoint {}", mountpointName);
136 nodeNamesHandled.add(mountpointName);
138 LOG.info("At node unknown mountpoint {}", mountpointName);
146 deviceMonitor.refreshAlarmsInDb();
148 threadDoClearCurrentFaultByNodename = new Thread(() -> {
150 LOG.info("Start refresh mountpoint task {}", refreshCounter);
151 // for(String nodeName:nodeNamesOutput) {
152 for (String nodeName : nodeNamesHandled) {
153 NetworkElement ne = deviceManager.getNeByMountpoint(nodeName);
155 LOG.info("Refresh mountpoint {}", nodeName);
158 LOG.info("Unhandled mountpoint {}", nodeName);
161 LOG.info("End refresh mountpoint task {}", refreshCounter);
163 threadDoClearCurrentFaultByNodename.start();
164 return nodeNamesHandled;