.name("RIC_1") //
.baseUrl("baseUrl1") //
.managedElementIds(new Vector<String>(Arrays.asList("kista_1", "kista_2"))) //
+ .controllerName("controllerName") //
.build());
private static final String POLICY_1_ID = "policyId1";
private A1ClientFactory a1ClientFactory;
@Mock
- private RicSynchronizationTask recoveryTaskMock;
+ private RicSynchronizationTask synchronizationTaskMock;
private final PolicyTypes types = new PolicyTypes();
private Policies policies = new Policies();
types.clear();
policies.clear();
rics.clear();
- RIC_1.setState(RicState.UNDEFINED);
+ RIC_1.setState(RicState.UNAVAILABLE);
RIC_1.clearSupportedPolicyTypes();
}
}
@Test
- public void whenRicIdleAndNoChangedPoliciesOrPolicyTypes_thenNoRecovery() {
- RIC_1.setState(RicState.IDLE);
+ public void whenRicIdleAndNoChangedPoliciesOrPolicyTypes_thenNoSynchronization() {
+ RIC_1.setState(RicState.AVAILABLE);
RIC_1.addSupportedPolicyType(POLICY_TYPE_1);
rics.put(RIC_1);
}
@Test
- public void whenRicUndefined_thenRecovery() {
- RIC_1.setState(RicState.UNDEFINED);
+ public void whenRicUndefined_thenSynchronization() {
+ RIC_1.setState(RicState.UNAVAILABLE);
rics.put(RIC_1);
RicSupervision supervisorUnderTest = spy(new RicSupervision(rics, policies, a1ClientFactory, types, null));
- doReturn(recoveryTaskMock).when(supervisorUnderTest).createSynchronizationTask();
+ doReturn(synchronizationTaskMock).when(supervisorUnderTest).createSynchronizationTask();
supervisorUnderTest.checkAllRics();
verify(supervisorUnderTest).checkAllRics();
verify(supervisorUnderTest).createSynchronizationTask();
- verify(recoveryTaskMock).run(RIC_1);
+ verify(synchronizationTaskMock).run(RIC_1);
verifyNoMoreInteractions(supervisorUnderTest);
}
@Test
- public void whenRicRecovering_thenNoRecovery() {
+ public void whenRicSynchronizing_thenNoSynchronization() {
RIC_1.setState(RicState.SYNCHRONIZING);
rics.put(RIC_1);
}
@Test
- public void whenRicIdleAndErrorGettingPolicyIdentities_thenNoRecovery() {
- RIC_1.setState(RicState.IDLE);
+ public void whenRicIdleAndErrorGettingPolicyIdentities_thenNoSynchronization() {
+ RIC_1.setState(RicState.AVAILABLE);
RIC_1.addSupportedPolicyType(POLICY_TYPE_1);
rics.put(RIC_1);
}
@Test
- public void whenRicIdleAndNotSameAmountOfPolicies_thenRecovery() {
- RIC_1.setState(RicState.IDLE);
+ public void whenRicIdleAndNotSameAmountOfPolicies_thenSynchronization() {
+ RIC_1.setState(RicState.AVAILABLE);
rics.put(RIC_1);
policies.put(POLICY_1);
RicSupervision supervisorUnderTest = spy(new RicSupervision(rics, policies, a1ClientFactory, types, null));
- doReturn(recoveryTaskMock).when(supervisorUnderTest).createSynchronizationTask();
+ doReturn(synchronizationTaskMock).when(supervisorUnderTest).createSynchronizationTask();
supervisorUnderTest.checkAllRics();
verify(supervisorUnderTest).checkAllRics();
verify(supervisorUnderTest).createSynchronizationTask();
- verify(recoveryTaskMock).run(RIC_1);
+ verify(synchronizationTaskMock).run(RIC_1);
verifyNoMoreInteractions(supervisorUnderTest);
}
@Test
- public void whenRicIdleAndSameAmountOfPoliciesButNotSamePolicies_thenRecovery() {
- RIC_1.setState(RicState.IDLE);
+ public void whenRicIdleAndSameAmountOfPoliciesButNotSamePolicies_thenSynchronization() {
+ RIC_1.setState(RicState.AVAILABLE);
rics.put(RIC_1);
policies.put(POLICY_1);
RicSupervision supervisorUnderTest = spy(new RicSupervision(rics, policies, a1ClientFactory, types, null));
- doReturn(recoveryTaskMock).when(supervisorUnderTest).createSynchronizationTask();
+ doReturn(synchronizationTaskMock).when(supervisorUnderTest).createSynchronizationTask();
supervisorUnderTest.checkAllRics();
verify(supervisorUnderTest).checkAllRics();
verify(supervisorUnderTest).createSynchronizationTask();
- verify(recoveryTaskMock).run(RIC_1);
+ verify(synchronizationTaskMock).run(RIC_1);
verifyNoMoreInteractions(supervisorUnderTest);
}
@Test
- public void whenRicIdleAndErrorGettingPolicyTypes_thenNoRecovery() {
- RIC_1.setState(RicState.IDLE);
+ public void whenRicIdleAndErrorGettingPolicyTypes_thenNoSynchronization() {
+ RIC_1.setState(RicState.AVAILABLE);
RIC_1.addSupportedPolicyType(POLICY_TYPE_1);
rics.put(RIC_1);
}
@Test
- public void whenRicIdleAndNotSameAmountOfPolicyTypes_thenRecovery() {
- RIC_1.setState(RicState.IDLE);
+ public void whenRicIdleAndNotSameAmountOfPolicyTypes_thenSynchronization() {
+ RIC_1.setState(RicState.AVAILABLE);
RIC_1.addSupportedPolicyType(POLICY_TYPE_1);
rics.put(RIC_1);
RicSupervision supervisorUnderTest = spy(new RicSupervision(rics, policies, a1ClientFactory, types, null));
- doReturn(recoveryTaskMock).when(supervisorUnderTest).createSynchronizationTask();
+ doReturn(synchronizationTaskMock).when(supervisorUnderTest).createSynchronizationTask();
supervisorUnderTest.checkAllRics();
verify(supervisorUnderTest).checkAllRics();
verify(supervisorUnderTest).createSynchronizationTask();
- verify(recoveryTaskMock).run(RIC_1);
+ verify(synchronizationTaskMock).run(RIC_1);
verifyNoMoreInteractions(supervisorUnderTest);
}
@Test
- public void whenRicIdleAndSameAmountOfPolicyTypesButNotSameTypes_thenRecovery() {
+ public void whenRicIdleAndSameAmountOfPolicyTypesButNotSameTypes_thenSynchronization() {
PolicyType policyType2 = ImmutablePolicyType.builder() //
.name("policyType2") //
.schema("") //
.build();
- RIC_1.setState(RicState.IDLE);
+ RIC_1.setState(RicState.AVAILABLE);
RIC_1.addSupportedPolicyType(POLICY_TYPE_1);
RIC_1.addSupportedPolicyType(policyType2);
rics.put(RIC_1);
RicSupervision supervisorUnderTest = spy(new RicSupervision(rics, policies, a1ClientFactory, types, null));
- doReturn(recoveryTaskMock).when(supervisorUnderTest).createSynchronizationTask();
+ doReturn(synchronizationTaskMock).when(supervisorUnderTest).createSynchronizationTask();
supervisorUnderTest.checkAllRics();
verify(supervisorUnderTest).checkAllRics();
verify(supervisorUnderTest).createSynchronizationTask();
- verify(recoveryTaskMock).run(RIC_1);
+ verify(synchronizationTaskMock).run(RIC_1);
verifyNoMoreInteractions(supervisorUnderTest);
}