Use separate name per logger thread

3 files changed, 11 insertions, 5 deletions

diff --git a/jdisc_http_service/src/main/java/com/yahoo/container/logging/AccessLogHandler.java b/jdisc_http_service/src/main/java/com/yahoo/container/logging/AccessLogHandler.java
index 376be879965..89aab1513ee 100644
--- a/jdisc_http_service/src/main/java/com/yahoo/container/logging/AccessLogHandler.java
+++ b/jdisc_http_service/src/main/java/com/yahoo/container/logging/AccessLogHandler.java
@@ -11,7 +11,9 @@ class AccessLogHandler {
     private final LogFileHandler<RequestLogEntry> logFileHandler;
 
     AccessLogHandler(AccessLogConfig.FileHandler config, LogWriter<RequestLogEntry> logWriter) {
-        logFileHandler = new LogFileHandler<>(toCompression(config), config.pattern(), config.rotation(), config.symlink(), config.queueSize(), logWriter);
+        logFileHandler = new LogFileHandler<>(
+                toCompression(config), config.pattern(), config.rotation(),
+                config.symlink(), config.queueSize(), "request-logger", logWriter);
     }
 
     public void log(RequestLogEntry entry) {
diff --git a/jdisc_http_service/src/main/java/com/yahoo/container/logging/ConnectionLogHandler.java b/jdisc_http_service/src/main/java/com/yahoo/container/logging/ConnectionLogHandler.java
index 38d979e8138..7a0e8aca95e 100644
--- a/jdisc_http_service/src/main/java/com/yahoo/container/logging/ConnectionLogHandler.java
+++ b/jdisc_http_service/src/main/java/com/yahoo/container/logging/ConnectionLogHandler.java
@@ -15,6 +15,7 @@ class ConnectionLogHandler {
                 "0 60 ...",
                 String.format("ConnectionLog.%s", clusterName),
                 queueSize,
+                "connection-logger",
                 logWriter);
     }
 
diff --git a/jdisc_http_service/src/main/java/com/yahoo/container/logging/LogFileHandler.java b/jdisc_http_service/src/main/java/com/yahoo/container/logging/LogFileHandler.java
index 5aca804ba64..b2d7dd80b7f 100644
--- a/jdisc_http_service/src/main/java/com/yahoo/container/logging/LogFileHandler.java
+++ b/jdisc_http_service/src/main/java/com/yahoo/container/logging/LogFileHandler.java
@@ -46,8 +46,9 @@ class LogFileHandler <LOGTYPE> {
 
     @FunctionalInterface private interface Pollable<T> { Operation<T> poll() throws InterruptedException; }
 
-    LogFileHandler(Compression compression, String filePattern, String rotationTimes, String symlinkName, int queueSize, LogWriter<LOGTYPE> logWriter) {
-        this(compression, filePattern, calcTimesMinutes(rotationTimes), symlinkName, queueSize, logWriter);
+    LogFileHandler(Compression compression, String filePattern, String rotationTimes, String symlinkName, int queueSize,
+                   String threadName, LogWriter<LOGTYPE> logWriter) {
+        this(compression, filePattern, calcTimesMinutes(rotationTimes), symlinkName, queueSize, threadName, logWriter);
     }
 
     LogFileHandler(
@@ -56,9 +57,10 @@ class LogFileHandler <LOGTYPE> {
             long[] rotationTimes,
             String symlinkName,
             int queueSize,
+            String threadName,
             LogWriter<LOGTYPE> logWriter) {
         this.logQueue = new LinkedBlockingQueue<>(queueSize);
-        this.logThread = new LogThread<LOGTYPE>(logWriter, filePattern, compression, rotationTimes, symlinkName, this::poll);
+        this.logThread = new LogThread<>(logWriter, filePattern, compression, rotationTimes, symlinkName, threadName, this::poll);
         this.logThread.start();
     }
 
@@ -205,8 +207,9 @@ class LogFileHandler <LOGTYPE> {
                   Compression compression,
                   long[] rotationTimes,
                   String symlinkName,
+                  String threadName,
                   Pollable<LOGTYPE> operationProvider) {
-            super("Logger");
+            super(threadName);
             setDaemon(true);
             this.logWriter = logWriter;
             this.filePattern = filePattern;