public class io.vertx.core.parsetools.impl.RecordParserImpl implements io.vertx.core.parsetools.RecordParser
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.core.parsetools.impl.RecordParserImpl
super_class: java.lang.Object
{
private static final io.vertx.core.buffer.Buffer EMPTY_BUFFER;
descriptor: Lio/vertx/core/buffer/Buffer;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private io.vertx.core.buffer.Buffer buff;
descriptor: Lio/vertx/core/buffer/Buffer;
flags: (0x0002) ACC_PRIVATE
private int pos;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private int start;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private int delimPos;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private boolean delimited;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private byte[] delim;
descriptor: [B
flags: (0x0002) ACC_PRIVATE
private int recordSize;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private int maxRecordSize;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private long demand;
descriptor: J
flags: (0x0002) ACC_PRIVATE
private io.vertx.core.Handler<io.vertx.core.buffer.Buffer> eventHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;
private io.vertx.core.Handler<java.lang.Void> endHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Void;>;
private io.vertx.core.Handler<java.lang.Throwable> exceptionHandler;
descriptor: Lio/vertx/core/Handler;
flags: (0x0002) ACC_PRIVATE
Signature: Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
private boolean parsing;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private boolean streamEnded;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private final io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer> stream;
descriptor: Lio/vertx/core/streams/ReadStream;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic io.netty.buffer.Unpooled.EMPTY_BUFFER:Lio/netty/buffer/ByteBuf;
invokestatic io.vertx.core.buffer.Buffer.buffer:(Lio/netty/buffer/ByteBuf;)Lio/vertx/core/buffer/Buffer;
putstatic io.vertx.core.parsetools.impl.RecordParserImpl.EMPTY_BUFFER:Lio/vertx/core/buffer/Buffer;
return
LocalVariableTable:
Start End Slot Name Signature
private void <init>(io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>);
descriptor: (Lio/vertx/core/streams/ReadStream;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
getstatic io.vertx.core.parsetools.impl.RecordParserImpl.EMPTY_BUFFER:Lio/vertx/core/buffer/Buffer;
putfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
2: aload 0
ldc 9223372036854775807
putfield io.vertx.core.parsetools.impl.RecordParserImpl.demand:J
3: aload 0
aload 1
putfield io.vertx.core.parsetools.impl.RecordParserImpl.stream:Lio/vertx/core/streams/ReadStream;
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
0 5 1 stream Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;
Signature: (Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;)V
MethodParameters:
Name Flags
stream
public void setOutput(io.vertx.core.Handler<io.vertx.core.buffer.Buffer>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "output"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
aload 1
putfield io.vertx.core.parsetools.impl.RecordParserImpl.eventHandler:Lio/vertx/core/Handler;
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
0 3 1 output Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;)V
MethodParameters:
Name Flags
output
public static io.vertx.core.buffer.Buffer latin1StringToBytes(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/vertx/core/buffer/Buffer;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=1
start local 0 0: aload 0
invokevirtual java.lang.String.length:()I
newarray 8
astore 1
start local 1 1: iconst_0
istore 2
start local 2 2: goto 6
3: StackMap locals: byte[] int
StackMap stack:
aload 0
iload 2
invokevirtual java.lang.String.charAt:(I)C
istore 3
start local 3 4: aload 1
iload 2
iload 3
sipush 255
iand
i2b
bastore
end local 3 5: iinc 2 1
StackMap locals:
StackMap stack:
6: iload 2
aload 0
invokevirtual java.lang.String.length:()I
if_icmplt 3
end local 2 7: aload 1
invokestatic io.vertx.core.buffer.Buffer.buffer:([B)Lio/vertx/core/buffer/Buffer;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 str Ljava/lang/String;
1 8 1 bytes [B
2 7 2 i I
4 5 3 c C
MethodParameters:
Name Flags
str
public static io.vertx.core.parsetools.RecordParser newDelimited(java.lang.String, io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>);
descriptor: (Ljava/lang/String;Lio/vertx/core/streams/ReadStream;Lio/vertx/core/Handler;)Lio/vertx/core/parsetools/RecordParser;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokestatic io.vertx.core.parsetools.impl.RecordParserImpl.latin1StringToBytes:(Ljava/lang/String;)Lio/vertx/core/buffer/Buffer;
aload 1
aload 2
invokestatic io.vertx.core.parsetools.impl.RecordParserImpl.newDelimited:(Lio/vertx/core/buffer/Buffer;Lio/vertx/core/streams/ReadStream;Lio/vertx/core/Handler;)Lio/vertx/core/parsetools/RecordParser;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 delim Ljava/lang/String;
0 1 1 stream Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;
0 1 2 output Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;
Signature: (Ljava/lang/String;Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;)Lio/vertx/core/parsetools/RecordParser;
MethodParameters:
Name Flags
delim
stream
output
public static io.vertx.core.parsetools.RecordParser newDelimited(io.vertx.core.buffer.Buffer, io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>);
descriptor: (Lio/vertx/core/buffer/Buffer;Lio/vertx/core/streams/ReadStream;Lio/vertx/core/Handler;)Lio/vertx/core/parsetools/RecordParser;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: new io.vertx.core.parsetools.impl.RecordParserImpl
dup
aload 1
invokespecial io.vertx.core.parsetools.impl.RecordParserImpl.<init>:(Lio/vertx/core/streams/ReadStream;)V
astore 3
start local 3 1: aload 3
aload 2
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/parsetools/RecordParser;
pop
2: aload 3
aload 0
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.delimitedMode:(Lio/vertx/core/buffer/Buffer;)V
3: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 delim Lio/vertx/core/buffer/Buffer;
0 4 1 stream Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;
0 4 2 output Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;
1 4 3 ls Lio/vertx/core/parsetools/impl/RecordParserImpl;
Signature: (Lio/vertx/core/buffer/Buffer;Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;)Lio/vertx/core/parsetools/RecordParser;
MethodParameters:
Name Flags
delim
stream
output
public static io.vertx.core.parsetools.RecordParser newFixed(int, io.vertx.core.streams.ReadStream<io.vertx.core.buffer.Buffer>, io.vertx.core.Handler<io.vertx.core.buffer.Buffer>);
descriptor: (ILio/vertx/core/streams/ReadStream;Lio/vertx/core/Handler;)Lio/vertx/core/parsetools/RecordParser;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: iload 0
ifle 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: ldc "Size must be > 0"
invokestatic io.vertx.core.impl.Arguments.require:(ZLjava/lang/String;)V
3: new io.vertx.core.parsetools.impl.RecordParserImpl
dup
aload 1
invokespecial io.vertx.core.parsetools.impl.RecordParserImpl.<init>:(Lio/vertx/core/streams/ReadStream;)V
astore 3
start local 3 4: aload 3
aload 2
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/parsetools/RecordParser;
pop
5: aload 3
iload 0
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.fixedSizeMode:(I)V
6: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 size I
0 7 1 stream Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;
0 7 2 output Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;
4 7 3 ls Lio/vertx/core/parsetools/impl/RecordParserImpl;
Signature: (ILio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;)Lio/vertx/core/parsetools/RecordParser;
MethodParameters:
Name Flags
size
stream
output
public void delimitedMode(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic io.vertx.core.parsetools.impl.RecordParserImpl.latin1StringToBytes:(Ljava/lang/String;)Lio/vertx/core/buffer/Buffer;
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.delimitedMode:(Lio/vertx/core/buffer/Buffer;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
0 2 1 delim Ljava/lang/String;
MethodParameters:
Name Flags
delim
public void delimitedMode(io.vertx.core.buffer.Buffer);
descriptor: (Lio/vertx/core/buffer/Buffer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ldc "delim"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: aload 0
iconst_1
putfield io.vertx.core.parsetools.impl.RecordParserImpl.delimited:Z
2: aload 0
aload 1
invokeinterface io.vertx.core.buffer.Buffer.getBytes:()[B
putfield io.vertx.core.parsetools.impl.RecordParserImpl.delim:[B
3: aload 0
iconst_0
putfield io.vertx.core.parsetools.impl.RecordParserImpl.delimPos:I
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
0 5 1 delim Lio/vertx/core/buffer/Buffer;
MethodParameters:
Name Flags
delim
public void fixedSizeMode(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: iload 1
ifle 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: ldc "Size must be > 0"
invokestatic io.vertx.core.impl.Arguments.require:(ZLjava/lang/String;)V
3: aload 0
iconst_0
putfield io.vertx.core.parsetools.impl.RecordParserImpl.delimited:Z
4: aload 0
iload 1
putfield io.vertx.core.parsetools.impl.RecordParserImpl.recordSize:I
5: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
0 6 1 size I
MethodParameters:
Name Flags
size
public io.vertx.core.parsetools.RecordParser maxRecordSize(int);
descriptor: (I)Lio/vertx/core/parsetools/RecordParser;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: iload 1
ifle 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: ldc "Size must be > 0"
invokestatic io.vertx.core.impl.Arguments.require:(ZLjava/lang/String;)V
3: aload 0
iload 1
putfield io.vertx.core.parsetools.impl.RecordParserImpl.maxRecordSize:I
4: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
0 5 1 size I
MethodParameters:
Name Flags
size
private void handleParsing();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=5, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.parsing:Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
iconst_1
putfield io.vertx.core.parsetools.impl.RecordParserImpl.parsing:Z
3: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.demand:J
lconst_0
lcmp
ifle 28
4: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.delimited:Z
ifeq 7
5: aload 0
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.parseDelimited:()I
istore 1
start local 1 6: goto 8
end local 1 7: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.parseFixed:()I
istore 1
start local 1 8: StackMap locals: int
StackMap stack:
iload 1
iconst_m1
if_icmpne 19
9: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.streamEnded:Z
ifeq 14
10: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
invokeinterface io.vertx.core.buffer.Buffer.length:()I
ifne 12
11: goto 31
12: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
invokeinterface io.vertx.core.buffer.Buffer.length:()I
istore 1
13: goto 19
14: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.stream:Lio/vertx/core/streams/ReadStream;
astore 2
start local 2 15: aload 2
ifnull 17
16: aload 2
invokeinterface io.vertx.core.streams.ReadStream.resume:()Lio/vertx/core/streams/ReadStream;
pop
17: StackMap locals: io.vertx.core.streams.ReadStream
StackMap stack:
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.streamEnded:Z
ifeq 31
18: goto 3
end local 2 19: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.demand:J
ldc 9223372036854775807
lcmp
ifeq 21
20: aload 0
dup
getfield io.vertx.core.parsetools.impl.RecordParserImpl.demand:J
lconst_1
lsub
putfield io.vertx.core.parsetools.impl.RecordParserImpl.demand:J
21: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.start:I
iload 1
invokeinterface io.vertx.core.buffer.Buffer.getBuffer:(II)Lio/vertx/core/buffer/Buffer;
astore 2
start local 2 22: aload 0
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.pos:I
putfield io.vertx.core.parsetools.impl.RecordParserImpl.start:I
23: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.eventHandler:Lio/vertx/core/Handler;
astore 3
start local 3 24: aload 3
ifnull 26
25: aload 3
aload 2
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
26: StackMap locals: io.vertx.core.buffer.Buffer io.vertx.core.Handler
StackMap stack:
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.streamEnded:Z
ifeq 3
27: goto 31
end local 3 end local 2 end local 1 28: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.stream:Lio/vertx/core/streams/ReadStream;
astore 1
start local 1 29: aload 1
ifnull 31
30: aload 1
invokeinterface io.vertx.core.streams.ReadStream.pause:()Lio/vertx/core/streams/ReadStream;
pop
end local 1 31: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
invokeinterface io.vertx.core.buffer.Buffer.length:()I
istore 1
start local 1 32: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.start:I
iload 1
if_icmpne 35
33: aload 0
getstatic io.vertx.core.parsetools.impl.RecordParserImpl.EMPTY_BUFFER:Lio/vertx/core/buffer/Buffer;
putfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
34: goto 37
StackMap locals: int
StackMap stack:
35: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.start:I
ifle 37
36: aload 0
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.start:I
iload 1
invokeinterface io.vertx.core.buffer.Buffer.getBuffer:(II)Lio/vertx/core/buffer/Buffer;
putfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
37: StackMap locals:
StackMap stack:
aload 0
dup
getfield io.vertx.core.parsetools.impl.RecordParserImpl.pos:I
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.start:I
isub
putfield io.vertx.core.parsetools.impl.RecordParserImpl.pos:I
38: aload 0
iconst_0
putfield io.vertx.core.parsetools.impl.RecordParserImpl.start:I
39: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.streamEnded:Z
ifeq 45
40: aload 0
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.end:()V
end local 1 41: goto 45
StackMap locals: io.vertx.core.parsetools.impl.RecordParserImpl
StackMap stack: java.lang.Throwable
42: astore 4
43: aload 0
iconst_0
putfield io.vertx.core.parsetools.impl.RecordParserImpl.parsing:Z
44: aload 4
athrow
45: StackMap locals:
StackMap stack:
aload 0
iconst_0
putfield io.vertx.core.parsetools.impl.RecordParserImpl.parsing:Z
46: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 47 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
6 7 1 next I
8 28 1 next I
15 19 2 s Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;
22 28 2 event Lio/vertx/core/buffer/Buffer;
24 28 3 handler Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;
29 31 1 s Lio/vertx/core/streams/ReadStream<Lio/vertx/core/buffer/Buffer;>;
32 41 1 len I
Exception table:
from to target type
3 42 42 any
private int parseDelimited();
descriptor: ()I
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
invokeinterface io.vertx.core.buffer.Buffer.length:()I
istore 1
start local 1 1: goto 12
2: StackMap locals: int
StackMap stack:
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.pos:I
invokeinterface io.vertx.core.buffer.Buffer.getByte:(I)B
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.delim:[B
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.delimPos:I
baload
if_icmpne 8
3: aload 0
dup
getfield io.vertx.core.parsetools.impl.RecordParserImpl.delimPos:I
iconst_1
iadd
putfield io.vertx.core.parsetools.impl.RecordParserImpl.delimPos:I
4: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.delimPos:I
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.delim:[B
arraylength
if_icmpne 11
5: aload 0
dup
getfield io.vertx.core.parsetools.impl.RecordParserImpl.pos:I
iconst_1
iadd
putfield io.vertx.core.parsetools.impl.RecordParserImpl.pos:I
6: aload 0
iconst_0
putfield io.vertx.core.parsetools.impl.RecordParserImpl.delimPos:I
7: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.pos:I
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.delim:[B
arraylength
isub
ireturn
8: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.delimPos:I
ifle 11
9: aload 0
dup
getfield io.vertx.core.parsetools.impl.RecordParserImpl.pos:I
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.delimPos:I
isub
putfield io.vertx.core.parsetools.impl.RecordParserImpl.pos:I
10: aload 0
iconst_0
putfield io.vertx.core.parsetools.impl.RecordParserImpl.delimPos:I
11: StackMap locals:
StackMap stack:
aload 0
dup
getfield io.vertx.core.parsetools.impl.RecordParserImpl.pos:I
iconst_1
iadd
putfield io.vertx.core.parsetools.impl.RecordParserImpl.pos:I
StackMap locals:
StackMap stack:
12: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.pos:I
iload 1
if_icmplt 2
13: iconst_m1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
1 14 1 len I
private int parseFixed();
descriptor: ()I
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
invokeinterface io.vertx.core.buffer.Buffer.length:()I
istore 1
start local 1 1: iload 1
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.start:I
isub
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.recordSize:I
if_icmplt 5
2: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.start:I
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.recordSize:I
iadd
istore 2
start local 2 3: aload 0
iload 2
putfield io.vertx.core.parsetools.impl.RecordParserImpl.pos:I
4: iload 2
ireturn
end local 2 5: StackMap locals: int
StackMap stack:
iconst_m1
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
1 6 1 len I
3 5 2 end I
public void handle(io.vertx.core.buffer.Buffer);
descriptor: (Lio/vertx/core/buffer/Buffer;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
invokeinterface io.vertx.core.buffer.Buffer.length:()I
ifne 3
1: aload 0
aload 1
putfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
aload 1
invokeinterface io.vertx.core.buffer.Buffer.appendBuffer:(Lio/vertx/core/buffer/Buffer;)Lio/vertx/core/buffer/Buffer;
pop
4: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.handleParsing:()V
5: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
ifnull 11
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.maxRecordSize:I
ifle 11
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.buff:Lio/vertx/core/buffer/Buffer;
invokeinterface io.vertx.core.buffer.Buffer.length:()I
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.maxRecordSize:I
if_icmple 11
6: new java.lang.IllegalStateException
dup
ldc "The current record is too long"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
astore 2
start local 2 7: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.exceptionHandler:Lio/vertx/core/Handler;
ifnull 10
8: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.exceptionHandler:Lio/vertx/core/Handler;
aload 2
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
9: goto 11
10: StackMap locals: java.lang.IllegalStateException
StackMap stack:
aload 2
athrow
end local 2 11: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
0 12 1 buffer Lio/vertx/core/buffer/Buffer;
7 11 2 ex Ljava/lang/IllegalStateException;
MethodParameters:
Name Flags
buffer
private void end();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.endHandler:Lio/vertx/core/Handler;
astore 1
start local 1 1: aload 1
ifnull 3
2: aload 1
aconst_null
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: StackMap locals: io.vertx.core.Handler
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
1 4 1 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
public io.vertx.core.parsetools.RecordParser exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/parsetools/RecordParser;
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.parsetools.impl.RecordParserImpl.exceptionHandler: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/parsetools/impl/RecordParserImpl;
0 2 1 handler Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Throwable;>;)Lio/vertx/core/parsetools/RecordParser;
MethodParameters:
Name Flags
handler
public io.vertx.core.parsetools.RecordParser handler(io.vertx.core.Handler<io.vertx.core.buffer.Buffer>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/parsetools/RecordParser;
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.parsetools.impl.RecordParserImpl.eventHandler:Lio/vertx/core/Handler;
1: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.stream:Lio/vertx/core/streams/ReadStream;
ifnull 10
2: aload 1
ifnull 7
3: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.stream:Lio/vertx/core/streams/ReadStream;
aload 0
invokedynamic handle(Lio/vertx/core/parsetools/impl/RecordParserImpl;)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/parsetools/impl/RecordParserImpl.lambda$0(Ljava/lang/Void;)V (7)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.streams.ReadStream.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
pop
4: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.stream:Lio/vertx/core/streams/ReadStream;
aload 0
invokedynamic handle(Lio/vertx/core/parsetools/impl/RecordParserImpl;)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/parsetools/impl/RecordParserImpl.lambda$1(Ljava/lang/Throwable;)V (7)
(Ljava/lang/Throwable;)V
invokeinterface io.vertx.core.streams.ReadStream.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
pop
5: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.stream:Lio/vertx/core/streams/ReadStream;
aload 0
invokeinterface io.vertx.core.streams.ReadStream.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
pop
6: goto 10
7: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.stream:Lio/vertx/core/streams/ReadStream;
aconst_null
invokeinterface io.vertx.core.streams.ReadStream.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
pop
8: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.stream:Lio/vertx/core/streams/ReadStream;
aconst_null
invokeinterface io.vertx.core.streams.ReadStream.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
pop
9: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.stream:Lio/vertx/core/streams/ReadStream;
aconst_null
invokeinterface io.vertx.core.streams.ReadStream.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
pop
10: StackMap locals:
StackMap stack:
aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
0 11 1 handler Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/buffer/Buffer;>;)Lio/vertx/core/parsetools/RecordParser;
MethodParameters:
Name Flags
handler
public io.vertx.core.parsetools.RecordParser pause();
descriptor: ()Lio/vertx/core/parsetools/RecordParser;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
lconst_0
putfield io.vertx.core.parsetools.impl.RecordParserImpl.demand:J
1: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
public io.vertx.core.parsetools.RecordParser fetch(long);
descriptor: (J)Lio/vertx/core/parsetools/RecordParser;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: lload 1
lconst_0
lcmp
ifle 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: ldc "Fetch amount must be > 0"
invokestatic io.vertx.core.impl.Arguments.require:(ZLjava/lang/String;)V
3: aload 0
dup
getfield io.vertx.core.parsetools.impl.RecordParserImpl.demand:J
lload 1
ladd
putfield io.vertx.core.parsetools.impl.RecordParserImpl.demand:J
4: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.demand:J
lconst_0
lcmp
ifge 6
5: aload 0
ldc 9223372036854775807
putfield io.vertx.core.parsetools.impl.RecordParserImpl.demand:J
6: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.handleParsing:()V
7: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
0 8 1 amount J
MethodParameters:
Name Flags
amount
public io.vertx.core.parsetools.RecordParser resume();
descriptor: ()Lio/vertx/core/parsetools/RecordParser;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
ldc 9223372036854775807
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.fetch:(J)Lio/vertx/core/parsetools/RecordParser;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
public io.vertx.core.parsetools.RecordParser endHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/parsetools/RecordParser;
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.parsetools.impl.RecordParserImpl.endHandler: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/parsetools/impl/RecordParserImpl;
0 2 1 handler Lio/vertx/core/Handler<Ljava/lang/Void;>;
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/core/parsetools/RecordParser;
MethodParameters:
Name Flags
handler
public io.vertx.core.streams.ReadStream pause();
descriptor: ()Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.pause:()Lio/vertx/core/parsetools/RecordParser;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream handler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.vertx.core.Handler
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.handler:(Lio/vertx/core/Handler;)Lio/vertx/core/parsetools/RecordParser;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream endHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/parsetools/RecordParser;
areturn
LocalVariableTable:
Start End Slot Name Signature
public void handle(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.vertx.core.buffer.Buffer
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.handle:(Lio/vertx/core/buffer/Buffer;)V
return
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream resume();
descriptor: ()Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: aload 0
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.resume:()Lio/vertx/core/parsetools/RecordParser;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream fetch(long);
descriptor: (J)Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=2
0: aload 0
lload 1
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.fetch:(J)Lio/vertx/core/parsetools/RecordParser;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.StreamBase exceptionHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/StreamBase;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/parsetools/RecordParser;
areturn
LocalVariableTable:
Start End Slot Name Signature
public io.vertx.core.streams.ReadStream exceptionHandler(io.vertx.core.Handler);
descriptor: (Lio/vertx/core/Handler;)Lio/vertx/core/streams/ReadStream;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/parsetools/RecordParser;
areturn
LocalVariableTable:
Start End Slot Name Signature
private void lambda$0(java.lang.Void);
descriptor: (Ljava/lang/Void;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iconst_1
putfield io.vertx.core.parsetools.impl.RecordParserImpl.streamEnded:Z
1: aload 0
invokevirtual io.vertx.core.parsetools.impl.RecordParserImpl.handleParsing:()V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/parsetools/impl/RecordParserImpl;
0 3 1 v Ljava/lang/Void;
private void lambda$1(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.exceptionHandler:Lio/vertx/core/Handler;
ifnull 2
1: aload 0
getfield io.vertx.core.parsetools.impl.RecordParserImpl.exceptionHandler:Lio/vertx/core/Handler;
aload 1
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
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/parsetools/impl/RecordParserImpl;
0 3 1 err Ljava/lang/Throwable;
}
SourceFile: "RecordParserImpl.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles