diff options
author | Jon Bratseth <bratseth@oath.com> | 2018-11-28 12:52:14 -0800 |
---|---|---|
committer | Jon Bratseth <bratseth@oath.com> | 2018-11-28 12:52:14 -0800 |
commit | 162af6427e8330b40cc3cbe3c953a6cd665130bf (patch) | |
tree | 02e95861708a418961e038b65dc3bd441f3e769f /container-search/src/main/java/com/yahoo/fs4 | |
parent | 0236f1224e9f9dced3584123470d3f2a5fa32975 (diff) |
Deprecate Server.getServerDiscriminator
Diffstat (limited to 'container-search/src/main/java/com/yahoo/fs4')
-rw-r--r-- | container-search/src/main/java/com/yahoo/fs4/QueryPacket.java | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/container-search/src/main/java/com/yahoo/fs4/QueryPacket.java b/container-search/src/main/java/com/yahoo/fs4/QueryPacket.java index b8242ff5101..e3c10c1f8ce 100644 --- a/container-search/src/main/java/com/yahoo/fs4/QueryPacket.java +++ b/container-search/src/main/java/com/yahoo/fs4/QueryPacket.java @@ -25,6 +25,7 @@ import java.util.List; */ public class QueryPacket extends Packet { + private final String serverId; private final Query query; private QueryPacketData queryPacketData; @@ -33,7 +34,8 @@ public class QueryPacket extends Packet { private int ignoreableOffset = 0; // Start of (hits/offset/timestamp) ignore section for cache key private int ignoreableSize = 0; // Length of (hits/offset/timestamp) ignore section for cache key - private QueryPacket(Query query) { + private QueryPacket(String serverId, Query query) { + this.serverId = serverId; this.query = query; } @@ -47,8 +49,8 @@ public class QueryPacket extends Packet { * * @param query the query to convert to a packet */ - public static QueryPacket create(Query query) { - return new QueryPacket(query); + public static QueryPacket create(String serverId, Query query) { + return new QueryPacket(serverId, query); } @@ -162,7 +164,7 @@ public class QueryPacket extends Packet { sessionOffset = buffer.position() - relativeZero; if (sendSessionKey) { - Utf8String key = query.getSessionId(true).asUtf8String(); + Utf8String key = query.getSessionId(serverId).asUtf8String(); sessionSize = key.getByteLength(); buffer.putInt(key.getByteLength()); buffer.put(key.getBytes()); |