1 package org.openecomp.sdc.be.components.distribution.engine;
3 import mockit.Deencapsulation;
5 import org.openecomp.sdc.be.components.BeConfDependentTest;
6 import org.openecomp.sdc.be.components.distribution.engine.DistributionEngineClusterHealth.HealthCheckScheduledTask;
7 import org.openecomp.sdc.common.api.HealthCheckInfo;
9 import java.util.HashMap;
10 import java.util.LinkedList;
12 import java.util.concurrent.atomic.AtomicBoolean;
14 public class DistributionEngineClusterHealthTest extends BeConfDependentTest{
16 private DistributionEngineClusterHealth createTestSubject() {
17 return new DistributionEngineClusterHealth();
21 public void testInit() throws Exception {
22 DistributionEngineClusterHealth testSubject;
25 testSubject = createTestSubject();
26 Deencapsulation.invoke(testSubject, "init");
30 public void testDestroy() throws Exception {
31 DistributionEngineClusterHealth testSubject;
34 testSubject = createTestSubject();
35 Deencapsulation.invoke(testSubject, "destroy");
39 public void testStartHealthCheckTask() throws Exception {
40 DistributionEngineClusterHealth testSubject;
41 Map<String, AtomicBoolean> envNamePerStatus = null;
42 boolean startTask = false;
45 testSubject = createTestSubject();
46 testSubject.startHealthCheckTask(envNamePerStatus, startTask);
50 public void testStartHealthCheckTask_1() throws Exception {
51 DistributionEngineClusterHealth testSubject;
52 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
55 testSubject = createTestSubject();
57 testSubject.startHealthCheckTask(envNamePerStatus);
61 public void testHealthCheckScheduledTask() throws Exception {
62 DistributionEngineClusterHealth testSubject;
63 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
66 testSubject = createTestSubject();
67 HealthCheckScheduledTask healthCheckScheduledTask = testSubject. new HealthCheckScheduledTask(new LinkedList<>());
68 LinkedList<UebHealthCheckCall> healthCheckCalls = new LinkedList<>();
69 UebHealthCheckCall hcc = new UebHealthCheckCall("mock", "mock");
70 healthCheckCalls.add(hcc);
71 healthCheckScheduledTask.healthCheckCalls = healthCheckCalls;
73 Deencapsulation.invoke(healthCheckScheduledTask, "queryUeb");
77 public void testHealthCheckScheduledTaskRun() throws Exception {
78 DistributionEngineClusterHealth testSubject;
79 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
80 envNamePerStatus.put("mock", new AtomicBoolean(true));
82 testSubject = createTestSubject();
83 testSubject.startHealthCheckTask(envNamePerStatus, false);
84 HealthCheckScheduledTask healthCheckScheduledTask = testSubject. new HealthCheckScheduledTask(new LinkedList<>());
85 LinkedList<UebHealthCheckCall> healthCheckCalls = new LinkedList<>();
86 UebHealthCheckCall hcc = new UebHealthCheckCall("mock", "mock");
87 healthCheckCalls.add(hcc);
88 healthCheckScheduledTask.healthCheckCalls = healthCheckCalls;
90 Deencapsulation.invoke(healthCheckScheduledTask, "run");
94 public void testHealthCheckScheduledTaskRun_2() throws Exception {
95 DistributionEngineClusterHealth testSubject;
96 Map<String, AtomicBoolean> envNamePerStatus = new HashMap<>();
97 envNamePerStatus.put("mock", new AtomicBoolean(false));
99 testSubject = createTestSubject();
100 testSubject.startHealthCheckTask(envNamePerStatus, false);
101 HealthCheckScheduledTask healthCheckScheduledTask = testSubject. new HealthCheckScheduledTask(new LinkedList<>());
102 LinkedList<UebHealthCheckCall> healthCheckCalls = new LinkedList<>();
103 UebHealthCheckCall hcc = new UebHealthCheckCall("mock", "mock");
104 healthCheckCalls.add(hcc);
105 healthCheckScheduledTask.healthCheckCalls = healthCheckCalls;
107 Deencapsulation.invoke(healthCheckScheduledTask, "run");
111 public void testLogAlarm() throws Exception {
112 DistributionEngineClusterHealth testSubject;
113 boolean lastHealthState = false;
116 testSubject = createTestSubject();
117 Deencapsulation.invoke(testSubject, "logAlarm", new Object[] { lastHealthState });
121 public void testGetHealthCheckInfo() throws Exception {
122 DistributionEngineClusterHealth testSubject;
123 HealthCheckInfo result;
126 testSubject = createTestSubject();
127 result = testSubject.getHealthCheckInfo();
131 public void testSetHealthCheckUebIsDisabled() throws Exception {
132 DistributionEngineClusterHealth testSubject;
135 testSubject = createTestSubject();
136 testSubject.setHealthCheckUebIsDisabled();
140 public void testSetHealthCheckUebConfigurationError() throws Exception {
141 DistributionEngineClusterHealth testSubject;
144 testSubject = createTestSubject();
145 testSubject.setHealthCheckUebConfigurationError();
149 public void testSetHealthCheckOkAndReportInCaseLastStateIsDown() throws Exception {
150 DistributionEngineClusterHealth testSubject;
153 testSubject = createTestSubject();
154 testSubject.setHealthCheckOkAndReportInCaseLastStateIsDown();