public final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool extends java.lang.Object implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisMessagePool
{
private static final java.lang.String[] DEFAULT_SIMPLE_STRINGS;
private static final java.lang.String[] DEFAULT_ERRORS;
private static final long MIN_CACHED_INTEGER_NUMBER;
private static final long MAX_CACHED_INTEGER_NUMBER;
private static final int SIZE_CACHED_INTEGER_NUMBER;
public static final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool INSTANCE;
private final java.util.Map byteBufToSimpleStrings;
private final java.util.Map stringToSimpleStrings;
private final java.util.Map byteBufToErrors;
private final java.util.Map stringToErrors;
private final java.util.Map byteBufToIntegers;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectMap longToIntegers;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectMap longToByteBufs;
private void <init>()
{
byte[] v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.SimpleStringRedisMessage v;
byte v;
java.util.Map v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectMap v, v;
java.lang.String[] v, v, v, v, v, v;
java.util.HashMap v, v, v, v, v;
long v;
java.nio.charset.Charset v, v;
int v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.IntegerRedisMessage v;
java.lang.String v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectHashMap v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v, v, v, v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.ErrorRedisMessage v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.HashMap;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.lang.String[] DEFAULT_SIMPLE_STRINGS>;
v = lengthof v;
specialinvoke v.<java.util.HashMap: void <init>(int,float)>(v, 1.0F);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.util.Map byteBufToSimpleStrings> = v;
v = new java.util.HashMap;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.lang.String[] DEFAULT_SIMPLE_STRINGS>;
v = lengthof v;
specialinvoke v.<java.util.HashMap: void <init>(int,float)>(v, 1.0F);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.util.Map stringToSimpleStrings> = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.lang.String[] DEFAULT_SIMPLE_STRINGS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.CharsetUtil: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.Unpooled: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf wrappedBuffer(byte[])>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.Unpooled: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf unreleasableBuffer(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.Unpooled: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf unmodifiableBuffer(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.SimpleStringRedisMessage;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.SimpleStringRedisMessage: void <init>(java.lang.String)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.util.Map byteBufToSimpleStrings>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.util.Map stringToSimpleStrings>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
v = new java.util.HashMap;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.lang.String[] DEFAULT_ERRORS>;
v = lengthof v;
specialinvoke v.<java.util.HashMap: void <init>(int,float)>(v, 1.0F);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.util.Map byteBufToErrors> = v;
v = new java.util.HashMap;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.lang.String[] DEFAULT_ERRORS>;
v = lengthof v;
specialinvoke v.<java.util.HashMap: void <init>(int,float)>(v, 1.0F);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.util.Map stringToErrors> = v;
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.lang.String[] DEFAULT_ERRORS>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.CharsetUtil: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.Unpooled: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf wrappedBuffer(byte[])>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.Unpooled: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf unreleasableBuffer(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.Unpooled: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf unmodifiableBuffer(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.ErrorRedisMessage;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.ErrorRedisMessage: void <init>(java.lang.String)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.util.Map byteBufToErrors>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.util.Map stringToErrors>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(int,float)>(129, 1.0F);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.util.Map byteBufToIntegers> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectHashMap;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectHashMap: void <init>(int,float)>(129, 1.0F);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectMap longToIntegers> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectHashMap;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectHashMap: void <init>(int,float)>(129, 1.0F);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectMap longToByteBufs> = v;
v = -1L;
label:
v = v cmp 128L;
if v >= 0 goto label;
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.RedisCodecUtil: byte[] longToAsciiBytes(long)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.Unpooled: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf wrappedBuffer(byte[])>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.Unpooled: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf unreleasableBuffer(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.Unpooled: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf unmodifiableBuffer(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)>(v);
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.IntegerRedisMessage;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.IntegerRedisMessage: void <init>(long)>(v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.util.Map byteBufToIntegers>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectMap longToIntegers>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectMap: java.lang.Object put(long,java.lang.Object)>(v, v);
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectMap longToByteBufs>;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectMap: java.lang.Object put(long,java.lang.Object)>(v, v);
v = v + 1L;
goto label;
label:
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.SimpleStringRedisMessage getSimpleString(java.lang.String)
{
java.util.Map v;
java.lang.Object v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool;
v := @parameter: java.lang.String;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.util.Map stringToSimpleStrings>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.SimpleStringRedisMessage getSimpleString(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
java.util.Map v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.util.Map byteBufToSimpleStrings>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.ErrorRedisMessage getError(java.lang.String)
{
java.util.Map v;
java.lang.Object v;
java.lang.String v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool;
v := @parameter: java.lang.String;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.util.Map stringToErrors>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.ErrorRedisMessage getError(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
java.util.Map v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.util.Map byteBufToErrors>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.IntegerRedisMessage getInteger(long)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectMap v;
java.lang.Object v;
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool;
v := @parameter: long;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectMap longToIntegers>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectMap: java.lang.Object get(long)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.IntegerRedisMessage getInteger(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf)
{
java.util.Map v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.buffer.ByteBuf;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.util.Map byteBufToIntegers>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public byte[] getByteBufOfInteger(long)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectMap v;
java.lang.Object v;
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool;
v := @parameter: long;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectMap longToByteBufs>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.collection.LongObjectMap: java.lang.Object get(long)>(v);
return v;
}
static void <clinit>()
{
java.lang.String[] v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool v;
v = newarray (java.lang.String)[3];
v[0] = "OK";
v[1] = "PONG";
v[2] = "QUEUED";
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.lang.String[] DEFAULT_SIMPLE_STRINGS> = v;
v = newarray (java.lang.String)[17];
v[0] = "ERR";
v[1] = "ERR index out of range";
v[2] = "ERR no such key";
v[3] = "ERR source and destination objects are the same";
v[4] = "ERR syntax error";
v[5] = "BUSY Redis is busy running a script. You can only call SCRIPT KILL or SHUTDOWN NOSAVE.";
v[6] = "BUSYKEY Target key name already exists.";
v[7] = "EXECABORT Transaction discarded because of previous errors.";
v[8] = "LOADING Redis is loading the dataset in memory";
v[9] = "MASTERDOWN Link with MASTER is down and slave-serve-stale-data is set to \'no\'.";
v[10] = "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.";
v[11] = "NOAUTH Authentication required.";
v[12] = "NOREPLICAS Not enough good slaves to write.";
v[13] = "NOSCRIPT No matching script. Please use EVAL.";
v[14] = "OOM command not allowed when used memory > \'maxmemory\'.";
v[15] = "READONLY You can\'t write against a read only slave.";
v[16] = "WRONGTYPE Operation against a key holding the wrong kind of value";
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: java.lang.String[] DEFAULT_ERRORS> = v;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: void <init>()>();
<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.redis.FixedRedisMessagePool INSTANCE> = v;
return;
}
}