Skip to content

Commit 87fea18

Browse files
committed
fix: format
Signed-off-by: Daniel Arteaga Barba <[email protected]>
1 parent ac7045b commit 87fea18

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

util/src/main/java/io/kubernetes/client/util/WebSocketStreamHandler.java

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -210,11 +210,11 @@ private synchronized OutputStream getSocketInputOutputStream(int stream) {
210210

211211
private class WebSocketOutputStream extends OutputStream {
212212

213-
private static final long WEB_SOCKET_MAX_QUEUE_SIZE = 16L * 1024 * 1024;
213+
private static final long MAX_QUEUE_SIZE = 16L * 1024 * 1024;
214214

215-
private static final int WEB_SOCKET_MAX_QUEUE_SIZE_MAX_ATTEMPTS = 15;
215+
private static final int MAX_QUEUE_SIZE_MAX_ATTEMPTS = 15;
216216

217-
private static final int WEB_SOCKET_MAX_QUEUE_SIZE_WAIT_MILLISECONDS = 1000;
217+
private static final int MAX_QUEUE_SIZE_WAIT_MILLISECONDS = 1000;
218218

219219
private final byte stream;
220220

@@ -277,11 +277,11 @@ public void write(byte[] b, int offset, int length) throws IOException {
277277
ByteString byteString = ByteString.of(buffer);
278278

279279
int attempts = 0;
280-
while (WebSocketStreamHandler.this.socket.queueSize() + byteString.size() > WEB_SOCKET_MAX_QUEUE_SIZE
281-
&& attempts < WEB_SOCKET_MAX_QUEUE_SIZE_MAX_ATTEMPTS) {
280+
while (WebSocketStreamHandler.this.socket.queueSize() + byteString.size() > MAX_QUEUE_SIZE
281+
&& attempts < MAX_QUEUE_SIZE_MAX_ATTEMPTS) {
282282
try {
283-
Thread.sleep(WEB_SOCKET_MAX_QUEUE_SIZE_WAIT_MILLISECONDS);
284-
attempts ++;
283+
Thread.sleep(MAX_QUEUE_SIZE_WAIT_MILLISECONDS);
284+
attempts++;
285285
} catch (InterruptedException e) {
286286
throw new IOException("Error waiting web socket queue", e);
287287
}

0 commit comments

Comments
 (0)