Skip to content

Instantly share code, notes, and snippets.

@Randgalt

Randgalt/ListenerContainer.class

Last active June 14, 2017 02:39
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save Randgalt/3fcdca337a2f8527a3f7ee871852f456 to your computer and use it in GitHub Desktop.
Save Randgalt/3fcdca337a2f8527a3f7ee871852f456 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
ListenerContainer.class
public class org.apache.curator.framework.listen.ListenerContainer<T extends java.lang.Object> extends java.lang.Object implements org.apache.curator.framework.listen.Listenable<T>
minor version: 0
major version: 51
flags: ACC_PUBLIC, ACC_SUPER
Constant pool:
#1 = Utf8 org/apache/curator/framework/listen/ListenerContainer
#2 = Class #1 // org/apache/curator/framework/listen/ListenerContainer
#3 = Utf8 <T:Ljava/lang/Object;>Ljava/lang/Object;Lorg/apache/curator/framework/listen/Listenable<TT;>;
#4 = Utf8 java/lang/Object
#5 = Class #4 // java/lang/Object
#6 = Utf8 org/apache/curator/framework/listen/Listenable
#7 = Class #6 // org/apache/curator/framework/listen/Listenable
#8 = Utf8 ListenerContainer.java
#9 = Utf8 org/apache/curator/framework/listen/ListenerContainer$1
#10 = Class #9 // org/apache/curator/framework/listen/ListenerContainer$1
#11 = Utf8 log
#12 = Utf8 Lorg/slf4j/Logger;
#13 = Utf8 listeners
#14 = Utf8 Ljava/util/Map;
#15 = Utf8 Ljava/util/Map<TT;Lorg/apache/curator/framework/listen/ListenerEntry<TT;>;>;
#16 = Utf8 <init>
#17 = Utf8 ()V
#18 = NameAndType #16:#17 // "<init>":()V
#19 = Methodref #5.#18 // java/lang/Object."<init>":()V
#20 = Utf8 getClass
#21 = Utf8 ()Ljava/lang/Class;
#22 = NameAndType #20:#21 // getClass:()Ljava/lang/Class;
#23 = Methodref #5.#22 // java/lang/Object.getClass:()Ljava/lang/Class;
#24 = Utf8 org/slf4j/LoggerFactory
#25 = Class #24 // org/slf4j/LoggerFactory
#26 = Utf8 getLogger
#27 = Utf8 (Ljava/lang/Class;)Lorg/slf4j/Logger;
#28 = NameAndType #26:#27 // getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
#29 = Methodref #25.#28 // org/slf4j/LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
#30 = NameAndType #11:#12 // log:Lorg/slf4j/Logger;
#31 = Fieldref #2.#30 // org/apache/curator/framework/listen/ListenerContainer.log:Lorg/slf4j/Logger;
#32 = Utf8 org/apache/curator/shaded/com/google/common/collect/Maps
#33 = Class #32 // org/apache/curator/shaded/com/google/common/collect/Maps
#34 = Utf8 newConcurrentMap
#35 = Utf8 ()Ljava/util/concurrent/ConcurrentMap;
#36 = NameAndType #34:#35 // newConcurrentMap:()Ljava/util/concurrent/ConcurrentMap;
#37 = Methodref #33.#36 // org/apache/curator/shaded/com/google/common/collect/Maps.newConcurrentMap:()Ljava/util/concurrent/ConcurrentMap;
#38 = NameAndType #13:#14 // listeners:Ljava/util/Map;
#39 = Fieldref #2.#38 // org/apache/curator/framework/listen/ListenerContainer.listeners:Ljava/util/Map;
#40 = Utf8 this
#41 = Utf8 Lorg/apache/curator/framework/listen/ListenerContainer<TT;>;
#42 = Utf8 Lorg/apache/curator/framework/listen/ListenerContainer;
#43 = Utf8 addListener
#44 = Utf8 (Ljava/lang/Object;)V
#45 = Utf8 org/apache/curator/shaded/com/google/common/util/concurrent/MoreExecutors
#46 = Class #45 // org/apache/curator/shaded/com/google/common/util/concurrent/MoreExecutors
#47 = Utf8 sameThreadExecutor
#48 = Utf8 ()Lorg/apache/curator/shaded/com/google/common/util/concurrent/ListeningExecutorService;
#49 = NameAndType #47:#48 // sameThreadExecutor:()Lorg/apache/curator/shaded/com/google/common/util/concurrent/ListeningExecutorService;
#50 = Methodref #46.#49 // org/apache/curator/shaded/com/google/common/util/concurrent/MoreExecutors.sameThreadExecutor:()Lorg/apache/curator/shaded/com/google/common/util/concurrent/ListeningExecutorService;
#51 = Utf8 (Ljava/lang/Object;Ljava/util/concurrent/Executor;)V
#52 = NameAndType #43:#51 // addListener:(Ljava/lang/Object;Ljava/util/concurrent/Executor;)V
#53 = Methodref #2.#52 // org/apache/curator/framework/listen/ListenerContainer.addListener:(Ljava/lang/Object;Ljava/util/concurrent/Executor;)V
#54 = Utf8 listener
#55 = Utf8 TT;
#56 = Utf8 Ljava/lang/Object;
#57 = Utf8 org/apache/curator/framework/listen/ListenerEntry
#58 = Class #57 // org/apache/curator/framework/listen/ListenerEntry
#59 = NameAndType #16:#51 // "<init>":(Ljava/lang/Object;Ljava/util/concurrent/Executor;)V
#60 = Methodref #58.#59 // org/apache/curator/framework/listen/ListenerEntry."<init>":(Ljava/lang/Object;Ljava/util/concurrent/Executor;)V
#61 = Utf8 java/util/Map
#62 = Class #61 // java/util/Map
#63 = Utf8 put
#64 = Utf8 (Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
#65 = NameAndType #63:#64 // put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
#66 = InterfaceMethodref #62.#65 // java/util/Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
#67 = Utf8 executor
#68 = Utf8 Ljava/util/concurrent/Executor;
#69 = Utf8 removeListener
#70 = Utf8 remove
#71 = Utf8 (Ljava/lang/Object;)Ljava/lang/Object;
#72 = NameAndType #70:#71 // remove:(Ljava/lang/Object;)Ljava/lang/Object;
#73 = InterfaceMethodref #62.#72 // java/util/Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
#74 = Utf8 clear
#75 = NameAndType #74:#17 // clear:()V
#76 = InterfaceMethodref #62.#75 // java/util/Map.clear:()V
#77 = Utf8 size
#78 = Utf8 ()I
#79 = NameAndType #77:#78 // size:()I
#80 = InterfaceMethodref #62.#79 // java/util/Map.size:()I
#81 = Utf8 forEach
#82 = Utf8 (Lcom/google/common/base/Function;)V
#83 = Utf8 values
#84 = Utf8 ()Ljava/util/Collection;
#85 = NameAndType #83:#84 // values:()Ljava/util/Collection;
#86 = InterfaceMethodref #62.#85 // java/util/Map.values:()Ljava/util/Collection;
#87 = Utf8 java/util/Collection
#88 = Class #87 // java/util/Collection
#89 = Utf8 iterator
#90 = Utf8 ()Ljava/util/Iterator;
#91 = NameAndType #89:#90 // iterator:()Ljava/util/Iterator;
#92 = InterfaceMethodref #88.#91 // java/util/Collection.iterator:()Ljava/util/Iterator;
#93 = Utf8 java/util/Iterator
#94 = Class #93 // java/util/Iterator
#95 = Utf8 hasNext
#96 = Utf8 ()Z
#97 = NameAndType #95:#96 // hasNext:()Z
#98 = InterfaceMethodref #94.#97 // java/util/Iterator.hasNext:()Z
#99 = Utf8 next
#100 = Utf8 ()Ljava/lang/Object;
#101 = NameAndType #99:#100 // next:()Ljava/lang/Object;
#102 = InterfaceMethodref #94.#101 // java/util/Iterator.next:()Ljava/lang/Object;
#103 = NameAndType #67:#68 // executor:Ljava/util/concurrent/Executor;
#104 = Fieldref #58.#103 // org/apache/curator/framework/listen/ListenerEntry.executor:Ljava/util/concurrent/Executor;
#105 = Utf8 (Lorg/apache/curator/framework/listen/ListenerContainer;Lcom/google/common/base/Function;Lorg/apache/curator/framework/listen/ListenerEntry;)V
#106 = NameAndType #16:#105 // "<init>":(Lorg/apache/curator/framework/listen/ListenerContainer;Lcom/google/common/base/Function;Lorg/apache/curator/framework/listen/ListenerEntry;)V
#107 = Methodref #10.#106 // org/apache/curator/framework/listen/ListenerContainer$1."<init>":(Lorg/apache/curator/framework/listen/ListenerContainer;Lcom/google/common/base/Function;Lorg/apache/curator/framework/listen/ListenerEntry;)V
#108 = Utf8 java/util/concurrent/Executor
#109 = Class #108 // java/util/concurrent/Executor
#110 = Utf8 execute
#111 = Utf8 (Ljava/lang/Runnable;)V
#112 = NameAndType #110:#111 // execute:(Ljava/lang/Runnable;)V
#113 = InterfaceMethodref #109.#112 // java/util/concurrent/Executor.execute:(Ljava/lang/Runnable;)V
#114 = Utf8 entry
#115 = Utf8 Lorg/apache/curator/framework/listen/ListenerEntry<TT;>;
#116 = Utf8 Lorg/apache/curator/framework/listen/ListenerEntry;
#117 = Utf8 function
#118 = Utf8 Lcom/google/common/base/Function<TT;Ljava/lang/Void;>;
#119 = Utf8 Lcom/google/common/base/Function;
#120 = Utf8 access$000
#121 = Utf8 (Lorg/apache/curator/framework/listen/ListenerContainer;)Lorg/slf4j/Logger;
#122 = Utf8 x0
#123 = Utf8 Signature
#124 = Utf8 Code
#125 = Utf8 LocalVariableTable
#126 = Utf8 LocalVariableTypeTable
#127 = Utf8 LineNumberTable
#128 = Utf8 (TT;)V
#129 = Utf8 (TT;Ljava/util/concurrent/Executor;)V
#130 = Utf8 StackMapTable
#131 = Utf8 (Lcom/google/common/base/Function<TT;Ljava/lang/Void;>;)V
#132 = Utf8 SourceFile
#133 = Utf8 InnerClasses
{
public org.apache.curator.framework.listen.ListenerContainer();
descriptor: ()V
flags: ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
0: aload_0
1: invokespecial #19 // Method java/lang/Object."<init>":()V
4: aload_0
5: aload_0
6: invokevirtual #23 // Method java/lang/Object.getClass:()Ljava/lang/Class;
9: invokestatic #29 // Method org/slf4j/LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
12: putfield #31 // Field log:Lorg/slf4j/Logger;
15: aload_0
16: invokestatic #37 // Method org/apache/curator/shaded/com/google/common/collect/Maps.newConcurrentMap:()Ljava/util/concurrent/ConcurrentMap;
19: putfield #39 // Field listeners:Ljava/util/Map;
22: return
LocalVariableTable:
Start Length Slot Name Signature
0 23 0 this Lorg/apache/curator/framework/listen/ListenerContainer;
LocalVariableTypeTable:
Start Length Slot Name Signature
0 23 0 this Lorg/apache/curator/framework/listen/ListenerContainer<TT;>;
LineNumberTable:
line 33: 0
line 35: 4
line 36: 15
public void addListener(T);
descriptor: (Ljava/lang/Object;)V
flags: ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
0: aload_0
1: aload_1
2: invokestatic #50 // Method org/apache/curator/shaded/com/google/common/util/concurrent/MoreExecutors.sameThreadExecutor:()Lorg/apache/curator/shaded/com/google/common/util/concurrent/ListeningExecutorService;
5: invokevirtual #53 // Method addListener:(Ljava/lang/Object;Ljava/util/concurrent/Executor;)V
8: return
LocalVariableTable:
Start Length Slot Name Signature
0 9 0 this Lorg/apache/curator/framework/listen/ListenerContainer;
0 9 1 listener Ljava/lang/Object;
LocalVariableTypeTable:
Start Length Slot Name Signature
0 9 0 this Lorg/apache/curator/framework/listen/ListenerContainer<TT;>;
0 9 1 listener TT;
LineNumberTable:
line 41: 0
line 42: 8
Signature: #128 // (TT;)V
public void addListener(T, java.util.concurrent.Executor);
descriptor: (Ljava/lang/Object;Ljava/util/concurrent/Executor;)V
flags: ACC_PUBLIC
Code:
stack=6, locals=3, args_size=3
0: aload_0
1: getfield #39 // Field listeners:Ljava/util/Map;
4: aload_1
5: new #58 // class org/apache/curator/framework/listen/ListenerEntry
8: dup
9: aload_1
10: aload_2
11: invokespecial #60 // Method org/apache/curator/framework/listen/ListenerEntry."<init>":(Ljava/lang/Object;Ljava/util/concurrent/Executor;)V
14: invokeinterface #66, 3 // InterfaceMethod java/util/Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
19: pop
20: return
LocalVariableTable:
Start Length Slot Name Signature
0 21 0 this Lorg/apache/curator/framework/listen/ListenerContainer;
0 21 1 listener Ljava/lang/Object;
0 21 2 executor Ljava/util/concurrent/Executor;
LocalVariableTypeTable:
Start Length Slot Name Signature
0 21 0 this Lorg/apache/curator/framework/listen/ListenerContainer<TT;>;
0 21 1 listener TT;
LineNumberTable:
line 47: 0
line 48: 20
Signature: #129 // (TT;Ljava/util/concurrent/Executor;)V
public void removeListener(T);
descriptor: (Ljava/lang/Object;)V
flags: ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
0: aload_0
1: getfield #39 // Field listeners:Ljava/util/Map;
4: aload_1
5: invokeinterface #73, 2 // InterfaceMethod java/util/Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
10: pop
11: return
LocalVariableTable:
Start Length Slot Name Signature
0 12 0 this Lorg/apache/curator/framework/listen/ListenerContainer;
0 12 1 listener Ljava/lang/Object;
LocalVariableTypeTable:
Start Length Slot Name Signature
0 12 0 this Lorg/apache/curator/framework/listen/ListenerContainer<TT;>;
0 12 1 listener TT;
LineNumberTable:
line 53: 0
line 54: 11
Signature: #128 // (TT;)V
public void clear();
descriptor: ()V
flags: ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
0: aload_0
1: getfield #39 // Field listeners:Ljava/util/Map;
4: invokeinterface #76, 1 // InterfaceMethod java/util/Map.clear:()V
9: return
LocalVariableTable:
Start Length Slot Name Signature
0 10 0 this Lorg/apache/curator/framework/listen/ListenerContainer;
LocalVariableTypeTable:
Start Length Slot Name Signature
0 10 0 this Lorg/apache/curator/framework/listen/ListenerContainer<TT;>;
LineNumberTable:
line 61: 0
line 62: 9
public int size();
descriptor: ()I
flags: ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
0: aload_0
1: getfield #39 // Field listeners:Ljava/util/Map;
4: invokeinterface #80, 1 // InterfaceMethod java/util/Map.size:()I
9: ireturn
LocalVariableTable:
Start Length Slot Name Signature
0 10 0 this Lorg/apache/curator/framework/listen/ListenerContainer;
LocalVariableTypeTable:
Start Length Slot Name Signature
0 10 0 this Lorg/apache/curator/framework/listen/ListenerContainer<TT;>;
LineNumberTable:
line 71: 0
public void forEach(com.google.common.base.Function<T, java.lang.Void>);
descriptor: (Lcom/google/common/base/Function;)V
flags: ACC_PUBLIC
Code:
stack=6, locals=4, args_size=2
0: aload_0
1: getfield #39 // Field listeners:Ljava/util/Map;
4: invokeinterface #86, 1 // InterfaceMethod java/util/Map.values:()Ljava/util/Collection;
9: invokeinterface #92, 1 // InterfaceMethod java/util/Collection.iterator:()Ljava/util/Iterator;
14: astore_2
15: aload_2
16: invokeinterface #98, 1 // InterfaceMethod java/util/Iterator.hasNext:()Z
21: ifeq 56
24: aload_2
25: invokeinterface #102, 1 // InterfaceMethod java/util/Iterator.next:()Ljava/lang/Object;
30: checkcast #58 // class org/apache/curator/framework/listen/ListenerEntry
33: astore_3
34: aload_3
35: getfield #104 // Field org/apache/curator/framework/listen/ListenerEntry.executor:Ljava/util/concurrent/Executor;
38: new #10 // class org/apache/curator/framework/listen/ListenerContainer$1
41: dup
42: aload_0
43: aload_1
44: aload_3
45: invokespecial #107 // Method org/apache/curator/framework/listen/ListenerContainer$1."<init>":(Lorg/apache/curator/framework/listen/ListenerContainer;Lcom/google/common/base/Function;Lorg/apache/curator/framework/listen/ListenerEntry;)V
48: invokeinterface #113, 2 // InterfaceMethod java/util/concurrent/Executor.execute:(Ljava/lang/Runnable;)V
53: goto 15
56: return
LocalVariableTable:
Start Length Slot Name Signature
34 19 3 entry Lorg/apache/curator/framework/listen/ListenerEntry;
0 57 0 this Lorg/apache/curator/framework/listen/ListenerContainer;
0 57 1 function Lcom/google/common/base/Function;
LocalVariableTypeTable:
Start Length Slot Name Signature
34 19 3 entry Lorg/apache/curator/framework/listen/ListenerEntry<TT;>;
0 57 0 this Lorg/apache/curator/framework/listen/ListenerContainer<TT;>;
0 57 1 function Lcom/google/common/base/Function<TT;Ljava/lang/Void;>;
LineNumberTable:
line 82: 0
line 84: 34
line 85: 48
line 103: 53
line 104: 56
StackMapTable: number_of_entries = 2
frame_type = 252 /* append */
offset_delta = 15
locals = [ class java/util/Iterator ]
frame_type = 250 /* chop */
offset_delta = 40
Signature: #131 // (Lcom/google/common/base/Function<TT;Ljava/lang/Void;>;)V
static org.slf4j.Logger access$000(org.apache.curator.framework.listen.ListenerContainer);
descriptor: (Lorg/apache/curator/framework/listen/ListenerContainer;)Lorg/slf4j/Logger;
flags: ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload_0
1: getfield #31 // Field log:Lorg/slf4j/Logger;
4: areturn
LocalVariableTable:
Start Length Slot Name Signature
0 5 0 x0 Lorg/apache/curator/framework/listen/ListenerContainer;
LineNumberTable:
line 33: 0
}
Signature: #3 // <T:Ljava/lang/Object;>Ljava/lang/Object;Lorg/apache/curator/framework/listen/Listenable<TT;>;
SourceFile: "ListenerContainer.java"
InnerClasses:
#10; //class org/apache/curator/framework/listen/ListenerContainer$1
~/dev/elastic/cloud/scala-services[klemme*]$
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment