summaryrefslogtreecommitdiffstats
path: root/container-search
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-09-22 09:13:54 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2019-09-22 09:13:54 +0200
commit8c66bd555439c4b8b554f54622241cba62ab49af (patch)
treeb844332ea9b7b403d6a0ec1e169b335338a0634c /container-search
parent4ddf0c7f069fe9d125b39eba44332b9027a91c2a (diff)
Follow api change
Diffstat (limited to 'container-search')
-rw-r--r--container-search/src/test/java/com/yahoo/prelude/fastsearch/test/MockDispatcher.java3
-rw-r--r--container-search/src/test/java/com/yahoo/search/dispatch/rpc/FillTestCase.java14
2 files changed, 7 insertions, 10 deletions
diff --git a/container-search/src/test/java/com/yahoo/prelude/fastsearch/test/MockDispatcher.java b/container-search/src/test/java/com/yahoo/prelude/fastsearch/test/MockDispatcher.java
index afb9cf6f571..0aa91442712 100644
--- a/container-search/src/test/java/com/yahoo/prelude/fastsearch/test/MockDispatcher.java
+++ b/container-search/src/test/java/com/yahoo/prelude/fastsearch/test/MockDispatcher.java
@@ -26,7 +26,7 @@ class MockDispatcher extends Dispatcher {
}
private MockDispatcher(SearchCluster searchCluster, DispatchConfig dispatchConfig, RpcResourcePool rpcResourcePool) {
- this(searchCluster, dispatchConfig, new RpcInvokerFactory(rpcResourcePool, searchCluster, dispatchConfig.dispatchWithProtobuf()));
+ this(searchCluster, dispatchConfig, new RpcInvokerFactory(rpcResourcePool, searchCluster));
}
private MockDispatcher(SearchCluster searchCluster, DispatchConfig dispatchConfig, RpcInvokerFactory invokerFactory) {
@@ -45,7 +45,6 @@ class MockDispatcher extends Dispatcher {
dispatchConfigNodeBuilder.key(key++); // not used
dispatchConfigBuilder.node(dispatchConfigNodeBuilder);
}
- dispatchConfigBuilder.useFdispatchByDefault(true);
return new DispatchConfig(dispatchConfigBuilder);
}
}
diff --git a/container-search/src/test/java/com/yahoo/search/dispatch/rpc/FillTestCase.java b/container-search/src/test/java/com/yahoo/search/dispatch/rpc/FillTestCase.java
index a5086c1446d..5bdeb340678 100644
--- a/container-search/src/test/java/com/yahoo/search/dispatch/rpc/FillTestCase.java
+++ b/container-search/src/test/java/com/yahoo/search/dispatch/rpc/FillTestCase.java
@@ -8,9 +8,7 @@ import com.yahoo.prelude.fastsearch.DocumentDatabase;
import com.yahoo.prelude.fastsearch.FastHit;
import com.yahoo.search.Query;
import com.yahoo.search.Result;
-import com.yahoo.search.dispatch.rpc.Client;
-import com.yahoo.search.dispatch.rpc.RpcInvokerFactory;
-import com.yahoo.search.dispatch.rpc.RpcResourcePool;
+
import org.junit.Test;
import java.util.ArrayList;
@@ -38,7 +36,7 @@ public class FillTestCase {
nodes.put(1, client.createConnection("host1", 123));
nodes.put(2, client.createConnection("host2", 123));
RpcResourcePool rpcResourcePool = new RpcResourcePool(nodes);
- RpcInvokerFactory factory = new RpcInvokerFactory(rpcResourcePool, null, true);
+ RpcInvokerFactory factory = new RpcInvokerFactory(rpcResourcePool, null);
Query query = new Query();
Result result = new Result(query);
@@ -75,7 +73,7 @@ public class FillTestCase {
nodes.put(1, client.createConnection("host1", 123));
nodes.put(2, client.createConnection("host2", 123));
RpcResourcePool rpcResourcePool = new RpcResourcePool(nodes);
- RpcInvokerFactory factory = new RpcInvokerFactory(rpcResourcePool, null, true);
+ RpcInvokerFactory factory = new RpcInvokerFactory(rpcResourcePool, null);
Query query = new Query();
Result result = new Result(query);
@@ -115,7 +113,7 @@ public class FillTestCase {
nodes.put(1, client.createConnection("host1", 123));
nodes.put(2, client.createConnection("host2", 123));
RpcResourcePool rpcResourcePool = new RpcResourcePool(nodes);
- RpcInvokerFactory factory = new RpcInvokerFactory(rpcResourcePool, null, true);
+ RpcInvokerFactory factory = new RpcInvokerFactory(rpcResourcePool, null);
Query query = new Query();
Result result = new Result(query);
@@ -155,7 +153,7 @@ public class FillTestCase {
Map<Integer, Client.NodeConnection> nodes = new HashMap<>();
nodes.put(0, client.createConnection("host0", 123));
RpcResourcePool rpcResourcePool = new RpcResourcePool(nodes);
- RpcInvokerFactory factory = new RpcInvokerFactory(rpcResourcePool, null, true);
+ RpcInvokerFactory factory = new RpcInvokerFactory(rpcResourcePool, null);
Query query = new Query();
Result result = new Result(query);
@@ -173,7 +171,7 @@ public class FillTestCase {
Map<Integer, Client.NodeConnection> nodes = new HashMap<>();
nodes.put(0, client.createConnection("host0", 123));
RpcResourcePool rpcResourcePool = new RpcResourcePool(nodes);
- RpcInvokerFactory factory = new RpcInvokerFactory(rpcResourcePool, null, true);
+ RpcInvokerFactory factory = new RpcInvokerFactory(rpcResourcePool, null);
Query query = new Query();
Result result = new Result(query);