summaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/dispatch/SearchInvoker.java
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-09-16 22:56:07 +0200
committerGitHub <noreply@github.com>2019-09-16 22:56:07 +0200
commitecb09fabab58ba8336626e07ab73fabf8ded7199 (patch)
tree3832bee43ce7c2d1df314897dd9071bb15444618 /container-search/src/main/java/com/yahoo/search/dispatch/SearchInvoker.java
parentc5a2086cf32305c6e9dde031e7b460a04f452c0f (diff)
Revert "Revert "Revert "Use a LeanHit until merging is done." MERGEOK""
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/SearchInvoker.java')
-rw-r--r--container-search/src/main/java/com/yahoo/search/dispatch/SearchInvoker.java13
1 files changed, 6 insertions, 7 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/SearchInvoker.java b/container-search/src/main/java/com/yahoo/search/dispatch/SearchInvoker.java
index 77b3df7c83a..3bfb9089457 100644
--- a/container-search/src/main/java/com/yahoo/search/dispatch/SearchInvoker.java
+++ b/container-search/src/main/java/com/yahoo/search/dispatch/SearchInvoker.java
@@ -32,15 +32,14 @@ public abstract class SearchInvoker extends CloseableInvoker {
*/
public Result search(Query query, Execution execution) throws IOException {
sendSearchRequest(query);
- InvokerResult result = getSearchResult(execution);
- setFinalStatus(result.getResult().hits().getError() == null);
- result.complete();
- return result.getResult();
+ Result result = getSearchResult(execution);
+ setFinalStatus(result.hits().getError() == null);
+ return result;
}
protected abstract void sendSearchRequest(Query query) throws IOException;
- protected abstract InvokerResult getSearchResult(Execution execution) throws IOException;
+ protected abstract Result getSearchResult(Execution execution) throws IOException;
protected void setMonitor(ResponseMonitor<SearchInvoker> monitor) {
this.monitor = monitor;
@@ -56,12 +55,12 @@ public abstract class SearchInvoker extends CloseableInvoker {
return node.map(Node::key);
}
- protected InvokerResult errorResult(Query query, ErrorMessage errorMessage) {
+ protected Result errorResult(Query query, ErrorMessage errorMessage) {
Result error = new Result(query, errorMessage);
Coverage errorCoverage = new Coverage(0, 0, 0);
errorCoverage.setNodesTried(1);
error.setCoverage(errorCoverage);
- return new InvokerResult(error);
+ return error;
}
}