public final class io.netty.handler.codec.redis.FixedRedisMessagePool implements io.netty.handler.codec.redis.RedisMessagePool
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: io.netty.handler.codec.redis.FixedRedisMessagePool
super_class: java.lang.Object
{
private static final java.lang.String[] DEFAULT_SIMPLE_STRINGS;
descriptor: [Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.lang.String[] DEFAULT_ERRORS;
descriptor: [Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final long MIN_CACHED_INTEGER_NUMBER;
descriptor: J
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: -1
private static final long MAX_CACHED_INTEGER_NUMBER;
descriptor: J
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 128
private static final int SIZE_CACHED_INTEGER_NUMBER;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 129
public static final io.netty.handler.codec.redis.FixedRedisMessagePool INSTANCE;
descriptor: Lio/netty/handler/codec/redis/FixedRedisMessagePool;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
private final java.util.Map<io.netty.buffer.ByteBuf, io.netty.handler.codec.redis.SimpleStringRedisMessage> byteBufToSimpleStrings;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/redis/SimpleStringRedisMessage;>;
private final java.util.Map<java.lang.String, io.netty.handler.codec.redis.SimpleStringRedisMessage> stringToSimpleStrings;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/String;Lio/netty/handler/codec/redis/SimpleStringRedisMessage;>;
private final java.util.Map<io.netty.buffer.ByteBuf, io.netty.handler.codec.redis.ErrorRedisMessage> byteBufToErrors;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/redis/ErrorRedisMessage;>;
private final java.util.Map<java.lang.String, io.netty.handler.codec.redis.ErrorRedisMessage> stringToErrors;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/String;Lio/netty/handler/codec/redis/ErrorRedisMessage;>;
private final java.util.Map<io.netty.buffer.ByteBuf, io.netty.handler.codec.redis.IntegerRedisMessage> byteBufToIntegers;
descriptor: Ljava/util/Map;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Map<Lio/netty/buffer/ByteBuf;Lio/netty/handler/codec/redis/IntegerRedisMessage;>;
private final io.netty.util.collection.LongObjectMap<io.netty.handler.codec.redis.IntegerRedisMessage> longToIntegers;
descriptor: Lio/netty/util/collection/LongObjectMap;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/netty/util/collection/LongObjectMap<Lio/netty/handler/codec/redis/IntegerRedisMessage;>;
private final io.netty.util.collection.LongObjectMap<byte[]> longToByteBufs;
descriptor: Lio/netty/util/collection/LongObjectMap;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lio/netty/util/collection/LongObjectMap<[B>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=0, args_size=0
0: iconst_3
anewarray java.lang.String
dup
iconst_0
1: ldc "OK"
aastore
dup
iconst_1
2: ldc "PONG"
aastore
dup
iconst_2
3: ldc "QUEUED"
aastore
4: putstatic io.netty.handler.codec.redis.FixedRedisMessagePool.DEFAULT_SIMPLE_STRINGS:[Ljava/lang/String;
5: bipush 17
anewarray java.lang.String
dup
iconst_0
6: ldc "ERR"
aastore
dup
iconst_1
7: ldc "ERR index out of range"
aastore
dup
iconst_2
8: ldc "ERR no such key"
aastore
dup
iconst_3
9: ldc "ERR source and destination objects are the same"
aastore
dup
iconst_4
10: ldc "ERR syntax error"
aastore
dup
iconst_5
11: ldc "BUSY Redis is busy running a script. You can only call SCRIPT KILL or SHUTDOWN NOSAVE."
aastore
dup
bipush 6
12: ldc "BUSYKEY Target key name already exists."
aastore
dup
bipush 7
13: ldc "EXECABORT Transaction discarded because of previous errors."
aastore
dup
bipush 8
14: ldc "LOADING Redis is loading the dataset in memory"
aastore
dup
bipush 9
15: ldc "MASTERDOWN Link with MASTER is down and slave-serve-stale-data is set to 'no'."
aastore
dup
bipush 10
16: ldc "MISCONF Redis is configured to save RDB snapshots, but is currently not able to persist on disk. Commands that may modify the data set are disabled. Please check Redis logs for details about the error."
aastore
dup
bipush 11
17: ldc "NOAUTH Authentication required."
aastore
dup
bipush 12
18: ldc "NOREPLICAS Not enough good slaves to write."
aastore
dup
bipush 13
19: ldc "NOSCRIPT No matching script. Please use EVAL."
aastore
dup
bipush 14
20: ldc "OOM command not allowed when used memory > 'maxmemory'."
aastore
dup
bipush 15
21: ldc "READONLY You can't write against a read only slave."
aastore
dup
bipush 16
22: ldc "WRONGTYPE Operation against a key holding the wrong kind of value"
aastore
23: putstatic io.netty.handler.codec.redis.FixedRedisMessagePool.DEFAULT_ERRORS:[Ljava/lang/String;
24: new io.netty.handler.codec.redis.FixedRedisMessagePool
dup
invokespecial io.netty.handler.codec.redis.FixedRedisMessagePool.<init>:()V
putstatic io.netty.handler.codec.redis.FixedRedisMessagePool.INSTANCE:Lio/netty/handler/codec/redis/FixedRedisMessagePool;
return
LocalVariableTable:
Start End Slot Name Signature
private void <init>();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=7, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.HashMap
dup
getstatic io.netty.handler.codec.redis.FixedRedisMessagePool.DEFAULT_SIMPLE_STRINGS:[Ljava/lang/String;
arraylength
fconst_1
invokespecial java.util.HashMap.<init>:(IF)V
putfield io.netty.handler.codec.redis.FixedRedisMessagePool.byteBufToSimpleStrings:Ljava/util/Map;
2: aload 0
new java.util.HashMap
dup
getstatic io.netty.handler.codec.redis.FixedRedisMessagePool.DEFAULT_SIMPLE_STRINGS:[Ljava/lang/String;
arraylength
fconst_1
invokespecial java.util.HashMap.<init>:(IF)V
putfield io.netty.handler.codec.redis.FixedRedisMessagePool.stringToSimpleStrings:Ljava/util/Map;
3: getstatic io.netty.handler.codec.redis.FixedRedisMessagePool.DEFAULT_SIMPLE_STRINGS:[Ljava/lang/String;
dup
astore 4
arraylength
istore 3
iconst_0
istore 2
goto 11
StackMap locals: io.netty.handler.codec.redis.FixedRedisMessagePool top int int java.lang.String[]
StackMap stack:
4: aload 4
iload 2
aaload
astore 1
start local 1 5: aload 1
getstatic io.netty.util.CharsetUtil.UTF_8:Ljava/nio/charset/Charset;
invokevirtual java.lang.String.getBytes:(Ljava/nio/charset/Charset;)[B
invokestatic io.netty.buffer.Unpooled.wrappedBuffer:([B)Lio/netty/buffer/ByteBuf;
invokestatic io.netty.buffer.Unpooled.unreleasableBuffer:(Lio/netty/buffer/ByteBuf;)Lio/netty/buffer/ByteBuf;
6: invokestatic io.netty.buffer.Unpooled.unmodifiableBuffer:(Lio/netty/buffer/ByteBuf;)Lio/netty/buffer/ByteBuf;
astore 5
start local 5 7: new io.netty.handler.codec.redis.SimpleStringRedisMessage
dup
aload 1
invokespecial io.netty.handler.codec.redis.SimpleStringRedisMessage.<init>:(Ljava/lang/String;)V
astore 6
start local 6 8: aload 0
getfield io.netty.handler.codec.redis.FixedRedisMessagePool.byteBufToSimpleStrings:Ljava/util/Map;
aload 5
aload 6
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
9: aload 0
getfield io.netty.handler.codec.redis.FixedRedisMessagePool.stringToSimpleStrings:Ljava/util/Map;
aload 1
aload 6
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 6 end local 5 end local 1 10: iinc 2 1
StackMap locals:
StackMap stack:
11: iload 2
iload 3
if_icmplt 4
12: aload 0
new java.util.HashMap
dup
getstatic io.netty.handler.codec.redis.FixedRedisMessagePool.DEFAULT_ERRORS:[Ljava/lang/String;
arraylength
fconst_1
invokespecial java.util.HashMap.<init>:(IF)V
putfield io.netty.handler.codec.redis.FixedRedisMessagePool.byteBufToErrors:Ljava/util/Map;
13: aload 0
new java.util.HashMap
dup
getstatic io.netty.handler.codec.redis.FixedRedisMessagePool.DEFAULT_ERRORS:[Ljava/lang/String;
arraylength
fconst_1
invokespecial java.util.HashMap.<init>:(IF)V
putfield io.netty.handler.codec.redis.FixedRedisMessagePool.stringToErrors:Ljava/util/Map;
14: getstatic io.netty.handler.codec.redis.FixedRedisMessagePool.DEFAULT_ERRORS:[Ljava/lang/String;
dup
astore 4
arraylength
istore 3
iconst_0
istore 2
goto 22
StackMap locals:
StackMap stack:
15: aload 4
iload 2
aaload
astore 1
start local 1 16: aload 1
getstatic io.netty.util.CharsetUtil.UTF_8:Ljava/nio/charset/Charset;
invokevirtual java.lang.String.getBytes:(Ljava/nio/charset/Charset;)[B
invokestatic io.netty.buffer.Unpooled.wrappedBuffer:([B)Lio/netty/buffer/ByteBuf;
invokestatic io.netty.buffer.Unpooled.unreleasableBuffer:(Lio/netty/buffer/ByteBuf;)Lio/netty/buffer/ByteBuf;
17: invokestatic io.netty.buffer.Unpooled.unmodifiableBuffer:(Lio/netty/buffer/ByteBuf;)Lio/netty/buffer/ByteBuf;
astore 5
start local 5 18: new io.netty.handler.codec.redis.ErrorRedisMessage
dup
aload 1
invokespecial io.netty.handler.codec.redis.ErrorRedisMessage.<init>:(Ljava/lang/String;)V
astore 6
start local 6 19: aload 0
getfield io.netty.handler.codec.redis.FixedRedisMessagePool.byteBufToErrors:Ljava/util/Map;
aload 5
aload 6
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
20: aload 0
getfield io.netty.handler.codec.redis.FixedRedisMessagePool.stringToErrors:Ljava/util/Map;
aload 1
aload 6
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 6 end local 5 end local 1 21: iinc 2 1
StackMap locals:
StackMap stack:
22: iload 2
iload 3
if_icmplt 15
23: aload 0
new java.util.HashMap
dup
sipush 129
fconst_1
invokespecial java.util.HashMap.<init>:(IF)V
putfield io.netty.handler.codec.redis.FixedRedisMessagePool.byteBufToIntegers:Ljava/util/Map;
24: aload 0
new io.netty.util.collection.LongObjectHashMap
dup
sipush 129
fconst_1
invokespecial io.netty.util.collection.LongObjectHashMap.<init>:(IF)V
putfield io.netty.handler.codec.redis.FixedRedisMessagePool.longToIntegers:Lio/netty/util/collection/LongObjectMap;
25: aload 0
new io.netty.util.collection.LongObjectHashMap
dup
sipush 129
fconst_1
invokespecial io.netty.util.collection.LongObjectHashMap.<init>:(IF)V
putfield io.netty.handler.codec.redis.FixedRedisMessagePool.longToByteBufs:Lio/netty/util/collection/LongObjectMap;
26: ldc -1
lstore 1
start local 1 27: goto 36
28: StackMap locals: io.netty.handler.codec.redis.FixedRedisMessagePool long
StackMap stack:
lload 1
invokestatic io.netty.handler.codec.redis.RedisCodecUtil.longToAsciiBytes:(J)[B
astore 3
start local 3 29: aload 3
invokestatic io.netty.buffer.Unpooled.wrappedBuffer:([B)Lio/netty/buffer/ByteBuf;
30: invokestatic io.netty.buffer.Unpooled.unreleasableBuffer:(Lio/netty/buffer/ByteBuf;)Lio/netty/buffer/ByteBuf;
invokestatic io.netty.buffer.Unpooled.unmodifiableBuffer:(Lio/netty/buffer/ByteBuf;)Lio/netty/buffer/ByteBuf;
astore 4
start local 4 31: new io.netty.handler.codec.redis.IntegerRedisMessage
dup
lload 1
invokespecial io.netty.handler.codec.redis.IntegerRedisMessage.<init>:(J)V
astore 5
start local 5 32: aload 0
getfield io.netty.handler.codec.redis.FixedRedisMessagePool.byteBufToIntegers:Ljava/util/Map;
aload 4
aload 5
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
33: aload 0
getfield io.netty.handler.codec.redis.FixedRedisMessagePool.longToIntegers:Lio/netty/util/collection/LongObjectMap;
lload 1
aload 5
invokeinterface io.netty.util.collection.LongObjectMap.put:(JLjava/lang/Object;)Ljava/lang/Object;
pop
34: aload 0
getfield io.netty.handler.codec.redis.FixedRedisMessagePool.longToByteBufs:Lio/netty/util/collection/LongObjectMap;
lload 1
aload 3
invokeinterface io.netty.util.collection.LongObjectMap.put:(JLjava/lang/Object;)Ljava/lang/Object;
pop
end local 5 end local 4 end local 3 35: lload 1
lconst_1
ladd
lstore 1
StackMap locals:
StackMap stack:
36: lload 1
ldc 128
lcmp
iflt 28
end local 1 37: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 38 0 this Lio/netty/handler/codec/redis/FixedRedisMessagePool;
5 10 1 message Ljava/lang/String;
7 10 5 key Lio/netty/buffer/ByteBuf;
8 10 6 cached Lio/netty/handler/codec/redis/SimpleStringRedisMessage;
16 21 1 message Ljava/lang/String;
18 21 5 key Lio/netty/buffer/ByteBuf;
19 21 6 cached Lio/netty/handler/codec/redis/ErrorRedisMessage;
27 37 1 value J
29 35 3 keyBytes [B
31 35 4 keyByteBuf Lio/netty/buffer/ByteBuf;
32 35 5 cached Lio/netty/handler/codec/redis/IntegerRedisMessage;
public io.netty.handler.codec.redis.SimpleStringRedisMessage getSimpleString(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/netty/handler/codec/redis/SimpleStringRedisMessage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.netty.handler.codec.redis.FixedRedisMessagePool.stringToSimpleStrings:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.netty.handler.codec.redis.SimpleStringRedisMessage
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/handler/codec/redis/FixedRedisMessagePool;
0 1 1 content Ljava/lang/String;
MethodParameters:
Name Flags
content
public io.netty.handler.codec.redis.SimpleStringRedisMessage getSimpleString(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/redis/SimpleStringRedisMessage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.netty.handler.codec.redis.FixedRedisMessagePool.byteBufToSimpleStrings:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.netty.handler.codec.redis.SimpleStringRedisMessage
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/handler/codec/redis/FixedRedisMessagePool;
0 1 1 content Lio/netty/buffer/ByteBuf;
MethodParameters:
Name Flags
content
public io.netty.handler.codec.redis.ErrorRedisMessage getError(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/netty/handler/codec/redis/ErrorRedisMessage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.netty.handler.codec.redis.FixedRedisMessagePool.stringToErrors:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.netty.handler.codec.redis.ErrorRedisMessage
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/handler/codec/redis/FixedRedisMessagePool;
0 1 1 content Ljava/lang/String;
MethodParameters:
Name Flags
content
public io.netty.handler.codec.redis.ErrorRedisMessage getError(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/redis/ErrorRedisMessage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.netty.handler.codec.redis.FixedRedisMessagePool.byteBufToErrors:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.netty.handler.codec.redis.ErrorRedisMessage
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/handler/codec/redis/FixedRedisMessagePool;
0 1 1 content Lio/netty/buffer/ByteBuf;
MethodParameters:
Name Flags
content
public io.netty.handler.codec.redis.IntegerRedisMessage getInteger(long);
descriptor: (J)Lio/netty/handler/codec/redis/IntegerRedisMessage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.netty.handler.codec.redis.FixedRedisMessagePool.longToIntegers:Lio/netty/util/collection/LongObjectMap;
lload 1
invokeinterface io.netty.util.collection.LongObjectMap.get:(J)Ljava/lang/Object;
checkcast io.netty.handler.codec.redis.IntegerRedisMessage
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/handler/codec/redis/FixedRedisMessagePool;
0 1 1 value J
MethodParameters:
Name Flags
value
public io.netty.handler.codec.redis.IntegerRedisMessage getInteger(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)Lio/netty/handler/codec/redis/IntegerRedisMessage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.netty.handler.codec.redis.FixedRedisMessagePool.byteBufToIntegers:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.netty.handler.codec.redis.IntegerRedisMessage
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/handler/codec/redis/FixedRedisMessagePool;
0 1 1 content Lio/netty/buffer/ByteBuf;
MethodParameters:
Name Flags
content
public byte[] getByteBufOfInteger(long);
descriptor: (J)[B
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.netty.handler.codec.redis.FixedRedisMessagePool.longToByteBufs:Lio/netty/util/collection/LongObjectMap;
lload 1
invokeinterface io.netty.util.collection.LongObjectMap.get:(J)Ljava/lang/Object;
checkcast byte[]
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/netty/handler/codec/redis/FixedRedisMessagePool;
0 1 1 value J
MethodParameters:
Name Flags
value
}
SourceFile: "FixedRedisMessagePool.java"