class io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 extends okhttp.WebSocketListener
{
private volatile boolean opened;
private boolean more;
private java.util.concurrent.locks.ReentrantLock lock;
private java.util.concurrent.locks.Condition moreRequested;
final java.util.concurrent.CompletableFuture val$future;
final io.fabric.kubernetes.client.http.WebSocket$Listener val$listener;
final io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl this$0;
void <init>(io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl, java.util.concurrent.CompletableFuture, io.fabric.kubernetes.client.http.WebSocket$Listener)
{
io.fabric.kubernetes.client.http.WebSocket$Listener v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl v;
java.util.concurrent.locks.Condition v;
java.util.concurrent.locks.ReentrantLock v, v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 v;
java.util.concurrent.CompletableFuture v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1;
v := @parameter: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl;
v := @parameter: java.util.concurrent.CompletableFuture;
v := @parameter: io.fabric.kubernetes.client.http.WebSocket$Listener;
v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl this$0> = v;
v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.CompletableFuture val$future> = v;
v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: io.fabric.kubernetes.client.http.WebSocket$Listener val$listener> = v;
specialinvoke v.<okhttp.WebSocketListener: void <init>()>();
v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: boolean more> = 1;
v = new java.util.concurrent.locks.ReentrantLock;
specialinvoke v.<java.util.concurrent.locks.ReentrantLock: void <init>()>();
v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.locks.ReentrantLock lock> = v;
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.locks.ReentrantLock lock>;
v = virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: java.util.concurrent.locks.Condition newCondition()>();
v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.locks.Condition moreRequested> = v;
return;
}
public void onFailure(okhttp.WebSocket, java.lang.Throwable, okhttp.Response)
{
io.fabric.kubernetes.client.http.WebSocket$Listener v;
java.lang.Throwable v;
java.io.IOException v;
java.util.concurrent.CompletableFuture v, v;
okhttp.WebSocket v;
java.lang.Runnable v;
io.fabric.kubernetes.client.http.WebSocketHandshakeException v, v;
io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpResponseImpl v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl v;
okhttp.Response v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 v;
boolean v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1;
v := @parameter: okhttp.WebSocket;
v := @parameter: java.lang.Throwable;
v := @parameter: okhttp.Response;
if v == null goto label;
virtualinvoke v.<okhttp.Response: void close()>();
label:
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: boolean opened>;
if v != 0 goto label;
if v == null goto label;
label:
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.CompletableFuture val$future>;
v = new io.fabric.kubernetes.client.http.WebSocketHandshakeException;
v = new io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpResponseImpl;
specialinvoke v.<io.fabric.kubernetes.client.okhttp.OkHttpClientImpl$OkHttpResponseImpl: void <init>(okhttp.Response,java.lang.Class)>(v, null);
specialinvoke v.<io.fabric.kubernetes.client.http.WebSocketHandshakeException: void <init>(io.fabric.kubernetes.client.http.HttpResponse)>(v);
v = virtualinvoke v.<io.fabric.kubernetes.client.http.WebSocketHandshakeException: io.fabric.kubernetes.client.http.WebSocketHandshakeException initCause(java.lang.Throwable)>(v);
virtualinvoke v.<java.util.concurrent.CompletableFuture: boolean completeExceptionally(java.lang.Throwable)>(v);
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.CompletableFuture val$future>;
virtualinvoke v.<java.util.concurrent.CompletableFuture: boolean completeExceptionally(java.lang.Throwable)>(v);
goto label;
label:
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: io.fabric.kubernetes.client.http.WebSocket$Listener val$listener>;
v = new io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl;
v = staticinvoke <io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1$request__10: java.lang.Runnable bootstrap$(io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1)>(v);
specialinvoke v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl: void <init>(okhttp.WebSocket,java.lang.Runnable)>(v, v);
interfaceinvoke v.<io.fabric.kubernetes.client.http.WebSocket$Listener: void onError(io.fabric.kubernetes.client.http.WebSocket,java.lang.Throwable)>(v, v);
label:
return;
catch java.io.IOException from label to label with label;
}
public void onOpen(okhttp.WebSocket, okhttp.Response)
{
io.fabric.kubernetes.client.http.WebSocket$Listener v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl v;
okhttp.Response v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 v;
java.util.concurrent.CompletableFuture v;
okhttp.WebSocket v;
java.lang.Runnable v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1;
v := @parameter: okhttp.WebSocket;
v := @parameter: okhttp.Response;
v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: boolean opened> = 1;
if v == null goto label;
virtualinvoke v.<okhttp.Response: void close()>();
label:
v = new io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl;
v = staticinvoke <io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1$request__11: java.lang.Runnable bootstrap$(io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1)>(v);
specialinvoke v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl: void <init>(okhttp.WebSocket,java.lang.Runnable)>(v, v);
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: io.fabric.kubernetes.client.http.WebSocket$Listener val$listener>;
interfaceinvoke v.<io.fabric.kubernetes.client.http.WebSocket$Listener: void onOpen(io.fabric.kubernetes.client.http.WebSocket)>(v);
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.CompletableFuture val$future>;
virtualinvoke v.<java.util.concurrent.CompletableFuture: boolean complete(java.lang.Object)>(v);
return;
}
public void onMessage(okhttp.WebSocket, okio.ByteString)
{
io.fabric.kubernetes.client.http.WebSocket$Listener v;
okio.ByteString v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 v;
okhttp.WebSocket v;
java.lang.Runnable v;
java.nio.ByteBuffer v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1;
v := @parameter: okhttp.WebSocket;
v := @parameter: okio.ByteString;
specialinvoke v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: void awaitMoreRequest()>();
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: io.fabric.kubernetes.client.http.WebSocket$Listener val$listener>;
v = new io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl;
v = staticinvoke <io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1$request__12: java.lang.Runnable bootstrap$(io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1)>(v);
specialinvoke v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl: void <init>(okhttp.WebSocket,java.lang.Runnable)>(v, v);
v = virtualinvoke v.<okio.ByteString: java.nio.ByteBuffer asByteBuffer()>();
interfaceinvoke v.<io.fabric.kubernetes.client.http.WebSocket$Listener: void onMessage(io.fabric.kubernetes.client.http.WebSocket,java.nio.ByteBuffer)>(v, v);
return;
}
public void onMessage(okhttp.WebSocket, java.lang.String)
{
io.fabric.kubernetes.client.http.WebSocket$Listener v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 v;
okhttp.WebSocket v;
java.lang.String v;
java.lang.Runnable v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1;
v := @parameter: okhttp.WebSocket;
v := @parameter: java.lang.String;
specialinvoke v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: void awaitMoreRequest()>();
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: io.fabric.kubernetes.client.http.WebSocket$Listener val$listener>;
v = new io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl;
v = staticinvoke <io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1$request__13: java.lang.Runnable bootstrap$(io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1)>(v);
specialinvoke v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl: void <init>(okhttp.WebSocket,java.lang.Runnable)>(v, v);
interfaceinvoke v.<io.fabric.kubernetes.client.http.WebSocket$Listener: void onMessage(io.fabric.kubernetes.client.http.WebSocket,java.lang.String)>(v, v);
return;
}
private void awaitMoreRequest()
{
java.lang.Throwable v;
java.util.concurrent.locks.ReentrantLock v, v, v;
java.lang.RuntimeException v;
java.util.concurrent.locks.Condition v;
java.lang.InterruptedException v;
java.lang.Thread v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 v;
boolean v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1;
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: boolean more>;
if v != 0 goto label;
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.locks.Condition moreRequested>;
interfaceinvoke v.<java.util.concurrent.locks.Condition: void await()>();
goto label;
label:
v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: boolean more> = 0;
label:
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
v = staticinvoke <io.fabric.kubernetes.client.KubernetesClientException: java.lang.RuntimeException launderThrowable(java.lang.Throwable)>(v);
throw v;
label:
v := @caughtexception;
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
label:
return;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void request()
{
java.lang.Throwable v;
java.util.concurrent.locks.Condition v;
java.util.concurrent.locks.ReentrantLock v, v, v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1;
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: boolean more> = 1;
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.locks.Condition moreRequested>;
interfaceinvoke v.<java.util.concurrent.locks.Condition: void signalAll()>();
label:
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void onClosing(okhttp.WebSocket, int, java.lang.String)
{
io.fabric.kubernetes.client.http.WebSocket$Listener v;
int v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl v;
io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1 v;
okhttp.WebSocket v;
java.lang.String v;
java.lang.Runnable v;
v := @this: io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1;
v := @parameter: okhttp.WebSocket;
v := @parameter: int;
v := @parameter: java.lang.String;
specialinvoke v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: void awaitMoreRequest()>();
v = v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1: io.fabric.kubernetes.client.http.WebSocket$Listener val$listener>;
v = new io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl;
v = staticinvoke <io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1$request__14: java.lang.Runnable bootstrap$(io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl$BuilderImpl$1)>(v);
specialinvoke v.<io.fabric.kubernetes.client.okhttp.OkHttpWebSocketImpl: void <init>(okhttp.WebSocket,java.lang.Runnable)>(v, v);
interfaceinvoke v.<io.fabric.kubernetes.client.http.WebSocket$Listener: void onClose(io.fabric.kubernetes.client.http.WebSocket,int,java.lang.String)>(v, v, v);
return;
}
}