ensure the correct output stream is used (#11175)

Prevent the random 'Unable to parse:' exception by fixing a race
condition while transferring the data of a request.

Co-authored-by: Diego Molina <[email protected]>

Author: joerg1985

java/src/org/openqa/selenium/netty/server/RequestConverter.java

@@ -110,9 +110,11 @@ protected void channelRead0(
 
     if (msg instanceof HttpContent) {
       ByteBuf buf = ((HttpContent) msg).content().retain();
+      PipedOutputStream target = out;
+
       EXECUTOR.submit(() -> {
         try (InputStream inputStream = new ByteBufInputStream(buf)) {
-          ByteStreams.copy(inputStream, out);
+          ByteStreams.copy(inputStream, target);
         } catch (IOException e) {
           throw new UncheckedIOException(e);
         } finally {
@@ -123,9 +125,11 @@ protected void channelRead0(
 
     if (msg instanceof LastHttpContent) {
       LOG.fine("Closing input pipe.");
+      PipedOutputStream target = out;
+
       EXECUTOR.submit(() -> {
         try {
-          out.close();
+          target.close();
         } catch (IOException e) {
           throw new UncheckedIOException(e);
         }
@@ -136,9 +140,11 @@ protected void channelRead0(
   @Override
   public void channelInactive(ChannelHandlerContext ctx) throws Exception {
     LOG.fine("Closing input pipe, channel became inactive.");
+    PipedOutputStream target = out;
+
     SHUTDOWN_EXECUTOR.submit(() -> {
       try {
-        out.close();
+        target.close();
       } catch (IOException e) {
         throw new UncheckedIOException(e);
       }