class org.ehcache.impl.internal.events.InvocationScopedEventSink<K, V> implements org.ehcache.impl.internal.events.CloseableStoreEventSink<K, V>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.ehcache.impl.internal.events.InvocationScopedEventSink
super_class: java.lang.Object
{
private final java.util.Set<org.ehcache.core.spi.store.events.StoreEventFilter<K, V>> filters;
descriptor: Ljava/util/Set;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Set<Lorg/ehcache/core/spi/store/events/StoreEventFilter<TK;TV;>;>;
private final boolean ordered;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.BlockingQueue<org.ehcache.impl.internal.events.FireableStoreEventHolder<K, V>>[] orderedQueues;
descriptor: [Ljava/util/concurrent/BlockingQueue;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: [Ljava/util/concurrent/BlockingQueue<Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;>;
private final java.util.Set<org.ehcache.core.spi.store.events.StoreEventListener<K, V>> listeners;
descriptor: Ljava/util/Set;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Set<Lorg/ehcache/core/spi/store/events/StoreEventListener<TK;TV;>;>;
private final java.util.Deque<org.ehcache.impl.internal.events.FireableStoreEventHolder<K, V>> events;
descriptor: Ljava/util/Deque;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Deque<Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;>;
void <init>(java.util.Set<org.ehcache.core.spi.store.events.StoreEventFilter<K, V>>, boolean, java.util.concurrent.BlockingQueue<org.ehcache.impl.internal.events.FireableStoreEventHolder<K, V>>[], java.util.Set<org.ehcache.core.spi.store.events.StoreEventListener<K, V>>);
descriptor: (Ljava/util/Set;Z[Ljava/util/concurrent/BlockingQueue;Ljava/util/Set;)V
flags: (0x0000)
Code:
stack=4, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.ArrayDeque
dup
iconst_4
invokespecial java.util.ArrayDeque.<init>:(I)V
putfield org.ehcache.impl.internal.events.InvocationScopedEventSink.events:Ljava/util/Deque;
2: aload 0
aload 1
putfield org.ehcache.impl.internal.events.InvocationScopedEventSink.filters:Ljava/util/Set;
3: aload 0
iload 2
putfield org.ehcache.impl.internal.events.InvocationScopedEventSink.ordered:Z
4: aload 0
aload 3
putfield org.ehcache.impl.internal.events.InvocationScopedEventSink.orderedQueues:[Ljava/util/concurrent/BlockingQueue;
5: aload 0
aload 4
putfield org.ehcache.impl.internal.events.InvocationScopedEventSink.listeners:Ljava/util/Set;
6: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/ehcache/impl/internal/events/InvocationScopedEventSink<TK;TV;>;
0 7 1 filters Ljava/util/Set<Lorg/ehcache/core/spi/store/events/StoreEventFilter<TK;TV;>;>;
0 7 2 ordered Z
0 7 3 orderedQueues [Ljava/util/concurrent/BlockingQueue;
0 7 4 listeners Ljava/util/Set<Lorg/ehcache/core/spi/store/events/StoreEventListener<TK;TV;>;>;
Signature: (Ljava/util/Set<Lorg/ehcache/core/spi/store/events/StoreEventFilter<TK;TV;>;>;Z[Ljava/util/concurrent/BlockingQueue<Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;>;Ljava/util/Set<Lorg/ehcache/core/spi/store/events/StoreEventListener<TK;TV;>;>;)V
MethodParameters:
Name Flags
filters
ordered
orderedQueues
listeners
public void removed(K, java.util.function.Supplier<V>);
descriptor: (Ljava/lang/Object;Ljava/util/function/Supplier;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 2
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
astore 3
start local 3 1: aload 0
getstatic org.ehcache.event.EventType.REMOVED:Lorg/ehcache/event/EventType;
aload 1
aload 3
aconst_null
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.acceptEvent:(Lorg/ehcache/event/EventType;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 3
2: aload 0
aload 1
new org.ehcache.impl.internal.events.FireableStoreEventHolder
dup
aload 1
aload 3
invokestatic org.ehcache.impl.internal.events.StoreEvents.removeEvent:(Ljava/lang/Object;Ljava/lang/Object;)Lorg/ehcache/core/spi/store/events/StoreEvent;
invokespecial org.ehcache.impl.internal.events.FireableStoreEventHolder.<init>:(Lorg/ehcache/core/spi/store/events/StoreEvent;)V
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.handleEvent:(Ljava/lang/Object;Lorg/ehcache/impl/internal/events/FireableStoreEventHolder;)V
3: StackMap locals: java.lang.Object
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/ehcache/impl/internal/events/InvocationScopedEventSink<TK;TV;>;
0 4 1 key TK;
0 4 2 value Ljava/util/function/Supplier<TV;>;
1 4 3 removedValue TV;
Signature: (TK;Ljava/util/function/Supplier<TV;>;)V
MethodParameters:
Name Flags
key
value
public void updated(K, java.util.function.Supplier<V>, );
descriptor: (Ljava/lang/Object;Ljava/util/function/Supplier;Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
astore 4
start local 4 1: aload 0
getstatic org.ehcache.event.EventType.UPDATED:Lorg/ehcache/event/EventType;
aload 1
aload 4
aload 3
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.acceptEvent:(Lorg/ehcache/event/EventType;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 3
2: aload 0
aload 1
new org.ehcache.impl.internal.events.FireableStoreEventHolder
dup
aload 1
aload 4
aload 3
invokestatic org.ehcache.impl.internal.events.StoreEvents.updateEvent:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Lorg/ehcache/core/spi/store/events/StoreEvent;
invokespecial org.ehcache.impl.internal.events.FireableStoreEventHolder.<init>:(Lorg/ehcache/core/spi/store/events/StoreEvent;)V
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.handleEvent:(Ljava/lang/Object;Lorg/ehcache/impl/internal/events/FireableStoreEventHolder;)V
3: StackMap locals: java.lang.Object
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/ehcache/impl/internal/events/InvocationScopedEventSink<TK;TV;>;
0 4 1 key TK;
0 4 2 oldValue Ljava/util/function/Supplier<TV;>;
0 4 3 newValue TV;
1 4 4 oldValueValue TV;
Signature: (TK;Ljava/util/function/Supplier<TV;>;TV;)V
MethodParameters:
Name Flags
key
oldValue
newValue
public void expired(K, java.util.function.Supplier<V>);
descriptor: (Ljava/lang/Object;Ljava/util/function/Supplier;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 2
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
astore 3
start local 3 1: aload 0
getstatic org.ehcache.event.EventType.EXPIRED:Lorg/ehcache/event/EventType;
aload 1
aload 3
aconst_null
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.acceptEvent:(Lorg/ehcache/event/EventType;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 3
2: aload 0
aload 1
new org.ehcache.impl.internal.events.FireableStoreEventHolder
dup
aload 1
aload 3
invokestatic org.ehcache.impl.internal.events.StoreEvents.expireEvent:(Ljava/lang/Object;Ljava/lang/Object;)Lorg/ehcache/core/spi/store/events/StoreEvent;
invokespecial org.ehcache.impl.internal.events.FireableStoreEventHolder.<init>:(Lorg/ehcache/core/spi/store/events/StoreEvent;)V
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.handleEvent:(Ljava/lang/Object;Lorg/ehcache/impl/internal/events/FireableStoreEventHolder;)V
3: StackMap locals: java.lang.Object
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/ehcache/impl/internal/events/InvocationScopedEventSink<TK;TV;>;
0 4 1 key TK;
0 4 2 value Ljava/util/function/Supplier<TV;>;
1 4 3 expired TV;
Signature: (TK;Ljava/util/function/Supplier<TV;>;)V
MethodParameters:
Name Flags
key
value
public void created(K, );
descriptor: (Ljava/lang/Object;Ljava/lang/Object;)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
getstatic org.ehcache.event.EventType.CREATED:Lorg/ehcache/event/EventType;
aload 1
aconst_null
aload 2
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.acceptEvent:(Lorg/ehcache/event/EventType;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 2
1: aload 0
aload 1
new org.ehcache.impl.internal.events.FireableStoreEventHolder
dup
aload 1
aload 2
invokestatic org.ehcache.impl.internal.events.StoreEvents.createEvent:(Ljava/lang/Object;Ljava/lang/Object;)Lorg/ehcache/core/spi/store/events/StoreEvent;
invokespecial org.ehcache.impl.internal.events.FireableStoreEventHolder.<init>:(Lorg/ehcache/core/spi/store/events/StoreEvent;)V
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.handleEvent:(Ljava/lang/Object;Lorg/ehcache/impl/internal/events/FireableStoreEventHolder;)V
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/ehcache/impl/internal/events/InvocationScopedEventSink<TK;TV;>;
0 3 1 key TK;
0 3 2 value TV;
Signature: (TK;TV;)V
MethodParameters:
Name Flags
key
value
public void evicted(K, java.util.function.Supplier<V>);
descriptor: (Ljava/lang/Object;Ljava/util/function/Supplier;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 2
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
astore 3
start local 3 1: aload 0
getstatic org.ehcache.event.EventType.EVICTED:Lorg/ehcache/event/EventType;
aload 1
aload 3
aconst_null
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.acceptEvent:(Lorg/ehcache/event/EventType;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 3
2: aload 0
aload 1
new org.ehcache.impl.internal.events.FireableStoreEventHolder
dup
aload 1
aload 3
invokestatic org.ehcache.impl.internal.events.StoreEvents.evictEvent:(Ljava/lang/Object;Ljava/lang/Object;)Lorg/ehcache/core/spi/store/events/StoreEvent;
invokespecial org.ehcache.impl.internal.events.FireableStoreEventHolder.<init>:(Lorg/ehcache/core/spi/store/events/StoreEvent;)V
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.handleEvent:(Ljava/lang/Object;Lorg/ehcache/impl/internal/events/FireableStoreEventHolder;)V
3: StackMap locals: java.lang.Object
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/ehcache/impl/internal/events/InvocationScopedEventSink<TK;TV;>;
0 4 1 key TK;
0 4 2 value Ljava/util/function/Supplier<TV;>;
1 4 3 evicted TV;
Signature: (TK;Ljava/util/function/Supplier<TV;>;)V
MethodParameters:
Name Flags
key
value
protected boolean acceptEvent(org.ehcache.event.EventType, K, V, );
descriptor: (Lorg/ehcache/event/EventType;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
flags: (0x0004) ACC_PROTECTED
Code:
stack=5, locals=7, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.filters:Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 6
goto 4
StackMap locals: org.ehcache.impl.internal.events.InvocationScopedEventSink org.ehcache.event.EventType java.lang.Object java.lang.Object java.lang.Object top java.util.Iterator
StackMap stack:
1: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.ehcache.core.spi.store.events.StoreEventFilter
astore 5
start local 5 2: aload 5
aload 1
aload 2
aload 3
aload 4
invokeinterface org.ehcache.core.spi.store.events.StoreEventFilter.acceptEvent:(Lorg/ehcache/event/EventType;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
ifne 4
3: iconst_0
ireturn
end local 5 4: StackMap locals:
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
5: iconst_1
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/ehcache/impl/internal/events/InvocationScopedEventSink<TK;TV;>;
0 6 1 type Lorg/ehcache/event/EventType;
0 6 2 key TK;
0 6 3 oldValue TV;
0 6 4 newValue TV;
2 4 5 filter Lorg/ehcache/core/spi/store/events/StoreEventFilter<TK;TV;>;
Signature: (Lorg/ehcache/event/EventType;TK;TV;TV;)Z
MethodParameters:
Name Flags
type
key
oldValue
newValue
public void close();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=1
start local 0 0: aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.ordered:Z
ifeq 3
1: aload 0
aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.listeners:Ljava/util/Set;
aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.events:Ljava/util/Deque;
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.fireOrdered:(Ljava/util/Set;Ljava/util/Deque;)V
2: goto 10
3: StackMap locals:
StackMap stack:
aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.events:Ljava/util/Deque;
invokeinterface java.util.Deque.iterator:()Ljava/util/Iterator;
astore 2
goto 9
StackMap locals: org.ehcache.impl.internal.events.InvocationScopedEventSink top java.util.Iterator
StackMap stack:
4: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.ehcache.impl.internal.events.FireableStoreEventHolder
astore 1
start local 1 5: aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.listeners:Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 4
goto 8
StackMap locals: org.ehcache.impl.internal.events.InvocationScopedEventSink org.ehcache.impl.internal.events.FireableStoreEventHolder java.util.Iterator top java.util.Iterator
StackMap stack:
6: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.ehcache.core.spi.store.events.StoreEventListener
astore 3
start local 3 7: aload 1
aload 3
invokevirtual org.ehcache.impl.internal.events.FireableStoreEventHolder.fireOn:(Lorg/ehcache/core/spi/store/events/StoreEventListener;)V
end local 3 8: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
end local 1 9: StackMap locals: org.ehcache.impl.internal.events.InvocationScopedEventSink top java.util.Iterator
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
10: StackMap locals: org.ehcache.impl.internal.events.InvocationScopedEventSink
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lorg/ehcache/impl/internal/events/InvocationScopedEventSink<TK;TV;>;
5 9 1 fireableEvent Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;
7 8 3 listener Lorg/ehcache/core/spi/store/events/StoreEventListener<TK;TV;>;
public void closeOnFailure();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=3, args_size=1
start local 0 0: aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.events:Ljava/util/Deque;
invokeinterface java.util.Deque.iterator:()Ljava/util/Iterator;
astore 2
goto 3
StackMap locals: org.ehcache.impl.internal.events.InvocationScopedEventSink top java.util.Iterator
StackMap stack:
1: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.ehcache.impl.internal.events.FireableStoreEventHolder
astore 1
start local 1 2: aload 1
invokevirtual org.ehcache.impl.internal.events.FireableStoreEventHolder.markFailed:()V
end local 1 3: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
4: aload 0
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.close:()V
5: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/ehcache/impl/internal/events/InvocationScopedEventSink<TK;TV;>;
2 3 1 fireableEvent Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;
public void reset();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=1
start local 0 0: aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.events:Ljava/util/Deque;
invokeinterface java.util.Deque.iterator:()Ljava/util/Iterator;
astore 1
start local 1 1: goto 8
2: StackMap locals: java.util.Iterator
StackMap stack:
aload 1
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.ehcache.impl.internal.events.FireableStoreEventHolder
astore 2
start local 2 3: aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.ordered:Z
ifeq 7
4: aload 0
aload 2
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.getOrderedQueue:(Lorg/ehcache/impl/internal/events/FireableStoreEventHolder;)Ljava/util/concurrent/BlockingQueue;
astore 3
start local 3 5: aload 3
aload 2
invokeinterface java.util.concurrent.BlockingQueue.remove:(Ljava/lang/Object;)Z
pop
6: aload 0
aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.listeners:Ljava/util/Set;
aload 3
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.fireWaiters:(Ljava/util/Set;Ljava/util/concurrent/BlockingQueue;)V
end local 3 7: StackMap locals: org.ehcache.impl.internal.events.FireableStoreEventHolder
StackMap stack:
aload 1
invokeinterface java.util.Iterator.remove:()V
end local 2 8: StackMap locals:
StackMap stack:
aload 1
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
9: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/ehcache/impl/internal/events/InvocationScopedEventSink<TK;TV;>;
1 10 1 iterator Ljava/util/Iterator<Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;>;
3 8 2 next Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;
5 7 3 orderedQueue Ljava/util/concurrent/BlockingQueue<Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;>;
protected java.util.Deque<org.ehcache.impl.internal.events.FireableStoreEventHolder<K, V>> getEvents();
descriptor: ()Ljava/util/Deque;
flags: (0x0004) ACC_PROTECTED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.events:Ljava/util/Deque;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/ehcache/impl/internal/events/InvocationScopedEventSink<TK;TV;>;
Signature: ()Ljava/util/Deque<Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;>;
protected void handleEvent(K, org.ehcache.impl.internal.events.FireableStoreEventHolder<K, V>);
descriptor: (Ljava/lang/Object;Lorg/ehcache/impl/internal/events/FireableStoreEventHolder;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.events:Ljava/util/Deque;
aload 2
invokeinterface java.util.Deque.add:(Ljava/lang/Object;)Z
pop
1: aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.ordered:Z
ifeq 7
2: aload 0
aload 2
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.getOrderedQueue:(Lorg/ehcache/impl/internal/events/FireableStoreEventHolder;)Ljava/util/concurrent/BlockingQueue;
aload 2
invokeinterface java.util.concurrent.BlockingQueue.put:(Ljava/lang/Object;)V
3: goto 7
StackMap locals:
StackMap stack: java.lang.InterruptedException
4: pop
5: aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.events:Ljava/util/Deque;
invokeinterface java.util.Deque.removeLast:()Ljava/lang/Object;
pop
6: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
invokevirtual java.lang.Thread.interrupt:()V
7: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/ehcache/impl/internal/events/InvocationScopedEventSink<TK;TV;>;
0 8 1 key TK;
0 8 2 event Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;
Exception table:
from to target type
2 3 4 Class java.lang.InterruptedException
Signature: (TK;Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;)V
MethodParameters:
Name Flags
key
event
private java.util.concurrent.BlockingQueue<org.ehcache.impl.internal.events.FireableStoreEventHolder<K, V>> getOrderedQueue(org.ehcache.impl.internal.events.FireableStoreEventHolder<K, V>);
descriptor: (Lorg/ehcache/impl/internal/events/FireableStoreEventHolder;)Ljava/util/concurrent/BlockingQueue;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.ehcache.impl.internal.events.FireableStoreEventHolder.eventKeyHash:()I
aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.orderedQueues:[Ljava/util/concurrent/BlockingQueue;
arraylength
irem
invokestatic java.lang.Math.abs:(I)I
istore 2
start local 2 1: aload 0
getfield org.ehcache.impl.internal.events.InvocationScopedEventSink.orderedQueues:[Ljava/util/concurrent/BlockingQueue;
iload 2
aaload
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/ehcache/impl/internal/events/InvocationScopedEventSink<TK;TV;>;
0 2 1 event Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;
1 2 2 i I
Signature: (Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;)Ljava/util/concurrent/BlockingQueue<Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;>;
MethodParameters:
Name Flags
event
private void fireOrdered(java.util.Set<org.ehcache.core.spi.store.events.StoreEventListener<K, V>>, java.util.Deque<org.ehcache.impl.internal.events.FireableStoreEventHolder<K, V>>);
descriptor: (Ljava/util/Set;Ljava/util/Deque;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=9, args_size=3
start local 0 start local 1 start local 2 0: aload 2
invokeinterface java.util.Deque.iterator:()Ljava/util/Iterator;
astore 4
goto 17
StackMap locals: org.ehcache.impl.internal.events.InvocationScopedEventSink java.util.Set java.util.Deque top java.util.Iterator
StackMap stack:
1: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.ehcache.impl.internal.events.FireableStoreEventHolder
astore 3
start local 3 2: aload 3
invokevirtual org.ehcache.impl.internal.events.FireableStoreEventHolder.markFireable:()V
3: aload 0
aload 3
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.getOrderedQueue:(Lorg/ehcache/impl/internal/events/FireableStoreEventHolder;)Ljava/util/concurrent/BlockingQueue;
astore 5
start local 5 4: aload 5
invokeinterface java.util.concurrent.BlockingQueue.peek:()Ljava/lang/Object;
checkcast org.ehcache.impl.internal.events.FireableStoreEventHolder
astore 6
start local 6 5: aload 6
aload 3
if_acmpne 16
6: aload 6
invokevirtual org.ehcache.impl.internal.events.FireableStoreEventHolder.markFired:()Z
ifeq 13
7: aload 1
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 8
goto 10
StackMap locals: org.ehcache.impl.internal.events.InvocationScopedEventSink java.util.Set java.util.Deque org.ehcache.impl.internal.events.FireableStoreEventHolder java.util.Iterator java.util.concurrent.BlockingQueue org.ehcache.impl.internal.events.FireableStoreEventHolder top java.util.Iterator
StackMap stack:
8: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.ehcache.core.spi.store.events.StoreEventListener
astore 7
start local 7 9: aload 6
aload 7
invokevirtual org.ehcache.impl.internal.events.FireableStoreEventHolder.fireOn:(Lorg/ehcache/core/spi/store/events/StoreEventListener;)V
end local 7 10: StackMap locals:
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 8
11: aload 5
invokeinterface java.util.concurrent.BlockingQueue.poll:()Ljava/lang/Object;
pop
12: goto 14
13: StackMap locals: org.ehcache.impl.internal.events.InvocationScopedEventSink java.util.Set java.util.Deque org.ehcache.impl.internal.events.FireableStoreEventHolder java.util.Iterator java.util.concurrent.BlockingQueue org.ehcache.impl.internal.events.FireableStoreEventHolder
StackMap stack:
aload 3
invokevirtual org.ehcache.impl.internal.events.FireableStoreEventHolder.waitTillFired:()V
14: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 5
invokevirtual org.ehcache.impl.internal.events.InvocationScopedEventSink.fireWaiters:(Ljava/util/Set;Ljava/util/concurrent/BlockingQueue;)V
15: goto 17
16: StackMap locals:
StackMap stack:
aload 3
invokevirtual org.ehcache.impl.internal.events.FireableStoreEventHolder.waitTillFired:()V
end local 6 end local 5 end local 3 17: StackMap locals: org.ehcache.impl.internal.events.InvocationScopedEventSink java.util.Set java.util.Deque top java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
18: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lorg/ehcache/impl/internal/events/InvocationScopedEventSink<TK;TV;>;
0 19 1 listeners Ljava/util/Set<Lorg/ehcache/core/spi/store/events/StoreEventListener<TK;TV;>;>;
0 19 2 events Ljava/util/Deque<Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;>;
2 17 3 fireableEvent Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;
4 17 5 orderedQueue Ljava/util/concurrent/BlockingQueue<Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;>;
5 17 6 head Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;
9 10 7 listener Lorg/ehcache/core/spi/store/events/StoreEventListener<TK;TV;>;
Signature: (Ljava/util/Set<Lorg/ehcache/core/spi/store/events/StoreEventListener<TK;TV;>;>;Ljava/util/Deque<Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;>;)V
MethodParameters:
Name Flags
listeners
events
private void fireWaiters(java.util.Set<org.ehcache.core.spi.store.events.StoreEventListener<K, V>>, java.util.concurrent.BlockingQueue<org.ehcache.impl.internal.events.FireableStoreEventHolder<K, V>>);
descriptor: (Ljava/util/Set;Ljava/util/concurrent/BlockingQueue;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=6, args_size=3
start local 0 start local 1 start local 2 0: goto 7
start local 3 1: StackMap locals: org.ehcache.impl.internal.events.FireableStoreEventHolder
StackMap stack:
aload 3
invokevirtual org.ehcache.impl.internal.events.FireableStoreEventHolder.markFired:()Z
ifeq 9
2: aload 1
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 5
StackMap locals: org.ehcache.impl.internal.events.InvocationScopedEventSink java.util.Set java.util.concurrent.BlockingQueue org.ehcache.impl.internal.events.FireableStoreEventHolder top java.util.Iterator
StackMap stack:
3: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.ehcache.core.spi.store.events.StoreEventListener
astore 4
start local 4 4: aload 3
aload 4
invokevirtual org.ehcache.impl.internal.events.FireableStoreEventHolder.fireOn:(Lorg/ehcache/core/spi/store/events/StoreEventListener;)V
end local 4 5: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
6: aload 2
invokeinterface java.util.concurrent.BlockingQueue.poll:()Ljava/lang/Object;
pop
end local 3 7: StackMap locals: org.ehcache.impl.internal.events.InvocationScopedEventSink java.util.Set java.util.concurrent.BlockingQueue
StackMap stack:
aload 2
invokeinterface java.util.concurrent.BlockingQueue.peek:()Ljava/lang/Object;
checkcast org.ehcache.impl.internal.events.FireableStoreEventHolder
dup
astore 3
start local 3 8: ifnull 9
aload 3
invokevirtual org.ehcache.impl.internal.events.FireableStoreEventHolder.isFireable:()Z
ifne 1
9: StackMap locals: org.ehcache.impl.internal.events.FireableStoreEventHolder
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/ehcache/impl/internal/events/InvocationScopedEventSink<TK;TV;>;
0 10 1 listeners Ljava/util/Set<Lorg/ehcache/core/spi/store/events/StoreEventListener<TK;TV;>;>;
0 10 2 orderedQueue Ljava/util/concurrent/BlockingQueue<Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;>;
1 7 3 head Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;
8 10 3 head Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;
4 5 4 listener Lorg/ehcache/core/spi/store/events/StoreEventListener<TK;TV;>;
Signature: (Ljava/util/Set<Lorg/ehcache/core/spi/store/events/StoreEventListener<TK;TV;>;>;Ljava/util/concurrent/BlockingQueue<Lorg/ehcache/impl/internal/events/FireableStoreEventHolder<TK;TV;>;>;)V
MethodParameters:
Name Flags
listeners
orderedQueue
}
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>Ljava/lang/Object;Lorg/ehcache/impl/internal/events/CloseableStoreEventSink<TK;TV;>;
SourceFile: "InvocationScopedEventSink.java"