summaryrefslogtreecommitdiffstats
path: root/logserver
diff options
context:
space:
mode:
authorBjørn Christian Seime <bjorncs@verizonmedia.com>2021-02-09 14:11:01 +0100
committerBjørn Christian Seime <bjorncs@verizonmedia.com>2021-02-09 14:11:01 +0100
commitdcf48329e291a06082e6693c6925f22b16000f3e (patch)
tree3da5c746707dd1ae1b9e3070abf7c6d2b8886992 /logserver
parent63a1628f1bbef54044c15f55fea518eb12e9b19a (diff)
Sleep in end of iteration
Diffstat (limited to 'logserver')
-rw-r--r--logserver/src/main/java/com/yahoo/logserver/Flusher.java9
1 files changed, 5 insertions, 4 deletions
diff --git a/logserver/src/main/java/com/yahoo/logserver/Flusher.java b/logserver/src/main/java/com/yahoo/logserver/Flusher.java
index 07ecae66d90..a837f9491dc 100644
--- a/logserver/src/main/java/com/yahoo/logserver/Flusher.java
+++ b/logserver/src/main/java/com/yahoo/logserver/Flusher.java
@@ -1,14 +1,14 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.logserver;
+import com.yahoo.logserver.handlers.LogHandler;
+
import java.lang.ref.WeakReference;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
-import java.util.logging.Logger;
-
import java.util.logging.Level;
-import com.yahoo.logserver.handlers.LogHandler;
+import java.util.logging.Logger;
/**
* @author Bjorn Borud
@@ -32,10 +32,10 @@ public class Flusher extends Thread {
logHandlers.add(new WeakReference<>(logHandler));
}
+ @Override
public synchronized void run() {
try {
while(!isInterrupted()) {
- Thread.sleep(2000);
Iterator<WeakReference<LogHandler>> it = logHandlers.iterator();
while (it.hasNext()) {
WeakReference<LogHandler> r = it.next();
@@ -49,6 +49,7 @@ public class Flusher extends Thread {
log.log(Level.FINE, "Flushing " + h);
}
}
+ Thread.sleep(2000);
}
} catch (InterruptedException e) {
log.log(Level.WARNING, "flusher was interrupted", e);