diff options
author | Jon Marius Venstad <venstad@gmail.com> | 2021-08-09 15:38:18 +0200 |
---|---|---|
committer | Jon Marius Venstad <venstad@gmail.com> | 2021-08-09 15:38:18 +0200 |
commit | d6353e8248bfa2819633b0512f50ce3b94da1b09 (patch) | |
tree | 28a11070e7b728262a15678d565c190a6f25bed0 /vespa-feed-client-cli/src | |
parent | 4b5ca059eda0ab6f3c1fa0c718980d7a6e978288 (diff) |
Start progress printer thread before all feeding is complete ...
Diffstat (limited to 'vespa-feed-client-cli/src')
-rw-r--r-- | vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/CliClient.java | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/CliClient.java b/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/CliClient.java index 19d1e4332d3..768cdf4c171 100644 --- a/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/CliClient.java +++ b/vespa-feed-client-cli/src/main/java/ai/vespa/feed/client/CliClient.java @@ -60,11 +60,6 @@ public class CliClient { CountDownLatch latch = new CountDownLatch(1); AtomicReference<FeedException> fatal = new AtomicReference<>(); long startNanos = System.nanoTime(); - feeder.feedMany(in, new ResultCallback() { - @Override public void onNextResult(Result result, FeedException error) { handleResult(result, error, cliArgs); } - @Override public void onError(FeedException error) { fatal.set(error); latch.countDown(); } - @Override public void onComplete() { latch.countDown(); } - }); if (cliArgs.showProgress()) { Thread progressPrinter = new Thread(() -> { try { @@ -77,7 +72,14 @@ public class CliClient { progressPrinter.setDaemon(true); progressPrinter.start(); } + + feeder.feedMany(in, new ResultCallback() { + @Override public void onNextResult(Result result, FeedException error) { handleResult(result, error, cliArgs); } + @Override public void onError(FeedException error) { fatal.set(error); latch.countDown(); } + @Override public void onComplete() { latch.countDown(); } + }); latch.await(); + if (cliArgs.benchmarkModeEnabled()) { printBenchmarkResult(System.nanoTime() - startNanos, feedClient.stats(), systemOut); } |