From 67dd7e54e9ff2f8a0ad0ba67a5695a69b4bd52dc Mon Sep 17 00:00:00 2001
From: Cedric Beust <cedric@beust.com>
Date: Sun, 26 Mar 2017 10:18:27 -0700
Subject: [PATCH] Allow ParallelLogger to log from apply().

---
 .../com/beust/kobalt/internal/ParallelLogger.kt     | 13 +++++++++----
 1 file changed, 9 insertions(+), 4 deletions(-)

diff --git a/modules/kobalt-plugin-api/src/main/kotlin/com/beust/kobalt/internal/ParallelLogger.kt b/modules/kobalt-plugin-api/src/main/kotlin/com/beust/kobalt/internal/ParallelLogger.kt
index 7fda0eac..4062c91d 100644
--- a/modules/kobalt-plugin-api/src/main/kotlin/com/beust/kobalt/internal/ParallelLogger.kt
+++ b/modules/kobalt-plugin-api/src/main/kotlin/com/beust/kobalt/internal/ParallelLogger.kt
@@ -32,15 +32,17 @@ class ParallelLogger @Inject constructor(val args: Args) : ILogger {
             val newLine: Boolean)
     private val logLines = ConcurrentHashMap<CharSequence, ArrayList<LogLine>>()
 
-    private val runningProjects = ConcurrentLinkedQueue<String>()
+    private val runningProjects = ConcurrentLinkedQueue<CharSequence>()
     var startTime: Long? = null
 
     fun onProjectStarted(name: String) {
         if (startTime == null) {
             startTime = System.currentTimeMillis()
         }
-        runningProjects.add(name)
-        logLines[name] = arrayListOf()
+        if (! runningProjects.contains(name)) {
+            runningProjects.add(name)
+            logLines[name] = arrayListOf()
+        }
         if (currentName == null) {
             currentName = name
         }
@@ -74,7 +76,7 @@ class ParallelLogger @Inject constructor(val args: Args) : ILogger {
     }
 
     val LOCK = Any()
-    var currentName: String? = null
+    var currentName: CharSequence? = null
         set(newName) {
             field = newName
         }
@@ -119,6 +121,9 @@ class ParallelLogger @Inject constructor(val args: Args) : ILogger {
         if (args.sequential) {
             kobaltLog(level, message, newLine)
         } else {
+            if (! runningProjects.contains(tag)) {
+                runningProjects.add(tag)
+            }
             addLogLine(tag, LogLine(tag, level, message, Type.LOG, newLine))
         }
     }