final class org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection extends org.apache.hc.core.http.impl.io.DefaultBHttpClientConnection implements org.apache.hc.client.http.io.ManagedHttpClientConnection, org.apache.hc.core.util.Identifiable
{
private static final org.slf4j.Logger LOG;
private static final org.slf4j.Logger HEADER_LOG;
private static final org.slf4j.Logger WIRE_LOG;
private final java.lang.String id;
private final java.util.concurrent.atomic.AtomicBoolean closed;
private org.apache.hc.core.util.Timeout socketTimeout;
public void <init>(java.lang.String, java.nio.charset.CharsetDecoder, java.nio.charset.CharsetEncoder, org.apache.hc.core.http.config.Http1Config, org.apache.hc.core.http.ContentLengthStrategy, org.apache.hc.core.http.ContentLengthStrategy, org.apache.hc.core.http.io.ResponseOutOfOrderStrategy, org.apache.hc.core.http.io.HttpMessageWriterFactory, org.apache.hc.core.http.io.HttpMessageParserFactory)
{
org.apache.hc.core.http.io.ResponseOutOfOrderStrategy v;
org.apache.hc.core.http.ContentLengthStrategy v, v;
java.util.concurrent.atomic.AtomicBoolean v;
java.nio.charset.CharsetDecoder v;
org.apache.hc.core.http.io.HttpMessageParserFactory v;
java.nio.charset.CharsetEncoder v;
org.apache.hc.core.http.io.HttpMessageWriterFactory v;
org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection v;
java.lang.String v;
org.apache.hc.core.http.config.Http1Config v;
v := @this: org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection;
v := @parameter: java.lang.String;
v := @parameter: java.nio.charset.CharsetDecoder;
v := @parameter: java.nio.charset.CharsetEncoder;
v := @parameter: org.apache.hc.core.http.config.Http1Config;
v := @parameter: org.apache.hc.core.http.ContentLengthStrategy;
v := @parameter: org.apache.hc.core.http.ContentLengthStrategy;
v := @parameter: org.apache.hc.core.http.io.ResponseOutOfOrderStrategy;
v := @parameter: org.apache.hc.core.http.io.HttpMessageWriterFactory;
v := @parameter: org.apache.hc.core.http.io.HttpMessageParserFactory;
specialinvoke v.<org.apache.hc.core.http.impl.io.DefaultBHttpClientConnection: void <init>(org.apache.hc.core.http.config.Http1Config,java.nio.charset.CharsetDecoder,java.nio.charset.CharsetEncoder,org.apache.hc.core.http.ContentLengthStrategy,org.apache.hc.core.http.ContentLengthStrategy,org.apache.hc.core.http.io.ResponseOutOfOrderStrategy,org.apache.hc.core.http.io.HttpMessageWriterFactory,org.apache.hc.core.http.io.HttpMessageParserFactory)>(v, v, v, v, v, v, v, v);
v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: java.lang.String id> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>()>();
v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: java.util.concurrent.atomic.AtomicBoolean closed> = v;
return;
}
public void <init>(java.lang.String, java.nio.charset.CharsetDecoder, java.nio.charset.CharsetEncoder, org.apache.hc.core.http.config.Http1Config, org.apache.hc.core.http.ContentLengthStrategy, org.apache.hc.core.http.ContentLengthStrategy, org.apache.hc.core.http.io.HttpMessageWriterFactory, org.apache.hc.core.http.io.HttpMessageParserFactory)
{
org.apache.hc.core.http.ContentLengthStrategy v, v;
java.nio.charset.CharsetDecoder v;
org.apache.hc.core.http.io.HttpMessageParserFactory v;
java.nio.charset.CharsetEncoder v;
org.apache.hc.core.http.io.HttpMessageWriterFactory v;
org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection v;
java.lang.String v;
org.apache.hc.core.http.config.Http1Config v;
v := @this: org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection;
v := @parameter: java.lang.String;
v := @parameter: java.nio.charset.CharsetDecoder;
v := @parameter: java.nio.charset.CharsetEncoder;
v := @parameter: org.apache.hc.core.http.config.Http1Config;
v := @parameter: org.apache.hc.core.http.ContentLengthStrategy;
v := @parameter: org.apache.hc.core.http.ContentLengthStrategy;
v := @parameter: org.apache.hc.core.http.io.HttpMessageWriterFactory;
v := @parameter: org.apache.hc.core.http.io.HttpMessageParserFactory;
specialinvoke v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: void <init>(java.lang.String,java.nio.charset.CharsetDecoder,java.nio.charset.CharsetEncoder,org.apache.hc.core.http.config.Http1Config,org.apache.hc.core.http.ContentLengthStrategy,org.apache.hc.core.http.ContentLengthStrategy,org.apache.hc.core.http.io.ResponseOutOfOrderStrategy,org.apache.hc.core.http.io.HttpMessageWriterFactory,org.apache.hc.core.http.io.HttpMessageParserFactory)>(v, v, v, v, v, v, null, v, v);
return;
}
public void <init>(java.lang.String)
{
org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection v;
java.lang.String v;
v := @this: org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection;
v := @parameter: java.lang.String;
specialinvoke v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: void <init>(java.lang.String,java.nio.charset.CharsetDecoder,java.nio.charset.CharsetEncoder,org.apache.hc.core.http.config.Http1Config,org.apache.hc.core.http.ContentLengthStrategy,org.apache.hc.core.http.ContentLengthStrategy,org.apache.hc.core.http.io.HttpMessageWriterFactory,org.apache.hc.core.http.io.HttpMessageParserFactory)>(v, null, null, null, null, null, null, null);
return;
}
public java.lang.String getId()
{
org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection v;
java.lang.String v;
v := @this: org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection;
v = v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: java.lang.String id>;
return v;
}
public void bind(org.apache.hc.core.http.impl.io.SocketHolder) throws java.io.IOException
{
java.net.Socket v, v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.hc.core.http.impl.io.SocketHolder v;
java.io.InterruptedIOException v;
org.apache.hc.core.util.Timeout v;
int v;
org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection v;
boolean v;
v := @this: org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection;
v := @parameter: org.apache.hc.core.http.impl.io.SocketHolder;
v = v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: java.util.concurrent.atomic.AtomicBoolean closed>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.hc.core.http.impl.io.SocketHolder: java.net.Socket getSocket()>();
virtualinvoke v.<java.net.Socket: void close()>();
v = new java.io.InterruptedIOException;
specialinvoke v.<java.io.InterruptedIOException: void <init>(java.lang.String)>("Connection already shutdown");
throw v;
label:
specialinvoke v.<org.apache.hc.core.http.impl.io.DefaultBHttpClientConnection: void bind(org.apache.hc.core.http.impl.io.SocketHolder)>(v);
v = virtualinvoke v.<org.apache.hc.core.http.impl.io.SocketHolder: java.net.Socket getSocket()>();
v = virtualinvoke v.<java.net.Socket: int getSoTimeout()>();
v = staticinvoke <org.apache.hc.core.util.Timeout: org.apache.hc.core.util.Timeout ofMilliseconds(long)>(v);
v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.apache.hc.core.util.Timeout socketTimeout> = v;
return;
}
public java.net.Socket getSocket()
{
org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection v;
java.net.Socket v;
org.apache.hc.core.http.impl.io.SocketHolder v;
v := @this: org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection;
v = virtualinvoke v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.apache.hc.core.http.impl.io.SocketHolder getSocketHolder()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.hc.core.http.impl.io.SocketHolder: java.net.Socket getSocket()>();
goto label;
label:
v = null;
label:
return v;
}
public javax.net.ssl.SSLSession getSSLSession()
{
java.net.Socket v;
javax.net.ssl.SSLSession v;
org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection v;
boolean v;
v := @this: org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection;
v = virtualinvoke v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: java.net.Socket getSocket()>();
v = v instanceof javax.net.ssl.SSLSocket;
if v == 0 goto label;
v = virtualinvoke v.<javax.net.ssl.SSLSocket: javax.net.ssl.SSLSession getSession()>();
return v;
label:
return null;
}
public void close() throws java.io.IOException
{
org.slf4j.Logger v, v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection v;
java.lang.String v;
boolean v, v;
v := @this: org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection;
v = v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: java.util.concurrent.atomic.AtomicBoolean closed>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger LOG>;
v = v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: java.lang.String id>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("{} Close connection", v);
label:
specialinvoke v.<org.apache.hc.core.http.impl.io.DefaultBHttpClientConnection: void close()>();
label:
return;
}
public void setSocketTimeout(org.apache.hc.core.util.Timeout)
{
org.slf4j.Logger v, v;
org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection v;
java.lang.String v;
org.apache.hc.core.util.Timeout v;
boolean v;
v := @this: org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection;
v := @parameter: org.apache.hc.core.util.Timeout;
v = <org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger LOG>;
v = v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: java.lang.String id>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} set socket timeout to {}", v, v);
label:
specialinvoke v.<org.apache.hc.core.http.impl.io.DefaultBHttpClientConnection: void setSocketTimeout(org.apache.hc.core.util.Timeout)>(v);
return;
}
public void close(org.apache.hc.core.io.CloseMode)
{
org.slf4j.Logger v, v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.hc.core.io.CloseMode v;
org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection v;
java.lang.String v;
boolean v, v;
v := @this: org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection;
v := @parameter: org.apache.hc.core.io.CloseMode;
v = v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: java.util.concurrent.atomic.AtomicBoolean closed>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger LOG>;
v = v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: java.lang.String id>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} close connection {}", v, v);
label:
specialinvoke v.<org.apache.hc.core.http.impl.io.DefaultBHttpClientConnection: void close(org.apache.hc.core.io.CloseMode)>(v);
label:
return;
}
public void bind(java.net.Socket) throws java.io.IOException
{
java.net.Socket v;
org.slf4j.Logger v, v;
org.apache.hc.core.http.impl.io.SocketHolder v, v;
org.apache.hc.core.util.Timeout v;
int v;
org.apache.hc.client.http.impl.io.LoggingSocketHolder v;
org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection v;
java.lang.String v;
boolean v;
v := @this: org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection;
v := @parameter: java.net.Socket;
v = <org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger WIRE_LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = new org.apache.hc.client.http.impl.io.LoggingSocketHolder;
v = v;
v = v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: java.lang.String id>;
v = <org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger WIRE_LOG>;
specialinvoke v.<org.apache.hc.client.http.impl.io.LoggingSocketHolder: void <init>(java.net.Socket,java.lang.String,org.slf4j.Logger)>(v, v, v);
goto label;
label:
v = new org.apache.hc.core.http.impl.io.SocketHolder;
v = v;
specialinvoke v.<org.apache.hc.core.http.impl.io.SocketHolder: void <init>(java.net.Socket)>(v);
label:
specialinvoke v.<org.apache.hc.core.http.impl.io.DefaultBHttpClientConnection: void bind(org.apache.hc.core.http.impl.io.SocketHolder)>(v);
v = virtualinvoke v.<java.net.Socket: int getSoTimeout()>();
v = staticinvoke <org.apache.hc.core.util.Timeout: org.apache.hc.core.util.Timeout ofMilliseconds(long)>(v);
v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.apache.hc.core.util.Timeout socketTimeout> = v;
return;
}
protected void onResponseReceived(org.apache.hc.core.http.ClassicHttpResponse)
{
org.slf4j.Logger v, v, v;
org.apache.hc.core.http.Header v;
org.apache.hc.core.http.message.StatusLine v;
org.apache.hc.core.http.ClassicHttpResponse v;
int v, v;
org.apache.hc.core.http.Header[] v;
org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection;
v := @parameter: org.apache.hc.core.http.ClassicHttpResponse;
if v == null goto label;
v = <org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger HEADER_LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger HEADER_LOG>;
v = v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: java.lang.String id>;
v = new org.apache.hc.core.http.message.StatusLine;
specialinvoke v.<org.apache.hc.core.http.message.StatusLine: void <init>(org.apache.hc.core.http.HttpResponse)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} << {}", v, v);
v = interfaceinvoke v.<org.apache.hc.core.http.ClassicHttpResponse: org.apache.hc.core.http.Header[] getHeaders()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger HEADER_LOG>;
v = v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: java.lang.String id>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} << {}", v, v);
v = v + 1;
goto label;
label:
return;
}
protected void onRequestSubmitted(org.apache.hc.core.http.ClassicHttpRequest)
{
org.slf4j.Logger v, v, v;
org.apache.hc.core.http.Header v;
org.apache.hc.core.http.message.RequestLine v;
org.apache.hc.core.http.ClassicHttpRequest v;
int v, v;
org.apache.hc.core.http.Header[] v;
org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection;
v := @parameter: org.apache.hc.core.http.ClassicHttpRequest;
if v == null goto label;
v = <org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger HEADER_LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger HEADER_LOG>;
v = v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: java.lang.String id>;
v = new org.apache.hc.core.http.message.RequestLine;
specialinvoke v.<org.apache.hc.core.http.message.RequestLine: void <init>(org.apache.hc.core.http.HttpRequest)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} >> {}", v, v);
v = interfaceinvoke v.<org.apache.hc.core.http.ClassicHttpRequest: org.apache.hc.core.http.Header[] getHeaders()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger HEADER_LOG>;
v = v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: java.lang.String id>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("{} >> {}", v, v);
v = v + 1;
goto label;
label:
return;
}
public void passivate()
{
org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection v;
org.apache.hc.core.util.Timeout v;
v := @this: org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection;
v = <org.apache.hc.core.util.Timeout: org.apache.hc.core.util.Timeout ZERO_MILLISECONDS>;
specialinvoke v.<org.apache.hc.core.http.impl.io.DefaultBHttpClientConnection: void setSocketTimeout(org.apache.hc.core.util.Timeout)>(v);
return;
}
public void activate()
{
org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection v;
org.apache.hc.core.util.Timeout v;
v := @this: org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection;
v = v.<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.apache.hc.core.util.Timeout socketTimeout>;
specialinvoke v.<org.apache.hc.core.http.impl.io.DefaultBHttpClientConnection: void setSocketTimeout(org.apache.hc.core.util.Timeout)>(v);
return;
}
static void <clinit>()
{
org.slf4j.Logger v, v, v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/hc/client5/http/impl/io/DefaultManagedHttpClientConnection;");
<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger LOG> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.String)>("org.apache.hc.client.http.headers");
<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger HEADER_LOG> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.String)>("org.apache.hc.client.http.wire");
<org.apache.hc.client.http.impl.io.DefaultManagedHttpClientConnection: org.slf4j.Logger WIRE_LOG> = v;
return;
}
}