From ad237aba91d05c81d28be2bce185e1eab2ba9bd0 Mon Sep 17 00:00:00 2001
From: Harald Musum <musum@yahooinc.com>
Date: Wed, 19 Oct 2022 09:14:39 +0200
Subject: Switch to a new file if some time after first write has passed

---
 .../main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

(limited to 'container-search/src/main/java/com/yahoo/search/logging/AbstractSpoolingLogger.java')

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();
-- 
cgit v1.2.3