From 2e819d59934b5308bc58d6c69709112e2a6af402 Mon Sep 17 00:00:00 2001
From: Fabian Mastenbroek <mail.fabianm@gmail.com>
Date: Tue, 13 Feb 2018 14:27:15 +0100
Subject: refactor(#18): Fix OpenDC model deployment

This change fixes the deployment of the OpenDC simulation model.
---
 .../com/atlarge/opendc/model/odc/topology/container/Datacenter.kt    | 5 +++++
 1 file changed, 5 insertions(+)

(limited to 'opendc-model-odc/core/src')

diff --git a/opendc-model-odc/core/src/main/kotlin/com/atlarge/opendc/model/odc/topology/container/Datacenter.kt b/opendc-model-odc/core/src/main/kotlin/com/atlarge/opendc/model/odc/topology/container/Datacenter.kt
index b9b804d3..7293d9f7 100644
--- a/opendc-model-odc/core/src/main/kotlin/com/atlarge/opendc/model/odc/topology/container/Datacenter.kt
+++ b/opendc-model-odc/core/src/main/kotlin/com/atlarge/opendc/model/odc/topology/container/Datacenter.kt
@@ -26,6 +26,7 @@ package com.atlarge.opendc.model.odc.topology.container
 
 import com.atlarge.opendc.model.odc.platform.scheduler.Scheduler
 import com.atlarge.opendc.model.odc.platform.workload.Task
+import com.atlarge.opendc.model.odc.platform.workload.TaskState
 import com.atlarge.opendc.model.odc.topology.machine.Machine
 import com.atlarge.opendc.model.topology.Topology
 import com.atlarge.opendc.model.topology.destinations
@@ -88,6 +89,10 @@ interface Datacenter : Process<Unit, Topology> {
             while (queue.isNotEmpty()) {
                 val msg = queue.poll()
                 if (msg is Task) {
+                    if (msg.state != TaskState.Underway) {
+                        logger.warn { "Received invalid task $msg"}
+                        continue
+                    }
                     msg.arrive(time)
                     scheduler.submit(msg)
                 }
-- 
cgit v1.2.3