class org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1 extends org.apache.dubbo.rpc.protocol.AbstractInvoker
{
final redis.clients.jedis.JedisPool val$jedisPool;
final java.lang.String val$get;
final java.lang.Class val$type;
final org.apache.dubbo.common.URL val$url;
final java.lang.String val$set;
final int val$expiry;
final java.lang.String val$delete;
final org.apache.dubbo.rpc.protocol.redis.RedisProtocol this$0;
void <init>(org.apache.dubbo.rpc.protocol.redis.RedisProtocol, java.lang.Class, org.apache.dubbo.common.URL, redis.clients.jedis.JedisPool, java.lang.String, java.lang.Class, org.apache.dubbo.common.URL, java.lang.String, int, java.lang.String)
{
org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1 v;
org.apache.dubbo.common.URL v, v;
org.apache.dubbo.rpc.protocol.redis.RedisProtocol v;
int v;
java.lang.Class v, v;
redis.clients.jedis.JedisPool v;
java.lang.String v, v, v;
v := @this: org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1;
v := @parameter: org.apache.dubbo.rpc.protocol.redis.RedisProtocol;
v := @parameter: java.lang.Class;
v := @parameter: org.apache.dubbo.common.URL;
v := @parameter: redis.clients.jedis.JedisPool;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Class;
v := @parameter: org.apache.dubbo.common.URL;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: java.lang.String;
v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: org.apache.dubbo.rpc.protocol.redis.RedisProtocol this$0> = v;
v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: redis.clients.jedis.JedisPool val$jedisPool> = v;
v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: java.lang.String val$get> = v;
v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: java.lang.Class val$type> = v;
v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: org.apache.dubbo.common.URL val$url> = v;
v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: java.lang.String val$set> = v;
v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: int val$expiry> = v;
v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: java.lang.String val$delete> = v;
specialinvoke v.<org.apache.dubbo.rpc.protocol.AbstractInvoker: void <init>(java.lang.Class,org.apache.dubbo.common.URL)>(v, v);
return;
}
protected org.apache.dubbo.rpc.Result doInvoke(org.apache.dubbo.rpc.Invocation) throws java.lang.Throwable
{
byte[] v, v, v, v, v;
java.lang.Throwable v;
java.lang.Object[] v, v, v, v, v, v, v;
java.io.ByteArrayOutputStream v;
org.apache.dubbo.rpc.Invocation v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.UnsupportedOperationException v;
org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1 v;
redis.clients.jedis.Jedis v;
org.apache.dubbo.common.URL v, v, v, v, v, v, v, v;
java.io.ByteArrayInputStream v;
redis.clients.jedis.JedisPool v;
boolean v, v, v, v, v, v, v;
org.apache.dubbo.rpc.AsyncRpcResult v, v, v, v;
org.apache.dubbo.rpc.RpcException v;
org.apache.dubbo.rpc.protocol.redis.RedisProtocol v, v;
int v, v, v, v, v, v;
java.lang.IllegalArgumentException v, v, v;
org.apache.dubbo.common.serialize.Serialization v, v;
org.apache.dubbo.common.serialize.ObjectOutput v;
java.lang.Class v, v, v, v;
java.lang.Object v, v, v, v, v;
org.apache.dubbo.common.serialize.ObjectInput v;
v := @this: org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1;
v := @parameter: org.apache.dubbo.rpc.Invocation;
label:
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: redis.clients.jedis.JedisPool val$jedisPool>;
v = virtualinvoke v.<redis.clients.jedis.JedisPool: redis.clients.jedis.Jedis getResource()>();
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: java.lang.String val$get>;
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.lang.String getMethodName()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.lang.Object[] getArguments()>();
v = lengthof v;
if v == 1 goto label;
v = new java.lang.IllegalArgumentException;
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: java.lang.Class val$type>;
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.lang.String getMethodName()>();
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: org.apache.dubbo.common.URL val$url>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,org.apache.dubbo.common.URL)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("The redis get method arguments mismatch, must only one arguments. interface: \u, method: \u, url: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.lang.Object[] getArguments()>();
v = v[0];
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = virtualinvoke v.<redis.clients.jedis.Jedis: byte[] get(byte[])>(v);
if v != null goto label;
v = staticinvoke <org.apache.dubbo.rpc.AsyncRpcResult: org.apache.dubbo.rpc.AsyncRpcResult newDefaultAsyncResult(org.apache.dubbo.rpc.Invocation)>(v);
label:
return v;
label:
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: org.apache.dubbo.rpc.protocol.redis.RedisProtocol this$0>;
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: org.apache.dubbo.common.URL val$url>;
v = specialinvoke v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol: org.apache.dubbo.common.serialize.Serialization getSerialization(org.apache.dubbo.common.URL)>(v);
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: org.apache.dubbo.common.URL val$url>;
v = new java.io.ByteArrayInputStream;
specialinvoke v.<java.io.ByteArrayInputStream: void <init>(byte[])>(v);
v = interfaceinvoke v.<org.apache.dubbo.common.serialize.Serialization: org.apache.dubbo.common.serialize.ObjectInput deserialize(org.apache.dubbo.common.URL,java.io.InputStream)>(v, v);
v = interfaceinvoke v.<org.apache.dubbo.common.serialize.ObjectInput: java.lang.Object readObject()>();
v = staticinvoke <org.apache.dubbo.rpc.AsyncRpcResult: org.apache.dubbo.rpc.AsyncRpcResult newDefaultAsyncResult(java.lang.Object,org.apache.dubbo.rpc.Invocation)>(v, v);
label:
return v;
label:
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: java.lang.String val$set>;
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.lang.String getMethodName()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.lang.Object[] getArguments()>();
v = lengthof v;
if v == 2 goto label;
v = new java.lang.IllegalArgumentException;
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: java.lang.Class val$type>;
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.lang.String getMethodName()>();
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: org.apache.dubbo.common.URL val$url>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,org.apache.dubbo.common.URL)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("The redis set method arguments mismatch, must be two arguments. interface: \u, method: \u, url: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.lang.Object[] getArguments()>();
v = v[0];
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = new java.io.ByteArrayOutputStream;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>()>();
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: org.apache.dubbo.rpc.protocol.redis.RedisProtocol this$0>;
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: org.apache.dubbo.common.URL val$url>;
v = specialinvoke v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol: org.apache.dubbo.common.serialize.Serialization getSerialization(org.apache.dubbo.common.URL)>(v);
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: org.apache.dubbo.common.URL val$url>;
v = interfaceinvoke v.<org.apache.dubbo.common.serialize.Serialization: org.apache.dubbo.common.serialize.ObjectOutput serialize(org.apache.dubbo.common.URL,java.io.OutputStream)>(v, v);
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.lang.Object[] getArguments()>();
v = v[1];
interfaceinvoke v.<org.apache.dubbo.common.serialize.ObjectOutput: void writeObject(java.lang.Object)>(v);
v = virtualinvoke v.<java.io.ByteArrayOutputStream: byte[] toByteArray()>();
virtualinvoke v.<redis.clients.jedis.Jedis: java.lang.String set(byte[],byte[])>(v, v);
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: int val$expiry>;
if v <= 1000 goto label;
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: int val$expiry>;
v = v / 1000;
virtualinvoke v.<redis.clients.jedis.Jedis: java.lang.Long expire(byte[],int)>(v, v);
label:
v = staticinvoke <org.apache.dubbo.rpc.AsyncRpcResult: org.apache.dubbo.rpc.AsyncRpcResult newDefaultAsyncResult(org.apache.dubbo.rpc.Invocation)>(v);
label:
return v;
label:
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: java.lang.String val$delete>;
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.lang.String getMethodName()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.lang.Object[] getArguments()>();
v = lengthof v;
if v == 1 goto label;
v = new java.lang.IllegalArgumentException;
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: java.lang.Class val$type>;
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.lang.String getMethodName()>();
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: org.apache.dubbo.common.URL val$url>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,org.apache.dubbo.common.URL)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("The redis delete method arguments mismatch, must only one arguments. interface: \u, method: \u, url: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.lang.Object[] getArguments()>();
v = v[0];
v = staticinvoke <java.lang.String: java.lang.String valueOf(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<redis.clients.jedis.Jedis: java.lang.Long del(byte[])>(v);
v = staticinvoke <org.apache.dubbo.rpc.AsyncRpcResult: org.apache.dubbo.rpc.AsyncRpcResult newDefaultAsyncResult(org.apache.dubbo.rpc.Invocation)>(v);
label:
return v;
label:
v = new java.lang.UnsupportedOperationException;
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.lang.String getMethodName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unsupported method \u in redis service.");
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
label:
v := @caughtexception;
v = new org.apache.dubbo.rpc.RpcException;
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: java.lang.Class val$type>;
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.lang.String getMethodName()>();
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: org.apache.dubbo.common.URL val$url>;
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,org.apache.dubbo.common.URL,java.lang.String)>(v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to invoke redis service method. interface: \u, method: \u, url: \u, cause: \u0001");
specialinvoke v.<org.apache.dubbo.rpc.RpcException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
v = v instanceof java.net.SocketTimeoutException;
if v == 0 goto label;
virtualinvoke v.<org.apache.dubbo.rpc.RpcException: void setCode(int)>(2);
goto label;
label:
v = v instanceof redis.clients.jedis.exceptions.JedisConnectionException;
if v != 0 goto label;
v = v instanceof java.io.IOException;
if v == 0 goto label;
label:
virtualinvoke v.<org.apache.dubbo.rpc.RpcException: void setCode(int)>(1);
goto label;
label:
v = v instanceof redis.clients.jedis.exceptions.JedisDataException;
if v == 0 goto label;
virtualinvoke v.<org.apache.dubbo.rpc.RpcException: void setCode(int)>(5);
label:
throw v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public void destroy()
{
java.lang.Throwable v;
org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1 v;
org.apache.dubbo.common.logger.Logger v;
redis.clients.jedis.JedisPool v;
java.lang.String v;
v := @this: org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1;
specialinvoke v.<org.apache.dubbo.rpc.protocol.AbstractInvoker: void destroy()>();
label:
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: redis.clients.jedis.JedisPool val$jedisPool>;
virtualinvoke v.<redis.clients.jedis.JedisPool: void destroy()>();
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.dubbo.rpc.protocol.redis.RedisProtocol$1: org.apache.dubbo.common.logger.Logger logger>;
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
interfaceinvoke v.<org.apache.dubbo.common.logger.Logger: void warn(java.lang.String,java.lang.Throwable)>(v, v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
}