diff options
author | Ola Aunrønning <olaa@verizonmedia.com> | 2020-02-19 12:11:00 +0100 |
---|---|---|
committer | Ola Aunrønning <olaa@verizonmedia.com> | 2020-02-19 12:11:00 +0100 |
commit | 3cbe2317700f03b98f68cf18eb6e902dea3402ce (patch) | |
tree | d77b98f37bcc4083816bc7c52c546461f4124ba7 /vespa-http-client | |
parent | 1a230786bd0709198dcd8e72ed8d326d26c073d8 (diff) |
Read input size from FormatInputStream instead of file
Diffstat (limited to 'vespa-http-client')
-rw-r--r-- | vespa-http-client/src/main/java/com/yahoo/vespa/http/client/runner/Runner.java | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/runner/Runner.java b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/runner/Runner.java index 0e202d1f348..e557bb3ca1b 100644 --- a/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/runner/Runner.java +++ b/vespa-http-client/src/main/java/com/yahoo/vespa/http/client/runner/Runner.java @@ -70,7 +70,7 @@ public class Runner { Optional.ofNullable(commandLineArgs.getFile()), commandLineArgs.getAddRootElementToXml()); - + double inputSizeMb = ((double) formatInputStream.getInputStream().available()) / 1024.0 / 1024.0; int intervalOfLogging = commandLineArgs.getVerbose() ? commandLineArgs.getWhenVerboseEnabledPrintMessageForEveryXDocuments() : Integer.MAX_VALUE; @@ -86,10 +86,9 @@ public class Runner { if (commandLineArgs.getVerbose()) { System.err.println(feedClient.getStatsAsJson()); - double fileSizeMb = ((double) new File(commandLineArgs.getFile()).length()) / 1024.0 / 1024.0; double transferTimeSec = ((double) sendTotalTimeMs) / 1000.0; - System.err.println("Sent " + fileSizeMb + " MB in " + transferTimeSec + " seconds."); - System.err.println("Speed: " + ((fileSizeMb / transferTimeSec) * 8.0) + " Mbits/sec, + HTTP overhead " + + System.err.println("Sent " + inputSizeMb + " MB in " + transferTimeSec + " seconds."); + System.err.println("Speed: " + ((inputSizeMb / transferTimeSec) * 8.0) + " Mbits/sec, + HTTP overhead " + "(not taking compression into account)"); if (transferTimeSec > 0) { System.err.printf("Docs/sec %.3f%n\n", numSent.get() / transferTimeSec); |