class jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask extends jdk.incubator.http.internal.common.SequentialScheduler$CompleteRestartableTask
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask
super_class: jdk.incubator.http.internal.common.SequentialScheduler$CompleteRestartableTask
{
final jdk.incubator.http.internal.websocket.WebSocketImpl this$0;
descriptor: Ljdk/incubator/http/internal/websocket/WebSocketImpl;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
private static volatile int[] $SWITCH_TABLE$jdk$incubator$http$internal$websocket$WebSocketImpl$State;
descriptor: [I
flags: (0x104a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE, ACC_SYNTHETIC
private void <init>(jdk.incubator.http.internal.websocket.WebSocketImpl);
descriptor: (Ljdk/incubator/http/internal/websocket/WebSocketImpl;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=2
start local 0 0: aload 0
aload 1
putfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
aload 0
invokespecial jdk.incubator.http.internal.common.SequentialScheduler$CompleteRestartableTask.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Ljdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask;
MethodParameters:
Name Flags
this$0 final
public void run();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=1
start local 0 0: StackMap locals:
StackMap stack:
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.state:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast jdk.incubator.http.internal.websocket.WebSocketImpl$State
astore 1
start local 1 1: invokestatic jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.$SWITCH_TABLE$jdk$incubator$http$internal$websocket$WebSocketImpl$State:()[I
aload 1
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$State.ordinal:()I
iaload
tableswitch { // 1 - 9
1: 2
2: 21
3: 25
4: 5
5: 8
6: 11
7: 14
8: 17
9: 19
default: 26
}
2: StackMap locals: jdk.incubator.http.internal.websocket.WebSocketImpl$State
StackMap stack:
aload 0
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.processOpen:()V
3: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.OPEN:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.IDLE:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl.tryChangeState:(Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;)Z
pop
4: goto 0
5: StackMap locals:
StackMap stack:
aload 0
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.processText:()V
6: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.TEXT:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.IDLE:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl.tryChangeState:(Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;)Z
pop
7: goto 0
8: StackMap locals:
StackMap stack:
aload 0
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.processBinary:()V
9: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.BINARY:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.IDLE:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl.tryChangeState:(Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;)Z
pop
10: goto 0
11: StackMap locals:
StackMap stack:
aload 0
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.processPing:()V
12: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.PING:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.IDLE:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl.tryChangeState:(Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;)Z
pop
13: goto 0
14: StackMap locals:
StackMap stack:
aload 0
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.processPong:()V
15: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.PONG:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.IDLE:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl.tryChangeState:(Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;)Z
pop
16: goto 0
17: StackMap locals:
StackMap stack:
aload 0
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.processClose:()V
18: return
19: StackMap locals:
StackMap stack:
aload 0
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.processError:()V
20: return
21: StackMap locals:
StackMap stack:
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.demand:Ljdk/incubator/http/internal/common/Demand;
invokevirtual jdk.incubator.http.internal.common.Demand.tryDecrement:()Z
ifeq 24
22: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.IDLE:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.WAITING:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl.tryChangeState:(Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;)Z
ifeq 24
23: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.receiver:Ljdk/incubator/http/internal/websocket/Receiver;
lconst_1
invokevirtual jdk.incubator.http.internal.websocket.Receiver.request:(J)V
24: StackMap locals:
StackMap stack:
return
25: StackMap locals:
StackMap stack:
return
26: StackMap locals:
StackMap stack:
new java.lang.InternalError
dup
aload 1
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.InternalError.<init>:(Ljava/lang/String;)V
athrow
27: StackMap locals:
StackMap stack: java.lang.Throwable
astore 2
start local 2 28: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
aload 2
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl.signalError:(Ljava/lang/Throwable;)V
end local 2 end local 1 29: goto 0
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 30 0 this Ljdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask;
1 29 1 s Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
28 29 2 t Ljava/lang/Throwable;
Exception table:
from to target type
1 18 27 Class java.lang.Throwable
19 20 27 Class java.lang.Throwable
21 24 27 Class java.lang.Throwable
26 27 27 Class java.lang.Throwable
private void processError();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=3, args_size=1
start local 0 0: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.receiver:Ljdk/incubator/http/internal/websocket/Receiver;
invokevirtual jdk.incubator.http.internal.websocket.Receiver.close:()V
1: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.receiveScheduler:Ljdk/incubator/http/internal/common/SequentialScheduler;
invokevirtual jdk.incubator.http.internal.common.SequentialScheduler.stop:()V
2: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.error:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast java.lang.Throwable
astore 1
start local 1 3: aload 1
instanceof jdk.incubator.http.internal.websocket.FailWebSocketException
ifeq 9
4: aload 1
checkcast jdk.incubator.http.internal.websocket.FailWebSocketException
invokevirtual jdk.incubator.http.internal.websocket.FailWebSocketException.getStatusCode:()I
istore 2
start local 2 5: new java.net.ProtocolException
dup
invokespecial java.net.ProtocolException.<init>:()V
aload 1
invokevirtual java.net.ProtocolException.initCause:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 1
6: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
new jdk.incubator.http.internal.websocket.OutgoingMessage$Close
dup
iload 2
ldc ""
invokespecial jdk.incubator.http.internal.websocket.OutgoingMessage$Close.<init>:(ILjava/lang/CharSequence;)V
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl.enqueueClose:(Ljdk/incubator/http/internal/websocket/OutgoingMessage$Close;)Ljava/util/concurrent/CompletableFuture;
7: invokedynamic accept()Ljava/util/function/BiConsumer;
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;)V
jdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask.lambda$0(Ljdk/incubator/http/WebSocket;Ljava/lang/Throwable;)V (6)
(Ljdk/incubator/http/WebSocket;Ljava/lang/Throwable;)V
8: invokevirtual java.util.concurrent.CompletableFuture.whenComplete:(Ljava/util/function/BiConsumer;)Ljava/util/concurrent/CompletableFuture;
pop
end local 2 9: StackMap locals: java.lang.Throwable
StackMap stack:
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.listener:Ljdk/incubator/http/WebSocket$Listener;
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
aload 1
invokeinterface jdk.incubator.http.WebSocket$Listener.onError:(Ljdk/incubator/http/WebSocket;Ljava/lang/Throwable;)V
10: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Ljdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask;
3 11 1 err Ljava/lang/Throwable;
5 9 2 code1 I
Exceptions:
throws java.io.IOException
private void processClose();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=3, args_size=1
start local 0 0: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.receiver:Ljdk/incubator/http/internal/websocket/Receiver;
invokevirtual jdk.incubator.http.internal.websocket.Receiver.close:()V
1: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.receiveScheduler:Ljdk/incubator/http/internal/common/SequentialScheduler;
invokevirtual jdk.incubator.http.internal.common.SequentialScheduler.stop:()V
2: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.listener:Ljdk/incubator/http/WebSocket$Listener;
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.statusCode:I
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.reason:Ljava/lang/String;
invokeinterface jdk.incubator.http.WebSocket$Listener.onClose:(Ljdk/incubator/http/WebSocket;ILjava/lang/String;)Ljava/util/concurrent/CompletionStage;
astore 1
start local 1 3: aload 1
ifnonnull 5
4: aconst_null
invokestatic jdk.incubator.http.internal.common.MinimalFuture.completedFuture:(Ljava/lang/Object;)Ljdk/incubator/http/internal/common/MinimalFuture;
astore 1
5: StackMap locals: java.util.concurrent.CompletionStage
StackMap stack:
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.statusCode:I
sipush 1005
if_icmpeq 6
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.statusCode:I
sipush 1006
if_icmpne 8
6: StackMap locals:
StackMap stack:
sipush 1000
istore 2
start local 2 7: goto 9
end local 2 8: StackMap locals:
StackMap stack:
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.statusCode:I
istore 2
start local 2 9: StackMap locals: int
StackMap stack:
aload 1
aload 0
iload 2
invokedynamic accept(Ljdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask;I)Ljava/util/function/BiConsumer;
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;)V
jdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask.lambda$1(ILjava/lang/Object;Ljava/lang/Throwable;)V (7)
(Ljava/lang/Object;Ljava/lang/Throwable;)V
invokeinterface java.util.concurrent.CompletionStage.whenComplete:(Ljava/util/function/BiConsumer;)Ljava/util/concurrent/CompletionStage;
pop
10: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Ljdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask;
3 11 1 readyToClose Ljava/util/concurrent/CompletionStage<*>;
7 8 2 code I
9 11 2 code I
Exceptions:
throws java.io.IOException
private void processPong();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.listener:Ljdk/incubator/http/WebSocket$Listener;
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.binaryData:Ljava/nio/ByteBuffer;
invokeinterface jdk.incubator.http.WebSocket$Listener.onPong:(Ljdk/incubator/http/WebSocket;Ljava/nio/ByteBuffer;)Ljava/util/concurrent/CompletionStage;
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Ljdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask;
private void processPing();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=1
start local 0 0: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.binaryData:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.slice:()Ljava/nio/ByteBuffer;
astore 1
start local 1 1: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.binaryData:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.remaining:()I
invokestatic java.nio.ByteBuffer.allocate:(I)Ljava/nio/ByteBuffer;
2: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.binaryData:Ljava/nio/ByteBuffer;
invokevirtual java.nio.ByteBuffer.put:(Ljava/nio/ByteBuffer;)Ljava/nio/ByteBuffer;
3: invokevirtual java.nio.ByteBuffer.flip:()Ljava/nio/ByteBuffer;
4: astore 2
start local 2 5: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
new jdk.incubator.http.internal.websocket.OutgoingMessage$Pong
dup
aload 2
invokespecial jdk.incubator.http.internal.websocket.OutgoingMessage$Pong.<init>:(Ljava/nio/ByteBuffer;)V
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl.enqueue:(Ljdk/incubator/http/internal/websocket/OutgoingMessage;)Ljava/util/concurrent/CompletableFuture;
astore 3
start local 3 6: aload 3
7: aload 0
invokedynamic accept(Ljdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask;)Ljava/util/function/BiConsumer;
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;)V
jdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask.lambda$3(Ljdk/incubator/http/WebSocket;Ljava/lang/Throwable;)V (7)
(Ljdk/incubator/http/WebSocket;Ljava/lang/Throwable;)V
8: invokevirtual java.util.concurrent.CompletableFuture.whenComplete:(Ljava/util/function/BiConsumer;)Ljava/util/concurrent/CompletableFuture;
pop
9: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.listener:Ljdk/incubator/http/WebSocket$Listener;
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
aload 1
invokeinterface jdk.incubator.http.WebSocket$Listener.onPing:(Ljdk/incubator/http/WebSocket;Ljava/nio/ByteBuffer;)Ljava/util/concurrent/CompletionStage;
pop
10: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Ljdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask;
1 11 1 slice Ljava/nio/ByteBuffer;
5 11 2 copy Ljava/nio/ByteBuffer;
6 11 3 pongSent Ljava/util/concurrent/CompletableFuture<Ljdk/incubator/http/WebSocket;>;
private void processBinary();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.listener:Ljdk/incubator/http/WebSocket$Listener;
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.binaryData:Ljava/nio/ByteBuffer;
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.part:Ljdk/incubator/http/WebSocket$MessagePart;
invokeinterface jdk.incubator.http.WebSocket$Listener.onBinary:(Ljdk/incubator/http/WebSocket;Ljava/nio/ByteBuffer;Ljdk/incubator/http/WebSocket$MessagePart;)Ljava/util/concurrent/CompletionStage;
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Ljdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask;
private void processText();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=1, args_size=1
start local 0 0: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.listener:Ljdk/incubator/http/WebSocket$Listener;
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.text:Ljava/lang/CharSequence;
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.part:Ljdk/incubator/http/WebSocket$MessagePart;
invokeinterface jdk.incubator.http.WebSocket$Listener.onText:(Ljdk/incubator/http/WebSocket;Ljava/lang/CharSequence;Ljdk/incubator/http/WebSocket$MessagePart;)Ljava/util/concurrent/CompletionStage;
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Ljdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask;
private void processOpen();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
getfield jdk.incubator.http.internal.websocket.WebSocketImpl.listener:Ljdk/incubator/http/WebSocket$Listener;
aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
invokeinterface jdk.incubator.http.WebSocket$Listener.onOpen:(Ljdk/incubator/http/WebSocket;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Ljdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask;
static int[] $SWITCH_TABLE$jdk$incubator$http$internal$websocket$WebSocketImpl$State();
descriptor: ()[I
flags: (0x1008) ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=0
0: getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.$SWITCH_TABLE$jdk$incubator$http$internal$websocket$WebSocketImpl$State:[I
dup
ifnull 1
areturn
StackMap locals:
StackMap stack: int[]
1: pop
invokestatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.values:()[Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
arraylength
newarray 10
astore 0
2: aload 0
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.BINARY:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$State.ordinal:()I
iconst_5
iastore
3: goto 5
StackMap locals: int[]
StackMap stack: java.lang.NoSuchFieldError
4: pop
StackMap locals:
StackMap stack:
5: aload 0
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.CLOSE:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$State.ordinal:()I
bipush 8
iastore
6: goto 8
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
7: pop
StackMap locals:
StackMap stack:
8: aload 0
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.ERROR:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$State.ordinal:()I
bipush 9
iastore
9: goto 11
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
10: pop
StackMap locals:
StackMap stack:
11: aload 0
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.IDLE:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$State.ordinal:()I
iconst_2
iastore
12: goto 14
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
13: pop
StackMap locals:
StackMap stack:
14: aload 0
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.OPEN:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$State.ordinal:()I
iconst_1
iastore
15: goto 17
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
16: pop
StackMap locals:
StackMap stack:
17: aload 0
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.PING:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$State.ordinal:()I
bipush 6
iastore
18: goto 20
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
19: pop
StackMap locals:
StackMap stack:
20: aload 0
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.PONG:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$State.ordinal:()I
bipush 7
iastore
21: goto 23
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
22: pop
StackMap locals:
StackMap stack:
23: aload 0
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.TEXT:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$State.ordinal:()I
iconst_4
iastore
24: goto 26
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
25: pop
StackMap locals:
StackMap stack:
26: aload 0
getstatic jdk.incubator.http.internal.websocket.WebSocketImpl$State.WAITING:Ljdk/incubator/http/internal/websocket/WebSocketImpl$State;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl$State.ordinal:()I
iconst_3
iastore
27: goto 29
StackMap locals:
StackMap stack: java.lang.NoSuchFieldError
28: pop
StackMap locals:
StackMap stack:
29: aload 0
dup
putstatic jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.$SWITCH_TABLE$jdk$incubator$http$internal$websocket$WebSocketImpl$State:[I
areturn
LocalVariableTable:
Start End Slot Name Signature
Exception table:
from to target type
2 3 4 Class java.lang.NoSuchFieldError
5 6 7 Class java.lang.NoSuchFieldError
8 9 10 Class java.lang.NoSuchFieldError
11 12 13 Class java.lang.NoSuchFieldError
14 15 16 Class java.lang.NoSuchFieldError
17 18 19 Class java.lang.NoSuchFieldError
20 21 22 Class java.lang.NoSuchFieldError
23 24 25 Class java.lang.NoSuchFieldError
26 27 28 Class java.lang.NoSuchFieldError
private static void lambda$0(jdk.incubator.http.WebSocket, java.lang.Throwable);
descriptor: (Ljdk/incubator/http/WebSocket;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnull 2
1: aload 1
invokestatic jdk.incubator.http.internal.common.Log.logError:(Ljava/lang/Throwable;)V
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 r Ljdk/incubator/http/WebSocket;
0 3 1 e Ljava/lang/Throwable;
private void lambda$1(int, java.lang.Object, java.lang.Throwable);
descriptor: (ILjava/lang/Object;Ljava/lang/Throwable;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 2 start local 3 0: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
new jdk.incubator.http.internal.websocket.OutgoingMessage$Close
dup
iload 1
ldc ""
invokespecial jdk.incubator.http.internal.websocket.OutgoingMessage$Close.<init>:(ILjava/lang/CharSequence;)V
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl.enqueueClose:(Ljdk/incubator/http/internal/websocket/OutgoingMessage$Close;)Ljava/util/concurrent/CompletableFuture;
1: invokedynamic accept()Ljava/util/function/BiConsumer;
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;)V
jdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask.lambda$2(Ljdk/incubator/http/WebSocket;Ljava/lang/Throwable;)V (6)
(Ljdk/incubator/http/WebSocket;Ljava/lang/Throwable;)V
invokevirtual java.util.concurrent.CompletableFuture.whenComplete:(Ljava/util/function/BiConsumer;)Ljava/util/concurrent/CompletableFuture;
pop
2: return
end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Ljdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask;
0 3 2 r Ljava/lang/Object;
0 3 3 e Ljava/lang/Throwable;
private void lambda$3(jdk.incubator.http.WebSocket, java.lang.Throwable);
descriptor: (Ljdk/incubator/http/WebSocket;Ljava/lang/Throwable;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 2
ifnull 2
1: aload 0
getfield jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask.this$0:Ljdk/incubator/http/internal/websocket/WebSocketImpl;
aload 2
invokestatic jdk.incubator.http.internal.common.Utils.getCompletionCause:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
invokevirtual jdk.incubator.http.internal.websocket.WebSocketImpl.signalError:(Ljava/lang/Throwable;)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 Ljdk/incubator/http/internal/websocket/WebSocketImpl$ReceiveTask;
0 3 1 r Ljdk/incubator/http/WebSocket;
0 3 2 e Ljava/lang/Throwable;
private static void lambda$2(jdk.incubator.http.WebSocket, java.lang.Throwable);
descriptor: (Ljdk/incubator/http/WebSocket;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnull 2
1: aload 1
invokestatic jdk.incubator.http.internal.common.Log.logError:(Ljava/lang/Throwable;)V
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 r1 Ljdk/incubator/http/WebSocket;
0 3 1 e1 Ljava/lang/Throwable;
}
SourceFile: "WebSocketImpl.java"
NestHost: jdk.incubator.http.internal.websocket.WebSocketImpl
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Listener = jdk.incubator.http.WebSocket$Listener of jdk.incubator.http.WebSocket
public final MessagePart = jdk.incubator.http.WebSocket$MessagePart of jdk.incubator.http.WebSocket
public abstract CompleteRestartableTask = jdk.incubator.http.internal.common.SequentialScheduler$CompleteRestartableTask of jdk.incubator.http.internal.common.SequentialScheduler
final Close = jdk.incubator.http.internal.websocket.OutgoingMessage$Close of jdk.incubator.http.internal.websocket.OutgoingMessage
final Pong = jdk.incubator.http.internal.websocket.OutgoingMessage$Pong of jdk.incubator.http.internal.websocket.OutgoingMessage
private ReceiveTask = jdk.incubator.http.internal.websocket.WebSocketImpl$ReceiveTask of jdk.incubator.http.internal.websocket.WebSocketImpl
final State = jdk.incubator.http.internal.websocket.WebSocketImpl$State of jdk.incubator.http.internal.websocket.WebSocketImpl