diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2019-09-13 21:46:03 +0200 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2019-09-13 21:46:03 +0200 |
commit | c7083376ca06579bbf644f3ec939bcebfebde3c9 (patch) | |
tree | db4ea2fd90c505d3c7c65a86e6e4f691e088c35a /container-core/src/main/java/com/yahoo/container/handler/LogHandler.java | |
parent | 078da6a5b6884f7d5441d0d0c16007dbe536773b (diff) |
Filter first and last log files on timestamp, and don't quit reading too early
Diffstat (limited to 'container-core/src/main/java/com/yahoo/container/handler/LogHandler.java')
-rw-r--r-- | container-core/src/main/java/com/yahoo/container/handler/LogHandler.java | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/container-core/src/main/java/com/yahoo/container/handler/LogHandler.java b/container-core/src/main/java/com/yahoo/container/handler/LogHandler.java index 645c231531d..0b42b3a481b 100644 --- a/container-core/src/main/java/com/yahoo/container/handler/LogHandler.java +++ b/container-core/src/main/java/com/yahoo/container/handler/LogHandler.java @@ -29,10 +29,10 @@ public class LogHandler extends ThreadedHttpRequestHandler { @Override public HttpResponse handle(HttpRequest request) { - Instant earliestLogThreshold = Optional.ofNullable(request.getProperty("from")) - .map(Long::valueOf).map(Instant::ofEpochMilli).orElse(Instant.MIN); - Instant latestLogThreshold = Optional.ofNullable(request.getProperty("to")) - .map(Long::valueOf).map(Instant::ofEpochMilli).orElseGet(Instant::now); + Instant from = Optional.ofNullable(request.getProperty("from")) + .map(Long::valueOf).map(Instant::ofEpochMilli).orElse(Instant.MIN); + Instant to = Optional.ofNullable(request.getProperty("to")) + .map(Long::valueOf).map(Instant::ofEpochMilli).orElse(Instant.MAX); return new HttpResponse(200) { { @@ -40,7 +40,7 @@ public class LogHandler extends ThreadedHttpRequestHandler { } @Override public void render(OutputStream outputStream) { - logReader.writeLogs(outputStream, earliestLogThreshold, latestLogThreshold); + logReader.writeLogs(outputStream, from, to); } }; } |