public class org.apache.cassandra.db.lifecycle.LogReplicaSet implements java.lang.AutoCloseable
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.db.lifecycle.LogReplicaSet
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 final java.util.Map<java.io.File, org.apache.cassandra.db.lifecycle.LogReplica> replicasByFile;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/io/File;Lorg/apache/cassandra/db/lifecycle/LogReplica;>;
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/lifecycle/LogReplicaSet;
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.lifecycle.LogReplicaSet.$assertionsDisabled:Z
3: ldc Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.db.lifecycle.LogReplicaSet.logger:Lorg/slf4j/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.LinkedHashMap
dup
invokespecial java.util.LinkedHashMap.<init>:()V
putfield org.apache.cassandra.db.lifecycle.LogReplicaSet.replicasByFile:Ljava/util/Map;
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
private java.util.Collection<org.apache.cassandra.db.lifecycle.LogReplica> replicas();
descriptor: ()Ljava/util/Collection;
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.lifecycle.LogReplicaSet.replicasByFile:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
Signature: ()Ljava/util/Collection<Lorg/apache/cassandra/db/lifecycle/LogReplica;>;
void addReplicas(java.util.List<java.io.File>);
descriptor: (Ljava/util/List;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 0
invokedynamic accept(Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;)Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/lifecycle/LogReplicaSet.addReplica(Ljava/io/File;)V (5)
(Ljava/io/File;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
0 2 1 replicas Ljava/util/List<Ljava/io/File;>;
Signature: (Ljava/util/List<Ljava/io/File;>;)V
MethodParameters:
Name Flags
replicas
void addReplica(java.io.File);
descriptor: (Ljava/io/File;)V
flags: (0x0000)
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual java.io.File.getParentFile:()Ljava/io/File;
astore 2
start local 2 1: getstatic org.apache.cassandra.db.lifecycle.LogReplicaSet.$assertionsDisabled:Z
ifne 2
aload 0
getfield org.apache.cassandra.db.lifecycle.LogReplicaSet.replicasByFile:Ljava/util/Map;
aload 2
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifeq 2
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
2: StackMap locals: java.io.File
StackMap stack:
aload 0
getfield org.apache.cassandra.db.lifecycle.LogReplicaSet.replicasByFile:Ljava/util/Map;
aload 2
aload 1
invokestatic org.apache.cassandra.db.lifecycle.LogReplica.open:(Ljava/io/File;)Lorg/apache/cassandra/db/lifecycle/LogReplica;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: goto 7
4: StackMap locals:
StackMap stack: org.apache.cassandra.io.FSError
astore 3
start local 3 5: getstatic org.apache.cassandra.db.lifecycle.LogReplicaSet.logger:Lorg/slf4j/Logger;
ldc "Failed to open log replica {}"
aload 1
aload 3
invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
6: aload 3
invokestatic org.apache.cassandra.io.util.FileUtils.handleFSErrorAndPropagate:(Lorg/apache/cassandra/io/FSError;)V
end local 3 7: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.db.lifecycle.LogReplicaSet.logger:Lorg/slf4j/Logger;
ldc "Added log file replica {} "
aload 1
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
8: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
0 9 1 file Ljava/io/File;
1 9 2 directory Ljava/io/File;
5 7 3 e Lorg/apache/cassandra/io/FSError;
Exception table:
from to target type
2 3 4 Class org.apache.cassandra.io.FSError
MethodParameters:
Name Flags
file
void maybeCreateReplica(java.io.File, java.lang.String, java.util.Set<org.apache.cassandra.db.lifecycle.LogRecord>);
descriptor: (Ljava/io/File;Ljava/lang/String;Ljava/util/Set;)V
flags: (0x0000)
Code:
stack=6, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield org.apache.cassandra.db.lifecycle.LogReplicaSet.replicasByFile:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic org.apache.cassandra.db.lifecycle.LogReplica.create:(Ljava/io/File;Ljava/lang/String;)Lorg/apache/cassandra/db/lifecycle/LogReplica;
astore 4
start local 4 3: aload 3
aload 4
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic accept(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/lifecycle/LogReplica.append(Lorg/apache/cassandra/db/lifecycle/LogRecord;)V (5)
(Lorg/apache/cassandra/db/lifecycle/LogRecord;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
4: aload 0
getfield org.apache.cassandra.db.lifecycle.LogReplicaSet.replicasByFile:Ljava/util/Map;
aload 1
aload 4
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
5: getstatic org.apache.cassandra.db.lifecycle.LogReplicaSet.logger:Lorg/slf4j/Logger;
ldc "Created new file replica {}"
aload 4
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
end local 4 6: goto 10
7: StackMap locals:
StackMap stack: org.apache.cassandra.io.FSError
astore 4
start local 4 8: getstatic org.apache.cassandra.db.lifecycle.LogReplicaSet.logger:Lorg/slf4j/Logger;
ldc "Failed to create log replica {}/{}"
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
dup
iconst_1
aload 2
aastore
dup
iconst_2
aload 4
aastore
invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;[Ljava/lang/Object;)V
9: aload 4
invokestatic org.apache.cassandra.io.util.FileUtils.handleFSErrorAndPropagate:(Lorg/apache/cassandra/io/FSError;)V
end local 4 10: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
0 11 1 directory Ljava/io/File;
0 11 2 fileName Ljava/lang/String;
0 11 3 records Ljava/util/Set<Lorg/apache/cassandra/db/lifecycle/LogRecord;>;
3 6 4 replica Lorg/apache/cassandra/db/lifecycle/LogReplica;
8 10 4 e Lorg/apache/cassandra/io/FSError;
Exception table:
from to target type
2 6 7 Class org.apache.cassandra.io.FSError
Signature: (Ljava/io/File;Ljava/lang/String;Ljava/util/Set<Lorg/apache/cassandra/db/lifecycle/LogRecord;>;)V
MethodParameters:
Name Flags
directory
fileName
records
java.lang.Throwable syncDirectory(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Ljava/lang/Throwable;
flags: (0x0000)
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 0
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.replicas:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/lifecycle/LogReplicaSet.lambda$2(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction; (6)
(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokestatic org.apache.cassandra.utils.Throwables.perform:(Ljava/lang/Throwable;Ljava/util/stream/Stream;)Ljava/lang/Throwable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
0 1 1 accumulate Ljava/lang/Throwable;
MethodParameters:
Name Flags
accumulate
java.lang.Throwable delete(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Ljava/lang/Throwable;
flags: (0x0000)
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 0
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.replicas:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/lifecycle/LogReplicaSet.lambda$4(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction; (6)
(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokestatic org.apache.cassandra.utils.Throwables.perform:(Ljava/lang/Throwable;Ljava/util/stream/Stream;)Ljava/lang/Throwable;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
0 1 1 accumulate Ljava/lang/Throwable;
MethodParameters:
Name Flags
accumulate
private static boolean isPrefixMatch(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Z
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual java.lang.String.length:()I
aload 1
invokevirtual java.lang.String.length:()I
if_icmplt 2
1: aload 0
aload 1
invokevirtual java.lang.String.startsWith:(Ljava/lang/String;)Z
goto 3
2: StackMap locals:
StackMap stack:
aload 1
aload 0
invokevirtual java.lang.String.startsWith:(Ljava/lang/String;)Z
3: StackMap locals:
StackMap stack: int
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 first Ljava/lang/String;
0 4 1 second Ljava/lang/String;
MethodParameters:
Name Flags
first
second
boolean readRecords(java.util.Set<org.apache.cassandra.db.lifecycle.LogRecord>);
descriptor: (Ljava/util/Set;)Z
flags: (0x0000)
Code:
stack=7, locals=11, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.replicas:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
1: invokestatic java.util.function.Function.identity:()Ljava/util/function/Function;
2: invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/lifecycle/LogReplica.readLines()Ljava/util/List; (5)
(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Ljava/util/List;
3: invokedynamic apply()Ljava/util/function/BinaryOperator;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/lifecycle/LogReplicaSet.lambda$7(Ljava/util/List;Ljava/util/List;)Ljava/util/List; (6)
(Ljava/util/List;Ljava/util/List;)Ljava/util/List;
4: invokedynamic get()Ljava/util/function/Supplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
java/util/LinkedHashMap.<init>()V (8)
()Ljava/util/LinkedHashMap;
5: invokestatic java.util.stream.Collectors.toMap:(Ljava/util/function/Function;Ljava/util/function/Function;Ljava/util/function/BinaryOperator;Ljava/util/function/Supplier;)Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Map
6: astore 2
start local 2 7: aload 2
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
java/util/List.size()I (9 itf)
(Ljava/util/List;)Ljava/lang/Integer;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
iconst_0
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokedynamic apply()Ljava/util/function/BinaryOperator;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
java/lang/Integer.max(II)I (6)
(Ljava/lang/Integer;Ljava/lang/Integer;)Ljava/lang/Integer;
invokeinterface java.util.stream.Stream.reduce:(Ljava/lang/Object;Ljava/util/function/BinaryOperator;)Ljava/lang/Object;
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
istore 3
start local 3 8: iconst_0
istore 4
start local 4 9: goto 61
10: StackMap locals: java.util.Map int int
StackMap stack:
aconst_null
astore 5
start local 5 11: iconst_0
istore 6
start local 6 12: aload 2
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 8
goto 47
StackMap locals: org.apache.cassandra.db.lifecycle.LogReplicaSet java.util.Set java.util.Map int int java.lang.String int top java.util.Iterator
StackMap stack:
13: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 7
start local 7 14: aload 7
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast java.util.List
astore 9
start local 9 15: iload 4
aload 9
invokeinterface java.util.List.size:()I
if_icmplt 17
16: goto 47
17: StackMap locals: org.apache.cassandra.db.lifecycle.LogReplicaSet java.util.Set java.util.Map int int java.lang.String int java.util.Map$Entry java.util.Iterator java.util.List
StackMap stack:
aload 9
iload 4
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast java.lang.String
astore 10
start local 10 18: aload 5
ifnonnull 21
19: aload 10
astore 5
20: goto 47
21: StackMap locals: java.lang.String
StackMap stack:
aload 5
aload 10
invokestatic org.apache.cassandra.db.lifecycle.LogReplicaSet.isPrefixMatch:(Ljava/lang/String;Ljava/lang/String;)Z
ifne 29
22: getstatic org.apache.cassandra.db.lifecycle.LogReplicaSet.logger:Lorg/slf4j/Logger;
ldc "Mismatched line in file {}: got '{}' expected '{}', giving up"
iconst_3
anewarray java.lang.Object
dup
iconst_0
23: aload 7
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.LogReplica
invokevirtual org.apache.cassandra.db.lifecycle.LogReplica.getFileName:()Ljava/lang/String;
aastore
dup
iconst_1
24: aload 10
aastore
dup
iconst_2
25: aload 5
aastore
26: invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;[Ljava/lang/Object;)V
27: aload 7
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.LogReplica
aload 10
ldc "Does not match <%s> in first replica file"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 5
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokevirtual org.apache.cassandra.db.lifecycle.LogReplica.setError:(Ljava/lang/String;Ljava/lang/String;)V
28: iconst_0
ireturn
29: StackMap locals:
StackMap stack:
aload 5
aload 10
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 47
30: iload 4
aload 9
invokeinterface java.util.List.size:()I
iconst_1
isub
if_icmpne 40
31: getstatic org.apache.cassandra.db.lifecycle.LogReplicaSet.logger:Lorg/slf4j/Logger;
ldc "Mismatched last line in file {}: '{}' not the same as '{}'"
iconst_3
anewarray java.lang.Object
dup
iconst_0
32: aload 7
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.LogReplica
invokevirtual org.apache.cassandra.db.lifecycle.LogReplica.getFileName:()Ljava/lang/String;
aastore
dup
iconst_1
33: aload 10
aastore
dup
iconst_2
34: aload 5
aastore
35: invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;[Ljava/lang/Object;)V
36: aload 10
invokevirtual java.lang.String.length:()I
aload 5
invokevirtual java.lang.String.length:()I
if_icmple 38
37: aload 10
astore 5
38: StackMap locals:
StackMap stack:
iconst_1
istore 6
39: goto 47
40: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.db.lifecycle.LogReplicaSet.logger:Lorg/slf4j/Logger;
ldc "Mismatched line in file {}: got '{}' expected '{}', giving up"
iconst_3
anewarray java.lang.Object
dup
iconst_0
41: aload 7
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.LogReplica
invokevirtual org.apache.cassandra.db.lifecycle.LogReplica.getFileName:()Ljava/lang/String;
aastore
dup
iconst_1
42: aload 10
aastore
dup
iconst_2
43: aload 5
aastore
44: invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;[Ljava/lang/Object;)V
45: aload 7
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.lifecycle.LogReplica
aload 10
ldc "Does not match <%s> in first replica file"
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 5
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokevirtual org.apache.cassandra.db.lifecycle.LogReplica.setError:(Ljava/lang/String;Ljava/lang/String;)V
46: iconst_0
ireturn
end local 10 end local 9 end local 7 47: StackMap locals: org.apache.cassandra.db.lifecycle.LogReplicaSet java.util.Set java.util.Map int int java.lang.String int top java.util.Iterator
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 13
48: aload 5
invokestatic org.apache.cassandra.db.lifecycle.LogRecord.make:(Ljava/lang/String;)Lorg/apache/cassandra/db/lifecycle/LogRecord;
astore 7
start local 7 49: aload 1
aload 7
invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
ifeq 53
50: getstatic org.apache.cassandra.db.lifecycle.LogReplicaSet.logger:Lorg/slf4j/Logger;
ldc "Found duplicate record {} for {}, giving up"
aload 7
aload 7
invokevirtual org.apache.cassandra.db.lifecycle.LogRecord.fileName:()Ljava/lang/String;
invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
51: aload 0
aload 7
ldc "Duplicated record"
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.setError:(Lorg/apache/cassandra/db/lifecycle/LogRecord;Ljava/lang/String;)V
52: iconst_0
ireturn
53: StackMap locals: org.apache.cassandra.db.lifecycle.LogReplicaSet java.util.Set java.util.Map int int java.lang.String int org.apache.cassandra.db.lifecycle.LogRecord
StackMap stack:
iload 6
ifeq 55
54: aload 7
invokevirtual org.apache.cassandra.db.lifecycle.LogRecord.setPartial:()V
55: StackMap locals:
StackMap stack:
aload 1
aload 7
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
56: aload 7
invokevirtual org.apache.cassandra.db.lifecycle.LogRecord.isFinal:()Z
ifeq 60
iload 4
iload 3
iconst_1
isub
if_icmpeq 60
57: getstatic org.apache.cassandra.db.lifecycle.LogReplicaSet.logger:Lorg/slf4j/Logger;
ldc "Found too many lines for {}, giving up"
aload 7
invokevirtual org.apache.cassandra.db.lifecycle.LogRecord.fileName:()Ljava/lang/String;
invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Object;)V
58: aload 0
aload 7
ldc "This record should have been the last one in all replicas"
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.setError:(Lorg/apache/cassandra/db/lifecycle/LogRecord;Ljava/lang/String;)V
59: iconst_0
ireturn
end local 7 end local 6 end local 5 60: StackMap locals:
StackMap stack:
iinc 4 1
StackMap locals:
StackMap stack:
61: iload 4
iload 3
if_icmplt 10
end local 4 62: iconst_1
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 63 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
0 63 1 records Ljava/util/Set<Lorg/apache/cassandra/db/lifecycle/LogRecord;>;
7 63 2 linesByReplica Ljava/util/Map<Lorg/apache/cassandra/db/lifecycle/LogReplica;Ljava/util/List<Ljava/lang/String;>;>;
8 63 3 maxNumLines I
9 62 4 i I
11 60 5 firstLine Ljava/lang/String;
12 60 6 partial Z
14 47 7 entry Ljava/util/Map$Entry<Lorg/apache/cassandra/db/lifecycle/LogReplica;Ljava/util/List<Ljava/lang/String;>;>;
15 47 9 currentLines Ljava/util/List<Ljava/lang/String;>;
18 47 10 currentLine Ljava/lang/String;
49 60 7 record Lorg/apache/cassandra/db/lifecycle/LogRecord;
Signature: (Ljava/util/Set<Lorg/apache/cassandra/db/lifecycle/LogRecord;>;)Z
MethodParameters:
Name Flags
records
void setError(org.apache.cassandra.db.lifecycle.LogRecord, java.lang.String);
descriptor: (Lorg/apache/cassandra/db/lifecycle/LogRecord;Ljava/lang/String;)V
flags: (0x0000)
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 1
aload 2
invokevirtual org.apache.cassandra.db.lifecycle.LogRecord.setError:(Ljava/lang/String;)Lorg/apache/cassandra/db/lifecycle/LogRecord;
pop
1: aload 0
aload 1
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.setErrorInReplicas:(Lorg/apache/cassandra/db/lifecycle/LogRecord;)V
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
0 3 1 record Lorg/apache/cassandra/db/lifecycle/LogRecord;
0 3 2 error Ljava/lang/String;
MethodParameters:
Name Flags
record
error
void setErrorInReplicas(org.apache.cassandra.db.lifecycle.LogRecord);
descriptor: (Lorg/apache/cassandra/db/lifecycle/LogRecord;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.replicas:()Ljava/util/Collection;
aload 1
invokedynamic accept(Lorg/apache/cassandra/db/lifecycle/LogRecord;)Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/lifecycle/LogReplicaSet.lambda$11(Lorg/apache/cassandra/db/lifecycle/LogRecord;Lorg/apache/cassandra/db/lifecycle/LogReplica;)V (6)
(Lorg/apache/cassandra/db/lifecycle/LogReplica;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
0 2 1 record Lorg/apache/cassandra/db/lifecycle/LogRecord;
MethodParameters:
Name Flags
record
void printContentsWithAnyErrors(java.lang.StringBuilder);
descriptor: (Ljava/lang/StringBuilder;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.replicas:()Ljava/util/Collection;
aload 1
invokedynamic accept(Ljava/lang/StringBuilder;)Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/lifecycle/LogReplicaSet.lambda$12(Ljava/lang/StringBuilder;Lorg/apache/cassandra/db/lifecycle/LogReplica;)V (6)
(Lorg/apache/cassandra/db/lifecycle/LogReplica;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
0 2 1 str Ljava/lang/StringBuilder;
MethodParameters:
Name Flags
str
void append(org.apache.cassandra.db.lifecycle.LogRecord);
descriptor: (Lorg/apache/cassandra/db/lifecycle/LogRecord;)V
flags: (0x0000)
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aconst_null
aload 0
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.replicas:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
aload 1
invokedynamic apply(Lorg/apache/cassandra/db/lifecycle/LogRecord;)Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/lifecycle/LogReplicaSet.lambda$13(Lorg/apache/cassandra/db/lifecycle/LogRecord;Lorg/apache/cassandra/db/lifecycle/LogReplica;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction; (6)
(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokestatic org.apache.cassandra.utils.Throwables.perform:(Ljava/lang/Throwable;Ljava/util/stream/Stream;)Ljava/lang/Throwable;
astore 2
start local 2 1: aload 2
ifnull 5
2: aload 1
invokevirtual org.apache.cassandra.db.lifecycle.LogRecord.isFinal:()Z
ifeq 3
aload 2
invokevirtual java.lang.Throwable.getSuppressed:()[Ljava/lang/Throwable;
arraylength
aload 0
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.replicas:()Ljava/util/Collection;
invokeinterface java.util.Collection.size:()I
iconst_1
isub
if_icmpne 4
3: StackMap locals: java.lang.Throwable
StackMap stack:
aload 2
invokestatic org.apache.cassandra.utils.Throwables.maybeFail:(Ljava/lang/Throwable;)V
4: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.db.lifecycle.LogReplicaSet.logger:Lorg/slf4j/Logger;
ldc "Failed to add record '{}' to some replicas '{}'"
aload 1
aload 0
invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
5: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
0 6 1 record Lorg/apache/cassandra/db/lifecycle/LogRecord;
1 6 2 err Ljava/lang/Throwable;
MethodParameters:
Name Flags
record
boolean exists();
descriptor: ()Z
flags: (0x0000)
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.replicas:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/lifecycle/LogReplica.exists()Z (5)
(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Ljava/lang/Boolean;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/BinaryOperator;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
java/lang/Boolean.logicalAnd(ZZ)Z (6)
(Ljava/lang/Boolean;Ljava/lang/Boolean;)Ljava/lang/Boolean;
invokeinterface java.util.stream.Stream.reduce:(Ljava/util/function/BinaryOperator;)Ljava/util/Optional;
astore 1
start local 1 1: aload 1
invokevirtual java.util.Optional.isPresent:()Z
ifeq 3
2: aload 1
invokevirtual java.util.Optional.get:()Ljava/lang/Object;
checkcast java.lang.Boolean
invokevirtual java.lang.Boolean.booleanValue:()Z
goto 4
3: StackMap locals: java.util.Optional
StackMap stack:
iconst_0
4: StackMap locals:
StackMap stack: int
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
1 5 1 ret Ljava/util/Optional<Ljava/lang/Boolean;>;
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aconst_null
aload 0
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.replicas:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/lifecycle/LogReplicaSet.lambda$17(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction; (6)
(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokestatic org.apache.cassandra.utils.Throwables.perform:(Ljava/lang/Throwable;Ljava/util/stream/Stream;)Ljava/lang/Throwable;
invokestatic org.apache.cassandra.utils.Throwables.maybeFail:(Ljava/lang/Throwable;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.replicas:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/lifecycle/LogReplica.toString()Ljava/lang/String; (5)
(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Ljava/lang/String;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/BinaryOperator;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
java/lang/String.concat(Ljava/lang/String;)Ljava/lang/String; (5)
(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
invokeinterface java.util.stream.Stream.reduce:(Ljava/util/function/BinaryOperator;)Ljava/util/Optional;
astore 1
start local 1 1: aload 1
invokevirtual java.util.Optional.isPresent:()Z
ifeq 3
2: aload 1
invokevirtual java.util.Optional.get:()Ljava/lang/Object;
checkcast java.lang.String
goto 4
3: StackMap locals: java.util.Optional
StackMap stack:
ldc "[-]"
4: StackMap locals:
StackMap stack: java.lang.String
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
1 5 1 ret Ljava/util/Optional<Ljava/lang/String;>;
java.lang.String getDirectories();
descriptor: ()Ljava/lang/String;
flags: (0x0000)
Code:
stack=3, locals=1, args_size=1
start local 0 0: ldc ", "
aload 0
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.replicas:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/lifecycle/LogReplica.getDirectory()Ljava/lang/String; (5)
(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Ljava/lang/String;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.lang.Iterable
invokestatic java.lang.String.join:(Ljava/lang/CharSequence;Ljava/lang/Iterable;)Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
java.util.List<java.io.File> getFiles();
descriptor: ()Ljava/util/List;
flags: (0x0000)
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.replicas:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/lifecycle/LogReplica.file()Ljava/io/File; (5)
(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Ljava/io/File;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.List
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
Signature: ()Ljava/util/List<Ljava/io/File;>;
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
com.google.common.annotations.VisibleForTesting()
java.util.List<java.lang.String> getFilePaths();
descriptor: ()Ljava/util/List;
flags: (0x0000)
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.db.lifecycle.LogReplicaSet.replicas:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/lifecycle/LogReplica.file()Ljava/io/File; (5)
(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Ljava/io/File;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
java/io/File.getPath()Ljava/lang/String; (5)
(Ljava/io/File;)Ljava/lang/String;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.List
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/db/lifecycle/LogReplicaSet;
Signature: ()Ljava/util/List<Ljava/lang/String;>;
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
com.google.common.annotations.VisibleForTesting()
private static org.apache.cassandra.utils.Throwables$DiscreteAction lambda$2(org.apache.cassandra.db.lifecycle.LogReplica);
descriptor: (Lorg/apache/cassandra/db/lifecycle/LogReplica;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic perform(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()V
org/apache/cassandra/db/lifecycle/LogReplica.syncDirectory()V (5)
()V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 s Lorg/apache/cassandra/db/lifecycle/LogReplica;
private static org.apache.cassandra.utils.Throwables$DiscreteAction lambda$4(org.apache.cassandra.db.lifecycle.LogReplica);
descriptor: (Lorg/apache/cassandra/db/lifecycle/LogReplica;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic perform(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()V
org/apache/cassandra/db/lifecycle/LogReplica.delete()V (5)
()V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 s Lorg/apache/cassandra/db/lifecycle/LogReplica;
private static java.util.List lambda$7(java.util.List, java.util.List);
descriptor: (Ljava/util/List;Ljava/util/List;)Ljava/util/List;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: new java.lang.IllegalStateException
dup
new java.lang.StringBuilder
dup
ldc "Duplicated key: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 k Ljava/util/List<Ljava/lang/String;>;
0 1 1 v Ljava/util/List<Ljava/lang/String;>;
private static void lambda$11(org.apache.cassandra.db.lifecycle.LogRecord, org.apache.cassandra.db.lifecycle.LogReplica);
descriptor: (Lorg/apache/cassandra/db/lifecycle/LogRecord;Lorg/apache/cassandra/db/lifecycle/LogReplica;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 1 0: aload 1
aload 0
getfield org.apache.cassandra.db.lifecycle.LogRecord.raw:Ljava/lang/String;
aload 0
invokevirtual org.apache.cassandra.db.lifecycle.LogRecord.error:()Ljava/lang/String;
invokevirtual org.apache.cassandra.db.lifecycle.LogReplica.setError:(Ljava/lang/String;Ljava/lang/String;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 r Lorg/apache/cassandra/db/lifecycle/LogReplica;
private static void lambda$12(java.lang.StringBuilder, org.apache.cassandra.db.lifecycle.LogReplica);
descriptor: (Ljava/lang/StringBuilder;Lorg/apache/cassandra/db/lifecycle/LogReplica;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
aload 0
invokevirtual org.apache.cassandra.db.lifecycle.LogReplica.printContentsWithAnyErrors:(Ljava/lang/StringBuilder;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 r Lorg/apache/cassandra/db/lifecycle/LogReplica;
private static org.apache.cassandra.utils.Throwables$DiscreteAction lambda$13(org.apache.cassandra.db.lifecycle.LogRecord, org.apache.cassandra.db.lifecycle.LogReplica);
descriptor: (Lorg/apache/cassandra/db/lifecycle/LogRecord;Lorg/apache/cassandra/db/lifecycle/LogReplica;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
aload 0
invokedynamic perform(Lorg/apache/cassandra/db/lifecycle/LogReplica;Lorg/apache/cassandra/db/lifecycle/LogRecord;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()V
org/apache/cassandra/db/lifecycle/LogReplicaSet.lambda$14(Lorg/apache/cassandra/db/lifecycle/LogReplica;Lorg/apache/cassandra/db/lifecycle/LogRecord;)V (6)
()V
areturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 r Lorg/apache/cassandra/db/lifecycle/LogReplica;
private static org.apache.cassandra.utils.Throwables$DiscreteAction lambda$17(org.apache.cassandra.db.lifecycle.LogReplica);
descriptor: (Lorg/apache/cassandra/db/lifecycle/LogReplica;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic perform(Lorg/apache/cassandra/db/lifecycle/LogReplica;)Lorg/apache/cassandra/utils/Throwables$DiscreteAction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()V
org/apache/cassandra/db/lifecycle/LogReplica.close()V (5)
()V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 r Lorg/apache/cassandra/db/lifecycle/LogReplica;
private static void lambda$14(org.apache.cassandra.db.lifecycle.LogReplica, org.apache.cassandra.db.lifecycle.LogRecord);
descriptor: (Lorg/apache/cassandra/db/lifecycle/LogReplica;Lorg/apache/cassandra/db/lifecycle/LogRecord;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual org.apache.cassandra.db.lifecycle.LogReplica.append:(Lorg/apache/cassandra/db/lifecycle/LogRecord;)V
return
LocalVariableTable:
Start End Slot Name Signature
Exceptions:
throws java.lang.Exception
}
SourceFile: "LogReplicaSet.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Entry = java.util.Map$Entry of java.util.Map
public abstract DiscreteAction = org.apache.cassandra.utils.Throwables$DiscreteAction of org.apache.cassandra.utils.Throwables