class org.apache.cassandra.locator.TokenMetadata$Topology$Builder
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.apache.cassandra.locator.TokenMetadata$Topology$Builder
super_class: java.lang.Object
{
private final com.google.common.collect.Multimap<java.lang.String, java.net.InetAddress> dcEndpoints;
descriptor: Lcom/google/common/collect/Multimap;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lcom/google/common/collect/Multimap<Ljava/lang/String;Ljava/net/InetAddress;>;
private final java.util.Map<java.lang.String, com.google.common.collect.Multimap<java.lang.String, java.net.InetAddress>> dcRacks;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/String;Lcom/google/common/collect/Multimap<Ljava/lang/String;Ljava/net/InetAddress;>;>;
private final java.util.Map<java.net.InetAddress, org.apache.cassandra.utils.Pair<java.lang.String, java.lang.String>> currentLocations;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/net/InetAddress;Lorg/apache/cassandra/utils/Pair<Ljava/lang/String;Ljava/lang/String;>;>;
void <init>();
descriptor: ()V
flags: (0x0000)
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
invokestatic com.google.common.collect.HashMultimap.create:()Lcom/google/common/collect/HashMultimap;
putfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.dcEndpoints:Lcom/google/common/collect/Multimap;
2: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.dcRacks:Ljava/util/Map;
3: aload 0
new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
putfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.currentLocations:Ljava/util/Map;
4: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/locator/TokenMetadata$Topology$Builder;
void <init>(org.apache.cassandra.locator.TokenMetadata$Topology);
descriptor: (Lorg/apache/cassandra/locator/TokenMetadata$Topology;)V
flags: (0x0000)
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
getfield org.apache.cassandra.locator.TokenMetadata$Topology.dcEndpoints:Lcom/google/common/collect/ImmutableMultimap;
invokestatic com.google.common.collect.HashMultimap.create:(Lcom/google/common/collect/Multimap;)Lcom/google/common/collect/HashMultimap;
putfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.dcEndpoints:Lcom/google/common/collect/Multimap;
2: aload 0
aload 1
getfield org.apache.cassandra.locator.TokenMetadata$Topology.dcRacks:Lcom/google/common/collect/ImmutableMap;
invokevirtual com.google.common.collect.ImmutableMap.size:()I
invokestatic com.google.common.collect.Maps.newHashMapWithExpectedSize:(I)Ljava/util/HashMap;
putfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.dcRacks:Ljava/util/Map;
3: aload 1
getfield org.apache.cassandra.locator.TokenMetadata$Topology.dcRacks:Lcom/google/common/collect/ImmutableMap;
invokevirtual com.google.common.collect.ImmutableMap.entrySet:()Lcom/google/common/collect/ImmutableSet;
invokevirtual com.google.common.collect.ImmutableSet.iterator:()Ljava/util/Iterator;
astore 3
goto 6
StackMap locals: org.apache.cassandra.locator.TokenMetadata$Topology$Builder org.apache.cassandra.locator.TokenMetadata$Topology top java.util.Iterator
StackMap stack:
4: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 2
start local 2 5: aload 0
getfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.dcRacks:Ljava/util/Map;
aload 2
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
aload 2
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast com.google.common.collect.Multimap
invokestatic com.google.common.collect.HashMultimap.create:(Lcom/google/common/collect/Multimap;)Lcom/google/common/collect/HashMultimap;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 2 6: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
7: aload 0
new java.util.HashMap
dup
aload 1
getfield org.apache.cassandra.locator.TokenMetadata$Topology.currentLocations:Lcom/google/common/collect/ImmutableMap;
invokespecial java.util.HashMap.<init>:(Ljava/util/Map;)V
putfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.currentLocations:Ljava/util/Map;
8: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/locator/TokenMetadata$Topology$Builder;
0 9 1 from Lorg/apache/cassandra/locator/TokenMetadata$Topology;
5 6 2 entry Ljava/util/Map$Entry<Ljava/lang/String;Lcom/google/common/collect/ImmutableMultimap<Ljava/lang/String;Ljava/net/InetAddress;>;>;
MethodParameters:
Name Flags
from
org.apache.cassandra.locator.TokenMetadata$Topology$Builder addEndpoint(java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;)Lorg/apache/cassandra/locator/TokenMetadata$Topology$Builder;
flags: (0x0000)
Code:
stack=4, locals=6, args_size=2
start local 0 start local 1 0: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getEndpointSnitch:()Lorg/apache/cassandra/locator/IEndpointSnitch;
astore 2
start local 2 1: aload 2
aload 1
invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getDatacenter:(Ljava/net/InetAddress;)Ljava/lang/String;
astore 3
start local 3 2: aload 2
aload 1
invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getRack:(Ljava/net/InetAddress;)Ljava/lang/String;
astore 4
start local 4 3: aload 0
getfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.currentLocations:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.utils.Pair
astore 5
start local 5 4: aload 5
ifnull 8
5: aload 5
getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
checkcast java.lang.String
aload 3
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 7
aload 5
getfield org.apache.cassandra.utils.Pair.right:Ljava/lang/Object;
checkcast java.lang.String
aload 4
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 7
6: aload 0
areturn
7: StackMap locals: org.apache.cassandra.locator.TokenMetadata$Topology$Builder java.net.InetAddress org.apache.cassandra.locator.IEndpointSnitch java.lang.String java.lang.String org.apache.cassandra.utils.Pair
StackMap stack:
aload 0
aload 1
aload 5
invokevirtual org.apache.cassandra.locator.TokenMetadata$Topology$Builder.doRemoveEndpoint:(Ljava/net/InetAddress;Lorg/apache/cassandra/utils/Pair;)V
8: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 3
aload 4
invokevirtual org.apache.cassandra.locator.TokenMetadata$Topology$Builder.doAddEndpoint:(Ljava/net/InetAddress;Ljava/lang/String;Ljava/lang/String;)V
9: aload 0
areturn
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 10 0 this Lorg/apache/cassandra/locator/TokenMetadata$Topology$Builder;
0 10 1 ep Ljava/net/InetAddress;
1 10 2 snitch Lorg/apache/cassandra/locator/IEndpointSnitch;
2 10 3 dc Ljava/lang/String;
3 10 4 rack Ljava/lang/String;
4 10 5 current Lorg/apache/cassandra/utils/Pair<Ljava/lang/String;Ljava/lang/String;>;
MethodParameters:
Name Flags
ep
private void doAddEndpoint(java.net.InetAddress, java.lang.String, java.lang.String);
descriptor: (Ljava/net/InetAddress;Ljava/lang/String;Ljava/lang/String;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.dcEndpoints:Lcom/google/common/collect/Multimap;
aload 2
aload 1
invokeinterface com.google.common.collect.Multimap.put:(Ljava/lang/Object;Ljava/lang/Object;)Z
pop
1: aload 0
getfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.dcRacks:Ljava/util/Map;
aload 2
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifne 3
2: aload 0
getfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.dcRacks:Ljava/util/Map;
aload 2
invokestatic com.google.common.collect.HashMultimap.create:()Lcom/google/common/collect/HashMultimap;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.dcRacks:Ljava/util/Map;
aload 2
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast com.google.common.collect.Multimap
aload 3
aload 1
invokeinterface com.google.common.collect.Multimap.put:(Ljava/lang/Object;Ljava/lang/Object;)Z
pop
4: aload 0
getfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.currentLocations:Ljava/util/Map;
aload 1
aload 2
aload 3
invokestatic org.apache.cassandra.utils.Pair.create:(Ljava/lang/Object;Ljava/lang/Object;)Lorg/apache/cassandra/utils/Pair;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
5: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/locator/TokenMetadata$Topology$Builder;
0 6 1 ep Ljava/net/InetAddress;
0 6 2 dc Ljava/lang/String;
0 6 3 rack Ljava/lang/String;
MethodParameters:
Name Flags
ep
dc
rack
org.apache.cassandra.locator.TokenMetadata$Topology$Builder removeEndpoint(java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;)Lorg/apache/cassandra/locator/TokenMetadata$Topology$Builder;
flags: (0x0000)
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.currentLocations:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifne 2
1: aload 0
areturn
2: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 0
getfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.currentLocations:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.utils.Pair
invokevirtual org.apache.cassandra.locator.TokenMetadata$Topology$Builder.doRemoveEndpoint:(Ljava/net/InetAddress;Lorg/apache/cassandra/utils/Pair;)V
3: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/locator/TokenMetadata$Topology$Builder;
0 4 1 ep Ljava/net/InetAddress;
MethodParameters:
Name Flags
ep
private void doRemoveEndpoint(java.net.InetAddress, org.apache.cassandra.utils.Pair<java.lang.String, java.lang.String>);
descriptor: (Ljava/net/InetAddress;Lorg/apache/cassandra/utils/Pair;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.dcRacks:Ljava/util/Map;
aload 2
getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast com.google.common.collect.Multimap
aload 2
getfield org.apache.cassandra.utils.Pair.right:Ljava/lang/Object;
aload 1
invokeinterface com.google.common.collect.Multimap.remove:(Ljava/lang/Object;Ljava/lang/Object;)Z
pop
1: aload 0
getfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.dcEndpoints:Lcom/google/common/collect/Multimap;
aload 2
getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
aload 1
invokeinterface com.google.common.collect.Multimap.remove:(Ljava/lang/Object;Ljava/lang/Object;)Z
pop
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/locator/TokenMetadata$Topology$Builder;
0 3 1 ep Ljava/net/InetAddress;
0 3 2 current Lorg/apache/cassandra/utils/Pair<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Ljava/net/InetAddress;Lorg/apache/cassandra/utils/Pair<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
ep
current
org.apache.cassandra.locator.TokenMetadata$Topology$Builder updateEndpoint(java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;)Lorg/apache/cassandra/locator/TokenMetadata$Topology$Builder;
flags: (0x0000)
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getEndpointSnitch:()Lorg/apache/cassandra/locator/IEndpointSnitch;
astore 2
start local 2 1: aload 2
ifnull 2
aload 0
getfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.currentLocations:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifne 3
2: StackMap locals: org.apache.cassandra.locator.IEndpointSnitch
StackMap stack:
aload 0
areturn
3: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 2
invokevirtual org.apache.cassandra.locator.TokenMetadata$Topology$Builder.updateEndpoint:(Ljava/net/InetAddress;Lorg/apache/cassandra/locator/IEndpointSnitch;)V
4: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/locator/TokenMetadata$Topology$Builder;
0 5 1 ep Ljava/net/InetAddress;
1 5 2 snitch Lorg/apache/cassandra/locator/IEndpointSnitch;
MethodParameters:
Name Flags
ep
org.apache.cassandra.locator.TokenMetadata$Topology$Builder updateEndpoints();
descriptor: ()Lorg/apache/cassandra/locator/TokenMetadata$Topology$Builder;
flags: (0x0000)
Code:
stack=3, locals=4, args_size=1
start local 0 0: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getEndpointSnitch:()Lorg/apache/cassandra/locator/IEndpointSnitch;
astore 1
start local 1 1: aload 1
ifnonnull 3
2: aload 0
areturn
3: StackMap locals: org.apache.cassandra.locator.IEndpointSnitch
StackMap stack:
aload 0
getfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.currentLocations:Ljava/util/Map;
invokeinterface java.util.Map.keySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 3
goto 6
StackMap locals: org.apache.cassandra.locator.TokenMetadata$Topology$Builder org.apache.cassandra.locator.IEndpointSnitch top java.util.Iterator
StackMap stack:
4: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.net.InetAddress
astore 2
start local 2 5: aload 0
aload 2
aload 1
invokevirtual org.apache.cassandra.locator.TokenMetadata$Topology$Builder.updateEndpoint:(Ljava/net/InetAddress;Lorg/apache/cassandra/locator/IEndpointSnitch;)V
end local 2 6: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
7: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/apache/cassandra/locator/TokenMetadata$Topology$Builder;
1 8 1 snitch Lorg/apache/cassandra/locator/IEndpointSnitch;
5 6 2 ep Ljava/net/InetAddress;
private void updateEndpoint(java.net.InetAddress, org.apache.cassandra.locator.IEndpointSnitch);
descriptor: (Ljava/net/InetAddress;Lorg/apache/cassandra/locator/IEndpointSnitch;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.locator.TokenMetadata$Topology$Builder.currentLocations:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.utils.Pair
astore 3
start local 3 1: aload 2
aload 1
invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getDatacenter:(Ljava/net/InetAddress;)Ljava/lang/String;
astore 4
start local 4 2: aload 2
aload 1
invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getRack:(Ljava/net/InetAddress;)Ljava/lang/String;
astore 5
start local 5 3: aload 4
aload 3
getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 5
aload 5
aload 3
getfield org.apache.cassandra.utils.Pair.right:Ljava/lang/Object;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 5
4: return
5: StackMap locals: org.apache.cassandra.utils.Pair java.lang.String java.lang.String
StackMap stack:
aload 0
aload 1
aload 3
invokevirtual org.apache.cassandra.locator.TokenMetadata$Topology$Builder.doRemoveEndpoint:(Ljava/net/InetAddress;Lorg/apache/cassandra/utils/Pair;)V
6: aload 0
aload 1
aload 4
aload 5
invokevirtual org.apache.cassandra.locator.TokenMetadata$Topology$Builder.doAddEndpoint:(Ljava/net/InetAddress;Ljava/lang/String;Ljava/lang/String;)V
7: return
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 8 0 this Lorg/apache/cassandra/locator/TokenMetadata$Topology$Builder;
0 8 1 ep Ljava/net/InetAddress;
0 8 2 snitch Lorg/apache/cassandra/locator/IEndpointSnitch;
1 8 3 current Lorg/apache/cassandra/utils/Pair<Ljava/lang/String;Ljava/lang/String;>;
2 8 4 dc Ljava/lang/String;
3 8 5 rack Ljava/lang/String;
MethodParameters:
Name Flags
ep
snitch
org.apache.cassandra.locator.TokenMetadata$Topology build();
descriptor: ()Lorg/apache/cassandra/locator/TokenMetadata$Topology;
flags: (0x0000)
Code:
stack=3, locals=1, args_size=1
start local 0 0: new org.apache.cassandra.locator.TokenMetadata$Topology
dup
aload 0
invokespecial org.apache.cassandra.locator.TokenMetadata$Topology.<init>:(Lorg/apache/cassandra/locator/TokenMetadata$Topology$Builder;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/locator/TokenMetadata$Topology$Builder;
}
SourceFile: "TokenMetadata.java"
NestHost: org.apache.cassandra.locator.TokenMetadata
InnerClasses:
public abstract Entry = java.util.Map$Entry of java.util.Map
public Topology = org.apache.cassandra.locator.TokenMetadata$Topology of org.apache.cassandra.locator.TokenMetadata
private Builder = org.apache.cassandra.locator.TokenMetadata$Topology$Builder of org.apache.cassandra.locator.TokenMetadata$Topology