public class org.apache.cassandra.db.commitlog.CommitLogDescriptor
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.db.commitlog.CommitLogDescriptor
super_class: java.lang.Object
{
private static final java.lang.String SEPARATOR;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "-"
private static final java.lang.String FILENAME_PREFIX;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "CommitLog-"
private static final java.lang.String FILENAME_EXTENSION;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: ".log"
private static final java.util.regex.Pattern COMMIT_LOG_FILE_PATTERN;
descriptor: Ljava/util/regex/Pattern;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static final java.lang.String COMPRESSION_PARAMETERS_KEY;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: "compressionParameters"
static final java.lang.String COMPRESSION_CLASS_KEY;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: "compressionClass"
public static final int VERSION_12;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: 2
public static final int VERSION_20;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: 3
public static final int VERSION_21;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: 4
public static final int VERSION_22;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: 5
public static final int VERSION_30;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: 6
public static final int current_version;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: 6
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
final int version;
descriptor: I
flags: (0x0010) ACC_FINAL
public final long id;
descriptor: J
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
public final org.apache.cassandra.config.ParameterizedClass compression;
descriptor: Lorg/apache/cassandra/config/ParameterizedClass;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
private final org.apache.cassandra.security.EncryptionContext encryptionContext;
descriptor: Lorg/apache/cassandra/security/EncryptionContext;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
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.db.commitlog.CommitLogDescriptor.$assertionsDisabled:Z
3: ldc "CommitLog-((\\d+)(-\\d+)?).log"
invokestatic java.util.regex.Pattern.compile:(Ljava/lang/String;)Ljava/util/regex/Pattern;
putstatic org.apache.cassandra.db.commitlog.CommitLogDescriptor.COMMIT_LOG_FILE_PATTERN:Ljava/util/regex/Pattern;
4: return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(int, long, org.apache.cassandra.config.ParameterizedClass, org.apache.cassandra.security.EncryptionContext);
descriptor: (IJLorg/apache/cassandra/config/ParameterizedClass;Lorg/apache/cassandra/security/EncryptionContext;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 4 start local 5 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
iload 1
putfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
2: aload 0
lload 2
putfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
3: aload 0
aload 4
putfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.compression:Lorg/apache/cassandra/config/ParameterizedClass;
4: aload 0
aload 5
putfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.encryptionContext:Lorg/apache/cassandra/security/EncryptionContext;
5: return
end local 5 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
0 6 1 version I
0 6 2 id J
0 6 4 compression Lorg/apache/cassandra/config/ParameterizedClass;
0 6 5 encryptionContext Lorg/apache/cassandra/security/EncryptionContext;
MethodParameters:
Name Flags
version
id
compression
encryptionContext
public void <init>(long, org.apache.cassandra.config.ParameterizedClass, org.apache.cassandra.security.EncryptionContext);
descriptor: (JLorg/apache/cassandra/config/ParameterizedClass;Lorg/apache/cassandra/security/EncryptionContext;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=4
start local 0 start local 1 start local 3 start local 4 0: aload 0
bipush 6
lload 1
aload 3
aload 4
invokespecial org.apache.cassandra.db.commitlog.CommitLogDescriptor.<init>:(IJLorg/apache/cassandra/config/ParameterizedClass;Lorg/apache/cassandra/security/EncryptionContext;)V
1: return
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
0 2 1 id J
0 2 3 compression Lorg/apache/cassandra/config/ParameterizedClass;
0 2 4 encryptionContext Lorg/apache/cassandra/security/EncryptionContext;
MethodParameters:
Name Flags
id
compression
encryptionContext
public static void writeHeader(java.nio.ByteBuffer, org.apache.cassandra.db.commitlog.CommitLogDescriptor);
descriptor: (Ljava/nio/ByteBuffer;Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic java.util.Collections.emptyMap:()Ljava/util/Map;
invokestatic org.apache.cassandra.db.commitlog.CommitLogDescriptor.writeHeader:(Ljava/nio/ByteBuffer;Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;Ljava/util/Map;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 out Ljava/nio/ByteBuffer;
0 2 1 descriptor Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
MethodParameters:
Name Flags
out
descriptor
public static void writeHeader(java.nio.ByteBuffer, org.apache.cassandra.db.commitlog.CommitLogDescriptor, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Ljava/nio/ByteBuffer;Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;Ljava/util/Map;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=6, args_size=3
start local 0 start local 1 start local 2 0: new java.util.zip.CRC32
dup
invokespecial java.util.zip.CRC32.<init>:()V
astore 3
start local 3 1: aload 0
aload 1
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
invokevirtual java.nio.ByteBuffer.putInt:(I)Ljava/nio/ByteBuffer;
pop
2: aload 3
aload 1
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
invokestatic org.apache.cassandra.utils.FBUtilities.updateChecksumInt:(Ljava/util/zip/Checksum;I)V
3: aload 0
aload 1
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
invokevirtual java.nio.ByteBuffer.putLong:(J)Ljava/nio/ByteBuffer;
pop
4: aload 3
aload 1
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
ldc 4294967295
land
l2i
invokestatic org.apache.cassandra.utils.FBUtilities.updateChecksumInt:(Ljava/util/zip/Checksum;I)V
5: aload 3
aload 1
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
bipush 32
lushr
l2i
invokestatic org.apache.cassandra.utils.FBUtilities.updateChecksumInt:(Ljava/util/zip/Checksum;I)V
6: aload 1
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
iconst_5
if_icmplt 18
7: aload 1
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.compression:Lorg/apache/cassandra/config/ParameterizedClass;
aload 1
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.encryptionContext:Lorg/apache/cassandra/security/EncryptionContext;
aload 2
invokestatic org.apache.cassandra.db.commitlog.CommitLogDescriptor.constructParametersString:(Lorg/apache/cassandra/config/ParameterizedClass;Lorg/apache/cassandra/security/EncryptionContext;Ljava/util/Map;)Ljava/lang/String;
astore 4
start local 4 8: aload 4
getstatic java.nio.charset.StandardCharsets.UTF_8:Ljava/nio/charset/Charset;
invokevirtual java.lang.String.getBytes:(Ljava/nio/charset/Charset;)[B
astore 5
start local 5 9: aload 5
arraylength
aload 5
arraylength
i2s
ldc 65535
iand
if_icmpeq 13
10: new org.apache.cassandra.exceptions.ConfigurationException
dup
ldc "Compression parameters too long, length %d cannot be above 65535."
iconst_1
anewarray java.lang.Object
dup
iconst_0
11: aload 5
arraylength
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
12: 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
13: StackMap locals: java.util.zip.CRC32 java.lang.String byte[]
StackMap stack:
aload 0
aload 5
arraylength
i2s
invokevirtual java.nio.ByteBuffer.putShort:(S)Ljava/nio/ByteBuffer;
pop
14: aload 3
aload 5
arraylength
invokestatic org.apache.cassandra.utils.FBUtilities.updateChecksumInt:(Ljava/util/zip/Checksum;I)V
15: aload 0
aload 5
invokevirtual java.nio.ByteBuffer.put:([B)Ljava/nio/ByteBuffer;
pop
16: aload 3
aload 5
iconst_0
aload 5
arraylength
invokevirtual java.util.zip.CRC32.update:([BII)V
end local 5 end local 4 17: goto 19
18: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.db.commitlog.CommitLogDescriptor.$assertionsDisabled:Z
ifne 19
aload 1
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.compression:Lorg/apache/cassandra/config/ParameterizedClass;
ifnull 19
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
19: StackMap locals:
StackMap stack:
aload 0
aload 3
invokevirtual java.util.zip.CRC32.getValue:()J
l2i
invokevirtual java.nio.ByteBuffer.putInt:(I)Ljava/nio/ByteBuffer;
pop
20: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 out Ljava/nio/ByteBuffer;
0 21 1 descriptor Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
0 21 2 additionalHeaders Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
1 21 3 crc Ljava/util/zip/CRC32;
8 17 4 parametersString Ljava/lang/String;
9 17 5 parametersBytes [B
Signature: (Ljava/nio/ByteBuffer;Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)V
MethodParameters:
Name Flags
out
descriptor
additionalHeaders
static java.lang.String constructParametersString(org.apache.cassandra.config.ParameterizedClass, org.apache.cassandra.security.EncryptionContext, java.util.Map<java.lang.String, java.lang.String>);
descriptor: (Lorg/apache/cassandra/config/ParameterizedClass;Lorg/apache/cassandra/security/EncryptionContext;Ljava/util/Map;)Ljava/lang/String;
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: new java.util.TreeMap
dup
invokespecial java.util.TreeMap.<init>:()V
astore 3
start local 3 1: aload 0
ifnull 4
2: aload 3
ldc "compressionParameters"
aload 0
getfield org.apache.cassandra.config.ParameterizedClass.parameters:Ljava/util/Map;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 3
ldc "compressionClass"
aload 0
getfield org.apache.cassandra.config.ParameterizedClass.class_name:Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: StackMap locals: java.util.Map
StackMap stack:
aload 1
ifnull 6
5: aload 3
aload 1
invokevirtual org.apache.cassandra.security.EncryptionContext.toHeaderParameters:()Ljava/util/Map;
invokeinterface java.util.Map.putAll:(Ljava/util/Map;)V
6: StackMap locals:
StackMap stack:
aload 3
aload 2
invokeinterface java.util.Map.putAll:(Ljava/util/Map;)V
7: aload 3
invokestatic org.json.simple.JSONValue.toJSONString:(Ljava/lang/Object;)Ljava/lang/String;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 compression Lorg/apache/cassandra/config/ParameterizedClass;
0 8 1 encryptionContext Lorg/apache/cassandra/security/EncryptionContext;
0 8 2 additionalHeaders Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
1 8 3 params Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
Signature: (Lorg/apache/cassandra/config/ParameterizedClass;Lorg/apache/cassandra/security/EncryptionContext;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;)Ljava/lang/String;
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
compression
encryptionContext
additionalHeaders
public static org.apache.cassandra.db.commitlog.CommitLogDescriptor fromHeader(java.io.File, org.apache.cassandra.security.EncryptionContext);
descriptor: (Ljava/io/File;Lorg/apache/cassandra/security/EncryptionContext;)Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=5, args_size=2
start local 0 start local 1 0: aconst_null
astore 2
aconst_null
astore 3
1: new java.io.RandomAccessFile
dup
aload 0
ldc "r"
invokespecial java.io.RandomAccessFile.<init>:(Ljava/io/File;Ljava/lang/String;)V
astore 4
start local 4 2: getstatic org.apache.cassandra.db.commitlog.CommitLogDescriptor.$assertionsDisabled:Z
ifne 3
aload 4
invokevirtual java.io.RandomAccessFile.getFilePointer:()J
lconst_0
lcmp
ifeq 3
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
3: StackMap locals: java.lang.Throwable java.lang.Throwable java.io.RandomAccessFile
StackMap stack:
aload 4
aload 1
invokestatic org.apache.cassandra.db.commitlog.CommitLogDescriptor.readHeader:(Ljava/io/DataInput;Lorg/apache/cassandra/security/EncryptionContext;)Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
4: aload 4
ifnull 5
aload 4
invokevirtual java.io.RandomAccessFile.close:()V
5: StackMap locals:
StackMap stack: org.apache.cassandra.db.commitlog.CommitLogDescriptor
areturn
StackMap locals:
StackMap stack: java.lang.Throwable
6: astore 2
7: aload 4
ifnull 8
aload 4
invokevirtual java.io.RandomAccessFile.close:()V
end local 4 StackMap locals:
StackMap stack:
8: aload 2
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
9: astore 3
aload 2
ifnonnull 10
aload 3
astore 2
goto 11
StackMap locals:
StackMap stack:
10: aload 2
aload 3
if_acmpeq 11
aload 2
aload 3
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
11: aload 2
athrow
12: StackMap locals: java.io.File org.apache.cassandra.security.EncryptionContext
StackMap stack: java.io.EOFException
astore 2
start local 2 13: new java.lang.RuntimeException
dup
aload 2
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 2 14: StackMap locals:
StackMap stack: java.io.IOException
astore 2
start local 2 15: new org.apache.cassandra.io.FSReadError
dup
aload 2
aload 0
invokespecial org.apache.cassandra.io.FSReadError.<init>:(Ljava/lang/Throwable;Ljava/io/File;)V
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 file Ljava/io/File;
0 16 1 encryptionContext Lorg/apache/cassandra/security/EncryptionContext;
2 8 4 raf Ljava/io/RandomAccessFile;
13 14 2 e Ljava/io/EOFException;
15 16 2 e Ljava/io/IOException;
Exception table:
from to target type
2 4 6 any
1 5 9 any
6 9 9 any
0 5 12 Class java.io.EOFException
6 12 12 Class java.io.EOFException
0 5 14 Class java.io.IOException
6 12 14 Class java.io.IOException
MethodParameters:
Name Flags
file
encryptionContext
public static org.apache.cassandra.db.commitlog.CommitLogDescriptor readHeader(java.io.DataInput, org.apache.cassandra.security.EncryptionContext);
descriptor: (Ljava/io/DataInput;Lorg/apache/cassandra/security/EncryptionContext;)Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=8, locals=10, args_size=2
start local 0 start local 1 0: new java.util.zip.CRC32
dup
invokespecial java.util.zip.CRC32.<init>:()V
astore 2
start local 2 1: aload 0
invokeinterface java.io.DataInput.readInt:()I
istore 3
start local 3 2: aload 2
iload 3
invokestatic org.apache.cassandra.utils.FBUtilities.updateChecksumInt:(Ljava/util/zip/Checksum;I)V
3: aload 0
invokeinterface java.io.DataInput.readLong:()J
lstore 4
start local 4 4: aload 2
lload 4
ldc 4294967295
land
l2i
invokestatic org.apache.cassandra.utils.FBUtilities.updateChecksumInt:(Ljava/util/zip/Checksum;I)V
5: aload 2
lload 4
bipush 32
lushr
l2i
invokestatic org.apache.cassandra.utils.FBUtilities.updateChecksumInt:(Ljava/util/zip/Checksum;I)V
6: iconst_0
istore 6
start local 6 7: iload 3
iconst_5
if_icmplt 10
8: aload 0
invokeinterface java.io.DataInput.readShort:()S
ldc 65535
iand
istore 6
9: aload 2
iload 6
invokestatic org.apache.cassandra.utils.FBUtilities.updateChecksumInt:(Ljava/util/zip/Checksum;I)V
10: StackMap locals: java.io.DataInput org.apache.cassandra.security.EncryptionContext java.util.zip.CRC32 int long int
StackMap stack:
iload 6
newarray 8
astore 7
start local 7 11: aload 0
aload 7
invokeinterface java.io.DataInput.readFully:([B)V
12: aload 2
aload 7
iconst_0
aload 7
arraylength
invokevirtual java.util.zip.CRC32.update:([BII)V
13: aload 0
invokeinterface java.io.DataInput.readInt:()I
istore 8
start local 8 14: iload 8
aload 2
invokevirtual java.util.zip.CRC32.getValue:()J
l2i
if_icmpne 17
15: new java.lang.String
dup
aload 7
getstatic java.nio.charset.StandardCharsets.UTF_8:Ljava/nio/charset/Charset;
invokespecial java.lang.String.<init>:([BLjava/nio/charset/Charset;)V
invokestatic org.json.simple.JSONValue.parse:(Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.Map
astore 9
start local 9 16: new org.apache.cassandra.db.commitlog.CommitLogDescriptor
dup
iload 3
lload 4
aload 9
invokestatic org.apache.cassandra.db.commitlog.CommitLogDescriptor.parseCompression:(Ljava/util/Map;)Lorg/apache/cassandra/config/ParameterizedClass;
aload 9
aload 1
invokestatic org.apache.cassandra.security.EncryptionContext.createFromMap:(Ljava/util/Map;Lorg/apache/cassandra/security/EncryptionContext;)Lorg/apache/cassandra/security/EncryptionContext;
invokespecial org.apache.cassandra.db.commitlog.CommitLogDescriptor.<init>:(IJLorg/apache/cassandra/config/ParameterizedClass;Lorg/apache/cassandra/security/EncryptionContext;)V
areturn
end local 9 17: StackMap locals: byte[] int
StackMap stack:
aconst_null
areturn
end local 8 end local 7 end local 6 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 input Ljava/io/DataInput;
0 18 1 encryptionContext Lorg/apache/cassandra/security/EncryptionContext;
1 18 2 checkcrc Ljava/util/zip/CRC32;
2 18 3 version I
4 18 4 id J
7 18 6 parametersLength I
11 18 7 parametersBytes [B
14 18 8 crc I
16 17 9 map Ljava/util/Map<**>;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
input
encryptionContext
static org.apache.cassandra.config.ParameterizedClass parseCompression(java.util.Map<?, ?>);
descriptor: (Ljava/util/Map;)Lorg/apache/cassandra/config/ParameterizedClass;
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=3, args_size=1
start local 0 0: aload 0
ifnull 1
aload 0
invokeinterface java.util.Map.isEmpty:()Z
ifeq 2
1: StackMap locals:
StackMap stack:
aconst_null
areturn
2: StackMap locals:
StackMap stack:
aload 0
ldc "compressionClass"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
astore 1
start local 1 3: aload 1
ifnonnull 5
4: aconst_null
areturn
5: StackMap locals: java.lang.String
StackMap stack:
aload 0
ldc "compressionParameters"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.util.Map
astore 2
start local 2 6: new org.apache.cassandra.config.ParameterizedClass
dup
aload 1
aload 2
invokespecial org.apache.cassandra.config.ParameterizedClass.<init>:(Ljava/lang/String;Ljava/util/Map;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 params Ljava/util/Map<**>;
3 7 1 className Ljava/lang/String;
6 7 2 cparams Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
Signature: (Ljava/util/Map<**>;)Lorg/apache/cassandra/config/ParameterizedClass;
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
params
public static org.apache.cassandra.db.commitlog.CommitLogDescriptor fromFileName(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=8, locals=4, args_size=1
start local 0 0: getstatic org.apache.cassandra.db.commitlog.CommitLogDescriptor.COMMIT_LOG_FILE_PATTERN:Ljava/util/regex/Pattern;
aload 0
invokevirtual java.util.regex.Pattern.matcher:(Ljava/lang/CharSequence;)Ljava/util/regex/Matcher;
dup
astore 1
start local 1 1: invokevirtual java.util.regex.Matcher.matches:()Z
ifne 3
2: new java.lang.RuntimeException
dup
new java.lang.StringBuilder
dup
ldc "Cannot parse the version of the file: "
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 java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: java.util.regex.Matcher
StackMap stack:
aload 1
iconst_3
invokevirtual java.util.regex.Matcher.group:(I)Ljava/lang/String;
ifnonnull 5
4: new java.lang.UnsupportedOperationException
dup
ldc "Commitlog segment is too old to open; upgrade to 1.2.5+ first"
invokespecial java.lang.UnsupportedOperationException.<init>:(Ljava/lang/String;)V
athrow
5: StackMap locals:
StackMap stack:
aload 1
iconst_3
invokevirtual java.util.regex.Matcher.group:(I)Ljava/lang/String;
ldc "-"
invokevirtual java.lang.String.split:(Ljava/lang/String;)[Ljava/lang/String;
iconst_1
aaload
invokestatic java.lang.Long.parseLong:(Ljava/lang/String;)J
lstore 2
start local 2 6: new org.apache.cassandra.db.commitlog.CommitLogDescriptor
dup
aload 1
iconst_2
invokevirtual java.util.regex.Matcher.group:(I)Ljava/lang/String;
invokestatic java.lang.Integer.parseInt:(Ljava/lang/String;)I
lload 2
aconst_null
new org.apache.cassandra.security.EncryptionContext
dup
invokespecial org.apache.cassandra.security.EncryptionContext.<init>:()V
invokespecial org.apache.cassandra.db.commitlog.CommitLogDescriptor.<init>:(IJLorg/apache/cassandra/config/ParameterizedClass;Lorg/apache/cassandra/security/EncryptionContext;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 name Ljava/lang/String;
1 7 1 matcher Ljava/util/regex/Matcher;
6 7 2 id J
MethodParameters:
Name Flags
name
public int getMessagingVersion();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
tableswitch { // 2 - 6
2: 1
3: 2
4: 3
5: 4
6: 5
default: 8
}
1: StackMap locals:
StackMap stack:
bipush 6
ireturn
2: StackMap locals:
StackMap stack:
bipush 7
ireturn
3: StackMap locals:
StackMap stack:
bipush 8
ireturn
4: StackMap locals:
StackMap stack:
bipush 9
ireturn
5: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.net.MessagingService.FORCE_3_0_PROTOCOL_VERSION:Z
ifeq 6
bipush 10
goto 7
StackMap locals:
StackMap stack:
6: bipush 11
StackMap locals:
StackMap stack: int
7: ireturn
8: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "Unknown commitlog version "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
public java.lang.String fileName();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.StringBuilder
dup
ldc "CommitLog-"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc "-"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc ".log"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
public static boolean isValid(java.lang.String);
descriptor: (Ljava/lang/String;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.db.commitlog.CommitLogDescriptor.COMMIT_LOG_FILE_PATTERN:Ljava/util/regex/Pattern;
aload 0
invokevirtual java.util.regex.Pattern.matcher:(Ljava/lang/CharSequence;)Ljava/util/regex/Matcher;
invokevirtual java.util.regex.Matcher.matches:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 filename Ljava/lang/String;
MethodParameters:
Name Flags
filename
public org.apache.cassandra.security.EncryptionContext getEncryptionContext();
descriptor: ()Lorg/apache/cassandra/security/EncryptionContext;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.encryptionContext:Lorg/apache/cassandra/security/EncryptionContext;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: new java.lang.StringBuilder
dup
ldc "("
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
ldc ","
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.compression:Lorg/apache/cassandra/config/ParameterizedClass;
ifnull 1
new java.lang.StringBuilder
dup
ldc ","
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.compression:Lorg/apache/cassandra/config/ParameterizedClass;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
goto 2
StackMap locals:
StackMap stack: java.lang.StringBuilder
1: ldc ""
StackMap locals: org.apache.cassandra.db.commitlog.CommitLogDescriptor
StackMap stack: java.lang.StringBuilder java.lang.String
2: invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ")"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
public boolean equals(java.lang.Object);
descriptor: (Ljava/lang/Object;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
instanceof org.apache.cassandra.db.commitlog.CommitLogDescriptor
ifeq 1
aload 0
aload 1
checkcast org.apache.cassandra.db.commitlog.CommitLogDescriptor
invokevirtual org.apache.cassandra.db.commitlog.CommitLogDescriptor.equals:(Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;)Z
ifeq 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
0 2 1 that Ljava/lang/Object;
MethodParameters:
Name Flags
that
public boolean equalsIgnoringCompression(org.apache.cassandra.db.commitlog.CommitLogDescriptor);
descriptor: (Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
aload 1
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.version:I
if_icmpne 1
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
aload 1
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.id:J
lcmp
ifne 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
0 2 1 that Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
MethodParameters:
Name Flags
that
public boolean equals(org.apache.cassandra.db.commitlog.CommitLogDescriptor);
descriptor: (Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual org.apache.cassandra.db.commitlog.CommitLogDescriptor.equalsIgnoringCompression:(Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;)Z
ifeq 3
aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.compression:Lorg/apache/cassandra/config/ParameterizedClass;
aload 1
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.compression:Lorg/apache/cassandra/config/ParameterizedClass;
invokestatic com.google.common.base.Objects.equal:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 3
1: aload 0
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.encryptionContext:Lorg/apache/cassandra/security/EncryptionContext;
aload 1
getfield org.apache.cassandra.db.commitlog.CommitLogDescriptor.encryptionContext:Lorg/apache/cassandra/security/EncryptionContext;
invokestatic com.google.common.base.Objects.equal:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 3
2: iconst_1
ireturn
StackMap locals:
StackMap stack:
3: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
0 4 1 that Lorg/apache/cassandra/db/commitlog/CommitLogDescriptor;
MethodParameters:
Name Flags
that
}
SourceFile: "CommitLogDescriptor.java"