diff options
author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-08-09 16:01:44 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-08-09 16:01:44 +0200 |
commit | 904dfd949a04be4dcbd9f4dfea0f6b87da84f942 (patch) | |
tree | 2d2e5dd00529b83656a43d13b6a90de3668b73d4 /vespa-feed-client-cli | |
parent | 54736ecad0dd57224282755361c93731501c8911 (diff) | |
parent | d6353e8248bfa2819633b0512f50ce3b94da1b09 (diff) |
Merge pull request #18696 from vespa-engine/jonmv/feed-client-cli-print-progress
Start progress printer thread before all feeding is complete ...
Diffstat (limited to 'vespa-feed-client-cli')
-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); } |