From af6a4be03de6f478093132f2a8d1eb51521682f1 Mon Sep 17 00:00:00 2001 From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com> Date: Wed, 10 Dec 2025 18:58:00 +0000 Subject: [PATCH 1/3] Initial plan From 2d7b94c16c388021ef5897fa51070bc13c4b9848 Mon Sep 17 00:00:00 2001 From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com> Date: Wed, 10 Dec 2025 19:07:20 +0000 Subject: [PATCH 2/3] Reduce WebSocket flush delay from 100ms to 1ms Co-authored-by: brendandburns <5751682+brendandburns@users.noreply.github.com> --- .../io/kubernetes/client/util/WebSocketStreamHandler.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/util/src/main/java/io/kubernetes/client/util/WebSocketStreamHandler.java b/util/src/main/java/io/kubernetes/client/util/WebSocketStreamHandler.java index eabcd6f581..76feb18ee1 100644 --- a/util/src/main/java/io/kubernetes/client/util/WebSocketStreamHandler.java +++ b/util/src/main/java/io/kubernetes/client/util/WebSocketStreamHandler.java @@ -272,11 +272,11 @@ public void flush() throws IOException { int i = 0; while (WebSocketStreamHandler.this.socket.queueSize() > 0) { try { - Thread.sleep(100); + Thread.sleep(1); } catch (InterruptedException ex) { } // Wait a maximum of 10 seconds. - if (i++ > 100) { + if (i++ > 10000) { throw new IOException("Timed out waiting for web-socket to flush."); } } From 913b334910dbaad4e2861b8e33f5c095b2105988 Mon Sep 17 00:00:00 2001 From: "copilot-swe-agent[bot]" <198982749+Copilot@users.noreply.github.com> Date: Wed, 10 Dec 2025 19:09:26 +0000 Subject: [PATCH 3/3] Use constants for flush timing values for better maintainability Co-authored-by: brendandburns <5751682+brendandburns@users.noreply.github.com> --- .../io/kubernetes/client/util/WebSocketStreamHandler.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/util/src/main/java/io/kubernetes/client/util/WebSocketStreamHandler.java b/util/src/main/java/io/kubernetes/client/util/WebSocketStreamHandler.java index 76feb18ee1..e98b8e092e 100644 --- a/util/src/main/java/io/kubernetes/client/util/WebSocketStreamHandler.java +++ b/util/src/main/java/io/kubernetes/client/util/WebSocketStreamHandler.java @@ -244,6 +244,10 @@ private class WebSocketOutputStream extends OutputStream { private static final int WAIT_MILLIS = 10; + private static final int FLUSH_WAIT_MILLIS = 1; + + private static final int MAX_FLUSH_ITERATIONS = MAX_WAIT_MILLIS / FLUSH_WAIT_MILLIS; + private final byte stream; public WebSocketOutputStream(int stream) { @@ -272,11 +276,11 @@ public void flush() throws IOException { int i = 0; while (WebSocketStreamHandler.this.socket.queueSize() > 0) { try { - Thread.sleep(1); + Thread.sleep(FLUSH_WAIT_MILLIS); } catch (InterruptedException ex) { } // Wait a maximum of 10 seconds. - if (i++ > 10000) { + if (i++ > MAX_FLUSH_ITERATIONS) { throw new IOException("Timed out waiting for web-socket to flush."); } }