public class com.datastax.oss.driver.internal.core.metadata.MetadataManager implements com.datastax.oss.driver.api.core.AsyncAutoCloseable
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: com.datastax.oss.driver.internal.core.metadata.MetadataManager
super_class: java.lang.Object
{
private static final org.slf4j.Logger LOG;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static final com.datastax.oss.driver.api.core.metadata.EndPoint DEFAULT_CONTACT_POINT;
descriptor: Lcom/datastax/oss/driver/api/core/metadata/EndPoint;
flags: (0x0018) ACC_STATIC, ACC_FINAL
private final com.datastax.oss.driver.internal.core.context.InternalDriverContext context;
descriptor: Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.String logPrefix;
descriptor: Ljava/lang/String;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.netty.util.concurrent.EventExecutor adminExecutor;
descriptor: Lio/netty/util/concurrent/EventExecutor;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.datastax.oss.driver.api.core.config.DriverExecutionProfile config;
descriptor: Lcom/datastax/oss/driver/api/core/config/DriverExecutionProfile;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.datastax.oss.driver.internal.core.metadata.MetadataManager$SingleThreaded singleThreaded;
descriptor: Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.datastax.oss.driver.internal.core.control.ControlConnection controlConnection;
descriptor: Lcom/datastax/oss/driver/internal/core/control/ControlConnection;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private volatile com.datastax.oss.driver.internal.core.metadata.DefaultMetadata metadata;
descriptor: Lcom/datastax/oss/driver/internal/core/metadata/DefaultMetadata;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile boolean schemaEnabledInConfig;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile java.util.List<java.lang.String> refreshedKeyspaces;
descriptor: Ljava/util/List;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
Signature: Ljava/util/List<Ljava/lang/String;>;
private volatile com.datastax.oss.driver.internal.core.metadata.schema.queries.KeyspaceFilter keyspaceFilter;
descriptor: Lcom/datastax/oss/driver/internal/core/metadata/schema/queries/KeyspaceFilter;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile java.lang.Boolean schemaEnabledProgrammatically;
descriptor: Ljava/lang/Boolean;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile boolean tokenMapEnabled;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile java.util.Set<com.datastax.oss.driver.internal.core.metadata.DefaultNode> contactPoints;
descriptor: Ljava/util/Set;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
Signature: Ljava/util/Set<Lcom/datastax/oss/driver/internal/core/metadata/DefaultNode;>;
private volatile boolean wasImplicitContactPoint;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=6, locals=0, args_size=0
0: ldc Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
invokevirtual java.lang.Class.desiredAssertionStatus:()Z
ifne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: putstatic com.datastax.oss.driver.internal.core.metadata.MetadataManager.$assertionsDisabled:Z
3: ldc Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic com.datastax.oss.driver.internal.core.metadata.MetadataManager.LOG:Lorg/slf4j/Logger;
4: new com.datastax.oss.driver.internal.core.metadata.DefaultEndPoint
dup
new java.net.InetSocketAddress
dup
ldc "127.0.0.1"
sipush 9042
invokespecial java.net.InetSocketAddress.<init>:(Ljava/lang/String;I)V
invokespecial com.datastax.oss.driver.internal.core.metadata.DefaultEndPoint.<init>:(Ljava/net/InetSocketAddress;)V
5: putstatic com.datastax.oss.driver.internal.core.metadata.MetadataManager.DEFAULT_CONTACT_POINT:Lcom/datastax/oss/driver/api/core/metadata/EndPoint;
6: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(com.datastax.oss.driver.internal.core.context.InternalDriverContext);
descriptor: (Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)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.internal.core.metadata.DefaultMetadata.EMPTY:Lcom/datastax/oss/driver/internal/core/metadata/DefaultMetadata;
invokespecial com.datastax.oss.driver.internal.core.metadata.MetadataManager.<init>:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Lcom/datastax/oss/driver/internal/core/metadata/DefaultMetadata;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
0 2 1 context Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
MethodParameters:
Name Flags
context
protected void <init>(com.datastax.oss.driver.internal.core.context.InternalDriverContext, com.datastax.oss.driver.internal.core.metadata.DefaultMetadata);
descriptor: (Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Lcom/datastax/oss/driver/internal/core/metadata/DefaultMetadata;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=6, 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
aload 1
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.context:Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
2: aload 0
aload 2
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.metadata:Lcom/datastax/oss/driver/internal/core/metadata/DefaultMetadata;
3: aload 0
aload 1
invokeinterface com.datastax.oss.driver.internal.core.context.InternalDriverContext.getSessionName:()Ljava/lang/String;
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.logPrefix:Ljava/lang/String;
4: aload 0
aload 1
invokeinterface com.datastax.oss.driver.internal.core.context.InternalDriverContext.getNettyOptions:()Lcom/datastax/oss/driver/internal/core/context/NettyOptions;
invokeinterface com.datastax.oss.driver.internal.core.context.NettyOptions.adminEventExecutorGroup:()Lio/netty/util/concurrent/EventExecutorGroup;
invokeinterface io.netty.util.concurrent.EventExecutorGroup.next:()Lio/netty/util/concurrent/EventExecutor;
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.adminExecutor:Lio/netty/util/concurrent/EventExecutor;
5: aload 0
aload 1
invokeinterface com.datastax.oss.driver.internal.core.context.InternalDriverContext.getConfig:()Lcom/datastax/oss/driver/api/core/config/DriverConfig;
invokeinterface com.datastax.oss.driver.api.core.config.DriverConfig.getDefaultProfile:()Lcom/datastax/oss/driver/api/core/config/DriverExecutionProfile;
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.config:Lcom/datastax/oss/driver/api/core/config/DriverExecutionProfile;
6: aload 0
new com.datastax.oss.driver.internal.core.metadata.MetadataManager$SingleThreaded
dup
aload 0
aload 1
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.config:Lcom/datastax/oss/driver/api/core/config/DriverExecutionProfile;
invokespecial com.datastax.oss.driver.internal.core.metadata.MetadataManager$SingleThreaded.<init>:(Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Lcom/datastax/oss/driver/api/core/config/DriverExecutionProfile;)V
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.singleThreaded:Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded;
7: aload 0
aload 1
invokeinterface com.datastax.oss.driver.internal.core.context.InternalDriverContext.getControlConnection:()Lcom/datastax/oss/driver/internal/core/control/ControlConnection;
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.controlConnection:Lcom/datastax/oss/driver/internal/core/control/ControlConnection;
8: aload 0
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.config:Lcom/datastax/oss/driver/api/core/config/DriverExecutionProfile;
getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.METADATA_SCHEMA_ENABLED:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
invokeinterface com.datastax.oss.driver.api.core.config.DriverExecutionProfile.getBoolean:(Lcom/datastax/oss/driver/api/core/config/DriverOption;)Z
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.schemaEnabledInConfig:Z
9: aload 0
10: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.config:Lcom/datastax/oss/driver/api/core/config/DriverExecutionProfile;
11: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.METADATA_SCHEMA_REFRESHED_KEYSPACES:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
invokestatic java.util.Collections.emptyList:()Ljava/util/List;
12: invokeinterface com.datastax.oss.driver.api.core.config.DriverExecutionProfile.getStringList:(Lcom/datastax/oss/driver/api/core/config/DriverOption;Ljava/util/List;)Ljava/util/List;
13: putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.refreshedKeyspaces:Ljava/util/List;
14: aload 0
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.logPrefix:Ljava/lang/String;
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.refreshedKeyspaces:Ljava/util/List;
invokestatic com.datastax.oss.driver.internal.core.metadata.schema.queries.KeyspaceFilter.newInstance:(Ljava/lang/String;Ljava/util/List;)Lcom/datastax/oss/driver/internal/core/metadata/schema/queries/KeyspaceFilter;
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.keyspaceFilter:Lcom/datastax/oss/driver/internal/core/metadata/schema/queries/KeyspaceFilter;
15: aload 0
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.config:Lcom/datastax/oss/driver/api/core/config/DriverExecutionProfile;
getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.METADATA_TOKEN_MAP_ENABLED:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
invokeinterface com.datastax.oss.driver.api.core.config.DriverExecutionProfile.getBoolean:(Lcom/datastax/oss/driver/api/core/config/DriverOption;)Z
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.tokenMapEnabled:Z
16: aload 1
invokeinterface com.datastax.oss.driver.internal.core.context.InternalDriverContext.getEventBus:()Lcom/datastax/oss/driver/internal/core/context/EventBus;
ldc Lcom/datastax/oss/driver/internal/core/config/ConfigChangeEvent;
aload 0
invokedynamic accept(Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;)Ljava/util/function/Consumer;
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;)V
com/datastax/oss/driver/internal/core/metadata/MetadataManager.onConfigChanged(Lcom/datastax/oss/driver/internal/core/config/ConfigChangeEvent;)V (7)
(Lcom/datastax/oss/driver/internal/core/config/ConfigChangeEvent;)V
invokevirtual com.datastax.oss.driver.internal.core.context.EventBus.register:(Ljava/lang/Class;Ljava/util/function/Consumer;)Ljava/lang/Object;
pop
17: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
0 18 1 context Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
0 18 2 initialMetadata Lcom/datastax/oss/driver/internal/core/metadata/DefaultMetadata;
MethodParameters:
Name Flags
context
initialMetadata
private void onConfigChanged(com.datastax.oss.driver.internal.core.config.ConfigChangeEvent);
descriptor: (Lcom/datastax/oss/driver/internal/core/config/ConfigChangeEvent;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=5, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual com.datastax.oss.driver.internal.core.metadata.MetadataManager.isSchemaEnabled:()Z
istore 2
start local 2 1: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.tokenMapEnabled:Z
istore 3
start local 3 2: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.refreshedKeyspaces:Ljava/util/List;
astore 4
start local 4 3: aload 0
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.config:Lcom/datastax/oss/driver/api/core/config/DriverExecutionProfile;
getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.METADATA_SCHEMA_ENABLED:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
invokeinterface com.datastax.oss.driver.api.core.config.DriverExecutionProfile.getBoolean:(Lcom/datastax/oss/driver/api/core/config/DriverOption;)Z
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.schemaEnabledInConfig:Z
4: aload 0
5: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.config:Lcom/datastax/oss/driver/api/core/config/DriverExecutionProfile;
6: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.METADATA_SCHEMA_REFRESHED_KEYSPACES:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
invokestatic java.util.Collections.emptyList:()Ljava/util/List;
7: invokeinterface com.datastax.oss.driver.api.core.config.DriverExecutionProfile.getStringList:(Lcom/datastax/oss/driver/api/core/config/DriverOption;Ljava/util/List;)Ljava/util/List;
8: putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.refreshedKeyspaces:Ljava/util/List;
9: aload 0
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.logPrefix:Ljava/lang/String;
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.refreshedKeyspaces:Ljava/util/List;
invokestatic com.datastax.oss.driver.internal.core.metadata.schema.queries.KeyspaceFilter.newInstance:(Ljava/lang/String;Ljava/util/List;)Lcom/datastax/oss/driver/internal/core/metadata/schema/queries/KeyspaceFilter;
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.keyspaceFilter:Lcom/datastax/oss/driver/internal/core/metadata/schema/queries/KeyspaceFilter;
10: aload 0
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.config:Lcom/datastax/oss/driver/api/core/config/DriverExecutionProfile;
getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.METADATA_TOKEN_MAP_ENABLED:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
invokeinterface com.datastax.oss.driver.api.core.config.DriverExecutionProfile.getBoolean:(Lcom/datastax/oss/driver/api/core/config/DriverOption;)Z
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.tokenMapEnabled:Z
11: iload 2
ifeq 14
12: aload 4
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.refreshedKeyspaces:Ljava/util/List;
invokeinterface java.util.List.equals:(Ljava/lang/Object;)Z
ifeq 14
13: iload 3
ifne 18
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.tokenMapEnabled:Z
ifeq 18
14: StackMap locals: int int java.util.List
StackMap stack:
aload 0
invokevirtual com.datastax.oss.driver.internal.core.metadata.MetadataManager.isSchemaEnabled:()Z
ifeq 18
15: aload 0
aconst_null
iconst_0
iconst_1
invokevirtual com.datastax.oss.driver.internal.core.metadata.MetadataManager.refreshSchema:(Ljava/lang/String;ZZ)Ljava/util/concurrent/CompletionStage;
16: aload 0
invokedynamic accept(Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;)Ljava/util/function/BiConsumer;
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;Ljava/lang/Object;)V
com/datastax/oss/driver/internal/core/metadata/MetadataManager.lambda$1(Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$RefreshSchemaResult;Ljava/lang/Throwable;)V (7)
(Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$RefreshSchemaResult;Ljava/lang/Throwable;)V
17: invokeinterface java.util.concurrent.CompletionStage.whenComplete:(Ljava/util/function/BiConsumer;)Ljava/util/concurrent/CompletionStage;
pop
18: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
0 19 1 event Lcom/datastax/oss/driver/internal/core/config/ConfigChangeEvent;
1 19 2 schemaEnabledBefore Z
2 19 3 tokenMapEnabledBefore Z
3 19 4 keyspacesBefore Ljava/util/List<Ljava/lang/String;>;
MethodParameters:
Name Flags
event
public com.datastax.oss.driver.api.core.metadata.Metadata getMetadata();
descriptor: ()Lcom/datastax/oss/driver/api/core/metadata/Metadata;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.metadata:Lcom/datastax/oss/driver/internal/core/metadata/DefaultMetadata;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
public void addContactPoints(java.util.Set<com.datastax.oss.driver.api.core.metadata.EndPoint>);
descriptor: (Ljava/util/Set;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=2
start local 0 start local 1 0: invokestatic com.datastax.oss.driver.shaded.guava.common.collect.ImmutableSet.builder:()Lcom/datastax/oss/driver/shaded/guava/common/collect/ImmutableSet$Builder;
astore 2
start local 2 1: aload 1
ifnull 2
aload 1
invokeinterface java.util.Set.isEmpty:()Z
ifeq 8
2: StackMap locals: com.datastax.oss.driver.shaded.guava.common.collect.ImmutableSet$Builder
StackMap stack:
getstatic com.datastax.oss.driver.internal.core.metadata.MetadataManager.LOG:Lorg/slf4j/Logger;
3: ldc "[{}] No contact points provided, defaulting to {}"
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.logPrefix:Ljava/lang/String;
getstatic com.datastax.oss.driver.internal.core.metadata.MetadataManager.DEFAULT_CONTACT_POINT:Lcom/datastax/oss/driver/api/core/metadata/EndPoint;
4: invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
5: aload 0
iconst_1
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.wasImplicitContactPoint:Z
6: aload 2
new com.datastax.oss.driver.internal.core.metadata.DefaultNode
dup
getstatic com.datastax.oss.driver.internal.core.metadata.MetadataManager.DEFAULT_CONTACT_POINT:Lcom/datastax/oss/driver/api/core/metadata/EndPoint;
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.context:Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
invokespecial com.datastax.oss.driver.internal.core.metadata.DefaultNode.<init>:(Lcom/datastax/oss/driver/api/core/metadata/EndPoint;Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)V
invokevirtual com.datastax.oss.driver.shaded.guava.common.collect.ImmutableSet$Builder.add:(Ljava/lang/Object;)Lcom/datastax/oss/driver/shaded/guava/common/collect/ImmutableSet$Builder;
pop
7: goto 12
8: StackMap locals:
StackMap stack:
aload 1
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 4
goto 11
StackMap locals: com.datastax.oss.driver.internal.core.metadata.MetadataManager java.util.Set com.datastax.oss.driver.shaded.guava.common.collect.ImmutableSet$Builder top java.util.Iterator
StackMap stack:
9: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.metadata.EndPoint
astore 3
start local 3 10: aload 2
new com.datastax.oss.driver.internal.core.metadata.DefaultNode
dup
aload 3
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.context:Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
invokespecial com.datastax.oss.driver.internal.core.metadata.DefaultNode.<init>:(Lcom/datastax/oss/driver/api/core/metadata/EndPoint;Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)V
invokevirtual com.datastax.oss.driver.shaded.guava.common.collect.ImmutableSet$Builder.add:(Ljava/lang/Object;)Lcom/datastax/oss/driver/shaded/guava/common/collect/ImmutableSet$Builder;
pop
end local 3 11: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 9
12: StackMap locals: com.datastax.oss.driver.internal.core.metadata.MetadataManager java.util.Set com.datastax.oss.driver.shaded.guava.common.collect.ImmutableSet$Builder
StackMap stack:
aload 0
aload 2
invokevirtual com.datastax.oss.driver.shaded.guava.common.collect.ImmutableSet$Builder.build:()Lcom/datastax/oss/driver/shaded/guava/common/collect/ImmutableSet;
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.contactPoints:Ljava/util/Set;
13: getstatic com.datastax.oss.driver.internal.core.metadata.MetadataManager.LOG:Lorg/slf4j/Logger;
ldc "[{}] Adding initial contact points {}"
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.logPrefix:Ljava/lang/String;
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.contactPoints:Ljava/util/Set;
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
14: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
0 15 1 providedContactPoints Ljava/util/Set<Lcom/datastax/oss/driver/api/core/metadata/EndPoint;>;
1 15 2 contactPointsBuilder Lcom/datastax/oss/driver/shaded/guava/common/collect/ImmutableSet$Builder<Lcom/datastax/oss/driver/internal/core/metadata/DefaultNode;>;
10 11 3 endPoint Lcom/datastax/oss/driver/api/core/metadata/EndPoint;
Signature: (Ljava/util/Set<Lcom/datastax/oss/driver/api/core/metadata/EndPoint;>;)V
MethodParameters:
Name Flags
providedContactPoints
public java.util.Set<com.datastax.oss.driver.internal.core.metadata.DefaultNode> getContactPoints();
descriptor: ()Ljava/util/Set;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.contactPoints:Ljava/util/Set;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
Signature: ()Ljava/util/Set<Lcom/datastax/oss/driver/internal/core/metadata/DefaultNode;>;
public boolean wasImplicitContactPoint();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.wasImplicitContactPoint:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
public java.util.concurrent.CompletionStage<java.lang.Void> refreshNodes();
descriptor: ()Ljava/util/concurrent/CompletionStage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.context:Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
1: invokeinterface com.datastax.oss.driver.internal.core.context.InternalDriverContext.getTopologyMonitor:()Lcom/datastax/oss/driver/internal/core/metadata/TopologyMonitor;
2: invokeinterface com.datastax.oss.driver.internal.core.metadata.TopologyMonitor.refreshNodeList:()Ljava/util/concurrent/CompletionStage;
3: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.singleThreaded:Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded;
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic apply(Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded;)Ljava/util/function/Function;
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;)Ljava/lang/Object;
com/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded.access$0(Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded;Ljava/lang/Iterable;)Ljava/lang/Void; (6)
(Ljava/lang/Iterable;)Ljava/lang/Void;
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.adminExecutor:Lio/netty/util/concurrent/EventExecutor;
invokeinterface java.util.concurrent.CompletionStage.thenApplyAsync:(Ljava/util/function/Function;Ljava/util/concurrent/Executor;)Ljava/util/concurrent/CompletionStage;
4: areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
Signature: ()Ljava/util/concurrent/CompletionStage<Ljava/lang/Void;>;
public java.util.concurrent.CompletionStage<java.lang.Void> refreshNode(com.datastax.oss.driver.api.core.metadata.Node);
descriptor: (Lcom/datastax/oss/driver/api/core/metadata/Node;)Ljava/util/concurrent/CompletionStage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.context:Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
1: invokeinterface com.datastax.oss.driver.internal.core.context.InternalDriverContext.getTopologyMonitor:()Lcom/datastax/oss/driver/internal/core/metadata/TopologyMonitor;
2: aload 1
invokeinterface com.datastax.oss.driver.internal.core.metadata.TopologyMonitor.refreshNode:(Lcom/datastax/oss/driver/api/core/metadata/Node;)Ljava/util/concurrent/CompletionStage;
3: aload 0
aload 1
invokedynamic apply(Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;Lcom/datastax/oss/driver/api/core/metadata/Node;)Ljava/util/function/Function;
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;)Ljava/lang/Object;
com/datastax/oss/driver/internal/core/metadata/MetadataManager.lambda$3(Lcom/datastax/oss/driver/api/core/metadata/Node;Ljava/util/Optional;)Ljava/lang/Void; (7)
(Ljava/util/Optional;)Ljava/lang/Void;
4: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.adminExecutor:Lio/netty/util/concurrent/EventExecutor;
5: invokeinterface java.util.concurrent.CompletionStage.thenApplyAsync:(Ljava/util/function/Function;Ljava/util/concurrent/Executor;)Ljava/util/concurrent/CompletionStage;
6: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
0 7 1 node Lcom/datastax/oss/driver/api/core/metadata/Node;
Signature: (Lcom/datastax/oss/driver/api/core/metadata/Node;)Ljava/util/concurrent/CompletionStage<Ljava/lang/Void;>;
MethodParameters:
Name Flags
node
public void addNode(java.net.InetSocketAddress);
descriptor: (Ljava/net/InetSocketAddress;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.context:Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
1: invokeinterface com.datastax.oss.driver.internal.core.context.InternalDriverContext.getTopologyMonitor:()Lcom/datastax/oss/driver/internal/core/metadata/TopologyMonitor;
2: aload 1
invokeinterface com.datastax.oss.driver.internal.core.metadata.TopologyMonitor.getNewNodeInfo:(Ljava/net/InetSocketAddress;)Ljava/util/concurrent/CompletionStage;
3: aload 0
aload 1
invokedynamic accept(Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;Ljava/net/InetSocketAddress;)Ljava/util/function/BiConsumer;
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;Ljava/lang/Object;)V
com/datastax/oss/driver/internal/core/metadata/MetadataManager.lambda$4(Ljava/net/InetSocketAddress;Ljava/util/Optional;Ljava/lang/Throwable;)V (7)
(Ljava/util/Optional;Ljava/lang/Throwable;)V
4: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.adminExecutor:Lio/netty/util/concurrent/EventExecutor;
5: invokeinterface java.util.concurrent.CompletionStage.whenCompleteAsync:(Ljava/util/function/BiConsumer;Ljava/util/concurrent/Executor;)Ljava/util/concurrent/CompletionStage;
pop
6: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
0 7 1 broadcastRpcAddress Ljava/net/InetSocketAddress;
MethodParameters:
Name Flags
broadcastRpcAddress
public void removeNode(java.net.InetSocketAddress);
descriptor: (Ljava/net/InetSocketAddress;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.adminExecutor:Lio/netty/util/concurrent/EventExecutor;
aload 0
aload 1
invokedynamic run(Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;Ljava/net/InetSocketAddress;)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
com/datastax/oss/driver/internal/core/metadata/MetadataManager.lambda$5(Ljava/net/InetSocketAddress;)V (7)
()V
invokestatic com.datastax.oss.driver.internal.core.util.concurrent.RunOrSchedule.on:(Lio/netty/util/concurrent/EventExecutor;Ljava/lang/Runnable;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
0 2 1 broadcastRpcAddress Ljava/net/InetSocketAddress;
MethodParameters:
Name Flags
broadcastRpcAddress
public java.util.concurrent.CompletionStage<com.datastax.oss.driver.internal.core.metadata.MetadataManager$RefreshSchemaResult> refreshSchema(java.lang.String, boolean, boolean);
descriptor: (Ljava/lang/String;ZZ)Ljava/util/concurrent/CompletionStage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new java.util.concurrent.CompletableFuture
dup
invokespecial java.util.concurrent.CompletableFuture.<init>:()V
astore 4
start local 4 1: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.adminExecutor:Lio/netty/util/concurrent/EventExecutor;
2: aload 0
aload 1
iload 2
iload 3
aload 4
invokedynamic run(Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;Ljava/lang/String;ZZLjava/util/concurrent/CompletableFuture;)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
com/datastax/oss/driver/internal/core/metadata/MetadataManager.lambda$6(Ljava/lang/String;ZZLjava/util/concurrent/CompletableFuture;)V (7)
()V
3: invokestatic com.datastax.oss.driver.internal.core.util.concurrent.RunOrSchedule.on:(Lio/netty/util/concurrent/EventExecutor;Ljava/lang/Runnable;)V
4: aload 4
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
0 5 1 keyspace Ljava/lang/String;
0 5 2 evenIfDisabled Z
0 5 3 flushNow Z
1 5 4 future Ljava/util/concurrent/CompletableFuture<Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$RefreshSchemaResult;>;
Signature: (Ljava/lang/String;ZZ)Ljava/util/concurrent/CompletionStage<Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$RefreshSchemaResult;>;
MethodParameters:
Name Flags
keyspace
evenIfDisabled
flushNow
public boolean isSchemaEnabled();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.schemaEnabledProgrammatically:Ljava/lang/Boolean;
ifnull 2
1: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.schemaEnabledProgrammatically:Ljava/lang/Boolean;
invokevirtual java.lang.Boolean.booleanValue:()Z
goto 3
2: StackMap locals:
StackMap stack:
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.schemaEnabledInConfig:Z
3: StackMap locals:
StackMap stack: int
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
public java.util.concurrent.CompletionStage<com.datastax.oss.driver.api.core.metadata.Metadata> setSchemaEnabled(java.lang.Boolean);
descriptor: (Ljava/lang/Boolean;)Ljava/util/concurrent/CompletionStage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual com.datastax.oss.driver.internal.core.metadata.MetadataManager.isSchemaEnabled:()Z
istore 2
start local 2 1: aload 0
aload 1
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.schemaEnabledProgrammatically:Ljava/lang/Boolean;
2: iload 2
ifne 4
aload 0
invokevirtual com.datastax.oss.driver.internal.core.metadata.MetadataManager.isSchemaEnabled:()Z
ifeq 4
3: aload 0
aconst_null
iconst_0
iconst_1
invokevirtual com.datastax.oss.driver.internal.core.metadata.MetadataManager.refreshSchema:(Ljava/lang/String;ZZ)Ljava/util/concurrent/CompletionStage;
invokedynamic apply()Ljava/util/function/Function;
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;)Ljava/lang/Object;
com/datastax/oss/driver/internal/core/metadata/MetadataManager$RefreshSchemaResult.getMetadata()Lcom/datastax/oss/driver/api/core/metadata/Metadata; (5)
(Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$RefreshSchemaResult;)Lcom/datastax/oss/driver/api/core/metadata/Metadata;
invokeinterface java.util.concurrent.CompletionStage.thenApply:(Ljava/util/function/Function;)Ljava/util/concurrent/CompletionStage;
areturn
4: StackMap locals: int
StackMap stack:
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.metadata:Lcom/datastax/oss/driver/internal/core/metadata/DefaultMetadata;
invokestatic java.util.concurrent.CompletableFuture.completedFuture:(Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
0 5 1 newValue Ljava/lang/Boolean;
1 5 2 wasEnabledBefore Z
Signature: (Ljava/lang/Boolean;)Ljava/util/concurrent/CompletionStage<Lcom/datastax/oss/driver/api/core/metadata/Metadata;>;
MethodParameters:
Name Flags
newValue
public java.util.concurrent.CompletionStage<java.lang.Void> closeFuture();
descriptor: ()Ljava/util/concurrent/CompletionStage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.singleThreaded:Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded;
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager$SingleThreaded.closeFuture:Ljava/util/concurrent/CompletableFuture;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
Signature: ()Ljava/util/concurrent/CompletionStage<Ljava/lang/Void;>;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public java.util.concurrent.CompletionStage<java.lang.Void> closeAsync();
descriptor: ()Ljava/util/concurrent/CompletionStage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.adminExecutor:Lio/netty/util/concurrent/EventExecutor;
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.singleThreaded:Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded;
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic run(Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded;)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
com/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded.access$1(Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded;)V (6)
()V
invokestatic com.datastax.oss.driver.internal.core.util.concurrent.RunOrSchedule.on:(Lio/netty/util/concurrent/EventExecutor;Ljava/lang/Runnable;)V
1: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.singleThreaded:Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded;
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager$SingleThreaded.closeFuture:Ljava/util/concurrent/CompletableFuture;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
Signature: ()Ljava/util/concurrent/CompletionStage<Ljava/lang/Void;>;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public java.util.concurrent.CompletionStage<java.lang.Void> forceCloseAsync();
descriptor: ()Ljava/util/concurrent/CompletionStage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual com.datastax.oss.driver.internal.core.metadata.MetadataManager.closeAsync:()Ljava/util/concurrent/CompletionStage;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
Signature: ()Ljava/util/concurrent/CompletionStage<Ljava/lang/Void;>;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
java.lang.Void apply(com.datastax.oss.driver.internal.core.metadata.MetadataRefresh);
descriptor: (Lcom/datastax/oss/driver/internal/core/metadata/MetadataRefresh;)Ljava/lang/Void;
flags: (0x0000)
Code:
stack=4, locals=6, args_size=2
start local 0 start local 1 0: getstatic com.datastax.oss.driver.internal.core.metadata.MetadataManager.$assertionsDisabled:Z
ifne 1
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.adminExecutor:Lio/netty/util/concurrent/EventExecutor;
invokeinterface io.netty.util.concurrent.EventExecutor.inEventLoop:()Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 1
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.metadata:Lcom/datastax/oss/driver/internal/core/metadata/DefaultMetadata;
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.tokenMapEnabled:Z
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.context:Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
invokeinterface com.datastax.oss.driver.internal.core.metadata.MetadataRefresh.compute:(Lcom/datastax/oss/driver/internal/core/metadata/DefaultMetadata;ZLcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)Lcom/datastax/oss/driver/internal/core/metadata/MetadataRefresh$Result;
astore 2
start local 2 2: aload 0
aload 2
getfield com.datastax.oss.driver.internal.core.metadata.MetadataRefresh$Result.newMetadata:Lcom/datastax/oss/driver/internal/core/metadata/DefaultMetadata;
putfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.metadata:Lcom/datastax/oss/driver/internal/core/metadata/DefaultMetadata;
3: aload 1
instanceof com.datastax.oss.driver.internal.core.metadata.schema.refresh.SchemaRefresh
ifeq 5
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.singleThreaded:Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded;
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager$SingleThreaded.firstSchemaRefreshFuture:Ljava/util/concurrent/CompletableFuture;
invokevirtual java.util.concurrent.CompletableFuture.isDone:()Z
ifne 5
4: iconst_1
goto 6
StackMap locals: com.datastax.oss.driver.internal.core.metadata.MetadataRefresh$Result
StackMap stack:
5: iconst_0
StackMap locals:
StackMap stack: int
6: istore 3
start local 3 7: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.singleThreaded:Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded;
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager$SingleThreaded.closeWasCalled:Z
ifne 12
iload 3
ifne 12
8: aload 2
getfield com.datastax.oss.driver.internal.core.metadata.MetadataRefresh$Result.events:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 5
goto 11
StackMap locals: com.datastax.oss.driver.internal.core.metadata.MetadataManager com.datastax.oss.driver.internal.core.metadata.MetadataRefresh com.datastax.oss.driver.internal.core.metadata.MetadataRefresh$Result int top java.util.Iterator
StackMap stack:
9: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
astore 4
start local 4 10: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.context:Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
invokeinterface com.datastax.oss.driver.internal.core.context.InternalDriverContext.getEventBus:()Lcom/datastax/oss/driver/internal/core/context/EventBus;
aload 4
invokevirtual com.datastax.oss.driver.internal.core.context.EventBus.fire:(Ljava/lang/Object;)V
end local 4 11: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 9
12: StackMap locals: com.datastax.oss.driver.internal.core.metadata.MetadataManager com.datastax.oss.driver.internal.core.metadata.MetadataRefresh com.datastax.oss.driver.internal.core.metadata.MetadataRefresh$Result int
StackMap stack:
aconst_null
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
0 13 1 refresh Lcom/datastax/oss/driver/internal/core/metadata/MetadataRefresh;
2 13 2 result Lcom/datastax/oss/driver/internal/core/metadata/MetadataRefresh$Result;
7 13 3 isFirstSchemaRefresh Z
10 11 4 event Ljava/lang/Object;
RuntimeInvisibleAnnotations:
com.datastax.oss.driver.shaded.guava.common.annotations.VisibleForTesting()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
com.datastax.oss.driver.shaded.guava.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
refresh
static com.datastax.oss.driver.internal.core.context.InternalDriverContext access$0(com.datastax.oss.driver.internal.core.metadata.MetadataManager);
descriptor: (Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;)Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.context:Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
areturn
LocalVariableTable:
Start End Slot Name Signature
private void lambda$1(com.datastax.oss.driver.internal.core.metadata.MetadataManager$RefreshSchemaResult, java.lang.Throwable);
descriptor: (Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$RefreshSchemaResult;Ljava/lang/Throwable;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 2
ifnull 6
1: getstatic com.datastax.oss.driver.internal.core.metadata.MetadataManager.LOG:Lorg/slf4j/Logger;
2: ldc "[{}] Unexpected error while refreshing schema after it was re-enabled in the configuration, keeping previous version"
iconst_2
anewarray java.lang.Object
dup
iconst_0
3: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.logPrefix:Ljava/lang/String;
aastore
dup
iconst_1
4: aload 2
aastore
5: invokestatic com.datastax.oss.driver.internal.core.util.Loggers.warnWithException:(Lorg/slf4j/Logger;Ljava/lang/String;[Ljava/lang/Object;)V
6: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
0 7 1 metadata Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$RefreshSchemaResult;
0 7 2 error Ljava/lang/Throwable;
private java.lang.Void lambda$3(com.datastax.oss.driver.api.core.metadata.Node, java.util.Optional);
descriptor: (Lcom/datastax/oss/driver/api/core/metadata/Node;Ljava/util/Optional;)Ljava/lang/Void;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 2 0: aload 2
invokevirtual java.util.Optional.isPresent:()Z
ifeq 6
1: aload 2
invokevirtual java.util.Optional.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.metadata.NodeInfo
aload 1
checkcast com.datastax.oss.driver.internal.core.metadata.DefaultNode
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.context:Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
invokestatic com.datastax.oss.driver.internal.core.metadata.NodesRefresh.copyInfos:(Lcom/datastax/oss/driver/internal/core/metadata/NodeInfo;Lcom/datastax/oss/driver/internal/core/metadata/DefaultNode;Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)Z
2: istore 3
start local 3 3: iload 3
ifeq 11
4: aload 0
new com.datastax.oss.driver.internal.core.metadata.TokensChangedRefresh
dup
invokespecial com.datastax.oss.driver.internal.core.metadata.TokensChangedRefresh.<init>:()V
invokevirtual com.datastax.oss.driver.internal.core.metadata.MetadataManager.apply:(Lcom/datastax/oss/driver/internal/core/metadata/MetadataRefresh;)Ljava/lang/Void;
pop
end local 3 5: goto 11
6: StackMap locals:
StackMap stack:
getstatic com.datastax.oss.driver.internal.core.metadata.MetadataManager.LOG:Lorg/slf4j/Logger;
7: ldc "[{}] Topology monitor did not return any info for the refresh of {}, skipping"
8: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.logPrefix:Ljava/lang/String;
9: aload 1
10: invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
11: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
0 12 2 maybeInfo Ljava/util/Optional<Lcom/datastax/oss/driver/internal/core/metadata/NodeInfo;>;
3 5 3 tokensChanged Z
private void lambda$4(java.net.InetSocketAddress, java.util.Optional, java.lang.Throwable);
descriptor: (Ljava/net/InetSocketAddress;Ljava/util/Optional;Ljava/lang/Throwable;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 2 start local 3 0: aload 3
ifnull 8
1: getstatic com.datastax.oss.driver.internal.core.metadata.MetadataManager.LOG:Lorg/slf4j/Logger;
2: ldc "[{}] Error refreshing node info for {}, this will be retried on the next full refresh"
iconst_3
anewarray java.lang.Object
dup
iconst_0
3: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.logPrefix:Ljava/lang/String;
aastore
dup
iconst_1
4: aload 1
aastore
dup
iconst_2
5: aload 3
aastore
6: invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;[Ljava/lang/Object;)V
7: goto 9
8: StackMap locals:
StackMap stack:
aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.singleThreaded:Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded;
aload 1
aload 2
aconst_null
invokevirtual java.util.Optional.orElse:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.metadata.NodeInfo
invokevirtual com.datastax.oss.driver.internal.core.metadata.MetadataManager$SingleThreaded.addNode:(Ljava/net/InetSocketAddress;Lcom/datastax/oss/driver/internal/core/metadata/NodeInfo;)V
9: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
0 10 2 info Ljava/util/Optional<Lcom/datastax/oss/driver/internal/core/metadata/NodeInfo;>;
0 10 3 error Ljava/lang/Throwable;
private void lambda$5(java.net.InetSocketAddress);
descriptor: (Ljava/net/InetSocketAddress;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 0: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.singleThreaded:Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded;
aload 1
invokevirtual com.datastax.oss.driver.internal.core.metadata.MetadataManager$SingleThreaded.removeNode:(Ljava/net/InetSocketAddress;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
private void lambda$6(java.lang.String, boolean, boolean, java.util.concurrent.CompletableFuture);
descriptor: (Ljava/lang/String;ZZLjava/util/concurrent/CompletableFuture;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=5, args_size=5
start local 0 0: aload 0
getfield com.datastax.oss.driver.internal.core.metadata.MetadataManager.singleThreaded:Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager$SingleThreaded;
aload 1
iload 2
iload 3
aload 4
invokevirtual com.datastax.oss.driver.internal.core.metadata.MetadataManager$SingleThreaded.refreshSchema:(Ljava/lang/String;ZZLjava/util/concurrent/CompletableFuture;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
}
SourceFile: "MetadataManager.java"
NestMembers:
com.datastax.oss.driver.internal.core.metadata.MetadataManager$RefreshSchemaResult com.datastax.oss.driver.internal.core.metadata.MetadataManager$SingleThreaded
InnerClasses:
public RefreshSchemaResult = com.datastax.oss.driver.internal.core.metadata.MetadataManager$RefreshSchemaResult of com.datastax.oss.driver.internal.core.metadata.MetadataManager
private SingleThreaded = com.datastax.oss.driver.internal.core.metadata.MetadataManager$SingleThreaded of com.datastax.oss.driver.internal.core.metadata.MetadataManager
public Result = com.datastax.oss.driver.internal.core.metadata.MetadataRefresh$Result of com.datastax.oss.driver.internal.core.metadata.MetadataRefresh
public Builder = com.datastax.oss.driver.shaded.guava.common.collect.ImmutableSet$Builder of com.datastax.oss.driver.shaded.guava.common.collect.ImmutableSet
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
RuntimeVisibleAnnotations:
net.jcip.annotations.ThreadSafe()