From db93e45bef99cdb41678326e5e7c1aa0c5f7781b Mon Sep 17 00:00:00 2001 From: nishantmonu51 Date: Fri, 7 Feb 2014 17:52:52 +0530 Subject: [PATCH] minor fix --- .../java/io/druid/client/cache/BytesBoundedLinkedQueue.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/src/main/java/io/druid/client/cache/BytesBoundedLinkedQueue.java b/server/src/main/java/io/druid/client/cache/BytesBoundedLinkedQueue.java index 50ca475c0d5..f0ab9763f6b 100644 --- a/server/src/main/java/io/druid/client/cache/BytesBoundedLinkedQueue.java +++ b/server/src/main/java/io/druid/client/cache/BytesBoundedLinkedQueue.java @@ -129,7 +129,7 @@ public abstract class BytesBoundedLinkedQueue extends AbstractQueue implem try { while (currentSize.get() >= capacity) { if (nanos <= 0) { - break; + return false; } nanos = notFull.awaitNanos(nanos); }