1 files changed, 57 insertions, 0 deletions
diff --git a/logserver/src/main/java/com/yahoo/logserver/Flusher.java b/logserver/src/main/java/com/yahoo/logserver/Flusher.java
new file mode 100644
index 00000000000..ee2b317f573
--- /dev/null
+++ b/logserver/src/main/java/com/yahoo/logserver/Flusher.java
@@ -0,0 +1,57 @@
+// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+package com.yahoo.logserver;
+
+import java.lang.ref.WeakReference;
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+import java.util.logging.Logger;
+
+import com.yahoo.log.LogLevel;
+import com.yahoo.logserver.handlers.LogHandler;
+
+/**
+ * @author <a href="mailto:borud@yahoo-inc.com">Bjorn Borud</a>
+ */
+public class Flusher extends Thread {
+    private static final Logger log = Logger.getLogger(Flusher.class.getName());
+    private static final Flusher instance;
+    private static final List<WeakReference<LogHandler>> logHandlers =
+            new ArrayList<WeakReference<LogHandler>>();
+
+    static {
+        instance = new Flusher();
+        instance.start();
+    }
+
+    Flusher() {
+        super("flusher");
+    }
+
+    public static synchronized void register(LogHandler logHandler) {
+        logHandlers.add(new WeakReference<LogHandler>(logHandler));
+    }
+
+    public synchronized void run() {
+        try {
+            while(!isInterrupted()) {
+                Thread.sleep(2000);
+                Iterator<WeakReference<LogHandler>> it = logHandlers.iterator();
+                while (it.hasNext()) {
+                    WeakReference<LogHandler> r = it.next();
+                    LogHandler h = r.get();
+                    if (h == null) {
+                        it.remove();
+                    } else {
+                        h.flush();
+                    }
+                    if (log.isLoggable(LogLevel.DEBUG)) {
+                        log.log(LogLevel.DEBUG, "Flushing " + h);
+                    }
+                }
+            }
+        } catch (InterruptedException e) {
+            log.log(LogLevel.WARNING, "flusher was interrupted", e);
+        }
+    }
+}