public abstract class org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler<E> implements org.glassfish.grizzly.comet.CometHandler<E>
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler
super_class: java.lang.Object
{
protected static final java.util.logging.Logger logger;
descriptor: Ljava/util/logging/Logger;
flags: (0x001c) ACC_PROTECTED, ACC_STATIC, ACC_FINAL
private boolean shuttingDown;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private final int messageQueueLimit;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private int queueSize;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private boolean readyForWork;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
protected final java.util.Queue<org.glassfish.grizzly.comet.CometEvent> messageQueue;
descriptor: Ljava/util/Queue;
flags: (0x0014) ACC_PROTECTED, ACC_FINAL
Signature: Ljava/util/Queue<Lorg/glassfish/grizzly/comet/CometEvent;>;
private org.glassfish.grizzly.comet.CometContext<E> context;
descriptor: Lorg/glassfish/grizzly/comet/CometContext;
flags: (0x0002) ACC_PRIVATE
Signature: Lorg/glassfish/grizzly/comet/CometContext<TE;>;
private org.glassfish.grizzly.http.server.Response response;
descriptor: Lorg/glassfish/grizzly/http/server/Response;
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/glassfish/grizzly/comet/concurrent/DefaultConcurrentCometHandler;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
invokestatic java.util.logging.Logger.getLogger:(Ljava/lang/String;)Ljava/util/logging/Logger;
putstatic org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.logger:Ljava/util/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(org.glassfish.grizzly.comet.CometContext<E>, org.glassfish.grizzly.http.server.Response);
descriptor: (Lorg/glassfish/grizzly/comet/CometContext;Lorg/glassfish/grizzly/http/server/Response;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
bipush 100
invokespecial org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.<init>:(I)V
1: aload 0
aload 1
putfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.context:Lorg/glassfish/grizzly/comet/CometContext;
2: aload 0
aload 2
putfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.response:Lorg/glassfish/grizzly/http/server/Response;
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/glassfish/grizzly/comet/concurrent/DefaultConcurrentCometHandler<TE;>;
0 4 1 context Lorg/glassfish/grizzly/comet/CometContext<TE;>;
0 4 2 response Lorg/glassfish/grizzly/http/server/Response;
Signature: (Lorg/glassfish/grizzly/comet/CometContext<TE;>;Lorg/glassfish/grizzly/http/server/Response;)V
MethodParameters:
Name Flags
context final
response final
public void <init>(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
iconst_1
putfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.readyForWork:Z
2: aload 0
new java.util.LinkedList
dup
invokespecial java.util.LinkedList.<init>:()V
putfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.messageQueue:Ljava/util/Queue;
3: aload 0
iload 1
putfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.messageQueueLimit:I
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/glassfish/grizzly/comet/concurrent/DefaultConcurrentCometHandler<TE;>;
0 5 1 messageQueueLimit I
MethodParameters:
Name Flags
messageQueueLimit
public org.glassfish.grizzly.comet.CometContext<E> getCometContext();
descriptor: ()Lorg/glassfish/grizzly/comet/CometContext;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.context:Lorg/glassfish/grizzly/comet/CometContext;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/glassfish/grizzly/comet/concurrent/DefaultConcurrentCometHandler<TE;>;
Signature: ()Lorg/glassfish/grizzly/comet/CometContext<TE;>;
public void setCometContext(org.glassfish.grizzly.comet.CometContext<E>);
descriptor: (Lorg/glassfish/grizzly/comet/CometContext;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.context:Lorg/glassfish/grizzly/comet/CometContext;
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/glassfish/grizzly/comet/concurrent/DefaultConcurrentCometHandler<TE;>;
0 2 1 context Lorg/glassfish/grizzly/comet/CometContext<TE;>;
Signature: (Lorg/glassfish/grizzly/comet/CometContext<TE;>;)V
MethodParameters:
Name Flags
context final
public org.glassfish.grizzly.http.server.Response getResponse();
descriptor: ()Lorg/glassfish/grizzly/http/server/Response;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.response:Lorg/glassfish/grizzly/http/server/Response;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/glassfish/grizzly/comet/concurrent/DefaultConcurrentCometHandler<TE;>;
public void setResponse(org.glassfish.grizzly.http.server.Response);
descriptor: (Lorg/glassfish/grizzly/http/server/Response;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.response:Lorg/glassfish/grizzly/http/server/Response;
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/glassfish/grizzly/comet/concurrent/DefaultConcurrentCometHandler<TE;>;
0 2 1 response Lorg/glassfish/grizzly/http/server/Response;
MethodParameters:
Name Flags
response final
public void enqueueEvent(org.glassfish.grizzly.comet.CometEvent);
descriptor: (Lorg/glassfish/grizzly/comet/CometEvent;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.messageQueue:Ljava/util/Queue;
dup
astore 2
monitorenter
1: aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.readyForWork:Z
ifne 7
2: aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.shuttingDown:Z
ifne 5
aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.queueSize:I
aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.messageQueueLimit:I
if_icmpge 5
3: aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.messageQueue:Ljava/util/Queue;
aload 1
invokeinterface java.util.Queue.add:(Ljava/lang/Object;)Z
pop
4: aload 0
dup
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.queueSize:I
iconst_1
iadd
putfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.queueSize:I
5: StackMap locals: java.util.Queue
StackMap stack:
aload 2
monitorexit
6: return
7: StackMap locals:
StackMap stack:
aload 0
iconst_0
putfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.readyForWork:Z
8: aload 2
monitorexit
9: goto 12
StackMap locals:
StackMap stack: java.lang.Throwable
10: aload 2
monitorexit
11: athrow
12: StackMap locals:
StackMap stack:
iconst_0
istore 2
start local 2 13: goto 53
14: StackMap locals: int
StackMap stack:
aload 1
invokevirtual org.glassfish.grizzly.comet.CometEvent.getCometContext:()Lorg/glassfish/grizzly/comet/CometContext;
aload 0
invokevirtual org.glassfish.grizzly.comet.CometContext.isActive:(Lorg/glassfish/grizzly/comet/CometHandler;)Z
ifne 17
15: aload 0
iconst_1
putfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.shuttingDown:Z
16: return
17: StackMap locals:
StackMap stack:
aload 0
dup
astore 3
monitorenter
18: aload 0
aload 1
invokevirtual org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.onEvent:(Lorg/glassfish/grizzly/comet/CometEvent;)V
19: aload 3
monitorexit
20: goto 33
StackMap locals: org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler org.glassfish.grizzly.comet.CometEvent int org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler
StackMap stack: java.lang.Throwable
21: aload 3
monitorexit
22: athrow
23: StackMap locals: org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler org.glassfish.grizzly.comet.CometEvent int
StackMap stack: java.io.IOException
pop
24: aload 0
iconst_1
putfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.shuttingDown:Z
25: aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.shuttingDown:Z
ifeq 36
26: aload 1
invokevirtual org.glassfish.grizzly.comet.CometEvent.getCometContext:()Lorg/glassfish/grizzly/comet/CometContext;
aload 0
invokevirtual org.glassfish.grizzly.comet.CometContext.resumeCometHandler:(Lorg/glassfish/grizzly/comet/CometHandler;)Z
pop
27: return
28: StackMap locals:
StackMap stack: java.lang.Throwable
astore 4
29: aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.shuttingDown:Z
ifeq 32
30: aload 1
invokevirtual org.glassfish.grizzly.comet.CometEvent.getCometContext:()Lorg/glassfish/grizzly/comet/CometContext;
aload 0
invokevirtual org.glassfish.grizzly.comet.CometContext.resumeCometHandler:(Lorg/glassfish/grizzly/comet/CometHandler;)Z
pop
31: return
32: StackMap locals: org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler org.glassfish.grizzly.comet.CometEvent int top java.lang.Throwable
StackMap stack:
aload 4
athrow
33: StackMap locals: org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler org.glassfish.grizzly.comet.CometEvent int
StackMap stack:
aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.shuttingDown:Z
ifeq 36
34: aload 1
invokevirtual org.glassfish.grizzly.comet.CometEvent.getCometContext:()Lorg/glassfish/grizzly/comet/CometContext;
aload 0
invokevirtual org.glassfish.grizzly.comet.CometContext.resumeCometHandler:(Lorg/glassfish/grizzly/comet/CometHandler;)Z
pop
35: return
36: StackMap locals:
StackMap stack:
aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.messageQueue:Ljava/util/Queue;
dup
astore 3
monitorenter
37: aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.queueSize:I
aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.messageQueueLimit:I
if_icmpne 40
38: iconst_1
istore 2
39: goto 46
StackMap locals: java.util.Queue
StackMap stack:
40: aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.queueSize:I
ifne 44
41: aload 0
iconst_1
putfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.readyForWork:Z
42: aload 3
monitorexit
43: return
44: StackMap locals:
StackMap stack:
aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.messageQueue:Ljava/util/Queue;
invokeinterface java.util.Queue.poll:()Ljava/lang/Object;
checkcast org.glassfish.grizzly.comet.CometEvent
astore 1
45: aload 0
dup
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.queueSize:I
iconst_1
isub
putfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.queueSize:I
46: StackMap locals:
StackMap stack:
aload 3
monitorexit
47: goto 50
StackMap locals:
StackMap stack: java.lang.Throwable
48: aload 3
monitorexit
49: athrow
50: StackMap locals:
StackMap stack:
iload 2
ifeq 53
51: aload 0
iconst_1
putfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.shuttingDown:Z
52: aload 0
aload 1
invokevirtual org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.onQueueFull:(Lorg/glassfish/grizzly/comet/CometEvent;)V
53: StackMap locals:
StackMap stack:
aload 0
getfield org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.shuttingDown:Z
ifeq 14
54: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 55 0 this Lorg/glassfish/grizzly/comet/concurrent/DefaultConcurrentCometHandler<TE;>;
0 55 1 event Lorg/glassfish/grizzly/comet/CometEvent;
13 55 2 queueFull Z
Exception table:
from to target type
1 6 10 any
7 9 10 any
10 11 10 any
18 20 21 any
21 22 21 any
17 23 23 Class java.io.IOException
17 25 28 any
37 43 48 any
44 47 48 any
48 49 48 any
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
event
public void onQueueFull(org.glassfish.grizzly.comet.CometEvent);
descriptor: (Lorg/glassfish/grizzly/comet/CometEvent;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.glassfish.grizzly.comet.CometEvent.getCometContext:()Lorg/glassfish/grizzly/comet/CometContext;
aload 0
invokevirtual org.glassfish.grizzly.comet.CometContext.resumeCometHandler:(Lorg/glassfish/grizzly/comet/CometHandler;)Z
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/glassfish/grizzly/comet/concurrent/DefaultConcurrentCometHandler<TE;>;
0 2 1 event Lorg/glassfish/grizzly/comet/CometEvent;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
event
public void onInterrupt(org.glassfish.grizzly.comet.CometEvent);
descriptor: (Lorg/glassfish/grizzly/comet/CometEvent;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.terminate:()V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/glassfish/grizzly/comet/concurrent/DefaultConcurrentCometHandler<TE;>;
0 2 1 event Lorg/glassfish/grizzly/comet/CometEvent;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
event
public void onTerminate(org.glassfish.grizzly.comet.CometEvent);
descriptor: (Lorg/glassfish/grizzly/comet/CometEvent;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual org.glassfish.grizzly.comet.concurrent.DefaultConcurrentCometHandler.terminate:()V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/glassfish/grizzly/comet/concurrent/DefaultConcurrentCometHandler<TE;>;
0 2 1 event Lorg/glassfish/grizzly/comet/CometEvent;
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
event
protected void terminate();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=0, locals=1, args_size=1
start local 0 0: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/glassfish/grizzly/comet/concurrent/DefaultConcurrentCometHandler<TE;>;
}
Signature: <E:Ljava/lang/Object;>Ljava/lang/Object;Lorg/glassfish/grizzly/comet/CometHandler<TE;>;
SourceFile: "DefaultConcurrentCometHandler.java"