erik/kobalt
erik/kobalt
1
0
Fork 0
mirror of https://github.com/ethauvin/kobalt.git synced 2025-04-27 00:38:11 -07:00
Code Releases Activity

Fix error case.

Browse source
This commit is contained in:
Cedric Beust 2016-04-18 03:29:41 -08:00
parent 7c1823941f
commit b7261182e8
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

3
modules/kobalt-plugin-api/src/main/kotlin/com/beust/kobalt/internal/DynamicGraph.kt
View file

@ -142,7 +142,7 @@ class DynamicGraphExecutor<T>(val graph : DynamicGraph<T>, val factory: IThreadW
var gotError = false var gotError = false
val nodesRun = hashSetOf<T>() val nodesRun = hashSetOf<T>()
var newFreeNodes = HashSet<T>(graph.freeNodes) var newFreeNodes = HashSet<T>(graph.freeNodes)
while (! gotError && running > 0 || newFreeNodes.size > 0) { while (! gotError && (running > 0 || newFreeNodes.size > 0)) {
nodesRun.addAll(newFreeNodes) nodesRun.addAll(newFreeNodes)
val callables : List<IWorker<T>> = factory.createWorkers(newFreeNodes) val callables : List<IWorker<T>> = factory.createWorkers(newFreeNodes)
callables.forEach { completion.submit(it) } callables.forEach { completion.submit(it) }
@ -160,6 +160,7 @@ class DynamicGraphExecutor<T>(val graph : DynamicGraph<T>, val factory: IThreadW
newFreeNodes.addAll(graph.freeNodes.minus(nodesRun)) newFreeNodes.addAll(graph.freeNodes.minus(nodesRun))
} else { } else {
log(2, "Task failed: $taskResult") log(2, "Task failed: $taskResult")
newFreeNodes.clear()
gotError = true gotError = true
} }
} catch(ex: TimeoutException) { } catch(ex: TimeoutException) {