org.apache.cassandra/cassandra-all/3.11.5 : org/apache/cassandra/dht/tokenallocator/TokenAllocation.class

TokenAllocation
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.
The Apache Software License, Version 2.0
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 class org.apache.cassandra.dht.tokenallocator.TokenAllocation
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.dht.tokenallocator.TokenAllocation
  super_class: java.lang.Object
{
  private static final org.slf4j.Logger logger;
    descriptor: Lorg/slf4j/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 49
            ldc Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation;
            invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
            putstatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.logger:Lorg/slf4j/Logger;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.dht.tokenallocator.TokenAllocation this
         0: .line 47
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // org.apache.cassandra.dht.tokenallocator.TokenAllocation this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation;

  public static java.util.Collection<org.apache.cassandra.dht.Token> allocateTokens(org.apache.cassandra.locator.TokenMetadata, org.apache.cassandra.locator.AbstractReplicationStrategy, java.net.InetAddress, int);
    descriptor: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/AbstractReplicationStrategy;Ljava/net/InetAddress;I)Ljava/util/Collection;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=9, args_size=4
        start local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        start local 1 // org.apache.cassandra.locator.AbstractReplicationStrategy rs
        start local 2 // java.net.InetAddress endpoint
        start local 3 // int numTokens
         0: .line 56
            aload 0 /* tokenMetadata */
            invokevirtual org.apache.cassandra.locator.TokenMetadata.cloneOnlyTokenMap:()Lorg/apache/cassandra/locator/TokenMetadata;
            astore 4 /* tokenMetadataCopy */
        start local 4 // org.apache.cassandra.locator.TokenMetadata tokenMetadataCopy
         1: .line 57
            aload 4 /* tokenMetadataCopy */
            aload 1 /* rs */
            aload 2 /* endpoint */
            invokestatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.getStrategy:(Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/AbstractReplicationStrategy;Ljava/net/InetAddress;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;
            astore 5 /* strategy */
        start local 5 // org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter strategy
         2: .line 58
            aload 0 /* tokenMetadata */
            aload 5 /* strategy */
            invokestatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.create:(Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocator;
            aload 2 /* endpoint */
            iload 3 /* numTokens */
            invokeinterface org.apache.cassandra.dht.tokenallocator.TokenAllocator.addUnit:(Ljava/lang/Object;I)Ljava/util/Collection;
            astore 6 /* tokens */
        start local 6 // java.util.Collection tokens
         3: .line 59
            aload 0 /* tokenMetadata */
            aload 5 /* strategy */
            aload 6 /* tokens */
            invokestatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.adjustForCrossDatacenterClashes:(Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;Ljava/util/Collection;)Ljava/util/Collection;
            astore 6 /* tokens */
         4: .line 61
            getstatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.logger:Lorg/slf4j/Logger;
            invokeinterface org.slf4j.Logger.isWarnEnabled:()Z
            ifeq 13
         5: .line 63
            getstatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.logger:Lorg/slf4j/Logger;
            ldc "Selected tokens {}"
            aload 6 /* tokens */
            invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;Ljava/lang/Object;)V
         6: .line 64
            aload 4 /* tokenMetadataCopy */
            aload 1 /* rs */
            aload 2 /* endpoint */
            invokestatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.replicatedOwnershipStats:(Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/AbstractReplicationStrategy;Ljava/net/InetAddress;)Lorg/apache/commons/math3/stat/descriptive/SummaryStatistics;
            astore 7 /* os */
        start local 7 // org.apache.commons.math3.stat.descriptive.SummaryStatistics os
         7: .line 65
            aload 4 /* tokenMetadataCopy */
            aload 6 /* tokens */
            aload 2 /* endpoint */
            invokevirtual org.apache.cassandra.locator.TokenMetadata.updateNormalTokens:(Ljava/util/Collection;Ljava/net/InetAddress;)V
         8: .line 66
            aload 4 /* tokenMetadataCopy */
            aload 1 /* rs */
            aload 2 /* endpoint */
            invokestatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.replicatedOwnershipStats:(Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/AbstractReplicationStrategy;Ljava/net/InetAddress;)Lorg/apache/commons/math3/stat/descriptive/SummaryStatistics;
            astore 8 /* ns */
        start local 8 // org.apache.commons.math3.stat.descriptive.SummaryStatistics ns
         9: .line 67
            getstatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.logger:Lorg/slf4j/Logger;
            ldc "Replicated node load in datacentre before allocation {}"
            aload 7 /* os */
            invokestatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.statToString:(Lorg/apache/commons/math3/stat/descriptive/SummaryStatistics;)Ljava/lang/String;
            invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;Ljava/lang/Object;)V
        10: .line 68
            getstatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.logger:Lorg/slf4j/Logger;
            ldc "Replicated node load in datacentre after allocation {}"
            aload 8 /* ns */
            invokestatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.statToString:(Lorg/apache/commons/math3/stat/descriptive/SummaryStatistics;)Ljava/lang/String;
            invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;Ljava/lang/Object;)V
        11: .line 71
            aload 8 /* ns */
            invokevirtual org.apache.commons.math3.stat.descriptive.SummaryStatistics.getStandardDeviation:()D
            aload 7 /* os */
            invokevirtual org.apache.commons.math3.stat.descriptive.SummaryStatistics.getStandardDeviation:()D
            dcmpl
            ifle 13
        12: .line 72
            getstatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.logger:Lorg/slf4j/Logger;
            ldc "Unexpected growth in standard deviation after allocation."
            invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;)V
        end local 8 // org.apache.commons.math3.stat.descriptive.SummaryStatistics ns
        end local 7 // org.apache.commons.math3.stat.descriptive.SummaryStatistics os
        13: .line 74
      StackMap locals: org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter java.util.Collection
      StackMap stack:
            aload 6 /* tokens */
            areturn
        end local 6 // java.util.Collection tokens
        end local 5 // org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter strategy
        end local 4 // org.apache.cassandra.locator.TokenMetadata tokenMetadataCopy
        end local 3 // int numTokens
        end local 2 // java.net.InetAddress endpoint
        end local 1 // org.apache.cassandra.locator.AbstractReplicationStrategy rs
        end local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   14     0      tokenMetadata  Lorg/apache/cassandra/locator/TokenMetadata;
            0   14     1                 rs  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            0   14     2           endpoint  Ljava/net/InetAddress;
            0   14     3          numTokens  I
            1   14     4  tokenMetadataCopy  Lorg/apache/cassandra/locator/TokenMetadata;
            2   14     5           strategy  Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;
            3   14     6             tokens  Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;
            7   13     7                 os  Lorg/apache/commons/math3/stat/descriptive/SummaryStatistics;
            9   13     8                 ns  Lorg/apache/commons/math3/stat/descriptive/SummaryStatistics;
    Signature: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/AbstractReplicationStrategy;Ljava/net/InetAddress;I)Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;
    MethodParameters:
               Name  Flags
      tokenMetadata  final
      rs             final
      endpoint       final
      numTokens      

  private static java.util.Collection<org.apache.cassandra.dht.Token> adjustForCrossDatacenterClashes(org.apache.cassandra.locator.TokenMetadata, org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter, java.util.Collection<org.apache.cassandra.dht.Token>);
    descriptor: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;Ljava/util/Collection;)Ljava/util/Collection;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=7, locals=7, args_size=3
        start local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        start local 1 // org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter strategy
        start local 2 // java.util.Collection tokens
         0: .line 80
            aload 2 /* tokens */
            invokeinterface java.util.Collection.size:()I
            invokestatic com.google.common.collect.Lists.newArrayListWithCapacity:(I)Ljava/util/ArrayList;
            astore 3 /* filtered */
        start local 3 // java.util.List filtered
         1: .line 82
            aload 2 /* tokens */
            invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
            astore 5
            goto 10
      StackMap locals: org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter java.util.Collection java.util.List top java.util.Iterator
      StackMap stack:
         2: aload 5
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.dht.Token
            astore 4 /* t */
        start local 4 // org.apache.cassandra.dht.Token t
         3: .line 84
            goto 8
         4: .line 86
      StackMap locals: org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter java.util.Collection java.util.List org.apache.cassandra.dht.Token java.util.Iterator
      StackMap stack:
            aload 0 /* tokenMetadata */
            aload 4 /* t */
            invokevirtual org.apache.cassandra.locator.TokenMetadata.getEndpoint:(Lorg/apache/cassandra/dht/Token;)Ljava/net/InetAddress;
            astore 6 /* other */
        start local 6 // java.net.InetAddress other
         5: .line 87
            aload 1 /* strategy */
            aload 6 /* other */
            invokeinterface org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter.inAllocationRing:(Ljava/net/InetAddress;)Z
            ifeq 7
         6: .line 88
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            ldc "Allocated token %s already assigned to node %s. Is another node also allocating tokens?"
            iconst_2
            anewarray java.lang.Object
            dup
            iconst_0
            aload 4 /* t */
            aastore
            dup
            iconst_1
            aload 6 /* other */
            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
         7: .line 89
      StackMap locals: java.net.InetAddress
      StackMap stack:
            aload 4 /* t */
            invokevirtual org.apache.cassandra.dht.Token.increaseSlightly:()Lorg/apache/cassandra/dht/Token;
            astore 4 /* t */
        end local 6 // java.net.InetAddress other
         8: .line 84
      StackMap locals:
      StackMap stack:
            aload 0 /* tokenMetadata */
            aload 4 /* t */
            invokevirtual org.apache.cassandra.locator.TokenMetadata.getEndpoint:(Lorg/apache/cassandra/dht/Token;)Ljava/net/InetAddress;
            ifnonnull 4
         9: .line 91
            aload 3 /* filtered */
            aload 4 /* t */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        end local 4 // org.apache.cassandra.dht.Token t
        10: .line 82
      StackMap locals: org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter java.util.Collection java.util.List top java.util.Iterator
      StackMap stack:
            aload 5
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
        11: .line 93
            aload 3 /* filtered */
            areturn
        end local 3 // java.util.List filtered
        end local 2 // java.util.Collection tokens
        end local 1 // org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter strategy
        end local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   12     0  tokenMetadata  Lorg/apache/cassandra/locator/TokenMetadata;
            0   12     1       strategy  Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;
            0   12     2         tokens  Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;
            1   12     3       filtered  Ljava/util/List<Lorg/apache/cassandra/dht/Token;>;
            3   10     4              t  Lorg/apache/cassandra/dht/Token;
            5    8     6          other  Ljava/net/InetAddress;
    Signature: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;)Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;
    MethodParameters:
               Name  Flags
      tokenMetadata  final
      strategy       
      tokens         

  public static java.util.Map<java.net.InetAddress, java.lang.Double> evaluateReplicatedOwnership(org.apache.cassandra.locator.TokenMetadata, org.apache.cassandra.locator.AbstractReplicationStrategy);
    descriptor: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/AbstractReplicationStrategy;)Ljava/util/Map;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=7, args_size=2
        start local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        start local 1 // org.apache.cassandra.locator.AbstractReplicationStrategy rs
         0: .line 99
            invokestatic com.google.common.collect.Maps.newHashMap:()Ljava/util/HashMap;
            astore 2 /* ownership */
        start local 2 // java.util.Map ownership
         1: .line 100
            aload 0 /* tokenMetadata */
            invokevirtual org.apache.cassandra.locator.TokenMetadata.sortedTokens:()Ljava/util/ArrayList;
            astore 3 /* sortedTokens */
        start local 3 // java.util.List sortedTokens
         2: .line 101
            aload 3 /* sortedTokens */
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 4 /* it */
        start local 4 // java.util.Iterator it
         3: .line 102
            aload 4 /* it */
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.dht.Token
            astore 5 /* current */
        start local 5 // org.apache.cassandra.dht.Token current
         4: .line 103
            goto 8
         5: .line 105
      StackMap locals: org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.locator.AbstractReplicationStrategy java.util.Map java.util.List java.util.Iterator org.apache.cassandra.dht.Token
      StackMap stack:
            aload 4 /* it */
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.dht.Token
            astore 6 /* next */
        start local 6 // org.apache.cassandra.dht.Token next
         6: .line 106
            aload 0 /* tokenMetadata */
            aload 1 /* rs */
            aload 5 /* current */
            aload 6 /* next */
            aload 2 /* ownership */
            invokestatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.addOwnership:(Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/AbstractReplicationStrategy;Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/dht/Token;Ljava/util/Map;)V
         7: .line 107
            aload 6 /* next */
            astore 5 /* current */
        end local 6 // org.apache.cassandra.dht.Token next
         8: .line 103
      StackMap locals:
      StackMap stack:
            aload 4 /* it */
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 5
         9: .line 109
            aload 0 /* tokenMetadata */
            aload 1 /* rs */
            aload 5 /* current */
            aload 3 /* sortedTokens */
            iconst_0
            invokeinterface java.util.List.get:(I)Ljava/lang/Object;
            checkcast org.apache.cassandra.dht.Token
            aload 2 /* ownership */
            invokestatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.addOwnership:(Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/AbstractReplicationStrategy;Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/dht/Token;Ljava/util/Map;)V
        10: .line 111
            aload 2 /* ownership */
            areturn
        end local 5 // org.apache.cassandra.dht.Token current
        end local 4 // java.util.Iterator it
        end local 3 // java.util.List sortedTokens
        end local 2 // java.util.Map ownership
        end local 1 // org.apache.cassandra.locator.AbstractReplicationStrategy rs
        end local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   11     0  tokenMetadata  Lorg/apache/cassandra/locator/TokenMetadata;
            0   11     1             rs  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            1   11     2      ownership  Ljava/util/Map<Ljava/net/InetAddress;Ljava/lang/Double;>;
            2   11     3   sortedTokens  Ljava/util/List<Lorg/apache/cassandra/dht/Token;>;
            3   11     4             it  Ljava/util/Iterator<Lorg/apache/cassandra/dht/Token;>;
            4   11     5        current  Lorg/apache/cassandra/dht/Token;
            6    8     6           next  Lorg/apache/cassandra/dht/Token;
    Signature: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/AbstractReplicationStrategy;)Ljava/util/Map<Ljava/net/InetAddress;Ljava/lang/Double;>;
    MethodParameters:
               Name  Flags
      tokenMetadata  
      rs             

  static void addOwnership(org.apache.cassandra.locator.TokenMetadata, org.apache.cassandra.locator.AbstractReplicationStrategy, org.apache.cassandra.dht.Token, org.apache.cassandra.dht.Token, java.util.Map<java.net.InetAddress, java.lang.Double>);
    descriptor: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/AbstractReplicationStrategy;Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/dht/Token;Ljava/util/Map;)V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=6, locals=11, args_size=5
        start local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        start local 1 // org.apache.cassandra.locator.AbstractReplicationStrategy rs
        start local 2 // org.apache.cassandra.dht.Token current
        start local 3 // org.apache.cassandra.dht.Token next
        start local 4 // java.util.Map ownership
         0: .line 116
            aload 2 /* current */
            aload 3 /* next */
            invokevirtual org.apache.cassandra.dht.Token.size:(Lorg/apache/cassandra/dht/Token;)D
            dstore 5 /* size */
        start local 5 // double size
         1: .line 117
            aload 2 /* current */
            invokevirtual org.apache.cassandra.dht.Token.getPartitioner:()Lorg/apache/cassandra/dht/IPartitioner;
            aload 2 /* current */
            aload 3 /* next */
            invokeinterface org.apache.cassandra.dht.IPartitioner.midpoint:(Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/dht/Token;)Lorg/apache/cassandra/dht/Token;
            astore 7 /* representative */
        start local 7 // org.apache.cassandra.dht.Token representative
         2: .line 118
            aload 1 /* rs */
            aload 7 /* representative */
            aload 0 /* tokenMetadata */
            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 9
            goto 8
      StackMap locals: org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.locator.AbstractReplicationStrategy org.apache.cassandra.dht.Token org.apache.cassandra.dht.Token java.util.Map double org.apache.cassandra.dht.Token top java.util.Iterator
      StackMap stack:
         3: aload 9
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.net.InetAddress
            astore 8 /* n */
        start local 8 // java.net.InetAddress n
         4: .line 120
            aload 4 /* ownership */
            aload 8 /* n */
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.lang.Double
            astore 10 /* v */
        start local 10 // java.lang.Double v
         5: .line 121
            aload 4 /* ownership */
            aload 8 /* n */
            aload 10 /* v */
            ifnull 6
            aload 10 /* v */
            invokevirtual java.lang.Double.doubleValue:()D
            dload 5 /* size */
            dadd
            goto 7
      StackMap locals: org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.locator.AbstractReplicationStrategy org.apache.cassandra.dht.Token org.apache.cassandra.dht.Token java.util.Map double org.apache.cassandra.dht.Token java.net.InetAddress java.util.Iterator java.lang.Double
      StackMap stack: java.util.Map java.net.InetAddress
         6: dload 5 /* size */
      StackMap locals: org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.locator.AbstractReplicationStrategy org.apache.cassandra.dht.Token org.apache.cassandra.dht.Token java.util.Map double org.apache.cassandra.dht.Token java.net.InetAddress java.util.Iterator java.lang.Double
      StackMap stack: java.util.Map java.net.InetAddress double
         7: invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        end local 10 // java.lang.Double v
        end local 8 // java.net.InetAddress n
         8: .line 118
      StackMap locals: org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.locator.AbstractReplicationStrategy org.apache.cassandra.dht.Token org.apache.cassandra.dht.Token java.util.Map double org.apache.cassandra.dht.Token top java.util.Iterator
      StackMap stack:
            aload 9
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 3
         9: .line 123
            return
        end local 7 // org.apache.cassandra.dht.Token representative
        end local 5 // double size
        end local 4 // java.util.Map ownership
        end local 3 // org.apache.cassandra.dht.Token next
        end local 2 // org.apache.cassandra.dht.Token current
        end local 1 // org.apache.cassandra.locator.AbstractReplicationStrategy rs
        end local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   10     0   tokenMetadata  Lorg/apache/cassandra/locator/TokenMetadata;
            0   10     1              rs  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            0   10     2         current  Lorg/apache/cassandra/dht/Token;
            0   10     3            next  Lorg/apache/cassandra/dht/Token;
            0   10     4       ownership  Ljava/util/Map<Ljava/net/InetAddress;Ljava/lang/Double;>;
            1   10     5            size  D
            2   10     7  representative  Lorg/apache/cassandra/dht/Token;
            4    8     8               n  Ljava/net/InetAddress;
            5    8    10               v  Ljava/lang/Double;
    Signature: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/AbstractReplicationStrategy;Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/dht/Token;Ljava/util/Map<Ljava/net/InetAddress;Ljava/lang/Double;>;)V
    MethodParameters:
               Name  Flags
      tokenMetadata  final
      rs             final
      current        
      next           
      ownership      

  public static java.lang.String statToString(org.apache.commons.math3.stat.descriptive.SummaryStatistics);
    descriptor: (Lorg/apache/commons/math3/stat/descriptive/SummaryStatistics;)Ljava/lang/String;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=8, locals=1, args_size=1
        start local 0 // org.apache.commons.math3.stat.descriptive.SummaryStatistics stat
         0: .line 127
            ldc "max %.2f min %.2f stddev %.4f"
            iconst_3
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* stat */
            invokevirtual org.apache.commons.math3.stat.descriptive.SummaryStatistics.getMax:()D
            aload 0 /* stat */
            invokevirtual org.apache.commons.math3.stat.descriptive.SummaryStatistics.getMean:()D
            ddiv
            invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
            aastore
            dup
            iconst_1
            aload 0 /* stat */
            invokevirtual org.apache.commons.math3.stat.descriptive.SummaryStatistics.getMin:()D
            aload 0 /* stat */
            invokevirtual org.apache.commons.math3.stat.descriptive.SummaryStatistics.getMean:()D
            ddiv
            invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
            aastore
            dup
            iconst_2
            aload 0 /* stat */
            invokevirtual org.apache.commons.math3.stat.descriptive.SummaryStatistics.getStandardDeviation:()D
            invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
            aastore
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            areturn
        end local 0 // org.apache.commons.math3.stat.descriptive.SummaryStatistics stat
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  stat  Lorg/apache/commons/math3/stat/descriptive/SummaryStatistics;
    MethodParameters:
      Name  Flags
      stat  

  public static org.apache.commons.math3.stat.descriptive.SummaryStatistics replicatedOwnershipStats(org.apache.cassandra.locator.TokenMetadata, org.apache.cassandra.locator.AbstractReplicationStrategy, java.net.InetAddress);
    descriptor: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/AbstractReplicationStrategy;Ljava/net/InetAddress;)Lorg/apache/commons/math3/stat/descriptive/SummaryStatistics;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=7, args_size=3
        start local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        start local 1 // org.apache.cassandra.locator.AbstractReplicationStrategy rs
        start local 2 // java.net.InetAddress endpoint
         0: .line 133
            new org.apache.commons.math3.stat.descriptive.SummaryStatistics
            dup
            invokespecial org.apache.commons.math3.stat.descriptive.SummaryStatistics.<init>:()V
            astore 3 /* stat */
        start local 3 // org.apache.commons.math3.stat.descriptive.SummaryStatistics stat
         1: .line 134
            aload 0 /* tokenMetadata */
            aload 1 /* rs */
            aload 2 /* endpoint */
            invokestatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.getStrategy:(Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/AbstractReplicationStrategy;Ljava/net/InetAddress;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;
            astore 4 /* strategy */
        start local 4 // org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter strategy
         2: .line 135
            aload 0 /* tokenMetadata */
            aload 1 /* rs */
            invokestatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.evaluateReplicatedOwnership:(Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/AbstractReplicationStrategy;)Ljava/util/Map;
            invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 6
            goto 6
      StackMap locals: org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.locator.AbstractReplicationStrategy java.net.InetAddress org.apache.commons.math3.stat.descriptive.SummaryStatistics org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter top java.util.Iterator
      StackMap stack:
         3: aload 6
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.util.Map$Entry
            astore 5 /* en */
        start local 5 // java.util.Map$Entry en
         4: .line 138
            aload 4 /* strategy */
            aload 5 /* en */
            invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
            checkcast java.net.InetAddress
            invokeinterface org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter.inAllocationRing:(Ljava/net/InetAddress;)Z
            ifeq 6
         5: .line 139
            aload 3 /* stat */
            aload 5 /* en */
            invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
            checkcast java.lang.Double
            invokevirtual java.lang.Double.doubleValue:()D
            aload 0 /* tokenMetadata */
            aload 5 /* en */
            invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
            checkcast java.net.InetAddress
            invokevirtual org.apache.cassandra.locator.TokenMetadata.getTokens:(Ljava/net/InetAddress;)Ljava/util/Collection;
            invokeinterface java.util.Collection.size:()I
            i2d
            ddiv
            invokevirtual org.apache.commons.math3.stat.descriptive.SummaryStatistics.addValue:(D)V
        end local 5 // java.util.Map$Entry en
         6: .line 135
      StackMap locals:
      StackMap stack:
            aload 6
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 3
         7: .line 141
            aload 3 /* stat */
            areturn
        end local 4 // org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter strategy
        end local 3 // org.apache.commons.math3.stat.descriptive.SummaryStatistics stat
        end local 2 // java.net.InetAddress endpoint
        end local 1 // org.apache.cassandra.locator.AbstractReplicationStrategy rs
        end local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    8     0  tokenMetadata  Lorg/apache/cassandra/locator/TokenMetadata;
            0    8     1             rs  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            0    8     2       endpoint  Ljava/net/InetAddress;
            1    8     3           stat  Lorg/apache/commons/math3/stat/descriptive/SummaryStatistics;
            2    8     4       strategy  Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;
            4    6     5             en  Ljava/util/Map$Entry<Ljava/net/InetAddress;Ljava/lang/Double;>;
    MethodParameters:
               Name  Flags
      tokenMetadata  
      rs             
      endpoint       

  static org.apache.cassandra.dht.tokenallocator.TokenAllocator<java.net.InetAddress> create(org.apache.cassandra.locator.TokenMetadata, org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter);
    descriptor: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocator;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=3, locals=5, args_size=2
        start local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        start local 1 // org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter strategy
         0: .line 146
            new java.util.TreeMap
            dup
            invokespecial java.util.TreeMap.<init>:()V
            astore 2 /* sortedTokens */
        start local 2 // java.util.NavigableMap sortedTokens
         1: .line 147
            aload 0 /* tokenMetadata */
            invokevirtual org.apache.cassandra.locator.TokenMetadata.getNormalAndBootstrappingTokenToEndpointMap:()Ljava/util/Map;
            invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 4
            goto 5
      StackMap locals: org.apache.cassandra.locator.TokenMetadata org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter java.util.NavigableMap top java.util.Iterator
      StackMap stack:
         2: aload 4
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.util.Map$Entry
            astore 3 /* en */
        start local 3 // java.util.Map$Entry en
         3: .line 149
            aload 1 /* strategy */
            aload 3 /* en */
            invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
            checkcast java.net.InetAddress
            invokeinterface org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter.inAllocationRing:(Ljava/net/InetAddress;)Z
            ifeq 5
         4: .line 150
            aload 2 /* sortedTokens */
            aload 3 /* en */
            invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
            checkcast org.apache.cassandra.dht.Token
            aload 3 /* en */
            invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
            checkcast java.net.InetAddress
            invokeinterface java.util.NavigableMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        end local 3 // java.util.Map$Entry en
         5: .line 147
      StackMap locals:
      StackMap stack:
            aload 4
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         6: .line 152
            aload 2 /* sortedTokens */
            aload 1 /* strategy */
            aload 0 /* tokenMetadata */
            getfield org.apache.cassandra.locator.TokenMetadata.partitioner:Lorg/apache/cassandra/dht/IPartitioner;
            invokestatic org.apache.cassandra.dht.tokenallocator.TokenAllocatorFactory.createTokenAllocator:(Ljava/util/NavigableMap;Lorg/apache/cassandra/dht/tokenallocator/ReplicationStrategy;Lorg/apache/cassandra/dht/IPartitioner;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocator;
            areturn
        end local 2 // java.util.NavigableMap sortedTokens
        end local 1 // org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter strategy
        end local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    7     0  tokenMetadata  Lorg/apache/cassandra/locator/TokenMetadata;
            0    7     1       strategy  Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;
            1    7     2   sortedTokens  Ljava/util/NavigableMap<Lorg/apache/cassandra/dht/Token;Ljava/net/InetAddress;>;
            3    5     3             en  Ljava/util/Map$Entry<Lorg/apache/cassandra/dht/Token;Ljava/net/InetAddress;>;
    Signature: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocator<Ljava/net/InetAddress;>;
    MethodParameters:
               Name  Flags
      tokenMetadata  
      strategy       

  static org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter getStrategy(org.apache.cassandra.locator.TokenMetadata, org.apache.cassandra.locator.AbstractReplicationStrategy, java.net.InetAddress);
    descriptor: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/AbstractReplicationStrategy;Ljava/net/InetAddress;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        start local 1 // org.apache.cassandra.locator.AbstractReplicationStrategy rs
        start local 2 // java.net.InetAddress endpoint
         0: .line 165
            aload 1 /* rs */
            instanceof org.apache.cassandra.locator.NetworkTopologyStrategy
            ifeq 2
         1: .line 166
            aload 0 /* tokenMetadata */
            aload 1 /* rs */
            checkcast org.apache.cassandra.locator.NetworkTopologyStrategy
            aload 1 /* rs */
            getfield org.apache.cassandra.locator.AbstractReplicationStrategy.snitch:Lorg/apache/cassandra/locator/IEndpointSnitch;
            aload 2 /* endpoint */
            invokestatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.getStrategy:(Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/NetworkTopologyStrategy;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/net/InetAddress;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;
            areturn
         2: .line 167
      StackMap locals:
      StackMap stack:
            aload 1 /* rs */
            instanceof org.apache.cassandra.locator.SimpleStrategy
            ifeq 4
         3: .line 168
            aload 0 /* tokenMetadata */
            aload 1 /* rs */
            checkcast org.apache.cassandra.locator.SimpleStrategy
            aload 2 /* endpoint */
            invokestatic org.apache.cassandra.dht.tokenallocator.TokenAllocation.getStrategy:(Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/SimpleStrategy;Ljava/net/InetAddress;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;
            areturn
         4: .line 169
      StackMap locals:
      StackMap stack:
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
            new java.lang.StringBuilder
            dup
            ldc "Token allocation does not support replication strategy "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 1 /* rs */
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            invokevirtual java.lang.Class.getSimpleName:()Ljava/lang/String;
            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
        end local 2 // java.net.InetAddress endpoint
        end local 1 // org.apache.cassandra.locator.AbstractReplicationStrategy rs
        end local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    5     0  tokenMetadata  Lorg/apache/cassandra/locator/TokenMetadata;
            0    5     1             rs  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            0    5     2       endpoint  Ljava/net/InetAddress;
    MethodParameters:
               Name  Flags
      tokenMetadata  final
      rs             final
      endpoint       final

  static org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter getStrategy(org.apache.cassandra.locator.TokenMetadata, org.apache.cassandra.locator.SimpleStrategy, java.net.InetAddress);
    descriptor: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/SimpleStrategy;Ljava/net/InetAddress;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        start local 1 // org.apache.cassandra.locator.SimpleStrategy rs
        start local 2 // java.net.InetAddress endpoint
         0: .line 174
            aload 1 /* rs */
            invokevirtual org.apache.cassandra.locator.SimpleStrategy.getReplicationFactor:()I
            istore 3 /* replicas */
        start local 3 // int replicas
         1: .line 176
            new org.apache.cassandra.dht.tokenallocator.TokenAllocation$1
            dup
            iload 3 /* replicas */
            invokespecial org.apache.cassandra.dht.tokenallocator.TokenAllocation$1.<init>:(I)V
            areturn
        end local 3 // int replicas
        end local 2 // java.net.InetAddress endpoint
        end local 1 // org.apache.cassandra.locator.SimpleStrategy rs
        end local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    2     0  tokenMetadata  Lorg/apache/cassandra/locator/TokenMetadata;
            0    2     1             rs  Lorg/apache/cassandra/locator/SimpleStrategy;
            0    2     2       endpoint  Ljava/net/InetAddress;
            1    2     3       replicas  I
    MethodParameters:
               Name  Flags
      tokenMetadata  final
      rs             final
      endpoint       final

  static org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter getStrategy(org.apache.cassandra.locator.TokenMetadata, org.apache.cassandra.locator.NetworkTopologyStrategy, org.apache.cassandra.locator.IEndpointSnitch, java.net.InetAddress);
    descriptor: (Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/NetworkTopologyStrategy;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/net/InetAddress;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocation$StrategyAdapter;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=7, locals=8, args_size=4
        start local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
        start local 1 // org.apache.cassandra.locator.NetworkTopologyStrategy rs
        start local 2 // org.apache.cassandra.locator.IEndpointSnitch snitch
        start local 3 // java.net.InetAddress endpoint
         0: .line 200
            aload 2 /* snitch */
            aload 3 /* endpoint */
            invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getDatacenter:(Ljava/net/InetAddress;)Ljava/lang/String;
            astore 4 /* dc */
        start local 4 // java.lang.String dc
         1: .line 201
            aload 1 /* rs */
            aload 4 /* dc */
            invokevirtual org.apache.cassandra.locator.NetworkTopologyStrategy.getReplicationFactor:(Ljava/lang/String;)I
            istore 5 /* replicas */
        start local 5 // int replicas
         2: .line 203
            iload 5 /* replicas */
            ifeq 3
            iload 5 /* replicas */
            iconst_1
            if_icmpne 4
         3: .line 206
      StackMap locals: java.lang.String int
      StackMap stack:
            new org.apache.cassandra.dht.tokenallocator.TokenAllocation$2
            dup
            aload 4 /* dc */
            aload 2 /* snitch */
            invokespecial org.apache.cassandra.dht.tokenallocator.TokenAllocation$2.<init>:(Ljava/lang/String;Lorg/apache/cassandra/locator/IEndpointSnitch;)V
            areturn
         4: .line 228
      StackMap locals:
      StackMap stack:
            aload 0 /* tokenMetadata */
            invokevirtual org.apache.cassandra.locator.TokenMetadata.getTopology:()Lorg/apache/cassandra/locator/TokenMetadata$Topology;
            astore 6 /* topology */
        start local 6 // org.apache.cassandra.locator.TokenMetadata$Topology topology
         5: .line 231
            aload 6 /* topology */
            invokevirtual org.apache.cassandra.locator.TokenMetadata$Topology.getDatacenterRacks:()Lcom/google/common/collect/ImmutableMap;
            aload 4 /* dc */
            invokevirtual com.google.common.collect.ImmutableMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            ifnull 7
            aload 6 /* topology */
            invokevirtual org.apache.cassandra.locator.TokenMetadata$Topology.getDatacenterRacks:()Lcom/google/common/collect/ImmutableMap;
            aload 4 /* dc */
            invokevirtual com.google.common.collect.ImmutableMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast com.google.common.collect.ImmutableMultimap
            aload 2 /* snitch */
            aload 3 /* endpoint */
            invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getRack:(Ljava/net/InetAddress;)Ljava/lang/String;
            invokevirtual com.google.common.collect.ImmutableMultimap.containsKey:(Ljava/lang/Object;)Z
            ifeq 7
         6: .line 232
            aload 6 /* topology */
            invokevirtual org.apache.cassandra.locator.TokenMetadata$Topology.getDatacenterRacks:()Lcom/google/common/collect/ImmutableMap;
            aload 4 /* dc */
            invokevirtual com.google.common.collect.ImmutableMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast com.google.common.collect.ImmutableMultimap
            invokevirtual com.google.common.collect.ImmutableMultimap.asMap:()Lcom/google/common/collect/ImmutableMap;
            invokevirtual com.google.common.collect.ImmutableMap.size:()I
            goto 8
         7: .line 233
      StackMap locals: org.apache.cassandra.locator.TokenMetadata$Topology
      StackMap stack:
            iconst_1
         8: .line 231
      StackMap locals:
      StackMap stack: int
            istore 7 /* racks */
        start local 7 // int racks
         9: .line 235
            iload 7 /* racks */
            iload 5 /* replicas */
            if_icmplt 11
        10: .line 237
            new org.apache.cassandra.dht.tokenallocator.TokenAllocation$3
            dup
            iload 5 /* replicas */
            aload 2 /* snitch */
            aload 4 /* dc */
            invokespecial org.apache.cassandra.dht.tokenallocator.TokenAllocation$3.<init>:(ILorg/apache/cassandra/locator/IEndpointSnitch;Ljava/lang/String;)V
            areturn
        11: .line 258
      StackMap locals: int
      StackMap stack:
            iload 7 /* racks */
            iconst_1
            if_icmpne 13
        12: .line 261
            new org.apache.cassandra.dht.tokenallocator.TokenAllocation$4
            dup
            iload 5 /* replicas */
            aload 4 /* dc */
            aload 2 /* snitch */
            invokespecial org.apache.cassandra.dht.tokenallocator.TokenAllocation$4.<init>:(ILjava/lang/String;Lorg/apache/cassandra/locator/IEndpointSnitch;)V
            areturn
        13: .line 283
      StackMap locals:
      StackMap stack:
            new org.apache.cassandra.exceptions.ConfigurationException
            dup
        14: .line 284
            ldc "Token allocation failed: the number of racks %d in datacenter %s is lower than its replication factor %d."
            iconst_3
            anewarray java.lang.Object
            dup
            iconst_0
        15: .line 285
            iload 7 /* racks */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_1
            aload 4 /* dc */
            aastore
            dup
            iconst_2
            iload 5 /* replicas */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
        16: .line 284
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
        17: .line 283
            invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
            athrow
        end local 7 // int racks
        end local 6 // org.apache.cassandra.locator.TokenMetadata$Topology topology
        end local 5 // int replicas
        end local 4 // java.lang.String dc
        end local 3 // java.net.InetAddress endpoint
        end local 2 // org.apache.cassandra.locator.IEndpointSnitch snitch
        end local 1 // org.apache.cassandra.locator.NetworkTopologyStrategy rs
        end local 0 // org.apache.cassandra.locator.TokenMetadata tokenMetadata
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   18     0  tokenMetadata  Lorg/apache/cassandra/locator/TokenMetadata;
            0   18     1             rs  Lorg/apache/cassandra/locator/NetworkTopologyStrategy;
            0   18     2         snitch  Lorg/apache/cassandra/locator/IEndpointSnitch;
            0   18     3       endpoint  Ljava/net/InetAddress;
            1   18     4             dc  Ljava/lang/String;
            2   18     5       replicas  I
            5   18     6       topology  Lorg/apache/cassandra/locator/TokenMetadata$Topology;
            9   18     7          racks  I
    MethodParameters:
               Name  Flags
      tokenMetadata  final
      rs             final
      snitch         final
      endpoint       final
}
SourceFile: "TokenAllocation.java"
NestMembers:
  org.apache.cassandra.dht.tokenallocator.TokenAllocation$1  org.apache.cassandra.dht.tokenallocator.TokenAllocation$2  org.apache.cassandra.dht.tokenallocator.TokenAllocation$3  org.apache.cassandra.dht.tokenallocator.TokenAllocation$4  org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter
InnerClasses:
  public abstract Entry = java.util.Map$Entry of java.util.Map
  org.apache.cassandra.dht.tokenallocator.TokenAllocation$1
  org.apache.cassandra.dht.tokenallocator.TokenAllocation$2
  org.apache.cassandra.dht.tokenallocator.TokenAllocation$3
  org.apache.cassandra.dht.tokenallocator.TokenAllocation$4
  abstract StrategyAdapter = org.apache.cassandra.dht.tokenallocator.TokenAllocation$StrategyAdapter of org.apache.cassandra.dht.tokenallocator.TokenAllocation
  public Topology = org.apache.cassandra.locator.TokenMetadata$Topology of org.apache.cassandra.locator.TokenMetadata
/

org.apache.cassandra/ cassandra-all/ 3.11.5/ org/apache/cassandra/dht/tokenallocator/TokenAllocation.class
