diff options
Diffstat (limited to 'opendc-compute/opendc-compute-simulator/src/main/java/org/opendc')
| -rw-r--r-- | opendc-compute/opendc-compute-simulator/src/main/java/org/opendc/compute/simulator/service/ComputeService.java | 7 |
1 files changed, 5 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 8df0d7d8..b6a69209 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 @@ -346,8 +346,11 @@ public final class ComputeService implements AutoCloseable { public void setTaskToBeRemoved(ServiceTask task) { this.tasksToRemove.add(task); - if ((tasksTerminated + tasksCompleted) == tasksExpected) { - metricReader.loggState(); // Logg the state for the final time. This will also delete all remaining tasks. + if ((this.tasksTerminated + this.tasksCompleted) == this.tasksExpected) { + if (this.metricReader != null) { + this.metricReader + .loggState(); // Logg the state for the final time. This will also delete all remaining tasks. + } } } |