Try reducing timeout and adding additional conditions.

Author: tecarter94

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

@@ -45,7 +45,7 @@ public void start() {
         try (final ServerSocket serverSocket = new ServerSocket(clientHttpPort)) {
             while (running) {
                 final Socket socket = serverSocket.accept();
-                socket.setSoTimeout(1200000);
+                socket.setSoTimeout(1000);
                 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

@@ -3,6 +3,7 @@
 import java.io.IOException;
 import java.net.Socket;
 import java.net.SocketException;
+import java.net.SocketTimeoutException;
 import java.nio.ByteBuffer;
 import java.nio.channels.AsynchronousCloseException;
 import java.nio.channels.SocketChannel;
@@ -23,14 +24,16 @@ public static Runnable createSocketToChannelWriter(final int byteBufferSize, fin
             int bytesWritten = 0;
             LOG.info("Writing from socket to channel");
             try {
-                while (!socket.isClosed() && socket.isConnected() && (r = socket.getInputStream().read(buf)) > 0) {
+                while (socket.isConnected() && channel.isConnected() && socket.getInputStream().available() > 0 && (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;
                 }
             } catch (final SocketException ignore) {
                 LOG.info("Socket closed");
+            } catch (final SocketTimeoutException ignore) {
+                LOG.info("Socket timed out");
             } catch (final IOException e) {
                 LOG.errorf(e, "Error writing from socket to channel");
             } finally {
@@ -60,7 +63,7 @@ public static Runnable createChannelToSocketWriter(final int byteBufferSize, fin
             int bytesWritten = 0;
             LOG.info("Writing from channel to socket");
             try {
-                while (channel.isOpen() && channel.isConnected() && (r = channel.read(buf)) > 0) {
+                while (channel.isConnected() && socket.isConnected() && (r = channel.read(buf)) > 0) {
                     LOG.infof("Read %d bytes from channel", r);
                     buf.flip();
                     socket.getOutputStream().write(buf.array(), buf.arrayOffset(), buf.remaining());

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

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