public class org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector extends org.apache.dubbo.rpc.cluster.router.AbstractRouter
{
public static final java.lang.String NAME;
private static final int MOCK_INVOKERS_DEFAULT_PRIORITY;
public void <init>()
{
int v;
org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector v;
v := @this: org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector;
specialinvoke v.<org.apache.dubbo.rpc.cluster.router.AbstractRouter: void <init>()>();
v = (int) -100;
v.<org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector: int priority> = v;
return;
}
public java.util.List route(java.util.List, org.apache.dubbo.common.URL, org.apache.dubbo.rpc.Invocation) throws org.apache.dubbo.rpc.RpcException
{
org.apache.dubbo.rpc.Invocation v;
java.util.List v, v, v, v;
org.apache.dubbo.common.URL v;
org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector v;
java.util.Map v, v;
java.lang.Boolean v;
java.lang.Object v;
java.lang.String v;
boolean v, v;
v := @this: org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector;
v := @parameter: java.util.List;
v := @parameter: org.apache.dubbo.common.URL;
v := @parameter: org.apache.dubbo.rpc.Invocation;
v = staticinvoke <org.apache.dubbo.common.utils.CollectionUtils: boolean isEmpty(java.util.Collection)>(v);
if v == 0 goto label;
return v;
label:
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.util.Map getObjectAttachments()>();
if v != null goto label;
v = specialinvoke v.<org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector: java.util.List getNormalInvokers(java.util.List)>(v);
return v;
label:
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invocation: java.util.Map getObjectAttachments()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("invocation.need.mock");
if v != null goto label;
v = specialinvoke v.<org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector: java.util.List getNormalInvokers(java.util.List)>(v);
return v;
label:
v = <java.lang.Boolean: java.lang.Boolean TRUE>;
v = virtualinvoke v.<java.lang.Boolean: java.lang.String toString()>();
v = virtualinvoke v.<java.lang.String: boolean equalsIgnoreCase(java.lang.String)>(v);
if v == 0 goto label;
v = specialinvoke v.<org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector: java.util.List getMockedInvokers(java.util.List)>(v);
return v;
label:
return v;
}
private java.util.List getMockedInvokers(java.util.List)
{
java.util.Iterator v;
java.util.ArrayList v;
java.util.List v;
org.apache.dubbo.common.URL v;
org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector v;
java.lang.Object v;
java.lang.String v;
boolean v, v, v;
v := @this: org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector;
v := @parameter: java.util.List;
v = specialinvoke v.<org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector: boolean hasMockProviders(java.util.List)>(v);
if v != 0 goto label;
return null;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(1);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invoker: org.apache.dubbo.common.URL getUrl()>();
v = virtualinvoke v.<org.apache.dubbo.common.URL: java.lang.String getProtocol()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("mock");
if v == 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
}
private java.util.List getNormalInvokers(java.util.List)
{
java.util.Iterator v;
java.util.ArrayList v;
java.util.List v;
org.apache.dubbo.common.URL v;
org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector v;
int v;
java.lang.Object v;
java.lang.String v;
boolean v, v, v;
v := @this: org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector;
v := @parameter: java.util.List;
v = specialinvoke v.<org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector: boolean hasMockProviders(java.util.List)>(v);
if v != 0 goto label;
return v;
label:
v = new java.util.ArrayList;
v = interfaceinvoke v.<java.util.List: int size()>();
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invoker: org.apache.dubbo.common.URL getUrl()>();
v = virtualinvoke v.<org.apache.dubbo.common.URL: java.lang.String getProtocol()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("mock");
if v != 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
}
private boolean hasMockProviders(java.util.List)
{
java.util.Iterator v;
java.util.List v;
org.apache.dubbo.common.URL v;
org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector v;
java.lang.Object v;
java.lang.String v;
boolean v, v, v;
v := @this: org.apache.dubbo.rpc.cluster.router.mock.MockInvokersSelector;
v := @parameter: java.util.List;
v = 0;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.dubbo.rpc.Invoker: org.apache.dubbo.common.URL getUrl()>();
v = virtualinvoke v.<org.apache.dubbo.common.URL: java.lang.String getProtocol()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("mock");
if v == 0 goto label;
v = 1;
label:
return v;
}
}