public abstract class io.netty.channel.AbstractChannel extends io.netty.util.DefaultAttributeMap implements io.netty.channel.Channel
{
private static final io.netty.util.internal.logging.InternalLogger logger;
private final io.netty.channel.Channel parent;
private final io.netty.channel.ChannelId id;
private final io.netty.channel.Channel$Unsafe unsafe;
private final io.netty.channel.DefaultChannelPipeline pipeline;
private final io.netty.channel.VoidChannelPromise unsafeVoidPromise;
private final io.netty.channel.AbstractChannel$CloseFuture closeFuture;
private volatile java.net.SocketAddress localAddress;
private volatile java.net.SocketAddress remoteAddress;
private volatile io.netty.channel.EventLoop eventLoop;
private volatile boolean registered;
private boolean closeInitiated;
private java.lang.Throwable initialCloseCause;
private boolean strValActive;
private java.lang.String strVal;
protected void <init>(io.netty.channel.Channel)
{
io.netty.channel.AbstractChannel$CloseFuture v;
io.netty.channel.Channel v;
io.netty.channel.VoidChannelPromise v;
io.netty.channel.ChannelId v;
io.netty.channel.AbstractChannel$AbstractUnsafe v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: io.netty.channel.Channel;
specialinvoke v.<io.netty.util.DefaultAttributeMap: void <init>()>();
v = new io.netty.channel.VoidChannelPromise;
specialinvoke v.<io.netty.channel.VoidChannelPromise: void <init>(io.netty.channel.Channel,boolean)>(v, 0);
v.<io.netty.channel.AbstractChannel: io.netty.channel.VoidChannelPromise unsafeVoidPromise> = v;
v = new io.netty.channel.AbstractChannel$CloseFuture;
specialinvoke v.<io.netty.channel.AbstractChannel$CloseFuture: void <init>(io.netty.channel.AbstractChannel)>(v);
v.<io.netty.channel.AbstractChannel: io.netty.channel.AbstractChannel$CloseFuture closeFuture> = v;
v.<io.netty.channel.AbstractChannel: io.netty.channel.Channel parent> = v;
v = virtualinvoke v.<io.netty.channel.AbstractChannel: io.netty.channel.ChannelId newId()>();
v.<io.netty.channel.AbstractChannel: io.netty.channel.ChannelId id> = v;
v = virtualinvoke v.<io.netty.channel.AbstractChannel: io.netty.channel.AbstractChannel$AbstractUnsafe newUnsafe()>();
v.<io.netty.channel.AbstractChannel: io.netty.channel.Channel$Unsafe unsafe> = v;
v = virtualinvoke v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline newChannelPipeline()>();
v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline> = v;
return;
}
protected void <init>(io.netty.channel.Channel, io.netty.channel.ChannelId)
{
io.netty.channel.AbstractChannel$CloseFuture v;
io.netty.channel.Channel v;
io.netty.channel.VoidChannelPromise v;
io.netty.channel.ChannelId v;
io.netty.channel.AbstractChannel$AbstractUnsafe v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: io.netty.channel.Channel;
v := @parameter: io.netty.channel.ChannelId;
specialinvoke v.<io.netty.util.DefaultAttributeMap: void <init>()>();
v = new io.netty.channel.VoidChannelPromise;
specialinvoke v.<io.netty.channel.VoidChannelPromise: void <init>(io.netty.channel.Channel,boolean)>(v, 0);
v.<io.netty.channel.AbstractChannel: io.netty.channel.VoidChannelPromise unsafeVoidPromise> = v;
v = new io.netty.channel.AbstractChannel$CloseFuture;
specialinvoke v.<io.netty.channel.AbstractChannel$CloseFuture: void <init>(io.netty.channel.AbstractChannel)>(v);
v.<io.netty.channel.AbstractChannel: io.netty.channel.AbstractChannel$CloseFuture closeFuture> = v;
v.<io.netty.channel.AbstractChannel: io.netty.channel.Channel parent> = v;
v.<io.netty.channel.AbstractChannel: io.netty.channel.ChannelId id> = v;
v = virtualinvoke v.<io.netty.channel.AbstractChannel: io.netty.channel.AbstractChannel$AbstractUnsafe newUnsafe()>();
v.<io.netty.channel.AbstractChannel: io.netty.channel.Channel$Unsafe unsafe> = v;
v = virtualinvoke v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline newChannelPipeline()>();
v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline> = v;
return;
}
protected final int maxMessagesPerWrite()
{
io.netty.channel.ChannelConfig v;
io.netty.channel.ChannelOption v;
int v, v;
java.lang.Object v;
io.netty.channel.AbstractChannel v;
boolean v;
v := @this: io.netty.channel.AbstractChannel;
v = virtualinvoke v.<io.netty.channel.AbstractChannel: io.netty.channel.ChannelConfig config()>();
v = v instanceof io.netty.channel.DefaultChannelConfig;
if v == 0 goto label;
v = virtualinvoke v.<io.netty.channel.DefaultChannelConfig: int getMaxMessagesPerWrite()>();
return v;
label:
v = <io.netty.channel.ChannelOption: io.netty.channel.ChannelOption MAX_MESSAGES_PER_WRITE>;
v = interfaceinvoke v.<io.netty.channel.ChannelConfig: java.lang.Object getOption(io.netty.channel.ChannelOption)>(v);
if v != null goto label;
return 2147483647;
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
return v;
}
public final io.netty.channel.ChannelId id()
{
io.netty.channel.ChannelId v;
io.netty.channel.AbstractChannel v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.ChannelId id>;
return v;
}
protected io.netty.channel.ChannelId newId()
{
io.netty.channel.DefaultChannelId v;
io.netty.channel.AbstractChannel v;
v := @this: io.netty.channel.AbstractChannel;
v = staticinvoke <io.netty.channel.DefaultChannelId: io.netty.channel.DefaultChannelId newInstance()>();
return v;
}
protected io.netty.channel.DefaultChannelPipeline newChannelPipeline()
{
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
v := @this: io.netty.channel.AbstractChannel;
v = new io.netty.channel.DefaultChannelPipeline;
specialinvoke v.<io.netty.channel.DefaultChannelPipeline: void <init>(io.netty.channel.Channel)>(v);
return v;
}
public boolean isWritable()
{
io.netty.channel.ChannelOutboundBuffer v;
io.netty.channel.AbstractChannel v;
io.netty.channel.Channel$Unsafe v;
boolean v, v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.Channel$Unsafe unsafe>;
v = interfaceinvoke v.<io.netty.channel.Channel$Unsafe: io.netty.channel.ChannelOutboundBuffer outboundBuffer()>();
if v == null goto label;
v = virtualinvoke v.<io.netty.channel.ChannelOutboundBuffer: boolean isWritable()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public long bytesBeforeUnwritable()
{
io.netty.channel.ChannelOutboundBuffer v;
long v;
io.netty.channel.AbstractChannel v;
io.netty.channel.Channel$Unsafe v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.Channel$Unsafe unsafe>;
v = interfaceinvoke v.<io.netty.channel.Channel$Unsafe: io.netty.channel.ChannelOutboundBuffer outboundBuffer()>();
if v == null goto label;
v = virtualinvoke v.<io.netty.channel.ChannelOutboundBuffer: long bytesBeforeUnwritable()>();
goto label;
label:
v = 0L;
label:
return v;
}
public long bytesBeforeWritable()
{
io.netty.channel.ChannelOutboundBuffer v;
long v;
io.netty.channel.AbstractChannel v;
io.netty.channel.Channel$Unsafe v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.Channel$Unsafe unsafe>;
v = interfaceinvoke v.<io.netty.channel.Channel$Unsafe: io.netty.channel.ChannelOutboundBuffer outboundBuffer()>();
if v == null goto label;
v = virtualinvoke v.<io.netty.channel.ChannelOutboundBuffer: long bytesBeforeWritable()>();
goto label;
label:
v = 9223372036854775807L;
label:
return v;
}
public io.netty.channel.Channel parent()
{
io.netty.channel.Channel v;
io.netty.channel.AbstractChannel v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.Channel parent>;
return v;
}
public io.netty.channel.ChannelPipeline pipeline()
{
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
return v;
}
public io.netty.buffer.ByteBufAllocator alloc()
{
io.netty.channel.AbstractChannel v;
io.netty.channel.ChannelConfig v;
io.netty.buffer.ByteBufAllocator v;
v := @this: io.netty.channel.AbstractChannel;
v = virtualinvoke v.<io.netty.channel.AbstractChannel: io.netty.channel.ChannelConfig config()>();
v = interfaceinvoke v.<io.netty.channel.ChannelConfig: io.netty.buffer.ByteBufAllocator getAllocator()>();
return v;
}
public io.netty.channel.EventLoop eventLoop()
{
java.lang.IllegalStateException v;
io.netty.channel.AbstractChannel v;
io.netty.channel.EventLoop v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.EventLoop eventLoop>;
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("channel not registered to an event loop");
throw v;
label:
return v;
}
public java.net.SocketAddress localAddress()
{
java.lang.Throwable v;
java.net.SocketAddress v, v;
java.lang.Error v;
io.netty.channel.AbstractChannel v;
io.netty.channel.Channel$Unsafe v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: java.net.SocketAddress localAddress>;
if v != null goto label;
label:
v = virtualinvoke v.<io.netty.channel.AbstractChannel: io.netty.channel.Channel$Unsafe unsafe()>();
v = interfaceinvoke v.<io.netty.channel.Channel$Unsafe: java.net.SocketAddress localAddress()>();
v = v;
v.<io.netty.channel.AbstractChannel: java.net.SocketAddress localAddress> = v;
label:
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
return null;
label:
return v;
catch java.lang.Error from label to label with label;
catch java.lang.Throwable from label to label with label;
}
protected void invalidateLocalAddress()
{
io.netty.channel.AbstractChannel v;
v := @this: io.netty.channel.AbstractChannel;
v.<io.netty.channel.AbstractChannel: java.net.SocketAddress localAddress> = null;
return;
}
public java.net.SocketAddress remoteAddress()
{
java.lang.Throwable v;
java.net.SocketAddress v, v;
java.lang.Error v;
io.netty.channel.AbstractChannel v;
io.netty.channel.Channel$Unsafe v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: java.net.SocketAddress remoteAddress>;
if v != null goto label;
label:
v = virtualinvoke v.<io.netty.channel.AbstractChannel: io.netty.channel.Channel$Unsafe unsafe()>();
v = interfaceinvoke v.<io.netty.channel.Channel$Unsafe: java.net.SocketAddress remoteAddress()>();
v = v;
v.<io.netty.channel.AbstractChannel: java.net.SocketAddress remoteAddress> = v;
label:
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
return null;
label:
return v;
catch java.lang.Error from label to label with label;
catch java.lang.Throwable from label to label with label;
}
protected void invalidateRemoteAddress()
{
io.netty.channel.AbstractChannel v;
v := @this: io.netty.channel.AbstractChannel;
v.<io.netty.channel.AbstractChannel: java.net.SocketAddress remoteAddress> = null;
return;
}
public boolean isRegistered()
{
io.netty.channel.AbstractChannel v;
boolean v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: boolean registered>;
return v;
}
public io.netty.channel.ChannelFuture bind(java.net.SocketAddress)
{
java.net.SocketAddress v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: java.net.SocketAddress;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture bind(java.net.SocketAddress)>(v);
return v;
}
public io.netty.channel.ChannelFuture connect(java.net.SocketAddress)
{
java.net.SocketAddress v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: java.net.SocketAddress;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture connect(java.net.SocketAddress)>(v);
return v;
}
public io.netty.channel.ChannelFuture connect(java.net.SocketAddress, java.net.SocketAddress)
{
java.net.SocketAddress v, v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: java.net.SocketAddress;
v := @parameter: java.net.SocketAddress;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture connect(java.net.SocketAddress,java.net.SocketAddress)>(v, v);
return v;
}
public io.netty.channel.ChannelFuture disconnect()
{
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture disconnect()>();
return v;
}
public io.netty.channel.ChannelFuture close()
{
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture close()>();
return v;
}
public io.netty.channel.ChannelFuture deregister()
{
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture deregister()>();
return v;
}
public io.netty.channel.Channel flush()
{
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelPipeline flush()>();
return v;
}
public io.netty.channel.ChannelFuture bind(java.net.SocketAddress, io.netty.channel.ChannelPromise)
{
io.netty.channel.ChannelPromise v;
java.net.SocketAddress v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: java.net.SocketAddress;
v := @parameter: io.netty.channel.ChannelPromise;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture bind(java.net.SocketAddress,io.netty.channel.ChannelPromise)>(v, v);
return v;
}
public io.netty.channel.ChannelFuture connect(java.net.SocketAddress, io.netty.channel.ChannelPromise)
{
io.netty.channel.ChannelPromise v;
java.net.SocketAddress v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: java.net.SocketAddress;
v := @parameter: io.netty.channel.ChannelPromise;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture connect(java.net.SocketAddress,io.netty.channel.ChannelPromise)>(v, v);
return v;
}
public io.netty.channel.ChannelFuture connect(java.net.SocketAddress, java.net.SocketAddress, io.netty.channel.ChannelPromise)
{
io.netty.channel.ChannelPromise v;
java.net.SocketAddress v, v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: java.net.SocketAddress;
v := @parameter: java.net.SocketAddress;
v := @parameter: io.netty.channel.ChannelPromise;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture connect(java.net.SocketAddress,java.net.SocketAddress,io.netty.channel.ChannelPromise)>(v, v, v);
return v;
}
public io.netty.channel.ChannelFuture disconnect(io.netty.channel.ChannelPromise)
{
io.netty.channel.ChannelPromise v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: io.netty.channel.ChannelPromise;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture disconnect(io.netty.channel.ChannelPromise)>(v);
return v;
}
public io.netty.channel.ChannelFuture close(io.netty.channel.ChannelPromise)
{
io.netty.channel.ChannelPromise v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: io.netty.channel.ChannelPromise;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture close(io.netty.channel.ChannelPromise)>(v);
return v;
}
public io.netty.channel.ChannelFuture deregister(io.netty.channel.ChannelPromise)
{
io.netty.channel.ChannelPromise v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: io.netty.channel.ChannelPromise;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture deregister(io.netty.channel.ChannelPromise)>(v);
return v;
}
public io.netty.channel.Channel read()
{
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelPipeline read()>();
return v;
}
public io.netty.channel.ChannelFuture write(java.lang.Object)
{
java.lang.Object v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: java.lang.Object;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture write(java.lang.Object)>(v);
return v;
}
public io.netty.channel.ChannelFuture write(java.lang.Object, io.netty.channel.ChannelPromise)
{
io.netty.channel.ChannelPromise v;
java.lang.Object v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: java.lang.Object;
v := @parameter: io.netty.channel.ChannelPromise;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture write(java.lang.Object,io.netty.channel.ChannelPromise)>(v, v);
return v;
}
public io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)
{
java.lang.Object v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: java.lang.Object;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object)>(v);
return v;
}
public io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object, io.netty.channel.ChannelPromise)
{
io.netty.channel.ChannelPromise v;
java.lang.Object v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: java.lang.Object;
v := @parameter: io.netty.channel.ChannelPromise;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture writeAndFlush(java.lang.Object,io.netty.channel.ChannelPromise)>(v, v);
return v;
}
public io.netty.channel.ChannelPromise newPromise()
{
io.netty.channel.AbstractChannel v;
io.netty.channel.ChannelPromise v;
io.netty.channel.DefaultChannelPipeline v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelPromise newPromise()>();
return v;
}
public io.netty.channel.ChannelProgressivePromise newProgressivePromise()
{
io.netty.channel.ChannelProgressivePromise v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelProgressivePromise newProgressivePromise()>();
return v;
}
public io.netty.channel.ChannelFuture newSucceededFuture()
{
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture newSucceededFuture()>();
return v;
}
public io.netty.channel.ChannelFuture newFailedFuture(java.lang.Throwable)
{
java.lang.Throwable v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultChannelPipeline v;
io.netty.channel.ChannelFuture v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: java.lang.Throwable;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelFuture newFailedFuture(java.lang.Throwable)>(v);
return v;
}
public io.netty.channel.ChannelFuture closeFuture()
{
io.netty.channel.AbstractChannel$CloseFuture v;
io.netty.channel.AbstractChannel v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.AbstractChannel$CloseFuture closeFuture>;
return v;
}
public io.netty.channel.Channel$Unsafe unsafe()
{
io.netty.channel.AbstractChannel v;
io.netty.channel.Channel$Unsafe v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.Channel$Unsafe unsafe>;
return v;
}
protected abstract io.netty.channel.AbstractChannel$AbstractUnsafe newUnsafe();
public final int hashCode()
{
int v;
io.netty.channel.ChannelId v;
io.netty.channel.AbstractChannel v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.ChannelId id>;
v = virtualinvoke v.<java.lang.Object: int hashCode()>();
return v;
}
public final boolean equals(java.lang.Object)
{
java.lang.Object v;
io.netty.channel.AbstractChannel v;
boolean v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: java.lang.Object;
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public final int compareTo(io.netty.channel.Channel)
{
io.netty.channel.Channel v;
int v;
io.netty.channel.ChannelId v, v;
io.netty.channel.AbstractChannel v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: io.netty.channel.Channel;
if v != v goto label;
return 0;
label:
v = virtualinvoke v.<io.netty.channel.AbstractChannel: io.netty.channel.ChannelId id()>();
v = interfaceinvoke v.<io.netty.channel.Channel: io.netty.channel.ChannelId id()>();
v = interfaceinvoke v.<io.netty.channel.ChannelId: int compareTo(java.lang.Object)>(v);
return v;
}
public java.lang.String toString()
{
java.net.SocketAddress v, v;
io.netty.channel.ChannelId v, v, v;
io.netty.channel.AbstractChannel v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
boolean v, v;
java.lang.StringBuilder v, v, v;
v := @this: io.netty.channel.AbstractChannel;
v = virtualinvoke v.<io.netty.channel.AbstractChannel: boolean isActive()>();
v = v.<io.netty.channel.AbstractChannel: boolean strValActive>;
if v != v goto label;
v = v.<io.netty.channel.AbstractChannel: java.lang.String strVal>;
if v == null goto label;
v = v.<io.netty.channel.AbstractChannel: java.lang.String strVal>;
return v;
label:
v = virtualinvoke v.<io.netty.channel.AbstractChannel: java.net.SocketAddress remoteAddress()>();
v = virtualinvoke v.<io.netty.channel.AbstractChannel: java.net.SocketAddress localAddress()>();
if v == null goto label;
specialinvoke v.<java.lang.StringBuilder: void <init>(int)>(96);
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.ChannelId id>;
v = interfaceinvoke v.<io.netty.channel.ChannelId: java.lang.String asShortText()>();
if v == 0 goto label;
v = " - ";
goto label;
label:
v = " ! ";
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.net.SocketAddress,java.lang.String,java.net.SocketAddress)>(v, v, 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[])>("[id: 0x\u, L:\u0001\u0001R:\u]");
v.<io.netty.channel.AbstractChannel: java.lang.String strVal> = v;
goto label;
label:
if v == null goto label;
specialinvoke v.<java.lang.StringBuilder: void <init>(int)>(64);
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.ChannelId id>;
v = interfaceinvoke v.<io.netty.channel.ChannelId: java.lang.String asShortText()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.net.SocketAddress)>(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[])>("[id: 0x\u, L:\u]");
v.<io.netty.channel.AbstractChannel: java.lang.String strVal> = v;
goto label;
label:
specialinvoke v.<java.lang.StringBuilder: void <init>(int)>(16);
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.ChannelId id>;
v = interfaceinvoke v.<io.netty.channel.ChannelId: java.lang.String asShortText()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("[id: 0x\u]");
v.<io.netty.channel.AbstractChannel: java.lang.String strVal> = v;
label:
v.<io.netty.channel.AbstractChannel: boolean strValActive> = v;
v = v.<io.netty.channel.AbstractChannel: java.lang.String strVal>;
return v;
}
public final io.netty.channel.ChannelPromise voidPromise()
{
io.netty.channel.AbstractChannel v;
io.netty.channel.ChannelPromise v;
io.netty.channel.DefaultChannelPipeline v;
v := @this: io.netty.channel.AbstractChannel;
v = v.<io.netty.channel.AbstractChannel: io.netty.channel.DefaultChannelPipeline pipeline>;
v = virtualinvoke v.<io.netty.channel.DefaultChannelPipeline: io.netty.channel.ChannelPromise voidPromise()>();
return v;
}
protected abstract boolean isCompatible(io.netty.channel.EventLoop);
protected abstract java.net.SocketAddress localAddress0();
protected abstract java.net.SocketAddress remoteAddress0();
protected void doRegister() throws java.lang.Exception
{
io.netty.channel.AbstractChannel v;
v := @this: io.netty.channel.AbstractChannel;
return;
}
protected abstract void doBind(java.net.SocketAddress) throws java.lang.Exception;
protected abstract void doDisconnect() throws java.lang.Exception;
protected abstract void doClose() throws java.lang.Exception;
protected void doShutdownOutput() throws java.lang.Exception
{
io.netty.channel.AbstractChannel v;
v := @this: io.netty.channel.AbstractChannel;
virtualinvoke v.<io.netty.channel.AbstractChannel: void doClose()>();
return;
}
protected void doDeregister() throws java.lang.Exception
{
io.netty.channel.AbstractChannel v;
v := @this: io.netty.channel.AbstractChannel;
return;
}
protected abstract void doBeginRead() throws java.lang.Exception;
protected abstract void doWrite(io.netty.channel.ChannelOutboundBuffer) throws java.lang.Exception;
protected java.lang.Object filterOutboundMessage(java.lang.Object) throws java.lang.Exception
{
java.lang.Object v;
io.netty.channel.AbstractChannel v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: java.lang.Object;
return v;
}
protected void validateFileRegion(io.netty.channel.DefaultFileRegion, long) throws java.io.IOException
{
long v;
io.netty.channel.AbstractChannel v;
io.netty.channel.DefaultFileRegion v;
v := @this: io.netty.channel.AbstractChannel;
v := @parameter: io.netty.channel.DefaultFileRegion;
v := @parameter: long;
staticinvoke <io.netty.channel.DefaultFileRegion: void validate(io.netty.channel.DefaultFileRegion,long)>(v, v);
return;
}
static void <clinit>()
{
io.netty.util.internal.logging.InternalLogger v;
v = staticinvoke <io.netty.util.internal.logging.InternalLoggerFactory: io.netty.util.internal.logging.InternalLogger getInstance(java.lang.Class)>(class "Lio/netty/channel/AbstractChannel;");
<io.netty.channel.AbstractChannel: io.netty.util.internal.logging.InternalLogger logger> = v;
return;
}
}