https://github.com/datastax/java-driver/java-driver-core: A driver for Apache Cassandra(R) 2.1+ that works exclusively with the Cassandra Query Language version 3 (CQL3) and Cassandra's native protocol versions 3 and above.
  • Various (DataStax) 
public class com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper implements java.lang.AutoCloseable
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper
  super_class: java.lang.Object
{
  private static final org.slf4j.Logger LOG;
    descriptor: Lorg/slf4j/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final com.datastax.oss.driver.internal.core.context.InternalDriverContext context;
    descriptor: Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.Set<com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy> policies;
    descriptor: Ljava/util/Set;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Set<Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;>;

  private final java.util.Map<java.lang.String, com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy> policiesPerProfile;
    descriptor: Ljava/util/Map;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Map<Ljava/lang/String;Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;>;

  private final java.util.Map<com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy, com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$SinglePolicyDistanceReporter> reporters;
    descriptor: Ljava/util/Map;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Map<Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$SinglePolicyDistanceReporter;>;

  private final java.util.concurrent.locks.Lock distancesLock;
    descriptor: Ljava/util/concurrent/locks/Lock;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.Map<com.datastax.oss.driver.api.core.metadata.Node, java.util.Map<com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy, com.datastax.oss.driver.api.core.loadbalancing.NodeDistance>> distances;
    descriptor: Ljava/util/Map;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Map<Lcom/datastax/oss/driver/api/core/metadata/Node;Ljava/util/Map<Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;Lcom/datastax/oss/driver/api/core/loadbalancing/NodeDistance;>;>;
    RuntimeVisibleAnnotations: 
      net.jcip.annotations.GuardedBy(value = "distancesLock")

  private final java.lang.String logPrefix;
    descriptor: Ljava/lang/String;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final com.datastax.oss.driver.internal.core.util.concurrent.ReplayingEventFilter<com.datastax.oss.driver.internal.core.metadata.NodeStateEvent> eventFilter;
    descriptor: Lcom/datastax/oss/driver/internal/core/util/concurrent/ReplayingEventFilter;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lcom/datastax/oss/driver/internal/core/util/concurrent/ReplayingEventFilter<Lcom/datastax/oss/driver/internal/core/metadata/NodeStateEvent;>;

  private final java.util.concurrent.atomic.AtomicReference<com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State> stateRef;
    descriptor: Ljava/util/concurrent/atomic/AtomicReference;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/concurrent/atomic/AtomicReference<Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;>;

  static final boolean $assertionsDisabled;
    descriptor: Z
    flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC

  private static volatile int[] $SWITCH_TABLE$com$datastax$oss$driver$internal$core$metadata$LoadBalancingPolicyWrapper$State;
    descriptor: [I
    flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 61
            ldc Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;
            invokevirtual java.lang.Class.desiredAssertionStatus:()Z
            ifne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: putstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.$assertionsDisabled:Z
         3: .line 63
            ldc Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;
            invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
            putstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.LOG:Lorg/slf4j/Logger;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(com.datastax.oss.driver.internal.core.context.InternalDriverContext, java.util.Map<java.lang.String, com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy>);
    descriptor: (Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Ljava/util/Map;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=6, args_size=3
        start local 0 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper this
        start local 1 // com.datastax.oss.driver.internal.core.context.InternalDriverContext context
        start local 2 // java.util.Map policiesPerProfile
         0: .line 89
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 77
            aload 0 /* this */
            new java.util.concurrent.locks.ReentrantLock
            dup
            invokespecial java.util.concurrent.locks.ReentrantLock.<init>:()V
            putfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.distancesLock:Ljava/util/concurrent/locks/Lock;
         2: .line 85
            aload 0 /* this */
         3: .line 86
            new com.datastax.oss.driver.internal.core.util.concurrent.ReplayingEventFilter
            dup
            aload 0 /* this */
            invokedynamic accept(Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  com/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper.processNodeStateEvent(Lcom/datastax/oss/driver/internal/core/metadata/NodeStateEvent;)V (7)
                  (Lcom/datastax/oss/driver/internal/core/metadata/NodeStateEvent;)V
            invokespecial com.datastax.oss.driver.internal.core.util.concurrent.ReplayingEventFilter.<init>:(Ljava/util/function/Consumer;)V
            putfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.eventFilter:Lcom/datastax/oss/driver/internal/core/util/concurrent/ReplayingEventFilter;
         4: .line 87
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicReference
            dup
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.BEFORE_INIT:Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;
            invokespecial java.util.concurrent.atomic.AtomicReference.<init>:(Ljava/lang/Object;)V
            putfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.stateRef:Ljava/util/concurrent/atomic/AtomicReference;
         5: .line 92
            aload 0 /* this */
            aload 1 /* context */
            putfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.context:Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
         6: .line 94
            aload 0 /* this */
            aload 2 /* policiesPerProfile */
            putfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.policiesPerProfile:Ljava/util/Map;
         7: .line 96
            invokestatic com.datastax.oss.driver.shaded.guava.common.collect.ImmutableMap.builder:()Lcom/datastax/oss/driver/shaded/guava/common/collect/ImmutableMap$Builder;
         8: .line 95
            astore 3 /* reportersBuilder */
        start local 3 // com.datastax.oss.driver.shaded.guava.common.collect.ImmutableMap$Builder reportersBuilder
         9: .line 99
            aload 2 /* policiesPerProfile */
            invokeinterface java.util.Map.values:()Ljava/util/Collection;
            invokestatic com.datastax.oss.driver.shaded.guava.common.collect.ImmutableSet.copyOf:(Ljava/util/Collection;)Lcom/datastax/oss/driver/shaded/guava/common/collect/ImmutableSet;
            invokevirtual com.datastax.oss.driver.shaded.guava.common.collect.ImmutableSet.iterator:()Ljava/util/Iterator;
            astore 5
            goto 12
      StackMap locals: com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper com.datastax.oss.driver.internal.core.context.InternalDriverContext java.util.Map com.datastax.oss.driver.shaded.guava.common.collect.ImmutableMap$Builder top java.util.Iterator
      StackMap stack:
        10: aload 5
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy
            astore 4 /* policy */
        start local 4 // com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy policy
        11: .line 100
            aload 3 /* reportersBuilder */
            aload 4 /* policy */
            new com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$SinglePolicyDistanceReporter
            dup
            aload 0 /* this */
            aload 4 /* policy */
            invokespecial com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$SinglePolicyDistanceReporter.<init>:(Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;)V
            invokevirtual com.datastax.oss.driver.shaded.guava.common.collect.ImmutableMap$Builder.put:(Ljava/lang/Object;Ljava/lang/Object;)Lcom/datastax/oss/driver/shaded/guava/common/collect/ImmutableMap$Builder;
            pop
        end local 4 // com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy policy
        12: .line 99
      StackMap locals:
      StackMap stack:
            aload 5
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 10
        13: .line 102
            aload 0 /* this */
            aload 3 /* reportersBuilder */
            invokevirtual com.datastax.oss.driver.shaded.guava.common.collect.ImmutableMap$Builder.build:()Lcom/datastax/oss/driver/shaded/guava/common/collect/ImmutableMap;
            putfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.reporters:Ljava/util/Map;
        14: .line 104
            aload 0 /* this */
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.reporters:Ljava/util/Map;
            invokeinterface java.util.Map.keySet:()Ljava/util/Set;
            putfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.policies:Ljava/util/Set;
        15: .line 106
            aload 0 /* this */
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            putfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.distances:Ljava/util/Map;
        16: .line 108
            aload 0 /* this */
            aload 1 /* context */
            invokeinterface com.datastax.oss.driver.internal.core.context.InternalDriverContext.getSessionName:()Ljava/lang/String;
            putfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.logPrefix:Ljava/lang/String;
        17: .line 109
            aload 1 /* context */
            invokeinterface com.datastax.oss.driver.internal.core.context.InternalDriverContext.getEventBus:()Lcom/datastax/oss/driver/internal/core/context/EventBus;
            ldc Lcom/datastax/oss/driver/internal/core/metadata/NodeStateEvent;
            aload 0 /* this */
            invokedynamic accept(Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  com/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper.onNodeStateEvent(Lcom/datastax/oss/driver/internal/core/metadata/NodeStateEvent;)V (7)
                  (Lcom/datastax/oss/driver/internal/core/metadata/NodeStateEvent;)V
            invokevirtual com.datastax.oss.driver.internal.core.context.EventBus.register:(Ljava/lang/Class;Ljava/util/function/Consumer;)Ljava/lang/Object;
            pop
        18: .line 110
            return
        end local 3 // com.datastax.oss.driver.shaded.guava.common.collect.ImmutableMap$Builder reportersBuilder
        end local 2 // java.util.Map policiesPerProfile
        end local 1 // com.datastax.oss.driver.internal.core.context.InternalDriverContext context
        end local 0 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0   19     0                this  Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;
            0   19     1             context  Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
            0   19     2  policiesPerProfile  Ljava/util/Map<Ljava/lang/String;Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;>;
            9   19     3    reportersBuilder  Lcom/datastax/oss/driver/shaded/guava/common/collect/ImmutableMap$Builder<Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$SinglePolicyDistanceReporter;>;
           11   12     4              policy  Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;
    Signature: (Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;Ljava/util/Map<Ljava/lang/String;Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;>;)V
    RuntimeInvisibleParameterAnnotations: 
      0:
        edu.umd.cs.findbugs.annotations.NonNull()
      1:
        edu.umd.cs.findbugs.annotations.NonNull()
    MethodParameters:
                    Name  Flags
      context             
      policiesPerProfile  

  public void init();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=5, args_size=1
        start local 0 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper this
         0: .line 113
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.stateRef:Ljava/util/concurrent/atomic/AtomicReference;
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.BEFORE_INIT:Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.DURING_INIT:Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifeq 17
         1: .line 114
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.LOG:Lorg/slf4j/Logger;
            ldc "[{}] Initializing policies"
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.logPrefix:Ljava/lang/String;
            invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
         2: .line 117
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.eventFilter:Lcom/datastax/oss/driver/internal/core/util/concurrent/ReplayingEventFilter;
            invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.ReplayingEventFilter.start:()V
         3: .line 118
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.context:Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
            invokeinterface com.datastax.oss.driver.internal.core.context.InternalDriverContext.getMetadataManager:()Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
            astore 1 /* metadataManager */
        start local 1 // com.datastax.oss.driver.internal.core.metadata.MetadataManager metadataManager
         4: .line 119
            aload 1 /* metadataManager */
            invokevirtual com.datastax.oss.driver.internal.core.metadata.MetadataManager.getMetadata:()Lcom/datastax/oss/driver/api/core/metadata/Metadata;
            astore 2 /* metadata */
        start local 2 // com.datastax.oss.driver.api.core.metadata.Metadata metadata
         5: .line 120
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.policies:Ljava/util/Set;
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 4
            goto 8
      StackMap locals: com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper com.datastax.oss.driver.internal.core.metadata.MetadataManager com.datastax.oss.driver.api.core.metadata.Metadata top java.util.Iterator
      StackMap stack:
         6: aload 4
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy
            astore 3 /* policy */
        start local 3 // com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy policy
         7: .line 121
            aload 3 /* policy */
            aload 2 /* metadata */
            invokeinterface com.datastax.oss.driver.api.core.metadata.Metadata.getNodes:()Ljava/util/Map;
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.reporters:Ljava/util/Map;
            aload 3 /* policy */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy$DistanceReporter
            invokeinterface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy.init:(Ljava/util/Map;Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy$DistanceReporter;)V
        end local 3 // com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy policy
         8: .line 120
      StackMap locals:
      StackMap stack:
            aload 4
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 6
         9: .line 123
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.stateRef:Ljava/util/concurrent/atomic/AtomicReference;
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.DURING_INIT:Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.RUNNING:Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifeq 12
        10: .line 124
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.eventFilter:Lcom/datastax/oss/driver/internal/core/util/concurrent/ReplayingEventFilter;
            invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.ReplayingEventFilter.markReady:()V
        11: .line 125
            goto 17
        12: .line 126
      StackMap locals: com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper com.datastax.oss.driver.internal.core.metadata.MetadataManager com.datastax.oss.driver.api.core.metadata.Metadata
      StackMap stack:
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.$assertionsDisabled:Z
            ifne 13
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.stateRef:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.CLOSING:Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;
            if_acmpeq 13
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        13: .line 127
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.policies:Ljava/util/Set;
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 4
            goto 16
      StackMap locals: com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper com.datastax.oss.driver.internal.core.metadata.MetadataManager com.datastax.oss.driver.api.core.metadata.Metadata top java.util.Iterator
      StackMap stack:
        14: aload 4
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy
            astore 3 /* policy */
        start local 3 // com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy policy
        15: .line 128
            aload 3 /* policy */
            invokeinterface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy.close:()V
        end local 3 // com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy policy
        16: .line 127
      StackMap locals:
      StackMap stack:
            aload 4
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 14
        end local 2 // com.datastax.oss.driver.api.core.metadata.Metadata metadata
        end local 1 // com.datastax.oss.driver.internal.core.metadata.MetadataManager metadataManager
        17: .line 132
      StackMap locals: com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper
      StackMap stack:
            return
        end local 0 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   18     0             this  Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;
            4   17     1  metadataManager  Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
            5   17     2         metadata  Lcom/datastax/oss/driver/api/core/metadata/Metadata;
            7    8     3           policy  Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;
           15   16     3           policy  Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;

  public java.util.Queue<com.datastax.oss.driver.api.core.metadata.Node> newQueryPlan(com.datastax.oss.driver.api.core.session.Request, java.lang.String, com.datastax.oss.driver.api.core.session.Session);
    descriptor: (Lcom/datastax/oss/driver/api/core/session/Request;Ljava/lang/String;Lcom/datastax/oss/driver/api/core/session/Session;)Ljava/util/Queue;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=6, args_size=4
        start local 0 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper this
        start local 1 // com.datastax.oss.driver.api.core.session.Request request
        start local 2 // java.lang.String executionProfileName
        start local 3 // com.datastax.oss.driver.api.core.session.Session session
         0: .line 143
            invokestatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.$SWITCH_TABLE$com$datastax$oss$driver$internal$core$metadata$LoadBalancingPolicyWrapper$State:()[I
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.stateRef:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State
            invokevirtual com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.ordinal:()I
            iaload
            tableswitch { // 1 - 3
                    1: 1
                    2: 1
                    3: 4
              default: 8
          }
         1: .line 147
      StackMap locals:
      StackMap stack:
            new java.util.ArrayList
            dup
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.context:Lcom/datastax/oss/driver/internal/core/context/InternalDriverContext;
            invokeinterface com.datastax.oss.driver.internal.core.context.InternalDriverContext.getMetadataManager:()Lcom/datastax/oss/driver/internal/core/metadata/MetadataManager;
            invokevirtual com.datastax.oss.driver.internal.core.metadata.MetadataManager.getContactPoints:()Ljava/util/Set;
            invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
            astore 4 /* nodes */
        start local 4 // java.util.List nodes
         2: .line 148
            aload 4 /* nodes */
            invokestatic java.util.Collections.shuffle:(Ljava/util/List;)V
         3: .line 149
            new java.util.concurrent.ConcurrentLinkedQueue
            dup
            aload 4 /* nodes */
            invokespecial java.util.concurrent.ConcurrentLinkedQueue.<init>:(Ljava/util/Collection;)V
            areturn
        end local 4 // java.util.List nodes
         4: .line 151
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.policiesPerProfile:Ljava/util/Map;
            aload 2 /* executionProfileName */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy
            astore 5 /* policy */
        start local 5 // com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy policy
         5: .line 152
            aload 5 /* policy */
            ifnonnull 7
         6: .line 153
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.policiesPerProfile:Ljava/util/Map;
            ldc "default"
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy
            astore 5 /* policy */
         7: .line 155
      StackMap locals: com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper com.datastax.oss.driver.api.core.session.Request java.lang.String com.datastax.oss.driver.api.core.session.Session top com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy
      StackMap stack:
            aload 5 /* policy */
            aload 1 /* request */
            aload 3 /* session */
            invokeinterface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy.newQueryPlan:(Lcom/datastax/oss/driver/api/core/session/Request;Lcom/datastax/oss/driver/api/core/session/Session;)Ljava/util/Queue;
            areturn
        end local 5 // com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy policy
         8: .line 157
      StackMap locals: com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper com.datastax.oss.driver.api.core.session.Request java.lang.String com.datastax.oss.driver.api.core.session.Session
      StackMap stack:
            new java.util.concurrent.ConcurrentLinkedQueue
            dup
            invokespecial java.util.concurrent.ConcurrentLinkedQueue.<init>:()V
            areturn
        end local 3 // com.datastax.oss.driver.api.core.session.Session session
        end local 2 // java.lang.String executionProfileName
        end local 1 // com.datastax.oss.driver.api.core.session.Request request
        end local 0 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper this
      LocalVariableTable:
        Start  End  Slot                  Name  Signature
            0    9     0                  this  Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;
            0    9     1               request  Lcom/datastax/oss/driver/api/core/session/Request;
            0    9     2  executionProfileName  Ljava/lang/String;
            0    9     3               session  Lcom/datastax/oss/driver/api/core/session/Session;
            2    4     4                 nodes  Ljava/util/List<Lcom/datastax/oss/driver/api/core/metadata/Node;>;
            5    8     5                policy  Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;
    Signature: (Lcom/datastax/oss/driver/api/core/session/Request;Ljava/lang/String;Lcom/datastax/oss/driver/api/core/session/Session;)Ljava/util/Queue<Lcom/datastax/oss/driver/api/core/metadata/Node;>;
    RuntimeInvisibleAnnotations: 
      edu.umd.cs.findbugs.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        edu.umd.cs.findbugs.annotations.Nullable()
      1:
        edu.umd.cs.findbugs.annotations.NonNull()
      2:
        edu.umd.cs.findbugs.annotations.Nullable()
    MethodParameters:
                      Name  Flags
      request               
      executionProfileName  
      session               

  public java.util.Queue<com.datastax.oss.driver.api.core.metadata.Node> newQueryPlan();
    descriptor: ()Ljava/util/Queue;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper this
         0: .line 163
            aload 0 /* this */
            aconst_null
            ldc "default"
            aconst_null
            invokevirtual com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.newQueryPlan:(Lcom/datastax/oss/driver/api/core/session/Request;Ljava/lang/String;Lcom/datastax/oss/driver/api/core/session/Session;)Ljava/util/Queue;
            areturn
        end local 0 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;
    Signature: ()Ljava/util/Queue<Lcom/datastax/oss/driver/api/core/metadata/Node;>;
    RuntimeInvisibleAnnotations: 
      edu.umd.cs.findbugs.annotations.NonNull()

  private void onNodeStateEvent(com.datastax.oss.driver.internal.core.metadata.NodeStateEvent);
    descriptor: (Lcom/datastax/oss/driver/internal/core/metadata/NodeStateEvent;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper this
        start local 1 // com.datastax.oss.driver.internal.core.metadata.NodeStateEvent event
         0: .line 168
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.eventFilter:Lcom/datastax/oss/driver/internal/core/util/concurrent/ReplayingEventFilter;
            aload 1 /* event */
            invokevirtual com.datastax.oss.driver.internal.core.util.concurrent.ReplayingEventFilter.accept:(Ljava/lang/Object;)V
         1: .line 169
            return
        end local 1 // com.datastax.oss.driver.internal.core.metadata.NodeStateEvent event
        end local 0 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;
            0    2     1  event  Lcom/datastax/oss/driver/internal/core/metadata/NodeStateEvent;
    MethodParameters:
       Name  Flags
      event  

  private void processNodeStateEvent(com.datastax.oss.driver.internal.core.metadata.NodeStateEvent);
    descriptor: (Lcom/datastax/oss/driver/internal/core/metadata/NodeStateEvent;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=4, args_size=2
        start local 0 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper this
        start local 1 // com.datastax.oss.driver.internal.core.metadata.NodeStateEvent event
         0: .line 173
            invokestatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.$SWITCH_TABLE$com$datastax$oss$driver$internal$core$metadata$LoadBalancingPolicyWrapper$State:()[I
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.stateRef:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State
            invokevirtual com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.ordinal:()I
            iaload
            tableswitch { // 1 - 4
                    1: 1
                    2: 1
                    3: 3
                    4: 2
              default: 19
          }
         1: .line 176
      StackMap locals:
      StackMap stack:
            new java.lang.AssertionError
            dup
            ldc "Filter should not be marked ready until LBP init"
            invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
            athrow
         2: .line 178
      StackMap locals:
      StackMap stack:
            return
         3: .line 180
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.policies:Ljava/util/Set;
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 3
            goto 18
      StackMap locals: com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper com.datastax.oss.driver.internal.core.metadata.NodeStateEvent top java.util.Iterator
      StackMap stack:
         4: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy
            astore 2 /* policy */
        start local 2 // com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy policy
         5: .line 181
            aload 1 /* event */
            getfield com.datastax.oss.driver.internal.core.metadata.NodeStateEvent.newState:Lcom/datastax/oss/driver/api/core/metadata/NodeState;
            getstatic com.datastax.oss.driver.api.core.metadata.NodeState.UP:Lcom/datastax/oss/driver/api/core/metadata/NodeState;
            if_acmpne 8
         6: .line 182
            aload 2 /* policy */
            aload 1 /* event */
            getfield com.datastax.oss.driver.internal.core.metadata.NodeStateEvent.node:Lcom/datastax/oss/driver/internal/core/metadata/DefaultNode;
            invokeinterface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy.onUp:(Lcom/datastax/oss/driver/api/core/metadata/Node;)V
         7: .line 183
            goto 18
      StackMap locals: com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper com.datastax.oss.driver.internal.core.metadata.NodeStateEvent com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy java.util.Iterator
      StackMap stack:
         8: aload 1 /* event */
            getfield com.datastax.oss.driver.internal.core.metadata.NodeStateEvent.newState:Lcom/datastax/oss/driver/api/core/metadata/NodeState;
            getstatic com.datastax.oss.driver.api.core.metadata.NodeState.DOWN:Lcom/datastax/oss/driver/api/core/metadata/NodeState;
            if_acmpeq 9
            aload 1 /* event */
            getfield com.datastax.oss.driver.internal.core.metadata.NodeStateEvent.newState:Lcom/datastax/oss/driver/api/core/metadata/NodeState;
            getstatic com.datastax.oss.driver.api.core.metadata.NodeState.FORCED_DOWN:Lcom/datastax/oss/driver/api/core/metadata/NodeState;
            if_acmpne 11
         9: .line 184
      StackMap locals:
      StackMap stack:
            aload 2 /* policy */
            aload 1 /* event */
            getfield com.datastax.oss.driver.internal.core.metadata.NodeStateEvent.node:Lcom/datastax/oss/driver/internal/core/metadata/DefaultNode;
            invokeinterface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy.onDown:(Lcom/datastax/oss/driver/api/core/metadata/Node;)V
        10: .line 185
            goto 18
      StackMap locals:
      StackMap stack:
        11: aload 1 /* event */
            getfield com.datastax.oss.driver.internal.core.metadata.NodeStateEvent.newState:Lcom/datastax/oss/driver/api/core/metadata/NodeState;
            getstatic com.datastax.oss.driver.api.core.metadata.NodeState.UNKNOWN:Lcom/datastax/oss/driver/api/core/metadata/NodeState;
            if_acmpne 14
        12: .line 186
            aload 2 /* policy */
            aload 1 /* event */
            getfield com.datastax.oss.driver.internal.core.metadata.NodeStateEvent.node:Lcom/datastax/oss/driver/internal/core/metadata/DefaultNode;
            invokeinterface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy.onAdd:(Lcom/datastax/oss/driver/api/core/metadata/Node;)V
        13: .line 187
            goto 18
      StackMap locals:
      StackMap stack:
        14: aload 1 /* event */
            getfield com.datastax.oss.driver.internal.core.metadata.NodeStateEvent.newState:Lcom/datastax/oss/driver/api/core/metadata/NodeState;
            ifnonnull 17
        15: .line 188
            aload 2 /* policy */
            aload 1 /* event */
            getfield com.datastax.oss.driver.internal.core.metadata.NodeStateEvent.node:Lcom/datastax/oss/driver/internal/core/metadata/DefaultNode;
            invokeinterface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy.onRemove:(Lcom/datastax/oss/driver/api/core/metadata/Node;)V
        16: .line 189
            goto 18
        17: .line 190
      StackMap locals:
      StackMap stack:
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.LOG:Lorg/slf4j/Logger;
            ldc "[{}] Unsupported event: {}"
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.logPrefix:Ljava/lang/String;
            aload 1 /* event */
            invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
        end local 2 // com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy policy
        18: .line 180
      StackMap locals: com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper com.datastax.oss.driver.internal.core.metadata.NodeStateEvent top java.util.Iterator
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 4
        19: .line 195
      StackMap locals: com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper com.datastax.oss.driver.internal.core.metadata.NodeStateEvent
      StackMap stack:
            return
        end local 1 // com.datastax.oss.driver.internal.core.metadata.NodeStateEvent event
        end local 0 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   20     0    this  Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;
            0   20     1   event  Lcom/datastax/oss/driver/internal/core/metadata/NodeStateEvent;
            5   18     2  policy  Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;
    MethodParameters:
       Name  Flags
      event  

  public void close();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=1
        start local 0 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper this
         0: .line 201
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.stateRef:Ljava/util/concurrent/atomic/AtomicReference;
            invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
            checkcast com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State
            astore 1 /* old */
        start local 1 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State old
         1: .line 202
            aload 1 /* old */
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.CLOSING:Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;
            if_acmpne 3
         2: .line 203
            return
         3: .line 204
      StackMap locals: com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State
      StackMap stack:
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.stateRef:Ljava/util/concurrent/atomic/AtomicReference;
            aload 1 /* old */
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.CLOSING:Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;
            invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifeq 0
         4: .line 210
            aload 1 /* old */
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.RUNNING:Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;
            if_acmpne 9
         5: .line 211
            aload 0 /* this */
            getfield com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.policies:Ljava/util/Set;
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 3
            goto 8
      StackMap locals: com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State top java.util.Iterator
      StackMap stack:
         6: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy
            astore 2 /* policy */
        start local 2 // com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy policy
         7: .line 212
            aload 2 /* policy */
            invokeinterface com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy.close:()V
        end local 2 // com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy policy
         8: .line 211
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 6
         9: .line 215
      StackMap locals: com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State
      StackMap stack:
            return
        end local 1 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State old
        end local 0 // com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   10     0    this  Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper;
            1   10     1     old  Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;
            7    8     2  policy  Lcom/datastax/oss/driver/api/core/loadbalancing/LoadBalancingPolicy;

  static int[] $SWITCH_TABLE$com$datastax$oss$driver$internal$core$metadata$LoadBalancingPolicyWrapper$State();
    descriptor: ()[I
    flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=0
         0: .line 61
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.$SWITCH_TABLE$com$datastax$oss$driver$internal$core$metadata$LoadBalancingPolicyWrapper$State:[I
            dup
            ifnull 1
            areturn
      StackMap locals:
      StackMap stack: int[]
         1: pop
            invokestatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.values:()[Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;
            arraylength
            newarray 10
            astore 0
         2: aload 0
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.BEFORE_INIT:Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;
            invokevirtual com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.ordinal:()I
            iconst_1
            iastore
         3: goto 5
      StackMap locals: int[]
      StackMap stack: java.lang.NoSuchFieldError
         4: pop
      StackMap locals:
      StackMap stack:
         5: aload 0
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.CLOSING:Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;
            invokevirtual com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.ordinal:()I
            iconst_4
            iastore
         6: goto 8
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
         7: pop
      StackMap locals:
      StackMap stack:
         8: aload 0
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.DURING_INIT:Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;
            invokevirtual com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.ordinal:()I
            iconst_2
            iastore
         9: goto 11
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        10: pop
      StackMap locals:
      StackMap stack:
        11: aload 0
            getstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.RUNNING:Lcom/datastax/oss/driver/internal/core/metadata/LoadBalancingPolicyWrapper$State;
            invokevirtual com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State.ordinal:()I
            iconst_3
            iastore
        12: goto 14
      StackMap locals:
      StackMap stack: java.lang.NoSuchFieldError
        13: pop
      StackMap locals:
      StackMap stack:
        14: aload 0
            dup
            putstatic com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper.$SWITCH_TABLE$com$datastax$oss$driver$internal$core$metadata$LoadBalancingPolicyWrapper$State:[I
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
      Exception table:
        from    to  target  type
           2     3       4  Class java.lang.NoSuchFieldError
           5     6       7  Class java.lang.NoSuchFieldError
           8     9      10  Class java.lang.NoSuchFieldError
          11    12      13  Class java.lang.NoSuchFieldError
}
SourceFile: "LoadBalancingPolicyWrapper.java"
NestMembers:
  com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$SinglePolicyDistanceReporter  com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State
InnerClasses:
  public abstract DistanceReporter = com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy$DistanceReporter of com.datastax.oss.driver.api.core.loadbalancing.LoadBalancingPolicy
  private SinglePolicyDistanceReporter = com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$SinglePolicyDistanceReporter of com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper
  private final State = com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper$State of com.datastax.oss.driver.internal.core.metadata.LoadBalancingPolicyWrapper
  public Builder = com.datastax.oss.driver.shaded.guava.common.collect.ImmutableMap$Builder of com.datastax.oss.driver.shaded.guava.common.collect.ImmutableMap
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
    RuntimeVisibleAnnotations: 
      net.jcip.annotations.ThreadSafe()