Remove timeout and synchronise writes.

Author: tecarter94

java-components/domain-proxy/client/src/main/java/com/redhat/hacbs/domainproxy/client/DomainProxyClient.java

@@ -45,7 +45,6 @@ public void start() {
         try (final ServerSocket serverSocket = new ServerSocket(clientHttpPort)) {
             while (running) {
                 final Socket socket = serverSocket.accept();
-                socket.setSoTimeout(10000);
                 final UnixDomainSocketAddress address = UnixDomainSocketAddress.of(domainSocket);
                 final SocketChannel channel = SocketChannel.open(address);
                 // Write from socket to channel

java-components/domain-proxy/common/src/main/java/com/redhat/hacbs/domainproxy/common/CommonIOUtil.java

@@ -25,10 +25,12 @@ public static Runnable createSocketToChannelWriter(final int byteBufferSize, fin
             LOG.info("Writing from socket to channel");
             try {
                 while ((r = socket.getInputStream().read(buf)) > 0) {
-                    LOG.infof("Read %d bytes from socket", r);
-                    channel.write(ByteBuffer.wrap(buf, 0, r));
-                    LOG.infof("Wrote %d bytes to channel", r);
-                    bytesWritten += r;
+                    synchronized (channel) {
+                        LOG.infof("Read %d bytes from socket", r);
+                        channel.write(ByteBuffer.wrap(buf, 0, r));
+                        LOG.infof("Wrote %d bytes to channel", r);
+                        bytesWritten += r;
+                    }
                 }
             } catch (final ClosedChannelException ignore) {
                 LOG.info("Channel closed");
@@ -66,12 +68,14 @@ public static Runnable createChannelToSocketWriter(final int byteBufferSize, fin
             LOG.info("Writing from channel to socket");
             try {
                 while ((r = channel.read(buf)) > 0) {
-                    LOG.infof("Read %d bytes from channel", r);
-                    buf.flip();
-                    socket.getOutputStream().write(buf.array(), buf.arrayOffset(), buf.remaining());
-                    LOG.infof("Wrote %d bytes to socket", r);
-                    buf.clear();
-                    bytesWritten += r;
+                    synchronized (socket) {
+                        LOG.infof("Read %d bytes from channel", r);
+                        buf.flip();
+                        socket.getOutputStream().write(buf.array(), buf.arrayOffset(), buf.remaining());
+                        LOG.infof("Wrote %d bytes to socket", r);
+                        buf.clear();
+                        bytesWritten += r;
+                    }
                 }
             } catch (final ClosedChannelException ignore) {
                 LOG.info("Channel closed");

java-components/domain-proxy/server/src/main/java/com/redhat/hacbs/domainproxy/DomainProxyServer.java

@@ -59,7 +59,6 @@ public void start() {
             while (running) {
                 final SocketChannel channel = serverChannel.accept();
                 final Socket socket = new Socket(LOCALHOST, httpServerPort);
-                socket.setSoTimeout(10000);
                 // Write from socket to channel
                 Thread.startVirtualThread(createSocketToChannelWriter(byteBufferSize, socket, channel));
                 // Write from channel to socket