aboutsummaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/prelude/cluster
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-09-23 16:18:40 +0200
committerGitHub <noreply@github.com>2019-09-23 16:18:40 +0200
commit8070bd0d1a0cd0eda908cc32fc2506d247ec2f67 (patch)
tree5bc2817ade8d96ae87ede69000ed8de09306a9be /container-search/src/main/java/com/yahoo/prelude/cluster
parent463bb2a8400f0fd9370f155454c385eb98be2acb (diff)
Revert "Revert "Balder/remove tld from config model rebased""
Diffstat (limited to 'container-search/src/main/java/com/yahoo/prelude/cluster')
-rw-r--r--container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java35
1 files changed, 8 insertions, 27 deletions
diff --git a/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java b/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java
index 22af77020eb..1f621eb926c 100644
--- a/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java
+++ b/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java
@@ -23,7 +23,6 @@ import com.yahoo.search.dispatch.Dispatcher;
import com.yahoo.search.query.ParameterParser;
import com.yahoo.search.result.ErrorMessage;
import com.yahoo.search.searchchain.Execution;
-import com.yahoo.statistics.Statistics;
import com.yahoo.vespa.config.search.DispatchConfig;
import com.yahoo.vespa.streamingvisitors.VdsStreamingSearcher;
import org.apache.commons.lang.StringUtils;
@@ -107,17 +106,9 @@ public class ClusterSearcher extends Searcher {
vipStatus.addToRotation(searcher.getName());
} else {
Dispatcher dispatcher = Dispatcher.create(id.stringValue(), dispatchConfig, clusterInfoConfig.nodeCount(), vipStatus, metric);
- for (int dispatcherIndex = 0; dispatcherIndex < searchClusterConfig.dispatcher().size(); dispatcherIndex++) {
- try {
- if ( ! isRemote(searchClusterConfig.dispatcher(dispatcherIndex).host())) {
- FastSearcher searcher = searchDispatch(searchClusterIndex, fs4ResourcePool.getServerId(), docSumParams,
- documentDbConfig, dispatcher, dispatcherIndex);
- addBackendSearcher(searcher);
- }
- } catch (UnknownHostException e) {
- throw new RuntimeException(e);
- }
- }
+ FastSearcher searcher = searchDispatch(searchClusterIndex, fs4ResourcePool.getServerId(), docSumParams, documentDbConfig, dispatcher);
+ addBackendSearcher(searcher);
+
}
if ( server == null ) {
throw new IllegalStateException("ClusterSearcher should have backend.");
@@ -133,26 +124,16 @@ public class ClusterSearcher extends Searcher {
return null;
}
- /**
- * Returns false if this host is local.
- */
- boolean isRemote(String host) throws UnknownHostException {
- return (InetAddress.getByName(host).isLoopbackAddress())
- ? false
- : !host.equals(HostName.getLocalhost());
- }
-
- private static ClusterParams makeClusterParams(int searchclusterIndex, int dispatchIndex) {
- return new ClusterParams("sc" + searchclusterIndex + ".num" + dispatchIndex);
+ private static ClusterParams makeClusterParams(int searchclusterIndex) {
+ return new ClusterParams("sc" + searchclusterIndex + ".num" + 0);
}
private static FastSearcher searchDispatch(int searchclusterIndex,
String serverId,
SummaryParameters docSumParams,
DocumentdbInfoConfig documentdbInfoConfig,
- Dispatcher dispatcher,
- int dispatcherIndex) {
- ClusterParams clusterParams = makeClusterParams(searchclusterIndex, dispatcherIndex);
+ Dispatcher dispatcher) {
+ ClusterParams clusterParams = makeClusterParams(searchclusterIndex);
return new FastSearcher(serverId, dispatcher, docSumParams, clusterParams, documentdbInfoConfig);
}
@@ -164,7 +145,7 @@ public class ClusterSearcher extends Searcher {
if (searchClusterConfig.searchdef().size() != 1) {
throw new IllegalArgumentException("Search clusters in streaming search shall only contain a single searchdefinition : " + searchClusterConfig.searchdef());
}
- ClusterParams clusterParams = makeClusterParams(searchclusterIndex, 0);
+ ClusterParams clusterParams = makeClusterParams(searchclusterIndex);
VdsStreamingSearcher searcher = new VdsStreamingSearcher();
searcher.setSearchClusterConfigId(searchClusterConfig.rankprofiles().configid());
searcher.setDocumentType(searchClusterConfig.searchdef(0));