diff --git a/jetty-websocket/websocket-core-common/src/main/java/org/eclipse/jetty/websocket/core/internal/PerMessageDeflateExtension.java b/jetty-websocket/websocket-core-common/src/main/java/org/eclipse/jetty/websocket/core/internal/PerMessageDeflateExtension.java index 2513fc8a097f..1dfa0f0eb05c 100644 --- a/jetty-websocket/websocket-core-common/src/main/java/org/eclipse/jetty/websocket/core/internal/PerMessageDeflateExtension.java +++ b/jetty-websocket/websocket-core-common/src/main/java/org/eclipse/jetty/websocket/core/internal/PerMessageDeflateExtension.java @@ -416,10 +416,10 @@ private boolean inflate(Callback callback) throws DataFormatException Inflater inflater = getInflater(); while (true) { - int read = inflater.inflate(payload.array(), payload.arrayOffset() + payload.position(), bufferSize - payload.position()); - payload.limit(payload.limit() + read); + int decompressed = inflater.inflate(payload.array(), payload.arrayOffset() + payload.position(), bufferSize - payload.position()); + payload.limit(payload.limit() + decompressed); if (LOG.isDebugEnabled()) - LOG.debug("Decompress: read {} {}", read, toDetail(inflater)); + LOG.debug("Decompress: read {} {}", decompressed, toDetail(inflater)); if (payload.limit() == bufferSize) { @@ -429,7 +429,7 @@ private boolean inflate(Callback callback) throws DataFormatException break; } - if (read == 0) + if (decompressed == 0) { if (!_tailBytes && _frame.isFin()) {