diff options
Diffstat (limited to 'opendc-compute/opendc-compute-simulator/src/main/java/org/opendc/compute')
| -rw-r--r-- | opendc-compute/opendc-compute-simulator/src/main/java/org/opendc/compute/simulator/service/ComputeService.java | 17 |
1 files changed, 2 insertions, 15 deletions
diff --git a/opendc-compute/opendc-compute-simulator/src/main/java/org/opendc/compute/simulator/service/ComputeService.java b/opendc-compute/opendc-compute-simulator/src/main/java/org/opendc/compute/simulator/service/ComputeService.java index 6d973b3f..11394ce9 100644 --- a/opendc-compute/opendc-compute-simulator/src/main/java/org/opendc/compute/simulator/service/ComputeService.java +++ b/opendc-compute/opendc-compute-simulator/src/main/java/org/opendc/compute/simulator/service/ComputeService.java @@ -418,7 +418,8 @@ public final class ComputeService implements AutoCloseable, CarbonReceiver { LOGGER.debug("Enqueueing task {} to be assigned to host", task.getUid()); if (task.getNumFailures() >= maxNumFailures) { - LOGGER.warn("task {} has been terminated because it failed {} times", task, task.getNumFailures()); + LOGGER.warn("task {} has been terminated because it failed {} times", (Object) task, (Object) + task.getNumFailures()); tasksTerminated++; task.setState(TaskState.TERMINATED); @@ -493,20 +494,6 @@ public final class ComputeService implements AutoCloseable, CarbonReceiver { final ServiceFlavor flavor = task.getFlavor(); - // if (task.getNumFailures() >= maxNumFailures) { - // LOGGER.warn("task {} has been terminated because it failed {} times", task, - // task.getNumFailures()); - // - // taskQueue.remove(req); - // tasksPending--; - // tasksTerminated++; - // task.setState(TaskState.TERMINATED); - // - // scheduler.removeTask(task, hv); - // this.setTaskToBeRemoved(task); - // continue; - // } - if (result.getResultType() == SchedulingResultType.FAILURE) { LOGGER.trace("Task {} selected for scheduling but no capacity available for it at the moment", task); |