diff options
Diffstat (limited to 'controlloop/common/eventmanager/src')
4 files changed, 71 insertions, 16 deletions
diff --git a/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/ControlLoopEventManager2.java b/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/ControlLoopEventManager2.java index dc2b513a6..f2e99a9ad 100644 --- a/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/ControlLoopEventManager2.java +++ b/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/ControlLoopEventManager2.java @@ -25,6 +25,7 @@ import static org.onap.policy.controlloop.ControlLoopTargetType.VM; import static org.onap.policy.controlloop.ControlLoopTargetType.VNF; import java.io.Serializable; +import java.util.Collections; import java.util.HashMap; import java.util.LinkedList; import java.util.Map; @@ -268,11 +269,11 @@ public class ControlLoopEventManager2 implements ManagerContext, Serializable { } catch (ControlLoopException | RuntimeException e) { // processor problem - this is fatal logger.warn("{}: cannot start next step for {}", closedLoopControlName, requestId, e); + finalResult = FinalResult.FINAL_FAILURE_EXCEPTION; notification = makeNotification(); notification.setNotification(ControlLoopNotificationType.FINAL_FAILURE); notification.setMessage("Policy processing aborted due to policy error"); notification.setHistory(controlLoopHistory); - finalResult = FinalResult.FINAL_FAILURE_EXCEPTION; } } @@ -301,8 +302,6 @@ public class ControlLoopEventManager2 implements ManagerContext, Serializable { VirtualControlLoopEvent event = context.getEvent(); - notification.setHistory(operation.getHistory()); - switch (operation.getState()) { case LOCK_DENIED: notification.setNotification(ControlLoopNotificationType.REJECTED); @@ -327,6 +326,11 @@ public class ControlLoopEventManager2 implements ManagerContext, Serializable { notification.setMessage("Guard result for " + operation.getActor() + " " + operation.getOperation() + " is Deny"); break; + case OPERATION_STARTED: + notification.setNotification(ControlLoopNotificationType.OPERATION); + notification.setMessage(operation.getOperationMessage()); + notification.setHistory(Collections.emptyList()); + break; case OPERATION_SUCCESS: notification.setNotification(ControlLoopNotificationType.OPERATION_SUCCESS); break; @@ -375,7 +379,7 @@ public class ControlLoopEventManager2 implements ManagerContext, Serializable { * @return a new notification */ public VirtualControlLoopNotification makeNotification() { - VirtualControlLoopNotification notif = new VirtualControlLoopNotification(); + VirtualControlLoopNotification notif = new VirtualControlLoopNotification(context.getEvent()); notif.setNotification(ControlLoopNotificationType.OPERATION); notif.setFrom("policy"); notif.setPolicyScope(policyScope); @@ -384,7 +388,7 @@ public class ControlLoopEventManager2 implements ManagerContext, Serializable { if (finalResult == null) { ControlLoopOperationManager2 oper = currentOperation.get(); if (oper != null) { - notif.setMessage(oper.getOperationMessage()); + notif.setMessage(oper.getOperationHistory()); notif.setHistory(oper.getHistory()); } } diff --git a/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/ControlLoopOperationManager2.java b/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/ControlLoopOperationManager2.java index 6bdaa1575..b880fd190 100644 --- a/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/ControlLoopOperationManager2.java +++ b/controlloop/common/eventmanager/src/main/java/org/onap/policy/controlloop/eventmanager/ControlLoopOperationManager2.java @@ -76,6 +76,7 @@ public class ControlLoopOperationManager2 implements Serializable { GUARD_STARTED, GUARD_PERMITTED, GUARD_DENIED, + OPERATION_STARTED, OPERATION_SUCCESS, OPERATION_FAILURE, CONTROL_LOOP_TIMEOUT @@ -197,6 +198,7 @@ public class ControlLoopOperationManager2 implements Serializable { attempt = ControlLoopOperationManager2.this.attempts; policyResult = outcome.getResult(); clOperation = outcome.toControlLoopOperation(); + clOperation.setTarget(policy.getTarget().toString()); } } @@ -356,7 +358,7 @@ public class ControlLoopOperationManager2 implements Serializable { * @param outcome outcome provided to the callback */ private void onStart(OperationOutcome outcome) { - if (GUARD_ACTOR.equals(outcome.getActor())) { + if (outcome.isFor(actor, operation) || GUARD_ACTOR.equals(outcome.getActor())) { addOutcome(outcome); } } @@ -477,10 +479,23 @@ public class ControlLoopOperationManager2 implements Serializable { break; default: - // operation completed - ++attempts; + if (outcome.getEnd() == null) { + // operation started + ++attempts; + state = State.OPERATION_STARTED; + operationHistory.add(new Operation(outcome)); + break; + } + + /* + * Operation completed. If the last entry was a "start" (i.e., "end" field + * is null), then replace it. Otherwise, just add the completion. + */ state = (outcome.getResult() == PolicyResult.SUCCESS ? State.OPERATION_SUCCESS : State.OPERATION_FAILURE); + if (!operationHistory.isEmpty() && operationHistory.peekLast().getClOperation().getEnd() == null) { + operationHistory.removeLast(); + } operationHistory.add(new Operation(outcome)); storeOperationInDataBase(); break; diff --git a/controlloop/common/eventmanager/src/test/java/org/onap/policy/controlloop/eventmanager/ControlLoopEventManager2Test.java b/controlloop/common/eventmanager/src/test/java/org/onap/policy/controlloop/eventmanager/ControlLoopEventManager2Test.java index 522d9f57b..d09c2c88b 100644 --- a/controlloop/common/eventmanager/src/test/java/org/onap/policy/controlloop/eventmanager/ControlLoopEventManager2Test.java +++ b/controlloop/common/eventmanager/src/test/java/org/onap/policy/controlloop/eventmanager/ControlLoopEventManager2Test.java @@ -137,14 +137,17 @@ public class ControlLoopEventManager2Test { when(oper1.getActor()).thenReturn("First"); when(oper1.getOperation()).thenReturn("OperationA"); when(oper1.getOperationMessage()).thenReturn("message-A"); + when(oper1.getOperationHistory()).thenReturn("history-A"); when(oper2.getActor()).thenReturn("Second"); when(oper2.getOperation()).thenReturn("OperationB"); when(oper2.getOperationMessage()).thenReturn("message-B"); + when(oper2.getOperationHistory()).thenReturn("history-B"); when(oper3.getActor()).thenReturn("Third"); when(oper3.getOperation()).thenReturn("OperationC"); when(oper3.getOperationMessage()).thenReturn("message-C"); + when(oper3.getOperationHistory()).thenReturn("history-C"); when(workMem.getFactHandle(any())).thenReturn(factHandle); @@ -365,13 +368,17 @@ public class ControlLoopEventManager2Test { mgr.updated(oper1); verifyNotification(ControlLoopNotificationType.OPERATION, "Guard result for First OperationA is Deny"); + when(oper1.getState()).thenReturn(State.OPERATION_STARTED); + mgr.updated(oper1); + verifyNotification(ControlLoopNotificationType.OPERATION, "message-A"); + when(oper1.getState()).thenReturn(State.OPERATION_SUCCESS); mgr.updated(oper1); - verifyNotification(ControlLoopNotificationType.OPERATION_SUCCESS, "message-A"); + verifyNotification(ControlLoopNotificationType.OPERATION_SUCCESS, "history-A"); when(oper1.getState()).thenReturn(State.OPERATION_FAILURE); mgr.updated(oper1); - verifyNotification(ControlLoopNotificationType.OPERATION_FAILURE, "message-A"); + verifyNotification(ControlLoopNotificationType.OPERATION_FAILURE, "history-A"); // should still be active assertTrue(mgr.isActive()); @@ -427,6 +434,9 @@ public class ControlLoopEventManager2Test { @Test public void testMakeNotification() throws ControlLoopException { + // before started + assertNotNull(mgr.makeNotification()); + mgr.start(); nextStep(oper1, true, PolicyResult.SUCCESS); @@ -434,7 +444,7 @@ public class ControlLoopEventManager2Test { // check notification while running VirtualControlLoopNotification notif = mgr.getNotification(); - assertEquals("message-A", notif.getMessage()); + assertEquals("history-A", notif.getMessage()); List<ControlLoopOperation> history = notif.getHistory(); assertNotNull(history); diff --git a/controlloop/common/eventmanager/src/test/java/org/onap/policy/controlloop/eventmanager/ControlLoopOperationManager2Test.java b/controlloop/common/eventmanager/src/test/java/org/onap/policy/controlloop/eventmanager/ControlLoopOperationManager2Test.java index a14cc1708..e946d2edc 100644 --- a/controlloop/common/eventmanager/src/test/java/org/onap/policy/controlloop/eventmanager/ControlLoopOperationManager2Test.java +++ b/controlloop/common/eventmanager/src/test/java/org/onap/policy/controlloop/eventmanager/ControlLoopOperationManager2Test.java @@ -188,6 +188,9 @@ public class ControlLoopOperationManager2Test { assertEquals(ControlLoopOperationManager2.State.GUARD_PERMITTED, mgr.getState()); assertTrue(mgr.nextStep()); + assertEquals(ControlLoopOperationManager2.State.OPERATION_STARTED, mgr.getState()); + + assertTrue(mgr.nextStep()); assertEquals(ControlLoopOperationManager2.State.OPERATION_SUCCESS, mgr.getState()); assertFalse(mgr.nextStep()); @@ -196,7 +199,7 @@ public class ControlLoopOperationManager2Test { assertEquals(PolicyResult.SUCCESS, outcome.getResult()); assertTrue(outcome.isFinalOutcome()); - verify(mgrctx, times(3)).updated(mgr); + verify(mgrctx, times(4)).updated(mgr); } /** @@ -204,7 +207,7 @@ public class ControlLoopOperationManager2Test { */ @Test public void testStartDetmTargetException() { - policy.setTarget(null); + policy.setTarget(new Target()); mgr.start(REMAINING_MS); runToCompletion(); @@ -454,13 +457,16 @@ public class ControlLoopOperationManager2Test { assertEquals(ControlLoopOperationManager2.State.GUARD_PERMITTED, mgr.getState()); assertTrue(mgr.nextStep()); + assertEquals(ControlLoopOperationManager2.State.OPERATION_STARTED, mgr.getState()); + + assertTrue(mgr.nextStep()); assertEquals(ControlLoopOperationManager2.State.OPERATION_SUCCESS, mgr.getState()); assertFalse(mgr.nextStep()); assertEquals(PolicyResult.SUCCESS, mgr.getOutcomes().peek().getResult()); - verify(mgrctx, times(3)).updated(mgr); + verify(mgrctx, times(4)).updated(mgr); } @Test @@ -600,10 +606,13 @@ public class ControlLoopOperationManager2Test { assertEquals(ControlLoopOperationManager2.State.GUARD_PERMITTED, mgr.getState()); assertTrue(mgr.nextStep()); + assertEquals(ControlLoopOperationManager2.State.OPERATION_STARTED, mgr.getState()); + + assertTrue(mgr.nextStep()); assertEquals(ControlLoopOperationManager2.State.OPERATION_SUCCESS, mgr.getState()); assertFalse(mgr.nextStep()); - verify(mgrctx, times(3)).updated(mgr); + verify(mgrctx, times(4)).updated(mgr); verifyDb(1, PolicyResult.SUCCESS, null); } @@ -627,6 +636,9 @@ public class ControlLoopOperationManager2Test { assertEquals(ControlLoopOperationManager2.State.GUARD_PERMITTED, mgr.getState()); assertTrue(mgr.nextStep()); + assertEquals(ControlLoopOperationManager2.State.OPERATION_STARTED, mgr.getState()); + + assertTrue(mgr.nextStep()); assertEquals(ControlLoopOperationManager2.State.OPERATION_FAILURE, mgr.getState()); verifyDb(1, PolicyResult.FAILURE, null); @@ -637,6 +649,9 @@ public class ControlLoopOperationManager2Test { runToCompletion(); assertTrue(mgr.nextStep()); + assertEquals(ControlLoopOperationManager2.State.OPERATION_STARTED, mgr.getState()); + + assertTrue(mgr.nextStep()); assertEquals(ControlLoopOperationManager2.State.OPERATION_FAILURE, mgr.getState()); verifyDb(2, PolicyResult.FAILURE, null); @@ -646,13 +661,16 @@ public class ControlLoopOperationManager2Test { genOpOutcome(); assertTrue(mgr.nextStep()); + assertEquals(ControlLoopOperationManager2.State.OPERATION_STARTED, mgr.getState()); + + assertTrue(mgr.nextStep()); assertEquals(ControlLoopOperationManager2.State.OPERATION_SUCCESS, mgr.getState()); verifyDb(3, PolicyResult.SUCCESS, null); assertThat(mgr.toString()).contains("attempts=3"); assertFalse(mgr.nextStep()); - verify(mgrctx, times(5)).updated(mgr); + verify(mgrctx, times(8)).updated(mgr); } @Test @@ -802,8 +820,16 @@ public class ControlLoopOperationManager2Test { runToCompletion(); + // guard start assertTrue(mgr.nextStep()); + + // guard permit assertTrue(mgr.nextStep()); + + // operation start + assertTrue(mgr.nextStep()); + + // operation success assertFalse(mgr.nextStep()); } |