diff options
author | Harald Musum <musum@yahooinc.com> | 2022-10-19 09:14:39 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2022-10-19 09:14:39 +0200 |
commit | ad237aba91d05c81d28be2bce185e1eab2ba9bd0 (patch) | |
tree | 5887fff189b15fc577bd5c3f31b84c6c5c2254d9 /container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java | |
parent | 733cb216bc1519e34749a5e358f7e12c962c96d6 (diff) |
Switch to a new file if some time after first write has passed
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java b/container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java index c9c6546711a..3569a28f563 100644 --- a/container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java +++ b/container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java @@ -3,6 +3,7 @@ package com.yahoo.search.logging; import com.yahoo.concurrent.DaemonThreadFactory; import java.io.IOException; +import java.time.Clock; import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledThreadPoolExecutor; @@ -25,7 +26,7 @@ public abstract class AbstractSpoolingLogger extends AbstractThreadedLogger impl protected final Spooler spooler; public AbstractSpoolingLogger() { - this(new Spooler()); + this(new Spooler(Clock.systemUTC())); } public AbstractSpoolingLogger(Spooler spooler) { @@ -35,6 +36,7 @@ public abstract class AbstractSpoolingLogger extends AbstractThreadedLogger impl public void run() { try { + spooler.switchFileIfNeeded(); spooler.processFiles(this::transport); } catch (IOException e) { e.printStackTrace(); |