summaryrefslogtreecommitdiff
path: root/opendc-compute/opendc-compute-simulator/src/main/java
diff options
context:
space:
mode:
authorSacheendra Talluri <sacheendra.t@gmail.com>2025-04-02 17:54:53 +0200
committerGitHub <noreply@github.com>2025-04-02 17:54:53 +0200
commit3a370ece860b0eba25cd1c7a366d767ae458192b (patch)
tree2f02db79ffddfa24ccf0a9345ac0472f5aa00f70 /opendc-compute/opendc-compute-simulator/src/main/java
parentaf632099d05636af3274ee95ada6b962703a67f0 (diff)
Separate timeshift into an interface and add it to memorizing (#329)
* Separate timeshift into an interface and add it to memorizing * Run spotless apply * Remove random from memorizing sched test * Record time on task termination * spotless apply
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.java2
-rw-r--r--opendc-compute/opendc-compute-simulator/src/main/java/org/opendc/compute/simulator/service/ServiceTask.java2
2 files changed, 2 insertions, 2 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 fb9dc6e6..6d973b3f 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
@@ -436,6 +436,7 @@ public final class ComputeService implements AutoCloseable, CarbonReceiver {
taskQueue.add(request);
}
tasksPending++;
+
requestSchedulingCycle();
return request;
}
@@ -484,7 +485,6 @@ public final class ComputeService implements AutoCloseable, CarbonReceiver {
iterator = taskQueue.iterator()) {
final SchedulingResult result = scheduler.select(iterator);
if (result.getResultType() == SchedulingResultType.EMPTY) {
-
break;
}
final HostView hv = result.getHost();
diff --git a/opendc-compute/opendc-compute-simulator/src/main/java/org/opendc/compute/simulator/service/ServiceTask.java b/opendc-compute/opendc-compute-simulator/src/main/java/org/opendc/compute/simulator/service/ServiceTask.java
index 6d097efb..66b69bde 100644
--- a/opendc-compute/opendc-compute-simulator/src/main/java/org/opendc/compute/simulator/service/ServiceTask.java
+++ b/opendc-compute/opendc-compute-simulator/src/main/java/org/opendc/compute/simulator/service/ServiceTask.java
@@ -251,7 +251,7 @@ public class ServiceTask {
this.numPauses++;
}
- if ((newState == TaskState.COMPLETED) || newState == TaskState.FAILED) {
+ if ((newState == TaskState.COMPLETED) || (newState == TaskState.FAILED) || (newState == TaskState.TERMINATED)) {
this.finishedAt = this.service.getClock().instant();
}