public abstract class org.xnio.XnioIoThread extends java.lang.Thread implements org.xnio.XnioExecutor, org.xnio.XnioIoFactory
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: org.xnio.XnioIoThread
super_class: java.lang.Thread
{
private final org.xnio.XnioWorker worker;
descriptor: Lorg/xnio/XnioWorker;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final int number;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
protected void <init>(org.xnio.XnioWorker, int);
descriptor: (Lorg/xnio/XnioWorker;I)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Thread.<init>:()V
1: aload 0
iload 2
putfield org.xnio.XnioIoThread.number:I
2: aload 0
aload 1
putfield org.xnio.XnioIoThread.worker:Lorg/xnio/XnioWorker;
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/xnio/XnioIoThread;
0 4 1 worker Lorg/xnio/XnioWorker;
0 4 2 number I
MethodParameters:
Name Flags
worker final
number final
protected void <init>(org.xnio.XnioWorker, int, java.lang.String);
descriptor: (Lorg/xnio/XnioWorker;ILjava/lang/String;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 3
invokespecial java.lang.Thread.<init>:(Ljava/lang/String;)V
1: aload 0
iload 2
putfield org.xnio.XnioIoThread.number:I
2: aload 0
aload 1
putfield org.xnio.XnioIoThread.worker:Lorg/xnio/XnioWorker;
3: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/xnio/XnioIoThread;
0 4 1 worker Lorg/xnio/XnioWorker;
0 4 2 number I
0 4 3 name Ljava/lang/String;
MethodParameters:
Name Flags
worker final
number final
name final
protected void <init>(org.xnio.XnioWorker, int, java.lang.ThreadGroup, java.lang.String);
descriptor: (Lorg/xnio/XnioWorker;ILjava/lang/ThreadGroup;Ljava/lang/String;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 3
aload 4
invokespecial java.lang.Thread.<init>:(Ljava/lang/ThreadGroup;Ljava/lang/String;)V
1: aload 0
iload 2
putfield org.xnio.XnioIoThread.number:I
2: aload 0
aload 1
putfield org.xnio.XnioIoThread.worker:Lorg/xnio/XnioWorker;
3: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/xnio/XnioIoThread;
0 4 1 worker Lorg/xnio/XnioWorker;
0 4 2 number I
0 4 3 group Ljava/lang/ThreadGroup;
0 4 4 name Ljava/lang/String;
MethodParameters:
Name Flags
worker final
number final
group final
name final
protected void <init>(org.xnio.XnioWorker, int, java.lang.ThreadGroup, java.lang.String, long);
descriptor: (Lorg/xnio/XnioWorker;ILjava/lang/ThreadGroup;Ljava/lang/String;J)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=6, locals=7, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
aload 3
aconst_null
aload 4
lload 5
invokespecial java.lang.Thread.<init>:(Ljava/lang/ThreadGroup;Ljava/lang/Runnable;Ljava/lang/String;J)V
1: aload 0
iload 2
putfield org.xnio.XnioIoThread.number:I
2: aload 0
aload 1
putfield org.xnio.XnioIoThread.worker:Lorg/xnio/XnioWorker;
3: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/xnio/XnioIoThread;
0 4 1 worker Lorg/xnio/XnioWorker;
0 4 2 number I
0 4 3 group Ljava/lang/ThreadGroup;
0 4 4 name Ljava/lang/String;
0 4 5 stackSize J
MethodParameters:
Name Flags
worker final
number final
group final
name final
stackSize final
public static org.xnio.XnioIoThread currentThread();
descriptor: ()Lorg/xnio/XnioIoThread;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=1, args_size=0
0: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
astore 0
start local 0 1: aload 0
instanceof org.xnio.XnioIoThread
ifeq 3
2: aload 0
checkcast org.xnio.XnioIoThread
areturn
3: StackMap locals: java.lang.Thread
StackMap stack:
aconst_null
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 4 0 thread Ljava/lang/Thread;
public static org.xnio.XnioIoThread requireCurrentThread();
descriptor: ()Lorg/xnio/XnioIoThread;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=1, args_size=0
0: invokestatic org.xnio.XnioIoThread.currentThread:()Lorg/xnio/XnioIoThread;
astore 0
start local 0 1: aload 0
ifnonnull 3
2: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
invokeinterface org.xnio._private.Messages.xnioThreadRequired:()Ljava/lang/IllegalStateException;
athrow
3: StackMap locals: org.xnio.XnioIoThread
StackMap stack:
aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 4 0 thread Lorg/xnio/XnioIoThread;
Exceptions:
throws java.lang.IllegalStateException
public int getNumber();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.xnio.XnioIoThread.number:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioIoThread;
public org.xnio.XnioWorker getWorker();
descriptor: ()Lorg/xnio/XnioWorker;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.xnio.XnioIoThread.worker:Lorg/xnio/XnioWorker;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioIoThread;
public org.xnio.IoFuture<org.xnio.StreamConnection> acceptStreamConnection(java.net.SocketAddress, org.xnio.ChannelListener<? super org.xnio.StreamConnection>, org.xnio.ChannelListener<? super org.xnio.channels.BoundChannel>, org.xnio.OptionMap);
descriptor: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
ifnonnull 2
1: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
ldc "destination"
invokeinterface org.xnio._private.Messages.nullParameter:(Ljava/lang/String;)Ljava/lang/IllegalArgumentException;
athrow
2: StackMap locals:
StackMap stack:
aload 1
instanceof java.net.InetSocketAddress
ifeq 4
3: aload 0
aload 1
checkcast java.net.InetSocketAddress
aload 2
aload 3
aload 4
invokevirtual org.xnio.XnioIoThread.acceptTcpStreamConnection:(Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
4: StackMap locals:
StackMap stack:
aload 1
instanceof org.xnio.LocalSocketAddress
ifeq 6
5: aload 0
aload 1
checkcast org.xnio.LocalSocketAddress
aload 2
aload 3
aload 4
invokevirtual org.xnio.XnioIoThread.acceptLocalStreamConnection:(Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
6: StackMap locals:
StackMap stack:
getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokeinterface org.xnio._private.Messages.badSockType:(Ljava/lang/Class;)Ljava/lang/IllegalArgumentException;
athrow
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/xnio/XnioIoThread;
0 7 1 destination Ljava/net/SocketAddress;
0 7 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;
0 7 3 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 7 4 optionMap Lorg/xnio/OptionMap;
Signature: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/StreamConnection;>;
MethodParameters:
Name Flags
destination
openListener
bindListener
optionMap
protected org.xnio.IoFuture<org.xnio.StreamConnection> acceptLocalStreamConnection(org.xnio.LocalSocketAddress, org.xnio.ChannelListener<? super org.xnio.StreamConnection>, org.xnio.ChannelListener<? super org.xnio.channels.BoundChannel>, org.xnio.OptionMap);
descriptor: (Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
ldc "acceptLocalStreamConnection"
invokeinterface org.xnio._private.Messages.unsupported:(Ljava/lang/String;)Ljava/lang/UnsupportedOperationException;
athrow
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioIoThread;
0 1 1 destination Lorg/xnio/LocalSocketAddress;
0 1 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;
0 1 3 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 1 4 optionMap Lorg/xnio/OptionMap;
Signature: (Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/StreamConnection;>;
MethodParameters:
Name Flags
destination
openListener
bindListener
optionMap
protected org.xnio.IoFuture<org.xnio.StreamConnection> acceptTcpStreamConnection(java.net.InetSocketAddress, org.xnio.ChannelListener<? super org.xnio.StreamConnection>, org.xnio.ChannelListener<? super org.xnio.channels.BoundChannel>, org.xnio.OptionMap);
descriptor: (Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
ldc "acceptTcpStreamConnection"
invokeinterface org.xnio._private.Messages.unsupported:(Ljava/lang/String;)Ljava/lang/UnsupportedOperationException;
athrow
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioIoThread;
0 1 1 destination Ljava/net/InetSocketAddress;
0 1 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;
0 1 3 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 1 4 optionMap Lorg/xnio/OptionMap;
Signature: (Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/StreamConnection;>;
MethodParameters:
Name Flags
destination
openListener
bindListener
optionMap
public org.xnio.IoFuture<org.xnio.MessageConnection> openMessageConnection(java.net.SocketAddress, org.xnio.ChannelListener<? super org.xnio.MessageConnection>, org.xnio.OptionMap);
descriptor: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ifnonnull 2
1: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
ldc "destination"
invokeinterface org.xnio._private.Messages.nullParameter:(Ljava/lang/String;)Ljava/lang/IllegalArgumentException;
athrow
2: StackMap locals:
StackMap stack:
aload 1
instanceof org.xnio.LocalSocketAddress
ifeq 4
3: aload 0
getstatic org.xnio.Xnio.ANY_LOCAL_ADDRESS:Lorg/xnio/LocalSocketAddress;
aload 1
checkcast org.xnio.LocalSocketAddress
aload 2
aload 3
invokevirtual org.xnio.XnioIoThread.openLocalMessageConnection:(Lorg/xnio/LocalSocketAddress;Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
4: StackMap locals:
StackMap stack:
getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokeinterface org.xnio._private.Messages.badSockType:(Ljava/lang/Class;)Ljava/lang/IllegalArgumentException;
athrow
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/xnio/XnioIoThread;
0 5 1 destination Ljava/net/SocketAddress;
0 5 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/MessageConnection;>;
0 5 3 optionMap Lorg/xnio/OptionMap;
Signature: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/MessageConnection;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/MessageConnection;>;
MethodParameters:
Name Flags
destination final
openListener final
optionMap final
public org.xnio.IoFuture<org.xnio.MessageConnection> acceptMessageConnection(java.net.SocketAddress, org.xnio.ChannelListener<? super org.xnio.MessageConnection>, org.xnio.ChannelListener<? super org.xnio.channels.BoundChannel>, org.xnio.OptionMap);
descriptor: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
ifnonnull 2
1: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
ldc "destination"
invokeinterface org.xnio._private.Messages.nullParameter:(Ljava/lang/String;)Ljava/lang/IllegalArgumentException;
athrow
2: StackMap locals:
StackMap stack:
aload 1
instanceof org.xnio.LocalSocketAddress
ifeq 4
3: aload 0
aload 1
checkcast org.xnio.LocalSocketAddress
aload 2
aload 3
aload 4
invokevirtual org.xnio.XnioIoThread.acceptLocalMessageConnection:(Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
4: StackMap locals:
StackMap stack:
getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokeinterface org.xnio._private.Messages.badSockType:(Ljava/lang/Class;)Ljava/lang/IllegalArgumentException;
athrow
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/xnio/XnioIoThread;
0 5 1 destination Ljava/net/SocketAddress;
0 5 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/MessageConnection;>;
0 5 3 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 5 4 optionMap Lorg/xnio/OptionMap;
Signature: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/MessageConnection;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/MessageConnection;>;
MethodParameters:
Name Flags
destination final
openListener final
bindListener final
optionMap final
protected org.xnio.IoFuture<org.xnio.MessageConnection> acceptLocalMessageConnection(org.xnio.LocalSocketAddress, org.xnio.ChannelListener<? super org.xnio.MessageConnection>, org.xnio.ChannelListener<? super org.xnio.channels.BoundChannel>, org.xnio.OptionMap);
descriptor: (Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
ldc "acceptLocalMessageConnection"
invokeinterface org.xnio._private.Messages.unsupported:(Ljava/lang/String;)Ljava/lang/UnsupportedOperationException;
athrow
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioIoThread;
0 1 1 destination Lorg/xnio/LocalSocketAddress;
0 1 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/MessageConnection;>;
0 1 3 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 1 4 optionMap Lorg/xnio/OptionMap;
Signature: (Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/MessageConnection;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/MessageConnection;>;
MethodParameters:
Name Flags
destination
openListener
bindListener
optionMap
public org.xnio.IoFuture<org.xnio.StreamConnection> openStreamConnection(java.net.SocketAddress, org.xnio.ChannelListener<? super org.xnio.StreamConnection>, org.xnio.OptionMap);
descriptor: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: ldc "destination"
aload 1
invokestatic org.wildfly.common.Assert.checkNotNullParam:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 1
instanceof java.net.InetSocketAddress
ifeq 3
2: aload 0
aload 1
checkcast java.net.InetSocketAddress
aload 2
aconst_null
aload 3
invokevirtual org.xnio.XnioIoThread.internalOpenTcpStreamConnection:(Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
3: StackMap locals:
StackMap stack:
aload 1
instanceof org.xnio.LocalSocketAddress
ifeq 5
4: aload 0
getstatic org.xnio.Xnio.ANY_LOCAL_ADDRESS:Lorg/xnio/LocalSocketAddress;
aload 1
checkcast org.xnio.LocalSocketAddress
aload 2
aconst_null
aload 3
invokevirtual org.xnio.XnioIoThread.openLocalStreamConnection:(Lorg/xnio/LocalSocketAddress;Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
5: StackMap locals:
StackMap stack:
getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokeinterface org.xnio._private.Messages.badSockType:(Ljava/lang/Class;)Ljava/lang/IllegalArgumentException;
athrow
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/xnio/XnioIoThread;
0 6 1 destination Ljava/net/SocketAddress;
0 6 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;
0 6 3 optionMap Lorg/xnio/OptionMap;
Signature: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/StreamConnection;>;
MethodParameters:
Name Flags
destination
openListener
optionMap
public org.xnio.IoFuture<org.xnio.StreamConnection> openStreamConnection(java.net.SocketAddress, org.xnio.ChannelListener<? super org.xnio.StreamConnection>, org.xnio.ChannelListener<? super org.xnio.channels.BoundChannel>, org.xnio.OptionMap);
descriptor: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: ldc "destination"
aload 1
invokestatic org.wildfly.common.Assert.checkNotNullParam:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 1
instanceof java.net.InetSocketAddress
ifeq 3
2: aload 0
aload 1
checkcast java.net.InetSocketAddress
aload 2
aload 3
aload 4
invokevirtual org.xnio.XnioIoThread.internalOpenTcpStreamConnection:(Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
3: StackMap locals:
StackMap stack:
aload 1
instanceof org.xnio.LocalSocketAddress
ifeq 5
4: aload 0
getstatic org.xnio.Xnio.ANY_LOCAL_ADDRESS:Lorg/xnio/LocalSocketAddress;
aload 1
checkcast org.xnio.LocalSocketAddress
aload 2
aload 3
aload 4
invokevirtual org.xnio.XnioIoThread.openLocalStreamConnection:(Lorg/xnio/LocalSocketAddress;Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
5: StackMap locals:
StackMap stack:
getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokeinterface org.xnio._private.Messages.badSockType:(Ljava/lang/Class;)Ljava/lang/IllegalArgumentException;
athrow
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/xnio/XnioIoThread;
0 6 1 destination Ljava/net/SocketAddress;
0 6 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;
0 6 3 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 6 4 optionMap Lorg/xnio/OptionMap;
Signature: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/StreamConnection;>;
MethodParameters:
Name Flags
destination
openListener
bindListener
optionMap
private org.xnio.IoFuture<org.xnio.StreamConnection> internalOpenTcpStreamConnection(java.net.InetSocketAddress, org.xnio.ChannelListener<? super org.xnio.StreamConnection>, org.xnio.ChannelListener<? super org.xnio.channels.BoundChannel>, org.xnio.OptionMap);
descriptor: (Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
invokevirtual java.net.InetSocketAddress.isUnresolved:()Z
ifeq 5
1: new java.net.InetSocketAddress
dup
aload 1
invokevirtual java.net.InetSocketAddress.getHostString:()Ljava/lang/String;
invokestatic java.net.InetAddress.getByName:(Ljava/lang/String;)Ljava/net/InetAddress;
aload 1
invokevirtual java.net.InetSocketAddress.getPort:()I
invokespecial java.net.InetSocketAddress.<init>:(Ljava/net/InetAddress;I)V
astore 1
2: goto 5
StackMap locals:
StackMap stack: java.net.UnknownHostException
3: astore 5
start local 5 4: new org.xnio.FailedIoFuture
dup
aload 5
invokespecial org.xnio.FailedIoFuture.<init>:(Ljava/io/IOException;)V
areturn
end local 5 5: StackMap locals:
StackMap stack:
aload 0
invokevirtual org.xnio.XnioIoThread.getWorker:()Lorg/xnio/XnioWorker;
invokevirtual org.xnio.XnioWorker.getBindAddressTable:()Lorg/wildfly/common/net/CidrAddressTable;
aload 1
invokevirtual java.net.InetSocketAddress.getAddress:()Ljava/net/InetAddress;
invokevirtual org.wildfly.common.net.CidrAddressTable.get:(Ljava/net/InetAddress;)Ljava/lang/Object;
checkcast java.net.InetSocketAddress
astore 5
start local 5 6: aload 0
aload 5
aload 1
aload 2
aload 3
aload 4
invokevirtual org.xnio.XnioIoThread.openTcpStreamConnection:(Ljava/net/InetSocketAddress;Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/xnio/XnioIoThread;
0 7 1 destination Ljava/net/InetSocketAddress;
0 7 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;
0 7 3 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 7 4 optionMap Lorg/xnio/OptionMap;
4 5 5 e Ljava/net/UnknownHostException;
6 7 5 bindAddress Ljava/net/InetSocketAddress;
Exception table:
from to target type
1 2 3 Class java.net.UnknownHostException
Signature: (Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/StreamConnection;>;
MethodParameters:
Name Flags
destination
openListener
bindListener
optionMap
public org.xnio.IoFuture<org.xnio.StreamConnection> openStreamConnection(java.net.SocketAddress, java.net.SocketAddress, org.xnio.ChannelListener<? super org.xnio.StreamConnection>, org.xnio.ChannelListener<? super org.xnio.channels.BoundChannel>, org.xnio.OptionMap);
descriptor: (Ljava/net/SocketAddress;Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: ldc "bindAddress"
aload 1
invokestatic org.wildfly.common.Assert.checkNotNullParam:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
pop
1: ldc "destination"
aload 2
invokestatic org.wildfly.common.Assert.checkNotNullParam:(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
aload 2
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
if_acmpeq 4
3: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
aload 2
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokeinterface org.xnio._private.Messages.mismatchSockType:(Ljava/lang/Class;Ljava/lang/Class;)Ljava/lang/IllegalArgumentException;
athrow
4: StackMap locals:
StackMap stack:
aload 2
instanceof java.net.InetSocketAddress
ifeq 6
5: aload 0
aload 1
checkcast java.net.InetSocketAddress
aload 2
checkcast java.net.InetSocketAddress
aload 3
aload 4
aload 5
invokevirtual org.xnio.XnioIoThread.openTcpStreamConnection:(Ljava/net/InetSocketAddress;Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
6: StackMap locals:
StackMap stack:
aload 2
instanceof org.xnio.LocalSocketAddress
ifeq 8
7: aload 0
aload 1
checkcast org.xnio.LocalSocketAddress
aload 2
checkcast org.xnio.LocalSocketAddress
aload 3
aload 4
aload 5
invokevirtual org.xnio.XnioIoThread.openLocalStreamConnection:(Lorg/xnio/LocalSocketAddress;Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
8: StackMap locals:
StackMap stack:
getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
aload 2
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokeinterface org.xnio._private.Messages.badSockType:(Ljava/lang/Class;)Ljava/lang/IllegalArgumentException;
athrow
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/xnio/XnioIoThread;
0 9 1 bindAddress Ljava/net/SocketAddress;
0 9 2 destination Ljava/net/SocketAddress;
0 9 3 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;
0 9 4 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 9 5 optionMap Lorg/xnio/OptionMap;
Signature: (Ljava/net/SocketAddress;Ljava/net/SocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/StreamConnection;>;
MethodParameters:
Name Flags
bindAddress
destination
openListener
bindListener
optionMap
protected org.xnio.IoFuture<org.xnio.StreamConnection> openTcpStreamConnection(java.net.InetSocketAddress, java.net.InetSocketAddress, org.xnio.ChannelListener<? super org.xnio.StreamConnection>, org.xnio.ChannelListener<? super org.xnio.channels.BoundChannel>, org.xnio.OptionMap);
descriptor: (Ljava/net/InetSocketAddress;Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
ldc "openTcpStreamConnection"
invokeinterface org.xnio._private.Messages.unsupported:(Ljava/lang/String;)Ljava/lang/UnsupportedOperationException;
athrow
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioIoThread;
0 1 1 bindAddress Ljava/net/InetSocketAddress;
0 1 2 destinationAddress Ljava/net/InetSocketAddress;
0 1 3 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;
0 1 4 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 1 5 optionMap Lorg/xnio/OptionMap;
Signature: (Ljava/net/InetSocketAddress;Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/StreamConnection;>;
MethodParameters:
Name Flags
bindAddress
destinationAddress
openListener
bindListener
optionMap
protected org.xnio.IoFuture<org.xnio.StreamConnection> openLocalStreamConnection(org.xnio.LocalSocketAddress, org.xnio.LocalSocketAddress, org.xnio.ChannelListener<? super org.xnio.StreamConnection>, org.xnio.ChannelListener<? super org.xnio.channels.BoundChannel>, org.xnio.OptionMap);
descriptor: (Lorg/xnio/LocalSocketAddress;Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
ldc "openLocalStreamConnection"
invokeinterface org.xnio._private.Messages.unsupported:(Ljava/lang/String;)Ljava/lang/UnsupportedOperationException;
athrow
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioIoThread;
0 1 1 bindAddress Lorg/xnio/LocalSocketAddress;
0 1 2 destinationAddress Lorg/xnio/LocalSocketAddress;
0 1 3 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;
0 1 4 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 1 5 optionMap Lorg/xnio/OptionMap;
Signature: (Lorg/xnio/LocalSocketAddress;Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/StreamConnection;>;
MethodParameters:
Name Flags
bindAddress
destinationAddress
openListener
bindListener
optionMap
protected org.xnio.IoFuture<org.xnio.MessageConnection> openLocalMessageConnection(org.xnio.LocalSocketAddress, org.xnio.LocalSocketAddress, org.xnio.ChannelListener<? super org.xnio.MessageConnection>, org.xnio.OptionMap);
descriptor: (Lorg/xnio/LocalSocketAddress;Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
ldc "openLocalMessageConnection"
invokeinterface org.xnio._private.Messages.unsupported:(Ljava/lang/String;)Ljava/lang/UnsupportedOperationException;
athrow
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioIoThread;
0 1 1 bindAddress Lorg/xnio/LocalSocketAddress;
0 1 2 destinationAddress Lorg/xnio/LocalSocketAddress;
0 1 3 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/MessageConnection;>;
0 1 4 optionMap Lorg/xnio/OptionMap;
Signature: (Lorg/xnio/LocalSocketAddress;Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/MessageConnection;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/MessageConnection;>;
MethodParameters:
Name Flags
bindAddress
destinationAddress
openListener
optionMap
public org.xnio.ChannelPipe<org.xnio.channels.StreamChannel, org.xnio.channels.StreamChannel> createFullDuplexPipe();
descriptor: ()Lorg/xnio/ChannelPipe;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=1
start local 0 0: aload 0
invokevirtual org.xnio.XnioIoThread.createFullDuplexPipeConnection:()Lorg/xnio/ChannelPipe;
astore 1
start local 1 1: new org.xnio.channels.AssembledStreamChannel
dup
aload 1
invokevirtual org.xnio.ChannelPipe.getLeftSide:()Lorg/xnio/channels/CloseableChannel;
aload 1
invokevirtual org.xnio.ChannelPipe.getLeftSide:()Lorg/xnio/channels/CloseableChannel;
checkcast org.xnio.StreamConnection
invokevirtual org.xnio.StreamConnection.getSourceChannel:()Lorg/xnio/conduits/ConduitStreamSourceChannel;
aload 1
invokevirtual org.xnio.ChannelPipe.getLeftSide:()Lorg/xnio/channels/CloseableChannel;
checkcast org.xnio.StreamConnection
invokevirtual org.xnio.StreamConnection.getSinkChannel:()Lorg/xnio/conduits/ConduitStreamSinkChannel;
invokespecial org.xnio.channels.AssembledStreamChannel.<init>:(Lorg/xnio/channels/CloseableChannel;Lorg/xnio/channels/StreamSourceChannel;Lorg/xnio/channels/StreamSinkChannel;)V
astore 2
start local 2 2: new org.xnio.channels.AssembledStreamChannel
dup
aload 1
invokevirtual org.xnio.ChannelPipe.getRightSide:()Lorg/xnio/channels/CloseableChannel;
aload 1
invokevirtual org.xnio.ChannelPipe.getRightSide:()Lorg/xnio/channels/CloseableChannel;
checkcast org.xnio.StreamConnection
invokevirtual org.xnio.StreamConnection.getSourceChannel:()Lorg/xnio/conduits/ConduitStreamSourceChannel;
aload 1
invokevirtual org.xnio.ChannelPipe.getRightSide:()Lorg/xnio/channels/CloseableChannel;
checkcast org.xnio.StreamConnection
invokevirtual org.xnio.StreamConnection.getSinkChannel:()Lorg/xnio/conduits/ConduitStreamSinkChannel;
invokespecial org.xnio.channels.AssembledStreamChannel.<init>:(Lorg/xnio/channels/CloseableChannel;Lorg/xnio/channels/StreamSourceChannel;Lorg/xnio/channels/StreamSinkChannel;)V
astore 3
start local 3 3: new org.xnio.ChannelPipe
dup
aload 2
aload 3
invokespecial org.xnio.ChannelPipe.<init>:(Lorg/xnio/channels/CloseableChannel;Lorg/xnio/channels/CloseableChannel;)V
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/xnio/XnioIoThread;
1 4 1 connection Lorg/xnio/ChannelPipe<Lorg/xnio/StreamConnection;Lorg/xnio/StreamConnection;>;
2 4 2 left Lorg/xnio/channels/StreamChannel;
3 4 3 right Lorg/xnio/channels/StreamChannel;
Exceptions:
throws java.io.IOException
Signature: ()Lorg/xnio/ChannelPipe<Lorg/xnio/channels/StreamChannel;Lorg/xnio/channels/StreamChannel;>;
public org.xnio.ChannelPipe<org.xnio.StreamConnection, org.xnio.StreamConnection> createFullDuplexPipeConnection();
descriptor: ()Lorg/xnio/ChannelPipe;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
aload 0
invokevirtual org.xnio.XnioIoThread.createFullDuplexPipeConnection:(Lorg/xnio/XnioIoFactory;)Lorg/xnio/ChannelPipe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioIoThread;
Exceptions:
throws java.io.IOException
Signature: ()Lorg/xnio/ChannelPipe<Lorg/xnio/StreamConnection;Lorg/xnio/StreamConnection;>;
public org.xnio.ChannelPipe<org.xnio.channels.StreamSourceChannel, org.xnio.channels.StreamSinkChannel> createHalfDuplexPipe();
descriptor: ()Lorg/xnio/ChannelPipe;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
aload 0
invokevirtual org.xnio.XnioIoThread.createHalfDuplexPipe:(Lorg/xnio/XnioIoFactory;)Lorg/xnio/ChannelPipe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioIoThread;
Exceptions:
throws java.io.IOException
Signature: ()Lorg/xnio/ChannelPipe<Lorg/xnio/channels/StreamSourceChannel;Lorg/xnio/channels/StreamSinkChannel;>;
public org.xnio.ChannelPipe<org.xnio.StreamConnection, org.xnio.StreamConnection> createFullDuplexPipeConnection(org.xnio.XnioIoFactory);
descriptor: (Lorg/xnio/XnioIoFactory;)Lorg/xnio/ChannelPipe;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
ldc "createFullDuplexPipeConnection"
invokeinterface org.xnio._private.Messages.unsupported:(Ljava/lang/String;)Ljava/lang/UnsupportedOperationException;
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioIoThread;
0 1 1 peer Lorg/xnio/XnioIoFactory;
Exceptions:
throws java.io.IOException
Signature: (Lorg/xnio/XnioIoFactory;)Lorg/xnio/ChannelPipe<Lorg/xnio/StreamConnection;Lorg/xnio/StreamConnection;>;
MethodParameters:
Name Flags
peer final
public org.xnio.ChannelPipe<org.xnio.channels.StreamSourceChannel, org.xnio.channels.StreamSinkChannel> createHalfDuplexPipe(org.xnio.XnioIoFactory);
descriptor: (Lorg/xnio/XnioIoFactory;)Lorg/xnio/ChannelPipe;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
ldc "createHalfDuplexPipe"
invokeinterface org.xnio._private.Messages.unsupported:(Ljava/lang/String;)Ljava/lang/UnsupportedOperationException;
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioIoThread;
0 1 1 peer Lorg/xnio/XnioIoFactory;
Exceptions:
throws java.io.IOException
Signature: (Lorg/xnio/XnioIoFactory;)Lorg/xnio/ChannelPipe<Lorg/xnio/channels/StreamSourceChannel;Lorg/xnio/channels/StreamSinkChannel;>;
MethodParameters:
Name Flags
peer final
}
SourceFile: "XnioIoThread.java"