From 625ecec7f6694d00dc9916318c20033b3e4ea589 Mon Sep 17 00:00:00 2001 From: Geir Storli Date: Fri, 29 Mar 2019 14:42:15 +0000 Subject: Support handling a list of log messages and flush after each time. --- .../java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethod.java | 1 + logserver/src/main/java/com/yahoo/logserver/LogDispatcher.java | 4 +++- .../ai/vespa/logserver/protocol/ArchiveLogMessagesMethodTest.java | 1 + 3 files changed, 5 insertions(+), 1 deletion(-) (limited to 'logserver/src') diff --git a/logserver/src/main/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethod.java b/logserver/src/main/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethod.java index 9d234b73692..f210ce38457 100644 --- a/logserver/src/main/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethod.java +++ b/logserver/src/main/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethod.java @@ -76,6 +76,7 @@ public class ArchiveLogMessagesMethod { return; } logDispatcher.handle(ProtobufSerialization.fromLogRequest(logRequestPayload)); + logDispatcher.flush(); rpcRequest.returnValues().add(new Int8Value((byte)0)); byte[] responsePayload = ProtobufSerialization.toLogResponse(); rpcRequest.returnValues().add(new Int32Value(responsePayload.length)); diff --git a/logserver/src/main/java/com/yahoo/logserver/LogDispatcher.java b/logserver/src/main/java/com/yahoo/logserver/LogDispatcher.java index 65fa83598b6..9b5816dc252 100644 --- a/logserver/src/main/java/com/yahoo/logserver/LogDispatcher.java +++ b/logserver/src/main/java/com/yahoo/logserver/LogDispatcher.java @@ -88,7 +88,9 @@ public class LogDispatcher implements LogHandler, SelectLoopHook { } public void handle(List messages) { - throw new IllegalStateException("method not supported"); + for (var message : messages) { + handle(message); + } } /** diff --git a/logserver/src/test/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethodTest.java b/logserver/src/test/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethodTest.java index a30df6bb050..847975bf2d9 100644 --- a/logserver/src/test/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethodTest.java +++ b/logserver/src/test/java/ai/vespa/logserver/protocol/ArchiveLogMessagesMethodTest.java @@ -47,6 +47,7 @@ public class ArchiveLogMessagesMethodTest { } } verify(logDispatcher).handle(new ArrayList<>(messages)); + verify(logDispatcher).flush(); } private static class TestClient implements AutoCloseable { -- cgit v1.2.3