summaryrefslogtreecommitdiffstats
path: root/container-search
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2018-02-05 14:14:43 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2018-02-05 14:30:58 +0100
commit50b28e226129546333db82b4c768241c39f6e5f9 (patch)
tree68dbd42b8018913bfd82f9e65039ca5c61560625 /container-search
parentef25cd5e64c5d8a4ce42423f914da381ca3d04b5 (diff)
When time is up it is up. Here too.
Diffstat (limited to 'container-search')
-rw-r--r--container-search/src/main/java/com/yahoo/fs4/GetDocSumsPacket.java5
-rw-r--r--container-search/src/main/java/com/yahoo/fs4/QueryPacket.java3
2 files changed, 3 insertions, 5 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 a40f5d55317..63fa313fe72 100644
--- a/container-search/src/main/java/com/yahoo/fs4/GetDocSumsPacket.java
+++ b/container-search/src/main/java/com/yahoo/fs4/GetDocSumsPacket.java
@@ -102,10 +102,9 @@ public class GetDocSumsPacket extends Packet {
buffer.putInt((int)features);
buffer.putInt(0); //Unused, was docstamp
long timeLeft = query.getTimeLeft();
- final int minTimeout = 50;
- buffer.putInt(Math.max(minTimeout, (int)timeLeft));
+ buffer.putInt((int)timeLeft);
if (log.isLoggable(LogLevel.DEBUG)) {
- log.log(LogLevel.DEBUG, "Timeout from query(" + query.getTimeout() + "), sent to backend: " + Math.max(minTimeout, timeLeft));
+ log.log(LogLevel.DEBUG, "Timeout from query(" + query.getTimeout() + "), sent to backend: " + timeLeft);
}
if (queryPacketData != null)
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 1513cf2213c..ff2ca443cbf 100644
--- a/container-search/src/main/java/com/yahoo/fs4/QueryPacket.java
+++ b/container-search/src/main/java/com/yahoo/fs4/QueryPacket.java
@@ -123,8 +123,7 @@ public class QueryPacket extends Packet {
ignoreableOffset = buffer.position() - relativeZero;
IntegerCompressor.putCompressedPositiveNumber(getOffset(), buffer);
IntegerCompressor.putCompressedPositiveNumber(getHits(), buffer);
- // store the cutoff time in the tag object, and then do a similar Math.max there
- buffer.putInt(Math.max(50, (int)query.getTimeLeft()));
+ buffer.putInt((int)query.getTimeLeft());
ignoreableSize = buffer.position() - relativeZero - ignoreableOffset;
buffer.putInt(getFlagInt());
int startOfFieldToSave = buffer.position();