public final class oadd.io.netty.channel.CoalescingBufferQueue extends oadd.io.netty.channel.AbstractCoalescingBufferQueue
{
private final oadd.io.netty.channel.Channel channel;
public void <init>(oadd.io.netty.channel.Channel)
{
oadd.io.netty.channel.Channel v;
oadd.io.netty.channel.CoalescingBufferQueue v;
v := @this: oadd.io.netty.channel.CoalescingBufferQueue;
v := @parameter: oadd.io.netty.channel.Channel;
specialinvoke v.<oadd.io.netty.channel.CoalescingBufferQueue: void <init>(oadd.io.netty.channel.Channel,int)>(v, 4);
return;
}
public void <init>(oadd.io.netty.channel.Channel, int)
{
int v;
oadd.io.netty.channel.Channel v;
oadd.io.netty.channel.CoalescingBufferQueue v;
v := @this: oadd.io.netty.channel.CoalescingBufferQueue;
v := @parameter: oadd.io.netty.channel.Channel;
v := @parameter: int;
specialinvoke v.<oadd.io.netty.channel.CoalescingBufferQueue: void <init>(oadd.io.netty.channel.Channel,int,boolean)>(v, v, 0);
return;
}
public void <init>(oadd.io.netty.channel.Channel, int, boolean)
{
oadd.io.netty.channel.CoalescingBufferQueue v;
int v;
oadd.io.netty.channel.Channel v, v;
java.lang.Object v;
boolean v;
v := @this: oadd.io.netty.channel.CoalescingBufferQueue;
v := @parameter: oadd.io.netty.channel.Channel;
v := @parameter: int;
v := @parameter: boolean;
if v == 0 goto label;
v = v;
goto label;
label:
v = null;
label:
specialinvoke v.<oadd.io.netty.channel.AbstractCoalescingBufferQueue: void <init>(oadd.io.netty.channel.Channel,int)>(v, v);
v = staticinvoke <oadd.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "channel");
v.<oadd.io.netty.channel.CoalescingBufferQueue: oadd.io.netty.channel.Channel channel> = v;
return;
}
public oadd.io.netty.buffer.ByteBuf remove(int, oadd.io.netty.channel.ChannelPromise)
{
oadd.io.netty.channel.CoalescingBufferQueue v;
int v;
oadd.io.netty.channel.Channel v;
oadd.io.netty.buffer.ByteBufAllocator v;
oadd.io.netty.buffer.ByteBuf v;
oadd.io.netty.channel.ChannelPromise v;
v := @this: oadd.io.netty.channel.CoalescingBufferQueue;
v := @parameter: int;
v := @parameter: oadd.io.netty.channel.ChannelPromise;
v = v.<oadd.io.netty.channel.CoalescingBufferQueue: oadd.io.netty.channel.Channel channel>;
v = interfaceinvoke v.<oadd.io.netty.channel.Channel: oadd.io.netty.buffer.ByteBufAllocator alloc()>();
v = virtualinvoke v.<oadd.io.netty.channel.CoalescingBufferQueue: oadd.io.netty.buffer.ByteBuf remove(oadd.io.netty.buffer.ByteBufAllocator,int,oadd.io.netty.channel.ChannelPromise)>(v, v, v);
return v;
}
public void releaseAndFailAll(java.lang.Throwable)
{
java.lang.Throwable v;
oadd.io.netty.channel.Channel v;
oadd.io.netty.channel.CoalescingBufferQueue v;
v := @this: oadd.io.netty.channel.CoalescingBufferQueue;
v := @parameter: java.lang.Throwable;
v = v.<oadd.io.netty.channel.CoalescingBufferQueue: oadd.io.netty.channel.Channel channel>;
virtualinvoke v.<oadd.io.netty.channel.CoalescingBufferQueue: void releaseAndFailAll(oadd.io.netty.channel.ChannelOutboundInvoker,java.lang.Throwable)>(v, v);
return;
}
protected oadd.io.netty.buffer.ByteBuf compose(oadd.io.netty.buffer.ByteBufAllocator, oadd.io.netty.buffer.ByteBuf, oadd.io.netty.buffer.ByteBuf)
{
oadd.io.netty.channel.CoalescingBufferQueue v;
oadd.io.netty.buffer.ByteBufAllocator v;
oadd.io.netty.buffer.ByteBuf v, v, v;
boolean v;
v := @this: oadd.io.netty.channel.CoalescingBufferQueue;
v := @parameter: oadd.io.netty.buffer.ByteBufAllocator;
v := @parameter: oadd.io.netty.buffer.ByteBuf;
v := @parameter: oadd.io.netty.buffer.ByteBuf;
v = v instanceof oadd.io.netty.buffer.CompositeByteBuf;
if v == 0 goto label;
virtualinvoke v.<oadd.io.netty.buffer.CompositeByteBuf: oadd.io.netty.buffer.CompositeByteBuf addComponent(boolean,oadd.io.netty.buffer.ByteBuf)>(1, v);
return v;
label:
v = virtualinvoke v.<oadd.io.netty.channel.CoalescingBufferQueue: oadd.io.netty.buffer.ByteBuf composeIntoComposite(oadd.io.netty.buffer.ByteBufAllocator,oadd.io.netty.buffer.ByteBuf,oadd.io.netty.buffer.ByteBuf)>(v, v, v);
return v;
}
protected oadd.io.netty.buffer.ByteBuf removeEmptyValue()
{
oadd.io.netty.channel.CoalescingBufferQueue v;
oadd.io.netty.buffer.ByteBuf v;
v := @this: oadd.io.netty.channel.CoalescingBufferQueue;
v = <oadd.io.netty.buffer.Unpooled: oadd.io.netty.buffer.ByteBuf EMPTY_BUFFER>;
return v;
}
}