public class org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator<Unit> extends org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase<Unit>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator
super_class: org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase
{
java.util.PriorityQueue<org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted<org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo>> sortedUnits;
descriptor: Ljava/util/PriorityQueue;
flags: (0x0000)
Signature: Ljava/util/PriorityQueue<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$Weighted<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo;>;>;
java.util.Map<Unit, java.util.PriorityQueue<org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted<org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo>>> tokensInUnits;
descriptor: Ljava/util/Map;
flags: (0x0000)
Signature: Ljava/util/Map<TUnit;Ljava/util/PriorityQueue<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$Weighted<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;>;>;>;
private static final double MAX_TAKEOVER_RATIO;
descriptor: D
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 0.9
private static final double MIN_TAKEOVER_RATIO;
descriptor: D
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 0.09999999999999998
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: ldc Lorg/apache/cassandra/dht/tokenallocator/NoReplicationTokenAllocator;
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.dht.tokenallocator.NoReplicationTokenAllocator.$assertionsDisabled:Z
3: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(java.util.NavigableMap<org.apache.cassandra.dht.Token, Unit>, org.apache.cassandra.dht.tokenallocator.ReplicationStrategy<Unit>, org.apache.cassandra.dht.IPartitioner);
descriptor: (Ljava/util/NavigableMap;Lorg/apache/cassandra/dht/tokenallocator/ReplicationStrategy;Lorg/apache/cassandra/dht/IPartitioner;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 1
aload 2
aload 3
invokespecial org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase.<init>:(Ljava/util/NavigableMap;Lorg/apache/cassandra/dht/tokenallocator/ReplicationStrategy;Lorg/apache/cassandra/dht/IPartitioner;)V
1: aload 0
invokestatic com.google.common.collect.Queues.newPriorityQueue:()Ljava/util/PriorityQueue;
putfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.sortedUnits:Ljava/util/PriorityQueue;
2: aload 0
invokestatic com.google.common.collect.Maps.newHashMap:()Ljava/util/HashMap;
putfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.tokensInUnits:Ljava/util/Map;
3: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/dht/tokenallocator/NoReplicationTokenAllocator<TUnit;>;
0 4 1 sortedTokens Ljava/util/NavigableMap<Lorg/apache/cassandra/dht/Token;TUnit;>;
0 4 2 strategy Lorg/apache/cassandra/dht/tokenallocator/ReplicationStrategy<TUnit;>;
0 4 3 partitioner Lorg/apache/cassandra/dht/IPartitioner;
Signature: (Ljava/util/NavigableMap<Lorg/apache/cassandra/dht/Token;TUnit;>;Lorg/apache/cassandra/dht/tokenallocator/ReplicationStrategy<TUnit;>;Lorg/apache/cassandra/dht/IPartitioner;)V
MethodParameters:
Name Flags
sortedTokens
strategy
partitioner
private org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo<Unit> createTokenInfos(java.util.Map<Unit, org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo<Unit>>);
descriptor: (Ljava/util/Map;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=9, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface java.util.Map.isEmpty:()Z
ifeq 2
1: aconst_null
areturn
2: StackMap locals:
StackMap stack:
aconst_null
astore 2
start local 2 3: aconst_null
astore 3
start local 3 4: aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.sortedTokens:Ljava/util/NavigableMap;
invokeinterface java.util.NavigableMap.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 11
StackMap locals: org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo top java.util.Iterator
StackMap stack:
5: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 4
start local 4 6: aload 4
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.Token
astore 6
start local 6 7: aload 1
aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo
astore 7
start local 7 8: new org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo
dup
aload 6
aload 7
invokespecial org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.<init>:(Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo;)V
astore 8
start local 8 9: aload 8
aload 3
aload 2
invokevirtual org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.insertAfter:(Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$CircularList;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$CircularList;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$CircularList;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo
astore 3
10: aload 8
astore 2
end local 8 end local 7 end local 6 end local 4 11: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
12: aload 3
astore 4
start local 4 13: aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.tokensInUnits:Ljava/util/Map;
invokeinterface java.util.Map.clear:()V
14: aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.sortedUnits:Ljava/util/PriorityQueue;
invokevirtual java.util.PriorityQueue.clear:()V
15: StackMap locals: org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo
StackMap stack:
aload 0
aload 4
invokevirtual org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.populateTokenInfoAndAdjustUnit:(Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;)V
16: aload 4
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.next:Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$CircularList;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo
astore 4
17: aload 4
aload 3
if_acmpne 15
18: aload 1
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 6
goto 21
StackMap locals: org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo top java.util.Iterator
StackMap stack:
19: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo
astore 5
start local 5 20: aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.sortedUnits:Ljava/util/PriorityQueue;
new org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted
dup
aload 5
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo.ownership:D
aload 5
invokespecial org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.<init>:(DLjava/lang/Object;)V
invokevirtual java.util.PriorityQueue.add:(Ljava/lang/Object;)Z
pop
end local 5 21: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 19
22: aload 3
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 23 0 this Lorg/apache/cassandra/dht/tokenallocator/NoReplicationTokenAllocator<TUnit;>;
0 23 1 units Ljava/util/Map<TUnit;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo<TUnit;>;>;
3 23 2 prev Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo<TUnit;>;
4 23 3 first Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo<TUnit;>;
6 11 4 en Ljava/util/Map$Entry<Lorg/apache/cassandra/dht/Token;TUnit;>;
7 11 6 t Lorg/apache/cassandra/dht/Token;
8 11 7 ni Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo<TUnit;>;
9 11 8 ti Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo<TUnit;>;
13 23 4 curr Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo<TUnit;>;
20 21 5 unitInfo Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo<TUnit;>;
Signature: (Ljava/util/Map<TUnit;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo<TUnit;>;>;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo<TUnit;>;
MethodParameters:
Name Flags
units
protected void createTokenInfos();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
aload 0
invokestatic com.google.common.collect.Maps.newHashMap:()Ljava/util/HashMap;
invokevirtual org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.createUnitInfos:(Ljava/util/Map;)Ljava/util/Map;
invokevirtual org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.createTokenInfos:(Ljava/util/Map;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/dht/tokenallocator/NoReplicationTokenAllocator<TUnit;>;
private void populateTokenInfoAndAdjustUnit(org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo<Unit>);
descriptor: (Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=6, locals=3, args_size=2
start local 0 start local 1 0: aload 1
aload 1
invokevirtual org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.prevInRing:()Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.token:Lorg/apache/cassandra/dht/Token;
putfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.replicationStart:Lorg/apache/cassandra/dht/Token;
1: aload 1
aload 1
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.token:Lorg/apache/cassandra/dht/Token;
putfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.replicationThreshold:Lorg/apache/cassandra/dht/Token;
2: aload 1
aload 1
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.replicationStart:Lorg/apache/cassandra/dht/Token;
aload 1
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.token:Lorg/apache/cassandra/dht/Token;
invokevirtual org.apache.cassandra.dht.Token.size:(Lorg/apache/cassandra/dht/Token;)D
putfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.replicatedOwnership:D
3: aload 1
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.owningUnit:Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo;
dup
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo.ownership:D
aload 1
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.replicatedOwnership:D
dadd
putfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo.ownership:D
4: aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.tokensInUnits:Ljava/util/Map;
aload 1
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.owningUnit:Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo;
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo.unit:Ljava/lang/Object;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.util.PriorityQueue
astore 2
start local 2 5: aload 2
ifnonnull 8
6: invokestatic com.google.common.collect.Queues.newPriorityQueue:()Ljava/util/PriorityQueue;
astore 2
7: aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.tokensInUnits:Ljava/util/Map;
aload 1
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.owningUnit:Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo;
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo.unit:Ljava/lang/Object;
aload 2
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
8: StackMap locals: java.util.PriorityQueue
StackMap stack:
aload 2
new org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted
dup
aload 1
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.replicatedOwnership:D
aload 1
invokespecial org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.<init>:(DLjava/lang/Object;)V
invokevirtual java.util.PriorityQueue.add:(Ljava/lang/Object;)Z
pop
9: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/dht/tokenallocator/NoReplicationTokenAllocator<TUnit;>;
0 10 1 token Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo<TUnit;>;
5 10 2 unitTokens Ljava/util/PriorityQueue<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$Weighted<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;>;>;
Signature: (Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo<TUnit;>;)V
MethodParameters:
Name Flags
token
private java.util.Collection<org.apache.cassandra.dht.Token> generateRandomTokens(org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo<Unit>, int, java.util.Map<Unit, org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo<Unit>>);
descriptor: (Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo;ILjava/util/Map;)Ljava/util/Collection;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new java.util.HashSet
dup
iload 2
invokespecial java.util.HashSet.<init>:(I)V
astore 4
start local 4 1: goto 6
2: StackMap locals: java.util.Set
StackMap stack:
aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.partitioner:Lorg/apache/cassandra/dht/IPartitioner;
invokeinterface org.apache.cassandra.dht.IPartitioner.getRandomToken:()Lorg/apache/cassandra/dht/Token;
astore 5
start local 5 3: aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.sortedTokens:Ljava/util/NavigableMap;
aload 5
invokeinterface java.util.NavigableMap.containsKey:(Ljava/lang/Object;)Z
ifne 6
4: aload 4
aload 5
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
5: aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.sortedTokens:Ljava/util/NavigableMap;
aload 5
aload 1
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo.unit:Ljava/lang/Object;
invokeinterface java.util.NavigableMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 5 6: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Set.size:()I
iload 2
if_icmplt 2
7: aload 3
aload 1
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo.unit:Ljava/lang/Object;
aload 1
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
8: aload 0
aload 3
invokevirtual org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.createTokenInfos:(Ljava/util/Map;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;
pop
9: aload 4
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/dht/tokenallocator/NoReplicationTokenAllocator<TUnit;>;
0 10 1 newUnit Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo<TUnit;>;
0 10 2 numTokens I
0 10 3 unitInfos Ljava/util/Map<TUnit;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo<TUnit;>;>;
1 10 4 tokens Ljava/util/Set<Lorg/apache/cassandra/dht/Token;>;
3 6 5 token Lorg/apache/cassandra/dht/Token;
Signature: (Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo<TUnit;>;ILjava/util/Map<TUnit;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo<TUnit;>;>;)Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;
MethodParameters:
Name Flags
newUnit
numTokens
unitInfos
public java.util.Collection<org.apache.cassandra.dht.Token> addUnit(Unit, int);
descriptor: (Ljava/lang/Object;I)Ljava/util/Collection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=29, args_size=3
start local 0 start local 1 start local 2 0: getstatic org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.$assertionsDisabled:Z
ifne 1
aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.tokensInUnits:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifeq 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
invokestatic com.google.common.collect.Maps.newHashMap:()Ljava/util/HashMap;
astore 3
start local 3 2: new org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo
dup
aload 1
dconst_0
aload 3
aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.strategy:Lorg/apache/cassandra/dht/tokenallocator/ReplicationStrategy;
invokespecial org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo.<init>:(Ljava/lang/Object;DLjava/util/Map;Lorg/apache/cassandra/dht/tokenallocator/ReplicationStrategy;)V
astore 4
start local 4 3: aload 0
aload 3
invokevirtual org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.createUnitInfos:(Ljava/util/Map;)Ljava/util/Map;
astore 5
start local 5 4: aload 5
invokeinterface java.util.Map.isEmpty:()Z
ifeq 6
5: aload 0
aload 4
iload 2
aload 5
invokevirtual org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.generateRandomTokens:(Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo;ILjava/util/Map;)Ljava/util/Collection;
areturn
6: StackMap locals: java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo java.util.Map
StackMap stack:
iload 2
aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.sortedTokens:Ljava/util/NavigableMap;
invokeinterface java.util.NavigableMap.size:()I
if_icmple 8
7: aload 0
aload 4
iload 2
aload 5
invokevirtual org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.generateRandomTokens:(Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo;ILjava/util/Map;)Ljava/util/Collection;
areturn
8: StackMap locals:
StackMap stack:
aload 0
aload 5
invokevirtual org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.createTokenInfos:(Ljava/util/Map;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;
astore 6
start local 6 9: dconst_0
dstore 7
start local 7 10: dconst_0
dstore 9
start local 9 11: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 11
start local 11 12: iconst_0
istore 12
start local 12 13: goto 25
14: StackMap locals: org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator java.lang.Object int java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo double double java.util.List int
StackMap stack:
aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.sortedUnits:Ljava/util/PriorityQueue;
invokevirtual java.util.PriorityQueue.peek:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted
astore 13
start local 13 15: aload 13
ifnonnull 17
16: goto 26
17: StackMap locals: org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted
StackMap stack:
dload 9
aload 13
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.weight:D
dadd
dstore 9
18: dload 9
aload 11
invokeinterface java.util.List.size:()I
iconst_2
iadd
i2d
ddiv
dstore 14
start local 14 19: aload 13
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.weight:D
dload 14
dcmpg
ifgt 21
20: goto 26
21: StackMap locals: double
StackMap stack:
aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.sortedUnits:Ljava/util/PriorityQueue;
invokevirtual java.util.PriorityQueue.remove:()Ljava/lang/Object;
pop
22: aload 11
aload 13
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
23: dload 14
dstore 7
end local 14 end local 13 24: iinc 12 1
StackMap locals:
StackMap stack:
25: iload 12
iload 2
if_icmplt 14
end local 12 26: StackMap locals:
StackMap stack:
iload 2
invokestatic com.google.common.collect.Lists.newArrayListWithCapacity:(I)Ljava/util/ArrayList;
astore 12
start local 12 27: iconst_0
istore 13
start local 13 28: aload 11
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 15
goto 65
StackMap locals: org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator java.lang.Object int java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo double double java.util.List java.util.List int top java.util.Iterator
StackMap stack:
29: aload 15
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted
astore 14
start local 14 30: iload 2
aload 11
invokeinterface java.util.List.size:()I
idiv
iload 13
iload 2
aload 11
invokeinterface java.util.List.size:()I
irem
if_icmpge 31
iconst_1
goto 32
StackMap locals: org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator java.lang.Object int java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo double double java.util.List java.util.List int org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted java.util.Iterator
StackMap stack: int
31: iconst_0
StackMap locals: org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator java.lang.Object int java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo double double java.util.List java.util.List int org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted java.util.Iterator
StackMap stack: int int
32: iadd
istore 16
start local 16 33: aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.tokensInUnits:Ljava/util/Map;
aload 14
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.value:Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo.unit:Ljava/lang/Object;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.util.Queue
astore 17
start local 17 34: iload 16
invokestatic com.google.common.collect.Lists.newArrayListWithCapacity:(I)Ljava/util/ArrayList;
astore 18
start local 18 35: dconst_0
dstore 19
start local 19 36: iconst_0
istore 21
start local 21 37: goto 43
38: StackMap locals: org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator java.lang.Object int java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo double double java.util.List java.util.List int org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted java.util.Iterator int java.util.Queue java.util.List double int
StackMap stack:
aload 17
invokeinterface java.util.Queue.remove:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted
astore 22
start local 22 39: aload 18
aload 22
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
40: dload 19
aload 22
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.weight:D
dadd
dstore 19
41: aload 14
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.value:Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo
dup
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo.ownership:D
aload 22
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.weight:D
dsub
putfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo.ownership:D
end local 22 42: iinc 21 1
StackMap locals:
StackMap stack:
43: iload 21
iload 16
if_icmplt 38
end local 21 44: aload 14
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.weight:D
dload 7
dsub
dstore 21
start local 21 45: aload 18
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 24
goto 62
StackMap locals: org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator java.lang.Object int java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo double double java.util.List java.util.List int org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted java.util.Iterator int java.util.Queue java.util.List double double top java.util.Iterator
StackMap stack:
46: aload 24
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted
astore 23
start local 23 47: dload 21
dload 19
dcmpg
ifge 54
48: dload 21
dload 19
ddiv
dstore 25
start local 25 49: dload 25
ldc 0.09999999999999998
dcmpg
ifge 51
50: ldc 0.09999999999999998
dstore 25
51: StackMap locals: org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator java.lang.Object int java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo double double java.util.List java.util.List int org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted java.util.Iterator int java.util.Queue java.util.List double double org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted java.util.Iterator double
StackMap stack:
dload 25
ldc 0.9
dcmpl
ifle 55
52: ldc 0.9
dstore 25
53: goto 55
end local 25 54: StackMap locals:
StackMap stack:
ldc 0.9
dstore 25
start local 25 55: StackMap locals: double
StackMap stack:
aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.partitioner:Lorg/apache/cassandra/dht/IPartitioner;
aload 23
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.value:Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo
invokevirtual org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.prevInRing:()Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.token:Lorg/apache/cassandra/dht/Token;
aload 23
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.value:Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.token:Lorg/apache/cassandra/dht/Token;
dload 25
invokeinterface org.apache.cassandra.dht.IPartitioner.split:(Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/dht/Token;D)Lorg/apache/cassandra/dht/Token;
astore 27
start local 27 56: aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.sortedTokens:Ljava/util/NavigableMap;
aload 27
aload 1
invokeinterface java.util.NavigableMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
57: new org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo
dup
aload 27
aload 4
invokespecial org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.<init>:(Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo;)V
astore 28
start local 28 58: aload 28
aload 6
aload 23
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.value:Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo
invokevirtual org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.prevInRing:()Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;
invokevirtual org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.insertAfter:(Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$CircularList;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$CircularList;)Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$CircularList;
pop
59: aload 0
aload 28
invokevirtual org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.populateTokenInfoAndAdjustUnit:(Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;)V
60: aload 0
aload 23
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.value:Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo
invokevirtual org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.populateTokenInfoAndAdjustUnit:(Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;)V
61: aload 12
aload 27
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 28 end local 27 end local 25 end local 23 62: StackMap locals: org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator java.lang.Object int java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo double double java.util.List java.util.List int org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted java.util.Iterator int java.util.Queue java.util.List double double top java.util.Iterator
StackMap stack:
aload 24
invokeinterface java.util.Iterator.hasNext:()Z
ifne 46
63: aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.sortedUnits:Ljava/util/PriorityQueue;
new org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted
dup
aload 14
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.value:Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo.ownership:D
aload 14
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.value:Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo
invokespecial org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.<init>:(DLjava/lang/Object;)V
invokevirtual java.util.PriorityQueue.add:(Ljava/lang/Object;)Z
pop
64: iinc 13 1
end local 21 end local 19 end local 18 end local 17 end local 16 end local 14 65: StackMap locals: org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator java.lang.Object int java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo java.util.Map org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo double double java.util.List java.util.List int top java.util.Iterator
StackMap stack:
aload 15
invokeinterface java.util.Iterator.hasNext:()Z
ifne 29
66: aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.sortedUnits:Ljava/util/PriorityQueue;
new org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted
dup
aload 4
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo.ownership:D
aload 4
invokespecial org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.<init>:(DLjava/lang/Object;)V
invokevirtual java.util.PriorityQueue.add:(Ljava/lang/Object;)Z
pop
67: aload 12
areturn
end local 13 end local 12 end local 11 end local 9 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 68 0 this Lorg/apache/cassandra/dht/tokenallocator/NoReplicationTokenAllocator<TUnit;>;
0 68 1 newUnit TUnit;
0 68 2 numTokens I
2 68 3 groups Ljava/util/Map<Ljava/lang/Object;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$GroupInfo;>;
3 68 4 newUnitInfo Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo<TUnit;>;
4 68 5 unitInfos Ljava/util/Map<TUnit;Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo<TUnit;>;>;
9 68 6 head Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo<TUnit;>;
10 68 7 targetAverage D
11 68 9 sum D
12 68 11 unitsToChange Ljava/util/List<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$Weighted<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo;>;>;
13 26 12 i I
15 24 13 unit Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$Weighted<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo;>;
19 24 14 average D
27 68 12 newTokens Ljava/util/List<Lorg/apache/cassandra/dht/Token;>;
28 68 13 nr I
30 65 14 unit Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$Weighted<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo;>;
33 65 16 tokensToChange I
34 65 17 unitTokens Ljava/util/Queue<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$Weighted<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;>;>;
35 65 18 tokens Ljava/util/List<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$Weighted<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;>;>;
36 65 19 workWeight D
37 44 21 i I
39 42 22 wt Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$Weighted<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;>;
45 65 21 toTakeOver D
47 62 23 wt Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$Weighted<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;>;
49 54 25 slice D
55 62 25 slice D
56 62 27 token Lorg/apache/cassandra/dht/Token;
58 62 28 ti Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo<TUnit;>;
Signature: (TUnit;I)Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;
MethodParameters:
Name Flags
newUnit
numTokens
void removeUnit();
descriptor: (Ljava/lang/Object;)V
flags: (0x0000)
Code:
stack=2, locals=7, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.sortedUnits:Ljava/util/PriorityQueue;
invokevirtual java.util.PriorityQueue.iterator:()Ljava/util/Iterator;
astore 2
start local 2 1: goto 5
2: StackMap locals: java.util.Iterator
StackMap stack:
aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.value:Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo.unit:Ljava/lang/Object;
aload 1
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 5
3: aload 2
invokeinterface java.util.Iterator.remove:()V
4: goto 6
5: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
6: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.tokensInUnits:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.util.PriorityQueue
astore 3
start local 3 7: aload 3
invokevirtual java.util.PriorityQueue.size:()I
invokestatic com.google.common.collect.Lists.newArrayListWithCapacity:(I)Ljava/util/ArrayList;
astore 4
start local 4 8: aload 3
invokevirtual java.util.PriorityQueue.iterator:()Ljava/util/Iterator;
astore 6
goto 11
StackMap locals: org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator java.lang.Object java.util.Iterator java.util.PriorityQueue java.util.Collection top java.util.Iterator
StackMap stack:
9: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted
astore 5
start local 5 10: aload 4
aload 5
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted.value:Ljava/lang/Object;
checkcast org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo
getfield org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo.token:Lorg/apache/cassandra/dht/Token;
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
pop
end local 5 11: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 9
12: aload 0
getfield org.apache.cassandra.dht.tokenallocator.NoReplicationTokenAllocator.sortedTokens:Ljava/util/NavigableMap;
invokeinterface java.util.NavigableMap.keySet:()Ljava/util/Set;
aload 4
invokeinterface java.util.Set.removeAll:(Ljava/util/Collection;)Z
pop
13: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lorg/apache/cassandra/dht/tokenallocator/NoReplicationTokenAllocator<TUnit;>;
0 14 1 n TUnit;
1 14 2 it Ljava/util/Iterator<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$Weighted<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$UnitInfo;>;>;
7 14 3 tokenInfos Ljava/util/PriorityQueue<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$Weighted<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;>;>;
8 14 4 tokens Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;
10 11 5 tokenInfo Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$Weighted<Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase$TokenInfo;>;
Signature: (TUnit;)V
MethodParameters:
Name Flags
n
public int getReplicas();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: iconst_1
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/dht/tokenallocator/NoReplicationTokenAllocator<TUnit;>;
}
Signature: <Unit:Ljava/lang/Object;>Lorg/apache/cassandra/dht/tokenallocator/TokenAllocatorBase<TUnit;>;
SourceFile: "NoReplicationTokenAllocator.java"
InnerClasses:
public abstract Entry = java.util.Map$Entry of java.util.Map
GroupInfo = org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$GroupInfo of org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase
TokenInfo = org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$TokenInfo of org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase
UnitInfo = org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$UnitInfo of org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase
Weighted = org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$Weighted of org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase
private CircularList = org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase$CircularList of org.apache.cassandra.dht.tokenallocator.TokenAllocatorBase