class org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory extends java.lang.Object implements org.apache.hc.core.reactor.IOEventHandlerFactory
{
private static final org.slf4j.Logger STREAM_LOG;
private static final org.slf4j.Logger HEADER_LOG;
private static final org.slf4j.Logger FRAME_LOG;
private static final org.slf4j.Logger FRAME_PAYLOAD_LOG;
private static final org.slf4j.Logger FLOW_CTRL_LOG;
private final org.apache.hc.core.http.protocol.HttpProcessor httpProcessor;
private final org.apache.hc.core.http.nio.HandlerFactory exchangeHandlerFactory;
private final org.apache.hc.core.http.HttpVersionPolicy versionPolicy;
private final org.apache.hc.core.http.config.H2Config h2Config;
private final org.apache.hc.core.http.config.Http1Config h1Config;
private final org.apache.hc.core.http.config.CharCodingConfig charCodingConfig;
private final org.apache.hc.core.http.ConnectionReuseStrategy http1ConnectionReuseStrategy;
private final org.apache.hc.core.http.nio.NHttpMessageParserFactory http1ResponseParserFactory;
private final org.apache.hc.core.http.nio.NHttpMessageWriterFactory http1RequestWriterFactory;
void <init>(org.apache.hc.core.http.protocol.HttpProcessor, org.apache.hc.core.http.nio.HandlerFactory, org.apache.hc.core.http.HttpVersionPolicy, org.apache.hc.core.http.config.H2Config, org.apache.hc.core.http.config.Http1Config, org.apache.hc.core.http.config.CharCodingConfig, org.apache.hc.core.http.ConnectionReuseStrategy)
{
org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory v;
org.apache.hc.core.http.config.H2Config v, v;
org.apache.hc.core.http.config.CharCodingConfig v, v;
org.apache.hc.core.http.HttpVersionPolicy v, v;
org.apache.hc.core.http.protocol.HttpProcessor v;
org.apache.hc.core.http.config.Http1Config v, v;
org.apache.hc.core.http.impl.nio.DefaultHttpRequestWriterFactory v;
org.apache.hc.core.http.nio.HandlerFactory v;
org.apache.hc.core.http.impl.nio.DefaultHttpResponseParserFactory v;
org.apache.hc.core.http.ConnectionReuseStrategy v, v;
java.lang.Object v;
v := @this: org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory;
v := @parameter: org.apache.hc.core.http.protocol.HttpProcessor;
v := @parameter: org.apache.hc.core.http.nio.HandlerFactory;
v := @parameter: org.apache.hc.core.http.HttpVersionPolicy;
v := @parameter: org.apache.hc.core.http.config.H2Config;
v := @parameter: org.apache.hc.core.http.config.Http1Config;
v := @parameter: org.apache.hc.core.http.config.CharCodingConfig;
v := @parameter: org.apache.hc.core.http.ConnectionReuseStrategy;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.apache.hc.core.util.Args: java.lang.Object notNull(java.lang.Object,java.lang.String)>(v, "HTTP processor");
v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor> = v;
v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.nio.HandlerFactory exchangeHandlerFactory> = v;
if v == null goto label;
v = v;
goto label;
label:
v = <org.apache.hc.core.http.HttpVersionPolicy: org.apache.hc.core.http.HttpVersionPolicy NEGOTIATE>;
label:
v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.HttpVersionPolicy versionPolicy> = v;
if v == null goto label;
v = v;
goto label;
label:
v = <org.apache.hc.core.http.config.H2Config: org.apache.hc.core.http.config.H2Config DEFAULT>;
label:
v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.config.H2Config h2Config> = v;
if v == null goto label;
v = v;
goto label;
label:
v = <org.apache.hc.core.http.config.Http1Config: org.apache.hc.core.http.config.Http1Config DEFAULT>;
label:
v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.config.Http1Config h1Config> = v;
if v == null goto label;
v = v;
goto label;
label:
v = <org.apache.hc.core.http.config.CharCodingConfig: org.apache.hc.core.http.config.CharCodingConfig DEFAULT>;
label:
v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.config.CharCodingConfig charCodingConfig> = v;
if v == null goto label;
v = v;
goto label;
label:
v = <org.apache.hc.client.http.impl.DefaultClientConnectionReuseStrategy: org.apache.hc.client.http.impl.DefaultClientConnectionReuseStrategy INSTANCE>;
label:
v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.ConnectionReuseStrategy http1ConnectionReuseStrategy> = v;
v = new org.apache.hc.core.http.impl.nio.DefaultHttpResponseParserFactory;
specialinvoke v.<org.apache.hc.core.http.impl.nio.DefaultHttpResponseParserFactory: void <init>(org.apache.hc.core.http.config.Http1Config)>(v);
v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.nio.NHttpMessageParserFactory http1ResponseParserFactory> = v;
v = <org.apache.hc.core.http.impl.nio.DefaultHttpRequestWriterFactory: org.apache.hc.core.http.impl.nio.DefaultHttpRequestWriterFactory INSTANCE>;
v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.nio.NHttpMessageWriterFactory http1RequestWriterFactory> = v;
return;
}
public org.apache.hc.core.reactor.IOEventHandler createHandler(org.apache.hc.core.reactor.ProtocolIOSession, java.lang.Object)
{
org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory v;
org.apache.hc.core.http.impl.nio.ClientHttpProtocolNegotiator v, v;
org.apache.hc.core.http.config.H2Config v, v;
org.apache.hc.core.http.config.CharCodingConfig v, v, v, v;
org.apache.hc.core.http.protocol.HttpProcessor v, v, v, v;
org.apache.hc.core.http.config.Http1Config v, v;
boolean v, v, v, v, v, v, v;
org.apache.hc.core.http.nio.HandlerFactory v, v;
org.apache.hc.core.http.ConnectionReuseStrategy v, v;
org.apache.hc.core.http.nio.NHttpMessageWriterFactory v, v;
org.apache.hc.core.reactor.ProtocolIOSession v;
org.apache.hc.core.http.impl.nio.ClientH2StreamMultiplexerFactory v, v;
org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory$2 v;
org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory$1 v;
java.lang.String v;
org.apache.hc.core.http.nio.NHttpMessageParserFactory v, v;
org.slf4j.Logger v, v, v, v, v;
java.lang.Object v;
org.apache.hc.core.http.impl.nio.ClientHttp1StreamDuplexerFactory v, v;
v := @this: org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory;
v := @parameter: org.apache.hc.core.reactor.ProtocolIOSession;
v := @parameter: java.lang.Object;
v = <org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.slf4j.Logger STREAM_LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v != 0 goto label;
v = <org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: 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.async.HttpAsyncClientEventHandlerFactory: org.slf4j.Logger FRAME_LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v != 0 goto label;
v = <org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.slf4j.Logger FRAME_PAYLOAD_LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v != 0 goto label;
v = <org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.slf4j.Logger FLOW_CTRL_LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
label:
v = interfaceinvoke v.<org.apache.hc.core.reactor.ProtocolIOSession: java.lang.String getId()>();
v = new org.apache.hc.core.http.impl.nio.ClientHttp1StreamDuplexerFactory;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.config.Http1Config h1Config>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.config.CharCodingConfig charCodingConfig>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.ConnectionReuseStrategy http1ConnectionReuseStrategy>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.nio.NHttpMessageParserFactory http1ResponseParserFactory>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.nio.NHttpMessageWriterFactory http1RequestWriterFactory>;
v = new org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory$1;
specialinvoke v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory$1: void <init>(org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory,java.lang.String)>(v, v);
specialinvoke v.<org.apache.hc.core.http.impl.nio.ClientHttp1StreamDuplexerFactory: void <init>(org.apache.hc.core.http.protocol.HttpProcessor,org.apache.hc.core.http.config.Http1Config,org.apache.hc.core.http.config.CharCodingConfig,org.apache.hc.core.http.ConnectionReuseStrategy,org.apache.hc.core.http.nio.NHttpMessageParserFactory,org.apache.hc.core.http.nio.NHttpMessageWriterFactory,org.apache.hc.core.http.impl.Http1StreamListener)>(v, v, v, v, v, v, v);
v = new org.apache.hc.core.http.impl.nio.ClientH2StreamMultiplexerFactory;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.nio.HandlerFactory exchangeHandlerFactory>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.config.H2Config h2Config>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.config.CharCodingConfig charCodingConfig>;
v = new org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory$2;
specialinvoke v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory$2: void <init>(org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory,java.lang.String)>(v, v);
specialinvoke v.<org.apache.hc.core.http.impl.nio.ClientH2StreamMultiplexerFactory: void <init>(org.apache.hc.core.http.protocol.HttpProcessor,org.apache.hc.core.http.nio.HandlerFactory,org.apache.hc.core.http.config.H2Config,org.apache.hc.core.http.config.CharCodingConfig,org.apache.hc.core.http.impl.nio.H2StreamListener)>(v, v, v, v, v);
v = new org.apache.hc.core.http.impl.nio.ClientHttpProtocolNegotiator;
v = v instanceof org.apache.hc.core.http.HttpVersionPolicy;
if v != 0 goto label;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.HttpVersionPolicy versionPolicy>;
label:
specialinvoke v.<org.apache.hc.core.http.impl.nio.ClientHttpProtocolNegotiator: void <init>(org.apache.hc.core.reactor.ProtocolIOSession,org.apache.hc.core.http.impl.nio.ClientHttp1StreamDuplexerFactory,org.apache.hc.core.http.impl.nio.ClientH2StreamMultiplexerFactory,org.apache.hc.core.http.HttpVersionPolicy)>(v, v, v, v);
return v;
label:
v = new org.apache.hc.core.http.impl.nio.ClientHttp1StreamDuplexerFactory;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.config.Http1Config h1Config>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.config.CharCodingConfig charCodingConfig>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.ConnectionReuseStrategy http1ConnectionReuseStrategy>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.nio.NHttpMessageParserFactory http1ResponseParserFactory>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.nio.NHttpMessageWriterFactory http1RequestWriterFactory>;
specialinvoke v.<org.apache.hc.core.http.impl.nio.ClientHttp1StreamDuplexerFactory: void <init>(org.apache.hc.core.http.protocol.HttpProcessor,org.apache.hc.core.http.config.Http1Config,org.apache.hc.core.http.config.CharCodingConfig,org.apache.hc.core.http.ConnectionReuseStrategy,org.apache.hc.core.http.nio.NHttpMessageParserFactory,org.apache.hc.core.http.nio.NHttpMessageWriterFactory,org.apache.hc.core.http.impl.Http1StreamListener)>(v, v, v, v, v, v, null);
v = new org.apache.hc.core.http.impl.nio.ClientH2StreamMultiplexerFactory;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.protocol.HttpProcessor httpProcessor>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.nio.HandlerFactory exchangeHandlerFactory>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.config.H2Config h2Config>;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.config.CharCodingConfig charCodingConfig>;
specialinvoke v.<org.apache.hc.core.http.impl.nio.ClientH2StreamMultiplexerFactory: void <init>(org.apache.hc.core.http.protocol.HttpProcessor,org.apache.hc.core.http.nio.HandlerFactory,org.apache.hc.core.http.config.H2Config,org.apache.hc.core.http.config.CharCodingConfig,org.apache.hc.core.http.impl.nio.H2StreamListener)>(v, v, v, v, null);
v = new org.apache.hc.core.http.impl.nio.ClientHttpProtocolNegotiator;
v = v instanceof org.apache.hc.core.http.HttpVersionPolicy;
if v != 0 goto label;
v = v.<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.apache.hc.core.http.HttpVersionPolicy versionPolicy>;
label:
specialinvoke v.<org.apache.hc.core.http.impl.nio.ClientHttpProtocolNegotiator: void <init>(org.apache.hc.core.reactor.ProtocolIOSession,org.apache.hc.core.http.impl.nio.ClientHttp1StreamDuplexerFactory,org.apache.hc.core.http.impl.nio.ClientH2StreamMultiplexerFactory,org.apache.hc.core.http.HttpVersionPolicy)>(v, v, v, v);
return v;
}
static void <clinit>()
{
org.slf4j.Logger v, v, v, v, v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/hc/client5/http/impl/async/InternalHttpAsyncClient;");
<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.slf4j.Logger STREAM_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.async.HttpAsyncClientEventHandlerFactory: org.slf4j.Logger HEADER_LOG> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.String)>("org.apache.hc.client.http.frame");
<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.slf4j.Logger FRAME_LOG> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.String)>("org.apache.hc.client.http.frame.payload");
<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.slf4j.Logger FRAME_PAYLOAD_LOG> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.String)>("org.apache.hc.client.http.flow");
<org.apache.hc.client.http.impl.async.HttpAsyncClientEventHandlerFactory: org.slf4j.Logger FLOW_CTRL_LOG> = v;
return;
}
}