Fix NettyInputStream ByteBuf leak

eclipse-ee4j · Aug 10, 2019 · 33ea812 · 33ea812
1 parent 35e581f
commit 33ea812
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/...nnector/src/main/java/org/glassfish/jersey/netty/connector/internal/NettyInputStream.java b/...nnector/src/main/java/org/glassfish/jersey/netty/connector/internal/NettyInputStream.java
@@ -87,6 +87,8 @@ public int read(byte[] b, int off, int len) throws IOException {
 
             if (take.available() > 0) {
                 isList.addFirst(take);
+            } else {
+                take.close();
             }
 
             return read;

diff --git a/...s/netty-http/src/main/java/org/glassfish/jersey/netty/httpserver/JerseyServerHandler.java b/...s/netty-http/src/main/java/org/glassfish/jersey/netty/httpserver/JerseyServerHandler.java
@@ -100,7 +100,7 @@ public void run() {
             ByteBuf content = httpContent.content();
 
             if (content.isReadable()) {
-                isList.add(new ByteBufInputStream(content));
+                isList.add(new ByteBufInputStream(content, true));
             }
 
             if (msg instanceof LastHttpContent) {