2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
21 package org.openecomp.sdc.be.components.distribution.engine;
23 import mockit.Deencapsulation;
24 import org.junit.Test;
25 import org.openecomp.sdc.be.components.BeConfDependentTest;
26 import org.openecomp.sdc.be.components.distribution.engine.DistributionEngineClusterHealth.HealthCheckScheduledTask;
27 import org.openecomp.sdc.common.api.HealthCheckInfo;
29 import java.util.HashMap;
30 import java.util.LinkedList;
32 import java.util.concurrent.atomic.AtomicBoolean;
34 public class DistributionEngineClusterHealthTest extends BeConfDependentTest{
36 private DistributionEngineClusterHealth createTestSubject() {
37 return new DistributionEngineClusterHealth();
41 public void testInit() throws Exception {
42 DistributionEngineClusterHealth testSubject;
45 testSubject = createTestSubject();
46 Deencapsulation.invoke(testSubject, "init");
50 public void testDestroy() throws Exception {
51 DistributionEngineClusterHealth testSubject;
54 testSubject = createTestSubject();
55 Deencapsulation.invoke(testSubject, "destroy");
59 public void testStartHealthCheckTask() throws Exception {
60 DistributionEngineClusterHealth testSubject;
61 Map<String, AtomicBoolean> envNamePerStatus = null;
62 boolean startTask = false;
65 testSubject = createTestSubject();
66 testSubject.startHealthCheckTask(envNamePerStatus, startTask);
70 public void testStartHealthCheckTask_1() throws Exception {
71 DistributionEngineClusterHealth testSubject;
72 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
75 testSubject = createTestSubject();
77 testSubject.startHealthCheckTask(envNamePerStatus);
81 public void testHealthCheckScheduledTask() throws Exception {
82 DistributionEngineClusterHealth testSubject;
83 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
86 testSubject = createTestSubject();
87 HealthCheckScheduledTask healthCheckScheduledTask = testSubject. new HealthCheckScheduledTask(new LinkedList<>());
88 LinkedList<UebHealthCheckCall> healthCheckCalls = new LinkedList<>();
89 UebHealthCheckCall hcc = new UebHealthCheckCall("mock", "mock");
90 healthCheckCalls.add(hcc);
91 healthCheckScheduledTask.healthCheckCalls = healthCheckCalls;
93 Deencapsulation.invoke(healthCheckScheduledTask, "queryUeb");
97 public void testHealthCheckScheduledTaskRun() throws Exception {
98 DistributionEngineClusterHealth testSubject;
99 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
100 envNamePerStatus.put("mock", new AtomicBoolean(true));
102 testSubject = createTestSubject();
103 testSubject.startHealthCheckTask(envNamePerStatus, false);
104 HealthCheckScheduledTask healthCheckScheduledTask = testSubject. new HealthCheckScheduledTask(new LinkedList<>());
105 LinkedList<UebHealthCheckCall> healthCheckCalls = new LinkedList<>();
106 UebHealthCheckCall hcc = new UebHealthCheckCall("mock", "mock");
107 healthCheckCalls.add(hcc);
108 healthCheckScheduledTask.healthCheckCalls = healthCheckCalls;
110 Deencapsulation.invoke(healthCheckScheduledTask, "run");
114 public void testHealthCheckScheduledTaskRun_2() throws Exception {
115 DistributionEngineClusterHealth testSubject;
116 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
117 envNamePerStatus.put("mock", new AtomicBoolean(false));
119 testSubject = createTestSubject();
120 testSubject.startHealthCheckTask(envNamePerStatus, false);
121 HealthCheckScheduledTask healthCheckScheduledTask = testSubject. new HealthCheckScheduledTask(new LinkedList<>());
122 LinkedList<UebHealthCheckCall> healthCheckCalls = new LinkedList<>();
123 UebHealthCheckCall hcc = new UebHealthCheckCall("mock", "mock");
124 healthCheckCalls.add(hcc);
125 healthCheckScheduledTask.healthCheckCalls = healthCheckCalls;
127 Deencapsulation.invoke(healthCheckScheduledTask, "run");
131 public void testLogAlarm() throws Exception {
132 DistributionEngineClusterHealth testSubject;
133 boolean lastHealthState = false;
136 testSubject = createTestSubject();
137 Deencapsulation.invoke(testSubject, "logAlarm", new Object[] { lastHealthState });
141 public void testGetHealthCheckInfo() throws Exception {
142 DistributionEngineClusterHealth testSubject;
143 HealthCheckInfo result;
146 testSubject = createTestSubject();
147 result = testSubject.getHealthCheckInfo();
151 public void testSetHealthCheckUebIsDisabled() throws Exception {
152 DistributionEngineClusterHealth testSubject;
155 testSubject = createTestSubject();
156 testSubject.setHealthCheckUebIsDisabled();
160 public void testSetHealthCheckUebConfigurationError() throws Exception {
161 DistributionEngineClusterHealth testSubject;
164 testSubject = createTestSubject();
165 testSubject.setHealthCheckUebConfigurationError();
169 public void testSetHealthCheckOkAndReportInCaseLastStateIsDown() throws Exception {
170 DistributionEngineClusterHealth testSubject;
173 testSubject = createTestSubject();
174 testSubject.setHealthCheckOkAndReportInCaseLastStateIsDown();