public abstract class org.xnio.XnioWorker extends java.util.concurrent.AbstractExecutorService implements org.xnio.channels.Configurable, java.util.concurrent.ExecutorService, org.xnio.XnioIoFactory, org.wildfly.common.context.Contextual<org.xnio.XnioWorker>
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: org.xnio.XnioWorker
super_class: java.util.concurrent.AbstractExecutorService
{
private final org.xnio.Xnio xnio;
descriptor: Lorg/xnio/Xnio;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.xnio.XnioWorker$TaskPool taskPool;
descriptor: Lorg/xnio/XnioWorker$TaskPool;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.String name;
descriptor: Ljava/lang/String;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.Runnable terminationTask;
descriptor: Ljava/lang/Runnable;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.wildfly.common.net.CidrAddressTable<java.net.InetSocketAddress> bindAddressTable;
descriptor: Lorg/wildfly/common/net/CidrAddressTable;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lorg/wildfly/common/net/CidrAddressTable<Ljava/net/InetSocketAddress;>;
private volatile int taskSeq;
descriptor: I
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<org.xnio.XnioWorker> taskSeqUpdater;
descriptor: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater<Lorg/xnio/XnioWorker;>;
private static final java.util.concurrent.atomic.AtomicInteger seq;
descriptor: Ljava/util/concurrent/atomic/AtomicInteger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.lang.RuntimePermission CREATE_WORKER_PERMISSION;
descriptor: Ljava/lang/RuntimePermission;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.jboss.logging.Logger log;
descriptor: Lorg/jboss/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.wildfly.common.context.ContextManager<org.xnio.XnioWorker> CONTEXT_MANAGER;
descriptor: Lorg/wildfly/common/context/ContextManager;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Lorg/wildfly/common/context/ContextManager<Lorg/xnio/XnioWorker;>;
private static final java.util.Set<org.xnio.Option<?>> OPTIONS;
descriptor: Ljava/util/Set;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Ljava/util/Set<Lorg/xnio/Option<*>;>;
private static final java.util.Set<org.xnio.Option<?>> EXTERNAL_POOL_OPTIONS;
descriptor: Ljava/util/Set;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Ljava/util/Set<Lorg/xnio/Option<*>;>;
private static final org.xnio.IoFuture$HandlingNotifier<org.xnio.StreamConnection, org.xnio.FutureResult<org.xnio.channels.ConnectedStreamChannel>> STREAM_WRAPPING_HANDLER;
descriptor: Lorg/xnio/IoFuture$HandlingNotifier;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Lorg/xnio/IoFuture$HandlingNotifier<Lorg/xnio/StreamConnection;Lorg/xnio/FutureResult<Lorg/xnio/channels/ConnectedStreamChannel;>;>;
private static final org.xnio.IoFuture$HandlingNotifier<org.xnio.MessageConnection, org.xnio.FutureResult<org.xnio.channels.ConnectedMessageChannel>> MESSAGE_WRAPPING_HANDLER;
descriptor: Lorg/xnio/IoFuture$HandlingNotifier;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Lorg/xnio/IoFuture$HandlingNotifier<Lorg/xnio/MessageConnection;Lorg/xnio/FutureResult<Lorg/xnio/channels/ConnectedMessageChannel;>;>;
private static volatile int[] $SWITCH_TABLE$org$xnio$CompressionType;
descriptor: [I
flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: ldc Lorg/xnio/XnioWorker;
ldc "taskSeq"
invokestatic java.util.concurrent.atomic.AtomicIntegerFieldUpdater.newUpdater:(Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
putstatic org.xnio.XnioWorker.taskSeqUpdater:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
1: new java.util.concurrent.atomic.AtomicInteger
dup
iconst_1
invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:(I)V
putstatic org.xnio.XnioWorker.seq:Ljava/util/concurrent/atomic/AtomicInteger;
2: new java.lang.RuntimePermission
dup
ldc "createXnioWorker"
invokespecial java.lang.RuntimePermission.<init>:(Ljava/lang/String;)V
putstatic org.xnio.XnioWorker.CREATE_WORKER_PERMISSION:Ljava/lang/RuntimePermission;
3: ldc "org.xnio"
invokestatic org.jboss.logging.Logger.getLogger:(Ljava/lang/String;)Lorg/jboss/logging/Logger;
putstatic org.xnio.XnioWorker.log:Lorg/jboss/logging/Logger;
4: invokedynamic run()Ljava/security/PrivilegedAction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
org/xnio/XnioWorker.lambda$0()Lorg/wildfly/common/context/ContextManager; (6)
()Lorg/wildfly/common/context/ContextManager;
invokestatic java.security.AccessController.doPrivileged:(Ljava/security/PrivilegedAction;)Ljava/lang/Object;
checkcast org.wildfly.common.context.ContextManager
putstatic org.xnio.XnioWorker.CONTEXT_MANAGER:Lorg/wildfly/common/context/ContextManager;
5: invokedynamic run()Ljava/security/PrivilegedAction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
org/xnio/XnioWorker.lambda$1()Ljava/lang/Void; (6)
()Ljava/lang/Void;
invokestatic java.security.AccessController.doPrivileged:(Ljava/security/PrivilegedAction;)Ljava/lang/Object;
pop
6: invokestatic org.xnio.Option.setBuilder:()Lorg/xnio/Option$SetBuilder;
7: getstatic org.xnio.Options.WORKER_TASK_CORE_THREADS:Lorg/xnio/Option;
invokevirtual org.xnio.Option$SetBuilder.add:(Lorg/xnio/Option;)Lorg/xnio/Option$SetBuilder;
8: getstatic org.xnio.Options.WORKER_TASK_MAX_THREADS:Lorg/xnio/Option;
invokevirtual org.xnio.Option$SetBuilder.add:(Lorg/xnio/Option;)Lorg/xnio/Option$SetBuilder;
9: getstatic org.xnio.Options.WORKER_TASK_KEEPALIVE:Lorg/xnio/Option;
invokevirtual org.xnio.Option$SetBuilder.add:(Lorg/xnio/Option;)Lorg/xnio/Option$SetBuilder;
10: invokevirtual org.xnio.Option$SetBuilder.create:()Ljava/util/Set;
11: putstatic org.xnio.XnioWorker.OPTIONS:Ljava/util/Set;
12: invokestatic org.xnio.Option.setBuilder:()Lorg/xnio/Option$SetBuilder;
13: invokevirtual org.xnio.Option$SetBuilder.create:()Ljava/util/Set;
14: putstatic org.xnio.XnioWorker.EXTERNAL_POOL_OPTIONS:Ljava/util/Set;
15: new org.xnio.XnioWorker$1
dup
invokespecial org.xnio.XnioWorker$1.<init>:()V
putstatic org.xnio.XnioWorker.STREAM_WRAPPING_HANDLER:Lorg/xnio/IoFuture$HandlingNotifier;
16: new org.xnio.XnioWorker$2
dup
invokespecial org.xnio.XnioWorker$2.<init>:()V
putstatic org.xnio.XnioWorker.MESSAGE_WRAPPING_HANDLER:Lorg/xnio/IoFuture$HandlingNotifier;
17: return
LocalVariableTable:
Start End Slot Name Signature
private int getNextSeq();
descriptor: ()I
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic org.xnio.XnioWorker.taskSeqUpdater:Ljava/util/concurrent/atomic/AtomicIntegerFieldUpdater;
aload 0
invokevirtual java.util.concurrent.atomic.AtomicIntegerFieldUpdater.incrementAndGet:(Ljava/lang/Object;)I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
protected void <init>(org.xnio.XnioWorker$Builder);
descriptor: (Lorg/xnio/XnioWorker$Builder;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=16, locals=8, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.util.concurrent.AbstractExecutorService.<init>:()V
1: aload 0
aload 1
getfield org.xnio.XnioWorker$Builder.xnio:Lorg/xnio/Xnio;
putfield org.xnio.XnioWorker.xnio:Lorg/xnio/Xnio;
2: aload 0
aload 1
getfield org.xnio.XnioWorker$Builder.terminationTask:Ljava/lang/Runnable;
putfield org.xnio.XnioWorker.terminationTask:Ljava/lang/Runnable;
3: invokestatic java.lang.System.getSecurityManager:()Ljava/lang/SecurityManager;
astore 2
start local 2 4: aload 2
ifnull 6
5: aload 2
getstatic org.xnio.XnioWorker.CREATE_WORKER_PERMISSION:Ljava/lang/RuntimePermission;
invokevirtual java.lang.SecurityManager.checkPermission:(Ljava/security/Permission;)V
6: StackMap locals: org.xnio.XnioWorker org.xnio.XnioWorker$Builder java.lang.SecurityManager
StackMap stack:
aload 1
invokevirtual org.xnio.XnioWorker$Builder.getWorkerName:()Ljava/lang/String;
astore 3
start local 3 7: aload 3
ifnonnull 9
8: new java.lang.StringBuilder
dup
ldc "XNIO-"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
getstatic org.xnio.XnioWorker.seq:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.getAndIncrement:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 3
9: StackMap locals: java.lang.String
StackMap stack:
aload 0
aload 3
putfield org.xnio.XnioWorker.name:Ljava/lang/String;
10: aload 1
invokevirtual org.xnio.XnioWorker$Builder.isDaemon:()Z
istore 4
start local 4 11: aload 0
aload 1
invokevirtual org.xnio.XnioWorker$Builder.getBindAddressConfigurations:()Lorg/wildfly/common/net/CidrAddressTable;
putfield org.xnio.XnioWorker.bindAddressTable:Lorg/wildfly/common/net/CidrAddressTable;
12: new org.xnio.XnioWorker$3
dup
aload 0
invokespecial org.xnio.XnioWorker$3.<init>:(Lorg/xnio/XnioWorker;)V
astore 5
start local 5 13: aload 1
invokevirtual org.xnio.XnioWorker$Builder.getExternalExecutorService:()Ljava/util/concurrent/ExecutorService;
astore 6
start local 6 14: aload 6
ifnull 17
15: aload 0
new org.xnio.XnioWorker$ExternalTaskPool
dup
aload 6
invokespecial org.xnio.XnioWorker$ExternalTaskPool.<init>:(Ljava/util/concurrent/ExecutorService;)V
putfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
16: goto 38
StackMap locals: int java.lang.Runnable java.util.concurrent.ExecutorService
StackMap stack:
17: getstatic org.jboss.threads.EnhancedQueueExecutor.DISABLE_HINT:Z
ifeq 28
18: aload 1
invokevirtual org.xnio.XnioWorker$Builder.getMaxWorkerPoolSize:()I
aload 1
invokevirtual org.xnio.XnioWorker$Builder.getCoreWorkerPoolSize:()I
invokestatic java.lang.Math.max:(II)I
istore 7
start local 7 19: aload 0
new org.xnio.XnioWorker$ThreadPoolExecutorTaskPool
dup
20: iload 7
21: iload 7
22: aload 1
invokevirtual org.xnio.XnioWorker$Builder.getWorkerKeepAlive:()J
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
23: new java.util.concurrent.LinkedBlockingDeque
dup
invokespecial java.util.concurrent.LinkedBlockingDeque.<init>:()V
24: new org.xnio.XnioWorker$WorkerThreadFactory
dup
aload 0
aload 1
invokevirtual org.xnio.XnioWorker$Builder.getThreadGroup:()Ljava/lang/ThreadGroup;
aload 1
invokevirtual org.xnio.XnioWorker$Builder.getWorkerStackSize:()J
iload 4
invokespecial org.xnio.XnioWorker$WorkerThreadFactory.<init>:(Lorg/xnio/XnioWorker;Ljava/lang/ThreadGroup;JZ)V
25: aload 5
invokespecial org.xnio.XnioWorker$ThreadPoolExecutorTaskPool.<init>:(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;Ljava/lang/Runnable;)V
26: putfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
end local 7 27: goto 38
28: StackMap locals:
StackMap stack:
aload 0
new org.xnio.XnioWorker$EnhancedQueueExecutorTaskPool
dup
new org.jboss.threads.EnhancedQueueExecutor$Builder
dup
invokespecial org.jboss.threads.EnhancedQueueExecutor$Builder.<init>:()V
29: aload 1
invokevirtual org.xnio.XnioWorker$Builder.getCoreWorkerPoolSize:()I
invokevirtual org.jboss.threads.EnhancedQueueExecutor$Builder.setCorePoolSize:(I)Lorg/jboss/threads/EnhancedQueueExecutor$Builder;
30: aload 1
invokevirtual org.xnio.XnioWorker$Builder.getMaxWorkerPoolSize:()I
invokevirtual org.jboss.threads.EnhancedQueueExecutor$Builder.setMaximumPoolSize:(I)Lorg/jboss/threads/EnhancedQueueExecutor$Builder;
31: aload 1
invokevirtual org.xnio.XnioWorker$Builder.getWorkerKeepAlive:()J
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokevirtual org.jboss.threads.EnhancedQueueExecutor$Builder.setKeepAliveTime:(JLjava/util/concurrent/TimeUnit;)Lorg/jboss/threads/EnhancedQueueExecutor$Builder;
32: new org.xnio.XnioWorker$WorkerThreadFactory
dup
aload 0
aload 1
invokevirtual org.xnio.XnioWorker$Builder.getThreadGroup:()Ljava/lang/ThreadGroup;
aload 1
invokevirtual org.xnio.XnioWorker$Builder.getWorkerStackSize:()J
iload 4
invokespecial org.xnio.XnioWorker$WorkerThreadFactory.<init>:(Lorg/xnio/XnioWorker;Ljava/lang/ThreadGroup;JZ)V
invokevirtual org.jboss.threads.EnhancedQueueExecutor$Builder.setThreadFactory:(Ljava/util/concurrent/ThreadFactory;)Lorg/jboss/threads/EnhancedQueueExecutor$Builder;
33: aload 5
invokevirtual org.jboss.threads.EnhancedQueueExecutor$Builder.setTerminationTask:(Ljava/lang/Runnable;)Lorg/jboss/threads/EnhancedQueueExecutor$Builder;
34: iconst_1
invokevirtual org.jboss.threads.EnhancedQueueExecutor$Builder.setRegisterMBean:(Z)Lorg/jboss/threads/EnhancedQueueExecutor$Builder;
35: aload 3
invokevirtual org.jboss.threads.EnhancedQueueExecutor$Builder.setMBeanName:(Ljava/lang/String;)Lorg/jboss/threads/EnhancedQueueExecutor$Builder;
36: invokevirtual org.jboss.threads.EnhancedQueueExecutor$Builder.build:()Lorg/jboss/threads/EnhancedQueueExecutor;
invokespecial org.xnio.XnioWorker$EnhancedQueueExecutorTaskPool.<init>:(Lorg/jboss/threads/EnhancedQueueExecutor;)V
37: putfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
38: StackMap locals:
StackMap stack:
return
end local 6 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 39 0 this Lorg/xnio/XnioWorker;
0 39 1 builder Lorg/xnio/XnioWorker$Builder;
4 39 2 sm Ljava/lang/SecurityManager;
7 39 3 workerName Ljava/lang/String;
11 39 4 markThreadAsDaemon Z
13 39 5 terminationTask Ljava/lang/Runnable;
14 39 6 executorService Ljava/util/concurrent/ExecutorService;
19 27 7 poolSize I
MethodParameters:
Name Flags
builder final
public static org.wildfly.common.context.ContextManager<org.xnio.XnioWorker> getContextManager();
descriptor: ()Lorg/wildfly/common/context/ContextManager;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic org.xnio.XnioWorker.CONTEXT_MANAGER:Lorg/wildfly/common/context/ContextManager;
areturn
LocalVariableTable:
Start End Slot Name Signature
Signature: ()Lorg/wildfly/common/context/ContextManager<Lorg/xnio/XnioWorker;>;
public org.wildfly.common.context.ContextManager<org.xnio.XnioWorker> getInstanceContextManager();
descriptor: ()Lorg/wildfly/common/context/ContextManager;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: invokestatic org.xnio.XnioWorker.getContextManager:()Lorg/wildfly/common/context/ContextManager;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
Signature: ()Lorg/wildfly/common/context/ContextManager<Lorg/xnio/XnioWorker;>;
public org.xnio.channels.AcceptingChannel<? extends org.xnio.channels.ConnectedStreamChannel> createStreamServer(java.net.SocketAddress, org.xnio.ChannelListener<? super org.xnio.channels.AcceptingChannel<org.xnio.channels.ConnectedStreamChannel>>, org.xnio.OptionMap);
descriptor: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/channels/AcceptingChannel;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aconst_null
aload 3
invokevirtual org.xnio.XnioWorker.createStreamConnectionServer:(Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/channels/AcceptingChannel;
astore 4
start local 4 1: new org.xnio.XnioWorker$4
dup
aload 0
aload 4
invokespecial org.xnio.XnioWorker$4.<init>:(Lorg/xnio/XnioWorker;Lorg/xnio/channels/AcceptingChannel;)V
astore 5
start local 5 2: aload 5
invokeinterface org.xnio.channels.AcceptingChannel.getAcceptSetter:()Lorg/xnio/ChannelListener$Setter;
aload 2
invokeinterface org.xnio.ChannelListener$Setter.set:(Lorg/xnio/ChannelListener;)V
3: aload 5
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 4 0 this Lorg/xnio/XnioWorker;
0 4 1 bindAddress Ljava/net/SocketAddress;
0 4 2 acceptListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/AcceptingChannel<Lorg/xnio/channels/ConnectedStreamChannel;>;>;
0 4 3 optionMap Lorg/xnio/OptionMap;
1 4 4 server Lorg/xnio/channels/AcceptingChannel<Lorg/xnio/StreamConnection;>;
2 4 5 acceptingChannel Lorg/xnio/channels/AcceptingChannel<Lorg/xnio/channels/ConnectedStreamChannel;>;
Exceptions:
throws java.io.IOException
Signature: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/AcceptingChannel<Lorg/xnio/channels/ConnectedStreamChannel;>;>;Lorg/xnio/OptionMap;)Lorg/xnio/channels/AcceptingChannel<+Lorg/xnio/channels/ConnectedStreamChannel;>;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
bindAddress
acceptListener
optionMap
public org.xnio.channels.AcceptingChannel<org.xnio.StreamConnection> createStreamConnectionServer(java.net.SocketAddress, org.xnio.ChannelListener<? super org.xnio.channels.AcceptingChannel<org.xnio.StreamConnection>>, org.xnio.OptionMap);
descriptor: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/channels/AcceptingChannel;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: ldc "bindAddress"
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
invokevirtual org.xnio.XnioWorker.createTcpConnectionServer:(Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/channels/AcceptingChannel;
areturn
3: StackMap locals:
StackMap stack:
aload 1
instanceof org.xnio.LocalSocketAddress
ifeq 5
4: aload 0
aload 1
checkcast org.xnio.LocalSocketAddress
aload 2
aload 3
invokevirtual org.xnio.XnioWorker.createLocalStreamConnectionServer:(Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/channels/AcceptingChannel;
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/XnioWorker;
0 6 1 bindAddress Ljava/net/SocketAddress;
0 6 2 acceptListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/AcceptingChannel<Lorg/xnio/StreamConnection;>;>;
0 6 3 optionMap Lorg/xnio/OptionMap;
Exceptions:
throws java.io.IOException
Signature: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/AcceptingChannel<Lorg/xnio/StreamConnection;>;>;Lorg/xnio/OptionMap;)Lorg/xnio/channels/AcceptingChannel<Lorg/xnio/StreamConnection;>;
MethodParameters:
Name Flags
bindAddress
acceptListener
optionMap
protected org.xnio.channels.AcceptingChannel<org.xnio.StreamConnection> createTcpConnectionServer(java.net.InetSocketAddress, org.xnio.ChannelListener<? super org.xnio.channels.AcceptingChannel<org.xnio.StreamConnection>>, org.xnio.OptionMap);
descriptor: (Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/channels/AcceptingChannel;
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: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
ldc "createTcpConnectionServer"
invokeinterface org.xnio._private.Messages.unsupported:(Ljava/lang/String;)Ljava/lang/UnsupportedOperationException;
athrow
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
0 1 1 bindAddress Ljava/net/InetSocketAddress;
0 1 2 acceptListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/AcceptingChannel<Lorg/xnio/StreamConnection;>;>;
0 1 3 optionMap Lorg/xnio/OptionMap;
Exceptions:
throws java.io.IOException
Signature: (Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/AcceptingChannel<Lorg/xnio/StreamConnection;>;>;Lorg/xnio/OptionMap;)Lorg/xnio/channels/AcceptingChannel<Lorg/xnio/StreamConnection;>;
MethodParameters:
Name Flags
bindAddress
acceptListener
optionMap
protected org.xnio.channels.AcceptingChannel<org.xnio.StreamConnection> createLocalStreamConnectionServer(org.xnio.LocalSocketAddress, org.xnio.ChannelListener<? super org.xnio.channels.AcceptingChannel<org.xnio.StreamConnection>>, org.xnio.OptionMap);
descriptor: (Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/channels/AcceptingChannel;
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: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
ldc "createLocalStreamConnectionServer"
invokeinterface org.xnio._private.Messages.unsupported:(Ljava/lang/String;)Ljava/lang/UnsupportedOperationException;
athrow
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
0 1 1 bindAddress Lorg/xnio/LocalSocketAddress;
0 1 2 acceptListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/AcceptingChannel<Lorg/xnio/StreamConnection;>;>;
0 1 3 optionMap Lorg/xnio/OptionMap;
Exceptions:
throws java.io.IOException
Signature: (Lorg/xnio/LocalSocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/AcceptingChannel<Lorg/xnio/StreamConnection;>;>;Lorg/xnio/OptionMap;)Lorg/xnio/channels/AcceptingChannel<Lorg/xnio/StreamConnection;>;
MethodParameters:
Name Flags
bindAddress
acceptListener
optionMap
public org.xnio.IoFuture<org.xnio.channels.ConnectedStreamChannel> connectStream(java.net.SocketAddress, org.xnio.ChannelListener<? super org.xnio.channels.ConnectedStreamChannel>, org.xnio.OptionMap);
descriptor: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new org.xnio.FutureResult
dup
invokespecial org.xnio.FutureResult.<init>:()V
astore 4
start local 4 1: new org.xnio.XnioWorker$StreamConnectionWrapListener
dup
aload 4
aload 2
invokespecial org.xnio.XnioWorker$StreamConnectionWrapListener.<init>:(Lorg/xnio/FutureResult;Lorg/xnio/ChannelListener;)V
astore 5
start local 5 2: aload 0
aload 1
aload 5
aload 3
invokevirtual org.xnio.XnioWorker.openStreamConnection:(Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
astore 6
start local 6 3: aload 6
getstatic org.xnio.XnioWorker.STREAM_WRAPPING_HANDLER:Lorg/xnio/IoFuture$HandlingNotifier;
aload 4
invokeinterface org.xnio.IoFuture.addNotifier:(Lorg/xnio/IoFuture$Notifier;Ljava/lang/Object;)Lorg/xnio/IoFuture;
pop
4: aload 4
aload 6
invokevirtual org.xnio.FutureResult.addCancelHandler:(Lorg/xnio/Cancellable;)V
5: aload 4
invokevirtual org.xnio.FutureResult.getIoFuture:()Lorg/xnio/IoFuture;
areturn
end local 6 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 6 0 this Lorg/xnio/XnioWorker;
0 6 1 destination Ljava/net/SocketAddress;
0 6 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/ConnectedStreamChannel;>;
0 6 3 optionMap Lorg/xnio/OptionMap;
1 6 4 futureResult Lorg/xnio/FutureResult<Lorg/xnio/channels/ConnectedStreamChannel;>;
2 6 5 nestedOpenListener Lorg/xnio/ChannelListener<Lorg/xnio/StreamConnection;>;
3 6 6 future Lorg/xnio/IoFuture<Lorg/xnio/StreamConnection;>;
Signature: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/ConnectedStreamChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/channels/ConnectedStreamChannel;>;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
destination
openListener
optionMap
public org.xnio.IoFuture<org.xnio.channels.ConnectedStreamChannel> connectStream(java.net.SocketAddress, org.xnio.ChannelListener<? super org.xnio.channels.ConnectedStreamChannel>, 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=8, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: new org.xnio.FutureResult
dup
invokespecial org.xnio.FutureResult.<init>:()V
astore 5
start local 5 1: new org.xnio.XnioWorker$StreamConnectionWrapListener
dup
aload 5
aload 2
invokespecial org.xnio.XnioWorker$StreamConnectionWrapListener.<init>:(Lorg/xnio/FutureResult;Lorg/xnio/ChannelListener;)V
astore 6
start local 6 2: aload 0
aload 1
aload 6
aload 3
aload 4
invokevirtual org.xnio.XnioWorker.openStreamConnection:(Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
astore 7
start local 7 3: aload 7
getstatic org.xnio.XnioWorker.STREAM_WRAPPING_HANDLER:Lorg/xnio/IoFuture$HandlingNotifier;
aload 5
invokeinterface org.xnio.IoFuture.addNotifier:(Lorg/xnio/IoFuture$Notifier;Ljava/lang/Object;)Lorg/xnio/IoFuture;
pop
4: aload 5
aload 7
invokevirtual org.xnio.FutureResult.addCancelHandler:(Lorg/xnio/Cancellable;)V
5: aload 5
invokevirtual org.xnio.FutureResult.getIoFuture:()Lorg/xnio/IoFuture;
areturn
end local 7 end local 6 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 6 0 this Lorg/xnio/XnioWorker;
0 6 1 destination Ljava/net/SocketAddress;
0 6 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/ConnectedStreamChannel;>;
0 6 3 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 6 4 optionMap Lorg/xnio/OptionMap;
1 6 5 futureResult Lorg/xnio/FutureResult<Lorg/xnio/channels/ConnectedStreamChannel;>;
2 6 6 nestedOpenListener Lorg/xnio/ChannelListener<Lorg/xnio/StreamConnection;>;
3 6 7 future Lorg/xnio/IoFuture<Lorg/xnio/StreamConnection;>;
Signature: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/ConnectedStreamChannel;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/channels/ConnectedStreamChannel;>;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
destination
openListener
bindListener
optionMap
public org.xnio.IoFuture<org.xnio.channels.ConnectedStreamChannel> connectStream(java.net.SocketAddress, java.net.SocketAddress, org.xnio.ChannelListener<? super org.xnio.channels.ConnectedStreamChannel>, 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=9, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: new org.xnio.FutureResult
dup
invokespecial org.xnio.FutureResult.<init>:()V
astore 6
start local 6 1: new org.xnio.XnioWorker$StreamConnectionWrapListener
dup
aload 6
aload 3
invokespecial org.xnio.XnioWorker$StreamConnectionWrapListener.<init>:(Lorg/xnio/FutureResult;Lorg/xnio/ChannelListener;)V
astore 7
start local 7 2: aload 0
aload 1
aload 2
aload 7
aload 4
aload 5
invokevirtual org.xnio.XnioWorker.openStreamConnection:(Ljava/net/SocketAddress;Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
astore 8
start local 8 3: aload 8
getstatic org.xnio.XnioWorker.STREAM_WRAPPING_HANDLER:Lorg/xnio/IoFuture$HandlingNotifier;
aload 6
invokeinterface org.xnio.IoFuture.addNotifier:(Lorg/xnio/IoFuture$Notifier;Ljava/lang/Object;)Lorg/xnio/IoFuture;
pop
4: aload 6
aload 8
invokevirtual org.xnio.FutureResult.addCancelHandler:(Lorg/xnio/Cancellable;)V
5: aload 6
invokevirtual org.xnio.FutureResult.getIoFuture:()Lorg/xnio/IoFuture;
areturn
end local 8 end local 7 end local 6 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 6 0 this Lorg/xnio/XnioWorker;
0 6 1 bindAddress Ljava/net/SocketAddress;
0 6 2 destination Ljava/net/SocketAddress;
0 6 3 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/ConnectedStreamChannel;>;
0 6 4 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 6 5 optionMap Lorg/xnio/OptionMap;
1 6 6 futureResult Lorg/xnio/FutureResult<Lorg/xnio/channels/ConnectedStreamChannel;>;
2 6 7 nestedOpenListener Lorg/xnio/ChannelListener<Lorg/xnio/StreamConnection;>;
3 6 8 future Lorg/xnio/IoFuture<Lorg/xnio/StreamConnection;>;
Signature: (Ljava/net/SocketAddress;Ljava/net/SocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/ConnectedStreamChannel;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/channels/ConnectedStreamChannel;>;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
bindAddress
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=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokevirtual org.xnio.XnioWorker.chooseThread:()Lorg/xnio/XnioIoThread;
aload 1
aload 2
aload 3
invokevirtual org.xnio.XnioIoThread.openStreamConnection:(Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
0 1 1 destination Ljava/net/SocketAddress;
0 1 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/StreamConnection;>;
0 1 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=5, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
invokevirtual org.xnio.XnioWorker.chooseThread:()Lorg/xnio/XnioIoThread;
aload 1
aload 2
aload 3
aload 4
invokevirtual org.xnio.XnioIoThread.openStreamConnection:(Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
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/XnioWorker;
0 1 1 destination Ljava/net/SocketAddress;
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/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
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: aload 0
invokevirtual org.xnio.XnioWorker.chooseThread:()Lorg/xnio/XnioIoThread;
aload 1
aload 2
aload 3
aload 4
aload 5
invokevirtual org.xnio.XnioIoThread.openStreamConnection:(Ljava/net/SocketAddress;Ljava/net/SocketAddress;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 1 0 this Lorg/xnio/XnioWorker;
0 1 1 bindAddress Ljava/net/SocketAddress;
0 1 2 destination Ljava/net/SocketAddress;
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/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
public org.xnio.IoFuture<org.xnio.channels.ConnectedStreamChannel> acceptStream(java.net.SocketAddress, org.xnio.ChannelListener<? super org.xnio.channels.ConnectedStreamChannel>, 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=8, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: new org.xnio.FutureResult
dup
invokespecial org.xnio.FutureResult.<init>:()V
astore 5
start local 5 1: new org.xnio.XnioWorker$StreamConnectionWrapListener
dup
aload 5
aload 2
invokespecial org.xnio.XnioWorker$StreamConnectionWrapListener.<init>:(Lorg/xnio/FutureResult;Lorg/xnio/ChannelListener;)V
astore 6
start local 6 2: aload 0
aload 1
aload 6
aload 3
aload 4
invokevirtual org.xnio.XnioWorker.acceptStreamConnection:(Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
astore 7
start local 7 3: aload 7
getstatic org.xnio.XnioWorker.STREAM_WRAPPING_HANDLER:Lorg/xnio/IoFuture$HandlingNotifier;
aload 5
invokeinterface org.xnio.IoFuture.addNotifier:(Lorg/xnio/IoFuture$Notifier;Ljava/lang/Object;)Lorg/xnio/IoFuture;
pop
4: aload 5
aload 7
invokevirtual org.xnio.FutureResult.addCancelHandler:(Lorg/xnio/Cancellable;)V
5: aload 5
invokevirtual org.xnio.FutureResult.getIoFuture:()Lorg/xnio/IoFuture;
areturn
end local 7 end local 6 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 6 0 this Lorg/xnio/XnioWorker;
0 6 1 destination Ljava/net/SocketAddress;
0 6 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/ConnectedStreamChannel;>;
0 6 3 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 6 4 optionMap Lorg/xnio/OptionMap;
1 6 5 futureResult Lorg/xnio/FutureResult<Lorg/xnio/channels/ConnectedStreamChannel;>;
2 6 6 nestedOpenListener Lorg/xnio/ChannelListener<Lorg/xnio/StreamConnection;>;
3 6 7 future Lorg/xnio/IoFuture<Lorg/xnio/StreamConnection;>;
Signature: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/ConnectedStreamChannel;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/channels/ConnectedStreamChannel;>;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
destination
openListener
bindListener
optionMap
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 0
invokevirtual org.xnio.XnioWorker.chooseThread:()Lorg/xnio/XnioIoThread;
aload 1
aload 2
aload 3
aload 4
invokevirtual org.xnio.XnioIoThread.acceptStreamConnection:(Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
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/XnioWorker;
0 1 1 destination Ljava/net/SocketAddress;
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/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
public org.xnio.IoFuture<org.xnio.channels.ConnectedMessageChannel> connectDatagram(java.net.SocketAddress, org.xnio.ChannelListener<? super org.xnio.channels.ConnectedMessageChannel>, 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=4, locals=8, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: new org.xnio.FutureResult
dup
invokespecial org.xnio.FutureResult.<init>:()V
astore 5
start local 5 1: new org.xnio.XnioWorker$MessageConnectionWrapListener
dup
aload 5
aload 2
invokespecial org.xnio.XnioWorker$MessageConnectionWrapListener.<init>:(Lorg/xnio/FutureResult;Lorg/xnio/ChannelListener;)V
astore 6
start local 6 2: aload 0
aload 1
aload 6
aload 4
invokevirtual org.xnio.XnioWorker.openMessageConnection:(Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
astore 7
start local 7 3: aload 7
getstatic org.xnio.XnioWorker.MESSAGE_WRAPPING_HANDLER:Lorg/xnio/IoFuture$HandlingNotifier;
aload 5
invokeinterface org.xnio.IoFuture.addNotifier:(Lorg/xnio/IoFuture$Notifier;Ljava/lang/Object;)Lorg/xnio/IoFuture;
pop
4: aload 5
aload 7
invokevirtual org.xnio.FutureResult.addCancelHandler:(Lorg/xnio/Cancellable;)V
5: aload 5
invokevirtual org.xnio.FutureResult.getIoFuture:()Lorg/xnio/IoFuture;
areturn
end local 7 end local 6 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 6 0 this Lorg/xnio/XnioWorker;
0 6 1 destination Ljava/net/SocketAddress;
0 6 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/ConnectedMessageChannel;>;
0 6 3 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 6 4 optionMap Lorg/xnio/OptionMap;
1 6 5 futureResult Lorg/xnio/FutureResult<Lorg/xnio/channels/ConnectedMessageChannel;>;
2 6 6 nestedOpenListener Lorg/xnio/ChannelListener<Lorg/xnio/MessageConnection;>;
3 6 7 future Lorg/xnio/IoFuture<Lorg/xnio/MessageConnection;>;
Signature: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/ConnectedMessageChannel;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/channels/ConnectedMessageChannel;>;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
destination
openListener
bindListener
optionMap
public org.xnio.IoFuture<org.xnio.channels.ConnectedMessageChannel> connectDatagram(java.net.SocketAddress, java.net.SocketAddress, org.xnio.ChannelListener<? super org.xnio.channels.ConnectedMessageChannel>, 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=4, locals=9, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: new org.xnio.FutureResult
dup
invokespecial org.xnio.FutureResult.<init>:()V
astore 6
start local 6 1: new org.xnio.XnioWorker$MessageConnectionWrapListener
dup
aload 6
aload 3
invokespecial org.xnio.XnioWorker$MessageConnectionWrapListener.<init>:(Lorg/xnio/FutureResult;Lorg/xnio/ChannelListener;)V
astore 7
start local 7 2: aload 0
aload 2
aload 7
aload 5
invokevirtual org.xnio.XnioWorker.openMessageConnection:(Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
astore 8
start local 8 3: aload 8
getstatic org.xnio.XnioWorker.MESSAGE_WRAPPING_HANDLER:Lorg/xnio/IoFuture$HandlingNotifier;
aload 6
invokeinterface org.xnio.IoFuture.addNotifier:(Lorg/xnio/IoFuture$Notifier;Ljava/lang/Object;)Lorg/xnio/IoFuture;
pop
4: aload 6
aload 8
invokevirtual org.xnio.FutureResult.addCancelHandler:(Lorg/xnio/Cancellable;)V
5: aload 6
invokevirtual org.xnio.FutureResult.getIoFuture:()Lorg/xnio/IoFuture;
areturn
end local 8 end local 7 end local 6 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 6 0 this Lorg/xnio/XnioWorker;
0 6 1 bindAddress Ljava/net/SocketAddress;
0 6 2 destination Ljava/net/SocketAddress;
0 6 3 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/ConnectedMessageChannel;>;
0 6 4 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 6 5 optionMap Lorg/xnio/OptionMap;
1 6 6 futureResult Lorg/xnio/FutureResult<Lorg/xnio/channels/ConnectedMessageChannel;>;
2 6 7 nestedOpenListener Lorg/xnio/ChannelListener<Lorg/xnio/MessageConnection;>;
3 6 8 future Lorg/xnio/IoFuture<Lorg/xnio/MessageConnection;>;
Signature: (Ljava/net/SocketAddress;Ljava/net/SocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/ConnectedMessageChannel;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/channels/ConnectedMessageChannel;>;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
bindAddress
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=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokevirtual org.xnio.XnioWorker.chooseThread:()Lorg/xnio/XnioIoThread;
aload 1
aload 2
aload 3
invokevirtual org.xnio.XnioIoThread.openMessageConnection:(Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
0 1 1 destination Ljava/net/SocketAddress;
0 1 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/MessageConnection;>;
0 1 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.channels.ConnectedMessageChannel> acceptDatagram(java.net.SocketAddress, org.xnio.ChannelListener<? super org.xnio.channels.ConnectedMessageChannel>, 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=8, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: new org.xnio.FutureResult
dup
invokespecial org.xnio.FutureResult.<init>:()V
astore 5
start local 5 1: new org.xnio.XnioWorker$MessageConnectionWrapListener
dup
aload 5
aload 2
invokespecial org.xnio.XnioWorker$MessageConnectionWrapListener.<init>:(Lorg/xnio/FutureResult;Lorg/xnio/ChannelListener;)V
astore 6
start local 6 2: aload 0
aload 1
aload 6
aload 3
aload 4
invokevirtual org.xnio.XnioWorker.acceptMessageConnection:(Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
astore 7
start local 7 3: aload 7
getstatic org.xnio.XnioWorker.MESSAGE_WRAPPING_HANDLER:Lorg/xnio/IoFuture$HandlingNotifier;
aload 5
invokeinterface org.xnio.IoFuture.addNotifier:(Lorg/xnio/IoFuture$Notifier;Ljava/lang/Object;)Lorg/xnio/IoFuture;
pop
4: aload 5
aload 7
invokevirtual org.xnio.FutureResult.addCancelHandler:(Lorg/xnio/Cancellable;)V
5: aload 5
invokevirtual org.xnio.FutureResult.getIoFuture:()Lorg/xnio/IoFuture;
areturn
end local 7 end local 6 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 6 0 this Lorg/xnio/XnioWorker;
0 6 1 destination Ljava/net/SocketAddress;
0 6 2 openListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/ConnectedMessageChannel;>;
0 6 3 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;
0 6 4 optionMap Lorg/xnio/OptionMap;
1 6 5 futureResult Lorg/xnio/FutureResult<Lorg/xnio/channels/ConnectedMessageChannel;>;
2 6 6 nestedOpenListener Lorg/xnio/ChannelListener<Lorg/xnio/MessageConnection;>;
3 6 7 future Lorg/xnio/IoFuture<Lorg/xnio/MessageConnection;>;
Signature: (Ljava/net/SocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/ConnectedMessageChannel;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/BoundChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture<Lorg/xnio/channels/ConnectedMessageChannel;>;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
destination
openListener
bindListener
optionMap
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 0
invokevirtual org.xnio.XnioWorker.chooseThread:()Lorg/xnio/XnioIoThread;
aload 1
aload 2
aload 3
aload 4
invokevirtual org.xnio.XnioIoThread.acceptMessageConnection:(Ljava/net/SocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/IoFuture;
areturn
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/XnioWorker;
0 1 1 destination Ljava/net/SocketAddress;
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: (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
public org.xnio.channels.MulticastMessageChannel createUdpServer(java.net.InetSocketAddress, org.xnio.ChannelListener<? super org.xnio.channels.MulticastMessageChannel>, org.xnio.OptionMap);
descriptor: (Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/channels/MulticastMessageChannel;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
ldc "createUdpServer"
invokeinterface org.xnio._private.Messages.unsupported:(Ljava/lang/String;)Ljava/lang/UnsupportedOperationException;
athrow
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
0 1 1 bindAddress Ljava/net/InetSocketAddress;
0 1 2 bindListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/MulticastMessageChannel;>;
0 1 3 optionMap Lorg/xnio/OptionMap;
Exceptions:
throws java.io.IOException
Signature: (Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/MulticastMessageChannel;>;Lorg/xnio/OptionMap;)Lorg/xnio/channels/MulticastMessageChannel;
MethodParameters:
Name Flags
bindAddress
bindListener
optionMap
public org.xnio.channels.MulticastMessageChannel createUdpServer(java.net.InetSocketAddress, org.xnio.OptionMap);
descriptor: (Ljava/net/InetSocketAddress;Lorg/xnio/OptionMap;)Lorg/xnio/channels/MulticastMessageChannel;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokestatic org.xnio.ChannelListeners.nullChannelListener:()Lorg/xnio/ChannelListener;
aload 2
invokevirtual org.xnio.XnioWorker.createUdpServer:(Ljava/net/InetSocketAddress;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)Lorg/xnio/channels/MulticastMessageChannel;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
0 1 1 bindAddress Ljava/net/InetSocketAddress;
0 1 2 optionMap Lorg/xnio/OptionMap;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
bindAddress
optionMap
public void createPipe(org.xnio.ChannelListener<? super org.xnio.channels.StreamChannel>, org.xnio.ChannelListener<? super org.xnio.channels.StreamChannel>, org.xnio.OptionMap);
descriptor: (Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=10, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokevirtual org.xnio.XnioWorker.createFullDuplexPipe:()Lorg/xnio/ChannelPipe;
astore 4
start local 4 1: aload 3
getstatic org.xnio.Options.WORKER_ESTABLISH_WRITING:Lorg/xnio/Option;
iconst_0
invokevirtual org.xnio.OptionMap.get:(Lorg/xnio/Option;Z)Z
istore 5
start local 5 2: aload 4
invokevirtual org.xnio.ChannelPipe.getLeftSide:()Lorg/xnio/channels/CloseableChannel;
checkcast org.xnio.channels.StreamChannel
astore 6
start local 6 3: iload 5
ifeq 4
aload 6
invokeinterface org.xnio.channels.StreamChannel.getWriteThread:()Lorg/xnio/XnioExecutor;
goto 5
StackMap locals: org.xnio.ChannelPipe int org.xnio.channels.StreamChannel
StackMap stack:
4: aload 6
invokeinterface org.xnio.channels.StreamChannel.getReadThread:()Lorg/xnio/XnioExecutor;
StackMap locals:
StackMap stack: org.xnio.XnioExecutor
5: astore 7
start local 7 6: aload 4
invokevirtual org.xnio.ChannelPipe.getRightSide:()Lorg/xnio/channels/CloseableChannel;
checkcast org.xnio.channels.StreamChannel
astore 8
start local 8 7: iload 5
ifeq 8
aload 8
invokeinterface org.xnio.channels.StreamChannel.getWriteThread:()Lorg/xnio/XnioExecutor;
goto 9
StackMap locals: org.xnio.XnioExecutor org.xnio.channels.StreamChannel
StackMap stack:
8: aload 8
invokeinterface org.xnio.channels.StreamChannel.getReadThread:()Lorg/xnio/XnioExecutor;
StackMap locals:
StackMap stack: org.xnio.XnioExecutor
9: astore 9
start local 9 10: aload 7
aload 6
aload 1
invokestatic org.xnio.ChannelListeners.getChannelListenerTask:(Ljava/nio/channels/Channel;Lorg/xnio/ChannelListener;)Ljava/lang/Runnable;
invokeinterface org.xnio.XnioExecutor.execute:(Ljava/lang/Runnable;)V
11: aload 9
aload 8
aload 2
invokestatic org.xnio.ChannelListeners.getChannelListenerTask:(Ljava/nio/channels/Channel;Lorg/xnio/ChannelListener;)Ljava/lang/Runnable;
invokeinterface org.xnio.XnioExecutor.execute:(Ljava/lang/Runnable;)V
12: return
end local 9 end local 8 end local 7 end local 6 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 13 0 this Lorg/xnio/XnioWorker;
0 13 1 leftOpenListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/StreamChannel;>;
0 13 2 rightOpenListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/StreamChannel;>;
0 13 3 optionMap Lorg/xnio/OptionMap;
1 13 4 pipe Lorg/xnio/ChannelPipe<Lorg/xnio/channels/StreamChannel;Lorg/xnio/channels/StreamChannel;>;
2 13 5 establishWriting Z
3 13 6 left Lorg/xnio/channels/StreamChannel;
6 13 7 leftExec Lorg/xnio/XnioExecutor;
7 13 8 right Lorg/xnio/channels/StreamChannel;
10 13 9 rightExec Lorg/xnio/XnioExecutor;
Exceptions:
throws java.io.IOException
Signature: (Lorg/xnio/ChannelListener<-Lorg/xnio/channels/StreamChannel;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/StreamChannel;>;Lorg/xnio/OptionMap;)V
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
leftOpenListener
rightOpenListener
optionMap final
public void createOneWayPipe(org.xnio.ChannelListener<? super org.xnio.channels.StreamSourceChannel>, org.xnio.ChannelListener<? super org.xnio.channels.StreamSinkChannel>, org.xnio.OptionMap);
descriptor: (Lorg/xnio/ChannelListener;Lorg/xnio/ChannelListener;Lorg/xnio/OptionMap;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=9, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokevirtual org.xnio.XnioWorker.createHalfDuplexPipe:()Lorg/xnio/ChannelPipe;
astore 4
start local 4 1: aload 4
invokevirtual org.xnio.ChannelPipe.getLeftSide:()Lorg/xnio/channels/CloseableChannel;
checkcast org.xnio.channels.StreamSourceChannel
astore 5
start local 5 2: aload 5
invokeinterface org.xnio.channels.StreamSourceChannel.getReadThread:()Lorg/xnio/XnioExecutor;
astore 6
start local 6 3: aload 4
invokevirtual org.xnio.ChannelPipe.getRightSide:()Lorg/xnio/channels/CloseableChannel;
checkcast org.xnio.channels.StreamSinkChannel
astore 7
start local 7 4: aload 7
invokeinterface org.xnio.channels.StreamSinkChannel.getWriteThread:()Lorg/xnio/XnioExecutor;
astore 8
start local 8 5: aload 6
aload 5
aload 1
invokestatic org.xnio.ChannelListeners.getChannelListenerTask:(Ljava/nio/channels/Channel;Lorg/xnio/ChannelListener;)Ljava/lang/Runnable;
invokeinterface org.xnio.XnioExecutor.execute:(Ljava/lang/Runnable;)V
6: aload 8
aload 7
aload 2
invokestatic org.xnio.ChannelListeners.getChannelListenerTask:(Ljava/nio/channels/Channel;Lorg/xnio/ChannelListener;)Ljava/lang/Runnable;
invokeinterface org.xnio.XnioExecutor.execute:(Ljava/lang/Runnable;)V
7: return
end local 8 end local 7 end local 6 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 8 0 this Lorg/xnio/XnioWorker;
0 8 1 sourceListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/StreamSourceChannel;>;
0 8 2 sinkListener Lorg/xnio/ChannelListener<-Lorg/xnio/channels/StreamSinkChannel;>;
0 8 3 optionMap Lorg/xnio/OptionMap;
1 8 4 pipe Lorg/xnio/ChannelPipe<Lorg/xnio/channels/StreamSourceChannel;Lorg/xnio/channels/StreamSinkChannel;>;
2 8 5 left Lorg/xnio/channels/StreamSourceChannel;
3 8 6 leftExec Lorg/xnio/XnioExecutor;
4 8 7 right Lorg/xnio/channels/StreamSinkChannel;
5 8 8 rightExec Lorg/xnio/XnioExecutor;
Exceptions:
throws java.io.IOException
Signature: (Lorg/xnio/ChannelListener<-Lorg/xnio/channels/StreamSourceChannel;>;Lorg/xnio/ChannelListener<-Lorg/xnio/channels/StreamSinkChannel;>;Lorg/xnio/OptionMap;)V
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
sourceListener
sinkListener
optionMap final
public org.xnio.channels.StreamSourceChannel getInflatingChannel(org.xnio.channels.StreamSourceChannel, org.xnio.OptionMap);
descriptor: (Lorg/xnio/channels/StreamSourceChannel;Lorg/xnio/OptionMap;)Lorg/xnio/channels/StreamSourceChannel;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: invokestatic org.xnio.XnioWorker.$SWITCH_TABLE$org$xnio$CompressionType:()[I
aload 2
getstatic org.xnio.Options.COMPRESSION_TYPE:Lorg/xnio/Option;
getstatic org.xnio.CompressionType.DEFLATE:Lorg/xnio/CompressionType;
invokevirtual org.xnio.OptionMap.get:(Lorg/xnio/Option;Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.xnio.CompressionType
invokevirtual org.xnio.CompressionType.ordinal:()I
iaload
tableswitch { // 1 - 2
1: 1
2: 3
default: 5
}
1: StackMap locals:
StackMap stack:
iconst_0
istore 3
start local 3 2: goto 6
end local 3 3: StackMap locals:
StackMap stack:
iconst_1
istore 3
start local 3 4: goto 6
end local 3 5: StackMap locals:
StackMap stack:
getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
invokeinterface org.xnio._private.Messages.badCompressionFormat:()Ljava/lang/IllegalArgumentException;
athrow
start local 3 6: StackMap locals: int
StackMap stack:
aload 0
aload 1
new java.util.zip.Inflater
dup
iload 3
invokespecial java.util.zip.Inflater.<init>:(Z)V
invokevirtual org.xnio.XnioWorker.getInflatingChannel:(Lorg/xnio/channels/StreamSourceChannel;Ljava/util/zip/Inflater;)Lorg/xnio/channels/StreamSourceChannel;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/xnio/XnioWorker;
0 7 1 delegate Lorg/xnio/channels/StreamSourceChannel;
0 7 2 options Lorg/xnio/OptionMap;
2 3 3 nowrap Z
4 5 3 nowrap Z
6 7 3 nowrap Z
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
delegate final
options
protected org.xnio.channels.StreamSourceChannel getInflatingChannel(org.xnio.channels.StreamSourceChannel, java.util.zip.Inflater);
descriptor: (Lorg/xnio/channels/StreamSourceChannel;Ljava/util/zip/Inflater;)Lorg/xnio/channels/StreamSourceChannel;
flags: (0x0004) ACC_PROTECTED
Code:
stack=8, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new org.xnio.conduits.ConduitStreamSourceChannel
dup
getstatic org.xnio.channels.Configurable.EMPTY:Lorg/xnio/channels/Configurable;
new org.xnio.conduits.InflatingStreamSourceConduit
dup
new org.xnio.conduits.StreamSourceChannelWrappingConduit
dup
aload 1
invokespecial org.xnio.conduits.StreamSourceChannelWrappingConduit.<init>:(Lorg/xnio/channels/StreamSourceChannel;)V
aload 2
invokespecial org.xnio.conduits.InflatingStreamSourceConduit.<init>:(Lorg/xnio/conduits/StreamSourceConduit;Ljava/util/zip/Inflater;)V
invokespecial org.xnio.conduits.ConduitStreamSourceChannel.<init>:(Lorg/xnio/channels/Configurable;Lorg/xnio/conduits/StreamSourceConduit;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
0 1 1 delegate Lorg/xnio/channels/StreamSourceChannel;
0 1 2 inflater Ljava/util/zip/Inflater;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
delegate final
inflater final
public org.xnio.channels.StreamSinkChannel getDeflatingChannel(org.xnio.channels.StreamSinkChannel, org.xnio.OptionMap);
descriptor: (Lorg/xnio/channels/StreamSinkChannel;Lorg/xnio/OptionMap;)Lorg/xnio/channels/StreamSinkChannel;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 2
getstatic org.xnio.Options.COMPRESSION_LEVEL:Lorg/xnio/Option;
iconst_m1
invokevirtual org.xnio.OptionMap.get:(Lorg/xnio/Option;I)I
istore 3
start local 3 1: invokestatic org.xnio.XnioWorker.$SWITCH_TABLE$org$xnio$CompressionType:()[I
aload 2
getstatic org.xnio.Options.COMPRESSION_TYPE:Lorg/xnio/Option;
getstatic org.xnio.CompressionType.DEFLATE:Lorg/xnio/CompressionType;
invokevirtual org.xnio.OptionMap.get:(Lorg/xnio/Option;Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.xnio.CompressionType
invokevirtual org.xnio.CompressionType.ordinal:()I
iaload
tableswitch { // 1 - 2
1: 2
2: 4
default: 6
}
2: StackMap locals: int
StackMap stack:
iconst_0
istore 4
start local 4 3: goto 7
end local 4 4: StackMap locals:
StackMap stack:
iconst_1
istore 4
start local 4 5: goto 7
end local 4 6: StackMap locals:
StackMap stack:
getstatic org.xnio._private.Messages.msg:Lorg/xnio/_private/Messages;
invokeinterface org.xnio._private.Messages.badCompressionFormat:()Ljava/lang/IllegalArgumentException;
athrow
start local 4 7: StackMap locals: int
StackMap stack:
aload 0
aload 1
new java.util.zip.Deflater
dup
iload 3
iload 4
invokespecial java.util.zip.Deflater.<init>:(IZ)V
invokevirtual org.xnio.XnioWorker.getDeflatingChannel:(Lorg/xnio/channels/StreamSinkChannel;Ljava/util/zip/Deflater;)Lorg/xnio/channels/StreamSinkChannel;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/xnio/XnioWorker;
0 8 1 delegate Lorg/xnio/channels/StreamSinkChannel;
0 8 2 options Lorg/xnio/OptionMap;
1 8 3 level I
3 4 4 nowrap Z
5 6 4 nowrap Z
7 8 4 nowrap Z
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
delegate final
options final
protected org.xnio.channels.StreamSinkChannel getDeflatingChannel(org.xnio.channels.StreamSinkChannel, java.util.zip.Deflater);
descriptor: (Lorg/xnio/channels/StreamSinkChannel;Ljava/util/zip/Deflater;)Lorg/xnio/channels/StreamSinkChannel;
flags: (0x0004) ACC_PROTECTED
Code:
stack=8, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new org.xnio.conduits.ConduitStreamSinkChannel
dup
getstatic org.xnio.channels.Configurable.EMPTY:Lorg/xnio/channels/Configurable;
new org.xnio.conduits.DeflatingStreamSinkConduit
dup
new org.xnio.conduits.StreamSinkChannelWrappingConduit
dup
aload 1
invokespecial org.xnio.conduits.StreamSinkChannelWrappingConduit.<init>:(Lorg/xnio/channels/StreamSinkChannel;)V
aload 2
invokespecial org.xnio.conduits.DeflatingStreamSinkConduit.<init>:(Lorg/xnio/conduits/StreamSinkConduit;Ljava/util/zip/Deflater;)V
invokespecial org.xnio.conduits.ConduitStreamSinkChannel.<init>:(Lorg/xnio/channels/Configurable;Lorg/xnio/conduits/StreamSinkConduit;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
0 1 1 delegate Lorg/xnio/channels/StreamSinkChannel;
0 1 2 deflater Ljava/util/zip/Deflater;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
delegate final
deflater final
public org.xnio.ChannelPipe<org.xnio.channels.StreamChannel, org.xnio.channels.StreamChannel> createFullDuplexPipe();
descriptor: ()Lorg/xnio/ChannelPipe;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.xnio.XnioWorker.chooseThread:()Lorg/xnio/XnioIoThread;
invokevirtual org.xnio.XnioIoThread.createFullDuplexPipe:()Lorg/xnio/ChannelPipe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
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=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.xnio.XnioWorker.chooseThread:()Lorg/xnio/XnioIoThread;
invokevirtual org.xnio.XnioIoThread.createFullDuplexPipeConnection:()Lorg/xnio/ChannelPipe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
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=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.xnio.XnioWorker.chooseThread:()Lorg/xnio/XnioIoThread;
invokevirtual org.xnio.XnioIoThread.createHalfDuplexPipe:()Lorg/xnio/ChannelPipe;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
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: aload 0
invokevirtual org.xnio.XnioWorker.chooseThread:()Lorg/xnio/XnioIoThread;
aload 1
invokevirtual org.xnio.XnioIoThread.createFullDuplexPipeConnection:(Lorg/xnio/XnioIoFactory;)Lorg/xnio/ChannelPipe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
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: aload 0
invokevirtual org.xnio.XnioWorker.chooseThread:()Lorg/xnio/XnioIoThread;
aload 1
invokevirtual org.xnio.XnioIoThread.createHalfDuplexPipe:(Lorg/xnio/XnioIoFactory;)Lorg/xnio/ChannelPipe;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
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
public abstract void shutdown();
descriptor: ()V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public abstract java.util.List<java.lang.Runnable> shutdownNow();
descriptor: ()Ljava/util/List;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: ()Ljava/util/List<Ljava/lang/Runnable;>;
public abstract boolean isShutdown();
descriptor: ()Z
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public abstract boolean isTerminated();
descriptor: ()Z
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public abstract boolean awaitTermination(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)Z
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Exceptions:
throws java.lang.InterruptedException
MethodParameters:
Name Flags
timeout final
unit final
public abstract void awaitTermination();
descriptor: ()V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Exceptions:
throws java.lang.InterruptedException
public final org.xnio.XnioIoThread getIoThread();
descriptor: ()Lorg/xnio/XnioIoThread;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.xnio.XnioWorker.chooseThread:()Lorg/xnio/XnioIoThread;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
public abstract org.xnio.XnioIoThread getIoThread(int);
descriptor: (I)Lorg/xnio/XnioIoThread;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
MethodParameters:
Name Flags
hashCode
protected java.lang.Runnable getTerminationTask();
descriptor: ()Ljava/lang/Runnable;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.xnio.XnioWorker.terminationTask:Ljava/lang/Runnable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
protected void taskPoolTerminated();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=0, locals=1, args_size=1
start local 0 0: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
protected void shutDownTaskPool();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.xnio.XnioWorker.isTaskPoolExternal:()Z
ifeq 3
1: aload 0
invokevirtual org.xnio.XnioWorker.taskPoolTerminated:()V
2: goto 4
3: StackMap locals:
StackMap stack:
new org.xnio.XnioWorker$5
dup
aload 0
invokespecial org.xnio.XnioWorker$5.<init>:(Lorg/xnio/XnioWorker;)V
invokestatic java.security.AccessController.doPrivileged:(Ljava/security/PrivilegedAction;)Ljava/lang/Object;
pop
4: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/xnio/XnioWorker;
protected java.util.List<java.lang.Runnable> shutDownTaskPoolNow();
descriptor: ()Ljava/util/List;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.xnio.XnioWorker.isTaskPoolExternal:()Z
ifne 1
new org.xnio.XnioWorker$6
dup
aload 0
invokespecial org.xnio.XnioWorker$6.<init>:(Lorg/xnio/XnioWorker;)V
invokestatic java.security.AccessController.doPrivileged:(Ljava/security/PrivilegedAction;)Ljava/lang/Object;
checkcast java.util.List
areturn
1: StackMap locals:
StackMap stack:
invokestatic java.util.Collections.emptyList:()Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/xnio/XnioWorker;
Signature: ()Ljava/util/List<Ljava/lang/Runnable;>;
protected boolean isTaskPoolExternal();
descriptor: ()Z
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
instanceof org.xnio.XnioWorker$ExternalTaskPool
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
public void execute(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
aload 1
invokeinterface org.xnio.XnioWorker$TaskPool.execute:(Ljava/lang/Runnable;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/xnio/XnioWorker;
0 2 1 command Ljava/lang/Runnable;
MethodParameters:
Name Flags
command final
public abstract int getIoThreadCount();
descriptor: ()I
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public boolean supportsOption(org.xnio.Option<?>);
descriptor: (Lorg/xnio/Option;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
instanceof org.xnio.XnioWorker$ExternalTaskPool
ifeq 1
getstatic org.xnio.XnioWorker.EXTERNAL_POOL_OPTIONS:Ljava/util/Set;
aload 1
invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
goto 2
StackMap locals:
StackMap stack:
1: getstatic org.xnio.XnioWorker.OPTIONS:Ljava/util/Set;
aload 1
invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
StackMap locals:
StackMap stack: int
2: ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/xnio/XnioWorker;
0 3 1 option Lorg/xnio/Option<*>;
Signature: (Lorg/xnio/Option<*>;)Z
MethodParameters:
Name Flags
option final
public <T> T getOption(org.xnio.Option<T>);
descriptor: (Lorg/xnio/Option;)Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual org.xnio.XnioWorker.supportsOption:(Lorg/xnio/Option;)Z
ifne 2
1: aconst_null
areturn
2: StackMap locals:
StackMap stack:
aload 1
getstatic org.xnio.Options.WORKER_TASK_CORE_THREADS:Lorg/xnio/Option;
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 4
3: aload 1
aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
invokeinterface org.xnio.XnioWorker$TaskPool.getCorePoolSize:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual org.xnio.Option.cast:(Ljava/lang/Object;)Ljava/lang/Object;
areturn
4: StackMap locals:
StackMap stack:
aload 1
getstatic org.xnio.Options.WORKER_TASK_MAX_THREADS:Lorg/xnio/Option;
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 6
5: aload 1
aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
invokeinterface org.xnio.XnioWorker$TaskPool.getMaximumPoolSize:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual org.xnio.Option.cast:(Ljava/lang/Object;)Ljava/lang/Object;
areturn
6: StackMap locals:
StackMap stack:
aload 1
getstatic org.xnio.Options.WORKER_TASK_KEEPALIVE:Lorg/xnio/Option;
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
7: aload 1
ldc 2147483647
aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface org.xnio.XnioWorker$TaskPool.getKeepAliveTime:(Ljava/util/concurrent/TimeUnit;)J
invokestatic java.lang.Math.min:(JJ)J
l2i
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual org.xnio.Option.cast:(Ljava/lang/Object;)Ljava/lang/Object;
areturn
8: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/xnio/XnioWorker;
0 9 1 option Lorg/xnio/Option<TT;>;
Exceptions:
throws java.io.IOException
Signature: <T:Ljava/lang/Object;>(Lorg/xnio/Option<TT;>;)TT;
MethodParameters:
Name Flags
option final
public <T> T setOption(org.xnio.Option<T>, );
descriptor: (Lorg/xnio/Option;Ljava/lang/Object;)Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual org.xnio.XnioWorker.supportsOption:(Lorg/xnio/Option;)Z
ifne 2
1: aconst_null
areturn
2: StackMap locals:
StackMap stack:
aload 1
getstatic org.xnio.Options.WORKER_TASK_CORE_THREADS:Lorg/xnio/Option;
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 6
3: aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
invokeinterface org.xnio.XnioWorker$TaskPool.getCorePoolSize:()I
istore 3
start local 3 4: aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
getstatic org.xnio.Options.WORKER_TASK_CORE_THREADS:Lorg/xnio/Option;
aload 2
invokevirtual org.xnio.Option.cast:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
invokeinterface org.xnio.XnioWorker$TaskPool.setCorePoolSize:(I)V
5: aload 1
iload 3
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual org.xnio.Option.cast:(Ljava/lang/Object;)Ljava/lang/Object;
areturn
end local 3 6: StackMap locals:
StackMap stack:
aload 1
getstatic org.xnio.Options.WORKER_TASK_MAX_THREADS:Lorg/xnio/Option;
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
7: aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
invokeinterface org.xnio.XnioWorker$TaskPool.getMaximumPoolSize:()I
istore 3
start local 3 8: aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
getstatic org.xnio.Options.WORKER_TASK_MAX_THREADS:Lorg/xnio/Option;
aload 2
invokevirtual org.xnio.Option.cast:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
invokeinterface org.xnio.XnioWorker$TaskPool.setMaximumPoolSize:(I)V
9: aload 1
iload 3
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual org.xnio.Option.cast:(Ljava/lang/Object;)Ljava/lang/Object;
areturn
end local 3 10: StackMap locals:
StackMap stack:
aload 1
getstatic org.xnio.Options.WORKER_TASK_KEEPALIVE:Lorg/xnio/Option;
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 14
11: aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface org.xnio.XnioWorker$TaskPool.getKeepAliveTime:(Ljava/util/concurrent/TimeUnit;)J
lstore 3
start local 3 12: aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
getstatic org.xnio.Options.WORKER_TASK_KEEPALIVE:Lorg/xnio/Option;
aload 2
invokevirtual org.xnio.Option.cast:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
i2l
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface org.xnio.XnioWorker$TaskPool.setKeepAliveTime:(JLjava/util/concurrent/TimeUnit;)V
13: aload 1
ldc 2147483647
lload 3
invokestatic java.lang.Math.min:(JJ)J
l2i
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual org.xnio.Option.cast:(Ljava/lang/Object;)Ljava/lang/Object;
areturn
end local 3 14: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lorg/xnio/XnioWorker;
0 15 1 option Lorg/xnio/Option<TT;>;
0 15 2 value TT;
4 6 3 old I
8 10 3 old I
12 14 3 old J
Exceptions:
throws java.lang.IllegalArgumentException, java.io.IOException
Signature: <T:Ljava/lang/Object;>(Lorg/xnio/Option<TT;>;TT;)TT;
MethodParameters:
Name Flags
option final
value final
public org.xnio.Xnio getXnio();
descriptor: ()Lorg/xnio/Xnio;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.xnio.XnioWorker.xnio:Lorg/xnio/Xnio;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
public java.lang.String getName();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.xnio.XnioWorker.name:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
protected abstract org.xnio.XnioIoThread chooseThread();
descriptor: ()Lorg/xnio/XnioIoThread;
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
protected final int getCoreWorkerPoolSize();
descriptor: ()I
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
invokeinterface org.xnio.XnioWorker$TaskPool.getCorePoolSize:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
protected final int getBusyWorkerThreadCount();
descriptor: ()I
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
invokeinterface org.xnio.XnioWorker$TaskPool.getActiveCount:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
protected final int getMaxWorkerPoolSize();
descriptor: ()I
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
invokeinterface org.xnio.XnioWorker$TaskPool.getMaximumPoolSize:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
protected final int getWorkerQueueSize();
descriptor: ()I
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.xnio.XnioWorker.taskPool:Lorg/xnio/XnioWorker$TaskPool;
invokeinterface org.xnio.XnioWorker$TaskPool.getQueueSize:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
protected org.wildfly.common.net.CidrAddressTable<java.net.InetSocketAddress> getBindAddressTable();
descriptor: ()Lorg/wildfly/common/net/CidrAddressTable;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.xnio.XnioWorker.bindAddressTable:Lorg/wildfly/common/net/CidrAddressTable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
Signature: ()Lorg/wildfly/common/net/CidrAddressTable<Ljava/net/InetSocketAddress;>;
public java.net.InetSocketAddress getBindAddress(java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;)Ljava/net/InetSocketAddress;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.xnio.XnioWorker.bindAddressTable:Lorg/wildfly/common/net/CidrAddressTable;
aload 1
invokevirtual org.wildfly.common.net.CidrAddressTable.get:(Ljava/net/InetAddress;)Ljava/lang/Object;
checkcast java.net.InetSocketAddress
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/xnio/XnioWorker;
0 1 1 destination Ljava/net/InetAddress;
MethodParameters:
Name Flags
destination
public abstract org.xnio.management.XnioWorkerMXBean getMXBean();
descriptor: ()Lorg/xnio/management/XnioWorkerMXBean;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
protected abstract org.xnio.ManagementRegistration registerServerMXBean(org.xnio.management.XnioServerMXBean);
descriptor: (Lorg/xnio/management/XnioServerMXBean;)Lorg/xnio/ManagementRegistration;
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
MethodParameters:
Name Flags
metrics
static int[] $SWITCH_TABLE$org$xnio$CompressionType();
descriptor: ()[I
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=0
0: getstatic org.xnio.XnioWorker.$SWITCH_TABLE$org$xnio$CompressionType:[I
dup
ifnull 1
areturn
StackMap locals:
StackMap stack: int[]
1: pop
invokestatic org.xnio.CompressionType.values:()[Lorg/xnio/CompressionType;
arraylength
newarray 10
astore 0
2: aload 0
getstatic org.xnio.CompressionType.DEFLATE:Lorg/xnio/CompressionType;
invokevirtual org.xnio.CompressionType.ordinal:()I
iconst_1
iastore
3: goto 5
StackMap locals: int[]
StackMap stack: java.lang.NoSuchFieldError
4: pop
StackMap locals:
StackMap stack:
5: aload 0
getstatic org.xnio.CompressionType.GZIP:Lorg/xnio/CompressionType;
invokevirtual org.xnio.CompressionType.ordinal:()I
iconst_2
iastore
6: goto 8
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
7: pop
StackMap locals:
StackMap stack:
8: aload 0
dup
putstatic org.xnio.XnioWorker.$SWITCH_TABLE$org$xnio$CompressionType:[I
areturn
LocalVariableTable:
Start End Slot Name Signature
Exception table:
from to target type
2 3 4 Class java.lang.NoSuchFieldError
5 6 7 Class java.lang.NoSuchFieldError
private static org.wildfly.common.context.ContextManager lambda$0();
descriptor: ()Lorg/wildfly/common/context/ContextManager;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=0, args_size=0
0: new org.wildfly.common.context.ContextManager
dup
ldc Lorg/xnio/XnioWorker;
ldc "org.xnio.worker"
invokespecial org.wildfly.common.context.ContextManager.<init>:(Ljava/lang/Class;Ljava/lang/String;)V
areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.lang.Void lambda$1();
descriptor: ()Ljava/lang/Void;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=0, args_size=0
0: getstatic org.xnio.XnioWorker.CONTEXT_MANAGER:Lorg/wildfly/common/context/ContextManager;
invokedynamic get()Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
org/xnio/XnioWorker.lambda$2()Lorg/xnio/XnioWorker; (6)
()Lorg/xnio/XnioWorker;
invokevirtual org.wildfly.common.context.ContextManager.setGlobalDefaultSupplier:(Ljava/util/function/Supplier;)V
1: aconst_null
areturn
LocalVariableTable:
Start End Slot Name Signature
private static org.xnio.XnioWorker lambda$2();
descriptor: ()Lorg/xnio/XnioWorker;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=0, args_size=0
0: getstatic org.xnio.DefaultXnioWorkerHolder.INSTANCE:Lorg/xnio/XnioWorker;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
Signature: Ljava/util/concurrent/AbstractExecutorService;Lorg/xnio/channels/Configurable;Ljava/util/concurrent/ExecutorService;Lorg/xnio/XnioIoFactory;Lorg/wildfly/common/context/Contextual<Lorg/xnio/XnioWorker;>;
SourceFile: "XnioWorker.java"
NestMembers:
org.xnio.XnioWorker$1 org.xnio.XnioWorker$2 org.xnio.XnioWorker$3 org.xnio.XnioWorker$4 org.xnio.XnioWorker$5 org.xnio.XnioWorker$6 org.xnio.XnioWorker$Builder org.xnio.XnioWorker$EnhancedQueueExecutorTaskPool org.xnio.XnioWorker$ExternalTaskPool org.xnio.XnioWorker$MessageConnectionWrapListener org.xnio.XnioWorker$StreamConnectionWrapListener org.xnio.XnioWorker$TaskPool org.xnio.XnioWorker$ThreadPoolExecutorTaskPool org.xnio.XnioWorker$WorkerThreadFactory org.xnio.XnioWorker$WorkerThreadFactory$1
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public final Builder = org.jboss.threads.EnhancedQueueExecutor$Builder of org.jboss.threads.EnhancedQueueExecutor
public abstract Setter = org.xnio.ChannelListener$Setter of org.xnio.ChannelListener
public abstract HandlingNotifier = org.xnio.IoFuture$HandlingNotifier of org.xnio.IoFuture
public abstract Notifier = org.xnio.IoFuture$Notifier of org.xnio.IoFuture
public SetBuilder = org.xnio.Option$SetBuilder of org.xnio.Option
org.xnio.XnioWorker$1
org.xnio.XnioWorker$2
org.xnio.XnioWorker$3
org.xnio.XnioWorker$4
org.xnio.XnioWorker$5
org.xnio.XnioWorker$6
public Builder = org.xnio.XnioWorker$Builder of org.xnio.XnioWorker
EnhancedQueueExecutorTaskPool = org.xnio.XnioWorker$EnhancedQueueExecutorTaskPool of org.xnio.XnioWorker
ExternalTaskPool = org.xnio.XnioWorker$ExternalTaskPool of org.xnio.XnioWorker
MessageConnectionWrapListener = org.xnio.XnioWorker$MessageConnectionWrapListener of org.xnio.XnioWorker
StreamConnectionWrapListener = org.xnio.XnioWorker$StreamConnectionWrapListener of org.xnio.XnioWorker
abstract TaskPool = org.xnio.XnioWorker$TaskPool of org.xnio.XnioWorker
ThreadPoolExecutorTaskPool = org.xnio.XnioWorker$ThreadPoolExecutorTaskPool of org.xnio.XnioWorker
WorkerThreadFactory = org.xnio.XnioWorker$WorkerThreadFactory of org.xnio.XnioWorker
XnioWorker
xnio: Xnio
<clinit>(): void
<init>(XnioWorker$Builder): void
