public class org.eclipse.jetty.io.ManagedSelector extends org.eclipse.jetty.util.component.ContainerLifeCycle implements org.eclipse.jetty.util.component.Dumpable
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.eclipse.jetty.io.ManagedSelector
super_class: org.eclipse.jetty.util.component.ContainerLifeCycle
{
private static final org.slf4j.Logger LOG;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final boolean FORCE_SELECT_NOW;
descriptor: Z
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final org.eclipse.jetty.util.thread.AutoLock _lock;
descriptor: Lorg/eclipse/jetty/util/thread/AutoLock;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.AtomicBoolean _started;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private boolean _selecting;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private final org.eclipse.jetty.io.SelectorManager _selectorManager;
descriptor: Lorg/eclipse/jetty/io/SelectorManager;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final int _id;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.eclipse.jetty.util.thread.ExecutionStrategy _strategy;
descriptor: Lorg/eclipse/jetty/util/thread/ExecutionStrategy;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private java.nio.channels.Selector _selector;
descriptor: Ljava/nio/channels/Selector;
flags: (0x0002) ACC_PRIVATE
private java.util.Deque<org.eclipse.jetty.io.ManagedSelector$SelectorUpdate> _updates;
descriptor: Ljava/util/Deque;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/Deque<Lorg/eclipse/jetty/io/ManagedSelector$SelectorUpdate;>;
private java.util.Deque<org.eclipse.jetty.io.ManagedSelector$SelectorUpdate> _updateable;
descriptor: Ljava/util/Deque;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/Deque<Lorg/eclipse/jetty/io/ManagedSelector$SelectorUpdate;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=1, args_size=0
0: ldc Lorg/eclipse/jetty/io/ManagedSelector;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
1: ldc "org.eclipse.jetty.io.forceSelectNow"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
astore 0
start local 0 2: aload 0
ifnull 5
3: aload 0
invokestatic java.lang.Boolean.parseBoolean:(Ljava/lang/String;)Z
putstatic org.eclipse.jetty.io.ManagedSelector.FORCE_SELECT_NOW:Z
4: goto 9
5: StackMap locals: java.lang.String
StackMap stack:
ldc "os.name"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
astore 0
6: aload 0
ifnull 7
aload 0
getstatic java.util.Locale.ENGLISH:Ljava/util/Locale;
invokevirtual java.lang.String.toLowerCase:(Ljava/util/Locale;)Ljava/lang/String;
ldc "windows"
invokevirtual java.lang.String.contains:(Ljava/lang/CharSequence;)Z
ifeq 7
iconst_1
goto 8
StackMap locals:
StackMap stack:
7: iconst_0
StackMap locals:
StackMap stack: int
8: putstatic org.eclipse.jetty.io.ManagedSelector.FORCE_SELECT_NOW:Z
end local 0 9: StackMap locals:
StackMap stack:
return
LocalVariableTable:
Start End Slot Name Signature
2 9 0 property Ljava/lang/String;
public void <init>(org.eclipse.jetty.io.SelectorManager, int);
descriptor: (Lorg/eclipse/jetty/io/SelectorManager;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial org.eclipse.jetty.util.component.ContainerLifeCycle.<init>:()V
1: aload 0
new org.eclipse.jetty.util.thread.AutoLock
dup
invokespecial org.eclipse.jetty.util.thread.AutoLock.<init>:()V
putfield org.eclipse.jetty.io.ManagedSelector._lock:Lorg/eclipse/jetty/util/thread/AutoLock;
2: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
iconst_0
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:(Z)V
putfield org.eclipse.jetty.io.ManagedSelector._started:Ljava/util/concurrent/atomic/AtomicBoolean;
3: aload 0
new java.util.ArrayDeque
dup
invokespecial java.util.ArrayDeque.<init>:()V
putfield org.eclipse.jetty.io.ManagedSelector._updates:Ljava/util/Deque;
4: aload 0
new java.util.ArrayDeque
dup
invokespecial java.util.ArrayDeque.<init>:()V
putfield org.eclipse.jetty.io.ManagedSelector._updateable:Ljava/util/Deque;
5: aload 0
aload 1
putfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
6: aload 0
iload 2
putfield org.eclipse.jetty.io.ManagedSelector._id:I
7: new org.eclipse.jetty.io.ManagedSelector$SelectorProducer
dup
aload 0
invokespecial org.eclipse.jetty.io.ManagedSelector$SelectorProducer.<init>:(Lorg/eclipse/jetty/io/ManagedSelector;)V
astore 3
start local 3 8: aload 1
invokevirtual org.eclipse.jetty.io.SelectorManager.getExecutor:()Ljava/util/concurrent/Executor;
astore 4
start local 4 9: aload 0
new org.eclipse.jetty.util.thread.strategy.EatWhatYouKill
dup
aload 3
aload 4
invokespecial org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.<init>:(Lorg/eclipse/jetty/util/thread/ExecutionStrategy$Producer;Ljava/util/concurrent/Executor;)V
putfield org.eclipse.jetty.io.ManagedSelector._strategy:Lorg/eclipse/jetty/util/thread/ExecutionStrategy;
10: aload 0
aload 0
getfield org.eclipse.jetty.io.ManagedSelector._strategy:Lorg/eclipse/jetty/util/thread/ExecutionStrategy;
iconst_1
invokevirtual org.eclipse.jetty.io.ManagedSelector.addBean:(Ljava/lang/Object;Z)Z
pop
11: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/eclipse/jetty/io/ManagedSelector;
0 12 1 selectorManager Lorg/eclipse/jetty/io/SelectorManager;
0 12 2 id I
8 12 3 producer Lorg/eclipse/jetty/io/ManagedSelector$SelectorProducer;
9 12 4 executor Ljava/util/concurrent/Executor;
MethodParameters:
Name Flags
selectorManager
id
public java.nio.channels.Selector getSelector();
descriptor: ()Ljava/nio/channels/Selector;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selector:Ljava/nio/channels/Selector;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/io/ManagedSelector;
protected void doStart();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=3, args_size=1
start local 0 0: aload 0
invokespecial org.eclipse.jetty.util.component.ContainerLifeCycle.doStart:()V
1: aload 0
aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
invokevirtual org.eclipse.jetty.io.SelectorManager.newSelector:()Ljava/nio/channels/Selector;
putfield org.eclipse.jetty.io.ManagedSelector._selector:Ljava/nio/channels/Selector;
2: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
aload 0
getfield org.eclipse.jetty.io.ManagedSelector._strategy:Lorg/eclipse/jetty/util/thread/ExecutionStrategy;
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic run(Lorg/eclipse/jetty/util/thread/ExecutionStrategy;)Ljava/lang/Runnable;
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:
()V
org/eclipse/jetty/util/thread/ExecutionStrategy.produce()V (9 itf)
()V
invokevirtual org.eclipse.jetty.io.SelectorManager.execute:(Ljava/lang/Runnable;)V
3: new org.eclipse.jetty.io.ManagedSelector$Start
dup
aload 0
invokespecial org.eclipse.jetty.io.ManagedSelector$Start.<init>:(Lorg/eclipse/jetty/io/ManagedSelector;)V
astore 2
start local 2 4: aload 0
aload 2
invokevirtual org.eclipse.jetty.io.ManagedSelector.submit:(Lorg/eclipse/jetty/io/ManagedSelector$SelectorUpdate;)V
5: aload 2
getfield org.eclipse.jetty.io.ManagedSelector$Start._started:Ljava/util/concurrent/CountDownLatch;
invokevirtual java.util.concurrent.CountDownLatch.await:()V
6: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/eclipse/jetty/io/ManagedSelector;
4 7 2 start Lorg/eclipse/jetty/io/ManagedSelector$Start;
Exceptions:
throws java.lang.Exception
protected void doStop();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=3, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._started:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_1
iconst_0
invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
ifeq 7
aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selector:Ljava/nio/channels/Selector;
ifnull 7
1: new org.eclipse.jetty.io.ManagedSelector$CloseConnections
dup
aload 0
invokespecial org.eclipse.jetty.io.ManagedSelector$CloseConnections.<init>:(Lorg/eclipse/jetty/io/ManagedSelector;)V
astore 1
start local 1 2: aload 0
aload 1
invokevirtual org.eclipse.jetty.io.ManagedSelector.submit:(Lorg/eclipse/jetty/io/ManagedSelector$SelectorUpdate;)V
3: aload 1
getfield org.eclipse.jetty.io.ManagedSelector$CloseConnections._complete:Ljava/util/concurrent/CountDownLatch;
invokevirtual java.util.concurrent.CountDownLatch.await:()V
4: new org.eclipse.jetty.io.ManagedSelector$StopSelector
dup
aload 0
invokespecial org.eclipse.jetty.io.ManagedSelector$StopSelector.<init>:(Lorg/eclipse/jetty/io/ManagedSelector;)V
astore 2
start local 2 5: aload 0
aload 2
invokevirtual org.eclipse.jetty.io.ManagedSelector.submit:(Lorg/eclipse/jetty/io/ManagedSelector$SelectorUpdate;)V
6: aload 2
getfield org.eclipse.jetty.io.ManagedSelector$StopSelector._stopped:Ljava/util/concurrent/CountDownLatch;
invokevirtual java.util.concurrent.CountDownLatch.await:()V
end local 2 end local 1 7: StackMap locals:
StackMap stack:
aload 0
invokespecial org.eclipse.jetty.util.component.ContainerLifeCycle.doStop:()V
8: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/eclipse/jetty/io/ManagedSelector;
2 7 1 closeConnections Lorg/eclipse/jetty/io/ManagedSelector$CloseConnections;
5 7 2 stopSelector Lorg/eclipse/jetty/io/ManagedSelector$StopSelector;
Exceptions:
throws java.lang.Exception
protected int nioSelect(java.nio.channels.Selector, boolean);
descriptor: (Ljava/nio/channels/Selector;Z)I
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=3, args_size=3
start local 0 start local 1 start local 2 0: iload 2
ifeq 1
aload 1
invokevirtual java.nio.channels.Selector.selectNow:()I
goto 2
StackMap locals:
StackMap stack:
1: aload 1
invokevirtual java.nio.channels.Selector.select:()I
StackMap locals:
StackMap stack: int
2: ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/eclipse/jetty/io/ManagedSelector;
0 3 1 selector Ljava/nio/channels/Selector;
0 3 2 now Z
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
selector
now
protected int select(java.nio.channels.Selector);
descriptor: (Ljava/nio/channels/Selector;)I
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
iconst_0
invokevirtual org.eclipse.jetty.io.ManagedSelector.nioSelect:(Ljava/nio/channels/Selector;Z)I
istore 2
start local 2 1: iload 2
ifne 8
2: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
ifeq 4
3: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
ldc "Selector {} woken with none selected"
aload 1
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
4: StackMap locals: int
StackMap stack:
invokestatic java.lang.Thread.interrupted:()Z
ifeq 6
aload 0
invokevirtual org.eclipse.jetty.io.ManagedSelector.isRunning:()Z
ifne 6
5: new java.nio.channels.ClosedSelectorException
dup
invokespecial java.nio.channels.ClosedSelectorException.<init>:()V
athrow
6: StackMap locals:
StackMap stack:
getstatic org.eclipse.jetty.io.ManagedSelector.FORCE_SELECT_NOW:Z
ifeq 8
7: aload 0
aload 1
iconst_1
invokevirtual org.eclipse.jetty.io.ManagedSelector.nioSelect:(Ljava/nio/channels/Selector;Z)I
istore 2
8: StackMap locals:
StackMap stack:
iload 2
9: ireturn
end local 2 10: StackMap locals: org.eclipse.jetty.io.ManagedSelector java.nio.channels.Selector
StackMap stack: java.nio.channels.ClosedSelectorException
astore 2
start local 2 11: aload 2
athrow
end local 2 12: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
start local 2 13: aload 0
aload 1
aload 2
invokevirtual org.eclipse.jetty.io.ManagedSelector.handleSelectFailure:(Ljava/nio/channels/Selector;Ljava/lang/Throwable;)V
14: iconst_0
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lorg/eclipse/jetty/io/ManagedSelector;
0 15 1 selector Ljava/nio/channels/Selector;
1 10 2 selected I
11 12 2 x Ljava/nio/channels/ClosedSelectorException;
13 15 2 x Ljava/lang/Throwable;
Exception table:
from to target type
0 9 10 Class java.nio.channels.ClosedSelectorException
0 9 12 Class java.lang.Throwable
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
selector
protected void handleSelectFailure(java.nio.channels.Selector, java.lang.Throwable);
descriptor: (Ljava/nio/channels/Selector;Ljava/lang/Throwable;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=6, locals=10, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
ldc "Caught select() failure, trying to recover: {}"
aload 2
invokevirtual java.lang.Throwable.toString:()Ljava/lang/String;
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;)V
1: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
ifeq 3
2: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
ldc ""
aload 2
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Throwable;)V
3: StackMap locals:
StackMap stack:
aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
invokevirtual org.eclipse.jetty.io.SelectorManager.newSelector:()Ljava/nio/channels/Selector;
astore 3
start local 3 4: aload 1
invokevirtual java.nio.channels.Selector.keys:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 25
StackMap locals: org.eclipse.jetty.io.ManagedSelector java.nio.channels.Selector java.lang.Throwable java.nio.channels.Selector top java.util.Iterator
StackMap stack:
5: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.nio.channels.SelectionKey
astore 4
start local 4 6: aload 4
invokevirtual java.nio.channels.SelectionKey.channel:()Ljava/nio/channels/SelectableChannel;
astore 6
start local 6 7: aload 4
invokestatic org.eclipse.jetty.io.ManagedSelector.safeInterestOps:(Ljava/nio/channels/SelectionKey;)I
istore 7
start local 7 8: iload 7
iflt 22
9: aload 4
invokevirtual java.nio.channels.SelectionKey.attachment:()Ljava/lang/Object;
astore 8
start local 8 10: aload 6
aload 3
iload 7
aload 8
invokevirtual java.nio.channels.SelectableChannel.register:(Ljava/nio/channels/Selector;ILjava/lang/Object;)Ljava/nio/channels/SelectionKey;
astore 9
start local 9 11: aload 8
instanceof org.eclipse.jetty.io.ManagedSelector$Selectable
ifeq 13
12: aload 8
checkcast org.eclipse.jetty.io.ManagedSelector$Selectable
aload 9
invokeinterface org.eclipse.jetty.io.ManagedSelector$Selectable.replaceKey:(Ljava/nio/channels/SelectionKey;)V
13: StackMap locals: org.eclipse.jetty.io.ManagedSelector java.nio.channels.Selector java.lang.Throwable java.nio.channels.Selector java.nio.channels.SelectionKey java.util.Iterator java.nio.channels.SelectableChannel int java.lang.Object java.nio.channels.SelectionKey
StackMap stack:
aload 4
invokevirtual java.nio.channels.SelectionKey.cancel:()V
14: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
ifeq 25
15: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
ldc "Transferred {} iOps={} att={}"
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 6
aastore
dup
iconst_1
iload 7
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
aload 8
aastore
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
end local 9 end local 8 16: goto 25
17: StackMap locals: org.eclipse.jetty.io.ManagedSelector java.nio.channels.Selector java.lang.Throwable java.nio.channels.Selector java.nio.channels.SelectionKey java.util.Iterator java.nio.channels.SelectableChannel int
StackMap stack: java.lang.Throwable
astore 8
start local 8 18: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
ifeq 20
19: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
ldc "Could not transfer {}"
aload 6
aload 8
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
20: StackMap locals: java.lang.Throwable
StackMap stack:
aload 6
invokestatic org.eclipse.jetty.util.IO.close:(Ljava/io/Closeable;)V
end local 8 21: goto 25
22: StackMap locals:
StackMap stack:
getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
ifeq 24
23: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
ldc "Invalid interestOps for {}"
aload 6
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
24: StackMap locals:
StackMap stack:
aload 6
invokestatic org.eclipse.jetty.util.IO.close:(Ljava/io/Closeable;)V
end local 7 end local 6 end local 4 25: StackMap locals: org.eclipse.jetty.io.ManagedSelector java.nio.channels.Selector java.lang.Throwable java.nio.channels.Selector top java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
26: aload 1
invokestatic org.eclipse.jetty.util.IO.close:(Ljava/io/Closeable;)V
27: aload 0
aload 3
putfield org.eclipse.jetty.io.ManagedSelector._selector:Ljava/nio/channels/Selector;
28: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 29 0 this Lorg/eclipse/jetty/io/ManagedSelector;
0 29 1 selector Ljava/nio/channels/Selector;
0 29 2 failure Ljava/lang/Throwable;
4 29 3 newSelector Ljava/nio/channels/Selector;
6 25 4 oldKey Ljava/nio/channels/SelectionKey;
7 25 6 channel Ljava/nio/channels/SelectableChannel;
8 25 7 interestOps I
10 16 8 attachment Ljava/lang/Object;
11 16 9 newKey Ljava/nio/channels/SelectionKey;
18 21 8 t Ljava/lang/Throwable;
Exception table:
from to target type
9 16 17 Class java.lang.Throwable
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
selector
failure
protected void onSelectFailed(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=0, locals=2, args_size=2
start local 0 start local 1 0: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/eclipse/jetty/io/ManagedSelector;
0 1 1 cause Ljava/lang/Throwable;
MethodParameters:
Name Flags
cause
public int size();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=3, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selector:Ljava/nio/channels/Selector;
astore 1
start local 1 1: aload 1
ifnonnull 3
2: iconst_0
ireturn
3: StackMap locals: java.nio.channels.Selector
StackMap stack:
aload 1
invokevirtual java.nio.channels.Selector.keys:()Ljava/util/Set;
astore 2
start local 2 4: aload 2
ifnonnull 6
5: iconst_0
ireturn
6: StackMap locals: java.util.Set
StackMap stack:
aload 2
invokeinterface java.util.Set.size:()I
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/eclipse/jetty/io/ManagedSelector;
1 7 1 s Ljava/nio/channels/Selector;
4 7 2 keys Ljava/util/Set<Ljava/nio/channels/SelectionKey;>;
public void submit(org.eclipse.jetty.io.ManagedSelector$SelectorUpdate);
descriptor: (Lorg/eclipse/jetty/io/ManagedSelector$SelectorUpdate;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
iconst_0
invokevirtual org.eclipse.jetty.io.ManagedSelector.submit:(Lorg/eclipse/jetty/io/ManagedSelector$SelectorUpdate;Z)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/io/ManagedSelector;
0 2 1 update Lorg/eclipse/jetty/io/ManagedSelector$SelectorUpdate;
MethodParameters:
Name Flags
update
private void submit(org.eclipse.jetty.io.ManagedSelector$SelectorUpdate, boolean);
descriptor: (Lorg/eclipse/jetty/io/ManagedSelector$SelectorUpdate;Z)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=7, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
ifeq 2
1: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
ldc "Queued change lazy={} {} on {}"
iconst_3
anewarray java.lang.Object
dup
iconst_0
iload 2
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 0
aastore
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
aconst_null
astore 3
start local 3 3: aconst_null
astore 4
aconst_null
astore 5
4: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._lock:Lorg/eclipse/jetty/util/thread/AutoLock;
invokevirtual org.eclipse.jetty.util.thread.AutoLock.lock:()Lorg/eclipse/jetty/util/thread/AutoLock;
astore 6
start local 6 5: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._updates:Ljava/util/Deque;
aload 1
invokeinterface java.util.Deque.offer:(Ljava/lang/Object;)Z
pop
6: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selecting:Z
ifeq 9
iload 2
ifne 9
7: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selector:Ljava/nio/channels/Selector;
astore 3
8: aload 0
iconst_0
putfield org.eclipse.jetty.io.ManagedSelector._selecting:Z
9: StackMap locals: org.eclipse.jetty.io.ManagedSelector org.eclipse.jetty.io.ManagedSelector$SelectorUpdate int java.nio.channels.Selector java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.AutoLock
StackMap stack:
aload 6
ifnull 15
aload 6
invokevirtual org.eclipse.jetty.util.thread.AutoLock.close:()V
goto 15
StackMap locals:
StackMap stack: java.lang.Throwable
10: astore 4
aload 6
ifnull 11
aload 6
invokevirtual org.eclipse.jetty.util.thread.AutoLock.close:()V
end local 6 StackMap locals:
StackMap stack:
11: aload 4
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
12: astore 5
aload 4
ifnonnull 13
aload 5
astore 4
goto 14
StackMap locals:
StackMap stack:
13: aload 4
aload 5
if_acmpeq 14
aload 4
aload 5
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
14: aload 4
athrow
15: StackMap locals:
StackMap stack:
aload 3
ifnull 19
16: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
ifeq 18
17: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
ldc "Wakeup on submit {}"
aload 0
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
18: StackMap locals:
StackMap stack:
aload 3
invokevirtual java.nio.channels.Selector.wakeup:()Ljava/nio/channels/Selector;
pop
19: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lorg/eclipse/jetty/io/ManagedSelector;
0 20 1 update Lorg/eclipse/jetty/io/ManagedSelector$SelectorUpdate;
0 20 2 lazy Z
3 20 3 selector Ljava/nio/channels/Selector;
5 11 6 l Lorg/eclipse/jetty/util/thread/AutoLock;
Exception table:
from to target type
5 9 10 any
4 12 12 any
MethodParameters:
Name Flags
update
lazy
private void wakeup();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=5, args_size=1
start local 0 0: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
ifeq 2
1: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
ldc "Wakeup {}"
aload 0
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
aconst_null
astore 1
start local 1 3: aconst_null
astore 2
aconst_null
astore 3
4: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._lock:Lorg/eclipse/jetty/util/thread/AutoLock;
invokevirtual org.eclipse.jetty.util.thread.AutoLock.lock:()Lorg/eclipse/jetty/util/thread/AutoLock;
astore 4
start local 4 5: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selecting:Z
ifeq 8
6: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selector:Ljava/nio/channels/Selector;
astore 1
7: aload 0
iconst_0
putfield org.eclipse.jetty.io.ManagedSelector._selecting:Z
8: StackMap locals: org.eclipse.jetty.io.ManagedSelector java.nio.channels.Selector java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.AutoLock
StackMap stack:
aload 4
ifnull 14
aload 4
invokevirtual org.eclipse.jetty.util.thread.AutoLock.close:()V
goto 14
StackMap locals:
StackMap stack: java.lang.Throwable
9: astore 2
aload 4
ifnull 10
aload 4
invokevirtual org.eclipse.jetty.util.thread.AutoLock.close:()V
end local 4 StackMap locals:
StackMap stack:
10: aload 2
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
11: astore 3
aload 2
ifnonnull 12
aload 3
astore 2
goto 13
StackMap locals:
StackMap stack:
12: aload 2
aload 3
if_acmpeq 13
aload 2
aload 3
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
13: aload 2
athrow
14: StackMap locals:
StackMap stack:
aload 1
ifnull 16
15: aload 1
invokevirtual java.nio.channels.Selector.wakeup:()Ljava/nio/channels/Selector;
pop
16: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 this Lorg/eclipse/jetty/io/ManagedSelector;
3 17 1 selector Ljava/nio/channels/Selector;
5 10 4 l Lorg/eclipse/jetty/util/thread/AutoLock;
Exception table:
from to target type
5 8 9 any
4 11 11 any
private void execute(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
aload 1
invokevirtual org.eclipse.jetty.io.SelectorManager.execute:(Ljava/lang/Runnable;)V
1: goto 5
2: StackMap locals:
StackMap stack: java.util.concurrent.RejectedExecutionException
pop
3: aload 1
instanceof java.io.Closeable
ifeq 5
4: aload 1
checkcast java.io.Closeable
invokestatic org.eclipse.jetty.util.IO.close:(Ljava/io/Closeable;)V
5: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/eclipse/jetty/io/ManagedSelector;
0 6 1 task Ljava/lang/Runnable;
Exception table:
from to target type
0 1 2 Class java.util.concurrent.RejectedExecutionException
MethodParameters:
Name Flags
task
private void processConnect(java.nio.channels.SelectionKey, org.eclipse.jetty.io.ManagedSelector$Connect);
descriptor: (Ljava/nio/channels/SelectionKey;Lorg/eclipse/jetty/io/ManagedSelector$Connect;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokevirtual java.nio.channels.SelectionKey.channel:()Ljava/nio/channels/SelectableChannel;
astore 3
start local 3 1: aload 1
aload 2
getfield org.eclipse.jetty.io.ManagedSelector$Connect.attachment:Ljava/lang/Object;
invokevirtual java.nio.channels.SelectionKey.attach:(Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
aload 3
invokevirtual org.eclipse.jetty.io.SelectorManager.doFinishConnect:(Ljava/nio/channels/SelectableChannel;)Z
istore 4
start local 4 3: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
ifeq 5
4: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
ldc "Connected {} {}"
iload 4
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
aload 3
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
5: StackMap locals: java.nio.channels.SelectableChannel int
StackMap stack:
iload 4
ifeq 11
6: aload 2
getfield org.eclipse.jetty.io.ManagedSelector$Connect.timeout:Lorg/eclipse/jetty/util/thread/Scheduler$Task;
invokeinterface org.eclipse.jetty.util.thread.Scheduler$Task.cancel:()Z
ifeq 10
7: aload 1
iconst_0
invokevirtual java.nio.channels.SelectionKey.interestOps:(I)Ljava/nio/channels/SelectionKey;
pop
8: aload 0
new org.eclipse.jetty.io.ManagedSelector$CreateEndPoint
dup
aload 0
aload 2
aload 1
invokespecial org.eclipse.jetty.io.ManagedSelector$CreateEndPoint.<init>:(Lorg/eclipse/jetty/io/ManagedSelector;Lorg/eclipse/jetty/io/ManagedSelector$Connect;Ljava/nio/channels/SelectionKey;)V
invokevirtual org.eclipse.jetty.io.ManagedSelector.execute:(Ljava/lang/Runnable;)V
9: goto 14
10: StackMap locals:
StackMap stack:
new java.net.SocketTimeoutException
dup
ldc "Concurrent Connect Timeout"
invokespecial java.net.SocketTimeoutException.<init>:(Ljava/lang/String;)V
athrow
11: StackMap locals:
StackMap stack:
new java.net.ConnectException
dup
invokespecial java.net.ConnectException.<init>:()V
athrow
end local 4 12: StackMap locals: org.eclipse.jetty.io.ManagedSelector java.nio.channels.SelectionKey org.eclipse.jetty.io.ManagedSelector$Connect java.nio.channels.SelectableChannel
StackMap stack: java.lang.Throwable
astore 4
start local 4 13: aload 2
aload 4
invokevirtual org.eclipse.jetty.io.ManagedSelector$Connect.failed:(Ljava/lang/Throwable;)V
end local 4 14: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lorg/eclipse/jetty/io/ManagedSelector;
0 15 1 key Ljava/nio/channels/SelectionKey;
0 15 2 connect Lorg/eclipse/jetty/io/ManagedSelector$Connect;
1 15 3 channel Ljava/nio/channels/SelectableChannel;
3 12 4 connected Z
13 14 4 x Ljava/lang/Throwable;
Exception table:
from to target type
1 12 12 Class java.lang.Throwable
MethodParameters:
Name Flags
key
connect
protected void endPointOpened(org.eclipse.jetty.io.EndPoint);
descriptor: (Lorg/eclipse/jetty/io/EndPoint;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
aload 1
invokevirtual org.eclipse.jetty.io.SelectorManager.endPointOpened:(Lorg/eclipse/jetty/io/EndPoint;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/io/ManagedSelector;
0 2 1 endPoint Lorg/eclipse/jetty/io/EndPoint;
MethodParameters:
Name Flags
endPoint
protected void endPointClosed(org.eclipse.jetty.io.EndPoint);
descriptor: (Lorg/eclipse/jetty/io/EndPoint;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
aload 1
invokevirtual org.eclipse.jetty.io.SelectorManager.endPointClosed:(Lorg/eclipse/jetty/io/EndPoint;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/eclipse/jetty/io/ManagedSelector;
0 2 1 endPoint Lorg/eclipse/jetty/io/EndPoint;
MethodParameters:
Name Flags
endPoint
private void createEndPoint(java.nio.channels.SelectableChannel, java.nio.channels.SelectionKey);
descriptor: (Ljava/nio/channels/SelectableChannel;Ljava/nio/channels/SelectionKey;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
aload 1
aload 0
aload 2
invokevirtual org.eclipse.jetty.io.SelectorManager.newEndPoint:(Ljava/nio/channels/SelectableChannel;Lorg/eclipse/jetty/io/ManagedSelector;Ljava/nio/channels/SelectionKey;)Lorg/eclipse/jetty/io/EndPoint;
astore 3
start local 3 1: aload 2
invokevirtual java.nio.channels.SelectionKey.attachment:()Ljava/lang/Object;
astore 4
start local 4 2: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
aload 1
aload 3
aload 4
invokevirtual org.eclipse.jetty.io.SelectorManager.newConnection:(Ljava/nio/channels/SelectableChannel;Lorg/eclipse/jetty/io/EndPoint;Ljava/lang/Object;)Lorg/eclipse/jetty/io/Connection;
astore 5
start local 5 3: aload 3
aload 5
invokeinterface org.eclipse.jetty.io.EndPoint.setConnection:(Lorg/eclipse/jetty/io/Connection;)V
4: aload 0
aload 2
aload 1
aload 3
invokedynamic update(Ljava/nio/channels/SelectionKey;Ljava/nio/channels/SelectableChannel;Lorg/eclipse/jetty/io/EndPoint;)Lorg/eclipse/jetty/io/ManagedSelector$SelectorUpdate;
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/nio/channels/Selector;)V
org/eclipse/jetty/io/ManagedSelector.lambda$1(Ljava/nio/channels/SelectionKey;Ljava/nio/channels/SelectableChannel;Lorg/eclipse/jetty/io/EndPoint;Ljava/nio/channels/Selector;)V (6)
(Ljava/nio/channels/Selector;)V
5: iconst_1
6: invokevirtual org.eclipse.jetty.io.ManagedSelector.submit:(Lorg/eclipse/jetty/io/ManagedSelector$SelectorUpdate;Z)V
7: aload 3
invokeinterface org.eclipse.jetty.io.EndPoint.onOpen:()V
8: aload 0
aload 3
invokevirtual org.eclipse.jetty.io.ManagedSelector.endPointOpened:(Lorg/eclipse/jetty/io/EndPoint;)V
9: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selectorManager:Lorg/eclipse/jetty/io/SelectorManager;
aload 5
aload 4
invokevirtual org.eclipse.jetty.io.SelectorManager.connectionOpened:(Lorg/eclipse/jetty/io/Connection;Ljava/lang/Object;)V
10: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
ifeq 12
11: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
ldc "Created {}"
aload 3
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
12: StackMap locals: org.eclipse.jetty.io.EndPoint java.lang.Object org.eclipse.jetty.io.Connection
StackMap stack:
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 13 0 this Lorg/eclipse/jetty/io/ManagedSelector;
0 13 1 channel Ljava/nio/channels/SelectableChannel;
0 13 2 selectionKey Ljava/nio/channels/SelectionKey;
1 13 3 endPoint Lorg/eclipse/jetty/io/EndPoint;
2 13 4 context Ljava/lang/Object;
3 13 5 connection Lorg/eclipse/jetty/io/Connection;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
channel
selectionKey
void destroyEndPoint(org.eclipse.jetty.io.EndPoint, java.lang.Throwable);
descriptor: (Lorg/eclipse/jetty/io/EndPoint;Ljava/lang/Throwable;)V
flags: (0x0000)
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual org.eclipse.jetty.io.ManagedSelector.wakeup:()V
1: aload 0
new org.eclipse.jetty.io.ManagedSelector$DestroyEndPoint
dup
aload 0
aload 1
aload 2
invokespecial org.eclipse.jetty.io.ManagedSelector$DestroyEndPoint.<init>:(Lorg/eclipse/jetty/io/ManagedSelector;Lorg/eclipse/jetty/io/EndPoint;Ljava/lang/Throwable;)V
invokevirtual org.eclipse.jetty.io.ManagedSelector.execute:(Ljava/lang/Runnable;)V
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/eclipse/jetty/io/ManagedSelector;
0 3 1 endPoint Lorg/eclipse/jetty/io/EndPoint;
0 3 2 cause Ljava/lang/Throwable;
MethodParameters:
Name Flags
endPoint
cause
private int getActionSize();
descriptor: ()I
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=4, args_size=1
start local 0 0: aconst_null
astore 1
aconst_null
astore 2
1: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._lock:Lorg/eclipse/jetty/util/thread/AutoLock;
invokevirtual org.eclipse.jetty.util.thread.AutoLock.lock:()Lorg/eclipse/jetty/util/thread/AutoLock;
astore 3
start local 3 2: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._updates:Ljava/util/Deque;
invokeinterface java.util.Deque.size:()I
3: aload 3
ifnull 4
aload 3
invokevirtual org.eclipse.jetty.util.thread.AutoLock.close:()V
4: StackMap locals: org.eclipse.jetty.io.ManagedSelector java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.AutoLock
StackMap stack: int
ireturn
StackMap locals:
StackMap stack: java.lang.Throwable
5: astore 1
6: aload 3
ifnull 7
aload 3
invokevirtual org.eclipse.jetty.util.thread.AutoLock.close:()V
end local 3 StackMap locals:
StackMap stack:
7: aload 1
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
8: astore 2
aload 1
ifnonnull 9
aload 2
astore 1
goto 10
StackMap locals:
StackMap stack:
9: aload 1
aload 2
if_acmpeq 10
aload 1
aload 2
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
10: aload 1
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/eclipse/jetty/io/ManagedSelector;
2 7 3 l Lorg/eclipse/jetty/util/thread/AutoLock;
Exception table:
from to target type
2 3 5 any
1 4 8 any
5 8 8 any
static int safeReadyOps(java.nio.channels.SelectionKey);
descriptor: (Ljava/nio/channels/SelectionKey;)I
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual java.nio.channels.SelectionKey.readyOps:()I
1: ireturn
2: StackMap locals:
StackMap stack: java.lang.Throwable
astore 1
start local 1 3: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
ldc "IGNORED"
aload 1
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Throwable;)V
4: iconst_m1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 selectionKey Ljava/nio/channels/SelectionKey;
3 5 1 x Ljava/lang/Throwable;
Exception table:
from to target type
0 1 2 Class java.lang.Throwable
MethodParameters:
Name Flags
selectionKey
static int safeInterestOps(java.nio.channels.SelectionKey);
descriptor: (Ljava/nio/channels/SelectionKey;)I
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual java.nio.channels.SelectionKey.interestOps:()I
1: ireturn
2: StackMap locals:
StackMap stack: java.lang.Throwable
astore 1
start local 1 3: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
ldc "IGNORED"
aload 1
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Throwable;)V
4: iconst_m1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 selectionKey Ljava/nio/channels/SelectionKey;
3 5 1 x Ljava/lang/Throwable;
Exception table:
from to target type
0 1 2 Class java.lang.Throwable
MethodParameters:
Name Flags
selectionKey
public void dump(java.lang.Appendable, java.lang.String);
descriptor: (Ljava/lang/Appendable;Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=11, locals=11, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selector:Ljava/nio/channels/Selector;
astore 5
start local 5 1: aload 5
ifnull 27
aload 5
invokevirtual java.nio.channels.Selector.isOpen:()Z
ifeq 27
2: new org.eclipse.jetty.io.ManagedSelector$DumpKeys
dup
invokespecial org.eclipse.jetty.io.ManagedSelector$DumpKeys.<init>:()V
astore 6
start local 6 3: getstatic java.time.format.DateTimeFormatter.ISO_OFFSET_DATE_TIME:Ljava/time/format/DateTimeFormatter;
invokestatic java.time.ZonedDateTime.now:()Ljava/time/ZonedDateTime;
invokevirtual java.time.format.DateTimeFormatter.format:(Ljava/time/temporal/TemporalAccessor;)Ljava/lang/String;
astore 7
start local 7 4: aconst_null
astore 8
aconst_null
astore 9
5: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._lock:Lorg/eclipse/jetty/util/thread/AutoLock;
invokevirtual org.eclipse.jetty.util.thread.AutoLock.lock:()Lorg/eclipse/jetty/util/thread/AutoLock;
astore 10
start local 10 6: new java.util.ArrayList
dup
aload 0
getfield org.eclipse.jetty.io.ManagedSelector._updates:Ljava/util/Deque;
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
astore 4
start local 4 7: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._updates:Ljava/util/Deque;
aload 6
invokeinterface java.util.Deque.addFirst:(Ljava/lang/Object;)V
8: aload 0
iconst_0
putfield org.eclipse.jetty.io.ManagedSelector._selecting:Z
9: aload 10
ifnull 15
aload 10
invokevirtual org.eclipse.jetty.util.thread.AutoLock.close:()V
goto 15
end local 4 StackMap locals: org.eclipse.jetty.io.ManagedSelector java.lang.Appendable java.lang.String top top java.nio.channels.Selector org.eclipse.jetty.io.ManagedSelector$DumpKeys java.lang.String java.lang.Throwable java.lang.Throwable org.eclipse.jetty.util.thread.AutoLock
StackMap stack: java.lang.Throwable
10: astore 8
aload 10
ifnull 11
aload 10
invokevirtual org.eclipse.jetty.util.thread.AutoLock.close:()V
end local 10 StackMap locals:
StackMap stack:
11: aload 8
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
12: astore 9
aload 8
ifnonnull 13
aload 9
astore 8
goto 14
StackMap locals:
StackMap stack:
13: aload 8
aload 9
if_acmpeq 14
aload 8
aload 9
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
14: aload 8
athrow
start local 4 15: StackMap locals: org.eclipse.jetty.io.ManagedSelector java.lang.Appendable java.lang.String top java.util.List java.nio.channels.Selector org.eclipse.jetty.io.ManagedSelector$DumpKeys java.lang.String
StackMap stack:
getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isDebugEnabled:()Z
ifeq 17
16: getstatic org.eclipse.jetty.io.ManagedSelector.LOG:Lorg/slf4j/Logger;
ldc "wakeup on dump {}"
aload 0
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
17: StackMap locals:
StackMap stack:
aload 5
invokevirtual java.nio.channels.Selector.wakeup:()Ljava/nio/channels/Selector;
pop
18: aload 6
ldc 5
getstatic java.util.concurrent.TimeUnit.SECONDS:Ljava/util/concurrent/TimeUnit;
invokevirtual org.eclipse.jetty.io.ManagedSelector$DumpKeys.get:(JLjava/util/concurrent/TimeUnit;)Ljava/util/List;
astore 3
start local 3 19: getstatic java.time.format.DateTimeFormatter.ISO_OFFSET_DATE_TIME:Ljava/time/format/DateTimeFormatter;
invokestatic java.time.ZonedDateTime.now:()Ljava/time/ZonedDateTime;
invokevirtual java.time.format.DateTimeFormatter.format:(Ljava/time/temporal/TemporalAccessor;)Ljava/lang/String;
astore 8
start local 8 20: aload 3
ifnonnull 22
21: ldc "No dump keys retrieved"
invokestatic java.util.Collections.singletonList:(Ljava/lang/Object;)Ljava/util/List;
astore 3
22: StackMap locals: org.eclipse.jetty.io.ManagedSelector java.lang.Appendable java.lang.String java.util.List java.util.List java.nio.channels.Selector org.eclipse.jetty.io.ManagedSelector$DumpKeys java.lang.String java.lang.String
StackMap stack:
aload 0
aload 1
aload 2
iconst_2
anewarray java.lang.Object
dup
iconst_0
23: new org.eclipse.jetty.util.component.DumpableCollection
dup
new java.lang.StringBuilder
dup
ldc "updates @ "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 7
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aload 4
invokespecial org.eclipse.jetty.util.component.DumpableCollection.<init>:(Ljava/lang/String;Ljava/util/Collection;)V
aastore
dup
iconst_1
24: new org.eclipse.jetty.util.component.DumpableCollection
dup
new java.lang.StringBuilder
dup
ldc "keys @ "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 8
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aload 3
invokespecial org.eclipse.jetty.util.component.DumpableCollection.<init>:(Ljava/lang/String;Ljava/util/Collection;)V
aastore
25: invokevirtual org.eclipse.jetty.io.ManagedSelector.dumpObjects:(Ljava/lang/Appendable;Ljava/lang/String;[Ljava/lang/Object;)V
end local 8 end local 7 end local 6 26: goto 28
end local 4 end local 3 27: StackMap locals: org.eclipse.jetty.io.ManagedSelector java.lang.Appendable java.lang.String top top java.nio.channels.Selector
StackMap stack:
aload 0
aload 1
aload 2
iconst_0
anewarray java.lang.Object
invokevirtual org.eclipse.jetty.io.ManagedSelector.dumpObjects:(Ljava/lang/Appendable;Ljava/lang/String;[Ljava/lang/Object;)V
28: StackMap locals:
StackMap stack:
return
end local 5 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 29 0 this Lorg/eclipse/jetty/io/ManagedSelector;
0 29 1 out Ljava/lang/Appendable;
0 29 2 indent Ljava/lang/String;
19 27 3 keys Ljava/util/List<Ljava/lang/String;>;
7 10 4 updates Ljava/util/List<Lorg/eclipse/jetty/io/ManagedSelector$SelectorUpdate;>;
15 27 4 updates Ljava/util/List<Lorg/eclipse/jetty/io/ManagedSelector$SelectorUpdate;>;
1 29 5 selector Ljava/nio/channels/Selector;
3 26 6 dump Lorg/eclipse/jetty/io/ManagedSelector$DumpKeys;
4 26 7 updatesAt Ljava/lang/String;
6 11 10 l Lorg/eclipse/jetty/util/thread/AutoLock;
20 26 8 keysAt Ljava/lang/String;
Exception table:
from to target type
6 9 10 any
5 12 12 any
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
out
indent
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=1
start local 0 0: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._selector:Ljava/nio/channels/Selector;
astore 1
start local 1 1: ldc "%s id=%s keys=%d selected=%d updates=%d"
iconst_5
anewarray java.lang.Object
dup
iconst_0
2: aload 0
invokespecial org.eclipse.jetty.util.component.ContainerLifeCycle.toString:()Ljava/lang/String;
aastore
dup
iconst_1
3: aload 0
getfield org.eclipse.jetty.io.ManagedSelector._id:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
4: aload 1
ifnull 5
aload 1
invokevirtual java.nio.channels.Selector.isOpen:()Z
ifeq 5
aload 1
invokevirtual java.nio.channels.Selector.keys:()Ljava/util/Set;
invokeinterface java.util.Set.size:()I
goto 6
StackMap locals: org.eclipse.jetty.io.ManagedSelector java.nio.channels.Selector
StackMap stack: java.lang.String java.lang.Object[] java.lang.Object[] int
5: iconst_m1
StackMap locals: org.eclipse.jetty.io.ManagedSelector java.nio.channels.Selector
StackMap stack: java.lang.String java.lang.Object[] java.lang.Object[] int int
6: invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_3
7: aload 1
ifnull 8
aload 1
invokevirtual java.nio.channels.Selector.isOpen:()Z
ifeq 8
aload 1
invokevirtual java.nio.channels.Selector.selectedKeys:()Ljava/util/Set;
invokeinterface java.util.Set.size:()I
goto 9
StackMap locals: org.eclipse.jetty.io.ManagedSelector java.nio.channels.Selector
StackMap stack: java.lang.String java.lang.Object[] java.lang.Object[] int
8: iconst_m1
StackMap locals: org.eclipse.jetty.io.ManagedSelector java.nio.channels.Selector
StackMap stack: java.lang.String java.lang.Object[] java.lang.Object[] int int
9: invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_4
10: aload 0
invokevirtual org.eclipse.jetty.io.ManagedSelector.getActionSize:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
11: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/eclipse/jetty/io/ManagedSelector;
1 12 1 selector Ljava/nio/channels/Selector;
private static void lambda$1(java.nio.channels.SelectionKey, java.nio.channels.SelectableChannel, org.eclipse.jetty.io.EndPoint, java.nio.channels.Selector);
descriptor: (Ljava/nio/channels/SelectionKey;Ljava/nio/channels/SelectableChannel;Lorg/eclipse/jetty/io/EndPoint;Ljava/nio/channels/Selector;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=5, args_size=4
start local 3 0: aload 0
astore 4
start local 4 1: aload 4
invokevirtual java.nio.channels.SelectionKey.selector:()Ljava/nio/channels/Selector;
aload 3
if_acmpeq 5
2: aload 1
aload 3
invokevirtual java.nio.channels.SelectableChannel.keyFor:(Ljava/nio/channels/Selector;)Ljava/nio/channels/SelectionKey;
astore 4
3: aload 4
ifnull 5
aload 2
instanceof org.eclipse.jetty.io.ManagedSelector$Selectable
ifeq 5
4: aload 2
checkcast org.eclipse.jetty.io.ManagedSelector$Selectable
aload 4
invokeinterface org.eclipse.jetty.io.ManagedSelector$Selectable.replaceKey:(Ljava/nio/channels/SelectionKey;)V
5: StackMap locals: java.nio.channels.SelectionKey
StackMap stack:
aload 4
ifnull 7
6: aload 4
aload 2
invokevirtual java.nio.channels.SelectionKey.attach:(Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 4 7: StackMap locals:
StackMap stack:
return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 8 3 selector Ljava/nio/channels/Selector;
1 7 4 key Ljava/nio/channels/SelectionKey;
}
SourceFile: "ManagedSelector.java"
NestMembers:
org.eclipse.jetty.io.ManagedSelector$Accept org.eclipse.jetty.io.ManagedSelector$Acceptor org.eclipse.jetty.io.ManagedSelector$CloseConnections org.eclipse.jetty.io.ManagedSelector$Connect org.eclipse.jetty.io.ManagedSelector$CreateEndPoint org.eclipse.jetty.io.ManagedSelector$DestroyEndPoint org.eclipse.jetty.io.ManagedSelector$DumpKeys org.eclipse.jetty.io.ManagedSelector$Selectable org.eclipse.jetty.io.ManagedSelector$SelectorProducer org.eclipse.jetty.io.ManagedSelector$SelectorUpdate org.eclipse.jetty.io.ManagedSelector$Start org.eclipse.jetty.io.ManagedSelector$StopSelector
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
Accept = org.eclipse.jetty.io.ManagedSelector$Accept of org.eclipse.jetty.io.ManagedSelector
Acceptor = org.eclipse.jetty.io.ManagedSelector$Acceptor of org.eclipse.jetty.io.ManagedSelector
private CloseConnections = org.eclipse.jetty.io.ManagedSelector$CloseConnections of org.eclipse.jetty.io.ManagedSelector
Connect = org.eclipse.jetty.io.ManagedSelector$Connect of org.eclipse.jetty.io.ManagedSelector
private final CreateEndPoint = org.eclipse.jetty.io.ManagedSelector$CreateEndPoint of org.eclipse.jetty.io.ManagedSelector
private DestroyEndPoint = org.eclipse.jetty.io.ManagedSelector$DestroyEndPoint of org.eclipse.jetty.io.ManagedSelector
private DumpKeys = org.eclipse.jetty.io.ManagedSelector$DumpKeys of org.eclipse.jetty.io.ManagedSelector
public abstract Selectable = org.eclipse.jetty.io.ManagedSelector$Selectable of org.eclipse.jetty.io.ManagedSelector
private SelectorProducer = org.eclipse.jetty.io.ManagedSelector$SelectorProducer of org.eclipse.jetty.io.ManagedSelector
public abstract SelectorUpdate = org.eclipse.jetty.io.ManagedSelector$SelectorUpdate of org.eclipse.jetty.io.ManagedSelector
private Start = org.eclipse.jetty.io.ManagedSelector$Start of org.eclipse.jetty.io.ManagedSelector
private StopSelector = org.eclipse.jetty.io.ManagedSelector$StopSelector of org.eclipse.jetty.io.ManagedSelector
public abstract Producer = org.eclipse.jetty.util.thread.ExecutionStrategy$Producer of org.eclipse.jetty.util.thread.ExecutionStrategy
public abstract Task = org.eclipse.jetty.util.thread.Scheduler$Task of org.eclipse.jetty.util.thread.Scheduler