summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@oath.com>2018-12-19 15:34:07 +0100
committergjoranv <gv@oath.com>2019-01-21 15:09:30 +0100
commit34a85971e9b05fd253b18677548de859d324529b (patch)
tree19ea5cfcbd86822bd84d08067856cef13f4e14ef
parentd54f2d0f140cf78513de3410335114dd6a7f4f6c (diff)
Remove Query.getSessionId(boolean)
-rw-r--r--container-search/src/main/java/com/yahoo/fs4/GetDocSumsPacket.java2
-rw-r--r--container-search/src/main/java/com/yahoo/prelude/fastsearch/VespaBackEndSearcher.java2
-rw-r--r--container-search/src/main/java/com/yahoo/search/Query.java16
-rw-r--r--container-search/src/main/java/com/yahoo/search/dispatch/RpcFillInvoker.java2
-rw-r--r--container-search/src/main/java/com/yahoo/search/grouping/vespa/GroupingExecutor.java2
-rw-r--r--container-search/src/test/java/com/yahoo/fs4/test/GetDocSumsPacketTestCase.java2
-rw-r--r--container-search/src/test/java/com/yahoo/prelude/fastsearch/test/FastSearcherTestCase.java2
-rw-r--r--container-search/src/test/java/com/yahoo/search/test/QueryTestCase.java34
8 files changed, 23 insertions, 39 deletions
diff --git a/container-search/src/main/java/com/yahoo/fs4/GetDocSumsPacket.java b/container-search/src/main/java/com/yahoo/fs4/GetDocSumsPacket.java
index a3b8e4f29a2..7dabb52a233 100644
--- a/container-search/src/main/java/com/yahoo/fs4/GetDocSumsPacket.java
+++ b/container-search/src/main/java/com/yahoo/fs4/GetDocSumsPacket.java
@@ -76,7 +76,7 @@ public class GetDocSumsPacket extends Packet {
boolean useQueryCache = query.getRanking().getQueryCache();
// If feature cache is used we need to include the sessionId as key.
if (useQueryCache) { // TODO: Move this decision (and the key) to ranking
- query.getRanking().getProperties().put(sessionIdKey, query.getSessionId(false).toString());
+ query.getRanking().getProperties().put(sessionIdKey, query.getSessionId().toString());
}
// set the default features
diff --git a/container-search/src/main/java/com/yahoo/prelude/fastsearch/VespaBackEndSearcher.java b/container-search/src/main/java/com/yahoo/prelude/fastsearch/VespaBackEndSearcher.java
index 7def8e744a6..d6e87e58fd8 100644
--- a/container-search/src/main/java/com/yahoo/prelude/fastsearch/VespaBackEndSearcher.java
+++ b/container-search/src/main/java/com/yahoo/prelude/fastsearch/VespaBackEndSearcher.java
@@ -372,7 +372,7 @@ public abstract class VespaBackEndSearcher extends PingableSearcher {
s.append(" ranking.queryCache=true");
}
if (query.getGroupingSessionCache() || query.getRanking().getQueryCache()) {
- s.append(" sessionId=").append(query.getSessionId(false));
+ s.append(" sessionId=").append(query.getSessionId());
}
List<Grouping> grouping = GroupingExecutor.getGroupingList(query);
diff --git a/container-search/src/main/java/com/yahoo/search/Query.java b/container-search/src/main/java/com/yahoo/search/Query.java
index b4adca2cef1..73335037b94 100644
--- a/container-search/src/main/java/com/yahoo/search/Query.java
+++ b/container-search/src/main/java/com/yahoo/search/Query.java
@@ -982,22 +982,6 @@ public class Query extends com.yahoo.processing.Request implements Cloneable {
*/
public HttpRequest getHttpRequest() { return httpRequest; }
- /**
- * Returns the unique and stable session id of this query.
- *
- * @param create if true this is created if not already set
- * @return the session id of this query, or null if not set and create is false
- * @deprecated use getSessionId() or getSessionId(serverId) instead
- */
- @Deprecated
- public SessionId getSessionId(boolean create) {
- if ( ! create) return getSessionId();
-
- if (requestId == null)
- requestId = UniqueRequestId.next();
- return new SessionId(requestId, getRanking().getProfile());
- }
-
/** Returns the session id of this query, or null if none is assigned */
public SessionId getSessionId() {
if (requestId == null) return null;
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/RpcFillInvoker.java b/container-search/src/main/java/com/yahoo/search/dispatch/RpcFillInvoker.java
index fb72e8c77c9..578c447dfbe 100644
--- a/container-search/src/main/java/com/yahoo/search/dispatch/RpcFillInvoker.java
+++ b/container-search/src/main/java/com/yahoo/search/dispatch/RpcFillInvoker.java
@@ -110,7 +110,7 @@ public class RpcFillInvoker extends FillInvoker {
Query query = result.getQuery();
String rankProfile = query.getRanking().getProfile();
byte[] serializedSlime = BinaryFormat
- .encode(toSlime(rankProfile, summaryClass, query.getModel().getDocumentDb(), query.getSessionId(false), hits));
+ .encode(toSlime(rankProfile, summaryClass, query.getModel().getDocumentDb(), query.getSessionId(), hits));
double timeoutSeconds = ((double) query.getTimeLeft() - 3.0) / 1000.0;
Compressor.Compression compressionResult = resourcePool.compressor().compress(compression, serializedSlime);
resourcePool.client().getDocsums(hits, node, compressionResult.type(), serializedSlime.length, compressionResult.data(),
diff --git a/container-search/src/main/java/com/yahoo/search/grouping/vespa/GroupingExecutor.java b/container-search/src/main/java/com/yahoo/search/grouping/vespa/GroupingExecutor.java
index b28e648be78..7c2e774f68b 100644
--- a/container-search/src/main/java/com/yahoo/search/grouping/vespa/GroupingExecutor.java
+++ b/container-search/src/main/java/com/yahoo/search/grouping/vespa/GroupingExecutor.java
@@ -217,7 +217,7 @@ public class GroupingExecutor extends Searcher {
baseRoot = origRoot.clone();
}
if (query.isTraceable(3) && query.getGroupingSessionCache()) {
- query.trace("Grouping in " + (lastPass + 1) + " passes. SessionId='" + query.getSessionId(false) + "'.", 3);
+ query.trace("Grouping in " + (lastPass + 1) + " passes. SessionId='" + query.getSessionId() + "'.", 3);
}
for (int pass = 0; pass <= lastPass; ++pass) {
boolean firstPass = (pass == 0);
diff --git a/container-search/src/test/java/com/yahoo/fs4/test/GetDocSumsPacketTestCase.java b/container-search/src/test/java/com/yahoo/fs4/test/GetDocSumsPacketTestCase.java
index 9b1517454a9..54512e727c2 100644
--- a/container-search/src/test/java/com/yahoo/fs4/test/GetDocSumsPacketTestCase.java
+++ b/container-search/src/test/java/com/yahoo/fs4/test/GetDocSumsPacketTestCase.java
@@ -50,7 +50,7 @@ public class GetDocSumsPacketTestCase {
@Test
public void requireThatSessionIdIsEncodedAsPropertyWhenUsingSearchSession() throws BufferTooSmallException {
Result result = new Result(new Query("?query=foo"));
- SessionId sessionId = result.getQuery().getSessionId(true); // create session id.
+ SessionId sessionId = result.getQuery().getSessionId("node-0");
result.getQuery().getRanking().setQueryCache(true);
FastHit hit = new FastHit();
result.hits().add(hit);
diff --git a/container-search/src/test/java/com/yahoo/prelude/fastsearch/test/FastSearcherTestCase.java b/container-search/src/test/java/com/yahoo/prelude/fastsearch/test/FastSearcherTestCase.java
index 4b827b2942f..fd01fb9a740 100644
--- a/container-search/src/test/java/com/yahoo/prelude/fastsearch/test/FastSearcherTestCase.java
+++ b/container-search/src/test/java/com/yahoo/prelude/fastsearch/test/FastSearcherTestCase.java
@@ -331,7 +331,7 @@ public class FastSearcherTestCase {
byte[] actual = new byte[buf.remaining()];
buf.get(actual);
- SessionId sessionId = query.getSessionId(false);
+ SessionId sessionId = query.getSessionId();
byte IGNORE = 69;
ByteBuffer answer = ByteBuffer.allocate(1024);
answer.put(new byte[] { 0, 0, 0, (byte)(141+sessionId.asUtf8String().getByteLength()), 0, 0, 0, -37, 0, 0, 16, 17, 0, 0, 0, 0,
diff --git a/container-search/src/test/java/com/yahoo/search/test/QueryTestCase.java b/container-search/src/test/java/com/yahoo/search/test/QueryTestCase.java
index ed80c0bf256..a5c46fc7887 100644
--- a/container-search/src/test/java/com/yahoo/search/test/QueryTestCase.java
+++ b/container-search/src/test/java/com/yahoo/search/test/QueryTestCase.java
@@ -684,34 +684,34 @@ public class QueryTestCase {
@Test
public void testThatSessionIdIsUniquePerQuery() {
Query q = new Query();
- assertNull(q.getSessionId(false));
- assertNull(q.getSessionId(false));
- SessionId s1 = q.getSessionId(true);
+ assertNull(q.getSessionId());
+ assertNull(q.getSessionId());
+ SessionId s1 = q.getSessionId("node-0");
assertNotNull(s1);
- SessionId s2 = q.getSessionId(true);
+ SessionId s2 = q.getSessionId("node-0");
assertNotSame(s1, s2);
assertEquals(s1, s2);
assertEquals(s1.toString(), s2.toString());
Query q2 = new Query();
- assertNotEquals(q.getSessionId(false), q2.getSessionId(true));
- assertNotEquals(q.getSessionId(false).toString(), q2.getSessionId(true).toString());
+ assertNotEquals(q.getSessionId(), q2.getSessionId("node-0"));
+ assertNotEquals(q.getSessionId().toString(), q2.getSessionId("node-0").toString());
}
@Test
public void testThatCloneGetANewSessionId() {
Query q = new Query();
- q.getSessionId(true);
+ q.getSessionId("node-0");
Query clonedQ = q.clone();
- assertNull(clonedQ.getSessionId(false));
- assertNotEquals(q.getSessionId(false), clonedQ.getSessionId(true));
+ assertNull(clonedQ.getSessionId());
+ assertNotEquals(q.getSessionId(), clonedQ.getSessionId("node-0"));
}
@Test
public void testThatSessionIdIsUniquePerRankProfilePerQuery() {
Query q = new Query();
- SessionId s1 = q.getSessionId(true);
+ SessionId s1 = q.getSessionId("node-0");
q.getRanking().setProfile("my-profile");
- SessionId s2 = q.getSessionId(false);
+ SessionId s2 = q.getSessionId();
assertNotEquals(s1, s2);
}
@@ -719,14 +719,14 @@ public class QueryTestCase {
public void testThatSessionIdIsNotSharedIfCreatedAfterClone() {
Query q = new Query();
Query q2 = q.clone();
- assertNull(q.getSessionId(false));
- assertNull(q2.getSessionId(false));
+ assertNull(q.getSessionId());
+ assertNull(q2.getSessionId());
- assertNotNull(q.getSessionId(true));
- assertNull(q2.getSessionId(false));
+ assertNotNull(q.getSessionId("node-0"));
+ assertNull(q2.getSessionId());
- assertNotNull(q2.getSessionId(true));
- assertNotEquals(q.getSessionId(false), q2.getSessionId(false));
+ assertNotNull(q2.getSessionId("node-0"));
+ assertNotEquals(q.getSessionId(), q2.getSessionId());
}
@Test