import org.onap.policy.controlloop.actor.guard.GuardActor;
import org.onap.policy.controlloop.actor.guard.DecisionOperation;
import org.onap.policy.controlloop.actorserviceprovider.Operation;
+import org.onap.policy.controlloop.actorserviceprovider.OperationFinalResult;
import org.onap.policy.controlloop.actorserviceprovider.OperationProperties;
+import org.onap.policy.controlloop.actorserviceprovider.OperationResult;
import org.onap.policy.controlloop.drl.legacy.ControlLoopParams;
import org.onap.policy.controlloop.eventmanager.ActorConstants;
import org.onap.policy.controlloop.eventmanager.Step;
-import org.onap.policy.controlloop.policy.Policy;
-import org.onap.policy.controlloop.policy.FinalResult;
-import org.onap.policy.controlloop.policy.PolicyResult;
import org.onap.policy.controlloop.utils.ControlLoopUtils;
import org.onap.policy.drools.apps.controller.usecases.UsecasesEventManager;
import org.onap.policy.drools.apps.controller.usecases.UsecasesEventManager.State;
logger.warn("{}: {}.{}: manager={} exception loading next policy",
$manager.getClosedLoopControlName(), $manager.getPolicyName(), drools.getRule().getName(),
$manager, e);
- $manager.abort(State.DONE, FinalResult.FINAL_FAILURE_EXCEPTION, "failed to load next policy");
+ $manager.abort(State.DONE, OperationFinalResult.FINAL_FAILURE_EXCEPTION, "failed to load next policy");
}
update($manager);
logger.warn("{}: {}.{}: manager={} exception loading preprocessor steps",
$manager.getClosedLoopControlName(), $manager.getPolicyName(), drools.getRule().getName(),
$manager, e);
- $manager.abort(State.DONE, FinalResult.FINAL_FAILURE_EXCEPTION, "failed to load preprocessing steps");
+ $manager.abort(State.DONE, OperationFinalResult.FINAL_FAILURE_EXCEPTION, "failed to load preprocessing steps");
}
update($manager);
logger.warn("{}: {}.{}: manager={} exception processing operation outcome",
$manager.getClosedLoopControlName(), $manager.getPolicyName(), drools.getRule().getName(),
$manager, e);
- $manager.abort(State.DONE, FinalResult.FINAL_FAILURE_EXCEPTION, "failed to accept the event");
+ $manager.abort(State.DONE, OperationFinalResult.FINAL_FAILURE_EXCEPTION, "failed to accept the event");
}
update($manager);
logger.warn("{}: {}.{}: manager={} exception executing a step",
$manager.getClosedLoopControlName(), $manager.getPolicyName(), drools.getRule().getName(),
$manager, e);
- $manager.abort(State.DONE, FinalResult.FINAL_FAILURE_EXCEPTION, "failed to execute the next step");
+ $manager.abort(State.DONE, OperationFinalResult.FINAL_FAILURE_EXCEPTION, "failed to execute the next step");
}
update($manager);
// it's a "start" operation
notification.setMessage("Sending guard query for " + step2.getActorName() + " " + step2.getOperationName());
- } else if ($outcome.getResult() == PolicyResult.SUCCESS) {
+ } else if ($outcome.getResult() == OperationResult.SUCCESS) {
notification.setMessage("Guard result for " + step2.getActorName() + " " + step2.getOperationName()
+ " is Permit");
} else {
logger.warn("{}: {}.{}: manager={} exception processing operation outcome",
$manager.getClosedLoopControlName(), $manager.getPolicyName(), drools.getRule().getName(),
$manager, e);
- $manager.abort(State.DONE, FinalResult.FINAL_FAILURE_EXCEPTION, "failed to handle policy 'start' outcome");
+ $manager.abort(State.DONE, OperationFinalResult.FINAL_FAILURE_EXCEPTION, "failed to handle policy 'start' outcome");
}
update($manager);
logger.warn("{}: {}.{}: manager={} exception processing operation outcome",
$manager.getClosedLoopControlName(), $manager.getPolicyName(), drools.getRule().getName(),
$manager, e);
- $manager.abort(State.DONE, FinalResult.FINAL_FAILURE_EXCEPTION, "failed to handle 'start' outcome");
+ $manager.abort(State.DONE, OperationFinalResult.FINAL_FAILURE_EXCEPTION, "failed to handle 'start' outcome");
}
update($manager);
$outcome : getOutcomes().peek(),
$outcome != null,
$outcome.getEnd() != null,
- $outcome.getResult() == PolicyResult.SUCCESS,
+ $outcome.getResult() == OperationResult.SUCCESS,
$step : getSteps().peek(),
$step.isPolicyStep(),
$outcome.isFor($step.getActorName(), $step.getOperationName()) )
logger.warn("{}: {}.{}: manager={} exception processing operation outcome",
$manager.getClosedLoopControlName(), $manager.getPolicyName(), drools.getRule().getName(),
$manager, e);
- $manager.abort(State.DONE, FinalResult.FINAL_FAILURE_EXCEPTION, "failed to handle policy 'success' outcome");
+ $manager.abort(State.DONE, OperationFinalResult.FINAL_FAILURE_EXCEPTION, "failed to handle policy 'success' outcome");
}
update($manager);
!isAbort($outcome),
$outcome.getEnd() != null,
$outcome.isFinalOutcome(),
- $outcome.getResult() != PolicyResult.SUCCESS,
+ $outcome.getResult() != OperationResult.SUCCESS,
$step : getSteps().peek() )
then
$manager.getOutcomes().remove();
if (!$outcome.isFor($step.getActorName(), $step.getOperationName())) {
- $outcome.setResult(PolicyResult.FAILURE_GUARD);
+ $outcome.setResult(OperationResult.FAILURE_GUARD);
$outcome.setMessage("Operation denied by " + $outcome.getActor());
}
logger.warn("{}: {}.{}: manager={} exception processing operation outcome",
$manager.getClosedLoopControlName(), $manager.getPolicyName(), drools.getRule().getName(),
$manager, e);
- $manager.abort(State.DONE, FinalResult.FINAL_FAILURE_EXCEPTION, "failed to handle policy 'failure' outcome");
+ $manager.abort(State.DONE, OperationFinalResult.FINAL_FAILURE_EXCEPTION, "failed to handle policy 'failure' outcome");
}
update($manager);
!isAbort($outcome),
$outcome.getEnd() != null,
$outcome.isFinalOutcome(),
- $outcome.getResult() != PolicyResult.SUCCESS,
+ $outcome.getResult() != OperationResult.SUCCESS,
$step : getSteps().peek() )
then
logger.warn("{}: {}.{}: manager={} exception processing operation outcome",
$manager.getClosedLoopControlName(), $manager.getPolicyName(), drools.getRule().getName(),
$manager, e);
- $manager.abort(State.DONE, FinalResult.FINAL_FAILURE_EXCEPTION, "failed to reject event");
+ $manager.abort(State.DONE, OperationFinalResult.FINAL_FAILURE_EXCEPTION, "failed to reject event");
}
$manager.destroy();
!isAbort($outcome),
$outcome.getEnd() != null,
!$outcome.isFinalOutcome(),
- $outcome.getResult() != PolicyResult.SUCCESS,
+ $outcome.getResult() != OperationResult.SUCCESS,
$step : getSteps().peek(),
$step.isPolicyStep(),
$outcome.isFor($step.getActorName(), $step.getOperationName()) )
logger.warn("{}: {}.{}: manager={} exception processing operation outcome",
$manager.getClosedLoopControlName(), $manager.getPolicyName(), drools.getRule().getName(),
$manager, e);
- $manager.abort(State.DONE, FinalResult.FINAL_FAILURE_EXCEPTION, "failed to handle policy 'failure' outcome");
+ $manager.abort(State.DONE, OperationFinalResult.FINAL_FAILURE_EXCEPTION, "failed to handle policy 'failure' outcome");
}
update($manager);
// it's a completion for the step
// let the step record the response that's contained within the outcome
- if ($outcome.getResult() == PolicyResult.SUCCESS) {
+ if ($outcome.getResult() == OperationResult.SUCCESS) {
$step.success($outcome);
}
logger.warn("{}: {}.{}: manager={} exception processing operation outcome",
$manager.getClosedLoopControlName(), $manager.getPolicyName(), drools.getRule().getName(),
$manager, e);
- $manager.abort(State.DONE, FinalResult.FINAL_FAILURE_EXCEPTION, "failed to handle outcome");
+ $manager.abort(State.DONE, OperationFinalResult.FINAL_FAILURE_EXCEPTION, "failed to handle outcome");
}
update($manager);
break;
}
- $manager.abort(State.DONE, FinalResult.FINAL_FAILURE, msg);
+ $manager.abort(State.DONE, OperationFinalResult.FINAL_FAILURE, msg);
if ($step != null && "SDNR".equals($step.getActorName())
&& $outcome.isFor($step.getActorName(), $step.getOperationName())) {
logger.warn("{}: {}.{}: manager={} exception handling ABORT outcome",
$manager.getClosedLoopControlName(), $manager.getPolicyName(), drools.getRule().getName(),
$manager, e);
- $manager.abort(State.DONE, FinalResult.FINAL_FAILURE_EXCEPTION, "failed to handle ABORT");
+ $manager.abort(State.DONE, OperationFinalResult.FINAL_FAILURE_EXCEPTION, "failed to handle ABORT");
}
update($manager);
notification.setHistory($manager.getFullHistory().stream().map(OperationOutcome2::getClOperation)
.collect(Collectors.toList()));
- FinalResult finalResult = $manager.getFinalResult();
+ OperationFinalResult finalResult = $manager.getFinalResult();
if (finalResult == null) {
- finalResult = ($manager.isActive() ? FinalResult.FINAL_SUCCESS : FinalResult.FINAL_FAILURE);
+ finalResult = ($manager.isActive() ? OperationFinalResult.FINAL_SUCCESS : OperationFinalResult.FINAL_FAILURE);
}
switch (finalResult) {