summaryrefslogtreecommitdiff
path: root/opendc-compute/opendc-compute-simulator/src/main/java
diff options
context:
space:
mode:
authorDante Niewenhuis <d.niewenhuis@hotmail.com>2025-05-16 10:32:08 +0200
committerGitHub <noreply@github.com>2025-05-16 10:32:08 +0200
commitd70312f122d9ef7c31b05757239ffc66af832dee (patch)
treec8eb5d86ce751b783c3f15744bcda35861eed65d /opendc-compute/opendc-compute-simulator/src/main/java
parent1bc17abd7691bc81f11ee125e2eeb4cb08da5245 (diff)
Updated website documentation (#334)
* Updated website documentation * Updated some documentation and fixed links * small updates * small updates
Diffstat (limited to 'opendc-compute/opendc-compute-simulator/src/main/java')
-rw-r--r--opendc-compute/opendc-compute-simulator/src/main/java/org/opendc/compute/simulator/service/ComputeService.java17
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);