class org.apache.cassandra.scheduler.WeightedQueue
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.apache.cassandra.scheduler.WeightedQueue
super_class: java.lang.Object
{
private final org.apache.cassandra.metrics.LatencyMetrics metric;
descriptor: Lorg/apache/cassandra/metrics/LatencyMetrics;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
public final java.lang.String key;
descriptor: Ljava/lang/String;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
public final int weight;
descriptor: I
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
private final java.util.concurrent.SynchronousQueue<org.apache.cassandra.scheduler.WeightedQueue$Entry> queue;
descriptor: Ljava/util/concurrent/SynchronousQueue;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/SynchronousQueue<Lorg/apache/cassandra/scheduler/WeightedQueue$Entry;>;
public void <init>(java.lang.String, int);
descriptor: (Ljava/lang/String;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield org.apache.cassandra.scheduler.WeightedQueue.key:Ljava/lang/String;
2: aload 0
iload 2
putfield org.apache.cassandra.scheduler.WeightedQueue.weight:I
3: aload 0
new java.util.concurrent.SynchronousQueue
dup
iconst_1
invokespecial java.util.concurrent.SynchronousQueue.<init>:(Z)V
putfield org.apache.cassandra.scheduler.WeightedQueue.queue:Ljava/util/concurrent/SynchronousQueue;
4: aload 0
new org.apache.cassandra.metrics.LatencyMetrics
dup
ldc "scheduler"
ldc "WeightedQueue"
aload 1
invokespecial org.apache.cassandra.metrics.LatencyMetrics.<init>:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
putfield org.apache.cassandra.scheduler.WeightedQueue.metric:Lorg/apache/cassandra/metrics/LatencyMetrics;
5: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/scheduler/WeightedQueue;
0 6 1 key Ljava/lang/String;
0 6 2 weight I
MethodParameters:
Name Flags
key
weight
public void put(java.lang.Thread, long);
descriptor: (Ljava/lang/Thread;J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.scheduler.WeightedQueue.queue:Ljava/util/concurrent/SynchronousQueue;
new org.apache.cassandra.scheduler.WeightedQueue$Entry
dup
aload 1
invokespecial org.apache.cassandra.scheduler.WeightedQueue$Entry.<init>:(Ljava/lang/Thread;)V
lload 2
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokevirtual java.util.concurrent.SynchronousQueue.offer:(Ljava/lang/Object;JLjava/util/concurrent/TimeUnit;)Z
ifne 2
1: new java.util.concurrent.TimeoutException
dup
new java.lang.StringBuilder
dup
ldc "Failed to acquire request scheduler slot for '"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.apache.cassandra.scheduler.WeightedQueue.key:Ljava/lang/String;
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;
invokespecial java.util.concurrent.TimeoutException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/scheduler/WeightedQueue;
0 3 1 t Ljava/lang/Thread;
0 3 2 timeoutMS J
Exceptions:
throws java.lang.InterruptedException, java.util.concurrent.TimeoutException
MethodParameters:
Name Flags
t
timeoutMS
public java.lang.Thread poll();
descriptor: ()Ljava/lang/Thread;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.scheduler.WeightedQueue.queue:Ljava/util/concurrent/SynchronousQueue;
invokevirtual java.util.concurrent.SynchronousQueue.poll:()Ljava/lang/Object;
checkcast org.apache.cassandra.scheduler.WeightedQueue$Entry
astore 1
start local 1 1: aload 1
ifnonnull 3
2: aconst_null
areturn
3: StackMap locals: org.apache.cassandra.scheduler.WeightedQueue$Entry
StackMap stack:
aload 0
getfield org.apache.cassandra.scheduler.WeightedQueue.metric:Lorg/apache/cassandra/metrics/LatencyMetrics;
invokestatic java.lang.System.nanoTime:()J
aload 1
getfield org.apache.cassandra.scheduler.WeightedQueue$Entry.creationTime:J
lsub
invokevirtual org.apache.cassandra.metrics.LatencyMetrics.addNano:(J)V
4: aload 1
getfield org.apache.cassandra.scheduler.WeightedQueue$Entry.thread:Ljava/lang/Thread;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/scheduler/WeightedQueue;
1 5 1 e Lorg/apache/cassandra/scheduler/WeightedQueue$Entry;
public java.lang.String toString();
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 "RoundRobinScheduler.WeightedQueue(key="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
getfield org.apache.cassandra.scheduler.WeightedQueue.key:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " weight="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.scheduler.WeightedQueue.weight:I
invokevirtual java.lang.StringBuilder.append:(I)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 1 0 this Lorg/apache/cassandra/scheduler/WeightedQueue;
}
SourceFile: "WeightedQueue.java"
NestMembers:
org.apache.cassandra.scheduler.WeightedQueue$Entry
InnerClasses:
private final Entry = org.apache.cassandra.scheduler.WeightedQueue$Entry of org.apache.cassandra.scheduler.WeightedQueue