Netty container - JerseyChunkedInput must copy written bytes.

The buffers are reused by Jersey and output entities were corrupted when they reached certain size.

Change-Id: I4c8ad8fd4e0b6e017cb55bc52ffd61252befdb25

Author: pavelbucek

connectors/netty-connector/src/main/java/org/glassfish/jersey/netty/connector/internal/JerseyChunkedInput.java

@@ -193,21 +193,27 @@ public ByteBuffer get() {
     @Override
     public void write(final byte[] b) throws IOException {
 
+        final byte[] bytes = new byte[b.length];
+        System.arraycopy(b, 0, bytes, 0, b.length);
+
         write(new Provider<ByteBuffer>() {
             @Override
             public ByteBuffer get() {
-                return ByteBuffer.wrap(b);
+                return ByteBuffer.wrap(bytes);
             }
         });
     }
 
     @Override
     public void write(final byte[] b, final int off, final int len) throws IOException {
 
+        final byte[] bytes = new byte[len];
+        System.arraycopy(b, off, bytes, 0, len);
+
         write(new Provider<ByteBuffer>() {
             @Override
             public ByteBuffer get() {
-                return ByteBuffer.wrap(b, off, len);
+                return ByteBuffer.wrap(bytes);
             }
         });
     }

containers/netty-http/src/main/java/org/glassfish/jersey/netty/httpserver/NettyHttp2ResponseWriter.java

@@ -47,6 +47,10 @@
 import java.util.concurrent.ScheduledFuture;
 import java.util.concurrent.TimeUnit;
 
+import org.glassfish.jersey.server.ContainerException;
+import org.glassfish.jersey.server.ContainerResponse;
+import org.glassfish.jersey.server.spi.ContainerResponseWriter;
+
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelFutureListener;
 import io.netty.channel.ChannelHandlerContext;
@@ -57,9 +61,6 @@
 import io.netty.handler.codec.http2.DefaultHttp2Headers;
 import io.netty.handler.codec.http2.DefaultHttp2HeadersFrame;
 import io.netty.handler.codec.http2.Http2HeadersFrame;
-import org.glassfish.jersey.server.ContainerException;
-import org.glassfish.jersey.server.ContainerResponse;
-import org.glassfish.jersey.server.spi.ContainerResponseWriter;
 
 /**
  * Netty implementation of {@link ContainerResponseWriter}.
@@ -103,7 +104,8 @@ public OutputStream writeResponseStatusAndHeaders(long contentLength, ContainerR
 
         ctx.writeAndFlush(new DefaultHttp2HeadersFrame(response));
 
-        if (!headersFrame.headers().method().equals(HttpMethod.HEAD.asciiName()) && (contentLength > 0 || contentLength == -1)) {
+        if (!headersFrame.headers().method().equals(HttpMethod.HEAD.asciiName())
+            && (contentLength > 0 || contentLength == -1)) {
 
             return new OutputStream() {
                 @Override