diff options
-rw-r--r-- | container-search/src/main/java/com/yahoo/prelude/fastsearch/FastSearcher.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/container-search/src/main/java/com/yahoo/prelude/fastsearch/FastSearcher.java b/container-search/src/main/java/com/yahoo/prelude/fastsearch/FastSearcher.java index 50d6a524320..52650279ad5 100644 --- a/container-search/src/main/java/com/yahoo/prelude/fastsearch/FastSearcher.java +++ b/container-search/src/main/java/com/yahoo/prelude/fastsearch/FastSearcher.java @@ -391,7 +391,7 @@ public class FastSearcher extends VespaBackEndSearcher { BasicPacket[] basicPackets; try { - basicPackets = channel.receivePackets(Math.max(50, query.getTimeLeft()), 1); + basicPackets = channel.receivePackets(query.getTimeLeft(), 1); } catch (ChannelTimeoutException e) { return new Result(query,ErrorMessage.createTimeout("Timeout while waiting for " + getName())); } catch (InvalidChannelException e) { @@ -472,7 +472,7 @@ public class FastSearcher extends VespaBackEndSearcher { if (isLoggingFine()) getLogger().finest("Sent " + docsumsPacket + " on " + channel); if ( ! couldSend) throw new IOException("Could not successfully send GetDocSumsPacket."); - receivedPackets = channel.receivePackets(Math.max(50, result.getQuery().getTimeLeft()), docsumsPacket.getNumDocsums() + 1); + receivedPackets = channel.receivePackets(result.getQuery().getTimeLeft(), docsumsPacket.getNumDocsums() + 1); if (isLoggingFine()) getLogger().finest("got " + receivedPackets.length + "docsumPackets"); |