public final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.CombinedChannelDuplexHandler implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientUpgradeHandler$SourceCodec
{
private final java.util.Queue queue;
private final boolean parseHttpAfterConnectRequest;
private boolean done;
private final java.util.concurrent.atomic.AtomicLong requestResponseCounter;
private final boolean failOnMissingResponse;
public void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: void <init>(int,int,int,boolean)>(4096, 8192, 8192, 0);
return;
}
public void <init>(int, int, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec v;
int v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: void <init>(int,int,int,boolean)>(v, v, v, 0);
return;
}
public void <init>(int, int, int, boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec v;
int v, v, v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
v := @parameter: boolean;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: void <init>(int,int,int,boolean,boolean)>(v, v, v, v, 1);
return;
}
public void <init>(int, int, int, boolean, boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec v;
int v, v, v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
v := @parameter: boolean;
v := @parameter: boolean;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: void <init>(int,int,int,boolean,boolean,boolean)>(v, v, v, v, v, 0);
return;
}
public void <init>(int, int, int, boolean, boolean, boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec$Decoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec$Encoder v;
java.util.concurrent.atomic.AtomicLong v;
int v, v, v;
java.util.ArrayDeque v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
v := @parameter: boolean;
v := @parameter: boolean;
v := @parameter: boolean;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.CombinedChannelDuplexHandler: void <init>()>();
v = new java.util.ArrayDeque;
specialinvoke v.<java.util.ArrayDeque: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: java.util.Queue queue> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: java.util.concurrent.atomic.AtomicLong requestResponseCounter> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec$Decoder;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec$Decoder: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec,int,int,int,boolean)>(v, v, v, v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec$Encoder;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec$Encoder: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: void init(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelInboundHandler,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundHandler)>(v, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: boolean failOnMissingResponse> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: boolean parseHttpAfterConnectRequest> = v;
return;
}
public void <init>(int, int, int, boolean, boolean, int)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec v;
int v, v, v, v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
v := @parameter: boolean;
v := @parameter: boolean;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: void <init>(int,int,int,boolean,boolean,int,boolean)>(v, v, v, v, v, v, 0);
return;
}
public void <init>(int, int, int, boolean, boolean, int, boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec$Decoder v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec$Encoder v;
java.util.concurrent.atomic.AtomicLong v;
int v, v, v, v;
java.util.ArrayDeque v;
boolean v, v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
v := @parameter: boolean;
v := @parameter: boolean;
v := @parameter: int;
v := @parameter: boolean;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.CombinedChannelDuplexHandler: void <init>()>();
v = new java.util.ArrayDeque;
specialinvoke v.<java.util.ArrayDeque: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: java.util.Queue queue> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: java.util.concurrent.atomic.AtomicLong requestResponseCounter> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec$Decoder;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec$Decoder: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec,int,int,int,boolean,int)>(v, v, v, v, v, v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec$Encoder;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec$Encoder: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec)>(v);
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: void init(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelInboundHandler,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundHandler)>(v, v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: boolean parseHttpAfterConnectRequest> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: boolean failOnMissingResponse> = v;
return;
}
public void prepareUpgradeFrom(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundHandler v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelOutboundHandler outboundHandler()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec$Encoder: boolean upgraded> = 1;
return;
}
public void upgradeFrom(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline pipeline()>();
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPipeline remove(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandler)>(v);
return;
}
public void setSingleDecode(boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelInboundHandler v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec;
v := @parameter: boolean;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelInboundHandler inboundHandler()>();
virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpResponseDecoder: void setSingleDecode(boolean)>(v);
return;
}
public boolean isSingleDecode()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelInboundHandler v;
boolean v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpClientCodec: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelInboundHandler inboundHandler()>();
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.http.HttpResponseDecoder: boolean isSingleDecode()>();
return v;
}
}