https://cassandra.apache.org: The Apache Cassandra Project develops a highly scalable second-generation distributed database, bringing together Dynamo's fully distributed design and Bigtable's ColumnFamily-based data model.
  • Andres de la Peña
  • Avinash Lakshman
  • Aleksey Yeschenko
  • Aaron Morton
  • Ariel Weisberg
  • Blake Eggleston
  • Benedict Elliott Smith
  • Benjamin Lerer
  • Branimir Lambov
  • Brandon Williams
  • Carl Yeksigian
  • David Brosiusd
  • Dikang Gu
  • Eric Evans
  • Gary Dusbabek
  • Chris Goffinet
  • Alex Petrov
  • Laine Jaakko Olavi
  • T Jake Luciani
  • Jason Brown
  • Jonathan Ellis
  • Jake Farrell
  • Jeff Jirsa
  • Joel Knighton
  • Josh McKenzie
  • Johan Oskarsson
  • Jun Rao
  • Jay Zhuang
  • Sankalp Kohli
  • Marcus Eriksson
  • Michael Semb Wever
  • Mikhail Stepura
  • Michael Shuler
  • Paulo Motta
  • Prashant Malik
  • Robert Stupp
  • Peter Schuller
  • Sam Tunnicliffe
  • Sylvain Lebresne
  • Stefania Alborghetti
  • Tyler Hobbs
  • Vijay Parthasarathy
  • Pavel Yaskevich
  • Yuki Morishita
  • Nate McCall 
public abstract class org.apache.cassandra.locator.AbstractReplicationStrategy
  minor version: 0
  major version: 59
  flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
  this_class: org.apache.cassandra.locator.AbstractReplicationStrategy
  super_class: java.lang.Object
{
  private static final org.slf4j.Logger logger;
    descriptor: Lorg/slf4j/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  final java.lang.String keyspaceName;
    descriptor: Ljava/lang/String;
    flags: (0x0010) ACC_FINAL
    RuntimeInvisibleAnnotations: 
      com.google.common.annotations.VisibleForTesting()

  private org.apache.cassandra.db.Keyspace keyspace;
    descriptor: Lorg/apache/cassandra/db/Keyspace;
    flags: (0x0002) ACC_PRIVATE

  public final java.util.Map<java.lang.String, java.lang.String> configOptions;
    descriptor: Ljava/util/Map;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Signature: Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;

  private final org.apache.cassandra.locator.TokenMetadata tokenMetadata;
    descriptor: Lorg/apache/cassandra/locator/TokenMetadata;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private volatile long lastInvalidatedVersion;
    descriptor: J
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE

  public org.apache.cassandra.locator.IEndpointSnitch snitch;
    descriptor: Lorg/apache/cassandra/locator/IEndpointSnitch;
    flags: (0x0001) ACC_PUBLIC

  private final java.util.Map<org.apache.cassandra.dht.Token, java.util.ArrayList<java.net.InetAddress>> cachedEndpoints;
    descriptor: Ljava/util/Map;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Map<Lorg/apache/cassandra/dht/Token;Ljava/util/ArrayList<Ljava/net/InetAddress;>;>;

  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=1, locals=0, args_size=0
         0: .line 48
            ldc Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            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 org.apache.cassandra.locator.AbstractReplicationStrategy.$assertionsDisabled:Z
         3: .line 50
            ldc Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
            putstatic org.apache.cassandra.locator.AbstractReplicationStrategy.logger:Lorg/slf4j/Logger;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  protected void <init>(java.lang.String, org.apache.cassandra.locator.TokenMetadata, org.apache.cassandra.locator.IEndpointSnitch, java.util.Map<java.lang.String, java.lang.String>);
    descriptor: (Ljava/lang/String;Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/util/Map;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=5, args_size=5
        start local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
        start local 1 // java.lang.String keyspaceName
        start local 2 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        start local 3 // org.apache.cassandra.locator.IEndpointSnitch snitch
        start local 4 // java.util.Map configOptions
         0: .line 63
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 59
            aload 0 /* this */
            lconst_0
            putfield org.apache.cassandra.locator.AbstractReplicationStrategy.lastInvalidatedVersion:J
         2: .line 75
            aload 0 /* this */
            new org.cliffc.high_scale_lib.NonBlockingHashMap
            dup
            invokespecial org.cliffc.high_scale_lib.NonBlockingHashMap.<init>:()V
            putfield org.apache.cassandra.locator.AbstractReplicationStrategy.cachedEndpoints:Ljava/util/Map;
         3: .line 65
            getstatic org.apache.cassandra.locator.AbstractReplicationStrategy.$assertionsDisabled:Z
            ifne 4
            aload 1 /* keyspaceName */
            ifnonnull 4
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         4: .line 66
      StackMap locals: org.apache.cassandra.locator.AbstractReplicationStrategy java.lang.String org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.locator.IEndpointSnitch java.util.Map
      StackMap stack:
            getstatic org.apache.cassandra.locator.AbstractReplicationStrategy.$assertionsDisabled:Z
            ifne 5
            aload 3 /* snitch */
            ifnonnull 5
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         5: .line 67
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.locator.AbstractReplicationStrategy.$assertionsDisabled:Z
            ifne 6
            aload 2 /* tokenMetadata */
            ifnonnull 6
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         6: .line 68
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 2 /* tokenMetadata */
            putfield org.apache.cassandra.locator.AbstractReplicationStrategy.tokenMetadata:Lorg/apache/cassandra/locator/TokenMetadata;
         7: .line 69
            aload 0 /* this */
            aload 3 /* snitch */
            putfield org.apache.cassandra.locator.AbstractReplicationStrategy.snitch:Lorg/apache/cassandra/locator/IEndpointSnitch;
         8: .line 70
            aload 0 /* this */
            aload 4 /* configOptions */
            ifnonnull 9
            invokestatic java.util.Collections.emptyMap:()Ljava/util/Map;
            goto 10
      StackMap locals:
      StackMap stack: org.apache.cassandra.locator.AbstractReplicationStrategy
         9: aload 4 /* configOptions */
      StackMap locals: org.apache.cassandra.locator.AbstractReplicationStrategy java.lang.String org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.locator.IEndpointSnitch java.util.Map
      StackMap stack: org.apache.cassandra.locator.AbstractReplicationStrategy java.util.Map
        10: putfield org.apache.cassandra.locator.AbstractReplicationStrategy.configOptions:Ljava/util/Map;
        11: .line 71
            aload 0 /* this */
            aload 1 /* keyspaceName */
            putfield org.apache.cassandra.locator.AbstractReplicationStrategy.keyspaceName:Ljava/lang/String;
        12: .line 73
            return
        end local 4 // java.util.Map configOptions
        end local 3 // org.apache.cassandra.locator.IEndpointSnitch snitch
        end local 2 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        end local 1 // java.lang.String keyspaceName
        end local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   13     0           this  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            0   13     1   keyspaceName  Ljava/lang/String;
            0   13     2  tokenMetadata  Lorg/apache/cassandra/locator/TokenMetadata;
            0   13     3         snitch  Lorg/apache/cassandra/locator/IEndpointSnitch;
            0   13     4  configOptions  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
    Signature: (Ljava/lang/String;Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
               Name  Flags
      keyspaceName   
      tokenMetadata  
      snitch         
      configOptions  

  public java.util.ArrayList<java.net.InetAddress> getCachedEndpoints(org.apache.cassandra.dht.Token);
    descriptor: (Lorg/apache/cassandra/dht/Token;)Ljava/util/ArrayList;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=5, args_size=2
        start local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
        start local 1 // org.apache.cassandra.dht.Token t
         0: .line 79
            aload 0 /* this */
            getfield org.apache.cassandra.locator.AbstractReplicationStrategy.tokenMetadata:Lorg/apache/cassandra/locator/TokenMetadata;
            invokevirtual org.apache.cassandra.locator.TokenMetadata.getRingVersion:()J
            lstore 2 /* lastVersion */
        start local 2 // long lastVersion
         1: .line 81
            lload 2 /* lastVersion */
            aload 0 /* this */
            getfield org.apache.cassandra.locator.AbstractReplicationStrategy.lastInvalidatedVersion:J
            lcmp
            ifle 11
         2: .line 83
            aload 0 /* this */
            dup
            astore 4
            monitorenter
         3: .line 85
            lload 2 /* lastVersion */
            aload 0 /* this */
            getfield org.apache.cassandra.locator.AbstractReplicationStrategy.lastInvalidatedVersion:J
            lcmp
            ifle 7
         4: .line 87
            getstatic org.apache.cassandra.locator.AbstractReplicationStrategy.logger:Lorg/slf4j/Logger;
            ldc "clearing cached endpoints"
            invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;)V
         5: .line 88
            aload 0 /* this */
            getfield org.apache.cassandra.locator.AbstractReplicationStrategy.cachedEndpoints:Ljava/util/Map;
            invokeinterface java.util.Map.clear:()V
         6: .line 89
            aload 0 /* this */
            lload 2 /* lastVersion */
            putfield org.apache.cassandra.locator.AbstractReplicationStrategy.lastInvalidatedVersion:J
         7: .line 83
      StackMap locals: long org.apache.cassandra.locator.AbstractReplicationStrategy
      StackMap stack:
            aload 4
            monitorexit
         8: goto 11
      StackMap locals:
      StackMap stack: java.lang.Throwable
         9: aload 4
            monitorexit
        10: athrow
        11: .line 94
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.locator.AbstractReplicationStrategy.cachedEndpoints:Ljava/util/Map;
            aload 1 /* t */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.util.ArrayList
            areturn
        end local 2 // long lastVersion
        end local 1 // org.apache.cassandra.dht.Token t
        end local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0   12     0         this  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            0   12     1            t  Lorg/apache/cassandra/dht/Token;
            1   12     2  lastVersion  J
      Exception table:
        from    to  target  type
           3     8       9  any
           9    10       9  any
    Signature: (Lorg/apache/cassandra/dht/Token;)Ljava/util/ArrayList<Ljava/net/InetAddress;>;
    MethodParameters:
      Name  Flags
      t     

  public java.util.ArrayList<java.net.InetAddress> getNaturalEndpoints(org.apache.cassandra.dht.RingPosition);
    descriptor: (Lorg/apache/cassandra/dht/RingPosition;)Ljava/util/ArrayList;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=6, args_size=2
        start local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
        start local 1 // org.apache.cassandra.dht.RingPosition searchPosition
         0: .line 106
            aload 1 /* searchPosition */
            invokeinterface org.apache.cassandra.dht.RingPosition.getToken:()Lorg/apache/cassandra/dht/Token;
            astore 2 /* searchToken */
        start local 2 // org.apache.cassandra.dht.Token searchToken
         1: .line 107
            aload 0 /* this */
            getfield org.apache.cassandra.locator.AbstractReplicationStrategy.tokenMetadata:Lorg/apache/cassandra/locator/TokenMetadata;
            invokevirtual org.apache.cassandra.locator.TokenMetadata.sortedTokens:()Ljava/util/ArrayList;
            aload 2 /* searchToken */
            invokestatic org.apache.cassandra.locator.TokenMetadata.firstToken:(Ljava/util/ArrayList;Lorg/apache/cassandra/dht/Token;)Lorg/apache/cassandra/dht/Token;
            astore 3 /* keyToken */
        start local 3 // org.apache.cassandra.dht.Token keyToken
         2: .line 108
            aload 0 /* this */
            aload 3 /* keyToken */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.getCachedEndpoints:(Lorg/apache/cassandra/dht/Token;)Ljava/util/ArrayList;
            astore 4 /* endpoints */
        start local 4 // java.util.ArrayList endpoints
         3: .line 109
            aload 4 /* endpoints */
            ifnonnull 8
         4: .line 111
            aload 0 /* this */
            getfield org.apache.cassandra.locator.AbstractReplicationStrategy.tokenMetadata:Lorg/apache/cassandra/locator/TokenMetadata;
            invokevirtual org.apache.cassandra.locator.TokenMetadata.cachedOnlyTokenMap:()Lorg/apache/cassandra/locator/TokenMetadata;
            astore 5 /* tm */
        start local 5 // org.apache.cassandra.locator.TokenMetadata tm
         5: .line 113
            aload 5 /* tm */
            invokevirtual org.apache.cassandra.locator.TokenMetadata.sortedTokens:()Ljava/util/ArrayList;
            aload 2 /* searchToken */
            invokestatic org.apache.cassandra.locator.TokenMetadata.firstToken:(Ljava/util/ArrayList;Lorg/apache/cassandra/dht/Token;)Lorg/apache/cassandra/dht/Token;
            astore 3 /* keyToken */
         6: .line 114
            new java.util.ArrayList
            dup
            aload 0 /* this */
            aload 2 /* searchToken */
            aload 5 /* tm */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.calculateNaturalEndpoints:(Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/locator/TokenMetadata;)Ljava/util/List;
            invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
            astore 4 /* endpoints */
         7: .line 115
            aload 0 /* this */
            getfield org.apache.cassandra.locator.AbstractReplicationStrategy.cachedEndpoints:Ljava/util/Map;
            aload 3 /* keyToken */
            aload 4 /* endpoints */
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        end local 5 // org.apache.cassandra.locator.TokenMetadata tm
         8: .line 118
      StackMap locals: org.apache.cassandra.dht.Token org.apache.cassandra.dht.Token java.util.ArrayList
      StackMap stack:
            new java.util.ArrayList
            dup
            aload 4 /* endpoints */
            invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
            areturn
        end local 4 // java.util.ArrayList endpoints
        end local 3 // org.apache.cassandra.dht.Token keyToken
        end local 2 // org.apache.cassandra.dht.Token searchToken
        end local 1 // org.apache.cassandra.dht.RingPosition searchPosition
        end local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    9     0            this  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            0    9     1  searchPosition  Lorg/apache/cassandra/dht/RingPosition;
            1    9     2     searchToken  Lorg/apache/cassandra/dht/Token;
            2    9     3        keyToken  Lorg/apache/cassandra/dht/Token;
            3    9     4       endpoints  Ljava/util/ArrayList<Ljava/net/InetAddress;>;
            5    8     5              tm  Lorg/apache/cassandra/locator/TokenMetadata;
    Signature: (Lorg/apache/cassandra/dht/RingPosition;)Ljava/util/ArrayList<Ljava/net/InetAddress;>;
    MethodParameters:
                Name  Flags
      searchPosition  

  public abstract java.util.List<java.net.InetAddress> calculateNaturalEndpoints(org.apache.cassandra.dht.Token, org.apache.cassandra.locator.TokenMetadata);
    descriptor: (Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/locator/TokenMetadata;)Ljava/util/List;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/locator/TokenMetadata;)Ljava/util/List<Ljava/net/InetAddress;>;
    MethodParameters:
               Name  Flags
      searchToken    
      tokenMetadata  

  public <T> org.apache.cassandra.service.AbstractWriteResponseHandler<T> getWriteResponseHandler(java.util.Collection<java.net.InetAddress>, java.util.Collection<java.net.InetAddress>, org.apache.cassandra.db.ConsistencyLevel, java.lang.Runnable, org.apache.cassandra.db.WriteType, long);
    descriptor: (Ljava/util/Collection;Ljava/util/Collection;Lorg/apache/cassandra/db/ConsistencyLevel;Ljava/lang/Runnable;Lorg/apache/cassandra/db/WriteType;J)Lorg/apache/cassandra/service/AbstractWriteResponseHandler;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=10, locals=8, args_size=7
        start local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
        start local 1 // java.util.Collection naturalEndpoints
        start local 2 // java.util.Collection pendingEndpoints
        start local 3 // org.apache.cassandra.db.ConsistencyLevel consistency_level
        start local 4 // java.lang.Runnable callback
        start local 5 // org.apache.cassandra.db.WriteType writeType
        start local 6 // long queryStartNanoTime
         0: .line 138
            aload 3 /* consistency_level */
            invokevirtual org.apache.cassandra.db.ConsistencyLevel.isDatacenterLocal:()Z
            ifeq 2
         1: .line 141
            new org.apache.cassandra.service.DatacenterWriteResponseHandler
            dup
            aload 1 /* naturalEndpoints */
            aload 2 /* pendingEndpoints */
            aload 3 /* consistency_level */
            aload 0 /* this */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.getKeyspace:()Lorg/apache/cassandra/db/Keyspace;
            aload 4 /* callback */
            aload 5 /* writeType */
            lload 6 /* queryStartNanoTime */
            invokespecial org.apache.cassandra.service.DatacenterWriteResponseHandler.<init>:(Ljava/util/Collection;Ljava/util/Collection;Lorg/apache/cassandra/db/ConsistencyLevel;Lorg/apache/cassandra/db/Keyspace;Ljava/lang/Runnable;Lorg/apache/cassandra/db/WriteType;J)V
            areturn
         2: .line 143
      StackMap locals:
      StackMap stack:
            aload 3 /* consistency_level */
            getstatic org.apache.cassandra.db.ConsistencyLevel.EACH_QUORUM:Lorg/apache/cassandra/db/ConsistencyLevel;
            if_acmpne 4
            aload 0 /* this */
            instanceof org.apache.cassandra.locator.NetworkTopologyStrategy
            ifeq 4
         3: .line 145
            new org.apache.cassandra.service.DatacenterSyncWriteResponseHandler
            dup
            aload 1 /* naturalEndpoints */
            aload 2 /* pendingEndpoints */
            aload 3 /* consistency_level */
            aload 0 /* this */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.getKeyspace:()Lorg/apache/cassandra/db/Keyspace;
            aload 4 /* callback */
            aload 5 /* writeType */
            lload 6 /* queryStartNanoTime */
            invokespecial org.apache.cassandra.service.DatacenterSyncWriteResponseHandler.<init>:(Ljava/util/Collection;Ljava/util/Collection;Lorg/apache/cassandra/db/ConsistencyLevel;Lorg/apache/cassandra/db/Keyspace;Ljava/lang/Runnable;Lorg/apache/cassandra/db/WriteType;J)V
            areturn
         4: .line 147
      StackMap locals:
      StackMap stack:
            new org.apache.cassandra.service.WriteResponseHandler
            dup
            aload 1 /* naturalEndpoints */
            aload 2 /* pendingEndpoints */
            aload 3 /* consistency_level */
            aload 0 /* this */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.getKeyspace:()Lorg/apache/cassandra/db/Keyspace;
            aload 4 /* callback */
            aload 5 /* writeType */
            lload 6 /* queryStartNanoTime */
            invokespecial org.apache.cassandra.service.WriteResponseHandler.<init>:(Ljava/util/Collection;Ljava/util/Collection;Lorg/apache/cassandra/db/ConsistencyLevel;Lorg/apache/cassandra/db/Keyspace;Ljava/lang/Runnable;Lorg/apache/cassandra/db/WriteType;J)V
            areturn
        end local 6 // long queryStartNanoTime
        end local 5 // org.apache.cassandra.db.WriteType writeType
        end local 4 // java.lang.Runnable callback
        end local 3 // org.apache.cassandra.db.ConsistencyLevel consistency_level
        end local 2 // java.util.Collection pendingEndpoints
        end local 1 // java.util.Collection naturalEndpoints
        end local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    5     0                this  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            0    5     1    naturalEndpoints  Ljava/util/Collection<Ljava/net/InetAddress;>;
            0    5     2    pendingEndpoints  Ljava/util/Collection<Ljava/net/InetAddress;>;
            0    5     3   consistency_level  Lorg/apache/cassandra/db/ConsistencyLevel;
            0    5     4            callback  Ljava/lang/Runnable;
            0    5     5           writeType  Lorg/apache/cassandra/db/WriteType;
            0    5     6  queryStartNanoTime  J
    Signature: <T:Ljava/lang/Object;>(Ljava/util/Collection<Ljava/net/InetAddress;>;Ljava/util/Collection<Ljava/net/InetAddress;>;Lorg/apache/cassandra/db/ConsistencyLevel;Ljava/lang/Runnable;Lorg/apache/cassandra/db/WriteType;J)Lorg/apache/cassandra/service/AbstractWriteResponseHandler<TT;>;
    MethodParameters:
                    Name  Flags
      naturalEndpoints    
      pendingEndpoints    
      consistency_level   
      callback            
      writeType           
      queryStartNanoTime  

  private org.apache.cassandra.db.Keyspace getKeyspace();
    descriptor: ()Lorg/apache/cassandra/db/Keyspace;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
         0: .line 152
            aload 0 /* this */
            getfield org.apache.cassandra.locator.AbstractReplicationStrategy.keyspace:Lorg/apache/cassandra/db/Keyspace;
            ifnonnull 2
         1: .line 153
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.locator.AbstractReplicationStrategy.keyspaceName:Ljava/lang/String;
            invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
            putfield org.apache.cassandra.locator.AbstractReplicationStrategy.keyspace:Lorg/apache/cassandra/db/Keyspace;
         2: .line 154
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.locator.AbstractReplicationStrategy.keyspace:Lorg/apache/cassandra/db/Keyspace;
            areturn
        end local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;

  public abstract int getReplicationFactor();
    descriptor: ()I
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT

  public com.google.common.collect.Multimap<java.net.InetAddress, org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>> getAddressRanges(org.apache.cassandra.locator.TokenMetadata);
    descriptor: (Lorg/apache/cassandra/locator/TokenMetadata;)Lcom/google/common/collect/Multimap;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=8, args_size=2
        start local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
        start local 1 // org.apache.cassandra.locator.TokenMetadata metadata
         0: .line 173
            invokestatic com.google.common.collect.HashMultimap.create:()Lcom/google/common/collect/HashMultimap;
            astore 2 /* map */
        start local 2 // com.google.common.collect.Multimap map
         1: .line 175
            aload 1 /* metadata */
            invokevirtual org.apache.cassandra.locator.TokenMetadata.sortedTokens:()Ljava/util/ArrayList;
            invokevirtual java.util.ArrayList.iterator:()Ljava/util/Iterator;
            astore 4
            goto 8
      StackMap locals: org.apache.cassandra.locator.AbstractReplicationStrategy org.apache.cassandra.locator.TokenMetadata com.google.common.collect.Multimap top java.util.Iterator
      StackMap stack:
         2: aload 4
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.dht.Token
            astore 3 /* token */
        start local 3 // org.apache.cassandra.dht.Token token
         3: .line 177
            aload 1 /* metadata */
            aload 3 /* token */
            invokevirtual org.apache.cassandra.locator.TokenMetadata.getPrimaryRangeFor:(Lorg/apache/cassandra/dht/Token;)Lorg/apache/cassandra/dht/Range;
            astore 5 /* range */
        start local 5 // org.apache.cassandra.dht.Range range
         4: .line 178
            aload 0 /* this */
            aload 3 /* token */
            aload 1 /* metadata */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.calculateNaturalEndpoints:(Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/locator/TokenMetadata;)Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 7
            goto 7
      StackMap locals: org.apache.cassandra.locator.AbstractReplicationStrategy org.apache.cassandra.locator.TokenMetadata com.google.common.collect.Multimap org.apache.cassandra.dht.Token java.util.Iterator org.apache.cassandra.dht.Range top java.util.Iterator
      StackMap stack:
         5: aload 7
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.net.InetAddress
            astore 6 /* ep */
        start local 6 // java.net.InetAddress ep
         6: .line 180
            aload 2 /* map */
            aload 6 /* ep */
            aload 5 /* range */
            invokeinterface com.google.common.collect.Multimap.put:(Ljava/lang/Object;Ljava/lang/Object;)Z
            pop
        end local 6 // java.net.InetAddress ep
         7: .line 178
      StackMap locals:
      StackMap stack:
            aload 7
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 5
        end local 5 // org.apache.cassandra.dht.Range range
        end local 3 // org.apache.cassandra.dht.Token token
         8: .line 175
      StackMap locals: org.apache.cassandra.locator.AbstractReplicationStrategy org.apache.cassandra.locator.TokenMetadata com.google.common.collect.Multimap top java.util.Iterator
      StackMap stack:
            aload 4
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         9: .line 184
            aload 2 /* map */
            areturn
        end local 2 // com.google.common.collect.Multimap map
        end local 1 // org.apache.cassandra.locator.TokenMetadata metadata
        end local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   10     0      this  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            0   10     1  metadata  Lorg/apache/cassandra/locator/TokenMetadata;
            1   10     2       map  Lcom/google/common/collect/Multimap<Ljava/net/InetAddress;Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
            3    8     3     token  Lorg/apache/cassandra/dht/Token;
            4    8     5     range  Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;
            6    7     6        ep  Ljava/net/InetAddress;
    Signature: (Lorg/apache/cassandra/locator/TokenMetadata;)Lcom/google/common/collect/Multimap<Ljava/net/InetAddress;Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
    MethodParameters:
          Name  Flags
      metadata  

  public com.google.common.collect.Multimap<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>, java.net.InetAddress> getRangeAddresses(org.apache.cassandra.locator.TokenMetadata);
    descriptor: (Lorg/apache/cassandra/locator/TokenMetadata;)Lcom/google/common/collect/Multimap;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=8, args_size=2
        start local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
        start local 1 // org.apache.cassandra.locator.TokenMetadata metadata
         0: .line 189
            invokestatic com.google.common.collect.HashMultimap.create:()Lcom/google/common/collect/HashMultimap;
            astore 2 /* map */
        start local 2 // com.google.common.collect.Multimap map
         1: .line 191
            aload 1 /* metadata */
            invokevirtual org.apache.cassandra.locator.TokenMetadata.sortedTokens:()Ljava/util/ArrayList;
            invokevirtual java.util.ArrayList.iterator:()Ljava/util/Iterator;
            astore 4
            goto 8
      StackMap locals: org.apache.cassandra.locator.AbstractReplicationStrategy org.apache.cassandra.locator.TokenMetadata com.google.common.collect.Multimap top java.util.Iterator
      StackMap stack:
         2: aload 4
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.dht.Token
            astore 3 /* token */
        start local 3 // org.apache.cassandra.dht.Token token
         3: .line 193
            aload 1 /* metadata */
            aload 3 /* token */
            invokevirtual org.apache.cassandra.locator.TokenMetadata.getPrimaryRangeFor:(Lorg/apache/cassandra/dht/Token;)Lorg/apache/cassandra/dht/Range;
            astore 5 /* range */
        start local 5 // org.apache.cassandra.dht.Range range
         4: .line 194
            aload 0 /* this */
            aload 3 /* token */
            aload 1 /* metadata */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.calculateNaturalEndpoints:(Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/locator/TokenMetadata;)Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 7
            goto 7
      StackMap locals: org.apache.cassandra.locator.AbstractReplicationStrategy org.apache.cassandra.locator.TokenMetadata com.google.common.collect.Multimap org.apache.cassandra.dht.Token java.util.Iterator org.apache.cassandra.dht.Range top java.util.Iterator
      StackMap stack:
         5: aload 7
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.net.InetAddress
            astore 6 /* ep */
        start local 6 // java.net.InetAddress ep
         6: .line 196
            aload 2 /* map */
            aload 5 /* range */
            aload 6 /* ep */
            invokeinterface com.google.common.collect.Multimap.put:(Ljava/lang/Object;Ljava/lang/Object;)Z
            pop
        end local 6 // java.net.InetAddress ep
         7: .line 194
      StackMap locals:
      StackMap stack:
            aload 7
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 5
        end local 5 // org.apache.cassandra.dht.Range range
        end local 3 // org.apache.cassandra.dht.Token token
         8: .line 191
      StackMap locals: org.apache.cassandra.locator.AbstractReplicationStrategy org.apache.cassandra.locator.TokenMetadata com.google.common.collect.Multimap top java.util.Iterator
      StackMap stack:
            aload 4
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         9: .line 200
            aload 2 /* map */
            areturn
        end local 2 // com.google.common.collect.Multimap map
        end local 1 // org.apache.cassandra.locator.TokenMetadata metadata
        end local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   10     0      this  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            0   10     1  metadata  Lorg/apache/cassandra/locator/TokenMetadata;
            1   10     2       map  Lcom/google/common/collect/Multimap<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;Ljava/net/InetAddress;>;
            3    8     3     token  Lorg/apache/cassandra/dht/Token;
            4    8     5     range  Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;
            6    7     6        ep  Ljava/net/InetAddress;
    Signature: (Lorg/apache/cassandra/locator/TokenMetadata;)Lcom/google/common/collect/Multimap<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;Ljava/net/InetAddress;>;
    MethodParameters:
          Name  Flags
      metadata  

  public com.google.common.collect.Multimap<java.net.InetAddress, org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>> getAddressRanges();
    descriptor: ()Lcom/google/common/collect/Multimap;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
         0: .line 205
            aload 0 /* this */
            aload 0 /* this */
            getfield org.apache.cassandra.locator.AbstractReplicationStrategy.tokenMetadata:Lorg/apache/cassandra/locator/TokenMetadata;
            invokevirtual org.apache.cassandra.locator.TokenMetadata.cloneOnlyTokenMap:()Lorg/apache/cassandra/locator/TokenMetadata;
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.getAddressRanges:(Lorg/apache/cassandra/locator/TokenMetadata;)Lcom/google/common/collect/Multimap;
            areturn
        end local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
    Signature: ()Lcom/google/common/collect/Multimap<Ljava/net/InetAddress;Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;

  public java.util.Collection<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>> getPendingAddressRanges(org.apache.cassandra.locator.TokenMetadata, org.apache.cassandra.dht.Token, java.net.InetAddress);
    descriptor: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/dht/Token;Ljava/net/InetAddress;)Ljava/util/Collection;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=4, args_size=4
        start local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
        start local 1 // org.apache.cassandra.locator.TokenMetadata metadata
        start local 2 // org.apache.cassandra.dht.Token pendingToken
        start local 3 // java.net.InetAddress pendingAddress
         0: .line 210
            aload 0 /* this */
            aload 1 /* metadata */
            iconst_1
            anewarray org.apache.cassandra.dht.Token
            dup
            iconst_0
            aload 2 /* pendingToken */
            aastore
            invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
            aload 3 /* pendingAddress */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.getPendingAddressRanges:(Lorg/apache/cassandra/locator/TokenMetadata;Ljava/util/Collection;Ljava/net/InetAddress;)Ljava/util/Collection;
            areturn
        end local 3 // java.net.InetAddress pendingAddress
        end local 2 // org.apache.cassandra.dht.Token pendingToken
        end local 1 // org.apache.cassandra.locator.TokenMetadata metadata
        end local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    1     0            this  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            0    1     1        metadata  Lorg/apache/cassandra/locator/TokenMetadata;
            0    1     2    pendingToken  Lorg/apache/cassandra/dht/Token;
            0    1     3  pendingAddress  Ljava/net/InetAddress;
    Signature: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/dht/Token;Ljava/net/InetAddress;)Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
    MethodParameters:
                Name  Flags
      metadata        
      pendingToken    
      pendingAddress  

  public java.util.Collection<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>> getPendingAddressRanges(org.apache.cassandra.locator.TokenMetadata, java.util.Collection<org.apache.cassandra.dht.Token>, java.net.InetAddress);
    descriptor: (Lorg/apache/cassandra/locator/TokenMetadata;Ljava/util/Collection;Ljava/net/InetAddress;)Ljava/util/Collection;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=5, args_size=4
        start local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
        start local 1 // org.apache.cassandra.locator.TokenMetadata metadata
        start local 2 // java.util.Collection pendingTokens
        start local 3 // java.net.InetAddress pendingAddress
         0: .line 215
            aload 1 /* metadata */
            invokevirtual org.apache.cassandra.locator.TokenMetadata.cloneOnlyTokenMap:()Lorg/apache/cassandra/locator/TokenMetadata;
            astore 4 /* temp */
        start local 4 // org.apache.cassandra.locator.TokenMetadata temp
         1: .line 216
            aload 4 /* temp */
            aload 2 /* pendingTokens */
            aload 3 /* pendingAddress */
            invokevirtual org.apache.cassandra.locator.TokenMetadata.updateNormalTokens:(Ljava/util/Collection;Ljava/net/InetAddress;)V
         2: .line 217
            aload 0 /* this */
            aload 4 /* temp */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.getAddressRanges:(Lorg/apache/cassandra/locator/TokenMetadata;)Lcom/google/common/collect/Multimap;
            aload 3 /* pendingAddress */
            invokeinterface com.google.common.collect.Multimap.get:(Ljava/lang/Object;)Ljava/util/Collection;
            areturn
        end local 4 // org.apache.cassandra.locator.TokenMetadata temp
        end local 3 // java.net.InetAddress pendingAddress
        end local 2 // java.util.Collection pendingTokens
        end local 1 // org.apache.cassandra.locator.TokenMetadata metadata
        end local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    3     0            this  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            0    3     1        metadata  Lorg/apache/cassandra/locator/TokenMetadata;
            0    3     2   pendingTokens  Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;
            0    3     3  pendingAddress  Ljava/net/InetAddress;
            1    3     4            temp  Lorg/apache/cassandra/locator/TokenMetadata;
    Signature: (Lorg/apache/cassandra/locator/TokenMetadata;Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;Ljava/net/InetAddress;)Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
    MethodParameters:
                Name  Flags
      metadata        
      pendingTokens   
      pendingAddress  

  public abstract void validateOptions();
    descriptor: ()V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Exceptions:
      throws org.apache.cassandra.exceptions.ConfigurationException

  public java.util.Collection<java.lang.String> recognizedOptions();
    descriptor: ()Ljava/util/Collection;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
         0: .line 230
            aconst_null
            areturn
        end local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
    Signature: ()Ljava/util/Collection<Ljava/lang/String;>;

  private static org.apache.cassandra.locator.AbstractReplicationStrategy createInternal(java.lang.String, java.lang.Class<? extends org.apache.cassandra.locator.AbstractReplicationStrategy>, org.apache.cassandra.locator.TokenMetadata, org.apache.cassandra.locator.IEndpointSnitch, java.util.Map<java.lang.String, java.lang.String>);
    descriptor: (Ljava/lang/String;Ljava/lang/Class;Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/util/Map;)Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=5, locals=9, args_size=5
        start local 0 // java.lang.String keyspaceName
        start local 1 // java.lang.Class strategyClass
        start local 2 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        start local 3 // org.apache.cassandra.locator.IEndpointSnitch snitch
        start local 4 // java.util.Map strategyOptions
         0: .line 241
            iconst_4
            anewarray java.lang.Class
            dup
            iconst_0
            ldc Ljava/lang/String;
            aastore
            dup
            iconst_1
            ldc Lorg/apache/cassandra/locator/TokenMetadata;
            aastore
            dup
            iconst_2
            ldc Lorg/apache/cassandra/locator/IEndpointSnitch;
            aastore
            dup
            iconst_3
            ldc Ljava/util/Map;
            aastore
            astore 6 /* parameterTypes */
        start local 6 // java.lang.Class[] parameterTypes
         1: .line 244
            aload 1 /* strategyClass */
            aload 6 /* parameterTypes */
            invokevirtual java.lang.Class.getConstructor:([Ljava/lang/Class;)Ljava/lang/reflect/Constructor;
            astore 7 /* constructor */
        start local 7 // java.lang.reflect.Constructor constructor
         2: .line 245
            aload 7 /* constructor */
            iconst_4
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* keyspaceName */
            aastore
            dup
            iconst_1
            aload 2 /* tokenMetadata */
            aastore
            dup
            iconst_2
            aload 3 /* snitch */
            aastore
            dup
            iconst_3
            aload 4 /* strategyOptions */
            aastore
            invokevirtual java.lang.reflect.Constructor.newInstance:([Ljava/lang/Object;)Ljava/lang/Object;
            checkcast org.apache.cassandra.locator.AbstractReplicationStrategy
            astore 5 /* strategy */
        end local 7 // java.lang.reflect.Constructor constructor
        start local 5 // org.apache.cassandra.locator.AbstractReplicationStrategy strategy
         3: .line 246
            goto 9
        end local 5 // org.apache.cassandra.locator.AbstractReplicationStrategy strategy
         4: .line 247
      StackMap locals: java.lang.String java.lang.Class org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.locator.IEndpointSnitch java.util.Map top java.lang.Class[]
      StackMap stack: java.lang.reflect.InvocationTargetException
            astore 7 /* e */
        start local 7 // java.lang.reflect.InvocationTargetException e
         5: .line 249
            aload 7 /* e */
            invokevirtual java.lang.reflect.InvocationTargetException.getTargetException:()Ljava/lang/Throwable;
            astore 8 /* targetException */
        start local 8 // java.lang.Throwable targetException
         6: .line 250
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            aload 8 /* targetException */
            invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
            aload 8 /* targetException */
            invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 8 // java.lang.Throwable targetException
        end local 7 // java.lang.reflect.InvocationTargetException e
         7: .line 252
      StackMap locals:
      StackMap stack: java.lang.Exception
            astore 7 /* e */
        start local 7 // java.lang.Exception e
         8: .line 254
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            ldc "Error constructing replication strategy class"
            aload 7 /* e */
            invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 7 // java.lang.Exception e
        start local 5 // org.apache.cassandra.locator.AbstractReplicationStrategy strategy
         9: .line 256
      StackMap locals: java.lang.String java.lang.Class org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.locator.IEndpointSnitch java.util.Map org.apache.cassandra.locator.AbstractReplicationStrategy java.lang.Class[]
      StackMap stack:
            aload 5 /* strategy */
            areturn
        end local 6 // java.lang.Class[] parameterTypes
        end local 5 // org.apache.cassandra.locator.AbstractReplicationStrategy strategy
        end local 4 // java.util.Map strategyOptions
        end local 3 // org.apache.cassandra.locator.IEndpointSnitch snitch
        end local 2 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        end local 1 // java.lang.Class strategyClass
        end local 0 // java.lang.String keyspaceName
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   10     0     keyspaceName  Ljava/lang/String;
            0   10     1    strategyClass  Ljava/lang/Class<+Lorg/apache/cassandra/locator/AbstractReplicationStrategy;>;
            0   10     2    tokenMetadata  Lorg/apache/cassandra/locator/TokenMetadata;
            0   10     3           snitch  Lorg/apache/cassandra/locator/IEndpointSnitch;
            0   10     4  strategyOptions  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
            3    4     5         strategy  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            9   10     5         strategy  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            1   10     6   parameterTypes  [Ljava/lang/Class;
            2    3     7      constructor  Ljava/lang/reflect/Constructor<+Lorg/apache/cassandra/locator/AbstractReplicationStrategy;>;
            5    7     7                e  Ljava/lang/reflect/InvocationTargetException;
            6    7     8  targetException  Ljava/lang/Throwable;
            8    9     7                e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           1     3       4  Class java.lang.reflect.InvocationTargetException
           1     3       7  Class java.lang.Exception
    Exceptions:
      throws org.apache.cassandra.exceptions.ConfigurationException
    Signature: (Ljava/lang/String;Ljava/lang/Class<+Lorg/apache/cassandra/locator/AbstractReplicationStrategy;>;Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
    MethodParameters:
                 Name  Flags
      keyspaceName     
      strategyClass    
      tokenMetadata    
      snitch           
      strategyOptions  

  public static org.apache.cassandra.locator.AbstractReplicationStrategy createReplicationStrategy(java.lang.String, java.lang.Class<? extends org.apache.cassandra.locator.AbstractReplicationStrategy>, org.apache.cassandra.locator.TokenMetadata, org.apache.cassandra.locator.IEndpointSnitch, java.util.Map<java.lang.String, java.lang.String>);
    descriptor: (Ljava/lang/String;Ljava/lang/Class;Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/util/Map;)Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=7, args_size=5
        start local 0 // java.lang.String keyspaceName
        start local 1 // java.lang.Class strategyClass
        start local 2 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        start local 3 // org.apache.cassandra.locator.IEndpointSnitch snitch
        start local 4 // java.util.Map strategyOptions
         0: .line 265
            aload 0 /* keyspaceName */
            aload 1 /* strategyClass */
            aload 2 /* tokenMetadata */
            aload 3 /* snitch */
            aload 4 /* strategyOptions */
            invokestatic org.apache.cassandra.locator.AbstractReplicationStrategy.createInternal:(Ljava/lang/String;Ljava/lang/Class;Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/util/Map;)Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            astore 5 /* strategy */
        start local 5 // org.apache.cassandra.locator.AbstractReplicationStrategy strategy
         1: .line 270
            aload 5 /* strategy */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.validateExpectedOptions:()V
         2: .line 271
            goto 5
         3: .line 272
      StackMap locals: java.lang.String java.lang.Class org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.locator.IEndpointSnitch java.util.Map org.apache.cassandra.locator.AbstractReplicationStrategy
      StackMap stack: org.apache.cassandra.exceptions.ConfigurationException
            astore 6 /* e */
        start local 6 // org.apache.cassandra.exceptions.ConfigurationException e
         4: .line 274
            getstatic org.apache.cassandra.locator.AbstractReplicationStrategy.logger:Lorg/slf4j/Logger;
            ldc "Ignoring {}"
            aload 6 /* e */
            invokevirtual org.apache.cassandra.exceptions.ConfigurationException.getMessage:()Ljava/lang/String;
            invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;Ljava/lang/Object;)V
        end local 6 // org.apache.cassandra.exceptions.ConfigurationException e
         5: .line 277
      StackMap locals:
      StackMap stack:
            aload 5 /* strategy */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.validateOptions:()V
         6: .line 278
            aload 5 /* strategy */
            areturn
        end local 5 // org.apache.cassandra.locator.AbstractReplicationStrategy strategy
        end local 4 // java.util.Map strategyOptions
        end local 3 // org.apache.cassandra.locator.IEndpointSnitch snitch
        end local 2 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        end local 1 // java.lang.Class strategyClass
        end local 0 // java.lang.String keyspaceName
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    7     0     keyspaceName  Ljava/lang/String;
            0    7     1    strategyClass  Ljava/lang/Class<+Lorg/apache/cassandra/locator/AbstractReplicationStrategy;>;
            0    7     2    tokenMetadata  Lorg/apache/cassandra/locator/TokenMetadata;
            0    7     3           snitch  Lorg/apache/cassandra/locator/IEndpointSnitch;
            0    7     4  strategyOptions  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
            1    7     5         strategy  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            4    5     6                e  Lorg/apache/cassandra/exceptions/ConfigurationException;
      Exception table:
        from    to  target  type
           1     2       3  Class org.apache.cassandra.exceptions.ConfigurationException
    Signature: (Ljava/lang/String;Ljava/lang/Class<+Lorg/apache/cassandra/locator/AbstractReplicationStrategy;>;Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
    MethodParameters:
                 Name  Flags
      keyspaceName     
      strategyClass    
      tokenMetadata    
      snitch           
      strategyOptions  

  public static void validateReplicationStrategy(java.lang.String, java.lang.Class<? extends org.apache.cassandra.locator.AbstractReplicationStrategy>, org.apache.cassandra.locator.TokenMetadata, org.apache.cassandra.locator.IEndpointSnitch, java.util.Map<java.lang.String, java.lang.String>);
    descriptor: (Ljava/lang/String;Ljava/lang/Class;Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/util/Map;)V
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=6, args_size=5
        start local 0 // java.lang.String keyspaceName
        start local 1 // java.lang.Class strategyClass
        start local 2 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        start local 3 // org.apache.cassandra.locator.IEndpointSnitch snitch
        start local 4 // java.util.Map strategyOptions
         0: .line 287
            aload 0 /* keyspaceName */
            aload 1 /* strategyClass */
            aload 2 /* tokenMetadata */
            aload 3 /* snitch */
            aload 4 /* strategyOptions */
            invokestatic org.apache.cassandra.locator.AbstractReplicationStrategy.createInternal:(Ljava/lang/String;Ljava/lang/Class;Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/util/Map;)Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            astore 5 /* strategy */
        start local 5 // org.apache.cassandra.locator.AbstractReplicationStrategy strategy
         1: .line 288
            aload 5 /* strategy */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.validateExpectedOptions:()V
         2: .line 289
            aload 5 /* strategy */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.validateOptions:()V
         3: .line 290
            return
        end local 5 // org.apache.cassandra.locator.AbstractReplicationStrategy strategy
        end local 4 // java.util.Map strategyOptions
        end local 3 // org.apache.cassandra.locator.IEndpointSnitch snitch
        end local 2 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        end local 1 // java.lang.Class strategyClass
        end local 0 // java.lang.String keyspaceName
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    4     0     keyspaceName  Ljava/lang/String;
            0    4     1    strategyClass  Ljava/lang/Class<+Lorg/apache/cassandra/locator/AbstractReplicationStrategy;>;
            0    4     2    tokenMetadata  Lorg/apache/cassandra/locator/TokenMetadata;
            0    4     3           snitch  Lorg/apache/cassandra/locator/IEndpointSnitch;
            0    4     4  strategyOptions  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
            1    4     5         strategy  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
    Exceptions:
      throws org.apache.cassandra.exceptions.ConfigurationException
    Signature: (Ljava/lang/String;Ljava/lang/Class<+Lorg/apache/cassandra/locator/AbstractReplicationStrategy;>;Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)V
    MethodParameters:
                 Name  Flags
      keyspaceName     
      strategyClass    
      tokenMetadata    
      snitch           
      strategyOptions  

  public static java.lang.Class<org.apache.cassandra.locator.AbstractReplicationStrategy> getClass(java.lang.String);
    descriptor: (Ljava/lang/String;)Ljava/lang/Class;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=7, locals=3, args_size=1
        start local 0 // java.lang.String cls
         0: .line 294
            aload 0 /* cls */
            ldc "."
            invokevirtual java.lang.String.contains:(Ljava/lang/CharSequence;)Z
            ifeq 1
            aload 0 /* cls */
            goto 2
      StackMap locals:
      StackMap stack:
         1: new java.lang.StringBuilder
            dup
            ldc "org.apache.cassandra.locator."
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* cls */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
      StackMap locals:
      StackMap stack: java.lang.String
         2: astore 1 /* className */
        start local 1 // java.lang.String className
         3: .line 295
            aload 1 /* className */
            ldc "replication strategy"
            invokestatic org.apache.cassandra.utils.FBUtilities.classForName:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Class;
            astore 2 /* strategyClass */
        start local 2 // java.lang.Class strategyClass
         4: .line 296
            ldc Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            aload 2 /* strategyClass */
            invokevirtual java.lang.Class.isAssignableFrom:(Ljava/lang/Class;)Z
            ifne 6
         5: .line 298
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            ldc "Specified replication strategy class (%s) is not derived from AbstractReplicationStrategy"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 1 /* className */
            aastore
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
            athrow
         6: .line 300
      StackMap locals: java.lang.String java.lang.Class
      StackMap stack:
            aload 2 /* strategyClass */
            areturn
        end local 2 // java.lang.Class strategyClass
        end local 1 // java.lang.String className
        end local 0 // java.lang.String cls
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    7     0            cls  Ljava/lang/String;
            3    7     1      className  Ljava/lang/String;
            4    7     2  strategyClass  Ljava/lang/Class<Lorg/apache/cassandra/locator/AbstractReplicationStrategy;>;
    Exceptions:
      throws org.apache.cassandra.exceptions.ConfigurationException
    Signature: (Ljava/lang/String;)Ljava/lang/Class<Lorg/apache/cassandra/locator/AbstractReplicationStrategy;>;
    MethodParameters:
      Name  Flags
      cls   

  public boolean hasSameSettings(org.apache.cassandra.locator.AbstractReplicationStrategy);
    descriptor: (Lorg/apache/cassandra/locator/AbstractReplicationStrategy;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
        start local 1 // org.apache.cassandra.locator.AbstractReplicationStrategy other
         0: .line 305
            aload 0 /* this */
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            aload 1 /* other */
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 1
            aload 0 /* this */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.getReplicationFactor:()I
            aload 1 /* other */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.getReplicationFactor:()I
            if_icmpne 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 1 // org.apache.cassandra.locator.AbstractReplicationStrategy other
        end local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    2     0   this  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            0    2     1  other  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
    MethodParameters:
       Name  Flags
      other  

  protected void validateReplicationFactor(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
        start local 1 // java.lang.String rf
         0: .line 312
            aload 1 /* rf */
            invokestatic java.lang.Integer.parseInt:(Ljava/lang/String;)I
            ifge 4
         1: .line 314
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Replication factor must be non-negative; found "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* rf */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
            athrow
         2: .line 317
      StackMap locals:
      StackMap stack: java.lang.NumberFormatException
            pop
         3: .line 319
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Replication factor must be numeric; found "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* rf */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
            athrow
         4: .line 321
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.String rf
        end local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            0    5     1    rf  Ljava/lang/String;
      Exception table:
        from    to  target  type
           0     2       2  Class java.lang.NumberFormatException
    Exceptions:
      throws org.apache.cassandra.exceptions.ConfigurationException
    MethodParameters:
      Name  Flags
      rf    

  private void validateExpectedOptions();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=7, locals=4, args_size=1
        start local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
         0: .line 325
            aload 0 /* this */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.recognizedOptions:()Ljava/util/Collection;
            astore 1 /* expectedOptions */
        start local 1 // java.util.Collection expectedOptions
         1: .line 326
            aload 1 /* expectedOptions */
            ifnonnull 3
         2: .line 327
            return
         3: .line 329
      StackMap locals: java.util.Collection
      StackMap stack:
            aload 0 /* this */
            getfield org.apache.cassandra.locator.AbstractReplicationStrategy.configOptions:Ljava/util/Map;
            invokeinterface java.util.Map.keySet:()Ljava/util/Set;
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 3
            goto 7
      StackMap locals: org.apache.cassandra.locator.AbstractReplicationStrategy java.util.Collection top java.util.Iterator
      StackMap stack:
         4: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.lang.String
            astore 2 /* key */
        start local 2 // java.lang.String key
         5: .line 331
            aload 1 /* expectedOptions */
            aload 2 /* key */
            invokeinterface java.util.Collection.contains:(Ljava/lang/Object;)Z
            ifne 7
         6: .line 332
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            ldc "Unrecognized strategy option {%s} passed to %s for keyspace %s"
            iconst_3
            anewarray java.lang.Object
            dup
            iconst_0
            aload 2 /* key */
            aastore
            dup
            iconst_1
            aload 0 /* this */
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            invokevirtual java.lang.Class.getSimpleName:()Ljava/lang/String;
            aastore
            dup
            iconst_2
            aload 0 /* this */
            getfield org.apache.cassandra.locator.AbstractReplicationStrategy.keyspaceName:Ljava/lang/String;
            aastore
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
            athrow
        end local 2 // java.lang.String key
         7: .line 329
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 4
         8: .line 334
            return
        end local 1 // java.util.Collection expectedOptions
        end local 0 // org.apache.cassandra.locator.AbstractReplicationStrategy this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    9     0             this  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            1    9     1  expectedOptions  Ljava/util/Collection;
            5    7     2              key  Ljava/lang/String;
    Exceptions:
      throws org.apache.cassandra.exceptions.ConfigurationException
}
SourceFile: "AbstractReplicationStrategy.java"