aboutsummaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2022-10-19 09:14:39 +0200
committerHarald Musum <musum@yahooinc.com>2022-10-19 09:14:39 +0200
commitad237aba91d05c81d28be2bce185e1eab2ba9bd0 (patch)
tree5887fff189b15fc577bd5c3f31b84c6c5c2254d9 /container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java
parent733cb216bc1519e34749a5e358f7e12c962c96d6 (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.java4
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();