public class io.vertx.core.http.impl.WebSocketImpl extends io.vertx.core.http.impl.WebSocketImplBase implements io.vertx.core.http.WebSocket
{
private final io.vertx.core.http.impl.Http1xClientConnection conn;
private final long closingTimeoutMS;
public void <init>(io.vertx.core.impl.ContextInternal, io.vertx.core.http.impl.Http1xClientConnection, boolean, long, int, int, boolean)
{
io.vertx.core.impl.ContextInternal v;
long v, v;
byte v;
int v, v;
io.vertx.core.http.impl.Http1xClientConnection v;
io.vertx.core.http.impl.WebSocketImpl v;
boolean v, v;
v := @this: io.vertx.core.http.impl.WebSocketImpl;
v := @parameter: io.vertx.core.impl.ContextInternal;
v := @parameter: io.vertx.core.http.impl.Http1xClientConnection;
v := @parameter: boolean;
v := @parameter: long;
v := @parameter: int;
v := @parameter: int;
v := @parameter: boolean;
specialinvoke v.<io.vertx.core.http.impl.WebSocketImplBase: void <init>(io.vertx.core.impl.ContextInternal,io.vertx.core.http.impl.Http1xConnectionBase,boolean,int,int,boolean)>(v, v, v, v, v, v);
v.<io.vertx.core.http.impl.WebSocketImpl: io.vertx.core.http.impl.Http1xClientConnection conn> = v;
v = v cmp 0L;
if v < 0 goto label;
v = v * 1000L;
goto label;
label:
v = -1L;
label:
v.<io.vertx.core.http.impl.WebSocketImpl: long closingTimeoutMS> = v;
return;
}
protected void handleCloseConnection()
{
byte v, v;
long v, v, v;
io.vertx.core.http.impl.WebSocketImpl v;
v := @this: io.vertx.core.http.impl.WebSocketImpl;
v = v.<io.vertx.core.http.impl.WebSocketImpl: long closingTimeoutMS>;
v = v cmp 0L;
if v != 0 goto label;
virtualinvoke v.<io.vertx.core.http.impl.WebSocketImpl: void closeConnection()>();
goto label;
label:
v = v.<io.vertx.core.http.impl.WebSocketImpl: long closingTimeoutMS>;
v = v cmp 0L;
if v <= 0 goto label;
v = v.<io.vertx.core.http.impl.WebSocketImpl: long closingTimeoutMS>;
virtualinvoke v.<io.vertx.core.http.impl.WebSocketImpl: void initiateConnectionCloseTimeout(long)>(v);
label:
return;
}
protected void handleClose(boolean)
{
io.vertx.core.spi.metrics.HttpClientMetrics v;
java.lang.Object v;
io.vertx.core.http.impl.Http1xClientConnection v;
io.vertx.core.http.impl.WebSocketImpl v;
boolean v, v;
v := @this: io.vertx.core.http.impl.WebSocketImpl;
v := @parameter: boolean;
v = v.<io.vertx.core.http.impl.WebSocketImpl: io.vertx.core.http.impl.Http1xClientConnection conn>;
v = virtualinvoke v.<io.vertx.core.http.impl.Http1xClientConnection: io.vertx.core.spi.metrics.HttpClientMetrics metrics()>();
v = <io.vertx.core.spi.metrics.Metrics: boolean METRICS_ENABLED>;
if v == 0 goto label;
if v == null goto label;
v = virtualinvoke v.<io.vertx.core.http.impl.WebSocketImpl: java.lang.Object getMetric()>();
interfaceinvoke v.<io.vertx.core.spi.metrics.HttpClientMetrics: void disconnected(java.lang.Object)>(v);
virtualinvoke v.<io.vertx.core.http.impl.WebSocketImpl: void setMetric(java.lang.Object)>(null);
label:
specialinvoke v.<io.vertx.core.http.impl.WebSocketImplBase: void handleClose(boolean)>(v);
return;
}
}