public class org.apache.cassandra.locator.OldNetworkTopologyStrategy extends org.apache.cassandra.locator.AbstractReplicationStrategy
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.locator.OldNetworkTopologyStrategy
super_class: org.apache.cassandra.locator.AbstractReplicationStrategy
{
public void <init>(java.lang.String, org.apache.cassandra.locator.TokenMetadata, org.apache.cassandra.locator.IEndpointSnitch, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Ljava/lang/String;Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/util/Map;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
aload 1
aload 2
aload 3
aload 4
invokespecial org.apache.cassandra.locator.AbstractReplicationStrategy.<init>:(Ljava/lang/String;Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/util/Map;)V
1: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/locator/OldNetworkTopologyStrategy;
0 2 1 keyspaceName Ljava/lang/String;
0 2 2 tokenMetadata Lorg/apache/cassandra/locator/TokenMetadata;
0 2 3 snitch Lorg/apache/cassandra/locator/IEndpointSnitch;
0 2 4 configOptions Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Ljava/lang/String;Lorg/apache/cassandra/locator/TokenMetadata;Lorg/apache/cassandra/locator/IEndpointSnitch;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
keyspaceName
tokenMetadata
snitch
configOptions
public java.util.List<java.net.InetAddress> calculateNaturalEndpoints(org.apache.cassandra.dht.Token, org.apache.cassandra.locator.TokenMetadata);
descriptor: (Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/locator/TokenMetadata;)Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=11, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual org.apache.cassandra.locator.OldNetworkTopologyStrategy.getReplicationFactor:()I
istore 3
start local 3 1: new java.util.ArrayList
dup
iload 3
invokespecial java.util.ArrayList.<init>:(I)V
astore 4
start local 4 2: aload 2
invokevirtual org.apache.cassandra.locator.TokenMetadata.sortedTokens:()Ljava/util/ArrayList;
astore 5
start local 5 3: aload 5
invokevirtual java.util.ArrayList.isEmpty:()Z
ifeq 5
4: aload 4
areturn
5: StackMap locals: int java.util.List java.util.ArrayList
StackMap stack:
aload 5
aload 1
iconst_0
invokestatic org.apache.cassandra.locator.TokenMetadata.ringIterator:(Ljava/util/ArrayList;Lorg/apache/cassandra/dht/Token;Z)Ljava/util/Iterator;
astore 6
start local 6 6: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.Token
astore 7
start local 7 7: aload 4
aload 2
aload 7
invokevirtual org.apache.cassandra.locator.TokenMetadata.getEndpoint:(Lorg/apache/cassandra/dht/Token;)Ljava/net/InetAddress;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
8: iconst_0
istore 8
start local 8 9: iconst_0
istore 9
start local 9 10: goto 22
11: StackMap locals: org.apache.cassandra.locator.OldNetworkTopologyStrategy org.apache.cassandra.dht.Token org.apache.cassandra.locator.TokenMetadata int java.util.List java.util.ArrayList java.util.Iterator org.apache.cassandra.dht.Token int int
StackMap stack:
aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.Token
astore 10
start local 10 12: aload 0
getfield org.apache.cassandra.locator.OldNetworkTopologyStrategy.snitch:Lorg/apache/cassandra/locator/IEndpointSnitch;
aload 2
aload 7
invokevirtual org.apache.cassandra.locator.TokenMetadata.getEndpoint:(Lorg/apache/cassandra/dht/Token;)Ljava/net/InetAddress;
invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getDatacenter:(Ljava/net/InetAddress;)Ljava/lang/String;
aload 0
getfield org.apache.cassandra.locator.OldNetworkTopologyStrategy.snitch:Lorg/apache/cassandra/locator/IEndpointSnitch;
aload 2
aload 10
invokevirtual org.apache.cassandra.locator.TokenMetadata.getEndpoint:(Lorg/apache/cassandra/dht/Token;)Ljava/net/InetAddress;
invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getDatacenter:(Ljava/net/InetAddress;)Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 17
13: iload 8
ifne 22
14: aload 4
aload 2
aload 10
invokevirtual org.apache.cassandra.locator.TokenMetadata.getEndpoint:(Lorg/apache/cassandra/dht/Token;)Ljava/net/InetAddress;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
15: iconst_1
istore 8
16: goto 22
17: StackMap locals: org.apache.cassandra.dht.Token
StackMap stack:
aload 0
getfield org.apache.cassandra.locator.OldNetworkTopologyStrategy.snitch:Lorg/apache/cassandra/locator/IEndpointSnitch;
aload 2
aload 7
invokevirtual org.apache.cassandra.locator.TokenMetadata.getEndpoint:(Lorg/apache/cassandra/dht/Token;)Ljava/net/InetAddress;
invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getRack:(Ljava/net/InetAddress;)Ljava/lang/String;
aload 0
getfield org.apache.cassandra.locator.OldNetworkTopologyStrategy.snitch:Lorg/apache/cassandra/locator/IEndpointSnitch;
aload 2
aload 10
invokevirtual org.apache.cassandra.locator.TokenMetadata.getEndpoint:(Lorg/apache/cassandra/dht/Token;)Ljava/net/InetAddress;
invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getRack:(Ljava/net/InetAddress;)Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 22
18: aload 0
getfield org.apache.cassandra.locator.OldNetworkTopologyStrategy.snitch:Lorg/apache/cassandra/locator/IEndpointSnitch;
aload 2
aload 7
invokevirtual org.apache.cassandra.locator.TokenMetadata.getEndpoint:(Lorg/apache/cassandra/dht/Token;)Ljava/net/InetAddress;
invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getDatacenter:(Ljava/net/InetAddress;)Ljava/lang/String;
aload 0
getfield org.apache.cassandra.locator.OldNetworkTopologyStrategy.snitch:Lorg/apache/cassandra/locator/IEndpointSnitch;
aload 2
aload 10
invokevirtual org.apache.cassandra.locator.TokenMetadata.getEndpoint:(Lorg/apache/cassandra/dht/Token;)Ljava/net/InetAddress;
invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getDatacenter:(Ljava/net/InetAddress;)Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 22
19: iload 9
ifne 22
20: aload 4
aload 2
aload 10
invokevirtual org.apache.cassandra.locator.TokenMetadata.getEndpoint:(Lorg/apache/cassandra/dht/Token;)Ljava/net/InetAddress;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
21: iconst_1
istore 9
end local 10 22: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.List.size:()I
iload 3
if_icmpge 23
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 11
23: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.List.size:()I
iload 3
if_icmpge 30
24: aload 5
aload 1
iconst_0
invokestatic org.apache.cassandra.locator.TokenMetadata.ringIterator:(Ljava/util/ArrayList;Lorg/apache/cassandra/dht/Token;Z)Ljava/util/Iterator;
astore 6
25: goto 29
26: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.Token
astore 10
start local 10 27: aload 4
aload 2
aload 10
invokevirtual org.apache.cassandra.locator.TokenMetadata.getEndpoint:(Lorg/apache/cassandra/dht/Token;)Ljava/net/InetAddress;
invokeinterface java.util.List.contains:(Ljava/lang/Object;)Z
ifne 29
28: aload 4
aload 2
aload 10
invokevirtual org.apache.cassandra.locator.TokenMetadata.getEndpoint:(Lorg/apache/cassandra/dht/Token;)Ljava/net/InetAddress;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 10 29: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.List.size:()I
iload 3
if_icmpge 30
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 26
30: StackMap locals:
StackMap stack:
aload 4
areturn
end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 31 0 this Lorg/apache/cassandra/locator/OldNetworkTopologyStrategy;
0 31 1 token Lorg/apache/cassandra/dht/Token;
0 31 2 metadata Lorg/apache/cassandra/locator/TokenMetadata;
1 31 3 replicas I
2 31 4 endpoints Ljava/util/List<Ljava/net/InetAddress;>;
3 31 5 tokens Ljava/util/ArrayList<Lorg/apache/cassandra/dht/Token;>;
6 31 6 iter Ljava/util/Iterator<Lorg/apache/cassandra/dht/Token;>;
7 31 7 primaryToken Lorg/apache/cassandra/dht/Token;
9 31 8 bDataCenter Z
10 31 9 bOtherRack Z
12 22 10 t Lorg/apache/cassandra/dht/Token;
27 29 10 t Lorg/apache/cassandra/dht/Token;
Signature: (Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/locator/TokenMetadata;)Ljava/util/List<Ljava/net/InetAddress;>;
MethodParameters:
Name Flags
token
metadata
public int getReplicationFactor();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.locator.OldNetworkTopologyStrategy.configOptions:Ljava/util/Map;
ldc "replication_factor"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
invokestatic java.lang.Integer.parseInt:(Ljava/lang/String;)I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/locator/OldNetworkTopologyStrategy;
public void validateOptions();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.locator.OldNetworkTopologyStrategy.configOptions:Ljava/util/Map;
ifnull 1
aload 0
getfield org.apache.cassandra.locator.OldNetworkTopologyStrategy.configOptions:Ljava/util/Map;
ldc "replication_factor"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
ifnonnull 2
1: StackMap locals:
StackMap stack:
new org.apache.cassandra.exceptions.ConfigurationException
dup
ldc "SimpleStrategy requires a replication_factor strategy option."
invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 0
aload 0
getfield org.apache.cassandra.locator.OldNetworkTopologyStrategy.configOptions:Ljava/util/Map;
ldc "replication_factor"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
invokevirtual org.apache.cassandra.locator.OldNetworkTopologyStrategy.validateReplicationFactor:(Ljava/lang/String;)V
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/locator/OldNetworkTopologyStrategy;
Exceptions:
throws org.apache.cassandra.exceptions.ConfigurationException
public java.util.Collection<java.lang.String> recognizedOptions();
descriptor: ()Ljava/util/Collection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: ldc "replication_factor"
invokestatic java.util.Collections.singleton:(Ljava/lang/Object;)Ljava/util/Set;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/locator/OldNetworkTopologyStrategy;
Signature: ()Ljava/util/Collection<Ljava/lang/String;>;
}
SourceFile: "OldNetworkTopologyStrategy.java"