public class com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener implements com.datastax.oss.driver.api.core.metadata.NodeStateListener
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener
super_class: java.lang.Object
{
private final com.datastax.oss.driver.api.core.metadata.NodeStateListener delegate;
descriptor: Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final boolean replayInitEvents;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.locks.ReadWriteLock lock;
descriptor: Ljava/util/concurrent/locks/ReadWriteLock;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private boolean sessionReady;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
RuntimeVisibleAnnotations:
net.jcip.annotations.GuardedBy(value = "lock")
private final java.util.List<com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent> initEvents;
descriptor: Ljava/util/List;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/List<Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener$InitEvent;>;
RuntimeVisibleAnnotations:
net.jcip.annotations.GuardedBy(value = "lock")
public void <init>(com.datastax.oss.driver.api.core.metadata.NodeStateListener, boolean);
descriptor: (Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.locks.ReentrantReadWriteLock
dup
invokespecial java.util.concurrent.locks.ReentrantReadWriteLock.<init>:()V
putfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.lock:Ljava/util/concurrent/locks/ReadWriteLock;
2: aload 0
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
putfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.initEvents:Ljava/util/List;
3: aload 0
aload 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.metadata.NodeStateListener
putfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.delegate:Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
4: aload 0
iload 2
putfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.replayInitEvents:Z
5: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener;
0 6 1 delegate Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
0 6 2 replayInitEvents Z
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
1:
MethodParameters:
Name Flags
delegate
replayInitEvents
public void onSessionReady(com.datastax.oss.driver.api.core.session.Session);
descriptor: (Lcom/datastax/oss/driver/api/core/session/Session;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.lock:Ljava/util/concurrent/locks/ReadWriteLock;
invokeinterface java.util.concurrent.locks.ReadWriteLock.writeLock:()Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.lock:()V
1: aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.sessionReady:Z
ifne 13
2: aload 0
iconst_1
putfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.sessionReady:Z
3: aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.delegate:Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
aload 1
invokeinterface com.datastax.oss.driver.api.core.metadata.NodeStateListener.onSessionReady:(Lcom/datastax/oss/driver/api/core/session/Session;)V
4: aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.replayInitEvents:Z
ifeq 13
5: aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.initEvents:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 8
StackMap locals: com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener com.datastax.oss.driver.api.core.session.Session top java.util.Iterator
StackMap stack:
6: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent
astore 2
start local 2 7: aload 2
aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.delegate:Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
invokevirtual com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent.invoke:(Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;)V
end local 2 8: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
9: goto 13
StackMap locals: com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener com.datastax.oss.driver.api.core.session.Session
StackMap stack: java.lang.Throwable
10: astore 4
11: aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.lock:Ljava/util/concurrent/locks/ReadWriteLock;
invokeinterface java.util.concurrent.locks.ReadWriteLock.writeLock:()Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
12: aload 4
athrow
13: StackMap locals:
StackMap stack:
aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.lock:Ljava/util/concurrent/locks/ReadWriteLock;
invokeinterface java.util.concurrent.locks.ReadWriteLock.writeLock:()Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
14: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener;
0 15 1 session Lcom/datastax/oss/driver/api/core/session/Session;
7 8 2 event Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener$InitEvent;
Exception table:
from to target type
1 10 10 any
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
MethodParameters:
Name Flags
session
public void onAdd(com.datastax.oss.driver.api.core.metadata.Node);
descriptor: (Lcom/datastax/oss/driver/api/core/metadata/Node;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
getstatic com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent$Type.ADD:Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener$InitEvent$Type;
invokevirtual com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.onEvent:(Lcom/datastax/oss/driver/api/core/metadata/Node;Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener$InitEvent$Type;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener;
0 2 1 node Lcom/datastax/oss/driver/api/core/metadata/Node;
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
MethodParameters:
Name Flags
node
public void onUp(com.datastax.oss.driver.api.core.metadata.Node);
descriptor: (Lcom/datastax/oss/driver/api/core/metadata/Node;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
getstatic com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent$Type.UP:Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener$InitEvent$Type;
invokevirtual com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.onEvent:(Lcom/datastax/oss/driver/api/core/metadata/Node;Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener$InitEvent$Type;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener;
0 2 1 node Lcom/datastax/oss/driver/api/core/metadata/Node;
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
MethodParameters:
Name Flags
node
public void onDown(com.datastax.oss.driver.api.core.metadata.Node);
descriptor: (Lcom/datastax/oss/driver/api/core/metadata/Node;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
getstatic com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent$Type.DOWN:Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener$InitEvent$Type;
invokevirtual com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.onEvent:(Lcom/datastax/oss/driver/api/core/metadata/Node;Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener$InitEvent$Type;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener;
0 2 1 node Lcom/datastax/oss/driver/api/core/metadata/Node;
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
MethodParameters:
Name Flags
node
public void onRemove(com.datastax.oss.driver.api.core.metadata.Node);
descriptor: (Lcom/datastax/oss/driver/api/core/metadata/Node;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
getstatic com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent$Type.REMOVE:Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener$InitEvent$Type;
invokevirtual com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.onEvent:(Lcom/datastax/oss/driver/api/core/metadata/Node;Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener$InitEvent$Type;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener;
0 2 1 node Lcom/datastax/oss/driver/api/core/metadata/Node;
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
MethodParameters:
Name Flags
node
private void onEvent(com.datastax.oss.driver.api.core.metadata.Node, com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent$Type);
descriptor: (Lcom/datastax/oss/driver/api/core/metadata/Node;Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener$InitEvent$Type;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.lock:Ljava/util/concurrent/locks/ReadWriteLock;
invokeinterface java.util.concurrent.locks.ReadWriteLock.readLock:()Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.lock:()V
1: aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.sessionReady:Z
ifeq 8
2: aload 2
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent$Type.listenerMethod:Ljava/util/function/BiConsumer;
aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.delegate:Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
aload 1
invokeinterface java.util.function.BiConsumer.accept:(Ljava/lang/Object;Ljava/lang/Object;)V
3: aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.lock:Ljava/util/concurrent/locks/ReadWriteLock;
invokeinterface java.util.concurrent.locks.ReadWriteLock.readLock:()Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
4: return
5: StackMap locals:
StackMap stack: java.lang.Throwable
astore 3
6: aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.lock:Ljava/util/concurrent/locks/ReadWriteLock;
invokeinterface java.util.concurrent.locks.ReadWriteLock.readLock:()Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
7: aload 3
athrow
8: StackMap locals:
StackMap stack:
aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.lock:Ljava/util/concurrent/locks/ReadWriteLock;
invokeinterface java.util.concurrent.locks.ReadWriteLock.readLock:()Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
9: aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.replayInitEvents:Z
ifeq 20
10: aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.lock:Ljava/util/concurrent/locks/ReadWriteLock;
invokeinterface java.util.concurrent.locks.ReadWriteLock.writeLock:()Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.lock:()V
11: aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.sessionReady:Z
ifeq 14
12: aload 2
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent$Type.listenerMethod:Ljava/util/function/BiConsumer;
aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.delegate:Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
aload 1
invokeinterface java.util.function.BiConsumer.accept:(Ljava/lang/Object;Ljava/lang/Object;)V
13: goto 19
14: StackMap locals:
StackMap stack:
aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.initEvents:Ljava/util/List;
new com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent
dup
aload 1
aload 2
invokespecial com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent.<init>:(Lcom/datastax/oss/driver/api/core/metadata/Node;Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener$InitEvent$Type;)V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
15: goto 19
StackMap locals:
StackMap stack: java.lang.Throwable
16: astore 3
17: aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.lock:Ljava/util/concurrent/locks/ReadWriteLock;
invokeinterface java.util.concurrent.locks.ReadWriteLock.writeLock:()Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
18: aload 3
athrow
19: StackMap locals:
StackMap stack:
aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.lock:Ljava/util/concurrent/locks/ReadWriteLock;
invokeinterface java.util.concurrent.locks.ReadWriteLock.writeLock:()Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
20: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 this Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener;
0 21 1 node Lcom/datastax/oss/driver/api/core/metadata/Node;
0 21 2 eventType Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener$InitEvent$Type;
Exception table:
from to target type
1 3 5 any
11 16 16 any
MethodParameters:
Name Flags
node
eventType
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener.delegate:Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
invokeinterface com.datastax.oss.driver.api.core.metadata.NodeStateListener.close:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/datastax/oss/driver/api/core/metadata/SafeInitNodeStateListener;
Exceptions:
throws java.lang.Exception
}
SourceFile: "SafeInitNodeStateListener.java"
NestMembers:
com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent$Type
InnerClasses:
private InitEvent = com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent of com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener
final Type = com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent$Type of com.datastax.oss.driver.api.core.metadata.SafeInitNodeStateListener$InitEvent