public abstract class oadd.org.apache.drill.exec.testing.Injection extends java.lang.Object
{
private static final org.slf4j.Logger logger;
protected final java.lang.String address;
protected final int port;
protected final java.lang.Class siteClass;
protected final java.lang.String desc;
private final java.util.concurrent.atomic.AtomicInteger nSkip;
private final java.util.concurrent.atomic.AtomicInteger nFire;
private final long msPause;
protected void <init>(java.lang.String, int, java.lang.String, java.lang.String, int, int, long) throws oadd.org.apache.drill.exec.testing.InjectionConfigurationException
{
long v;
java.util.concurrent.atomic.AtomicInteger v, v;
int v, v, v;
oadd.org.apache.drill.exec.testing.InjectionConfigurationException v, v, v, v;
java.lang.String v, v, v;
boolean v;
java.lang.Class v;
java.lang.ClassNotFoundException v;
oadd.org.apache.drill.exec.testing.Injection v;
v := @this: oadd.org.apache.drill.exec.testing.Injection;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: int;
v := @parameter: long;
specialinvoke v.<java.lang.Object: void <init>()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
label:
v = new oadd.org.apache.drill.exec.testing.InjectionConfigurationException;
specialinvoke v.<oadd.org.apache.drill.exec.testing.InjectionConfigurationException: void <init>(java.lang.String)>("Injection desc is null or empty.");
throw v;
label:
if v >= 0 goto label;
v = new oadd.org.apache.drill.exec.testing.InjectionConfigurationException;
specialinvoke v.<oadd.org.apache.drill.exec.testing.InjectionConfigurationException: void <init>(java.lang.String)>("Injection nSkip is not non-negative.");
throw v;
label:
if v > 0 goto label;
v = new oadd.org.apache.drill.exec.testing.InjectionConfigurationException;
specialinvoke v.<oadd.org.apache.drill.exec.testing.InjectionConfigurationException: void <init>(java.lang.String)>("Injection nFire is non-positive.");
throw v;
label:
v = staticinvoke <java.lang.Class: java.lang.Class forName(java.lang.String)>(v);
v.<oadd.org.apache.drill.exec.testing.Injection: java.lang.Class siteClass> = v;
label:
goto label;
label:
v := @caughtexception;
v = new oadd.org.apache.drill.exec.testing.InjectionConfigurationException;
specialinvoke v.<oadd.org.apache.drill.exec.testing.InjectionConfigurationException: void <init>(java.lang.String,java.lang.Throwable)>("Injection siteClass not found.", v);
throw v;
label:
v.<oadd.org.apache.drill.exec.testing.Injection: java.lang.String address> = v;
v.<oadd.org.apache.drill.exec.testing.Injection: int port> = v;
v.<oadd.org.apache.drill.exec.testing.Injection: java.lang.String desc> = v;
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(v);
v.<oadd.org.apache.drill.exec.testing.Injection: java.util.concurrent.atomic.AtomicInteger nSkip> = v;
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(v);
v.<oadd.org.apache.drill.exec.testing.Injection: java.util.concurrent.atomic.AtomicInteger nFire> = v;
v.<oadd.org.apache.drill.exec.testing.Injection: long msPause> = v;
return;
catch java.lang.ClassNotFoundException from label to label with label;
}
protected boolean injectNow()
{
org.slf4j.Logger v, v;
java.util.concurrent.atomic.AtomicInteger v, v;
int v, v;
java.lang.String v;
oadd.org.apache.drill.exec.testing.Injection v;
boolean v, v;
v := @this: oadd.org.apache.drill.exec.testing.Injection;
v = <oadd.org.apache.drill.exec.testing.Injection: org.slf4j.Logger logger>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.drill.exec.testing.Injection: org.slf4j.Logger logger>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.testing.Injection: java.lang.String toString()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
v = v.<oadd.org.apache.drill.exec.testing.Injection: java.util.concurrent.atomic.AtomicInteger nSkip>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int decrementAndGet()>();
if v >= 0 goto label;
v = v.<oadd.org.apache.drill.exec.testing.Injection: java.util.concurrent.atomic.AtomicInteger nFire>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int decrementAndGet()>();
if v < 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public java.lang.String getDesc()
{
java.lang.String v;
oadd.org.apache.drill.exec.testing.Injection v;
v := @this: oadd.org.apache.drill.exec.testing.Injection;
v = v.<oadd.org.apache.drill.exec.testing.Injection: java.lang.String desc>;
return v;
}
public java.lang.Class getSiteClass()
{
java.lang.Class v;
oadd.org.apache.drill.exec.testing.Injection v;
v := @this: oadd.org.apache.drill.exec.testing.Injection;
v = v.<oadd.org.apache.drill.exec.testing.Injection: java.lang.Class siteClass>;
return v;
}
public final boolean isValidForBit(oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint)
{
oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint v;
int v, v;
java.lang.String v, v, v;
oadd.org.apache.drill.exec.testing.Injection v;
boolean v, v;
v := @this: oadd.org.apache.drill.exec.testing.Injection;
v := @parameter: oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint;
v = v.<oadd.org.apache.drill.exec.testing.Injection: java.lang.String address>;
if v == null goto label;
v = v.<oadd.org.apache.drill.exec.testing.Injection: java.lang.String address>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint: java.lang.String getAddress()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.testing.Injection: int port>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint: int getUserPort()>();
if v != v goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public long getMsPause()
{
long v;
oadd.org.apache.drill.exec.testing.Injection v;
v := @this: oadd.org.apache.drill.exec.testing.Injection;
v = v.<oadd.org.apache.drill.exec.testing.Injection: long msPause>;
return v;
}
public java.lang.String toString()
{
long v;
java.util.concurrent.atomic.AtomicInteger v, v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
java.util.StringJoiner v, v, v, v, v, v, v, v;
java.lang.Class v, v;
oadd.org.apache.drill.exec.testing.Injection v;
v := @this: oadd.org.apache.drill.exec.testing.Injection;
v = new java.util.StringJoiner;
v = class "Loadd/org/apache/drill/exec/testing/Injection;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getSimpleName()>();
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[])>("\u[");
specialinvoke v.<java.util.StringJoiner: void <init>(java.lang.CharSequence,java.lang.CharSequence,java.lang.CharSequence)>(", ", v, "]");
v = v.<oadd.org.apache.drill.exec.testing.Injection: java.lang.String address>;
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[])>("address=\'\u0001\'");
v = virtualinvoke v.<java.util.StringJoiner: java.util.StringJoiner add(java.lang.CharSequence)>(v);
v = v.<oadd.org.apache.drill.exec.testing.Injection: int port>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("port=\u0001");
v = virtualinvoke v.<java.util.StringJoiner: java.util.StringJoiner add(java.lang.CharSequence)>(v);
v = v.<oadd.org.apache.drill.exec.testing.Injection: java.lang.Class siteClass>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Class)>(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[])>("siteClass=\u0001");
v = virtualinvoke v.<java.util.StringJoiner: java.util.StringJoiner add(java.lang.CharSequence)>(v);
v = v.<oadd.org.apache.drill.exec.testing.Injection: java.lang.String desc>;
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[])>("desc=\'\u0001\'");
v = virtualinvoke v.<java.util.StringJoiner: java.util.StringJoiner add(java.lang.CharSequence)>(v);
v = v.<oadd.org.apache.drill.exec.testing.Injection: java.util.concurrent.atomic.AtomicInteger nSkip>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.concurrent.atomic.AtomicInteger)>(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[])>("nSkip=\u0001");
v = virtualinvoke v.<java.util.StringJoiner: java.util.StringJoiner add(java.lang.CharSequence)>(v);
v = v.<oadd.org.apache.drill.exec.testing.Injection: java.util.concurrent.atomic.AtomicInteger nFire>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.concurrent.atomic.AtomicInteger)>(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[])>("nFire=\u0001");
v = virtualinvoke v.<java.util.StringJoiner: java.util.StringJoiner add(java.lang.CharSequence)>(v);
v = v.<oadd.org.apache.drill.exec.testing.Injection: long msPause>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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[])>("msPause=\u0001");
v = virtualinvoke v.<java.util.StringJoiner: java.util.StringJoiner add(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.StringJoiner: java.lang.String toString()>();
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/drill/exec/testing/Injection;");
<oadd.org.apache.drill.exec.testing.Injection: org.slf4j.Logger logger> = v;
return;
}
}