public class com.datastax.oss.driver.internal.core.context.DefaultDriverContext implements com.datastax.oss.driver.internal.core.context.InternalDriverContext
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: com.datastax.oss.driver.internal.core.context.DefaultDriverContext
super_class: java.lang.Object
{
private static final java.util.concurrent.atomic.AtomicInteger SESSION_NAME_COUNTER;
descriptor: Ljava/util/concurrent/atomic/AtomicInteger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
protected final com.datastax.oss.driver.internal.core.util.concurrent.CycleDetector cycleDetector;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<java.util.Map<java.lang.String, com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy>> loadBalancingPoliciesRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Ljava/util/Map<Ljava/lang/String;Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;>;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.api.core.connection.ReconnectionPolicy> reconnectionPolicyRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/api/core/connection/ReconnectionPolicy;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<java.util.Map<java.lang.String, com.datastax.oss.driver.api.core.retry.RetryPolicy>> retryPoliciesRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Ljava/util/Map<Ljava/lang/String;Lcom/datastax/oss/driver/api/core/retry/RetryPolicy;>;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<java.util.Map<java.lang.String, com.datastax.oss.driver.api.core.specex.SpeculativeExecutionPolicy>> speculativeExecutionPoliciesRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Ljava/util/Map<Ljava/lang/String;Lcom/datastax/oss/driver/api/core/specex/SpeculativeExecutionPolicy;>;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.api.core.time.TimestampGenerator> timestampGeneratorRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/api/core/time/TimestampGenerator;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.api.core.addresstranslation.AddressTranslator> addressTranslatorRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/api/core/addresstranslation/AddressTranslator;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<java.util.Optional<com.datastax.oss.driver.api.core.ssl.SslEngineFactory>> sslEngineFactoryRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Ljava/util/Optional<Lcom/datastax/oss/driver/api/core/ssl/SslEngineFactory;>;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.context.EventBus> eventBusRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/context/EventBus;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.protocol.internal.Compressor<io.netty.buffer.ByteBuf>> compressorRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/protocol/internal/Compressor<Lio/netty/buffer/ByteBuf;>;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.protocol.internal.FrameCodec<io.netty.buffer.ByteBuf>> frameCodecRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/protocol/internal/FrameCodec<Lio/netty/buffer/ByteBuf;>;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.ProtocolVersionRegistry> protocolVersionRegistryRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/ProtocolVersionRegistry;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.ConsistencyLevelRegistry> consistencyLevelRegistryRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/ConsistencyLevelRegistry;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.servererrors.WriteTypeRegistry> writeTypeRegistryRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/servererrors/WriteTypeRegistry;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.context.NettyOptions> nettyOptionsRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/context/NettyOptions;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.channel.WriteCoalescer> writeCoalescerRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/channel/WriteCoalescer;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<java.util.Optional<com.datastax.oss.driver.internal.core.ssl.SslHandlerFactory>> sslHandlerFactoryRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Ljava/util/Optional<Lcom/datastax/oss/driver/internal/core/ssl/SslHandlerFactory;>;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.channel.ChannelFactory> channelFactoryRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/channel/ChannelFactory;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.metadata.TopologyMonitor> topologyMonitorRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/metadata/TopologyMonitor;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.metadata.MetadataManager> metadataManagerRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper> loadBalancingPolicyWrapperRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.control.ControlConnection> controlConnectionRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/control/ControlConnection;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.session.RequestProcessorRegistry> requestProcessorRegistryRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/session/RequestProcessorRegistry;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.metadata.schema.queries.SchemaQueriesFactory> schemaQueriesFactoryRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/metadata/schema/queries/SchemaQueriesFactory;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.metadata.schema.parsing.SchemaParserFactory> schemaParserFactoryRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/metadata/schema/parsing/SchemaParserFactory;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.metadata.token.TokenFactoryRegistry> tokenFactoryRegistryRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/metadata/token/TokenFactoryRegistry;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.metadata.token.ReplicationStrategyFactory> replicationStrategyFactoryRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/metadata/token/ReplicationStrategyFactory;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.session.PoolManager> poolManagerRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/session/PoolManager;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.metrics.MetricsFactory> metricsFactoryRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/metrics/MetricsFactory;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.api.core.session.throttling.RequestThrottler> requestThrottlerRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/api/core/session/throttling/RequestThrottler;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<java.util.Map<java.lang.String, java.lang.String>> startupOptionsRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.api.core.metadata.NodeStateListener> nodeStateListenerRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.api.core.metadata.schema.SchemaChangeListener> schemaChangeListenerRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.api.core.tracker.RequestTracker> requestTrackerRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;>;
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<java.util.Optional<com.datastax.oss.driver.api.core.auth.AuthProvider>> authProviderRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Ljava/util/Optional<Lcom/datastax/oss/driver/api/core/auth/AuthProvider;>;>;
private final com.datastax.oss.driver.api.core.config.DriverConfig config;
descriptor: Lcom/datastax/oss/driver/api/core/config/DriverConfig;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.datastax.oss.driver.api.core.config.DriverConfigLoader configLoader;
descriptor: Lcom/datastax/oss/driver/api/core/config/DriverConfigLoader;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.datastax.oss.driver.internal.core.pool.ChannelPoolFactory channelPoolFactory;
descriptor: Lcom/datastax/oss/driver/internal/core/pool/ChannelPoolFactory;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.datastax.oss.driver.api.core.type.codec.registry.CodecRegistry codecRegistry;
descriptor: Lcom/datastax/oss/driver/api/core/type/codec/registry/CodecRegistry;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.String sessionName;
descriptor: Ljava/lang/String;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.datastax.oss.driver.api.core.metadata.NodeStateListener nodeStateListenerFromBuilder;
descriptor: Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.datastax.oss.driver.api.core.metadata.schema.SchemaChangeListener schemaChangeListenerFromBuilder;
descriptor: Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.datastax.oss.driver.api.core.tracker.RequestTracker requestTrackerFromBuilder;
descriptor: Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.Map<java.lang.String, java.lang.String> localDatacentersFromBuilder;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
private final java.util.Map<java.lang.String, java.util.function.Predicate<com.datastax.oss.driver.api.core.metadata.Node>> nodeFiltersFromBuilder;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/String;Ljava/util/function/Predicate<Lcom/datastax/oss/driver/api/core/metadata/Node;>;>;
private final java.lang.ClassLoader classLoader;
descriptor: Ljava/lang/ClassLoader;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.net.InetSocketAddress cloudProxyAddress;
descriptor: Ljava/net/InetSocketAddress;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final com.datastax.oss.driver.internal.core.util.concurrent.LazyReference<com.datastax.oss.driver.internal.core.tracker.RequestLogFormatter> requestLogFormatterRef;
descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference<Lcom/datastax/oss/driver/internal/core/tracker/RequestLogFormatter;>;
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=2, locals=0, args_size=0
0: ldc Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
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.context.DefaultDriverContext.$assertionsDisabled:Z
3: new java.util.concurrent.atomic.AtomicInteger
dup
invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
putstatic com.datastax.oss.driver.internal.core.context.DefaultDriverContext.SESSION_NAME_COUNTER:Ljava/util/concurrent/atomic/AtomicInteger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(com.datastax.oss.driver.api.core.config.DriverConfigLoader, com.datastax.oss.driver.api.core.session.ProgrammaticArguments);
descriptor: (Lcom/datastax/oss/driver/api/core/config/DriverConfigLoader;Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
2: new com.datastax.oss.driver.internal.core.util.concurrent.CycleDetector
dup
ldc "Detected cycle in context initialization"
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.CycleDetector.<init>:(Ljava/lang/String;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
3: aload 0
4: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "loadBalancingPolicies"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildLoadBalancingPolicies()Ljava/util/Map; (5)
()Ljava/util/Map;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.loadBalancingPoliciesRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
5: aload 0
6: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "reconnectionPolicy"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildReconnectionPolicy()Lcom/datastax/oss/driver/api/core/connection/ReconnectionPolicy; (5)
()Lcom/datastax/oss/driver/api/core/connection/ReconnectionPolicy;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.reconnectionPolicyRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
7: aload 0
8: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "retryPolicies"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildRetryPolicies()Ljava/util/Map; (5)
()Ljava/util/Map;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.retryPoliciesRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
9: aload 0
10: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
11: ldc "speculativeExecutionPolicies"
12: aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildSpeculativeExecutionPolicies()Ljava/util/Map; (5)
()Ljava/util/Map;
13: aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
14: invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.speculativeExecutionPoliciesRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
15: aload 0
16: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "timestampGenerator"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildTimestampGenerator()Lcom/datastax/oss/driver/api/core/time/TimestampGenerator; (5)
()Lcom/datastax/oss/driver/api/core/time/TimestampGenerator;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.timestampGeneratorRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
17: aload 0
18: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "addressTranslator"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildAddressTranslator()Lcom/datastax/oss/driver/api/core/addresstranslation/AddressTranslator; (5)
()Lcom/datastax/oss/driver/api/core/addresstranslation/AddressTranslator;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.addressTranslatorRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
19: aload 0
20: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "eventBus"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildEventBus()Lcom/datastax/oss/driver/internal/core/context/EventBus; (5)
()Lcom/datastax/oss/driver/internal/core/context/EventBus;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.eventBusRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
21: aload 0
22: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "compressor"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildCompressor()Lcom/datastax/oss/protocol/internal/Compressor; (5)
()Lcom/datastax/oss/protocol/internal/Compressor;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.compressorRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
23: aload 0
24: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "frameCodec"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildFrameCodec()Lcom/datastax/oss/protocol/internal/FrameCodec; (5)
()Lcom/datastax/oss/protocol/internal/FrameCodec;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.frameCodecRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
25: aload 0
26: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
27: ldc "protocolVersionRegistry"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildProtocolVersionRegistry()Lcom/datastax/oss/driver/internal/core/ProtocolVersionRegistry; (5)
()Lcom/datastax/oss/driver/internal/core/ProtocolVersionRegistry;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
28: invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.protocolVersionRegistryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
29: aload 0
30: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
31: ldc "consistencyLevelRegistry"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildConsistencyLevelRegistry()Lcom/datastax/oss/driver/internal/core/ConsistencyLevelRegistry; (5)
()Lcom/datastax/oss/driver/internal/core/ConsistencyLevelRegistry;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
32: invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.consistencyLevelRegistryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
33: aload 0
34: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "writeTypeRegistry"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildWriteTypeRegistry()Lcom/datastax/oss/driver/internal/core/servererrors/WriteTypeRegistry; (5)
()Lcom/datastax/oss/driver/internal/core/servererrors/WriteTypeRegistry;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.writeTypeRegistryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
35: aload 0
36: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "nettyOptions"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildNettyOptions()Lcom/datastax/oss/driver/internal/core/context/NettyOptions; (5)
()Lcom/datastax/oss/driver/internal/core/context/NettyOptions;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.nettyOptionsRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
37: aload 0
38: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "writeCoalescer"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildWriteCoalescer()Lcom/datastax/oss/driver/internal/core/channel/WriteCoalescer; (5)
()Lcom/datastax/oss/driver/internal/core/channel/WriteCoalescer;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.writeCoalescerRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
39: aload 0
40: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "sslHandlerFactory"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildSslHandlerFactory()Ljava/util/Optional; (5)
()Ljava/util/Optional;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.sslHandlerFactoryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
41: aload 0
42: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "channelFactory"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildChannelFactory()Lcom/datastax/oss/driver/internal/core/channel/ChannelFactory; (5)
()Lcom/datastax/oss/driver/internal/core/channel/ChannelFactory;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.channelFactoryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
43: aload 0
44: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "topologyMonitor"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildTopologyMonitor()Lcom/datastax/oss/driver/internal/core/metadata/TopologyMonitor; (5)
()Lcom/datastax/oss/driver/internal/core/metadata/TopologyMonitor;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.topologyMonitorRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
45: aload 0
46: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "metadataManager"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildMetadataManager()Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager; (5)
()Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.metadataManagerRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
47: aload 0
48: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
49: ldc "loadBalancingPolicyWrapper"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildLoadBalancingPolicyWrapper()Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper; (5)
()Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
50: invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.loadBalancingPolicyWrapperRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
51: aload 0
52: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "controlConnection"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildControlConnection()Lcom/datastax/oss/driver/internal/core/control/ControlConnection; (5)
()Lcom/datastax/oss/driver/internal/core/control/ControlConnection;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.controlConnectionRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
53: aload 0
54: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
55: ldc "requestProcessorRegistry"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildRequestProcessorRegistry()Lcom/datastax/oss/driver/internal/core/session/RequestProcessorRegistry; (5)
()Lcom/datastax/oss/driver/internal/core/session/RequestProcessorRegistry;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
56: invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.requestProcessorRegistryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
57: aload 0
58: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "schemaQueriesFactory"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildSchemaQueriesFactory()Lcom/datastax/oss/driver/internal/core/metadata/schema/queries/SchemaQueriesFactory; (5)
()Lcom/datastax/oss/driver/internal/core/metadata/schema/queries/SchemaQueriesFactory;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.schemaQueriesFactoryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
59: aload 0
60: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "schemaParserFactory"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildSchemaParserFactory()Lcom/datastax/oss/driver/internal/core/metadata/schema/parsing/SchemaParserFactory; (5)
()Lcom/datastax/oss/driver/internal/core/metadata/schema/parsing/SchemaParserFactory;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.schemaParserFactoryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
61: aload 0
62: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "tokenFactoryRegistry"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildTokenFactoryRegistry()Lcom/datastax/oss/driver/internal/core/metadata/token/TokenFactoryRegistry; (5)
()Lcom/datastax/oss/driver/internal/core/metadata/token/TokenFactoryRegistry;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.tokenFactoryRegistryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
63: aload 0
64: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
65: ldc "replicationStrategyFactory"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildReplicationStrategyFactory()Lcom/datastax/oss/driver/internal/core/metadata/token/ReplicationStrategyFactory; (5)
()Lcom/datastax/oss/driver/internal/core/metadata/token/ReplicationStrategyFactory;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
66: invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.replicationStrategyFactoryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
67: aload 0
68: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "poolManager"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildPoolManager()Lcom/datastax/oss/driver/internal/core/session/PoolManager; (5)
()Lcom/datastax/oss/driver/internal/core/session/PoolManager;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.poolManagerRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
69: aload 0
70: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "metricsFactory"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildMetricsFactory()Lcom/datastax/oss/driver/internal/core/metrics/MetricsFactory; (5)
()Lcom/datastax/oss/driver/internal/core/metrics/MetricsFactory;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.metricsFactoryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
71: aload 0
72: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "requestThrottler"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildRequestThrottler()Lcom/datastax/oss/driver/api/core/session/throttling/RequestThrottler; (5)
()Lcom/datastax/oss/driver/api/core/session/throttling/RequestThrottler;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.requestThrottlerRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
73: aload 0
74: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "startupOptions"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildStartupOptions()Ljava/util/Map; (5)
()Ljava/util/Map;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.startupOptionsRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
75: aload 0
new com.datastax.oss.driver.internal.core.pool.ChannelPoolFactory
dup
invokespecial com.datastax.oss.driver.internal.core.pool.ChannelPoolFactory.<init>:()V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.channelPoolFactory:Lcom/datastax/oss/driver/internal/core/pool/ChannelPoolFactory;
76: aload 0
77: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
ldc "requestLogFormatter"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.buildRequestLogFormatter()Lcom/datastax/oss/driver/internal/core/tracker/RequestLogFormatter; (5)
()Lcom/datastax/oss/driver/internal/core/tracker/RequestLogFormatter;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.requestLogFormatterRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
78: aload 0
aload 1
invokeinterface com.datastax.oss.driver.api.core.config.DriverConfigLoader.getInitialConfig:()Lcom/datastax/oss/driver/api/core/config/DriverConfig;
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.config:Lcom/datastax/oss/driver/api/core/config/DriverConfig;
79: aload 0
aload 1
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.configLoader:Lcom/datastax/oss/driver/api/core/config/DriverConfigLoader;
80: aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.config: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;
astore 3
start local 3 81: aload 3
getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.SESSION_NAME:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
invokeinterface com.datastax.oss.driver.api.core.config.DriverExecutionProfile.isDefined:(Lcom/datastax/oss/driver/api/core/config/DriverOption;)Z
ifeq 84
82: aload 0
aload 3
getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.SESSION_NAME:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
invokeinterface com.datastax.oss.driver.api.core.config.DriverExecutionProfile.getString:(Lcom/datastax/oss/driver/api/core/config/DriverOption;)Ljava/lang/String;
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.sessionName:Ljava/lang/String;
83: goto 85
84: StackMap locals: com.datastax.oss.driver.internal.core.context.DefaultDriverContext com.datastax.oss.driver.api.core.config.DriverConfigLoader com.datastax.oss.driver.api.core.session.ProgrammaticArguments com.datastax.oss.driver.api.core.config.DriverExecutionProfile
StackMap stack:
aload 0
new java.lang.StringBuilder
dup
ldc "s"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
getstatic com.datastax.oss.driver.internal.core.context.DefaultDriverContext.SESSION_NAME_COUNTER:Ljava/util/concurrent/atomic/AtomicInteger;
invokevirtual java.util.concurrent.atomic.AtomicInteger.getAndIncrement:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.sessionName:Ljava/lang/String;
85: StackMap locals:
StackMap stack:
aload 0
aload 2
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments.getLocalDatacenters:()Ljava/util/Map;
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.localDatacentersFromBuilder:Ljava/util/Map;
86: aload 0
87: aload 0
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.sessionName:Ljava/lang/String;
aload 2
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments.getTypeCodecs:()Ljava/util/List;
invokevirtual com.datastax.oss.driver.internal.core.context.DefaultDriverContext.buildCodecRegistry:(Ljava/lang/String;Ljava/util/List;)Lcom/datastax/oss/driver/api/core/type/codec/registry/CodecRegistry;
88: putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.codecRegistry:Lcom/datastax/oss/driver/api/core/type/codec/registry/CodecRegistry;
89: aload 0
aload 2
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments.getNodeStateListener:()Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.nodeStateListenerFromBuilder:Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
90: aload 0
91: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
92: ldc "nodeStateListener"
93: aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.lambda$30()Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener; (7)
()Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
94: aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
95: invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
96: putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.nodeStateListenerRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
97: aload 0
aload 2
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments.getSchemaChangeListener:()Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.schemaChangeListenerFromBuilder:Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;
98: aload 0
99: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
100: ldc "schemaChangeListener"
101: aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.lambda$31()Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener; (7)
()Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;
102: aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
103: invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
104: putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.schemaChangeListenerRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
105: aload 0
aload 2
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments.getRequestTracker:()Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.requestTrackerFromBuilder:Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;
106: aload 0
107: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
108: ldc "authProvider"
109: aload 0
aload 2
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.lambda$32(Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments;)Ljava/util/Optional; (7)
()Ljava/util/Optional;
110: aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
111: invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
112: putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.authProviderRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
113: aload 0
114: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
115: ldc "requestTracker"
aload 0
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.lambda$33()Lcom/datastax/oss/driver/api/core/tracker/RequestTracker; (7)
()Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
116: invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
117: putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.requestTrackerRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
118: aload 0
119: new com.datastax.oss.driver.internal.core.util.concurrent.LazyReference
dup
120: ldc "sslEngineFactory"
121: aload 0
aload 2
invokedynamic get(Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments;)Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.lambda$34(Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments;)Ljava/util/Optional; (7)
()Ljava/util/Optional;
122: aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cycleDetector:Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;
123: invokespecial com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.<init>:(Ljava/lang/String;Ljava/util/function/Supplier;Lcom/datastax/oss/driver/internal/core/util/concurrent/CycleDetector;)V
124: putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.sslEngineFactoryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
125: aload 0
aload 2
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments.getNodeFilters:()Ljava/util/Map;
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.nodeFiltersFromBuilder:Ljava/util/Map;
126: aload 0
aload 2
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments.getClassLoader:()Ljava/lang/ClassLoader;
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.classLoader:Ljava/lang/ClassLoader;
127: aload 0
aload 2
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments.getCloudProxyAddress:()Ljava/net/InetSocketAddress;
putfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cloudProxyAddress:Ljava/net/InetSocketAddress;
128: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 129 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
0 129 1 configLoader Lcom/datastax/oss/driver/api/core/config/DriverConfigLoader;
0 129 2 programmaticArguments Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments;
81 129 3 defaultProfile Lcom/datastax/oss/driver/api/core/config/DriverExecutionProfile;
MethodParameters:
Name Flags
configLoader
programmaticArguments
public void <init>(com.datastax.oss.driver.api.core.config.DriverConfigLoader, java.util.List<com.datastax.oss.driver.api.core.type.codec.TypeCodec<?>>, com.datastax.oss.driver.api.core.metadata.NodeStateListener, com.datastax.oss.driver.api.core.metadata.schema.SchemaChangeListener, com.datastax.oss.driver.api.core.tracker.RequestTracker, java.util.Map<java.lang.String, java.lang.String>, java.util.Map<java.lang.String, java.util.function.Predicate<com.datastax.oss.driver.api.core.metadata.Node>>, java.lang.ClassLoader);
descriptor: (Lcom/datastax/oss/driver/api/core/config/DriverConfigLoader;Ljava/util/List;Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;Ljava/util/Map;Ljava/util/Map;Ljava/lang/ClassLoader;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=9, args_size=9
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 0: aload 0
1: aload 1
2: invokestatic com.datastax.oss.driver.api.core.session.ProgrammaticArguments.builder:()Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments$Builder;
3: aload 2
iconst_0
anewarray com.datastax.oss.driver.api.core.type.codec.TypeCodec
invokeinterface java.util.List.toArray:([Ljava/lang/Object;)[Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.type.codec.TypeCodec[]
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments$Builder.addTypeCodecs:([Lcom/datastax/oss/driver/api/core/type/codec/TypeCodec;)Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments$Builder;
4: aload 3
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments$Builder.withNodeStateListener:(Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;)Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments$Builder;
5: aload 4
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments$Builder.withSchemaChangeListener:(Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;)Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments$Builder;
6: aload 5
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments$Builder.withRequestTracker:(Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;)Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments$Builder;
7: aload 6
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments$Builder.withLocalDatacenters:(Ljava/util/Map;)Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments$Builder;
8: aload 7
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments$Builder.withNodeFilters:(Ljava/util/Map;)Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments$Builder;
9: aload 8
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments$Builder.withClassLoader:(Ljava/lang/ClassLoader;)Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments$Builder;
10: invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments$Builder.build:()Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments;
invokespecial com.datastax.oss.driver.internal.core.context.DefaultDriverContext.<init>:(Lcom/datastax/oss/driver/api/core/config/DriverConfigLoader;Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments;)V
11: return
end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
0 12 1 configLoader Lcom/datastax/oss/driver/api/core/config/DriverConfigLoader;
0 12 2 typeCodecs Ljava/util/List<Lcom/datastax/oss/driver/api/core/type/codec/TypeCodec<*>;>;
0 12 3 nodeStateListener Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
0 12 4 schemaChangeListener Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;
0 12 5 requestTracker Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;
0 12 6 localDatacenters Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 12 7 nodeFilters Ljava/util/Map<Ljava/lang/String;Ljava/util/function/Predicate<Lcom/datastax/oss/driver/api/core/metadata/Node;>;>;
0 12 8 classLoader Ljava/lang/ClassLoader;
Signature: (Lcom/datastax/oss/driver/api/core/config/DriverConfigLoader;Ljava/util/List<Lcom/datastax/oss/driver/api/core/type/codec/TypeCodec<*>;>;Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Ljava/util/Map<Ljava/lang/String;Ljava/util/function/Predicate<Lcom/datastax/oss/driver/api/core/metadata/Node;>;>;Ljava/lang/ClassLoader;)V
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
configLoader
typeCodecs
nodeStateListener
schemaChangeListener
requestTracker
localDatacenters
nodeFilters
classLoader
protected java.util.Map<java.lang.String, java.lang.String> buildStartupOptions();
descriptor: ()Ljava/util/Map;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.context.StartupOptionsBuilder
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.context.StartupOptionsBuilder.<init>:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)V
invokevirtual com.datastax.oss.driver.internal.core.context.StartupOptionsBuilder.build:()Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
Signature: ()Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
protected java.util.Map<java.lang.String, com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy> buildLoadBalancingPolicies();
descriptor: ()Ljava/util/Map;
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=1, args_size=1
start local 0 0: aload 0
1: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.LOAD_BALANCING_POLICY:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
2: ldc Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;
iconst_1
anewarray java.lang.String
dup
iconst_0
3: ldc "com.datastax.oss.driver.internal.core.loadbalancing"
aastore
4: invokestatic com.datastax.oss.driver.internal.core.util.Reflection.buildFromConfigProfiles:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Lcom/datastax/oss/driver/api/core/config/DriverOption;Ljava/lang/Class;[Ljava/lang/String;)Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
Signature: ()Ljava/util/Map<Ljava/lang/String;Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;>;
protected java.util.Map<java.lang.String, com.datastax.oss.driver.api.core.retry.RetryPolicy> buildRetryPolicies();
descriptor: ()Ljava/util/Map;
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=1, args_size=1
start local 0 0: aload 0
1: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.RETRY_POLICY:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
2: ldc Lcom/datastax/oss/driver/api/core/retry/RetryPolicy;
iconst_1
anewarray java.lang.String
dup
iconst_0
3: ldc "com.datastax.oss.driver.internal.core.retry"
aastore
4: invokestatic com.datastax.oss.driver.internal.core.util.Reflection.buildFromConfigProfiles:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Lcom/datastax/oss/driver/api/core/config/DriverOption;Ljava/lang/Class;[Ljava/lang/String;)Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
Signature: ()Ljava/util/Map<Ljava/lang/String;Lcom/datastax/oss/driver/api/core/retry/RetryPolicy;>;
protected java.util.Map<java.lang.String, com.datastax.oss.driver.api.core.specex.SpeculativeExecutionPolicy> buildSpeculativeExecutionPolicies();
descriptor: ()Ljava/util/Map;
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=1, args_size=1
start local 0 0: aload 0
1: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.SPECULATIVE_EXECUTION_POLICY:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
2: ldc Lcom/datastax/oss/driver/api/core/specex/SpeculativeExecutionPolicy;
iconst_1
anewarray java.lang.String
dup
iconst_0
3: ldc "com.datastax.oss.driver.internal.core.specex"
aastore
4: invokestatic com.datastax.oss.driver.internal.core.util.Reflection.buildFromConfigProfiles:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Lcom/datastax/oss/driver/api/core/config/DriverOption;Ljava/lang/Class;[Ljava/lang/String;)Ljava/util/Map;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
Signature: ()Ljava/util/Map<Ljava/lang/String;Lcom/datastax/oss/driver/api/core/specex/SpeculativeExecutionPolicy;>;
protected com.datastax.oss.driver.api.core.time.TimestampGenerator buildTimestampGenerator();
descriptor: ()Lcom/datastax/oss/driver/api/core/time/TimestampGenerator;
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=1, args_size=1
start local 0 0: aload 0
1: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.TIMESTAMP_GENERATOR_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
2: ldc Lcom/datastax/oss/driver/api/core/time/TimestampGenerator;
iconst_1
anewarray java.lang.String
dup
iconst_0
3: ldc "com.datastax.oss.driver.internal.core.time"
aastore
4: invokestatic com.datastax.oss.driver.internal.core.util.Reflection.buildFromConfig:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Lcom/datastax/oss/driver/api/core/config/DriverOption;Ljava/lang/Class;[Ljava/lang/String;)Ljava/util/Optional;
5: invokedynamic get()Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.lambda$35()Ljava/lang/IllegalArgumentException; (6)
()Ljava/lang/IllegalArgumentException;
6: invokevirtual java.util.Optional.orElseThrow:(Ljava/util/function/Supplier;)Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.time.TimestampGenerator
7: areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.api.core.connection.ReconnectionPolicy buildReconnectionPolicy();
descriptor: ()Lcom/datastax/oss/driver/api/core/connection/ReconnectionPolicy;
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=1, args_size=1
start local 0 0: aload 0
1: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.RECONNECTION_POLICY_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
2: ldc Lcom/datastax/oss/driver/api/core/connection/ReconnectionPolicy;
iconst_1
anewarray java.lang.String
dup
iconst_0
3: ldc "com.datastax.oss.driver.internal.core.connection"
aastore
4: invokestatic com.datastax.oss.driver.internal.core.util.Reflection.buildFromConfig:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Lcom/datastax/oss/driver/api/core/config/DriverOption;Ljava/lang/Class;[Ljava/lang/String;)Ljava/util/Optional;
5: invokedynamic get()Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.lambda$36()Ljava/lang/IllegalArgumentException; (6)
()Ljava/lang/IllegalArgumentException;
6: invokevirtual java.util.Optional.orElseThrow:(Ljava/util/function/Supplier;)Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.connection.ReconnectionPolicy
7: areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.api.core.addresstranslation.AddressTranslator buildAddressTranslator();
descriptor: ()Lcom/datastax/oss/driver/api/core/addresstranslation/AddressTranslator;
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=1, args_size=1
start local 0 0: aload 0
1: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.ADDRESS_TRANSLATOR_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
2: ldc Lcom/datastax/oss/driver/api/core/addresstranslation/AddressTranslator;
iconst_1
anewarray java.lang.String
dup
iconst_0
3: ldc "com.datastax.oss.driver.internal.core.addresstranslation"
aastore
4: invokestatic com.datastax.oss.driver.internal.core.util.Reflection.buildFromConfig:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Lcom/datastax/oss/driver/api/core/config/DriverOption;Ljava/lang/Class;[Ljava/lang/String;)Ljava/util/Optional;
5: invokedynamic get()Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.lambda$37()Ljava/lang/IllegalArgumentException; (6)
()Ljava/lang/IllegalArgumentException;
6: invokevirtual java.util.Optional.orElseThrow:(Ljava/util/function/Supplier;)Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.addresstranslation.AddressTranslator
7: areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected java.util.Optional<com.datastax.oss.driver.api.core.ssl.SslEngineFactory> buildSslEngineFactory(com.datastax.oss.driver.api.core.ssl.SslEngineFactory);
descriptor: (Lcom/datastax/oss/driver/api/core/ssl/SslEngineFactory;)Ljava/util/Optional;
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnull 2
1: aload 1
invokestatic java.util.Optional.of:(Ljava/lang/Object;)Ljava/util/Optional;
goto 7
2: StackMap locals:
StackMap stack:
aload 0
3: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.SSL_ENGINE_FACTORY_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
4: ldc Lcom/datastax/oss/driver/api/core/ssl/SslEngineFactory;
iconst_1
anewarray java.lang.String
dup
iconst_0
5: ldc "com.datastax.oss.driver.internal.core.ssl"
aastore
6: invokestatic com.datastax.oss.driver.internal.core.util.Reflection.buildFromConfig:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Lcom/datastax/oss/driver/api/core/config/DriverOption;Ljava/lang/Class;[Ljava/lang/String;)Ljava/util/Optional;
7: StackMap locals:
StackMap stack: java.util.Optional
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
0 8 1 factoryFromBuilder Lcom/datastax/oss/driver/api/core/ssl/SslEngineFactory;
Signature: (Lcom/datastax/oss/driver/api/core/ssl/SslEngineFactory;)Ljava/util/Optional<Lcom/datastax/oss/driver/api/core/ssl/SslEngineFactory;>;
MethodParameters:
Name Flags
factoryFromBuilder
protected com.datastax.oss.driver.internal.core.context.EventBus buildEventBus();
descriptor: ()Lcom/datastax/oss/driver/internal/core/context/EventBus;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.context.EventBus
dup
aload 0
invokevirtual com.datastax.oss.driver.internal.core.context.DefaultDriverContext.getSessionName:()Ljava/lang/String;
invokespecial com.datastax.oss.driver.internal.core.context.EventBus.<init>:(Ljava/lang/String;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.protocol.internal.Compressor<io.netty.buffer.ByteBuf> buildCompressor();
descriptor: ()Lcom/datastax/oss/protocol/internal/Compressor;
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=4, args_size=1
start local 0 0: aload 0
invokevirtual com.datastax.oss.driver.internal.core.context.DefaultDriverContext.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;
astore 1
start local 1 1: aload 1
getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.PROTOCOL_COMPRESSION:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
ldc "none"
invokeinterface com.datastax.oss.driver.api.core.config.DriverExecutionProfile.getString:(Lcom/datastax/oss/driver/api/core/config/DriverOption;Ljava/lang/String;)Ljava/lang/String;
astore 2
start local 2 2: getstatic com.datastax.oss.driver.internal.core.context.DefaultDriverContext.$assertionsDisabled:Z
ifne 3
aload 2
ifnonnull 3
new java.lang.AssertionError
dup
ldc "should use default value"
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
3: StackMap locals: com.datastax.oss.driver.api.core.config.DriverExecutionProfile java.lang.String
StackMap stack:
aload 2
invokevirtual java.lang.String.toLowerCase:()Ljava/lang/String;
dup
astore 3
invokevirtual java.lang.String.hashCode:()I
lookupswitch { // 3
-898026669: 4
107622: 5
3387192: 6
default: 10
}
StackMap locals: java.lang.String
StackMap stack:
4: aload 3
ldc "snappy"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 8
goto 10
StackMap locals:
StackMap stack:
5: aload 3
ldc "lz4"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 7
goto 10
StackMap locals:
StackMap stack:
6: aload 3
ldc "none"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 9
goto 10
7: StackMap locals:
StackMap stack:
new com.datastax.oss.driver.internal.core.protocol.Lz4Compressor
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.protocol.Lz4Compressor.<init>:(Lcom/datastax/oss/driver/api/core/context/DriverContext;)V
areturn
8: StackMap locals:
StackMap stack:
new com.datastax.oss.driver.internal.core.protocol.SnappyCompressor
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.protocol.SnappyCompressor.<init>:(Lcom/datastax/oss/driver/api/core/context/DriverContext;)V
areturn
9: StackMap locals:
StackMap stack:
invokestatic com.datastax.oss.protocol.internal.Compressor.none:()Lcom/datastax/oss/protocol/internal/Compressor;
areturn
10: StackMap locals:
StackMap stack:
new java.lang.IllegalArgumentException
dup
11: ldc "Unsupported compression algorithm '%s' (from configuration option %s)"
iconst_2
anewarray java.lang.Object
dup
iconst_0
12: aload 2
aastore
dup
iconst_1
getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.PROTOCOL_COMPRESSION:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
invokevirtual com.datastax.oss.driver.api.core.config.DefaultDriverOption.getPath:()Ljava/lang/String;
aastore
13: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
14: invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
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/context/DefaultDriverContext;
1 15 1 defaultProfile Lcom/datastax/oss/driver/api/core/config/DriverExecutionProfile;
2 15 2 name Ljava/lang/String;
Signature: ()Lcom/datastax/oss/protocol/internal/Compressor<Lio/netty/buffer/ByteBuf;>;
protected com.datastax.oss.protocol.internal.FrameCodec<io.netty.buffer.ByteBuf> buildFrameCodec();
descriptor: ()Lcom/datastax/oss/protocol/internal/FrameCodec;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec
dup
aload 0
invokevirtual com.datastax.oss.driver.internal.core.context.DefaultDriverContext.getNettyOptions:()Lcom/datastax/oss/driver/internal/core/context/NettyOptions;
invokeinterface com.datastax.oss.driver.internal.core.context.NettyOptions.allocator:()Lio/netty/buffer/ByteBufAllocator;
invokespecial com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.<init>:(Lio/netty/buffer/ByteBufAllocator;)V
aload 0
invokevirtual com.datastax.oss.driver.internal.core.context.DefaultDriverContext.getCompressor:()Lcom/datastax/oss/protocol/internal/Compressor;
1: invokestatic com.datastax.oss.protocol.internal.FrameCodec.defaultClient:(Lcom/datastax/oss/protocol/internal/PrimitiveCodec;Lcom/datastax/oss/protocol/internal/Compressor;)Lcom/datastax/oss/protocol/internal/FrameCodec;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
Signature: ()Lcom/datastax/oss/protocol/internal/FrameCodec<Lio/netty/buffer/ByteBuf;>;
protected com.datastax.oss.driver.internal.core.ProtocolVersionRegistry buildProtocolVersionRegistry();
descriptor: ()Lcom/datastax/oss/driver/internal/core/ProtocolVersionRegistry;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.CassandraProtocolVersionRegistry
dup
aload 0
invokevirtual com.datastax.oss.driver.internal.core.context.DefaultDriverContext.getSessionName:()Ljava/lang/String;
invokespecial com.datastax.oss.driver.internal.core.CassandraProtocolVersionRegistry.<init>:(Ljava/lang/String;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.internal.core.ConsistencyLevelRegistry buildConsistencyLevelRegistry();
descriptor: ()Lcom/datastax/oss/driver/internal/core/ConsistencyLevelRegistry;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.DefaultConsistencyLevelRegistry
dup
invokespecial com.datastax.oss.driver.internal.core.DefaultConsistencyLevelRegistry.<init>:()V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.internal.core.servererrors.WriteTypeRegistry buildWriteTypeRegistry();
descriptor: ()Lcom/datastax/oss/driver/internal/core/servererrors/WriteTypeRegistry;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.servererrors.DefaultWriteTypeRegistry
dup
invokespecial com.datastax.oss.driver.internal.core.servererrors.DefaultWriteTypeRegistry.<init>:()V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.internal.core.context.NettyOptions buildNettyOptions();
descriptor: ()Lcom/datastax/oss/driver/internal/core/context/NettyOptions;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.context.DefaultNettyOptions
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.context.DefaultNettyOptions.<init>:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected java.util.Optional<com.datastax.oss.driver.internal.core.ssl.SslHandlerFactory> buildSslHandlerFactory();
descriptor: ()Ljava/util/Optional;
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual com.datastax.oss.driver.internal.core.context.DefaultDriverContext.getSslEngineFactory:()Ljava/util/Optional;
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/ssl/JdkSslHandlerFactory.<init>(Lcom/datastax/oss/driver/api/core/ssl/SslEngineFactory;)V (8)
(Lcom/datastax/oss/driver/api/core/ssl/SslEngineFactory;)Lcom/datastax/oss/driver/internal/core/ssl/SslHandlerFactory;
invokevirtual java.util.Optional.map:(Ljava/util/function/Function;)Ljava/util/Optional;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
Signature: ()Ljava/util/Optional<Lcom/datastax/oss/driver/internal/core/ssl/SslHandlerFactory;>;
protected com.datastax.oss.driver.internal.core.channel.WriteCoalescer buildWriteCoalescer();
descriptor: ()Lcom/datastax/oss/driver/internal/core/channel/WriteCoalescer;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.channel.DefaultWriteCoalescer
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.channel.DefaultWriteCoalescer.<init>:(Lcom/datastax/oss/driver/api/core/context/DriverContext;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.internal.core.channel.ChannelFactory buildChannelFactory();
descriptor: ()Lcom/datastax/oss/driver/internal/core/channel/ChannelFactory;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.channel.ChannelFactory
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.channel.ChannelFactory.<init>:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.internal.core.metadata.TopologyMonitor buildTopologyMonitor();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metadata/TopologyMonitor;
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cloudProxyAddress:Ljava/net/InetSocketAddress;
ifnonnull 2
1: new com.datastax.oss.driver.internal.core.metadata.DefaultTopologyMonitor
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.metadata.DefaultTopologyMonitor.<init>:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)V
areturn
2: StackMap locals:
StackMap stack:
new com.datastax.oss.driver.internal.core.metadata.CloudTopologyMonitor
dup
aload 0
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.cloudProxyAddress:Ljava/net/InetSocketAddress;
invokespecial com.datastax.oss.driver.internal.core.metadata.CloudTopologyMonitor.<init>:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Ljava/net/InetSocketAddress;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.internal.core.metadata.MetadataManager buildMetadataManager();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.metadata.MetadataManager
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.metadata.MetadataManager.<init>:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper buildLoadBalancingPolicyWrapper();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;
flags: (0x0004) ACC_PROTECTED
Code:
stack=4, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper
dup
aload 0
aload 0
invokevirtual com.datastax.oss.driver.internal.core.context.DefaultDriverContext.getLoadBalancingPolicies:()Ljava/util/Map;
invokespecial com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.<init>:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Ljava/util/Map;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.internal.core.control.ControlConnection buildControlConnection();
descriptor: ()Lcom/datastax/oss/driver/internal/core/control/ControlConnection;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.control.ControlConnection
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.control.ControlConnection.<init>:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.internal.core.session.RequestProcessorRegistry buildRequestProcessorRegistry();
descriptor: ()Lcom/datastax/oss/driver/internal/core/session/RequestProcessorRegistry;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual com.datastax.oss.driver.internal.core.context.DefaultDriverContext.getSessionName:()Ljava/lang/String;
invokestatic com.datastax.oss.driver.internal.core.session.RequestProcessorRegistry.defaultCqlProcessors:(Ljava/lang/String;)Lcom/datastax/oss/driver/internal/core/session/RequestProcessorRegistry;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.api.core.type.codec.registry.CodecRegistry buildCodecRegistry(java.lang.String, java.util.List<com.datastax.oss.driver.api.core.type.codec.TypeCodec<?>>);
descriptor: (Ljava/lang/String;Ljava/util/List;)Lcom/datastax/oss/driver/api/core/type/codec/registry/CodecRegistry;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: new com.datastax.oss.driver.internal.core.type.codec.registry.DefaultCodecRegistry
dup
aload 1
invokespecial com.datastax.oss.driver.internal.core.type.codec.registry.DefaultCodecRegistry.<init>:(Ljava/lang/String;)V
astore 3
start local 3 1: aload 3
aload 2
invokeinterface com.datastax.oss.driver.api.core.type.codec.registry.MutableCodecRegistry.register:(Ljava/lang/Iterable;)V
2: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
0 3 1 logPrefix Ljava/lang/String;
0 3 2 codecs Ljava/util/List<Lcom/datastax/oss/driver/api/core/type/codec/TypeCodec<*>;>;
1 3 3 registry Lcom/datastax/oss/driver/api/core/type/codec/registry/MutableCodecRegistry;
Signature: (Ljava/lang/String;Ljava/util/List<Lcom/datastax/oss/driver/api/core/type/codec/TypeCodec<*>;>;)Lcom/datastax/oss/driver/api/core/type/codec/registry/CodecRegistry;
MethodParameters:
Name Flags
logPrefix
codecs
protected com.datastax.oss.driver.internal.core.metadata.schema.queries.SchemaQueriesFactory buildSchemaQueriesFactory();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metadata/schema/queries/SchemaQueriesFactory;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.metadata.schema.queries.DefaultSchemaQueriesFactory
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.metadata.schema.queries.DefaultSchemaQueriesFactory.<init>:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.internal.core.metadata.schema.parsing.SchemaParserFactory buildSchemaParserFactory();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metadata/schema/parsing/SchemaParserFactory;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.metadata.schema.parsing.DefaultSchemaParserFactory
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.metadata.schema.parsing.DefaultSchemaParserFactory.<init>:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.internal.core.metadata.token.TokenFactoryRegistry buildTokenFactoryRegistry();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metadata/token/TokenFactoryRegistry;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.metadata.token.DefaultTokenFactoryRegistry
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.metadata.token.DefaultTokenFactoryRegistry.<init>:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.internal.core.metadata.token.ReplicationStrategyFactory buildReplicationStrategyFactory();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metadata/token/ReplicationStrategyFactory;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.metadata.token.DefaultReplicationStrategyFactory
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.metadata.token.DefaultReplicationStrategyFactory.<init>:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.internal.core.session.PoolManager buildPoolManager();
descriptor: ()Lcom/datastax/oss/driver/internal/core/session/PoolManager;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.session.PoolManager
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.session.PoolManager.<init>:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.internal.core.metrics.MetricsFactory buildMetricsFactory();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metrics/MetricsFactory;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.metrics.DropwizardMetricsFactory
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.metrics.DropwizardMetricsFactory.<init>:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.api.core.session.throttling.RequestThrottler buildRequestThrottler();
descriptor: ()Lcom/datastax/oss/driver/api/core/session/throttling/RequestThrottler;
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=1, args_size=1
start local 0 0: aload 0
1: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.REQUEST_THROTTLER_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
2: ldc Lcom/datastax/oss/driver/api/core/session/throttling/RequestThrottler;
iconst_1
anewarray java.lang.String
dup
iconst_0
3: ldc "com.datastax.oss.driver.internal.core.session.throttling"
aastore
4: invokestatic com.datastax.oss.driver.internal.core.util.Reflection.buildFromConfig:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Lcom/datastax/oss/driver/api/core/config/DriverOption;Ljava/lang/Class;[Ljava/lang/String;)Ljava/util/Optional;
5: invokedynamic get()Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.lambda$39()Ljava/lang/IllegalArgumentException; (6)
()Ljava/lang/IllegalArgumentException;
6: invokevirtual java.util.Optional.orElseThrow:(Ljava/util/function/Supplier;)Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.session.throttling.RequestThrottler
7: areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
protected com.datastax.oss.driver.api.core.metadata.NodeStateListener buildNodeStateListener(com.datastax.oss.driver.api.core.metadata.NodeStateListener);
descriptor: (Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;)Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnull 2
1: aload 1
goto 9
2: StackMap locals:
StackMap stack:
aload 0
3: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.METADATA_NODE_STATE_LISTENER_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
4: ldc Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
iconst_1
anewarray java.lang.String
dup
iconst_0
5: ldc "com.datastax.oss.driver.internal.core.metadata"
aastore
6: invokestatic com.datastax.oss.driver.internal.core.util.Reflection.buildFromConfig:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Lcom/datastax/oss/driver/api/core/config/DriverOption;Ljava/lang/Class;[Ljava/lang/String;)Ljava/util/Optional;
7: invokedynamic get()Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.lambda$40()Ljava/lang/IllegalArgumentException; (6)
()Ljava/lang/IllegalArgumentException;
8: invokevirtual java.util.Optional.orElseThrow:(Ljava/util/function/Supplier;)Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.metadata.NodeStateListener
9: StackMap locals:
StackMap stack: com.datastax.oss.driver.api.core.metadata.NodeStateListener
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
0 10 1 nodeStateListenerFromBuilder Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
MethodParameters:
Name Flags
nodeStateListenerFromBuilder
protected com.datastax.oss.driver.api.core.metadata.schema.SchemaChangeListener buildSchemaChangeListener(com.datastax.oss.driver.api.core.metadata.schema.SchemaChangeListener);
descriptor: (Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;)Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnull 2
1: aload 1
goto 9
2: StackMap locals:
StackMap stack:
aload 0
3: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.METADATA_SCHEMA_CHANGE_LISTENER_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
4: ldc Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;
iconst_1
anewarray java.lang.String
dup
iconst_0
5: ldc "com.datastax.oss.driver.internal.core.metadata.schema"
aastore
6: invokestatic com.datastax.oss.driver.internal.core.util.Reflection.buildFromConfig:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Lcom/datastax/oss/driver/api/core/config/DriverOption;Ljava/lang/Class;[Ljava/lang/String;)Ljava/util/Optional;
7: invokedynamic get()Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.lambda$41()Ljava/lang/IllegalArgumentException; (6)
()Ljava/lang/IllegalArgumentException;
8: invokevirtual java.util.Optional.orElseThrow:(Ljava/util/function/Supplier;)Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.metadata.schema.SchemaChangeListener
9: StackMap locals:
StackMap stack: com.datastax.oss.driver.api.core.metadata.schema.SchemaChangeListener
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
0 10 1 schemaChangeListenerFromBuilder Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;
MethodParameters:
Name Flags
schemaChangeListenerFromBuilder
protected com.datastax.oss.driver.api.core.tracker.RequestTracker buildRequestTracker(com.datastax.oss.driver.api.core.tracker.RequestTracker);
descriptor: (Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;)Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnull 2
1: aload 1
goto 9
2: StackMap locals:
StackMap stack:
aload 0
3: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.REQUEST_TRACKER_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
4: ldc Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;
iconst_1
anewarray java.lang.String
dup
iconst_0
5: ldc "com.datastax.oss.driver.internal.core.tracker"
aastore
6: invokestatic com.datastax.oss.driver.internal.core.util.Reflection.buildFromConfig:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Lcom/datastax/oss/driver/api/core/config/DriverOption;Ljava/lang/Class;[Ljava/lang/String;)Ljava/util/Optional;
7: invokedynamic get()Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
com/datastax/oss/driver/internal/core/context/DefaultDriverContext.lambda$42()Ljava/lang/IllegalArgumentException; (6)
()Ljava/lang/IllegalArgumentException;
8: invokevirtual java.util.Optional.orElseThrow:(Ljava/util/function/Supplier;)Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.tracker.RequestTracker
9: StackMap locals:
StackMap stack: com.datastax.oss.driver.api.core.tracker.RequestTracker
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
0 10 1 requestTrackerFromBuilder Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;
MethodParameters:
Name Flags
requestTrackerFromBuilder
protected java.util.Optional<com.datastax.oss.driver.api.core.auth.AuthProvider> buildAuthProvider(com.datastax.oss.driver.api.core.auth.AuthProvider);
descriptor: (Lcom/datastax/oss/driver/api/core/auth/AuthProvider;)Ljava/util/Optional;
flags: (0x0004) ACC_PROTECTED
Code:
stack=7, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnull 2
1: aload 1
invokestatic java.util.Optional.of:(Ljava/lang/Object;)Ljava/util/Optional;
goto 7
2: StackMap locals:
StackMap stack:
aload 0
3: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.AUTH_PROVIDER_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
4: ldc Lcom/datastax/oss/driver/api/core/auth/AuthProvider;
iconst_1
anewarray java.lang.String
dup
iconst_0
5: ldc "com.datastax.oss.driver.internal.core.auth"
aastore
6: invokestatic com.datastax.oss.driver.internal.core.util.Reflection.buildFromConfig:(Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Lcom/datastax/oss/driver/api/core/config/DriverOption;Ljava/lang/Class;[Ljava/lang/String;)Ljava/util/Optional;
7: StackMap locals:
StackMap stack: java.util.Optional
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
0 8 1 authProviderFromBuilder Lcom/datastax/oss/driver/api/core/auth/AuthProvider;
Signature: (Lcom/datastax/oss/driver/api/core/auth/AuthProvider;)Ljava/util/Optional<Lcom/datastax/oss/driver/api/core/auth/AuthProvider;>;
MethodParameters:
Name Flags
authProviderFromBuilder
public java.lang.String getSessionName();
descriptor: ()Ljava/lang/String;
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.context.DefaultDriverContext.sessionName:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.api.core.config.DriverConfig getConfig();
descriptor: ()Lcom/datastax/oss/driver/api/core/config/DriverConfig;
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.context.DefaultDriverContext.config:Lcom/datastax/oss/driver/api/core/config/DriverConfig;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.api.core.config.DriverConfigLoader getConfigLoader();
descriptor: ()Lcom/datastax/oss/driver/api/core/config/DriverConfigLoader;
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.context.DefaultDriverContext.configLoader:Lcom/datastax/oss/driver/api/core/config/DriverConfigLoader;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public java.util.Map<java.lang.String, com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy> getLoadBalancingPolicies();
descriptor: ()Ljava/util/Map;
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.context.DefaultDriverContext.loadBalancingPoliciesRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast java.util.Map
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
Signature: ()Ljava/util/Map<Ljava/lang/String;Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;>;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public java.util.Map<java.lang.String, com.datastax.oss.driver.api.core.retry.RetryPolicy> getRetryPolicies();
descriptor: ()Ljava/util/Map;
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.context.DefaultDriverContext.retryPoliciesRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast java.util.Map
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
Signature: ()Ljava/util/Map<Ljava/lang/String;Lcom/datastax/oss/driver/api/core/retry/RetryPolicy;>;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public java.util.Map<java.lang.String, com.datastax.oss.driver.api.core.specex.SpeculativeExecutionPolicy> getSpeculativeExecutionPolicies();
descriptor: ()Ljava/util/Map;
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.context.DefaultDriverContext.speculativeExecutionPoliciesRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast java.util.Map
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
Signature: ()Ljava/util/Map<Ljava/lang/String;Lcom/datastax/oss/driver/api/core/specex/SpeculativeExecutionPolicy;>;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.api.core.time.TimestampGenerator getTimestampGenerator();
descriptor: ()Lcom/datastax/oss/driver/api/core/time/TimestampGenerator;
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.context.DefaultDriverContext.timestampGeneratorRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.time.TimestampGenerator
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.api.core.connection.ReconnectionPolicy getReconnectionPolicy();
descriptor: ()Lcom/datastax/oss/driver/api/core/connection/ReconnectionPolicy;
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.context.DefaultDriverContext.reconnectionPolicyRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.connection.ReconnectionPolicy
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.api.core.addresstranslation.AddressTranslator getAddressTranslator();
descriptor: ()Lcom/datastax/oss/driver/api/core/addresstranslation/AddressTranslator;
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.context.DefaultDriverContext.addressTranslatorRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.addresstranslation.AddressTranslator
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public java.util.Optional<com.datastax.oss.driver.api.core.auth.AuthProvider> getAuthProvider();
descriptor: ()Ljava/util/Optional;
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.context.DefaultDriverContext.authProviderRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast java.util.Optional
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
Signature: ()Ljava/util/Optional<Lcom/datastax/oss/driver/api/core/auth/AuthProvider;>;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public java.util.Optional<com.datastax.oss.driver.api.core.ssl.SslEngineFactory> getSslEngineFactory();
descriptor: ()Ljava/util/Optional;
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.context.DefaultDriverContext.sslEngineFactoryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast java.util.Optional
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
Signature: ()Ljava/util/Optional<Lcom/datastax/oss/driver/api/core/ssl/SslEngineFactory;>;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.context.EventBus getEventBus();
descriptor: ()Lcom/datastax/oss/driver/internal/core/context/EventBus;
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.context.DefaultDriverContext.eventBusRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.context.EventBus
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.protocol.internal.Compressor<io.netty.buffer.ByteBuf> getCompressor();
descriptor: ()Lcom/datastax/oss/protocol/internal/Compressor;
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.context.DefaultDriverContext.compressorRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.protocol.internal.Compressor
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
Signature: ()Lcom/datastax/oss/protocol/internal/Compressor<Lio/netty/buffer/ByteBuf;>;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.protocol.internal.FrameCodec<io.netty.buffer.ByteBuf> getFrameCodec();
descriptor: ()Lcom/datastax/oss/protocol/internal/FrameCodec;
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.context.DefaultDriverContext.frameCodecRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.protocol.internal.FrameCodec
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
Signature: ()Lcom/datastax/oss/protocol/internal/FrameCodec<Lio/netty/buffer/ByteBuf;>;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.ProtocolVersionRegistry getProtocolVersionRegistry();
descriptor: ()Lcom/datastax/oss/driver/internal/core/ProtocolVersionRegistry;
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.context.DefaultDriverContext.protocolVersionRegistryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.ProtocolVersionRegistry
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.ConsistencyLevelRegistry getConsistencyLevelRegistry();
descriptor: ()Lcom/datastax/oss/driver/internal/core/ConsistencyLevelRegistry;
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.context.DefaultDriverContext.consistencyLevelRegistryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.ConsistencyLevelRegistry
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.servererrors.WriteTypeRegistry getWriteTypeRegistry();
descriptor: ()Lcom/datastax/oss/driver/internal/core/servererrors/WriteTypeRegistry;
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.context.DefaultDriverContext.writeTypeRegistryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.servererrors.WriteTypeRegistry
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.context.NettyOptions getNettyOptions();
descriptor: ()Lcom/datastax/oss/driver/internal/core/context/NettyOptions;
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.context.DefaultDriverContext.nettyOptionsRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.context.NettyOptions
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.channel.WriteCoalescer getWriteCoalescer();
descriptor: ()Lcom/datastax/oss/driver/internal/core/channel/WriteCoalescer;
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.context.DefaultDriverContext.writeCoalescerRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.channel.WriteCoalescer
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public java.util.Optional<com.datastax.oss.driver.internal.core.ssl.SslHandlerFactory> getSslHandlerFactory();
descriptor: ()Ljava/util/Optional;
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.context.DefaultDriverContext.sslHandlerFactoryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast java.util.Optional
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
Signature: ()Ljava/util/Optional<Lcom/datastax/oss/driver/internal/core/ssl/SslHandlerFactory;>;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.channel.ChannelFactory getChannelFactory();
descriptor: ()Lcom/datastax/oss/driver/internal/core/channel/ChannelFactory;
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.context.DefaultDriverContext.channelFactoryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.channel.ChannelFactory
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.pool.ChannelPoolFactory getChannelPoolFactory();
descriptor: ()Lcom/datastax/oss/driver/internal/core/pool/ChannelPoolFactory;
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.context.DefaultDriverContext.channelPoolFactory:Lcom/datastax/oss/driver/internal/core/pool/ChannelPoolFactory;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.metadata.TopologyMonitor getTopologyMonitor();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metadata/TopologyMonitor;
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.context.DefaultDriverContext.topologyMonitorRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.metadata.TopologyMonitor
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.metadata.MetadataManager getMetadataManager();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
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.context.DefaultDriverContext.metadataManagerRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.metadata.MetadataManager
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper getLoadBalancingPolicyWrapper();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;
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.context.DefaultDriverContext.loadBalancingPolicyWrapperRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.control.ControlConnection getControlConnection();
descriptor: ()Lcom/datastax/oss/driver/internal/core/control/ControlConnection;
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.context.DefaultDriverContext.controlConnectionRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.control.ControlConnection
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.session.RequestProcessorRegistry getRequestProcessorRegistry();
descriptor: ()Lcom/datastax/oss/driver/internal/core/session/RequestProcessorRegistry;
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.context.DefaultDriverContext.requestProcessorRegistryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.session.RequestProcessorRegistry
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.metadata.schema.queries.SchemaQueriesFactory getSchemaQueriesFactory();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metadata/schema/queries/SchemaQueriesFactory;
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.context.DefaultDriverContext.schemaQueriesFactoryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.metadata.schema.queries.SchemaQueriesFactory
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.metadata.schema.parsing.SchemaParserFactory getSchemaParserFactory();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metadata/schema/parsing/SchemaParserFactory;
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.context.DefaultDriverContext.schemaParserFactoryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.metadata.schema.parsing.SchemaParserFactory
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.metadata.token.TokenFactoryRegistry getTokenFactoryRegistry();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metadata/token/TokenFactoryRegistry;
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.context.DefaultDriverContext.tokenFactoryRegistryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.metadata.token.TokenFactoryRegistry
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.metadata.token.ReplicationStrategyFactory getReplicationStrategyFactory();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metadata/token/ReplicationStrategyFactory;
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.context.DefaultDriverContext.replicationStrategyFactoryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.metadata.token.ReplicationStrategyFactory
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.session.PoolManager getPoolManager();
descriptor: ()Lcom/datastax/oss/driver/internal/core/session/PoolManager;
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.context.DefaultDriverContext.poolManagerRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.session.PoolManager
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.internal.core.metrics.MetricsFactory getMetricsFactory();
descriptor: ()Lcom/datastax/oss/driver/internal/core/metrics/MetricsFactory;
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.context.DefaultDriverContext.metricsFactoryRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.metrics.MetricsFactory
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.api.core.session.throttling.RequestThrottler getRequestThrottler();
descriptor: ()Lcom/datastax/oss/driver/api/core/session/throttling/RequestThrottler;
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.context.DefaultDriverContext.requestThrottlerRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.session.throttling.RequestThrottler
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.api.core.metadata.NodeStateListener getNodeStateListener();
descriptor: ()Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
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.context.DefaultDriverContext.nodeStateListenerRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.metadata.NodeStateListener
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.api.core.metadata.schema.SchemaChangeListener getSchemaChangeListener();
descriptor: ()Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;
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.context.DefaultDriverContext.schemaChangeListenerRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.metadata.schema.SchemaChangeListener
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.api.core.tracker.RequestTracker getRequestTracker();
descriptor: ()Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;
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.context.DefaultDriverContext.requestTrackerRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.api.core.tracker.RequestTracker
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public java.lang.String getLocalDatacenter(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.localDatacentersFromBuilder:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
0 1 1 profileName Ljava/lang/String;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.Nullable()
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
MethodParameters:
Name Flags
profileName
public java.util.function.Predicate<com.datastax.oss.driver.api.core.metadata.Node> getNodeFilter(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/util/function/Predicate;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.nodeFiltersFromBuilder:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.util.function.Predicate
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
0 1 1 profileName Ljava/lang/String;
Signature: (Ljava/lang/String;)Ljava/util/function/Predicate<Lcom/datastax/oss/driver/api/core/metadata/Node;>;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.Nullable()
RuntimeInvisibleParameterAnnotations:
0:
edu.umd.cs.findbugs.annotations.NonNull()
MethodParameters:
Name Flags
profileName
public java.lang.ClassLoader getClassLoader();
descriptor: ()Ljava/lang/ClassLoader;
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.context.DefaultDriverContext.classLoader:Ljava/lang/ClassLoader;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.Nullable()
public com.datastax.oss.driver.api.core.type.codec.registry.CodecRegistry getCodecRegistry();
descriptor: ()Lcom/datastax/oss/driver/api/core/type/codec/registry/CodecRegistry;
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.context.DefaultDriverContext.codecRegistry:Lcom/datastax/oss/driver/api/core/type/codec/registry/CodecRegistry;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public com.datastax.oss.driver.api.core.ProtocolVersion getProtocolVersion();
descriptor: ()Lcom/datastax/oss/driver/api/core/ProtocolVersion;
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.context.DefaultDriverContext.getChannelFactory:()Lcom/datastax/oss/driver/internal/core/channel/ChannelFactory;
invokevirtual com.datastax.oss.driver.internal.core.channel.ChannelFactory.getProtocolVersion:()Lcom/datastax/oss/driver/api/core/ProtocolVersion;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
public java.util.Map<java.lang.String, java.lang.String> getStartupOptions();
descriptor: ()Ljava/util/Map;
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.context.DefaultDriverContext.startupOptionsRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast java.util.Map
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
Signature: ()Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
protected com.datastax.oss.driver.internal.core.tracker.RequestLogFormatter buildRequestLogFormatter();
descriptor: ()Lcom/datastax/oss/driver/internal/core/tracker/RequestLogFormatter;
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: new com.datastax.oss.driver.internal.core.tracker.RequestLogFormatter
dup
aload 0
invokespecial com.datastax.oss.driver.internal.core.tracker.RequestLogFormatter.<init>:(Lcom/datastax/oss/driver/api/core/context/DriverContext;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
public com.datastax.oss.driver.internal.core.tracker.RequestLogFormatter getRequestLogFormatter();
descriptor: ()Lcom/datastax/oss/driver/internal/core/tracker/RequestLogFormatter;
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.context.DefaultDriverContext.requestLogFormatterRef:Lcom/datastax/oss/driver/internal/core/util/concurrent/LazyReference;
invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.LazyReference.get:()Ljava/lang/Object;
checkcast com.datastax.oss.driver.internal.core.tracker.RequestLogFormatter
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
RuntimeInvisibleAnnotations:
edu.umd.cs.findbugs.annotations.NonNull()
private com.datastax.oss.driver.api.core.metadata.NodeStateListener lambda$30();
descriptor: ()Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.nodeStateListenerFromBuilder:Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
invokevirtual com.datastax.oss.driver.internal.core.context.DefaultDriverContext.buildNodeStateListener:(Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;)Lcom/datastax/oss/driver/api/core/metadata/NodeStateListener;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
private com.datastax.oss.driver.api.core.metadata.schema.SchemaChangeListener lambda$31();
descriptor: ()Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.schemaChangeListenerFromBuilder:Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;
invokevirtual com.datastax.oss.driver.internal.core.context.DefaultDriverContext.buildSchemaChangeListener:(Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;)Lcom/datastax/oss/driver/api/core/metadata/schema/SchemaChangeListener;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
private java.util.Optional lambda$32(com.datastax.oss.driver.api.core.session.ProgrammaticArguments);
descriptor: (Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments;)Ljava/util/Optional;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 0: aload 0
aload 1
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments.getAuthProvider:()Lcom/datastax/oss/driver/api/core/auth/AuthProvider;
invokevirtual com.datastax.oss.driver.internal.core.context.DefaultDriverContext.buildAuthProvider:(Lcom/datastax/oss/driver/api/core/auth/AuthProvider;)Ljava/util/Optional;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
private com.datastax.oss.driver.api.core.tracker.RequestTracker lambda$33();
descriptor: ()Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
aload 0
getfield com.datastax.oss.driver.internal.core.context.DefaultDriverContext.requestTrackerFromBuilder:Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;
invokevirtual com.datastax.oss.driver.internal.core.context.DefaultDriverContext.buildRequestTracker:(Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;)Lcom/datastax/oss/driver/api/core/tracker/RequestTracker;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
private java.util.Optional lambda$34(com.datastax.oss.driver.api.core.session.ProgrammaticArguments);
descriptor: (Lcom/datastax/oss/driver/api/core/session/ProgrammaticArguments;)Ljava/util/Optional;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 0: aload 0
aload 1
invokevirtual com.datastax.oss.driver.api.core.session.ProgrammaticArguments.getSslEngineFactory:()Lcom/datastax/oss/driver/api/core/ssl/SslEngineFactory;
invokevirtual com.datastax.oss.driver.internal.core.context.DefaultDriverContext.buildSslEngineFactory:(Lcom/datastax/oss/driver/api/core/ssl/SslEngineFactory;)Ljava/util/Optional;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lcom/datastax/oss/driver/internal/core/context/DefaultDriverContext;
private static java.lang.IllegalArgumentException lambda$35();
descriptor: ()Ljava/lang/IllegalArgumentException;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=7, locals=0, args_size=0
0: new java.lang.IllegalArgumentException
dup
1: ldc "Missing timestamp generator, check your configuration (%s)"
iconst_1
anewarray java.lang.Object
dup
iconst_0
2: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.TIMESTAMP_GENERATOR_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
4: invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
5: areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.lang.IllegalArgumentException lambda$36();
descriptor: ()Ljava/lang/IllegalArgumentException;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=7, locals=0, args_size=0
0: new java.lang.IllegalArgumentException
dup
1: ldc "Missing reconnection policy, check your configuration (%s)"
iconst_1
anewarray java.lang.Object
dup
iconst_0
2: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.RECONNECTION_POLICY_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
4: invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
5: areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.lang.IllegalArgumentException lambda$37();
descriptor: ()Ljava/lang/IllegalArgumentException;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=7, locals=0, args_size=0
0: new java.lang.IllegalArgumentException
dup
1: ldc "Missing address translator, check your configuration (%s)"
iconst_1
anewarray java.lang.Object
dup
iconst_0
2: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.ADDRESS_TRANSLATOR_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
4: invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
5: areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.lang.IllegalArgumentException lambda$39();
descriptor: ()Ljava/lang/IllegalArgumentException;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=7, locals=0, args_size=0
0: new java.lang.IllegalArgumentException
dup
1: ldc "Missing request throttler, check your configuration (%s)"
iconst_1
anewarray java.lang.Object
dup
iconst_0
2: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.REQUEST_THROTTLER_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
4: invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
5: areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.lang.IllegalArgumentException lambda$40();
descriptor: ()Ljava/lang/IllegalArgumentException;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=7, locals=0, args_size=0
0: new java.lang.IllegalArgumentException
dup
1: ldc "Missing node state listener, check your configuration (%s)"
iconst_1
anewarray java.lang.Object
dup
iconst_0
2: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.METADATA_NODE_STATE_LISTENER_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
4: invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
5: areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.lang.IllegalArgumentException lambda$41();
descriptor: ()Ljava/lang/IllegalArgumentException;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=7, locals=0, args_size=0
0: new java.lang.IllegalArgumentException
dup
1: ldc "Missing schema change listener, check your configuration (%s)"
iconst_1
anewarray java.lang.Object
dup
iconst_0
2: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.METADATA_SCHEMA_CHANGE_LISTENER_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
4: invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
5: areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.lang.IllegalArgumentException lambda$42();
descriptor: ()Ljava/lang/IllegalArgumentException;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=7, locals=0, args_size=0
0: new java.lang.IllegalArgumentException
dup
1: ldc "Missing request tracker, check your configuration (%s)"
iconst_1
anewarray java.lang.Object
dup
iconst_0
2: getstatic com.datastax.oss.driver.api.core.config.DefaultDriverOption.REQUEST_TRACKER_CLASS:Lcom/datastax/oss/driver/api/core/config/DefaultDriverOption;
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
4: invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
5: areturn
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "DefaultDriverContext.java"
InnerClasses:
public Builder = com.datastax.oss.driver.api.core.session.ProgrammaticArguments$Builder of com.datastax.oss.driver.api.core.session.ProgrammaticArguments
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
RuntimeVisibleAnnotations:
net.jcip.annotations.ThreadSafe()