1 package org.openecomp.sdc.be.components.distribution.engine;
3 import java.util.HashMap;
4 import java.util.LinkedList;
6 import java.util.concurrent.atomic.AtomicBoolean;
9 import org.openecomp.sdc.be.components.BeConfDependentTest;
10 import org.openecomp.sdc.be.components.distribution.engine.DistributionEngineClusterHealth.HealthCheckScheduledTask;
11 import org.openecomp.sdc.common.api.HealthCheckInfo;
13 import mockit.Deencapsulation;
15 public class DistributionEngineClusterHealthTest extends BeConfDependentTest{
17 private DistributionEngineClusterHealth createTestSubject() {
18 return new DistributionEngineClusterHealth();
22 public void testInit() throws Exception {
23 DistributionEngineClusterHealth testSubject;
26 testSubject = createTestSubject();
27 Deencapsulation.invoke(testSubject, "init");
31 public void testDestroy() throws Exception {
32 DistributionEngineClusterHealth testSubject;
35 testSubject = createTestSubject();
36 Deencapsulation.invoke(testSubject, "destroy");
40 public void testStartHealthCheckTask() throws Exception {
41 DistributionEngineClusterHealth testSubject;
42 Map<String, AtomicBoolean> envNamePerStatus = null;
43 boolean startTask = false;
46 testSubject = createTestSubject();
47 testSubject.startHealthCheckTask(envNamePerStatus, startTask);
51 public void testStartHealthCheckTask_1() throws Exception {
52 DistributionEngineClusterHealth testSubject;
53 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
56 testSubject = createTestSubject();
58 testSubject.startHealthCheckTask(envNamePerStatus);
62 public void testHealthCheckScheduledTask() throws Exception {
63 DistributionEngineClusterHealth testSubject;
64 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
67 testSubject = createTestSubject();
68 HealthCheckScheduledTask healthCheckScheduledTask = testSubject. new HealthCheckScheduledTask(new LinkedList<>());
69 LinkedList<UebHealthCheckCall> healthCheckCalls = new LinkedList<>();
70 UebHealthCheckCall hcc = new UebHealthCheckCall("mock", "mock");
71 healthCheckCalls.add(hcc);
72 healthCheckScheduledTask.healthCheckCalls = healthCheckCalls;
74 Deencapsulation.invoke(healthCheckScheduledTask, "queryUeb");
78 public void testHealthCheckScheduledTaskRun() throws Exception {
79 DistributionEngineClusterHealth testSubject;
80 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
81 envNamePerStatus.put("mock", new AtomicBoolean(true));
83 testSubject = createTestSubject();
84 testSubject.startHealthCheckTask(envNamePerStatus, false);
85 HealthCheckScheduledTask healthCheckScheduledTask = testSubject. new HealthCheckScheduledTask(new LinkedList<>());
86 LinkedList<UebHealthCheckCall> healthCheckCalls = new LinkedList<>();
87 UebHealthCheckCall hcc = new UebHealthCheckCall("mock", "mock");
88 healthCheckCalls.add(hcc);
89 healthCheckScheduledTask.healthCheckCalls = healthCheckCalls;
91 Deencapsulation.invoke(healthCheckScheduledTask, "run");
95 public void testHealthCheckScheduledTaskRun_2() throws Exception {
96 DistributionEngineClusterHealth testSubject;
97 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
98 envNamePerStatus.put("mock", new AtomicBoolean(false));
100 testSubject = createTestSubject();
101 testSubject.startHealthCheckTask(envNamePerStatus, false);
102 HealthCheckScheduledTask healthCheckScheduledTask = testSubject. new HealthCheckScheduledTask(new LinkedList<>());
103 LinkedList<UebHealthCheckCall> healthCheckCalls = new LinkedList<>();
104 UebHealthCheckCall hcc = new UebHealthCheckCall("mock", "mock");
105 healthCheckCalls.add(hcc);
106 healthCheckScheduledTask.healthCheckCalls = healthCheckCalls;
108 Deencapsulation.invoke(healthCheckScheduledTask, "run");
112 public void testLogAlarm() throws Exception {
113 DistributionEngineClusterHealth testSubject;
114 boolean lastHealthState = false;
117 testSubject = createTestSubject();
118 Deencapsulation.invoke(testSubject, "logAlarm", new Object[] { lastHealthState });
122 public void testGetHealthCheckInfo() throws Exception {
123 DistributionEngineClusterHealth testSubject;
124 HealthCheckInfo result;
127 testSubject = createTestSubject();
128 result = testSubject.getHealthCheckInfo();
132 public void testSetHealthCheckUebIsDisabled() throws Exception {
133 DistributionEngineClusterHealth testSubject;
136 testSubject = createTestSubject();
137 testSubject.setHealthCheckUebIsDisabled();
141 public void testSetHealthCheckUebConfigurationError() throws Exception {
142 DistributionEngineClusterHealth testSubject;
145 testSubject = createTestSubject();
146 testSubject.setHealthCheckUebConfigurationError();
150 public void testSetHealthCheckOkAndReportInCaseLastStateIsDown() throws Exception {
151 DistributionEngineClusterHealth testSubject;
154 testSubject = createTestSubject();
155 testSubject.setHealthCheckOkAndReportInCaseLastStateIsDown();