public class org.apache.cassandra.utils.FBUtilities
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.utils.FBUtilities
super_class: java.lang.Object
{
private static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.codehaus.jackson.map.ObjectMapper jsonMapper;
descriptor: Lorg/codehaus/jackson/map/ObjectMapper;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
public static final java.lang.String UNKNOWN_RELEASE_VERSION;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "Unknown"
public static final java.math.BigInteger TWO;
descriptor: Ljava/math/BigInteger;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
private static final java.lang.String DEFAULT_TRIGGER_DIR;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "triggers"
private static final java.lang.String OPERATING_SYSTEM;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
public static final boolean isWindows;
descriptor: Z
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
public static final boolean isLinux;
descriptor: Z
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
private static volatile java.net.InetAddress localInetAddress;
descriptor: Ljava/net/InetAddress;
flags: (0x004a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE
private static volatile java.net.InetAddress broadcastInetAddress;
descriptor: Ljava/net/InetAddress;
flags: (0x004a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE
private static volatile java.net.InetAddress broadcastRpcAddress;
descriptor: Ljava/net/InetAddress;
flags: (0x004a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE
private static final io.netty.util.concurrent.FastThreadLocal<java.security.MessageDigest> localMD5Digest;
descriptor: Lio/netty/util/concurrent/FastThreadLocal;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Lio/netty/util/concurrent/FastThreadLocal<Ljava/security/MessageDigest;>;
public static final int MAX_UNSIGNED_SHORT;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: 65535
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=4, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/utils/FBUtilities;
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.utils.FBUtilities.$assertionsDisabled:Z
3: ldc Lorg/apache/cassandra/utils/FBUtilities;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.utils.FBUtilities.logger:Lorg/slf4j/Logger;
4: new org.codehaus.jackson.map.ObjectMapper
dup
new org.codehaus.jackson.JsonFactory
dup
invokespecial org.codehaus.jackson.JsonFactory.<init>:()V
invokespecial org.codehaus.jackson.map.ObjectMapper.<init>:(Lorg/codehaus/jackson/JsonFactory;)V
putstatic org.apache.cassandra.utils.FBUtilities.jsonMapper:Lorg/codehaus/jackson/map/ObjectMapper;
5: new java.math.BigInteger
dup
ldc "2"
invokespecial java.math.BigInteger.<init>:(Ljava/lang/String;)V
putstatic org.apache.cassandra.utils.FBUtilities.TWO:Ljava/math/BigInteger;
6: ldc "os.name"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual java.lang.String.toLowerCase:()Ljava/lang/String;
putstatic org.apache.cassandra.utils.FBUtilities.OPERATING_SYSTEM:Ljava/lang/String;
7: getstatic org.apache.cassandra.utils.FBUtilities.OPERATING_SYSTEM:Ljava/lang/String;
ldc "windows"
invokevirtual java.lang.String.contains:(Ljava/lang/CharSequence;)Z
putstatic org.apache.cassandra.utils.FBUtilities.isWindows:Z
8: getstatic org.apache.cassandra.utils.FBUtilities.OPERATING_SYSTEM:Ljava/lang/String;
ldc "linux"
invokevirtual java.lang.String.contains:(Ljava/lang/CharSequence;)Z
putstatic org.apache.cassandra.utils.FBUtilities.isLinux:Z
9: new org.apache.cassandra.utils.FBUtilities$1
dup
invokespecial org.apache.cassandra.utils.FBUtilities$1.<init>:()V
putstatic org.apache.cassandra.utils.FBUtilities.localMD5Digest:Lio/netty/util/concurrent/FastThreadLocal;
10: 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 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/utils/FBUtilities;
public static int getAvailableProcessors();
descriptor: ()I
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=1, args_size=0
0: ldc "cassandra.available_processors"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
astore 0
start local 0 1: aload 0
invokestatic com.google.common.base.Strings.isNullOrEmpty:(Ljava/lang/String;)Z
ifne 3
2: aload 0
invokestatic java.lang.Integer.parseInt:(Ljava/lang/String;)I
ireturn
3: StackMap locals: java.lang.String
StackMap stack:
invokestatic java.lang.Runtime.getRuntime:()Ljava/lang/Runtime;
invokevirtual java.lang.Runtime.availableProcessors:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 4 0 availableProcessors Ljava/lang/String;
public static java.security.MessageDigest threadLocalMD5Digest();
descriptor: ()Ljava/security/MessageDigest;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=1, args_size=0
0: getstatic org.apache.cassandra.utils.FBUtilities.localMD5Digest:Lio/netty/util/concurrent/FastThreadLocal;
invokevirtual io.netty.util.concurrent.FastThreadLocal.get:()Ljava/lang/Object;
checkcast java.security.MessageDigest
astore 0
start local 0 1: aload 0
invokevirtual java.security.MessageDigest.reset:()V
2: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 3 0 md Ljava/security/MessageDigest;
public static java.security.MessageDigest newMessageDigest(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/security/MessageDigest;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=2, args_size=1
start local 0 0: aload 0
invokestatic java.security.MessageDigest.getInstance:(Ljava/lang/String;)Ljava/security/MessageDigest;
1: areturn
2: StackMap locals:
StackMap stack: java.security.NoSuchAlgorithmException
astore 1
start local 1 3: new java.lang.RuntimeException
dup
new java.lang.StringBuilder
dup
ldc "the requested digest algorithm ("
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ") is not available"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aload 1
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 algorithm Ljava/lang/String;
3 4 1 nsae Ljava/security/NoSuchAlgorithmException;
Exception table:
from to target type
0 1 2 Class java.security.NoSuchAlgorithmException
MethodParameters:
Name Flags
algorithm
public static java.net.InetAddress getLocalAddress();
descriptor: ()Ljava/net/InetAddress;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=0
0: getstatic org.apache.cassandra.utils.FBUtilities.localInetAddress:Ljava/net/InetAddress;
ifnonnull 8
1: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getListenAddress:()Ljava/net/InetAddress;
ifnonnull 3
2: invokestatic java.net.InetAddress.getLocalHost:()Ljava/net/InetAddress;
goto 4
3: StackMap locals:
StackMap stack:
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getListenAddress:()Ljava/net/InetAddress;
4: StackMap locals:
StackMap stack: java.net.InetAddress
putstatic org.apache.cassandra.utils.FBUtilities.localInetAddress:Ljava/net/InetAddress;
5: goto 8
6: StackMap locals:
StackMap stack: java.net.UnknownHostException
astore 0
start local 0 7: new java.lang.RuntimeException
dup
aload 0
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 0 8: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.utils.FBUtilities.localInetAddress:Ljava/net/InetAddress;
areturn
LocalVariableTable:
Start End Slot Name Signature
7 8 0 e Ljava/net/UnknownHostException;
Exception table:
from to target type
1 5 6 Class java.net.UnknownHostException
public static java.net.InetAddress getBroadcastAddress();
descriptor: ()Ljava/net/InetAddress;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic org.apache.cassandra.utils.FBUtilities.broadcastInetAddress:Ljava/net/InetAddress;
ifnonnull 5
1: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getBroadcastAddress:()Ljava/net/InetAddress;
ifnonnull 3
2: invokestatic org.apache.cassandra.utils.FBUtilities.getLocalAddress:()Ljava/net/InetAddress;
goto 4
3: StackMap locals:
StackMap stack:
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getBroadcastAddress:()Ljava/net/InetAddress;
4: StackMap locals:
StackMap stack: java.net.InetAddress
putstatic org.apache.cassandra.utils.FBUtilities.broadcastInetAddress:Ljava/net/InetAddress;
5: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.utils.FBUtilities.broadcastInetAddress:Ljava/net/InetAddress;
areturn
LocalVariableTable:
Start End Slot Name Signature
public static void setBroadcastInetAddress(java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
putstatic org.apache.cassandra.utils.FBUtilities.broadcastInetAddress:Ljava/net/InetAddress;
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 addr Ljava/net/InetAddress;
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
addr
public static java.net.InetAddress getBroadcastRpcAddress();
descriptor: ()Ljava/net/InetAddress;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic org.apache.cassandra.utils.FBUtilities.broadcastRpcAddress:Ljava/net/InetAddress;
ifnonnull 5
1: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getBroadcastRpcAddress:()Ljava/net/InetAddress;
ifnonnull 3
2: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getRpcAddress:()Ljava/net/InetAddress;
goto 4
3: StackMap locals:
StackMap stack:
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getBroadcastRpcAddress:()Ljava/net/InetAddress;
4: StackMap locals:
StackMap stack: java.net.InetAddress
putstatic org.apache.cassandra.utils.FBUtilities.broadcastRpcAddress:Ljava/net/InetAddress;
5: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.utils.FBUtilities.broadcastRpcAddress:Ljava/net/InetAddress;
areturn
LocalVariableTable:
Start End Slot Name Signature
public static java.util.Collection<java.net.InetAddress> getAllLocalAddresses();
descriptor: ()Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=0
0: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 0
start local 0 1: invokestatic java.net.NetworkInterface.getNetworkInterfaces:()Ljava/util/Enumeration;
astore 1
start local 1 2: aload 1
ifnull 9
3: goto 5
4: StackMap locals: java.util.Set java.util.Enumeration
StackMap stack:
aload 0
aload 1
invokeinterface java.util.Enumeration.nextElement:()Ljava/lang/Object;
checkcast java.net.NetworkInterface
invokevirtual java.net.NetworkInterface.getInetAddresses:()Ljava/util/Enumeration;
invokestatic java.util.Collections.list:(Ljava/util/Enumeration;)Ljava/util/ArrayList;
invokeinterface java.util.Set.addAll:(Ljava/util/Collection;)Z
pop
5: StackMap locals:
StackMap stack:
aload 1
invokeinterface java.util.Enumeration.hasMoreElements:()Z
ifne 4
end local 1 6: goto 9
7: StackMap locals: java.util.Set
StackMap stack: java.net.SocketException
astore 1
start local 1 8: new java.lang.AssertionError
dup
aload 1
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
end local 1 9: StackMap locals:
StackMap stack:
aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 10 0 localAddresses Ljava/util/Set<Ljava/net/InetAddress;>;
2 6 1 nets Ljava/util/Enumeration<Ljava/net/NetworkInterface;>;
8 9 1 e Ljava/net/SocketException;
Exception table:
from to target type
1 6 7 Class java.net.SocketException
Signature: ()Ljava/util/Collection<Ljava/net/InetAddress;>;
public static java.lang.String getNetworkInterface(java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;)Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=5, args_size=1
start local 0 0: invokestatic java.net.NetworkInterface.getNetworkInterfaces:()Ljava/util/Enumeration;
invokestatic java.util.Collections.list:(Ljava/util/Enumeration;)Ljava/util/ArrayList;
invokevirtual java.util.ArrayList.iterator:()Ljava/util/Iterator;
astore 2
goto 9
StackMap locals: java.net.InetAddress top java.util.Iterator
StackMap stack:
1: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.net.NetworkInterface
astore 1
start local 1 2: aload 1
invokevirtual java.net.NetworkInterface.isUp:()Z
ifeq 9
3: aload 1
invokevirtual java.net.NetworkInterface.getInetAddresses:()Ljava/util/Enumeration;
invokestatic java.util.Collections.list:(Ljava/util/Enumeration;)Ljava/util/ArrayList;
invokevirtual java.util.ArrayList.iterator:()Ljava/util/Iterator;
astore 4
goto 8
StackMap locals: java.net.InetAddress java.net.NetworkInterface java.util.Iterator top java.util.Iterator
StackMap stack:
4: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.net.InetAddress
astore 3
start local 3 5: aload 3
aload 0
invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
ifeq 8
6: aload 1
invokevirtual java.net.NetworkInterface.getDisplayName:()Ljava/lang/String;
7: areturn
end local 3 8: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
end local 1 9: StackMap locals: java.net.InetAddress top java.util.Iterator
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
10: goto 12
11: StackMap locals: java.net.InetAddress
StackMap stack: java.net.SocketException
pop
12: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 localAddress Ljava/net/InetAddress;
2 9 1 ifc Ljava/net/NetworkInterface;
5 8 3 addr Ljava/net/InetAddress;
Exception table:
from to target type
0 7 11 Class java.net.SocketException
8 10 11 Class java.net.SocketException
MethodParameters:
Name Flags
localAddress
public static org.apache.cassandra.utils.Pair<java.math.BigInteger, java.lang.Boolean> midpoint(java.math.BigInteger, java.math.BigInteger, int);
descriptor: (Ljava/math/BigInteger;Ljava/math/BigInteger;I)Lorg/apache/cassandra/utils/Pair;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=7, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokevirtual java.math.BigInteger.compareTo:(Ljava/math/BigInteger;)I
ifge 5
1: aload 0
aload 1
invokevirtual java.math.BigInteger.add:(Ljava/math/BigInteger;)Ljava/math/BigInteger;
astore 5
start local 5 2: aload 5
iconst_0
invokevirtual java.math.BigInteger.testBit:(I)Z
istore 4
start local 4 3: aload 5
iconst_1
invokevirtual java.math.BigInteger.shiftRight:(I)Ljava/math/BigInteger;
astore 3
end local 5 start local 3 4: goto 9
end local 4 end local 3 5: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.utils.FBUtilities.TWO:Ljava/math/BigInteger;
iload 2
invokevirtual java.math.BigInteger.pow:(I)Ljava/math/BigInteger;
astore 5
start local 5 6: aload 5
aload 1
invokevirtual java.math.BigInteger.add:(Ljava/math/BigInteger;)Ljava/math/BigInteger;
aload 0
invokevirtual java.math.BigInteger.subtract:(Ljava/math/BigInteger;)Ljava/math/BigInteger;
astore 6
start local 6 7: aload 6
iconst_0
invokevirtual java.math.BigInteger.testBit:(I)Z
istore 4
start local 4 8: aload 6
iconst_1
invokevirtual java.math.BigInteger.shiftRight:(I)Ljava/math/BigInteger;
aload 0
invokevirtual java.math.BigInteger.add:(Ljava/math/BigInteger;)Ljava/math/BigInteger;
aload 5
invokevirtual java.math.BigInteger.mod:(Ljava/math/BigInteger;)Ljava/math/BigInteger;
astore 3
end local 6 end local 5 start local 3 9: StackMap locals: java.math.BigInteger int
StackMap stack:
aload 3
iload 4
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokestatic org.apache.cassandra.utils.Pair.create:(Ljava/lang/Object;Ljava/lang/Object;)Lorg/apache/cassandra/utils/Pair;
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 left Ljava/math/BigInteger;
0 10 1 right Ljava/math/BigInteger;
0 10 2 sigbits I
4 5 3 midpoint Ljava/math/BigInteger;
9 10 3 midpoint Ljava/math/BigInteger;
3 5 4 remainder Z
8 10 4 remainder Z
2 4 5 sum Ljava/math/BigInteger;
6 9 5 max Ljava/math/BigInteger;
7 9 6 distance Ljava/math/BigInteger;
Signature: (Ljava/math/BigInteger;Ljava/math/BigInteger;I)Lorg/apache/cassandra/utils/Pair<Ljava/math/BigInteger;Ljava/lang/Boolean;>;
MethodParameters:
Name Flags
left
right
sigbits
public static int compareUnsigned(byte[], byte[], int, int, int, int);
descriptor: ([B[BIIII)I
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 0: aload 0
iload 2
iload 4
aload 1
iload 3
iload 5
invokestatic org.apache.cassandra.utils.FastByteOperations.compareUnsigned:([BII[BII)I
ireturn
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 1 0 bytes1 [B
0 1 1 bytes2 [B
0 1 2 offset1 I
0 1 3 offset2 I
0 1 4 len1 I
0 1 5 len2 I
MethodParameters:
Name Flags
bytes1
bytes2
offset1
offset2
len1
len2
public static int compareUnsigned(byte[], byte[]);
descriptor: ([B[B)I
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
iconst_0
iconst_0
aload 0
arraylength
aload 1
arraylength
invokestatic org.apache.cassandra.utils.FBUtilities.compareUnsigned:([B[BIIII)I
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 bytes1 [B
0 1 1 bytes2 [B
MethodParameters:
Name Flags
bytes1
bytes2
public static byte[] xor(byte[], byte[]);
descriptor: ([B[B)[B
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 0
ifnull 1
aload 1
ifnonnull 2
1: StackMap locals:
StackMap stack:
aconst_null
areturn
2: StackMap locals:
StackMap stack:
aload 0
arraylength
aload 1
arraylength
if_icmple 6
3: aload 0
astore 2
start local 2 4: aload 1
astore 0
5: aload 2
astore 1
end local 2 6: StackMap locals:
StackMap stack:
aload 1
aload 1
arraylength
invokestatic java.util.Arrays.copyOf:([BI)[B
astore 2
start local 2 7: iconst_0
istore 3
start local 3 8: goto 11
9: StackMap locals: byte[] int
StackMap stack:
aload 2
iload 3
aload 0
iload 3
baload
sipush 255
iand
aload 1
iload 3
baload
sipush 255
iand
ixor
i2b
bastore
10: iinc 3 1
StackMap locals:
StackMap stack:
11: iload 3
aload 0
arraylength
if_icmplt 9
end local 3 12: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 left [B
0 13 1 right [B
4 6 2 swap [B
7 13 2 out [B
8 12 3 i I
MethodParameters:
Name Flags
left
right
public static void sortSampledKeys(java.util.List<org.apache.cassandra.db.DecoratedKey>, org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>);
descriptor: (Ljava/util/List;Lorg/apache/cassandra/dht/Range;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 1
getfield org.apache.cassandra.dht.Range.left:Lorg/apache/cassandra/dht/RingPosition;
checkcast org.apache.cassandra.dht.Token
aload 1
getfield org.apache.cassandra.dht.Range.right:Lorg/apache/cassandra/dht/RingPosition;
checkcast org.apache.cassandra.dht.Token
invokevirtual org.apache.cassandra.dht.Token.compareTo:(Ljava/lang/Object;)I
iflt 5
1: aload 1
getfield org.apache.cassandra.dht.Range.right:Lorg/apache/cassandra/dht/RingPosition;
checkcast org.apache.cassandra.dht.Token
astore 2
start local 2 2: new org.apache.cassandra.utils.FBUtilities$2
dup
aload 2
invokespecial org.apache.cassandra.utils.FBUtilities$2.<init>:(Lorg/apache/cassandra/dht/Token;)V
astore 3
start local 3 3: aload 0
aload 3
invokestatic java.util.Collections.sort:(Ljava/util/List;Ljava/util/Comparator;)V
end local 3 end local 2 4: goto 6
5: StackMap locals:
StackMap stack:
aload 0
invokestatic java.util.Collections.sort:(Ljava/util/List;)V
6: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 keys Ljava/util/List<Lorg/apache/cassandra/db/DecoratedKey;>;
0 7 1 range Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;
2 4 2 right Lorg/apache/cassandra/dht/Token;
3 4 3 comparator Ljava/util/Comparator<Lorg/apache/cassandra/db/DecoratedKey;>;
Signature: (Ljava/util/List<Lorg/apache/cassandra/db/DecoratedKey;>;Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;)V
MethodParameters:
Name Flags
keys
range
public static java.lang.String resourceToFile(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=1
start local 0 0: ldc Lorg/apache/cassandra/utils/FBUtilities;
invokevirtual java.lang.Class.getClassLoader:()Ljava/lang/ClassLoader;
astore 1
start local 1 1: aload 1
aload 0
invokevirtual java.lang.ClassLoader.getResource:(Ljava/lang/String;)Ljava/net/URL;
astore 2
start local 2 2: aload 2
ifnonnull 4
3: new org.apache.cassandra.exceptions.ConfigurationException
dup
new java.lang.StringBuilder
dup
ldc "unable to locate "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
athrow
4: StackMap locals: java.lang.ClassLoader java.net.URL
StackMap stack:
new java.io.File
dup
aload 2
invokevirtual java.net.URL.getFile:()Ljava/lang/String;
invokespecial java.io.File.<init>:(Ljava/lang/String;)V
invokevirtual java.io.File.getAbsolutePath:()Ljava/lang/String;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 filename Ljava/lang/String;
1 5 1 loader Ljava/lang/ClassLoader;
2 5 2 scpurl Ljava/net/URL;
Exceptions:
throws org.apache.cassandra.exceptions.ConfigurationException
MethodParameters:
Name Flags
filename
public static java.io.File cassandraTriggerDir();
descriptor: ()Ljava/io/File;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=0
0: aconst_null
astore 0
start local 0 1: ldc "cassandra.triggers_dir"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
ifnull 4
2: new java.io.File
dup
ldc "cassandra.triggers_dir"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
invokespecial java.io.File.<init>:(Ljava/lang/String;)V
astore 0
3: goto 7
4: StackMap locals: java.io.File
StackMap stack:
ldc Lorg/apache/cassandra/utils/FBUtilities;
invokevirtual java.lang.Class.getClassLoader:()Ljava/lang/ClassLoader;
ldc "triggers"
invokevirtual java.lang.ClassLoader.getResource:(Ljava/lang/String;)Ljava/net/URL;
astore 1
start local 1 5: aload 1
ifnull 7
6: new java.io.File
dup
aload 1
invokevirtual java.net.URL.getFile:()Ljava/lang/String;
invokespecial java.io.File.<init>:(Ljava/lang/String;)V
astore 0
end local 1 7: StackMap locals:
StackMap stack:
aload 0
ifnull 8
aload 0
invokevirtual java.io.File.exists:()Z
ifne 10
8: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.utils.FBUtilities.logger:Lorg/slf4j/Logger;
ldc "Trigger directory doesn't exist, please create it and try again."
invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;)V
9: aconst_null
areturn
10: StackMap locals:
StackMap stack:
aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 11 0 triggerDir Ljava/io/File;
5 7 1 confDir Ljava/net/URL;
public static java.lang.String getReleaseVersionString();
descriptor: ()Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=4, args_size=0
0: aconst_null
astore 0
aconst_null
astore 1
1: ldc Lorg/apache/cassandra/utils/FBUtilities;
invokevirtual java.lang.Class.getClassLoader:()Ljava/lang/ClassLoader;
ldc "org/apache/cassandra/config/version.properties"
invokevirtual java.lang.ClassLoader.getResourceAsStream:(Ljava/lang/String;)Ljava/io/InputStream;
astore 2
start local 2 2: aload 2
ifnonnull 6
3: ldc "cassandra.releaseVersion"
ldc "Unknown"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
4: aload 2
ifnull 5
aload 2
invokevirtual java.io.InputStream.close:()V
5: StackMap locals: java.lang.Throwable java.lang.Throwable java.io.InputStream
StackMap stack: java.lang.String
areturn
6: StackMap locals:
StackMap stack:
new java.util.Properties
dup
invokespecial java.util.Properties.<init>:()V
astore 3
start local 3 7: aload 3
aload 2
invokevirtual java.util.Properties.load:(Ljava/io/InputStream;)V
8: aload 3
ldc "CassandraVersion"
invokevirtual java.util.Properties.getProperty:(Ljava/lang/String;)Ljava/lang/String;
9: aload 2
ifnull 10
aload 2
invokevirtual java.io.InputStream.close:()V
10: StackMap locals: java.lang.Throwable java.lang.Throwable java.io.InputStream java.util.Properties
StackMap stack: java.lang.String
areturn
end local 3 StackMap locals: java.lang.Throwable java.lang.Throwable java.io.InputStream
StackMap stack: java.lang.Throwable
11: astore 0
12: aload 2
ifnull 13
aload 2
invokevirtual java.io.InputStream.close:()V
end local 2 StackMap locals:
StackMap stack:
13: aload 0
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
14: astore 1
aload 0
ifnonnull 15
aload 1
astore 0
goto 16
StackMap locals:
StackMap stack:
15: aload 0
aload 1
if_acmpeq 16
aload 0
aload 1
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
16: aload 0
athrow
17: StackMap locals:
StackMap stack: java.lang.Exception
astore 0
start local 0 18: aload 0
invokestatic org.apache.cassandra.utils.JVMStabilityInspector.inspectThrowable:(Ljava/lang/Throwable;)V
19: getstatic org.apache.cassandra.utils.FBUtilities.logger:Lorg/slf4j/Logger;
ldc "Unable to load version.properties"
aload 0
invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;Ljava/lang/Throwable;)V
20: ldc "debug version"
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
2 13 2 in Ljava/io/InputStream;
7 11 3 props Ljava/util/Properties;
18 21 0 e Ljava/lang/Exception;
Exception table:
from to target type
2 4 11 any
6 9 11 any
1 5 14 any
6 10 14 any
11 14 14 any
0 5 17 Class java.lang.Exception
6 10 17 Class java.lang.Exception
11 17 17 Class java.lang.Exception
public static java.lang.String getReleaseVersionMajor();
descriptor: ()Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=1, args_size=0
0: invokestatic org.apache.cassandra.utils.FBUtilities.getReleaseVersionString:()Ljava/lang/String;
astore 0
start local 0 1: ldc "Unknown"
aload 0
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 3
2: new java.lang.AssertionError
dup
ldc "Release version is unknown"
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
3: StackMap locals: java.lang.String
StackMap stack:
aload 0
iconst_0
aload 0
bipush 46
invokevirtual java.lang.String.indexOf:(I)I
invokevirtual java.lang.String.substring:(II)Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 4 0 releaseVersion Ljava/lang/String;
public static long timestampMicros();
descriptor: ()J
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=0, args_size=0
0: invokestatic java.lang.System.currentTimeMillis:()J
ldc 1000
lmul
lreturn
LocalVariableTable:
Start End Slot Name Signature
public static int nowInSeconds();
descriptor: ()I
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=0, args_size=0
0: invokestatic java.lang.System.currentTimeMillis:()J
ldc 1000
ldiv
l2i
ireturn
LocalVariableTable:
Start End Slot Name Signature
public static <T> java.util.List<T> waitOnFutures(java.lang.Iterable<? extends java.util.concurrent.Future<? extends T>>);
descriptor: (Ljava/lang/Iterable;)Ljava/util/List;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
ldc -1
aconst_null
invokestatic org.apache.cassandra.utils.FBUtilities.waitOnFutures:(Ljava/lang/Iterable;JLjava/util/concurrent/TimeUnit;)Ljava/util/List;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 futures Ljava/lang/Iterable<+Ljava/util/concurrent/Future<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Ljava/util/concurrent/Future<+TT;>;>;)Ljava/util/List<TT;>;
MethodParameters:
Name Flags
futures
public static <T> java.util.List<T> waitOnFutures(java.lang.Iterable<? extends java.util.concurrent.Future<? extends T>>, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/lang/Iterable;JLjava/util/concurrent/TimeUnit;)Ljava/util/List;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=12, args_size=3
start local 0 start local 1 start local 3 0: lconst_0
lstore 4
start local 4 1: lload 1
lconst_0
lcmp
ifle 3
2: invokestatic java.lang.System.nanoTime:()J
aload 3
lload 1
invokevirtual java.util.concurrent.TimeUnit.toNanos:(J)J
ladd
lstore 4
3: StackMap locals: long
StackMap stack:
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 6
start local 6 4: aconst_null
astore 7
start local 7 5: aload 0
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 9
goto 15
StackMap locals: java.lang.Iterable long java.util.concurrent.TimeUnit long java.util.List java.lang.Throwable top java.util.Iterator
StackMap stack:
6: aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.concurrent.Future
astore 8
start local 8 7: lload 4
lconst_0
lcmp
ifne 10
8: aload 6
aload 8
invokeinterface java.util.concurrent.Future.get:()Ljava/lang/Object;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
9: goto 15
10: StackMap locals: java.lang.Iterable long java.util.concurrent.TimeUnit long java.util.List java.lang.Throwable java.util.concurrent.Future java.util.Iterator
StackMap stack:
lconst_1
lload 4
invokestatic java.lang.System.nanoTime:()J
lsub
invokestatic java.lang.Math.max:(JJ)J
lstore 10
start local 10 11: aload 6
aload 8
lload 10
getstatic java.util.concurrent.TimeUnit.NANOSECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface java.util.concurrent.Future.get:(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 10 12: goto 15
13: StackMap locals:
StackMap stack: java.lang.Throwable
astore 10
start local 10 14: aload 7
aload 10
invokestatic org.apache.cassandra.utils.Throwables.merge:(Ljava/lang/Throwable;Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 7
end local 10 end local 8 15: StackMap locals: java.lang.Iterable long java.util.concurrent.TimeUnit long java.util.List java.lang.Throwable top java.util.Iterator
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
16: aload 7
invokestatic org.apache.cassandra.utils.Throwables.maybeFail:(Ljava/lang/Throwable;)V
17: aload 6
areturn
end local 7 end local 6 end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 futures Ljava/lang/Iterable<+Ljava/util/concurrent/Future<+TT;>;>;
0 18 1 timeout J
0 18 3 units Ljava/util/concurrent/TimeUnit;
1 18 4 endNanos J
4 18 6 results Ljava/util/List<TT;>;
5 18 7 fail Ljava/lang/Throwable;
7 15 8 f Ljava/util/concurrent/Future<+TT;>;
11 12 10 waitFor J
14 15 10 t Ljava/lang/Throwable;
Exception table:
from to target type
7 12 13 Class java.lang.Throwable
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Ljava/util/concurrent/Future<+TT;>;>;JLjava/util/concurrent/TimeUnit;)Ljava/util/List<TT;>;
MethodParameters:
Name Flags
futures
timeout
units
public static <T> T waitOnFuture(java.util.concurrent.Future<T>);
descriptor: (Ljava/util/concurrent/Future;)Ljava/lang/Object;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
invokeinterface java.util.concurrent.Future.get:()Ljava/lang/Object;
1: areturn
2: StackMap locals:
StackMap stack: java.util.concurrent.ExecutionException
astore 1
start local 1 3: new java.lang.RuntimeException
dup
aload 1
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 1 4: StackMap locals:
StackMap stack: java.lang.InterruptedException
astore 1
start local 1 5: new java.lang.AssertionError
dup
aload 1
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 future Ljava/util/concurrent/Future<TT;>;
3 4 1 ee Ljava/util/concurrent/ExecutionException;
5 6 1 ie Ljava/lang/InterruptedException;
Exception table:
from to target type
0 1 2 Class java.util.concurrent.ExecutionException
0 1 4 Class java.lang.InterruptedException
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/Future<TT;>;)TT;
MethodParameters:
Name Flags
future
public static void waitOnFutures(java.util.List<org.apache.cassandra.net.AsyncOneResponse>, );
descriptor: (Ljava/util/List;J)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=5, args_size=2
start local 0 start local 1 0: aload 0
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 4
goto 3
StackMap locals: java.util.List long top java.util.Iterator
StackMap stack:
1: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.net.AsyncOneResponse
astore 3
start local 3 2: aload 3
lload 1
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokevirtual org.apache.cassandra.net.AsyncOneResponse.get:(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;
pop
end local 3 3: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 results Ljava/util/List<Lorg/apache/cassandra/net/AsyncOneResponse;>;
0 5 1 ms J
2 3 3 result Lorg/apache/cassandra/net/AsyncOneResponse;
Exceptions:
throws java.util.concurrent.TimeoutException
Signature: (Ljava/util/List<Lorg/apache/cassandra/net/AsyncOneResponse;>;J)V
MethodParameters:
Name Flags
results
ms
public static <T> java.util.concurrent.Future<? extends T> waitOnFirstFuture(java.lang.Iterable<? extends java.util.concurrent.Future<? extends T>>);
descriptor: (Ljava/lang/Iterable;)Ljava/util/concurrent/Future;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc 100
invokestatic org.apache.cassandra.utils.FBUtilities.waitOnFirstFuture:(Ljava/lang/Iterable;J)Ljava/util/concurrent/Future;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 futures Ljava/lang/Iterable<+Ljava/util/concurrent/Future<+TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Ljava/util/concurrent/Future<+TT;>;>;)Ljava/util/concurrent/Future<+TT;>;
MethodParameters:
Name Flags
futures
public static <T> java.util.concurrent.Future<? extends T> waitOnFirstFuture(java.lang.Iterable<? extends java.util.concurrent.Future<? extends T>>, long);
descriptor: (Ljava/lang/Iterable;J)Ljava/util/concurrent/Future;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=6, args_size=2
start local 0 start local 1 0: StackMap locals:
StackMap stack:
aload 0
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 4
goto 10
StackMap locals: java.lang.Iterable long top java.util.Iterator
StackMap stack:
1: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.concurrent.Future
astore 3
start local 3 2: aload 3
invokeinterface java.util.concurrent.Future.isDone:()Z
ifeq 10
3: aload 3
invokeinterface java.util.concurrent.Future.get:()Ljava/lang/Object;
pop
4: goto 9
5: StackMap locals: java.lang.Iterable long java.util.concurrent.Future java.util.Iterator
StackMap stack: java.lang.InterruptedException
astore 5
start local 5 6: new java.lang.AssertionError
dup
aload 5
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
end local 5 7: StackMap locals:
StackMap stack: java.util.concurrent.ExecutionException
astore 5
start local 5 8: new java.lang.RuntimeException
dup
aload 5
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 5 9: StackMap locals:
StackMap stack:
aload 3
areturn
end local 3 10: StackMap locals: java.lang.Iterable long top java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
11: lload 1
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokestatic com.google.common.util.concurrent.Uninterruptibles.sleepUninterruptibly:(JLjava/util/concurrent/TimeUnit;)V
12: goto 0
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 futures Ljava/lang/Iterable<+Ljava/util/concurrent/Future<+TT;>;>;
0 13 1 delay J
2 10 3 f Ljava/util/concurrent/Future<+TT;>;
6 7 5 e Ljava/lang/InterruptedException;
8 9 5 e Ljava/util/concurrent/ExecutionException;
Exception table:
from to target type
3 4 5 Class java.lang.InterruptedException
3 4 7 Class java.util.concurrent.ExecutionException
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Iterable<+Ljava/util/concurrent/Future<+TT;>;>;J)Ljava/util/concurrent/Future<+TT;>;
MethodParameters:
Name Flags
futures
delay
public static org.apache.cassandra.dht.IPartitioner newPartitioner(org.apache.cassandra.io.sstable.Descriptor);
descriptor: (Lorg/apache/cassandra/io/sstable/Descriptor;)Lorg/apache/cassandra/dht/IPartitioner;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=5, args_size=1
start local 0 0: getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.VALIDATION:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.HEADER:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokestatic java.util.EnumSet.of:(Ljava/lang/Enum;Ljava/lang/Enum;)Ljava/util/EnumSet;
astore 1
start local 1 1: aload 0
invokevirtual org.apache.cassandra.io.sstable.Descriptor.getMetadataSerializer:()Lorg/apache/cassandra/io/sstable/metadata/IMetadataSerializer;
aload 0
aload 1
invokeinterface org.apache.cassandra.io.sstable.metadata.IMetadataSerializer.deserialize:(Lorg/apache/cassandra/io/sstable/Descriptor;Ljava/util/EnumSet;)Ljava/util/Map;
astore 2
start local 2 2: aload 2
getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.VALIDATION:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.io.sstable.metadata.ValidationMetadata
astore 3
start local 3 3: aload 2
getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.HEADER:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.SerializationHeader$Component
astore 4
start local 4 4: aload 3
getfield org.apache.cassandra.io.sstable.metadata.ValidationMetadata.partitioner:Ljava/lang/String;
aload 4
invokevirtual org.apache.cassandra.db.SerializationHeader$Component.getKeyType:()Lorg/apache/cassandra/db/marshal/AbstractType;
invokestatic java.util.Optional.of:(Ljava/lang/Object;)Ljava/util/Optional;
invokestatic org.apache.cassandra.utils.FBUtilities.newPartitioner:(Ljava/lang/String;Ljava/util/Optional;)Lorg/apache/cassandra/dht/IPartitioner;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 desc Lorg/apache/cassandra/io/sstable/Descriptor;
1 5 1 types Ljava/util/EnumSet<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;>;
2 5 2 sstableMetadata Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;
3 5 3 validationMetadata Lorg/apache/cassandra/io/sstable/metadata/ValidationMetadata;
4 5 4 header Lorg/apache/cassandra/db/SerializationHeader$Component;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
desc
public static org.apache.cassandra.dht.IPartitioner newPartitioner(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/dht/IPartitioner;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokestatic java.util.Optional.empty:()Ljava/util/Optional;
invokestatic org.apache.cassandra.utils.FBUtilities.newPartitioner:(Ljava/lang/String;Ljava/util/Optional;)Lorg/apache/cassandra/dht/IPartitioner;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 partitionerClassName Ljava/lang/String;
Exceptions:
throws org.apache.cassandra.exceptions.ConfigurationException
MethodParameters:
Name Flags
partitionerClassName
static org.apache.cassandra.dht.IPartitioner newPartitioner(java.lang.String, java.util.Optional<org.apache.cassandra.db.marshal.AbstractType<?>>);
descriptor: (Ljava/lang/String;Ljava/util/Optional;)Lorg/apache/cassandra/dht/IPartitioner;
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
ldc "."
invokevirtual java.lang.String.contains:(Ljava/lang/CharSequence;)Z
ifne 2
1: new java.lang.StringBuilder
dup
ldc "org.apache.cassandra.dht."
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 0
2: StackMap locals:
StackMap stack:
aload 0
ldc "org.apache.cassandra.dht.LocalPartitioner"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 5
3: getstatic org.apache.cassandra.utils.FBUtilities.$assertionsDisabled:Z
ifne 4
aload 1
invokevirtual java.util.Optional.isPresent:()Z
ifne 4
new java.lang.AssertionError
dup
ldc "Expected a comparator for local partitioner"
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
4: StackMap locals:
StackMap stack:
new org.apache.cassandra.dht.LocalPartitioner
dup
aload 1
invokevirtual java.util.Optional.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.marshal.AbstractType
invokespecial org.apache.cassandra.dht.LocalPartitioner.<init>:(Lorg/apache/cassandra/db/marshal/AbstractType;)V
areturn
5: StackMap locals:
StackMap stack:
aload 0
ldc "partitioner"
invokestatic org.apache.cassandra.utils.FBUtilities.instanceOrConstruct:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;
checkcast org.apache.cassandra.dht.IPartitioner
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 partitionerClassName Ljava/lang/String;
0 6 1 comparator Ljava/util/Optional<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;
Exceptions:
throws org.apache.cassandra.exceptions.ConfigurationException
Signature: (Ljava/lang/String;Ljava/util/Optional<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;)Lorg/apache/cassandra/dht/IPartitioner;
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
partitionerClassName
comparator
public static org.apache.cassandra.auth.IAuthorizer newAuthorizer(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/auth/IAuthorizer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "."
invokevirtual java.lang.String.contains:(Ljava/lang/CharSequence;)Z
ifne 2
1: new java.lang.StringBuilder
dup
ldc "org.apache.cassandra.auth."
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 0
2: StackMap locals:
StackMap stack:
aload 0
ldc "authorizer"
invokestatic org.apache.cassandra.utils.FBUtilities.construct:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;
checkcast org.apache.cassandra.auth.IAuthorizer
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 className Ljava/lang/String;
Exceptions:
throws org.apache.cassandra.exceptions.ConfigurationException
MethodParameters:
Name Flags
className
public static org.apache.cassandra.auth.IAuthenticator newAuthenticator(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/auth/IAuthenticator;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "."
invokevirtual java.lang.String.contains:(Ljava/lang/CharSequence;)Z
ifne 2
1: new java.lang.StringBuilder
dup
ldc "org.apache.cassandra.auth."
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 0
2: StackMap locals:
StackMap stack:
aload 0
ldc "authenticator"
invokestatic org.apache.cassandra.utils.FBUtilities.construct:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;
checkcast org.apache.cassandra.auth.IAuthenticator
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 className Ljava/lang/String;
Exceptions:
throws org.apache.cassandra.exceptions.ConfigurationException
MethodParameters:
Name Flags
className
public static org.apache.cassandra.auth.IRoleManager newRoleManager(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/auth/IRoleManager;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc "."
invokevirtual java.lang.String.contains:(Ljava/lang/CharSequence;)Z
ifne 2
1: new java.lang.StringBuilder
dup
ldc "org.apache.cassandra.auth."
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
astore 0
2: StackMap locals:
StackMap stack:
aload 0
ldc "role manager"
invokestatic org.apache.cassandra.utils.FBUtilities.construct:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;
checkcast org.apache.cassandra.auth.IRoleManager
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 className Ljava/lang/String;
Exceptions:
throws org.apache.cassandra.exceptions.ConfigurationException
MethodParameters:
Name Flags
className
public static <T> java.lang.Class<T> classForName(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Class;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=3, args_size=2
start local 0 start local 1 0: aload 0
invokestatic java.lang.Class.forName:(Ljava/lang/String;)Ljava/lang/Class;
1: areturn
2: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
start local 2 3: new org.apache.cassandra.exceptions.ConfigurationException
dup
ldc "Unable to find %s class '%s'"
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
dup
iconst_1
aload 0
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
aload 2
invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 classname Ljava/lang/String;
0 4 1 readable Ljava/lang/String;
3 4 2 e Ljava/lang/Throwable;
Exception table:
from to target type
0 1 2 Class java.lang.ClassNotFoundException
0 1 2 Class java.lang.NoClassDefFoundError
Exceptions:
throws org.apache.cassandra.exceptions.ConfigurationException
Signature: <T:Ljava/lang/Object;>(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Class<TT;>;
MethodParameters:
Name Flags
classname
readable
public static <T> T instanceOrConstruct(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=4, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic org.apache.cassandra.utils.FBUtilities.classForName:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Class;
astore 2
start local 2 1: aload 2
ldc "instance"
invokevirtual java.lang.Class.getField:(Ljava/lang/String;)Ljava/lang/reflect/Field;
astore 3
start local 3 2: aload 2
aload 3
aconst_null
invokevirtual java.lang.reflect.Field.get:(Ljava/lang/Object;)Ljava/lang/Object;
invokevirtual java.lang.Class.cast:(Ljava/lang/Object;)Ljava/lang/Object;
3: areturn
end local 3 4: StackMap locals: java.lang.String java.lang.String java.lang.Class
StackMap stack: java.lang.Exception
pop
5: aload 2
aload 0
aload 1
invokestatic org.apache.cassandra.utils.FBUtilities.construct:(Ljava/lang/Class;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 classname Ljava/lang/String;
0 6 1 readable Ljava/lang/String;
1 6 2 cls Ljava/lang/Class<TT;>;
2 4 3 instance Ljava/lang/reflect/Field;
Exception table:
from to target type
1 3 4 Class java.lang.NoSuchFieldException
1 3 4 Class java.lang.SecurityException
1 3 4 Class java.lang.IllegalArgumentException
1 3 4 Class java.lang.IllegalAccessException
Exceptions:
throws org.apache.cassandra.exceptions.ConfigurationException
Signature: <T:Ljava/lang/Object;>(Ljava/lang/String;Ljava/lang/String;)TT;
MethodParameters:
Name Flags
classname
readable
public static <T> T construct(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic org.apache.cassandra.utils.FBUtilities.classForName:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Class;
astore 2
start local 2 1: aload 2
aload 0
aload 1
invokestatic org.apache.cassandra.utils.FBUtilities.construct:(Ljava/lang/Class;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 classname Ljava/lang/String;
0 2 1 readable Ljava/lang/String;
1 2 2 cls Ljava/lang/Class<TT;>;
Exceptions:
throws org.apache.cassandra.exceptions.ConfigurationException
Signature: <T:Ljava/lang/Object;>(Ljava/lang/String;Ljava/lang/String;)TT;
MethodParameters:
Name Flags
classname
readable
private static <T> T construct(java.lang.Class<T>, java.lang.String, java.lang.String);
descriptor: (Ljava/lang/Class;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=7, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual java.lang.Class.newInstance:()Ljava/lang/Object;
1: areturn
2: StackMap locals:
StackMap stack: java.lang.IllegalAccessException
pop
3: new org.apache.cassandra.exceptions.ConfigurationException
dup
ldc "Default constructor for %s class '%s' is inaccessible."
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 2
aastore
dup
iconst_1
aload 1
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
4: StackMap locals:
StackMap stack: java.lang.InstantiationException
pop
5: new org.apache.cassandra.exceptions.ConfigurationException
dup
ldc "Cannot use abstract class '%s' as %s."
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
dup
iconst_1
aload 2
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
athrow
6: StackMap locals:
StackMap stack: java.lang.Exception
astore 3
start local 3 7: aload 3
invokevirtual java.lang.Exception.getCause:()Ljava/lang/Throwable;
instanceof org.apache.cassandra.exceptions.ConfigurationException
ifeq 9
8: aload 3
invokevirtual java.lang.Exception.getCause:()Ljava/lang/Throwable;
checkcast org.apache.cassandra.exceptions.ConfigurationException
athrow
9: StackMap locals: java.lang.Exception
StackMap stack:
new org.apache.cassandra.exceptions.ConfigurationException
dup
ldc "Error instantiating %s class '%s'."
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 2
aastore
dup
iconst_1
aload 1
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
aload 3
invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
athrow
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 cls Ljava/lang/Class<TT;>;
0 10 1 classname Ljava/lang/String;
0 10 2 readable Ljava/lang/String;
7 10 3 e Ljava/lang/Exception;
Exception table:
from to target type
0 1 2 Class java.lang.IllegalAccessException
0 1 4 Class java.lang.InstantiationException
0 1 6 Class java.lang.Exception
Exceptions:
throws org.apache.cassandra.exceptions.ConfigurationException
Signature: <T:Ljava/lang/Object;>(Ljava/lang/Class<TT;>;Ljava/lang/String;Ljava/lang/String;)TT;
MethodParameters:
Name Flags
cls
classname
readable
public static <T> java.util.NavigableSet<T> singleton(T, java.util.Comparator<? super T>);
descriptor: (Ljava/lang/Object;Ljava/util/Comparator;)Ljava/util/NavigableSet;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: new java.util.TreeSet
dup
aload 1
invokespecial java.util.TreeSet.<init>:(Ljava/util/Comparator;)V
astore 2
start local 2 1: aload 2
aload 0
invokeinterface java.util.NavigableSet.add:(Ljava/lang/Object;)Z
pop
2: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 column TT;
0 3 1 comparator Ljava/util/Comparator<-TT;>;
1 3 2 s Ljava/util/NavigableSet<TT;>;
Signature: <T:Ljava/lang/Object;>(TT;Ljava/util/Comparator<-TT;>;)Ljava/util/NavigableSet<TT;>;
MethodParameters:
Name Flags
column
comparator
public static <T> java.util.NavigableSet<T> emptySortedSet(java.util.Comparator<? super T>);
descriptor: (Ljava/util/Comparator;)Ljava/util/NavigableSet;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.util.TreeSet
dup
aload 0
invokespecial java.util.TreeSet.<init>:(Ljava/util/Comparator;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 comparator Ljava/util/Comparator<-TT;>;
Signature: <T:Ljava/lang/Object;>(Ljava/util/Comparator<-TT;>;)Ljava/util/NavigableSet<TT;>;
MethodParameters:
Name Flags
comparator
public static java.lang.String toString(java.util.Map<?, ?>);
descriptor: (Ljava/util/Map;)Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
ifnonnull 2
1: ldc ""
areturn
2: StackMap locals:
StackMap stack:
ldc ", "
invokestatic com.google.common.base.Joiner.on:(Ljava/lang/String;)Lcom/google/common/base/Joiner;
ldc ":"
invokevirtual com.google.common.base.Joiner.withKeyValueSeparator:(Ljava/lang/String;)Lcom/google/common/base/Joiner$MapJoiner;
astore 1
start local 1 3: aload 1
aload 0
invokevirtual com.google.common.base.Joiner$MapJoiner.join:(Ljava/util/Map;)Ljava/lang/String;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 map Ljava/util/Map<**>;
3 4 1 joiner Lcom/google/common/base/Joiner$MapJoiner;
Signature: (Ljava/util/Map<**>;)Ljava/lang/String;
RuntimeVisibleAnnotations:
javax.annotation.Nonnull()
RuntimeVisibleTypeAnnotations:
METHOD_FORMAL_PARAMETER
javax.annotation.Nullable()
METHOD_RETURN
javax.annotation.Nonnull()
RuntimeVisibleParameterAnnotations:
0:
javax.annotation.Nullable()
MethodParameters:
Name Flags
map
public static java.lang.reflect.Field getProtectedField(java.lang.Class, java.lang.String);
descriptor: (Ljava/lang/Class;Ljava/lang/String;)Ljava/lang/reflect/Field;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual java.lang.Class.getDeclaredField:(Ljava/lang/String;)Ljava/lang/reflect/Field;
astore 2
start local 2 1: aload 2
iconst_1
invokevirtual java.lang.reflect.Field.setAccessible:(Z)V
2: aload 2
3: areturn
end local 2 4: StackMap locals:
StackMap stack: java.lang.Exception
astore 2
start local 2 5: new java.lang.AssertionError
dup
aload 2
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 klass Ljava/lang/Class;
0 6 1 fieldName Ljava/lang/String;
1 4 2 field Ljava/lang/reflect/Field;
5 6 2 e Ljava/lang/Exception;
Exception table:
from to target type
0 3 4 Class java.lang.Exception
MethodParameters:
Name Flags
klass
fieldName
public static <T> org.apache.cassandra.utils.CloseableIterator<T> closeableIterator(java.util.Iterator<T>);
descriptor: (Ljava/util/Iterator;)Lorg/apache/cassandra/utils/CloseableIterator;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new org.apache.cassandra.utils.FBUtilities$WrappedCloseableIterator
dup
aload 0
invokespecial org.apache.cassandra.utils.FBUtilities$WrappedCloseableIterator.<init>:(Ljava/util/Iterator;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 iterator Ljava/util/Iterator<TT;>;
Signature: <T:Ljava/lang/Object;>(Ljava/util/Iterator<TT;>;)Lorg/apache/cassandra/utils/CloseableIterator<TT;>;
MethodParameters:
Name Flags
iterator
public static java.util.Map<java.lang.String, java.lang.String> fromJsonMap(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/util/Map;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: getstatic org.apache.cassandra.utils.FBUtilities.jsonMapper:Lorg/codehaus/jackson/map/ObjectMapper;
aload 0
ldc Ljava/util/Map;
invokevirtual org.codehaus.jackson.map.ObjectMapper.readValue:(Ljava/lang/String;Ljava/lang/Class;)Ljava/lang/Object;
checkcast java.util.Map
1: areturn
2: StackMap locals:
StackMap stack: java.io.IOException
astore 1
start local 1 3: new java.lang.RuntimeException
dup
aload 1
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 json Ljava/lang/String;
3 4 1 e Ljava/io/IOException;
Exception table:
from to target type
0 1 2 Class java.io.IOException
Signature: (Ljava/lang/String;)Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
MethodParameters:
Name Flags
json
public static java.util.List<java.lang.String> fromJsonList(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/util/List;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: getstatic org.apache.cassandra.utils.FBUtilities.jsonMapper:Lorg/codehaus/jackson/map/ObjectMapper;
aload 0
ldc Ljava/util/List;
invokevirtual org.codehaus.jackson.map.ObjectMapper.readValue:(Ljava/lang/String;Ljava/lang/Class;)Ljava/lang/Object;
checkcast java.util.List
1: areturn
2: StackMap locals:
StackMap stack: java.io.IOException
astore 1
start local 1 3: new java.lang.RuntimeException
dup
aload 1
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 json Ljava/lang/String;
3 4 1 e Ljava/io/IOException;
Exception table:
from to target type
0 1 2 Class java.io.IOException
Signature: (Ljava/lang/String;)Ljava/util/List<Ljava/lang/String;>;
MethodParameters:
Name Flags
json
public static java.lang.String json(java.lang.Object);
descriptor: (Ljava/lang/Object;)Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: getstatic org.apache.cassandra.utils.FBUtilities.jsonMapper:Lorg/codehaus/jackson/map/ObjectMapper;
aload 0
invokevirtual org.codehaus.jackson.map.ObjectMapper.writeValueAsString:(Ljava/lang/Object;)Ljava/lang/String;
1: areturn
2: StackMap locals:
StackMap stack: java.io.IOException
astore 1
start local 1 3: new java.lang.RuntimeException
dup
aload 1
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 object Ljava/lang/Object;
3 4 1 e Ljava/io/IOException;
Exception table:
from to target type
0 1 2 Class java.io.IOException
MethodParameters:
Name Flags
object
public static java.lang.String prettyPrintMemory(long);
descriptor: (J)Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: lload 0
iconst_0
invokestatic org.apache.cassandra.utils.FBUtilities.prettyPrintMemory:(JZ)Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 size J
MethodParameters:
Name Flags
size
public static java.lang.String prettyPrintMemory(long, boolean);
descriptor: (JZ)Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=8, locals=3, args_size=2
start local 0 start local 2 0: lload 0
ldc 1073741824
lcmp
iflt 4
1: ldc "%.3f%sGiB"
iconst_2
anewarray java.lang.Object
dup
iconst_0
lload 0
l2d
ldc 1.073741824E9
ddiv
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
dup
iconst_1
iload 2
ifeq 2
ldc " "
goto 3
StackMap locals: long int
StackMap stack: java.lang.String java.lang.Object[] java.lang.Object[] int
2: ldc ""
StackMap locals: long int
StackMap stack: java.lang.String java.lang.Object[] java.lang.Object[] int java.lang.String
3: aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
areturn
4: StackMap locals:
StackMap stack:
lload 0
ldc 1048576
lcmp
iflt 8
5: ldc "%.3f%sMiB"
iconst_2
anewarray java.lang.Object
dup
iconst_0
lload 0
l2d
ldc 1048576.0
ddiv
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
dup
iconst_1
iload 2
ifeq 6
ldc " "
goto 7
StackMap locals: long int
StackMap stack: java.lang.String java.lang.Object[] java.lang.Object[] int
6: ldc ""
StackMap locals: long int
StackMap stack: java.lang.String java.lang.Object[] java.lang.Object[] int java.lang.String
7: aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
areturn
8: StackMap locals:
StackMap stack:
ldc "%.3f%sKiB"
iconst_2
anewarray java.lang.Object
dup
iconst_0
lload 0
l2d
ldc 1024.0
ddiv
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
dup
iconst_1
iload 2
ifeq 9
ldc " "
goto 10
StackMap locals: long int
StackMap stack: java.lang.String java.lang.Object[] java.lang.Object[] int
9: ldc ""
StackMap locals: long int
StackMap stack: java.lang.String java.lang.Object[] java.lang.Object[] int java.lang.String
10: aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
areturn
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 size J
0 11 2 includeSpace Z
MethodParameters:
Name Flags
size
includeSpace
public static java.lang.String prettyPrintMemoryPerSecond(long);
descriptor: (J)Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=8, locals=2, args_size=1
start local 0 0: lload 0
ldc 1073741824
lcmp
iflt 2
1: ldc "%.3fGiB/s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
lload 0
l2d
ldc 1.073741824E9
ddiv
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
2: StackMap locals:
StackMap stack:
lload 0
ldc 1048576
lcmp
iflt 4
3: ldc "%.3fMiB/s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
lload 0
l2d
ldc 1048576.0
ddiv
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
4: StackMap locals:
StackMap stack:
ldc "%.3fKiB/s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
lload 0
l2d
ldc 1024.0
ddiv
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 LocalVariableTable:
Start End Slot Name Signature
0 5 0 rate J
MethodParameters:
Name Flags
rate
public static java.lang.String prettyPrintMemoryPerSecond(long, long);
descriptor: (JJ)Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=6, args_size=2
start local 0 start local 2 0: lload 2
lconst_0
lcmp
ifne 2
1: ldc "NaN KiB/s"
areturn
2: StackMap locals:
StackMap stack:
lload 0
l2d
lload 2
l2d
ddiv
ldc 1000.0
dmul
ldc 1000.0
dmul
ldc 1000.0
dmul
d2l
lstore 4
start local 4 3: lload 4
invokestatic org.apache.cassandra.utils.FBUtilities.prettyPrintMemoryPerSecond:(J)Ljava/lang/String;
areturn
end local 4 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 bytes J
0 4 2 timeInNano J
3 4 4 rate J
MethodParameters:
Name Flags
bytes
timeInNano
public static void exec(java.lang.ProcessBuilder);
descriptor: (Ljava/lang/ProcessBuilder;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=10, args_size=1
start local 0 0: aload 0
invokevirtual java.lang.ProcessBuilder.start:()Ljava/lang/Process;
astore 1
start local 1 1: aload 1
invokevirtual java.lang.Process.waitFor:()I
istore 2
start local 2 2: iload 2
ifeq 31
3: aconst_null
astore 3
aconst_null
astore 4
4: new java.io.BufferedReader
dup
new java.io.InputStreamReader
dup
aload 1
invokevirtual java.lang.Process.getInputStream:()Ljava/io/InputStream;
invokespecial java.io.InputStreamReader.<init>:(Ljava/io/InputStream;)V
invokespecial java.io.BufferedReader.<init>:(Ljava/io/Reader;)V
astore 5
start local 5 5: new java.io.BufferedReader
dup
new java.io.InputStreamReader
dup
aload 1
invokevirtual java.lang.Process.getErrorStream:()Ljava/io/InputStream;
invokespecial java.io.InputStreamReader.<init>:(Ljava/io/InputStream;)V
invokespecial java.io.BufferedReader.<init>:(Ljava/io/Reader;)V
astore 6
start local 6 6: ldc "line.separator"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
astore 7
start local 7 7: new java.lang.StringBuilder
dup
invokespecial java.lang.StringBuilder.<init>:()V
astore 8
start local 8 8: goto 10
start local 9 9: StackMap locals: java.lang.ProcessBuilder java.lang.Process int java.lang.Throwable java.lang.Throwable java.io.BufferedReader java.io.BufferedReader java.lang.String java.lang.StringBuilder java.lang.String
StackMap stack:
aload 8
aload 9
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 7
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
end local 9 10: StackMap locals:
StackMap stack:
aload 5
invokevirtual java.io.BufferedReader.readLine:()Ljava/lang/String;
dup
astore 9
start local 9 11: ifnonnull 9
12: goto 14
13: StackMap locals: java.lang.String
StackMap stack:
aload 8
aload 9
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 7
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
14: StackMap locals:
StackMap stack:
aload 6
invokevirtual java.io.BufferedReader.readLine:()Ljava/lang/String;
dup
astore 9
ifnonnull 13
15: new java.io.IOException
dup
new java.lang.StringBuilder
dup
ldc "Exception while executing the command: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.ProcessBuilder.command:()Ljava/util/List;
ldc " "
invokestatic org.apache.commons.lang3.StringUtils.join:(Ljava/lang/Iterable;Ljava/lang/String;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
16: ldc ", command error Code: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
iload 2
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
17: ldc ", command output: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 8
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
18: invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
athrow
end local 9 end local 8 end local 7 StackMap locals: java.lang.ProcessBuilder java.lang.Process int java.lang.Throwable java.lang.Throwable java.io.BufferedReader java.io.BufferedReader
StackMap stack: java.lang.Throwable
19: astore 3
20: aload 6
ifnull 21
aload 6
invokevirtual java.io.BufferedReader.close:()V
end local 6 StackMap locals:
StackMap stack:
21: aload 3
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
22: astore 4
aload 3
ifnonnull 23
aload 4
astore 3
goto 24
StackMap locals:
StackMap stack:
23: aload 3
aload 4
if_acmpeq 24
aload 3
aload 4
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
24: aload 5
ifnull 25
aload 5
invokevirtual java.io.BufferedReader.close:()V
end local 5 StackMap locals:
StackMap stack:
25: aload 3
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
26: astore 4
aload 3
ifnonnull 27
aload 4
astore 3
goto 28
StackMap locals:
StackMap stack:
27: aload 3
aload 4
if_acmpeq 28
aload 3
aload 4
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
28: aload 3
athrow
end local 2 29: StackMap locals: java.lang.ProcessBuilder java.lang.Process
StackMap stack: java.lang.InterruptedException
astore 2
start local 2 30: new java.lang.AssertionError
dup
aload 2
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
end local 2 31: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 32 0 pb Ljava/lang/ProcessBuilder;
1 32 1 p Ljava/lang/Process;
2 29 2 errCode I
5 25 5 in Ljava/io/BufferedReader;
6 21 6 err Ljava/io/BufferedReader;
7 19 7 lineSep Ljava/lang/String;
8 19 8 sb Ljava/lang/StringBuilder;
9 10 9 str Ljava/lang/String;
11 19 9 str Ljava/lang/String;
30 31 2 e Ljava/lang/InterruptedException;
Exception table:
from to target type
6 19 19 any
5 22 22 any
4 26 26 any
1 29 29 Class java.lang.InterruptedException
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
pb
public static void updateChecksumInt(java.util.zip.Checksum, int);
descriptor: (Ljava/util/zip/Checksum;I)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
bipush 24
iushr
sipush 255
iand
invokeinterface java.util.zip.Checksum.update:(I)V
1: aload 0
iload 1
bipush 16
iushr
sipush 255
iand
invokeinterface java.util.zip.Checksum.update:(I)V
2: aload 0
iload 1
bipush 8
iushr
sipush 255
iand
invokeinterface java.util.zip.Checksum.update:(I)V
3: aload 0
iload 1
iconst_0
iushr
sipush 255
iand
invokeinterface java.util.zip.Checksum.update:(I)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 checksum Ljava/util/zip/Checksum;
0 5 1 v I
MethodParameters:
Name Flags
checksum
v
public static void updateChecksum(java.util.zip.CRC32, java.nio.ByteBuffer, int, int);
descriptor: (Ljava/util/zip/CRC32;Ljava/nio/ByteBuffer;II)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
invokevirtual java.nio.ByteBuffer.position:()I
istore 4
start local 4 1: aload 1
invokevirtual java.nio.ByteBuffer.limit:()I
istore 5
start local 5 2: aload 1
iload 2
invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
iload 2
iload 3
iadd
invokevirtual java.nio.Buffer.limit:(I)Ljava/nio/Buffer;
pop
3: aload 0
aload 1
invokevirtual java.util.zip.CRC32.update:(Ljava/nio/ByteBuffer;)V
4: aload 1
iload 4
invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
iload 5
invokevirtual java.nio.Buffer.limit:(I)Ljava/nio/Buffer;
pop
5: 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 6 0 checksum Ljava/util/zip/CRC32;
0 6 1 buffer Ljava/nio/ByteBuffer;
0 6 2 offset I
0 6 3 length I
1 6 4 position I
2 6 5 limit I
MethodParameters:
Name Flags
checksum
buffer
offset
length
public static void updateChecksum(java.util.zip.CRC32, java.nio.ByteBuffer);
descriptor: (Ljava/util/zip/CRC32;Ljava/nio/ByteBuffer;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual java.nio.ByteBuffer.position:()I
istore 2
start local 2 1: aload 0
aload 1
invokevirtual java.util.zip.CRC32.update:(Ljava/nio/ByteBuffer;)V
2: aload 1
iload 2
invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
pop
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 checksum Ljava/util/zip/CRC32;
0 4 1 buffer Ljava/nio/ByteBuffer;
1 4 2 position I
MethodParameters:
Name Flags
checksum
buffer
public static long abs(long);
descriptor: (J)J
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=1
start local 0 0: lload 0
bipush 63
lshr
lstore 2
start local 2 1: lload 0
lload 2
lxor
lload 2
lsub
lreturn
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 index J
1 2 2 negbit J
MethodParameters:
Name Flags
index
public static <T> byte[] serialize(T, org.apache.cassandra.io.IVersionedSerializer<T>, );
descriptor: (Ljava/lang/Object;Lorg/apache/cassandra/io/IVersionedSerializer;I)[B
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=7, args_size=3
start local 0 start local 1 start local 2 0: aload 1
aload 0
iload 2
invokeinterface org.apache.cassandra.io.IVersionedSerializer.serializedSize:(Ljava/lang/Object;I)J
l2i
istore 3
start local 3 1: aconst_null
astore 4
aconst_null
astore 5
2: new org.apache.cassandra.io.util.DataOutputBufferFixed
dup
iload 3
invokespecial org.apache.cassandra.io.util.DataOutputBufferFixed.<init>:(I)V
astore 6
start local 6 3: aload 1
aload 0
aload 6
iload 2
invokeinterface org.apache.cassandra.io.IVersionedSerializer.serialize:(Ljava/lang/Object;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
4: getstatic org.apache.cassandra.utils.FBUtilities.$assertionsDisabled:Z
ifne 9
aload 6
invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.getLength:()I
iload 3
if_icmpne 5
aload 6
invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.getData:()[B
arraylength
iload 3
if_icmpeq 9
StackMap locals: java.lang.Object org.apache.cassandra.io.IVersionedSerializer int int java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.DataOutputBuffer
StackMap stack:
5: new java.lang.AssertionError
dup
6: ldc "Final buffer length %s to accommodate data size of %s (predicted %s) for %s"
iconst_4
anewarray java.lang.Object
dup
iconst_0
7: aload 6
invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.getData:()[B
arraylength
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
aload 6
invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.getLength:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
iload 3
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_3
aload 0
aastore
8: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
9: StackMap locals:
StackMap stack:
aload 6
invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.getData:()[B
10: aload 6
ifnull 11
aload 6
invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.close:()V
11: StackMap locals:
StackMap stack: byte[]
areturn
StackMap locals:
StackMap stack: java.lang.Throwable
12: astore 4
13: aload 6
ifnull 14
aload 6
invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.close:()V
end local 6 StackMap locals:
StackMap stack:
14: aload 4
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
15: astore 5
aload 4
ifnonnull 16
aload 5
astore 4
goto 17
StackMap locals:
StackMap stack:
16: aload 4
aload 5
if_acmpeq 17
aload 4
aload 5
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
17: aload 4
athrow
18: StackMap locals: java.lang.Object org.apache.cassandra.io.IVersionedSerializer int int
StackMap stack: java.io.IOException
astore 4
start local 4 19: new java.lang.AssertionError
dup
aload 4
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 object TT;
0 20 1 serializer Lorg/apache/cassandra/io/IVersionedSerializer<TT;>;
0 20 2 version I
1 20 3 size I
3 14 6 buffer Lorg/apache/cassandra/io/util/DataOutputBuffer;
19 20 4 e Ljava/io/IOException;
Exception table:
from to target type
3 10 12 any
2 11 15 any
12 15 15 any
1 11 18 Class java.io.IOException
12 18 18 Class java.io.IOException
Signature: <T:Ljava/lang/Object;>(TT;Lorg/apache/cassandra/io/IVersionedSerializer<TT;>;I)[B
MethodParameters:
Name Flags
object
serializer
version
public static long copy(java.io.InputStream, java.io.OutputStream, long);
descriptor: (Ljava/io/InputStream;Ljava/io/OutputStream;J)J
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=9, args_size=3
start local 0 start local 1 start local 2 0: bipush 64
newarray 8
astore 4
start local 4 1: lconst_0
lstore 5
start local 5 2: aload 4
arraylength
istore 7
start local 7 3: StackMap locals: byte[] long int
StackMap stack:
lload 2
aload 4
arraylength
i2l
lload 5
ladd
lcmp
ifge 5
4: lload 2
lload 5
lsub
l2i
istore 7
5: StackMap locals:
StackMap stack:
aload 0
aload 4
iconst_0
iload 7
invokevirtual java.io.InputStream.read:([BII)I
istore 8
start local 8 6: iload 8
iconst_m1
if_icmpne 8
7: goto 11
8: StackMap locals: int
StackMap stack:
aload 1
aload 4
iconst_0
iload 8
invokevirtual java.io.OutputStream.write:([BII)V
9: lload 5
iload 8
i2l
ladd
lstore 5
10: lload 2
lload 5
lcmp
ifne 3
end local 8 11: StackMap locals:
StackMap stack:
lload 5
lreturn
end local 7 end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 from Ljava/io/InputStream;
0 12 1 to Ljava/io/OutputStream;
0 12 2 limit J
1 12 4 buffer [B
2 12 5 copied J
3 12 7 toCopy I
6 11 8 sofar I
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
from
to
limit
public static java.io.File getToolsOutputDirectory();
descriptor: ()Ljava/io/File;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=1, args_size=0
0: new java.io.File
dup
ldc "user.home"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
ldc ".cassandra"
invokespecial java.io.File.<init>:(Ljava/lang/String;Ljava/lang/String;)V
astore 0
start local 0 1: aload 0
invokestatic org.apache.cassandra.io.util.FileUtils.createDirectory:(Ljava/io/File;)V
2: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 3 0 historyDir Ljava/io/File;
public static void updateWithShort(java.security.MessageDigest, int);
descriptor: (Ljava/security/MessageDigest;I)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
bipush 8
ishr
sipush 255
iand
i2b
invokevirtual java.security.MessageDigest.update:(B)V
1: aload 0
iload 1
sipush 255
iand
i2b
invokevirtual java.security.MessageDigest.update:(B)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 digest Ljava/security/MessageDigest;
0 3 1 val I
MethodParameters:
Name Flags
digest
val
public static void updateWithByte(java.security.MessageDigest, int);
descriptor: (Ljava/security/MessageDigest;I)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
sipush 255
iand
i2b
invokevirtual java.security.MessageDigest.update:(B)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 digest Ljava/security/MessageDigest;
0 2 1 val I
MethodParameters:
Name Flags
digest
val
public static void updateWithInt(java.security.MessageDigest, int);
descriptor: (Ljava/security/MessageDigest;I)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
bipush 24
iushr
sipush 255
iand
i2b
invokevirtual java.security.MessageDigest.update:(B)V
1: aload 0
iload 1
bipush 16
iushr
sipush 255
iand
i2b
invokevirtual java.security.MessageDigest.update:(B)V
2: aload 0
iload 1
bipush 8
iushr
sipush 255
iand
i2b
invokevirtual java.security.MessageDigest.update:(B)V
3: aload 0
iload 1
iconst_0
iushr
sipush 255
iand
i2b
invokevirtual java.security.MessageDigest.update:(B)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 digest Ljava/security/MessageDigest;
0 5 1 val I
MethodParameters:
Name Flags
digest
val
public static void updateWithLong(java.security.MessageDigest, long);
descriptor: (Ljava/security/MessageDigest;J)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: aload 0
lload 1
bipush 56
lushr
ldc 255
land
l2i
i2b
invokevirtual java.security.MessageDigest.update:(B)V
1: aload 0
lload 1
bipush 48
lushr
ldc 255
land
l2i
i2b
invokevirtual java.security.MessageDigest.update:(B)V
2: aload 0
lload 1
bipush 40
lushr
ldc 255
land
l2i
i2b
invokevirtual java.security.MessageDigest.update:(B)V
3: aload 0
lload 1
bipush 32
lushr
ldc 255
land
l2i
i2b
invokevirtual java.security.MessageDigest.update:(B)V
4: aload 0
lload 1
bipush 24
lushr
ldc 255
land
l2i
i2b
invokevirtual java.security.MessageDigest.update:(B)V
5: aload 0
lload 1
bipush 16
lushr
ldc 255
land
l2i
i2b
invokevirtual java.security.MessageDigest.update:(B)V
6: aload 0
lload 1
bipush 8
lushr
ldc 255
land
l2i
i2b
invokevirtual java.security.MessageDigest.update:(B)V
7: aload 0
lload 1
iconst_0
lushr
ldc 255
land
l2i
i2b
invokevirtual java.security.MessageDigest.update:(B)V
8: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 digest Ljava/security/MessageDigest;
0 9 1 val J
MethodParameters:
Name Flags
digest
val
public static void updateWithBoolean(java.security.MessageDigest, boolean);
descriptor: (Ljava/security/MessageDigest;Z)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
ifeq 1
iconst_0
goto 2
StackMap locals:
StackMap stack: java.security.MessageDigest
1: iconst_1
StackMap locals: java.security.MessageDigest int
StackMap stack: java.security.MessageDigest int
2: invokestatic org.apache.cassandra.utils.FBUtilities.updateWithByte:(Ljava/security/MessageDigest;I)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 digest Ljava/security/MessageDigest;
0 4 1 val Z
MethodParameters:
Name Flags
digest
val
public static void closeAll(java.util.Collection<? extends java.lang.AutoCloseable>);
descriptor: (Ljava/util/Collection;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=5, args_size=1
start local 0 0: aconst_null
astore 1
start local 1 1: aload 0
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 3
goto 9
StackMap locals: java.util.Collection java.lang.Exception top java.util.Iterator
StackMap stack:
2: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.AutoCloseable
astore 2
start local 2 3: aload 2
invokeinterface java.lang.AutoCloseable.close:()V
4: goto 9
5: StackMap locals: java.util.Collection java.lang.Exception java.lang.AutoCloseable java.util.Iterator
StackMap stack: java.lang.Exception
astore 4
start local 4 6: aload 1
ifnonnull 8
7: aload 4
astore 1
goto 9
8: StackMap locals: java.lang.Exception
StackMap stack:
aload 1
aload 4
invokevirtual java.lang.Exception.addSuppressed:(Ljava/lang/Throwable;)V
end local 4 end local 2 9: StackMap locals: java.util.Collection java.lang.Exception top java.util.Iterator
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
10: aload 1
ifnull 12
11: aload 1
athrow
12: StackMap locals: java.util.Collection java.lang.Exception
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 l Ljava/util/Collection<+Ljava/lang/AutoCloseable;>;
1 13 1 toThrow Ljava/lang/Exception;
3 9 2 c Ljava/lang/AutoCloseable;
6 9 4 e Ljava/lang/Exception;
Exception table:
from to target type
3 4 5 Class java.lang.Exception
Exceptions:
throws java.lang.Exception
Signature: (Ljava/util/Collection<+Ljava/lang/AutoCloseable;>;)V
MethodParameters:
Name Flags
l
public static byte[] toWriteUTFBytes(java.lang.String);
descriptor: (Ljava/lang/String;)[B
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=1
start local 0 0: new java.io.ByteArrayOutputStream
dup
invokespecial java.io.ByteArrayOutputStream.<init>:()V
astore 1
start local 1 1: new java.io.DataOutputStream
dup
aload 1
invokespecial java.io.DataOutputStream.<init>:(Ljava/io/OutputStream;)V
astore 2
start local 2 2: aload 2
aload 0
invokevirtual java.io.DataOutputStream.writeUTF:(Ljava/lang/String;)V
3: aload 2
invokevirtual java.io.DataOutputStream.flush:()V
4: aload 1
invokevirtual java.io.ByteArrayOutputStream.toByteArray:()[B
5: areturn
end local 2 end local 1 6: StackMap locals:
StackMap stack: java.io.IOException
astore 1
start local 1 7: new java.lang.RuntimeException
dup
aload 1
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 s Ljava/lang/String;
1 6 1 baos Ljava/io/ByteArrayOutputStream;
2 6 2 dos Ljava/io/DataOutputStream;
7 8 1 e Ljava/io/IOException;
Exception table:
from to target type
0 5 6 Class java.io.IOException
MethodParameters:
Name Flags
s
public static void sleepQuietly(long);
descriptor: (J)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=1
start local 0 0: lload 0
invokestatic java.lang.Thread.sleep:(J)V
1: goto 4
2: StackMap locals:
StackMap stack: java.lang.InterruptedException
astore 2
start local 2 3: new java.lang.RuntimeException
dup
aload 2
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 2 4: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 millis J
3 4 2 e Ljava/lang/InterruptedException;
Exception table:
from to target type
0 1 2 Class java.lang.InterruptedException
MethodParameters:
Name Flags
millis
public static long align(long, int);
descriptor: (JI)J
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 2 0: lload 0
iload 2
i2l
ladd
iload 2
iconst_1
isub
iconst_m1
ixor
i2l
land
lreturn
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 val J
0 1 2 boundary I
MethodParameters:
Name Flags
val
boundary
protected static void reset();
descriptor: ()V
flags: (0x000c) ACC_PROTECTED, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: aconst_null
putstatic org.apache.cassandra.utils.FBUtilities.localInetAddress:Ljava/net/InetAddress;
1: aconst_null
putstatic org.apache.cassandra.utils.FBUtilities.broadcastInetAddress:Ljava/net/InetAddress;
2: aconst_null
putstatic org.apache.cassandra.utils.FBUtilities.broadcastRpcAddress:Ljava/net/InetAddress;
3: return
LocalVariableTable:
Start End Slot Name Signature
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
}
SourceFile: "FBUtilities.java"
NestMembers:
org.apache.cassandra.utils.FBUtilities$1 org.apache.cassandra.utils.FBUtilities$2 org.apache.cassandra.utils.FBUtilities$WrappedCloseableIterator
InnerClasses:
public final MapJoiner = com.google.common.base.Joiner$MapJoiner of com.google.common.base.Joiner
public Component = org.apache.cassandra.db.SerializationHeader$Component of org.apache.cassandra.db.SerializationHeader
org.apache.cassandra.utils.FBUtilities$1
org.apache.cassandra.utils.FBUtilities$2
private final WrappedCloseableIterator = org.apache.cassandra.utils.FBUtilities$WrappedCloseableIterator of org.apache.cassandra.utils.FBUtilities
FBUtilities
logger: Logger
$assertionsDisabled: boolean
reset(): void