diff options
Diffstat (limited to 'jetty-client')
| -rw-r--r-- | jetty-client/src/main/java/org/eclipse/jetty/client/util/InputStreamResponseListener.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/jetty-client/src/main/java/org/eclipse/jetty/client/util/InputStreamResponseListener.java b/jetty-client/src/main/java/org/eclipse/jetty/client/util/InputStreamResponseListener.java index 6ac55e6f65..d59943a467 100644 --- a/jetty-client/src/main/java/org/eclipse/jetty/client/util/InputStreamResponseListener.java +++ b/jetty-client/src/main/java/org/eclipse/jetty/client/util/InputStreamResponseListener.java @@ -155,7 +155,7 @@ public class InputStreamResponseListener extends Response.Listener.Empty { synchronized (this) { - if (length.get() >= maxBufferSize && failure == null && !closed) + while (length.get() >= maxBufferSize && failure == null && !closed) wait(); // Re-read the values as they may have changed while waiting. return failure == null && !closed; @@ -163,6 +163,7 @@ public class InputStreamResponseListener extends Response.Listener.Empty } catch (InterruptedException x) { + Thread.currentThread().interrupt(); return false; } } |