public class io.vertx.core.http.impl.Http1xServerConnection extends io.vertx.core.http.impl.Http1xConnectionBase<io.vertx.core.http.impl.ServerWebSocketImpl> implements io.vertx.core.http.impl.HttpServerConnection
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.core.http.impl.Http1xServerConnection
super_class: io.vertx.core.http.impl.Http1xConnectionBase
{
private static final io.vertx.core.logging.Logger log;
descriptor: Lio/vertx/core/logging/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final java.lang.String serverOrigin;
descriptor: Ljava/lang/String;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.net.impl.SSLHelper sslHelper;
descriptor: Lio/vertx/core/net/impl/SSLHelper;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private boolean requestFailed;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private long bytesRead;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private long bytesWritten;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.http.impl.HttpServerRequestImpl requestInProgress;
descriptor: Lio/vertx/core/http/impl/HttpServerRequestImpl;
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.http.impl.HttpServerRequestImpl responseInProgress;
descriptor: Lio/vertx/core/http/impl/HttpServerRequestImpl;
flags: (0x0002) ACC_PRIVATE
private boolean channelPaused;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.Handler<io.vertx.core.http.HttpServerRequest> requestHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/core/http/HttpServerRequest;>;
final io.vertx.core.spi.metrics.HttpServerMetrics metrics;
descriptor: Lio/vertx/core/spi/metrics/HttpServerMetrics;
flags: (0x0010) ACC_FINAL
final boolean handle100ContinueAutomatically;
descriptor: Z
flags: (0x0010) ACC_FINAL
final io.vertx.core.http.HttpServerOptions options;
descriptor: Lio/vertx/core/http/HttpServerOptions;
flags: (0x0010) ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lio/vertx/core/http/impl/Http1xServerConnection;
invokestatic io.vertx.core.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/logging/Logger;
putstatic io.vertx.core.http.impl.Http1xServerConnection.log:Lio/vertx/core/logging/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(io.vertx.core.impl.VertxInternal, io.vertx.core.net.impl.SSLHelper, io.vertx.core.http.HttpServerOptions, io.netty.channel.ChannelHandlerContext, io.vertx.core.impl.ContextInternal, java.lang.String, io.vertx.core.spi.metrics.HttpServerMetrics);
descriptor: (Lio/vertx/core/impl/VertxInternal;Lio/vertx/core/net/impl/SSLHelper;Lio/vertx/core/http/HttpServerOptions;Lio/netty/channel/ChannelHandlerContext;Lio/vertx/core/impl/ContextInternal;Ljava/lang/String;Lio/vertx/core/spi/metrics/HttpServerMetrics;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=8, args_size=8
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 0: aload 0
aload 1
aload 4
aload 5
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.<init>:(Lio/vertx/core/impl/VertxInternal;Lio/netty/channel/ChannelHandlerContext;Lio/vertx/core/impl/ContextInternal;)V
1: aload 0
aload 6
putfield io.vertx.core.http.impl.Http1xServerConnection.serverOrigin:Ljava/lang/String;
2: aload 0
aload 3
putfield io.vertx.core.http.impl.Http1xServerConnection.options:Lio/vertx/core/http/HttpServerOptions;
3: aload 0
aload 2
putfield io.vertx.core.http.impl.Http1xServerConnection.sslHelper:Lio/vertx/core/net/impl/SSLHelper;
4: aload 0
aload 7
putfield io.vertx.core.http.impl.Http1xServerConnection.metrics:Lio/vertx/core/spi/metrics/HttpServerMetrics;
5: aload 0
aload 3
invokevirtual io.vertx.core.http.HttpServerOptions.isHandle100ContinueAutomatically:()Z
putfield io.vertx.core.http.impl.Http1xServerConnection.handle100ContinueAutomatically:Z
6: return
end local 7 end local 6 end local 5 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 Lio/vertx/core/http/impl/Http1xServerConnection;
0 7 1 vertx Lio/vertx/core/impl/VertxInternal;
0 7 2 sslHelper Lio/vertx/core/net/impl/SSLHelper;
0 7 3 options Lio/vertx/core/http/HttpServerOptions;
0 7 4 channel Lio/netty/channel/ChannelHandlerContext;
0 7 5 context Lio/vertx/core/impl/ContextInternal;
0 7 6 serverOrigin Ljava/lang/String;
0 7 7 metrics Lio/vertx/core/spi/metrics/HttpServerMetrics;
MethodParameters:
Name Flags
vertx
sslHelper
options
channel
context
serverOrigin
metrics
public io.vertx.core.http.impl.HttpServerConnection handler(io.vertx.core.Handler<io.vertx.core.http.HttpServerRequest>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/impl/HttpServerConnection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.core.http.impl.Http1xServerConnection.requestHandler:Lio/vertx/core/Handler;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 2 1 handler Lio/vertx/core/Handler<Lio/vertx/core/http/HttpServerRequest;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/http/HttpServerRequest;>;)Lio/vertx/core/http/impl/HttpServerConnection;
MethodParameters:
Name Flags
handler
public io.vertx.core.spi.metrics.HttpServerMetrics metrics();
descriptor: ()Lio/vertx/core/spi/metrics/HttpServerMetrics;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.metrics:Lio/vertx/core/spi/metrics/HttpServerMetrics;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
public void handleMessage(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=2
start local 0 start local 1 0: aload 1
instanceof io.netty.handler.codec.http.HttpRequest
ifeq 20
1: aload 1
checkcast io.netty.handler.codec.http.DefaultHttpRequest
astore 2
start local 2 2: aload 2
invokevirtual io.netty.handler.codec.http.DefaultHttpRequest.decoderResult:()Lio/netty/handler/codec/DecoderResult;
getstatic io.netty.handler.codec.DecoderResult.SUCCESS:Lio/netty/handler/codec/DecoderResult;
if_acmpeq 5
3: aload 0
aload 2
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.handleError:(Lio/netty/handler/codec/http/HttpObject;)V
4: return
5: StackMap locals: io.netty.handler.codec.http.DefaultHttpRequest
StackMap stack:
new io.vertx.core.http.impl.HttpServerRequestImpl
dup
aload 0
aload 2
invokespecial io.vertx.core.http.impl.HttpServerRequestImpl.<init>:(Lio/vertx/core/http/impl/Http1xServerConnection;Lio/netty/handler/codec/http/HttpRequest;)V
astore 3
start local 3 6: aload 0
dup
astore 4
monitorenter
7: aload 0
aload 3
putfield io.vertx.core.http.impl.Http1xServerConnection.requestInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
8: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.responseInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
ifnull 13
9: aload 3
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.pause:()Lio/vertx/core/http/HttpServerRequest;
pop
10: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.responseInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
aload 3
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.enqueue:(Lio/vertx/core/http/impl/HttpServerRequestImpl;)V
11: aload 4
monitorexit
12: return
13: StackMap locals: io.vertx.core.http.impl.HttpServerRequestImpl io.vertx.core.http.impl.Http1xServerConnection
StackMap stack:
aload 0
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.requestInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
putfield io.vertx.core.http.impl.Http1xServerConnection.responseInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
14: aload 4
monitorexit
15: goto 18
StackMap locals:
StackMap stack: java.lang.Throwable
16: aload 4
monitorexit
17: athrow
18: StackMap locals:
StackMap stack:
aload 3
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.requestHandler:Lio/vertx/core/Handler;
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.handleBegin:(Lio/vertx/core/Handler;)V
end local 3 end local 2 19: goto 28
StackMap locals:
StackMap stack:
20: aload 1
getstatic io.netty.handler.codec.http.LastHttpContent.EMPTY_LAST_CONTENT:Lio/netty/handler/codec/http/LastHttpContent;
if_acmpne 23
21: aload 0
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.handleEnd:()V
22: goto 28
StackMap locals:
StackMap stack:
23: aload 1
instanceof io.netty.handler.codec.http.HttpContent
ifeq 26
24: aload 0
aload 1
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.handleContent:(Ljava/lang/Object;)V
25: goto 28
StackMap locals:
StackMap stack:
26: aload 1
instanceof io.netty.handler.codec.http.websocketx.WebSocketFrame
ifeq 28
27: aload 0
aload 1
checkcast io.netty.handler.codec.http.websocketx.WebSocketFrame
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.handleWsFrame:(Lio/netty/handler/codec/http/websocketx/WebSocketFrame;)V
28: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 29 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 29 1 msg Ljava/lang/Object;
2 19 2 request Lio/netty/handler/codec/http/DefaultHttpRequest;
6 19 3 req Lio/vertx/core/http/impl/HttpServerRequestImpl;
Exception table:
from to target type
7 12 16 any
13 15 16 any
16 17 16 any
MethodParameters:
Name Flags
msg
private void handleContent(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=6, args_size=2
start local 0 start local 1 0: aload 1
checkcast io.netty.handler.codec.http.HttpContent
astore 2
start local 2 1: aload 2
invokeinterface io.netty.handler.codec.http.HttpContent.decoderResult:()Lio/netty/handler/codec/DecoderResult;
getstatic io.netty.handler.codec.DecoderResult.SUCCESS:Lio/netty/handler/codec/DecoderResult;
if_acmpeq 4
2: aload 0
aload 2
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.handleError:(Lio/netty/handler/codec/http/HttpObject;)V
3: return
4: StackMap locals: io.netty.handler.codec.http.HttpContent
StackMap stack:
aload 2
invokeinterface io.netty.handler.codec.http.HttpContent.content:()Lio/netty/buffer/ByteBuf;
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.alloc:()Lio/netty/buffer/ByteBufAllocator;
invokestatic io.vertx.core.net.impl.VertxHandler.safeBuffer:(Lio/netty/buffer/ByteBuf;Lio/netty/buffer/ByteBufAllocator;)Lio/netty/buffer/ByteBuf;
invokestatic io.vertx.core.buffer.Buffer.buffer:(Lio/netty/buffer/ByteBuf;)Lio/vertx/core/buffer/Buffer;
astore 3
start local 3 5: aload 0
dup
astore 5
monitorenter
6: getstatic io.vertx.core.spi.metrics.Metrics.METRICS_ENABLED:Z
ifeq 8
7: aload 0
aload 3
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.reportBytesRead:(Lio/vertx/core/buffer/Buffer;)V
8: StackMap locals: io.vertx.core.http.impl.Http1xServerConnection java.lang.Object io.netty.handler.codec.http.HttpContent io.vertx.core.buffer.Buffer top io.vertx.core.http.impl.Http1xServerConnection
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.requestInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
astore 4
start local 4 9: aload 5
monitorexit
10: goto 13
end local 4 StackMap locals:
StackMap stack: java.lang.Throwable
11: aload 5
monitorexit
12: athrow
start local 4 13: StackMap locals: io.vertx.core.http.impl.Http1xServerConnection java.lang.Object io.netty.handler.codec.http.HttpContent io.vertx.core.buffer.Buffer io.vertx.core.http.impl.HttpServerRequestImpl
StackMap stack:
aload 4
aload 3
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.handleContent:(Lio/vertx/core/buffer/Buffer;)V
14: aload 2
instanceof io.netty.handler.codec.http.LastHttpContent
ifeq 16
15: aload 0
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.handleEnd:()V
16: StackMap locals:
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 17 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 17 1 msg Ljava/lang/Object;
1 17 2 content Lio/netty/handler/codec/http/HttpContent;
5 17 3 buffer Lio/vertx/core/buffer/Buffer;
9 11 4 request Lio/vertx/core/http/impl/HttpServerRequestImpl;
13 17 4 request Lio/vertx/core/http/impl/HttpServerRequestImpl;
Exception table:
from to target type
6 10 11 any
11 12 11 any
MethodParameters:
Name Flags
msg
private void handleEnd();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
dup
astore 2
monitorenter
1: getstatic io.vertx.core.spi.metrics.Metrics.METRICS_ENABLED:Z
ifeq 3
2: aload 0
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.reportRequestComplete:()V
3: StackMap locals: io.vertx.core.http.impl.Http1xServerConnection top io.vertx.core.http.impl.Http1xServerConnection
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.requestInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
astore 1
start local 1 4: aload 0
aconst_null
putfield io.vertx.core.http.impl.Http1xServerConnection.requestInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
5: aload 2
monitorexit
6: goto 9
end local 1 StackMap locals:
StackMap stack: java.lang.Throwable
7: aload 2
monitorexit
8: athrow
start local 1 9: StackMap locals: io.vertx.core.http.impl.Http1xServerConnection io.vertx.core.http.impl.HttpServerRequestImpl
StackMap stack:
aload 1
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.handleEnd:()V
10: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
4 7 1 request Lio/vertx/core/http/impl/HttpServerRequestImpl;
9 11 1 request Lio/vertx/core/http/impl/HttpServerRequestImpl;
Exception table:
from to target type
1 6 7 any
7 8 7 any
synchronized void responseComplete();
descriptor: ()V
flags: (0x0020) ACC_SYNCHRONIZED
Code:
stack=2, locals=3, args_size=1
start local 0 0: getstatic io.vertx.core.spi.metrics.Metrics.METRICS_ENABLED:Z
ifeq 2
1: aload 0
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.reportResponseComplete:()V
2: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.responseInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
astore 1
start local 1 3: aload 0
aconst_null
putfield io.vertx.core.http.impl.Http1xServerConnection.responseInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
4: aload 1
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.next:()Lio/vertx/core/http/impl/HttpServerRequestImpl;
astore 2
start local 2 5: aload 2
ifnull 7
6: aload 0
aload 2
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.handleNext:(Lio/vertx/core/http/impl/HttpServerRequestImpl;)V
7: StackMap locals: io.vertx.core.http.impl.HttpServerRequestImpl io.vertx.core.http.impl.HttpServerRequestImpl
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
3 8 1 request Lio/vertx/core/http/impl/HttpServerRequestImpl;
5 8 2 next Lio/vertx/core/http/impl/HttpServerRequestImpl;
private void handleNext(io.vertx.core.http.impl.HttpServerRequestImpl);
descriptor: (Lio/vertx/core/http/impl/HttpServerRequestImpl;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.vertx.core.http.impl.Http1xServerConnection.responseInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
1: aload 0
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.getContext:()Lio/vertx/core/impl/ContextInternal;
aload 0
aload 1
invokedynamic handle(Lio/vertx/core/http/impl/Http1xServerConnection;Lio/vertx/core/http/impl/HttpServerRequestImpl;)Lio/vertx/core/Handler;
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;)V
io/vertx/core/http/impl/Http1xServerConnection.lambda$0(Lio/vertx/core/http/impl/HttpServerRequestImpl;Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.impl.ContextInternal.runOnContext:(Lio/vertx/core/Handler;)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 3 1 next Lio/vertx/core/http/impl/HttpServerRequestImpl;
MethodParameters:
Name Flags
next
public void doPause();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.channelPaused:Z
ifne 3
1: aload 0
iconst_1
putfield io.vertx.core.http.impl.Http1xServerConnection.channelPaused:Z
2: aload 0
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.doPause:()V
3: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
public void doResume();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.channelPaused:Z
ifeq 3
1: aload 0
iconst_0
putfield io.vertx.core.http.impl.Http1xServerConnection.channelPaused:Z
2: aload 0
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.doResume:()V
3: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
private void reportBytesRead(io.vertx.core.buffer.Buffer);
descriptor: (Lio/vertx/core/buffer/Buffer;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.metrics:Lio/vertx/core/spi/metrics/HttpServerMetrics;
ifnull 2
1: aload 0
dup
getfield io.vertx.core.http.impl.Http1xServerConnection.bytesRead:J
aload 1
invokeinterface io.vertx.core.buffer.Buffer.length:()I
i2l
ladd
putfield io.vertx.core.http.impl.Http1xServerConnection.bytesRead:J
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 3 1 buffer Lio/vertx/core/buffer/Buffer;
MethodParameters:
Name Flags
buffer
private void reportBytesWritten(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.metrics:Lio/vertx/core/spi/metrics/HttpServerMetrics;
ifnull 6
1: aload 0
aload 1
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.getBytes:(Ljava/lang/Object;)J
lstore 2
start local 2 2: lload 2
ldc -1
lcmp
ifne 5
3: getstatic io.vertx.core.http.impl.Http1xServerConnection.log:Lio/vertx/core/logging/Logger;
new java.lang.StringBuilder
dup
ldc "Metrics could not be updated to include bytes written because of unknown object "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc " being written."
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual io.vertx.core.logging.Logger.warn:(Ljava/lang/Object;)V
4: goto 6
5: StackMap locals: long
StackMap stack:
aload 0
dup
getfield io.vertx.core.http.impl.Http1xServerConnection.bytesWritten:J
lload 2
ladd
putfield io.vertx.core.http.impl.Http1xServerConnection.bytesWritten:J
end local 2 6: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 7 1 msg Ljava/lang/Object;
2 6 2 bytes J
MethodParameters:
Name Flags
msg
private void reportRequestComplete();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.metrics:Lio/vertx/core/spi/metrics/HttpServerMetrics;
ifnull 3
1: aload 0
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.bytesRead:J
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.reportBytesRead:(J)V
2: aload 0
lconst_0
putfield io.vertx.core.http.impl.Http1xServerConnection.bytesRead:J
3: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
private void reportResponseComplete();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.metrics:Lio/vertx/core/spi/metrics/HttpServerMetrics;
ifnull 8
1: aload 0
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.bytesWritten:J
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.reportBytesWritten:(J)V
2: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.requestFailed:Z
ifeq 6
3: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.metrics:Lio/vertx/core/spi/metrics/HttpServerMetrics;
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.responseInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.metric:()Ljava/lang/Object;
invokeinterface io.vertx.core.spi.metrics.HttpServerMetrics.requestReset:(Ljava/lang/Object;)V
4: aload 0
iconst_0
putfield io.vertx.core.http.impl.Http1xServerConnection.requestFailed:Z
5: goto 7
6: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.metrics:Lio/vertx/core/spi/metrics/HttpServerMetrics;
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.responseInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.metric:()Ljava/lang/Object;
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.responseInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.response:()Lio/vertx/core/http/impl/HttpServerResponseImpl;
invokeinterface io.vertx.core.spi.metrics.HttpServerMetrics.responseEnd:(Ljava/lang/Object;Lio/vertx/core/http/HttpServerResponse;)V
7: StackMap locals:
StackMap stack:
aload 0
lconst_0
putfield io.vertx.core.http.impl.Http1xServerConnection.bytesWritten:J
8: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
java.lang.String getServerOrigin();
descriptor: ()Ljava/lang/String;
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.serverOrigin:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
io.vertx.core.Vertx vertx();
descriptor: ()Lio/vertx/core/Vertx;
flags: (0x0000)
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.vertx:Lio/vertx/core/impl/VertxInternal;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
public void writeToChannel(java.lang.Object, io.netty.channel.ChannelPromise);
descriptor: (Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: getstatic io.vertx.core.spi.metrics.Metrics.METRICS_ENABLED:Z
ifeq 2
1: aload 0
aload 1
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.reportBytesWritten:(Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 2
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.writeToChannel:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 4 1 msg Ljava/lang/Object;
0 4 2 promise Lio/netty/channel/ChannelPromise;
MethodParameters:
Name Flags
msg
promise
io.vertx.core.http.impl.ServerWebSocketImpl createWebSocket(io.vertx.core.http.impl.HttpServerRequestImpl);
descriptor: (Lio/vertx/core/http/impl/HttpServerRequestImpl;)Lio/vertx/core/http/impl/ServerWebSocketImpl;
flags: (0x0000)
Code:
stack=9, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
ifnull 2
1: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.ServerWebSocketImpl
areturn
2: StackMap locals:
StackMap stack:
aload 1
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.nettyRequest:()Lio/netty/handler/codec/http/HttpRequest;
instanceof io.netty.handler.codec.http.FullHttpRequest
ifne 4
3: new java.lang.IllegalStateException
dup
invokespecial java.lang.IllegalStateException.<init>:()V
athrow
4: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.createHandshaker:(Lio/vertx/core/http/impl/HttpServerRequestImpl;)Lio/netty/handler/codec/http/websocketx/WebSocketServerHandshaker;
astore 2
start local 2 5: aload 2
ifnonnull 7
6: aconst_null
areturn
7: StackMap locals: io.netty.handler.codec.http.websocketx.WebSocketServerHandshaker
StackMap stack:
aload 0
8: new io.vertx.core.http.impl.ServerWebSocketImpl
dup
aload 0
aload 2
invokevirtual io.netty.handler.codec.http.websocketx.WebSocketServerHandshaker.version:()Lio/netty/handler/codec/http/websocketx/WebSocketVersion;
getstatic io.netty.handler.codec.http.websocketx.WebSocketVersion.V00:Lio/netty/handler/codec/http/websocketx/WebSocketVersion;
if_acmpeq 9
iconst_1
goto 10
StackMap locals: io.vertx.core.http.impl.Http1xServerConnection io.vertx.core.http.impl.HttpServerRequestImpl io.netty.handler.codec.http.websocketx.WebSocketServerHandshaker
StackMap stack: io.vertx.core.http.impl.Http1xServerConnection new 8 new 8 io.vertx.core.http.impl.Http1xServerConnection
9: iconst_0
10: StackMap locals: io.vertx.core.http.impl.Http1xServerConnection io.vertx.core.http.impl.HttpServerRequestImpl io.netty.handler.codec.http.websocketx.WebSocketServerHandshaker
StackMap stack: io.vertx.core.http.impl.Http1xServerConnection new 8 new 8 io.vertx.core.http.impl.Http1xServerConnection int
aload 1
aload 2
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.options:Lio/vertx/core/http/HttpServerOptions;
invokevirtual io.vertx.core.http.HttpServerOptions.getMaxWebsocketFrameSize:()I
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.options:Lio/vertx/core/http/HttpServerOptions;
invokevirtual io.vertx.core.http.HttpServerOptions.getMaxWebsocketMessageSize:()I
invokespecial io.vertx.core.http.impl.ServerWebSocketImpl.<init>:(Lio/vertx/core/http/impl/Http1xServerConnection;ZLio/vertx/core/http/impl/HttpServerRequestImpl;Lio/netty/handler/codec/http/websocketx/WebSocketServerHandshaker;II)V
11: putfield io.vertx.core.http.impl.Http1xServerConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
12: getstatic io.vertx.core.spi.metrics.Metrics.METRICS_ENABLED:Z
ifeq 14
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.metrics:Lio/vertx/core/spi/metrics/HttpServerMetrics;
ifnull 14
13: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.ServerWebSocketImpl
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.metrics:Lio/vertx/core/spi/metrics/HttpServerMetrics;
aload 0
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.metric:()Ljava/lang/Object;
aload 1
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.metric:()Ljava/lang/Object;
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.ServerWebSocket
invokeinterface io.vertx.core.spi.metrics.HttpServerMetrics.connected:(Ljava/lang/Object;Ljava/lang/Object;Lio/vertx/core/http/ServerWebSocket;)Ljava/lang/Object;
invokevirtual io.vertx.core.http.impl.ServerWebSocketImpl.setMetric:(Ljava/lang/Object;)V
14: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.ServerWebSocketImpl
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 15 1 request Lio/vertx/core/http/impl/HttpServerRequestImpl;
5 15 2 handshaker Lio/netty/handler/codec/http/websocketx/WebSocketServerHandshaker;
MethodParameters:
Name Flags
request
private io.netty.handler.codec.http.websocketx.WebSocketServerHandshaker createHandshaker(io.vertx.core.http.impl.HttpServerRequestImpl);
descriptor: (Lio/vertx/core/http/impl/HttpServerRequestImpl;)Lio/netty/handler/codec/http/websocketx/WebSocketServerHandshaker;
flags: (0x0002) ACC_PRIVATE
Code:
stack=7, locals=6, args_size=2
start local 0 start local 1 0: aload 0
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.channel:()Lio/netty/channel/Channel;
pop
1: aload 1
getstatic io.vertx.core.http.HttpHeaders.CONNECTION:Ljava/lang/CharSequence;
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.getHeader:(Ljava/lang/CharSequence;)Ljava/lang/String;
astore 2
start local 2 2: aload 2
ifnull 3
aload 2
invokevirtual java.lang.String.toLowerCase:()Ljava/lang/String;
ldc "upgrade"
invokevirtual java.lang.String.contains:(Ljava/lang/CharSequence;)Z
ifne 7
3: StackMap locals: java.lang.String
StackMap stack:
aload 1
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.response:()Lio/vertx/core/http/impl/HttpServerResponseImpl;
4: getstatic io.netty.handler.codec.http.HttpResponseStatus.BAD_REQUEST:Lio/netty/handler/codec/http/HttpResponseStatus;
invokevirtual io.netty.handler.codec.http.HttpResponseStatus.code:()I
invokevirtual io.vertx.core.http.impl.HttpServerResponseImpl.setStatusCode:(I)Lio/vertx/core/http/HttpServerResponse;
5: ldc "\"Connection\" header must be \"Upgrade\"."
invokeinterface io.vertx.core.http.HttpServerResponse.end:(Ljava/lang/String;)V
6: aconst_null
areturn
7: StackMap locals:
StackMap stack:
aload 1
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.method:()Lio/vertx/core/http/HttpMethod;
getstatic io.vertx.core.http.HttpMethod.GET:Lio/vertx/core/http/HttpMethod;
if_acmpeq 12
8: aload 1
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.response:()Lio/vertx/core/http/impl/HttpServerResponseImpl;
9: getstatic io.netty.handler.codec.http.HttpResponseStatus.METHOD_NOT_ALLOWED:Lio/netty/handler/codec/http/HttpResponseStatus;
invokevirtual io.netty.handler.codec.http.HttpResponseStatus.code:()I
invokevirtual io.vertx.core.http.impl.HttpServerResponseImpl.setStatusCode:(I)Lio/vertx/core/http/HttpServerResponse;
10: invokeinterface io.vertx.core.http.HttpServerResponse.end:()V
11: aconst_null
areturn
12: StackMap locals:
StackMap stack:
aload 1
aload 0
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.isSsl:()Z
invokestatic io.vertx.core.http.impl.HttpUtils.getWebSocketLocation:(Lio/vertx/core/http/HttpServerRequest;Z)Ljava/lang/String;
astore 3
start local 3 13: goto 19
end local 3 StackMap locals:
StackMap stack: java.lang.Exception
14: pop
15: aload 1
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.response:()Lio/vertx/core/http/impl/HttpServerResponseImpl;
16: getstatic io.netty.handler.codec.http.HttpResponseStatus.BAD_REQUEST:Lio/netty/handler/codec/http/HttpResponseStatus;
invokevirtual io.netty.handler.codec.http.HttpResponseStatus.code:()I
invokevirtual io.vertx.core.http.impl.HttpServerResponseImpl.setStatusCode:(I)Lio/vertx/core/http/HttpServerResponse;
17: ldc "Invalid request URI"
invokeinterface io.vertx.core.http.HttpServerResponse.end:(Ljava/lang/String;)V
18: aconst_null
areturn
start local 3 19: StackMap locals: java.lang.String
StackMap stack:
new io.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory
dup
aload 3
20: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.options:Lio/vertx/core/http/HttpServerOptions;
invokevirtual io.vertx.core.http.HttpServerOptions.getWebsocketSubProtocols:()Ljava/lang/String;
21: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.options:Lio/vertx/core/http/HttpServerOptions;
invokevirtual io.vertx.core.http.HttpServerOptions.getPerMessageWebsocketCompressionSupported:()Z
ifne 22
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.options:Lio/vertx/core/http/HttpServerOptions;
invokevirtual io.vertx.core.http.HttpServerOptions.getPerFrameWebsocketCompressionSupported:()Z
ifne 22
iconst_0
goto 23
StackMap locals: io.vertx.core.http.impl.Http1xServerConnection io.vertx.core.http.impl.HttpServerRequestImpl java.lang.String java.lang.String
StackMap stack: new 19 new 19 java.lang.String java.lang.String
22: iconst_1
23: StackMap locals: io.vertx.core.http.impl.Http1xServerConnection io.vertx.core.http.impl.HttpServerRequestImpl java.lang.String java.lang.String
StackMap stack: new 19 new 19 java.lang.String java.lang.String int
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.options:Lio/vertx/core/http/HttpServerOptions;
invokevirtual io.vertx.core.http.HttpServerOptions.getMaxWebsocketFrameSize:()I
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.options:Lio/vertx/core/http/HttpServerOptions;
invokevirtual io.vertx.core.http.HttpServerOptions.isAcceptUnmaskedFrames:()Z
24: invokespecial io.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory.<init>:(Ljava/lang/String;Ljava/lang/String;ZIZ)V
25: astore 4
start local 4 26: aload 4
aload 1
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.nettyRequest:()Lio/netty/handler/codec/http/HttpRequest;
invokevirtual io.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory.newHandshaker:(Lio/netty/handler/codec/http/HttpRequest;)Lio/netty/handler/codec/http/websocketx/WebSocketServerHandshaker;
astore 5
start local 5 27: aload 5
ifnonnull 32
28: aload 1
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.response:()Lio/vertx/core/http/impl/HttpServerResponseImpl;
29: getstatic io.netty.handler.codec.http.HttpHeaderNames.SEC_WEBSOCKET_VERSION:Lio/netty/util/AsciiString;
getstatic io.netty.handler.codec.http.websocketx.WebSocketVersion.V13:Lio/netty/handler/codec/http/websocketx/WebSocketVersion;
invokevirtual io.netty.handler.codec.http.websocketx.WebSocketVersion.toHttpHeaderValue:()Ljava/lang/String;
invokevirtual io.vertx.core.http.impl.HttpServerResponseImpl.putHeader:(Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Lio/vertx/core/http/HttpServerResponse;
30: getstatic io.netty.handler.codec.http.HttpResponseStatus.UPGRADE_REQUIRED:Lio/netty/handler/codec/http/HttpResponseStatus;
invokevirtual io.netty.handler.codec.http.HttpResponseStatus.code:()I
invokeinterface io.vertx.core.http.HttpServerResponse.setStatusCode:(I)Lio/vertx/core/http/HttpServerResponse;
31: invokeinterface io.vertx.core.http.HttpServerResponse.end:()V
32: StackMap locals: io.netty.handler.codec.http.websocketx.WebSocketServerHandshakerFactory io.netty.handler.codec.http.websocketx.WebSocketServerHandshaker
StackMap stack:
aload 5
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 33 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 33 1 request Lio/vertx/core/http/impl/HttpServerRequestImpl;
2 33 2 connectionHeader Ljava/lang/String;
13 14 3 wsURL Ljava/lang/String;
19 33 3 wsURL Ljava/lang/String;
26 33 4 factory Lio/netty/handler/codec/http/websocketx/WebSocketServerHandshakerFactory;
27 33 5 shake Lio/netty/handler/codec/http/websocketx/WebSocketServerHandshaker;
Exception table:
from to target type
12 13 14 Class java.lang.Exception
MethodParameters:
Name Flags
request
io.vertx.core.net.NetSocket createNetSocket();
descriptor: ()Lio/vertx/core/net/NetSocket;
flags: (0x0000)
Code:
stack=9, locals=5, args_size=1
start local 0 0: new java.util.HashMap
dup
iconst_1
invokespecial java.util.HashMap.<init>:(I)V
astore 1
start local 1 1: new io.vertx.core.http.impl.Http1xServerConnection$1
dup
aload 0
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.vertx:Lio/vertx/core/impl/VertxInternal;
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.context:Lio/vertx/core/impl/ContextInternal;
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.sslHelper:Lio/vertx/core/net/impl/SSLHelper;
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.metrics:Lio/vertx/core/spi/metrics/HttpServerMetrics;
aload 1
invokespecial io.vertx.core.http.impl.Http1xServerConnection$1.<init>:(Lio/vertx/core/http/impl/Http1xServerConnection;Lio/vertx/core/impl/VertxInternal;Lio/netty/channel/ChannelHandlerContext;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/net/impl/SSLHelper;Lio/vertx/core/spi/metrics/TCPMetrics;Ljava/util/Map;)V
astore 2
start local 2 2: aload 2
aload 0
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.metric:()Ljava/lang/Object;
invokevirtual io.vertx.core.net.impl.NetSocketImpl.metric:(Ljava/lang/Object;)V
3: aload 1
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.channel:()Lio/netty/channel/Channel;
aload 2
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 0
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.flush:()V
5: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
astore 3
start local 3 6: aload 3
ldc Lio/vertx/core/http/impl/HttpChunkContentCompressor;
invokeinterface io.netty.channel.ChannelPipeline.get:(Ljava/lang/Class;)Lio/netty/channel/ChannelHandler;
astore 4
start local 4 7: aload 4
ifnull 9
8: aload 3
aload 4
invokeinterface io.netty.channel.ChannelPipeline.remove:(Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelPipeline;
pop
9: StackMap locals: io.vertx.core.http.impl.Http1xServerConnection java.util.Map io.vertx.core.net.impl.NetSocketImpl io.netty.channel.ChannelPipeline io.netty.channel.ChannelHandler
StackMap stack:
aload 3
ldc "httpDecoder"
invokeinterface io.netty.channel.ChannelPipeline.remove:(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;
pop
10: aload 3
ldc "chunkedWriter"
invokeinterface io.netty.channel.ChannelPipeline.get:(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;
ifnull 12
11: aload 3
ldc "chunkedWriter"
invokeinterface io.netty.channel.ChannelPipeline.remove:(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;
pop
12: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
ldc "handler"
ldc "handler"
aload 2
invokestatic io.vertx.core.net.impl.VertxHandler.create:(Lio/vertx/core/net/impl/ConnectionBase;)Lio/vertx/core/net/impl/VertxHandler;
invokeinterface io.netty.channel.ChannelPipeline.replace:(Ljava/lang/String;Ljava/lang/String;Lio/netty/channel/ChannelHandler;)Lio/netty/channel/ChannelHandler;
pop
13: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
ldc "httpEncoder"
invokeinterface io.netty.channel.ChannelPipeline.remove:(Ljava/lang/String;)Lio/netty/channel/ChannelHandler;
pop
14: aload 2
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
1 15 1 connectionMap Ljava/util/Map<Lio/netty/channel/Channel;Lio/vertx/core/net/impl/NetSocketImpl;>;
2 15 2 socket Lio/vertx/core/net/impl/NetSocketImpl;
6 15 3 pipeline Lio/netty/channel/ChannelPipeline;
7 15 4 compressor Lio/netty/channel/ChannelHandler;
public synchronized void handleInterestedOpsChanged();
descriptor: ()V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.isNotWritable:()Z
ifne 6
1: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.responseInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
ifnull 4
2: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.responseInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.response:()Lio/vertx/core/http/impl/HttpServerResponseImpl;
invokevirtual io.vertx.core.http.impl.HttpServerResponseImpl.handleDrained:()V
3: goto 6
StackMap locals:
StackMap stack:
4: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
ifnull 6
5: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.ServerWebSocketImpl
invokevirtual io.vertx.core.http.impl.ServerWebSocketImpl.handleDrained:()V
6: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
void write100Continue();
descriptor: ()V
flags: (0x0000)
Code:
stack=5, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
new io.netty.handler.codec.http.DefaultFullHttpResponse
dup
getstatic io.netty.handler.codec.http.HttpVersion.HTTP_1_1:Lio/netty/handler/codec/http/HttpVersion;
getstatic io.netty.handler.codec.http.HttpResponseStatus.CONTINUE:Lio/netty/handler/codec/http/HttpResponseStatus;
invokespecial io.netty.handler.codec.http.DefaultFullHttpResponse.<init>:(Lio/netty/handler/codec/http/HttpVersion;Lio/netty/handler/codec/http/HttpResponseStatus;)V
invokeinterface io.netty.channel.ChannelHandlerContext.writeAndFlush:(Ljava/lang/Object;)Lio/netty/channel/ChannelFuture;
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
protected void handleClosed();
descriptor: ()V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=5, args_size=1
start local 0 0: aload 0
dup
astore 4
monitorenter
1: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.ServerWebSocketImpl
astore 3
start local 3 2: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.requestInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
astore 2
start local 2 3: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.responseInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
astore 1
start local 1 4: getstatic io.vertx.core.spi.metrics.Metrics.METRICS_ENABLED:Z
ifeq 7
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.metrics:Lio/vertx/core/spi/metrics/HttpServerMetrics;
ifnull 7
aload 3
ifnull 7
5: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.metrics:Lio/vertx/core/spi/metrics/HttpServerMetrics;
aload 3
invokevirtual io.vertx.core.http.impl.ServerWebSocketImpl.getMetric:()Ljava/lang/Object;
invokeinterface io.vertx.core.spi.metrics.HttpServerMetrics.disconnected:(Ljava/lang/Object;)V
6: aload 3
aconst_null
invokevirtual io.vertx.core.http.impl.ServerWebSocketImpl.setMetric:(Ljava/lang/Object;)V
7: StackMap locals: io.vertx.core.http.impl.Http1xServerConnection io.vertx.core.http.impl.HttpServerRequestImpl io.vertx.core.http.impl.HttpServerRequestImpl io.vertx.core.http.impl.ServerWebSocketImpl io.vertx.core.http.impl.Http1xServerConnection
StackMap stack:
aload 4
monitorexit
8: goto 11
end local 3 end local 2 end local 1 StackMap locals: io.vertx.core.http.impl.Http1xServerConnection top top top io.vertx.core.http.impl.Http1xServerConnection
StackMap stack: java.lang.Throwable
9: aload 4
monitorexit
10: athrow
start local 1 start local 2 start local 3 11: StackMap locals: io.vertx.core.http.impl.Http1xServerConnection io.vertx.core.http.impl.HttpServerRequestImpl io.vertx.core.http.impl.HttpServerRequestImpl io.vertx.core.http.impl.ServerWebSocketImpl
StackMap stack:
aload 2
ifnull 13
12: aload 2
getstatic io.vertx.core.http.impl.Http1xServerConnection.CLOSED_EXCEPTION:Lio/vertx/core/VertxException;
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.handleException:(Ljava/lang/Throwable;)V
13: StackMap locals:
StackMap stack:
aload 1
ifnull 15
aload 1
aload 2
if_acmpeq 15
14: aload 1
getstatic io.vertx.core.http.impl.Http1xServerConnection.CLOSED_EXCEPTION:Lio/vertx/core/VertxException;
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.handleException:(Ljava/lang/Throwable;)V
15: StackMap locals:
StackMap stack:
aload 3
ifnull 17
16: aload 3
invokevirtual io.vertx.core.http.impl.ServerWebSocketImpl.handleClosed:()V
17: StackMap locals:
StackMap stack:
aload 0
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.handleClosed:()V
18: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
4 9 1 responseInProgress Lio/vertx/core/http/impl/HttpServerRequestImpl;
11 19 1 responseInProgress Lio/vertx/core/http/impl/HttpServerRequestImpl;
3 9 2 requestInProgress Lio/vertx/core/http/impl/HttpServerRequestImpl;
11 19 2 requestInProgress Lio/vertx/core/http/impl/HttpServerRequestImpl;
2 9 3 ws Lio/vertx/core/http/impl/ServerWebSocketImpl;
11 19 3 ws Lio/vertx/core/http/impl/ServerWebSocketImpl;
Exception table:
from to target type
1 8 9 any
9 10 9 any
protected void handleException(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=6, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.handleException:(Ljava/lang/Throwable;)V
1: aload 0
dup
astore 5
monitorenter
2: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.ws:Lio/vertx/core/http/impl/WebSocketImplBase;
checkcast io.vertx.core.http.impl.ServerWebSocketImpl
astore 4
start local 4 3: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.requestInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
astore 3
start local 3 4: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.responseInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
astore 2
start local 2 5: getstatic io.vertx.core.spi.metrics.Metrics.METRICS_ENABLED:Z
ifeq 7
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.metrics:Lio/vertx/core/spi/metrics/HttpServerMetrics;
ifnull 7
6: aload 0
iconst_1
putfield io.vertx.core.http.impl.Http1xServerConnection.requestFailed:Z
7: StackMap locals: io.vertx.core.http.impl.Http1xServerConnection java.lang.Throwable io.vertx.core.http.impl.HttpServerRequestImpl io.vertx.core.http.impl.HttpServerRequestImpl io.vertx.core.http.impl.ServerWebSocketImpl io.vertx.core.http.impl.Http1xServerConnection
StackMap stack:
aload 5
monitorexit
8: goto 11
end local 4 end local 3 end local 2 StackMap locals: io.vertx.core.http.impl.Http1xServerConnection java.lang.Throwable top top top io.vertx.core.http.impl.Http1xServerConnection
StackMap stack: java.lang.Throwable
9: aload 5
monitorexit
10: athrow
start local 2 start local 3 start local 4 11: StackMap locals: io.vertx.core.http.impl.Http1xServerConnection java.lang.Throwable io.vertx.core.http.impl.HttpServerRequestImpl io.vertx.core.http.impl.HttpServerRequestImpl io.vertx.core.http.impl.ServerWebSocketImpl
StackMap stack:
aload 3
ifnull 13
12: aload 3
aload 1
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.handleException:(Ljava/lang/Throwable;)V
13: StackMap locals:
StackMap stack:
aload 2
ifnull 15
aload 2
aload 3
if_acmpeq 15
14: aload 2
aload 1
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.handleException:(Ljava/lang/Throwable;)V
15: StackMap locals:
StackMap stack:
aload 4
ifnull 17
16: aload 4
aload 1
invokevirtual io.vertx.core.http.impl.ServerWebSocketImpl.handleException:(Ljava/lang/Throwable;)V
17: StackMap locals:
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 18 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 18 1 t Ljava/lang/Throwable;
5 9 2 responseInProgress Lio/vertx/core/http/impl/HttpServerRequestImpl;
11 18 2 responseInProgress Lio/vertx/core/http/impl/HttpServerRequestImpl;
4 9 3 requestInProgress Lio/vertx/core/http/impl/HttpServerRequestImpl;
11 18 3 requestInProgress Lio/vertx/core/http/impl/HttpServerRequestImpl;
3 9 4 ws Lio/vertx/core/http/impl/ServerWebSocketImpl;
11 18 4 ws Lio/vertx/core/http/impl/ServerWebSocketImpl;
Exception table:
from to target type
2 8 9 any
9 10 9 any
MethodParameters:
Name Flags
t
protected void addFuture(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>, io.netty.channel.ChannelFuture);
descriptor: (Lio/vertx/core/Handler;Lio/netty/channel/ChannelFuture;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.addFuture:(Lio/vertx/core/Handler;Lio/netty/channel/ChannelFuture;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 2 1 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
0 2 2 future Lio/netty/channel/ChannelFuture;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;Lio/netty/channel/ChannelFuture;)V
MethodParameters:
Name Flags
completionHandler
future
protected boolean supportsFileRegion();
descriptor: ()Z
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.supportsFileRegion:()Z
ifeq 1
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.pipeline:()Lio/netty/channel/ChannelPipeline;
ldc Lio/vertx/core/http/impl/HttpChunkContentCompressor;
invokeinterface io.netty.channel.ChannelPipeline.get:(Ljava/lang/Class;)Lio/netty/channel/ChannelHandler;
ifnonnull 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
protected io.netty.channel.ChannelFuture sendFile(java.io.RandomAccessFile, long, long);
descriptor: (Ljava/io/RandomAccessFile;JJ)Lio/netty/channel/ChannelFuture;
flags: (0x0004) ACC_PROTECTED
Code:
stack=6, locals=6, args_size=4
start local 0 start local 1 start local 2 start local 4 0: aload 0
aload 1
lload 2
lload 4
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.sendFile:(Ljava/io/RandomAccessFile;JJ)Lio/netty/channel/ChannelFuture;
areturn
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 1 1 file Ljava/io/RandomAccessFile;
0 1 2 offset J
0 1 4 length J
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
file
offset
length
private void handleError(io.netty.handler.codec.http.HttpObject);
descriptor: (Lio/netty/handler/codec/http/HttpObject;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=9, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface io.netty.handler.codec.http.HttpObject.decoderResult:()Lio/netty/handler/codec/DecoderResult;
astore 2
start local 2 1: aload 2
invokevirtual io.netty.handler.codec.DecoderResult.cause:()Ljava/lang/Throwable;
astore 3
start local 3 2: aload 3
instanceof io.netty.handler.codec.TooLongFrameException
ifeq 21
3: aload 3
invokevirtual java.lang.Throwable.getMessage:()Ljava/lang/String;
astore 4
start local 4 4: aload 1
instanceof io.netty.handler.codec.http.HttpRequest
ifeq 7
5: aload 1
checkcast io.netty.handler.codec.http.HttpRequest
invokeinterface io.netty.handler.codec.http.HttpRequest.protocolVersion:()Lio/netty/handler/codec/http/HttpVersion;
astore 5
start local 5 6: goto 13
end local 5 StackMap locals: io.netty.handler.codec.DecoderResult java.lang.Throwable java.lang.String
StackMap stack:
7: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.requestInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
ifnull 12
8: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.requestInProgress:Lio/vertx/core/http/impl/HttpServerRequestImpl;
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.version:()Lio/vertx/core/http/HttpVersion;
getstatic io.vertx.core.http.HttpVersion.HTTP_1_0:Lio/vertx/core/http/HttpVersion;
if_acmpne 9
getstatic io.netty.handler.codec.http.HttpVersion.HTTP_1_0:Lio/netty/handler/codec/http/HttpVersion;
goto 10
StackMap locals:
StackMap stack:
9: getstatic io.netty.handler.codec.http.HttpVersion.HTTP_1_1:Lio/netty/handler/codec/http/HttpVersion;
StackMap locals:
StackMap stack: io.netty.handler.codec.http.HttpVersion
10: astore 5
start local 5 11: goto 13
end local 5 12: StackMap locals:
StackMap stack:
getstatic io.netty.handler.codec.http.HttpVersion.HTTP_1_1:Lio/netty/handler/codec/http/HttpVersion;
astore 5
start local 5 13: StackMap locals: io.netty.handler.codec.http.HttpVersion
StackMap stack:
aload 4
ldc "An HTTP line is larger than"
invokevirtual java.lang.String.startsWith:(Ljava/lang/String;)Z
ifeq 14
getstatic io.netty.handler.codec.http.HttpResponseStatus.REQUEST_URI_TOO_LONG:Lio/netty/handler/codec/http/HttpResponseStatus;
goto 15
StackMap locals:
StackMap stack:
14: getstatic io.netty.handler.codec.http.HttpResponseStatus.BAD_REQUEST:Lio/netty/handler/codec/http/HttpResponseStatus;
StackMap locals:
StackMap stack: io.netty.handler.codec.http.HttpResponseStatus
15: astore 6
start local 6 16: new io.netty.handler.codec.http.DefaultFullHttpResponse
dup
aload 5
aload 6
invokespecial io.netty.handler.codec.http.DefaultFullHttpResponse.<init>:(Lio/netty/handler/codec/http/HttpVersion;Lio/netty/handler/codec/http/HttpResponseStatus;)V
astore 7
start local 7 17: aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.chctx:Lio/netty/channel/ChannelHandlerContext;
invokeinterface io.netty.channel.ChannelHandlerContext.newPromise:()Lio/netty/channel/ChannelPromise;
astore 8
start local 8 18: aload 0
aload 7
aload 8
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.writeToChannel:(Ljava/lang/Object;Lio/netty/channel/ChannelPromise;)V
19: aload 8
aload 0
aload 2
invokedynamic operationComplete(Lio/vertx/core/http/impl/Http1xServerConnection;Lio/netty/handler/codec/DecoderResult;)Lio/netty/util/concurrent/GenericFutureListener;
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:
(Lio/netty/util/concurrent/Future;)V
io/vertx/core/http/impl/Http1xServerConnection.lambda$1(Lio/netty/handler/codec/DecoderResult;Lio/netty/util/concurrent/Future;)V (7)
(Lio/netty/util/concurrent/Future;)V
invokeinterface io.netty.channel.ChannelPromise.addListener:(Lio/netty/util/concurrent/GenericFutureListener;)Lio/netty/channel/ChannelPromise;
pop
end local 8 end local 7 end local 6 end local 5 end local 4 20: goto 22
21: StackMap locals:
StackMap stack:
aload 0
aload 2
invokevirtual io.netty.handler.codec.DecoderResult.cause:()Ljava/lang/Throwable;
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.fail:(Ljava/lang/Throwable;)V
22: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 23 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 23 1 obj Lio/netty/handler/codec/http/HttpObject;
1 23 2 result Lio/netty/handler/codec/DecoderResult;
2 23 3 cause Ljava/lang/Throwable;
4 20 4 causeMsg Ljava/lang/String;
6 7 5 version Lio/netty/handler/codec/http/HttpVersion;
11 12 5 version Lio/netty/handler/codec/http/HttpVersion;
13 20 5 version Lio/netty/handler/codec/http/HttpVersion;
16 20 6 status Lio/netty/handler/codec/http/HttpResponseStatus;
17 20 7 resp Lio/netty/handler/codec/http/DefaultFullHttpResponse;
18 20 8 fut Lio/netty/channel/ChannelPromise;
MethodParameters:
Name Flags
obj
private long getBytes(java.lang.Object);
descriptor: (Ljava/lang/Object;)J
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 1
ifnonnull 1
lconst_0
lreturn
1: StackMap locals:
StackMap stack:
aload 1
instanceof io.vertx.core.buffer.Buffer
ifeq 3
2: aload 1
checkcast io.vertx.core.buffer.Buffer
invokeinterface io.vertx.core.buffer.Buffer.length:()I
i2l
lreturn
3: StackMap locals:
StackMap stack:
aload 1
instanceof io.netty.buffer.ByteBuf
ifeq 5
4: aload 1
checkcast io.netty.buffer.ByteBuf
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
i2l
lreturn
5: StackMap locals:
StackMap stack:
aload 1
instanceof io.netty.handler.codec.http.HttpContent
ifeq 7
6: aload 1
checkcast io.netty.handler.codec.http.HttpContent
invokeinterface io.netty.handler.codec.http.HttpContent.content:()Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
i2l
lreturn
7: StackMap locals:
StackMap stack:
aload 1
instanceof io.netty.handler.codec.http.websocketx.WebSocketFrame
ifeq 9
8: aload 1
checkcast io.netty.handler.codec.http.websocketx.WebSocketFrame
invokevirtual io.netty.handler.codec.http.websocketx.WebSocketFrame.content:()Lio/netty/buffer/ByteBuf;
invokevirtual io.netty.buffer.ByteBuf.readableBytes:()I
i2l
lreturn
9: StackMap locals:
StackMap stack:
aload 1
instanceof io.netty.channel.FileRegion
ifeq 11
10: aload 1
checkcast io.netty.channel.FileRegion
invokeinterface io.netty.channel.FileRegion.count:()J
lreturn
11: StackMap locals:
StackMap stack:
aload 1
instanceof io.netty.handler.stream.ChunkedFile
ifeq 14
12: aload 1
checkcast io.netty.handler.stream.ChunkedFile
astore 2
start local 2 13: aload 2
invokevirtual io.netty.handler.stream.ChunkedFile.endOffset:()J
aload 2
invokevirtual io.netty.handler.stream.ChunkedFile.startOffset:()J
lsub
lreturn
end local 2 14: StackMap locals:
StackMap stack:
ldc -1
lreturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 15 1 obj Ljava/lang/Object;
13 14 2 file Lio/netty/handler/stream/ChunkedFile;
MethodParameters:
Name Flags
obj
public io.vertx.core.http.HttpConnection shutdown(long);
descriptor: (J)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=2
0: aload 0
lload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.shutdown:(J)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.HttpConnection shutdown();
descriptor: ()Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.shutdown:()Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.HttpConnection shutdownHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.shutdownHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.HttpConnection ping(io.vertx.core.buffer.Buffer, io.vertx.core.Handler);
descriptor: (Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
aload 2
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.ping:(Lio/vertx/core/buffer/Buffer;Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.HttpConnection updateSettings(io.vertx.core.http.Http2Settings, io.vertx.core.Handler);
descriptor: (Lio/vertx/core/http/Http2Settings;Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
aload 2
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.updateSettings:(Lio/vertx/core/http/Http2Settings;Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.HttpConnection updateSettings(io.vertx.core.http.Http2Settings);
descriptor: (Lio/vertx/core/http/Http2Settings;)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.updateSettings:(Lio/vertx/core/http/Http2Settings;)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.HttpConnection pingHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.pingHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.impl.Http1xConnectionBase exceptionHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/impl/Http1xConnectionBase;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/impl/Http1xConnectionBase;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.impl.Http1xConnectionBase closeHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/impl/Http1xConnectionBase;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/impl/Http1xConnectionBase;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.Http2Settings remoteSettings();
descriptor: ()Lio/vertx/core/http/Http2Settings;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.remoteSettings:()Lio/vertx/core/http/Http2Settings;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.spi.metrics.NetworkMetrics metrics();
descriptor: ()Lio/vertx/core/spi/metrics/NetworkMetrics;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.metrics:()Lio/vertx/core/spi/metrics/HttpServerMetrics;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.HttpConnection goAway(long, int, io.vertx.core.buffer.Buffer);
descriptor: (JILio/vertx/core/buffer/Buffer;)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=5, locals=5, args_size=4
0: aload 0
lload 1
iload 3
aload 4
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.goAway:(JILio/vertx/core/buffer/Buffer;)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.HttpConnection goAwayHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.goAwayHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.HttpConnection remoteSettingsHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.remoteSettingsHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/http/HttpConnection;
areturn
LocalVariableTable:
Start End Slot Name Signature
public void close(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.close:(Lio/vertx/core/Handler;)V
return
LocalVariableTable:
Start End Slot Name Signature
public void close();
descriptor: ()V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.close:()V
return
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.http.Http2Settings settings();
descriptor: ()Lio/vertx/core/http/Http2Settings;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokespecial io.vertx.core.http.impl.Http1xConnectionBase.settings:()Lio/vertx/core/http/Http2Settings;
areturn
LocalVariableTable:
Start End Slot Name Signature
private void lambda$0(io.vertx.core.http.impl.HttpServerRequestImpl, java.lang.Void);
descriptor: (Lio/vertx/core/http/impl/HttpServerRequestImpl;Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 1
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.resume:()Lio/vertx/core/http/HttpServerRequest;
pop
1: aload 1
aload 0
getfield io.vertx.core.http.impl.Http1xServerConnection.requestHandler:Lio/vertx/core/Handler;
invokevirtual io.vertx.core.http.impl.HttpServerRequestImpl.handleBegin:(Lio/vertx/core/Handler;)V
2: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 3 2 v Ljava/lang/Void;
private void lambda$1(io.netty.handler.codec.DecoderResult, io.netty.util.concurrent.Future);
descriptor: (Lio/netty/handler/codec/DecoderResult;Lio/netty/util/concurrent/Future;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 0
aload 1
invokevirtual io.netty.handler.codec.DecoderResult.cause:()Ljava/lang/Throwable;
invokevirtual io.vertx.core.http.impl.Http1xServerConnection.fail:(Ljava/lang/Throwable;)V
1: return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/http/impl/Http1xServerConnection;
0 2 2 res Lio/netty/util/concurrent/Future<-Ljava/lang/Void;>;
Exceptions:
throws java.lang.Exception
}
Signature: Lio/vertx/core/http/impl/Http1xConnectionBase<Lio/vertx/core/http/impl/ServerWebSocketImpl;>;Lio/vertx/core/http/impl/HttpServerConnection;
SourceFile: "Http1xServerConnection.java"
NestMembers:
io.vertx.core.http.impl.Http1xServerConnection$1
InnerClasses:
io.vertx.core.http.impl.Http1xServerConnection$1
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
Http1xServerConnection
log: Logger
metrics: HttpServerMetrics
handleClosed(): void
http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-core: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/
(Eclipse)