public class io.netty.channel.DefaultChannelConfig extends java.lang.Object implements io.netty.channel.ChannelConfig
{
private static final io.netty.channel.MessageSizeEstimator DEFAULT_MSG_SIZE_ESTIMATOR;
private static final int DEFAULT_CONNECT_TIMEOUT;
private static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater AUTOREAD_UPDATER;
private static final java.util.concurrent.atomic.AtomicReferenceFieldUpdater WATERMARK_UPDATER;
protected final io.netty.channel.Channel channel;
private volatile io.netty.buffer.ByteBufAllocator allocator;
private volatile io.netty.channel.RecvByteBufAllocator rcvBufAllocator;
private volatile io.netty.channel.MessageSizeEstimator msgSizeEstimator;
private volatile int connectTimeoutMillis;
private volatile int writeSpinCount;
private volatile int maxMessagesPerWrite;
private volatile int autoRead;
private volatile boolean autoClose;
private volatile io.netty.channel.WriteBufferWaterMark writeBufferWaterMark;
private volatile boolean pinEventExecutor;
public void <init>(io.netty.channel.Channel)
{
io.netty.channel.Channel v;
io.netty.channel.AdaptiveRecvByteBufAllocator v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: io.netty.channel.Channel;
v = new io.netty.channel.AdaptiveRecvByteBufAllocator;
specialinvoke v.<io.netty.channel.AdaptiveRecvByteBufAllocator: void <init>()>();
specialinvoke v.<io.netty.channel.DefaultChannelConfig: void <init>(io.netty.channel.Channel,io.netty.channel.RecvByteBufAllocator)>(v, v);
return;
}
protected void <init>(io.netty.channel.Channel, io.netty.channel.RecvByteBufAllocator)
{
io.netty.channel.Channel v;
io.netty.channel.MessageSizeEstimator v;
io.netty.channel.WriteBufferWaterMark v;
io.netty.buffer.ByteBufAllocator v;
io.netty.channel.DefaultChannelConfig v;
io.netty.channel.ChannelMetadata v;
io.netty.channel.RecvByteBufAllocator v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: io.netty.channel.Channel;
v := @parameter: io.netty.channel.RecvByteBufAllocator;
specialinvoke v.<java.lang.Object: void <init>()>();
v = <io.netty.buffer.ByteBufAllocator: io.netty.buffer.ByteBufAllocator DEFAULT>;
v.<io.netty.channel.DefaultChannelConfig: io.netty.buffer.ByteBufAllocator allocator> = v;
v = <io.netty.channel.DefaultChannelConfig: io.netty.channel.MessageSizeEstimator DEFAULT_MSG_SIZE_ESTIMATOR>;
v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.MessageSizeEstimator msgSizeEstimator> = v;
v.<io.netty.channel.DefaultChannelConfig: int connectTimeoutMillis> = 30000;
v.<io.netty.channel.DefaultChannelConfig: int writeSpinCount> = 16;
v.<io.netty.channel.DefaultChannelConfig: int maxMessagesPerWrite> = 2147483647;
v.<io.netty.channel.DefaultChannelConfig: int autoRead> = 1;
v.<io.netty.channel.DefaultChannelConfig: boolean autoClose> = 1;
v = <io.netty.channel.WriteBufferWaterMark: io.netty.channel.WriteBufferWaterMark DEFAULT>;
v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.WriteBufferWaterMark writeBufferWaterMark> = v;
v.<io.netty.channel.DefaultChannelConfig: boolean pinEventExecutor> = 1;
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelMetadata metadata()>();
specialinvoke v.<io.netty.channel.DefaultChannelConfig: void setRecvByteBufAllocator(io.netty.channel.RecvByteBufAllocator,io.netty.channel.ChannelMetadata)>(v, v);
v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.Channel channel> = v;
return;
}
public java.util.Map getOptions()
{
io.netty.channel.ChannelOption v, v, v, v, v, v, v, v, v, v, v, v, v;
io.netty.channel.DefaultChannelConfig v;
io.netty.channel.ChannelOption[] v;
java.util.Map v;
v := @this: io.netty.channel.DefaultChannelConfig;
v = newarray (io.netty.channel.ChannelOption)[13];
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption CONNECT_TIMEOUT_MILLIS>;
v[0] = v;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption MAX_MESSAGES_PER_READ>;
v[1] = v;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption WRITE_SPIN_COUNT>;
v[2] = v;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption ALLOCATOR>;
v[3] = v;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption AUTO_READ>;
v[4] = v;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption AUTO_CLOSE>;
v[5] = v;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption RCVBUF_ALLOCATOR>;
v[6] = v;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption WRITE_BUFFER_HIGH_WATER_MARK>;
v[7] = v;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption WRITE_BUFFER_LOW_WATER_MARK>;
v[8] = v;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption WRITE_BUFFER_WATER_MARK>;
v[9] = v;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption MESSAGE_SIZE_ESTIMATOR>;
v[10] = v;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption SINGLE_EVENTEXECUTOR_PER_GROUP>;
v[11] = v;
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption MAX_MESSAGES_PER_WRITE>;
v[12] = v;
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: java.util.Map getOptions(java.util.Map,io.netty.channel.ChannelOption[])>(null, v);
return v;
}
protected transient java.util.Map getOptions(java.util.Map, io.netty.channel.ChannelOption[])
{
java.util.IdentityHashMap v;
io.netty.channel.ChannelOption v;
io.netty.channel.DefaultChannelConfig v;
io.netty.channel.ChannelOption[] v;
java.util.Map v;
int v, v;
java.lang.Object v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: java.util.Map;
v := @parameter: io.netty.channel.ChannelOption[];
if v != null goto label;
v = new java.util.IdentityHashMap;
specialinvoke v.<java.util.IdentityHashMap: void <init>()>();
v = v;
label:
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: java.lang.Object getOption(io.netty.channel.ChannelOption)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
return v;
}
public boolean setOptions(java.util.Map)
{
java.util.Iterator v;
io.netty.channel.DefaultChannelConfig v;
java.util.Set v;
java.util.Map v;
java.lang.Object v, v, v;
boolean v, v, v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: java.util.Map;
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "options");
v = 1;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: boolean setOption(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
if v != 0 goto label;
v = 0;
goto label;
label:
return v;
}
public java.lang.Object getOption(io.netty.channel.ChannelOption)
{
io.netty.buffer.ByteBufAllocator v;
io.netty.channel.DefaultChannelConfig v;
java.lang.Integer v, v, v, v, v, v;
io.netty.channel.MessageSizeEstimator v;
boolean v, v, v;
io.netty.channel.RecvByteBufAllocator v;
io.netty.channel.WriteBufferWaterMark v;
io.netty.channel.ChannelOption v, v, v, v, v, v, v, v, v, v, v, v, v, v;
int v, v, v, v, v, v;
java.lang.Boolean v, v, v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: io.netty.channel.ChannelOption;
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "option");
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption CONNECT_TIMEOUT_MILLIS>;
if v != v goto label;
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: int getConnectTimeoutMillis()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
return v;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption MAX_MESSAGES_PER_READ>;
if v != v goto label;
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: int getMaxMessagesPerRead()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
return v;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption WRITE_SPIN_COUNT>;
if v != v goto label;
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: int getWriteSpinCount()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
return v;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption ALLOCATOR>;
if v != v goto label;
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.buffer.ByteBufAllocator getAllocator()>();
return v;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption RCVBUF_ALLOCATOR>;
if v != v goto label;
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.RecvByteBufAllocator getRecvByteBufAllocator()>();
return v;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption AUTO_READ>;
if v != v goto label;
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: boolean isAutoRead()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
return v;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption AUTO_CLOSE>;
if v != v goto label;
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: boolean isAutoClose()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
return v;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption WRITE_BUFFER_HIGH_WATER_MARK>;
if v != v goto label;
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: int getWriteBufferHighWaterMark()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
return v;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption WRITE_BUFFER_LOW_WATER_MARK>;
if v != v goto label;
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: int getWriteBufferLowWaterMark()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
return v;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption WRITE_BUFFER_WATER_MARK>;
if v != v goto label;
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.WriteBufferWaterMark getWriteBufferWaterMark()>();
return v;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption MESSAGE_SIZE_ESTIMATOR>;
if v != v goto label;
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.MessageSizeEstimator getMessageSizeEstimator()>();
return v;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption SINGLE_EVENTEXECUTOR_PER_GROUP>;
if v != v goto label;
v = specialinvoke v.<io.netty.channel.DefaultChannelConfig: boolean getPinEventExecutorPerGroup()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
return v;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption MAX_MESSAGES_PER_WRITE>;
if v != v goto label;
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: int getMaxMessagesPerWrite()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
return v;
label:
return null;
}
public boolean setOption(io.netty.channel.ChannelOption, java.lang.Object)
{
io.netty.channel.ChannelOption v, v, v, v, v, v, v, v, v, v, v, v, v, v;
io.netty.channel.DefaultChannelConfig v;
int v, v, v, v, v, v;
boolean v, v, v;
java.lang.Object v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: io.netty.channel.ChannelOption;
v := @parameter: java.lang.Object;
virtualinvoke v.<io.netty.channel.DefaultChannelConfig: void validate(io.netty.channel.ChannelOption,java.lang.Object)>(v, v);
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption CONNECT_TIMEOUT_MILLIS>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.ChannelConfig setConnectTimeoutMillis(int)>(v);
goto label;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption MAX_MESSAGES_PER_READ>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.ChannelConfig setMaxMessagesPerRead(int)>(v);
goto label;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption WRITE_SPIN_COUNT>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.ChannelConfig setWriteSpinCount(int)>(v);
goto label;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption ALLOCATOR>;
if v != v goto label;
virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.ChannelConfig setAllocator(io.netty.buffer.ByteBufAllocator)>(v);
goto label;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption RCVBUF_ALLOCATOR>;
if v != v goto label;
virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.ChannelConfig setRecvByteBufAllocator(io.netty.channel.RecvByteBufAllocator)>(v);
goto label;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption AUTO_READ>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.ChannelConfig setAutoRead(boolean)>(v);
goto label;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption AUTO_CLOSE>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.ChannelConfig setAutoClose(boolean)>(v);
goto label;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption WRITE_BUFFER_HIGH_WATER_MARK>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.ChannelConfig setWriteBufferHighWaterMark(int)>(v);
goto label;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption WRITE_BUFFER_LOW_WATER_MARK>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.ChannelConfig setWriteBufferLowWaterMark(int)>(v);
goto label;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption WRITE_BUFFER_WATER_MARK>;
if v != v goto label;
virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.ChannelConfig setWriteBufferWaterMark(io.netty.channel.WriteBufferWaterMark)>(v);
goto label;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption MESSAGE_SIZE_ESTIMATOR>;
if v != v goto label;
virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.ChannelConfig setMessageSizeEstimator(io.netty.channel.MessageSizeEstimator)>(v);
goto label;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption SINGLE_EVENTEXECUTOR_PER_GROUP>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
specialinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.ChannelConfig setPinEventExecutorPerGroup(boolean)>(v);
goto label;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption MAX_MESSAGES_PER_WRITE>;
if v != v goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.ChannelConfig setMaxMessagesPerWrite(int)>(v);
goto label;
label:
return 0;
label:
return 1;
}
protected void validate(io.netty.channel.ChannelOption, java.lang.Object)
{
io.netty.channel.ChannelOption v;
io.netty.channel.DefaultChannelConfig v;
java.lang.Object v, v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: io.netty.channel.ChannelOption;
v := @parameter: java.lang.Object;
v = staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "option");
virtualinvoke v.<io.netty.channel.ChannelOption: void validate(java.lang.Object)>(v);
return;
}
public int getConnectTimeoutMillis()
{
int v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v = v.<io.netty.channel.DefaultChannelConfig: int connectTimeoutMillis>;
return v;
}
public io.netty.channel.ChannelConfig setConnectTimeoutMillis(int)
{
int v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: int;
staticinvoke <io.netty.util.internal.ObjectUtil: int checkPositiveOrZero(int,java.lang.String)>(v, "connectTimeoutMillis");
v.<io.netty.channel.DefaultChannelConfig: int connectTimeoutMillis> = v;
return v;
}
public int getMaxMessagesPerRead()
{
java.lang.IllegalStateException v;
io.netty.channel.DefaultChannelConfig v;
int v;
io.netty.channel.RecvByteBufAllocator v;
java.lang.ClassCastException v;
v := @this: io.netty.channel.DefaultChannelConfig;
label:
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.RecvByteBufAllocator getRecvByteBufAllocator()>();
v = interfaceinvoke v.<io.netty.channel.MaxMessagesRecvByteBufAllocator: int maxMessagesPerRead()>();
label:
return v;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>("getRecvByteBufAllocator() must return an object of type MaxMessagesRecvByteBufAllocator", v);
throw v;
catch java.lang.ClassCastException from label to label with label;
}
public io.netty.channel.ChannelConfig setMaxMessagesPerRead(int)
{
java.lang.IllegalStateException v;
io.netty.channel.DefaultChannelConfig v;
int v;
io.netty.channel.RecvByteBufAllocator v;
java.lang.ClassCastException v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: int;
label:
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.RecvByteBufAllocator getRecvByteBufAllocator()>();
interfaceinvoke v.<io.netty.channel.MaxMessagesRecvByteBufAllocator: io.netty.channel.MaxMessagesRecvByteBufAllocator maxMessagesPerRead(int)>(v);
label:
return v;
label:
v := @caughtexception;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String,java.lang.Throwable)>("getRecvByteBufAllocator() must return an object of type MaxMessagesRecvByteBufAllocator", v);
throw v;
catch java.lang.ClassCastException from label to label with label;
}
public int getMaxMessagesPerWrite()
{
int v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v = v.<io.netty.channel.DefaultChannelConfig: int maxMessagesPerWrite>;
return v;
}
public io.netty.channel.ChannelConfig setMaxMessagesPerWrite(int)
{
int v, v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: int;
v = staticinvoke <io.netty.util.internal.ObjectUtil: int checkPositive(int,java.lang.String)>(v, "maxMessagesPerWrite");
v.<io.netty.channel.DefaultChannelConfig: int maxMessagesPerWrite> = v;
return v;
}
public int getWriteSpinCount()
{
int v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v = v.<io.netty.channel.DefaultChannelConfig: int writeSpinCount>;
return v;
}
public io.netty.channel.ChannelConfig setWriteSpinCount(int)
{
int v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: int;
staticinvoke <io.netty.util.internal.ObjectUtil: int checkPositive(int,java.lang.String)>(v, "writeSpinCount");
if v != 2147483647 goto label;
v = v - 1;
label:
v.<io.netty.channel.DefaultChannelConfig: int writeSpinCount> = v;
return v;
}
public io.netty.buffer.ByteBufAllocator getAllocator()
{
io.netty.buffer.ByteBufAllocator v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v = v.<io.netty.channel.DefaultChannelConfig: io.netty.buffer.ByteBufAllocator allocator>;
return v;
}
public io.netty.channel.ChannelConfig setAllocator(io.netty.buffer.ByteBufAllocator)
{
java.lang.Object v;
io.netty.buffer.ByteBufAllocator v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: io.netty.buffer.ByteBufAllocator;
v = staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "allocator");
v.<io.netty.channel.DefaultChannelConfig: io.netty.buffer.ByteBufAllocator allocator> = v;
return v;
}
public io.netty.channel.RecvByteBufAllocator getRecvByteBufAllocator()
{
io.netty.channel.RecvByteBufAllocator v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v = v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.RecvByteBufAllocator rcvBufAllocator>;
return v;
}
public io.netty.channel.ChannelConfig setRecvByteBufAllocator(io.netty.channel.RecvByteBufAllocator)
{
java.lang.Object v;
io.netty.channel.RecvByteBufAllocator v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: io.netty.channel.RecvByteBufAllocator;
v = staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "allocator");
v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.RecvByteBufAllocator rcvBufAllocator> = v;
return v;
}
private void setRecvByteBufAllocator(io.netty.channel.RecvByteBufAllocator, io.netty.channel.ChannelMetadata)
{
io.netty.channel.DefaultChannelConfig v;
int v;
io.netty.channel.ChannelMetadata v;
io.netty.channel.RecvByteBufAllocator v;
boolean v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: io.netty.channel.RecvByteBufAllocator;
v := @parameter: io.netty.channel.ChannelMetadata;
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "allocator");
staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "metadata");
v = v instanceof io.netty.channel.MaxMessagesRecvByteBufAllocator;
if v == 0 goto label;
v = virtualinvoke v.<io.netty.channel.ChannelMetadata: int defaultMaxMessagesPerRead()>();
interfaceinvoke v.<io.netty.channel.MaxMessagesRecvByteBufAllocator: io.netty.channel.MaxMessagesRecvByteBufAllocator maxMessagesPerRead(int)>(v);
label:
virtualinvoke v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.ChannelConfig setRecvByteBufAllocator(io.netty.channel.RecvByteBufAllocator)>(v);
return;
}
public boolean isAutoRead()
{
int v;
boolean v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v = v.<io.netty.channel.DefaultChannelConfig: int autoRead>;
if v != 1 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public io.netty.channel.ChannelConfig setAutoRead(boolean)
{
java.util.concurrent.atomic.AtomicIntegerFieldUpdater v;
io.netty.channel.DefaultChannelConfig v;
io.netty.channel.Channel v;
byte v;
int v;
boolean v, v, v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: boolean;
v = <io.netty.channel.DefaultChannelConfig: java.util.concurrent.atomic.AtomicIntegerFieldUpdater AUTOREAD_UPDATER>;
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicIntegerFieldUpdater: int getAndSet(java.lang.Object,int)>(v, v);
if v != 1 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v;
if v == 0 goto label;
if v != 0 goto label;
v = v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.Channel channel>;
interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.Channel read()>();
goto label;
label:
if v != 0 goto label;
if v == 0 goto label;
virtualinvoke v.<io.netty.channel.DefaultChannelConfig: void autoReadCleared()>();
label:
return v;
}
protected void autoReadCleared()
{
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
return;
}
public boolean isAutoClose()
{
boolean v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v = v.<io.netty.channel.DefaultChannelConfig: boolean autoClose>;
return v;
}
public io.netty.channel.ChannelConfig setAutoClose(boolean)
{
boolean v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: boolean;
v.<io.netty.channel.DefaultChannelConfig: boolean autoClose> = v;
return v;
}
public int getWriteBufferHighWaterMark()
{
int v;
io.netty.channel.WriteBufferWaterMark v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v = v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.WriteBufferWaterMark writeBufferWaterMark>;
v = virtualinvoke v.<io.netty.channel.WriteBufferWaterMark: int high()>();
return v;
}
public io.netty.channel.ChannelConfig setWriteBufferHighWaterMark(int)
{
io.netty.channel.WriteBufferWaterMark v, v;
java.util.concurrent.atomic.AtomicReferenceFieldUpdater v;
io.netty.channel.DefaultChannelConfig v;
java.lang.IllegalArgumentException v;
int v, v, v, v;
java.lang.String v;
boolean v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: int;
staticinvoke <io.netty.util.internal.ObjectUtil: int checkPositiveOrZero(int,java.lang.String)>(v, "writeBufferHighWaterMark");
label:
v = v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.WriteBufferWaterMark writeBufferWaterMark>;
v = virtualinvoke v.<io.netty.channel.WriteBufferWaterMark: int low()>();
if v >= v goto label;
v = new java.lang.IllegalArgumentException;
v = virtualinvoke v.<io.netty.channel.WriteBufferWaterMark: int low()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("writeBufferHighWaterMark cannot be less than writeBufferLowWaterMark (\u): \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = <io.netty.channel.DefaultChannelConfig: java.util.concurrent.atomic.AtomicReferenceFieldUpdater WATERMARK_UPDATER>;
v = new io.netty.channel.WriteBufferWaterMark;
v = virtualinvoke v.<io.netty.channel.WriteBufferWaterMark: int low()>();
specialinvoke v.<io.netty.channel.WriteBufferWaterMark: void <init>(int,int,boolean)>(v, v, 0);
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReferenceFieldUpdater: boolean compareAndSet(java.lang.Object,java.lang.Object,java.lang.Object)>(v, v, v);
if v == 0 goto label;
return v;
}
public int getWriteBufferLowWaterMark()
{
int v;
io.netty.channel.WriteBufferWaterMark v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v = v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.WriteBufferWaterMark writeBufferWaterMark>;
v = virtualinvoke v.<io.netty.channel.WriteBufferWaterMark: int low()>();
return v;
}
public io.netty.channel.ChannelConfig setWriteBufferLowWaterMark(int)
{
io.netty.channel.WriteBufferWaterMark v, v;
java.util.concurrent.atomic.AtomicReferenceFieldUpdater v;
io.netty.channel.DefaultChannelConfig v;
java.lang.IllegalArgumentException v;
int v, v, v, v;
java.lang.String v;
boolean v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: int;
staticinvoke <io.netty.util.internal.ObjectUtil: int checkPositiveOrZero(int,java.lang.String)>(v, "writeBufferLowWaterMark");
label:
v = v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.WriteBufferWaterMark writeBufferWaterMark>;
v = virtualinvoke v.<io.netty.channel.WriteBufferWaterMark: int high()>();
if v <= v goto label;
v = new java.lang.IllegalArgumentException;
v = virtualinvoke v.<io.netty.channel.WriteBufferWaterMark: int high()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("writeBufferLowWaterMark cannot be greater than writeBufferHighWaterMark (\u): \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = <io.netty.channel.DefaultChannelConfig: java.util.concurrent.atomic.AtomicReferenceFieldUpdater WATERMARK_UPDATER>;
v = new io.netty.channel.WriteBufferWaterMark;
v = virtualinvoke v.<io.netty.channel.WriteBufferWaterMark: int high()>();
specialinvoke v.<io.netty.channel.WriteBufferWaterMark: void <init>(int,int,boolean)>(v, v, 0);
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReferenceFieldUpdater: boolean compareAndSet(java.lang.Object,java.lang.Object,java.lang.Object)>(v, v, v);
if v == 0 goto label;
return v;
}
public io.netty.channel.ChannelConfig setWriteBufferWaterMark(io.netty.channel.WriteBufferWaterMark)
{
io.netty.channel.WriteBufferWaterMark v;
java.lang.Object v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: io.netty.channel.WriteBufferWaterMark;
v = staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "writeBufferWaterMark");
v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.WriteBufferWaterMark writeBufferWaterMark> = v;
return v;
}
public io.netty.channel.WriteBufferWaterMark getWriteBufferWaterMark()
{
io.netty.channel.WriteBufferWaterMark v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v = v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.WriteBufferWaterMark writeBufferWaterMark>;
return v;
}
public io.netty.channel.MessageSizeEstimator getMessageSizeEstimator()
{
io.netty.channel.MessageSizeEstimator v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v = v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.MessageSizeEstimator msgSizeEstimator>;
return v;
}
public io.netty.channel.ChannelConfig setMessageSizeEstimator(io.netty.channel.MessageSizeEstimator)
{
io.netty.channel.MessageSizeEstimator v;
java.lang.Object v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: io.netty.channel.MessageSizeEstimator;
v = staticinvoke <io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "estimator");
v.<io.netty.channel.DefaultChannelConfig: io.netty.channel.MessageSizeEstimator msgSizeEstimator> = v;
return v;
}
private io.netty.channel.ChannelConfig setPinEventExecutorPerGroup(boolean)
{
boolean v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v := @parameter: boolean;
v.<io.netty.channel.DefaultChannelConfig: boolean pinEventExecutor> = v;
return v;
}
private boolean getPinEventExecutorPerGroup()
{
boolean v;
io.netty.channel.DefaultChannelConfig v;
v := @this: io.netty.channel.DefaultChannelConfig;
v = v.<io.netty.channel.DefaultChannelConfig: boolean pinEventExecutor>;
return v;
}
static void <clinit>()
{
io.netty.channel.MessageSizeEstimator v;
java.util.concurrent.atomic.AtomicIntegerFieldUpdater v;
java.util.concurrent.atomic.AtomicReferenceFieldUpdater v;
v = <io.netty.channel.DefaultMessageSizeEstimator: io.netty.channel.MessageSizeEstimator DEFAULT>;
<io.netty.channel.DefaultChannelConfig: io.netty.channel.MessageSizeEstimator DEFAULT_MSG_SIZE_ESTIMATOR> = v;
v = staticinvoke <java.util.concurrent.atomic.AtomicIntegerFieldUpdater: java.util.concurrent.atomic.AtomicIntegerFieldUpdater newUpdater(java.lang.Class,java.lang.String)>(class "Lio/netty/channel/DefaultChannelConfig;", "autoRead");
<io.netty.channel.DefaultChannelConfig: java.util.concurrent.atomic.AtomicIntegerFieldUpdater AUTOREAD_UPDATER> = v;
v = staticinvoke <java.util.concurrent.atomic.AtomicReferenceFieldUpdater: java.util.concurrent.atomic.AtomicReferenceFieldUpdater newUpdater(java.lang.Class,java.lang.Class,java.lang.String)>(class "Lio/netty/channel/DefaultChannelConfig;", class "Lio/netty/channel/WriteBufferWaterMark;", "writeBufferWaterMark");
<io.netty.channel.DefaultChannelConfig: java.util.concurrent.atomic.AtomicReferenceFieldUpdater WATERMARK_UPDATER> = v;
return;
}
}