Skip to content
Snippets Groups Projects
Commit 1e011a2d authored by Nikolaus Huber's avatar Nikolaus Huber
Browse files

added log messages for tactic execution

removed log messages for adaptationPlan

git-svn-id: https://se1.informatik.uni-wuerzburg.de/usvn/svn/code/code/DMM/trunk@12188 9e42b895-fcda-4063-8a3b-11be15eb1bbd
parent baf8443a
No related branches found
No related tags found
No related merge requests found
......@@ -31,20 +31,21 @@ import edu.kit.ipd.descartes.mm.resourcelandscape.ResourcelandscapePackage;
public class TacticExecutor {
private static Logger logger = Logger.getLogger(TacticExecutor.class);
private List<IObserver> observers = new ArrayList<IObserver>();
private IActionHandler dmmModelActionHandler;
private TacticsHistory hist;
private ChangeDescription changeDescription = null;
public TacticExecutor(IActionHandler actionExecutor) {
dmmModelActionHandler = actionExecutor;
hist = TacticsHistory.getInstance();
register(BlueYonderExperimentTracker.getInstance()); // TODO implement clean observer pattern
}
/**
private static Logger logger = Logger.getLogger(TacticExecutor.class);
private List<IObserver> observers = new ArrayList<IObserver>();
private IActionHandler dmmModelActionHandler;
private TacticsHistory hist;
private ChangeDescription changeDescription = null;
public TacticExecutor(IActionHandler actionExecutor) {
dmmModelActionHandler = actionExecutor;
hist = TacticsHistory.getInstance();
register(BlueYonderExperimentTracker.getInstance()); // TODO implement clean observer
// pattern
}
/**
* Applies the the given tactic.
*
* @param currentTactic
......@@ -52,38 +53,37 @@ public class TacticExecutor {
* @return
*/
public void applyTactic(WeightedTactic weightedTactic) {
try {
AdaptationProcessModelLoader.startRecording();
try {
logger.info("Applying tactic " + weightedTactic.getUsedTactic().getName() + ", ID: "
+ weightedTactic.getUsedTactic().getId() + ".");
AdaptationProcessModelLoader.startRecording();
executeAdaptationPlan(weightedTactic.getUsedTactic().getImplementedPlan());
logger.info("Tactic " + weightedTactic.getUsedTactic().getName()
+ " successfully applied.");
logger.info("Tactic " + weightedTactic.getUsedTactic().getName() + " successfully applied.");
hist.add(weightedTactic, TacticsHistory.NO_RESULT, true);
// if this point is reached everything was fine, so persist them (save the models)
dmmModelActionHandler.persistActions();
changeDescription = AdaptationProcessModelLoader.endRecording();
return;
} catch (OperationNotPerformedException e) {
logger.error("Tactic " + weightedTactic.getUsedTactic().getName()
+ " could not be executed. Please check adaptation plan and/or log files for errors.", e);
hist.add(weightedTactic, TacticsHistory.NO_RESULT, false);
logger.error("Tactic " + weightedTactic.getUsedTactic().getName()
+ " could not be executed. Please check adaptation plan and/or log files for errors.", e);
hist.add(weightedTactic, TacticsHistory.NO_RESULT, false);
/*
* TODO Something went wrong.
* 1) Detect error
* 2) reevaluate tactics
* 3) apply different tactic.
* TODO Something went wrong. 1) Detect error 2) reevaluate tactics 3) apply different
* tactic.
*/
}
}
private StartAction findStartAction(AdaptationPlan plan) {
for (AbstractControlFlowElement abstractControlFlowElement : plan.getSteps()) {
// Find start of adaptation plan
if (abstractControlFlowElement instanceof StartAction) {
return (StartAction) abstractControlFlowElement;
}
}
return null;
for (AbstractControlFlowElement abstractControlFlowElement : plan.getSteps()) {
// Find start of adaptation plan
if (abstractControlFlowElement instanceof StartAction) {
return (StartAction) abstractControlFlowElement;
}
}
return null;
}
/**
......@@ -97,50 +97,49 @@ public class TacticExecutor {
private void executeAdaptationPlan(AdaptationPlan plan) throws OperationNotPerformedException {
StartAction start = findStartAction(plan);
if (start == null)
throw new OperationNotPerformedException("No start action for adaptation plan " + plan.getName() + " found.");
if (start == null)
throw new OperationNotPerformedException("No start action for adaptation plan " + plan.getName()
+ " found.");
logger.info("Executing the adaptation plan <<" + plan.getName() + ">>.");
try {
executeNextStep(start.getSuccessor());
} catch (InvalidAdaptationPlan e) {
logger.error("Invalid adaptation plan <<" + plan.getName() + ">> when executing action with ID <<" + start.getId() + ">>.", e);
logger.error(
"Invalid adaptation plan <<" + plan.getName() + ">> when executing action with ID <<"
+ start.getId() + ">>.", e);
}
logger.info("Adaptation plan of adaptation plan <<" + plan.getName() + ">> terminated.");
}
private void executeNextStep(AbstractControlFlowElement step)
throws OperationNotPerformedException, InvalidAdaptationPlan {
if (step == null)
throw new InvalidAdaptationPlan("Current AbstractControlFlowElement is null!");
if (step instanceof StopAction) {
return;
} else if (step instanceof BranchAction) {
executeBranchAction(step);
} else if (step instanceof LoopAction) {
execLoopAction(step);
} else if (step instanceof ActionReference) {
executeReferredAction(step);
} else // Handle invalid actions and control flow elements
throw new OperationNotPerformedException(
"No valid control flow element " + step.toString());
// in any case (except stop action)
// continue with the next step
executeNextStep(step.getSuccessor());
}
private void executeNextStep(AbstractControlFlowElement step) throws OperationNotPerformedException,
InvalidAdaptationPlan {
if (step == null)
throw new InvalidAdaptationPlan("Current AbstractControlFlowElement is null!");
if (step instanceof StopAction) {
return;
} else if (step instanceof BranchAction) {
executeBranchAction(step);
} else if (step instanceof LoopAction) {
execLoopAction(step);
} else if (step instanceof ActionReference) {
executeReferredAction(step);
} else
// Handle invalid actions and control flow elements
throw new OperationNotPerformedException("No valid control flow element " + step.toString());
// in any case (except stop action)
// continue with the next step
executeNextStep(step.getSuccessor());
}
private void executeReferredAction(AbstractControlFlowElement step) throws OperationNotPerformedException {
ActionReference ref = (ActionReference) step;
Action action = ref.getRefersTo();
logger.info("Executing action <<" + action.getName() + ">>.");
AdaptationPoint currentAdaptationPoint = action
.getReferredAdaptationPoint();
dmmModelActionHandler.execute(currentAdaptationPoint,
action.getAdaptationActionOperation());
AdaptationPoint currentAdaptationPoint = action.getReferredAdaptationPoint();
dmmModelActionHandler.execute(currentAdaptationPoint, action.getAdaptationActionOperation());
}
private void executeBranchAction(AbstractControlFlowElement branchAction) throws OperationNotPerformedException {
......@@ -155,9 +154,9 @@ public class TacticExecutor {
LoopAction loop = (LoopAction) loopAction;
Parameter counter = loop.getCounter();
int counterValue = Integer.parseInt(counter.getValue());
int i = 1;
while (i <= counterValue) {
logger.debug("Executing iteration " + i + " of loop action " + loop.getBody().getName());
executeAdaptationPlan(loop.getBody());
......@@ -176,7 +175,7 @@ public class TacticExecutor {
case ContainerrepositoryPackage.CONTAINER_TEMPLATE:
context = ContainerrepositoryPackage.Literals.CONTAINER_TEMPLATE;
break;
// TODO add further contexts if necessary
// TODO add further contexts if necessary
default:
logger.error("Could not set context for eClass " + obj.getClass());
return false;
......@@ -188,16 +187,16 @@ public class TacticExecutor {
public void undoPreviousTactic() {
logger.info("Reverting model to previous state");
for(IObserver o : observers)
for (IObserver o : observers)
o.undo();
if (changeDescription != null)
changeDescription.apply();
}
public void register(IObserver observer) {
observers.add(observer);
}
public void remove(IObserver observer) {
observers.remove(observer);
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment