Fix issue jetty#5499

this PR let the ByteAccumulator recyclable. after invoke ByteAccumulator.transferTo method we can invoke ByteAccumulator.recycle method to reuse byte[] via ByteAccumulator.newByteArray method Signed-off-by: leonchen83 <chen.bao.yi@qq.com>
leonchen83 · Oct 28, 2020 · 10051a6 · 10051a6
1 parent 723eb15
commit 10051a6
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/...c/main/java/org/eclipse/jetty/websocket/common/extensions/compress/CompressExtension.java b/...c/main/java/org/eclipse/jetty/websocket/common/extensions/compress/CompressExtension.java
@@ -209,13 +209,9 @@ protected void decompress(ByteAccumulator accumulator, ByteBuffer buf) throws Da
             {
                 byte[] output = accumulator.newByteArray(DECOMPRESS_BUF_SIZE);
                 read = inflater.inflate(output);
-                if (read < 0)
+                if (read <= 0)
                 {
-                    break;
-                }
-                else if (read == 0)
-                {
-                    if (LOG.isDebugEnabled())
+                    if (read == 0 && LOG.isDebugEnabled())
                         LOG.debug("Decompress: read 0 {}", toDetail(inflater));
                     break;
                 }