summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2024-03-11 15:43:18 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2024-03-11 15:43:18 +0100
commitd51144a9aa9be319acb1a0b3677a403b8f5fc358 (patch)
treec1d60999e1e86ea50f22257f94ff6fa0e1b4b964
parent0f7a4e4b0ae2902535249cb7a9d9e1acbf6dd503 (diff)
Correct naming
-rw-r--r--container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java2
-rw-r--r--container-search/src/test/java/com/yahoo/prelude/test/IntegrationTestCase.java174
2 files changed, 1 insertions, 175 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 36e918c9ba3..28ba4fb09b2 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
@@ -93,7 +93,7 @@ public class ClusterSearcher extends Searcher {
maxQueryCacheTimeout = ParameterParser.asMilliSeconds(clusterConfig.maxQueryCacheTimeout(), DEFAULT_MAX_QUERY_CACHE_TIMEOUT);
SummaryParameters docSumParams = new SummaryParameters(qrsConfig
- .com().yahoo().prelude().fastsearch().FastSearcher().docsum()
+ .com().yahoo().prelude().fastsearch().FastBackend().docsum()
.defaultclass());
String uniqueServerId = UUID.randomUUID().toString();
diff --git a/container-search/src/test/java/com/yahoo/prelude/test/IntegrationTestCase.java b/container-search/src/test/java/com/yahoo/prelude/test/IntegrationTestCase.java
deleted file mode 100644
index 0a3e7bda318..00000000000
--- a/container-search/src/test/java/com/yahoo/prelude/test/IntegrationTestCase.java
+++ /dev/null
@@ -1,174 +0,0 @@
-// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-package com.yahoo.prelude.test;
-
-import com.yahoo.search.result.Hit;
-import com.yahoo.search.Result;
-import com.yahoo.search.Searcher;
-import com.yahoo.search.searchchain.Execution;
-import org.junit.jupiter.api.Test;
-
-/**
- * Runs a query thru the configured search chain from a real http channel
- * to a mock fdispatch channel. The setup is rather complicated, as the point is
- * to span as much of the processing from query to result as possible.
- *
- * @author bratseth
- */
-public class IntegrationTestCase {
-
- public static class SecondSearcher extends Searcher {
- public Result search(com.yahoo.search.Query query, Execution execution) {
- Result result = execution.search(query);
- result.hits().add(new Hit("searcher:2",1000));
- return result;
- }
- }
- public static class ThirdSearcher extends Searcher {
- public Result search(com.yahoo.search.Query query, Execution execution) {
- Result result = execution.search(query);
- result.hits().add(new Hit("searcher:3",1000));
- return result;
- }
- }
-
- @Test
- void testQuery() throws java.io.IOException {
- /*
- TODO: (JSB) This blocks forever on Linux (not Windows) because
- the ServerSocketChannel.accept method in Server
- seems to starve the test running thread,
- causing it to get stuck in waitForServerInitialization.
- This must be caused by starvation because
- replacing the test with Thread.sleep(n)
- gives the same result if n is large enough (2000
- is large enough, 1000 is not.
- Resolve this in some way, perhaps by switching to
- non-blocking io (and then remember to remove the next line).
- */
- }
-
- /*
- if (1==1) return;
- ServerThread serverThread=new ServerThread();
- try {
- serverThread.start();
- waitForServerInitialization();
- insertMockFs4Channel();
- ByteBuffer buffer=ByteBuffer.allocate(4096);
- buffer.put(getBytes("GET /?query=hans HTTP/1.1\n\n"));
- SocketChannel socket=
- SocketChannel.open(new InetSocketAddress(Server.get().getHost(),
- Server.get().getPort()));
- buffer.flip();
- socket.write(buffer);
-
- buffer.clear();
- socket.read(buffer);
- // TODO: Validate return too
-
- }
- finally {
- serverThread.interrupt();
- }
- }
-
- private static void assertCorrectQueryData(QueryPacket packet) {
- assertEquals("Query x packet " +
- "[query: query 'RANK hans bcatpat.bidxpatlvl1:hans' [path='/']]",
- packet.toString());
- }
-
- private void insertMockFs4Channel() {
- Searcher current=SearchChain.get();
- while (current.getChained().getChained()!=null)
- current=current.getChained();
- assertTrue(current.getChained() instanceof FastSearcher);
- FastSearcher mockFastSearcher=
- new FastSearcher(new MockFSChannel(),
- "file:etc/qr-summary.cf",
- "testhittype");
- current.setChained(mockFastSearcher);
- }
-
- private void waitForServerInitialization() {
- int sleptMs=0;
- while (Server.get().getHost()==null) {
- try { Thread.sleep(10); } catch (Exception e) {}
- sleptMs+=10;
- }
- }
-
- private class ServerThread extends Thread {
-
- public void run() {
- try {
- Server.get().start(8081,new SearchRequestHandler());
- }
- catch (java.io.IOException e) {
- throw new RuntimeException("Failed",e);
- }
- }
- }
-
- private byte[] getBytes(String string) {
- try {
- return string.getBytes("utf-8");
- }
- catch (java.io.UnsupportedEncodingException e) {
- throw new RuntimeException("Won't happen",e);
- }
- }
- */
- /** A channel which returns hardcoded packets of the same type as fdispatch */
- /*
- private static class MockFSChannel extends Channel {
-
- public MockFSChannel() {}
-
- public void sendPacket(Packet packet) {
- if (packet instanceof QueryPacket) {
- assertCorrectQueryData((QueryPacket)packet);
- }
- else {
- throw new RuntimeException("Mock channel don't know what to reply to " +
- packet);
- }
- }
-
- public Packet[] receivePackets() {
- List packets=new java.util.ArrayList();
- QueryResultPacket result=QueryResultPacket.create();
- result.addDocument(new DocumentInfo(123,2003,234,1000,1));
- result.addDocument(new DocumentInfo(456,1855,234,1001,1));
- packets.add(result);
- addDocsums(packets);
- return (Packet[])packets.toArray(new Packet[packets.size()]);
- }
-
- private void addDocsums(List packets) {
- ByteBuffer buffer=createDocsumPacketData(DocsumDefinitionTestCase.docsum4);
- buffer.position(0);
- packets.add(PacketDecoder.decode(buffer));
-
- buffer=createDocsumPacketData(DocsumDefinitionTestCase.docsum4);
- buffer.position(0);
- packets.add(PacketDecoder.decode(buffer));
-
- packets.add(EolPacket.create());
- }
-
- private ByteBuffer createDocsumPacketData(byte[] docsumData) {
- ByteBuffer buffer=ByteBuffer.allocate(docsumData.length+12+4);
- buffer.limit(buffer.capacity());
- buffer.position(0);
- buffer.putInt(docsumData.length+8+4);
- buffer.putInt(205); // Docsum packet code
- buffer.putInt(0);
- buffer.putInt(0);
- buffer.put(docsumData);
- return buffer;
- }
-
- }
- */
-}