public class oadd.org.apache.hadoop.util.Progress extends java.lang.Object
{
private static final org.slf4j.Logger LOG;
private java.lang.String status;
private float progress;
private int currentPhase;
private java.util.ArrayList phases;
private oadd.org.apache.hadoop.util.Progress parent;
private boolean fixedWeightageForAllPhases;
private float progressPerPhase;
private java.util.ArrayList progressWeightagesForPhases;
public void <init>()
{
oadd.org.apache.hadoop.util.Progress v;
java.util.ArrayList v, v;
v := @this: oadd.org.apache.hadoop.util.Progress;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<oadd.org.apache.hadoop.util.Progress: java.lang.String status> = "";
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<oadd.org.apache.hadoop.util.Progress: java.util.ArrayList phases> = v;
v.<oadd.org.apache.hadoop.util.Progress: boolean fixedWeightageForAllPhases> = 0;
v.<oadd.org.apache.hadoop.util.Progress: float progressPerPhase> = 0.0F;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<oadd.org.apache.hadoop.util.Progress: java.util.ArrayList progressWeightagesForPhases> = v;
return;
}
public oadd.org.apache.hadoop.util.Progress addPhase(java.lang.String)
{
java.lang.String v;
oadd.org.apache.hadoop.util.Progress v, v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v := @parameter: java.lang.String;
v = virtualinvoke v.<oadd.org.apache.hadoop.util.Progress: oadd.org.apache.hadoop.util.Progress addPhase()>();
virtualinvoke v.<oadd.org.apache.hadoop.util.Progress: void setStatus(java.lang.String)>(v);
return v;
}
public synchronized oadd.org.apache.hadoop.util.Progress addPhase()
{
int v;
float v;
oadd.org.apache.hadoop.util.Progress v, v;
java.util.ArrayList v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v = specialinvoke v.<oadd.org.apache.hadoop.util.Progress: oadd.org.apache.hadoop.util.Progress addNewPhase()>();
v = v.<oadd.org.apache.hadoop.util.Progress: java.util.ArrayList phases>;
v = virtualinvoke v.<java.util.ArrayList: int size()>();
v = 1.0F / v;
v.<oadd.org.apache.hadoop.util.Progress: float progressPerPhase> = v;
v.<oadd.org.apache.hadoop.util.Progress: boolean fixedWeightageForAllPhases> = 1;
return v;
}
private synchronized oadd.org.apache.hadoop.util.Progress addNewPhase()
{
oadd.org.apache.hadoop.util.Progress v, v;
java.util.ArrayList v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v = new oadd.org.apache.hadoop.util.Progress;
specialinvoke v.<oadd.org.apache.hadoop.util.Progress: void <init>()>();
v = v.<oadd.org.apache.hadoop.util.Progress: java.util.ArrayList phases>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
virtualinvoke v.<oadd.org.apache.hadoop.util.Progress: void setParent(oadd.org.apache.hadoop.util.Progress)>(v);
return v;
}
public oadd.org.apache.hadoop.util.Progress addPhase(java.lang.String, float)
{
float v;
java.lang.String v;
oadd.org.apache.hadoop.util.Progress v, v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v := @parameter: java.lang.String;
v := @parameter: float;
v = virtualinvoke v.<oadd.org.apache.hadoop.util.Progress: oadd.org.apache.hadoop.util.Progress addPhase(float)>(v);
virtualinvoke v.<oadd.org.apache.hadoop.util.Progress: void setStatus(java.lang.String)>(v);
return v;
}
public synchronized oadd.org.apache.hadoop.util.Progress addPhase(float)
{
java.lang.Float v;
java.util.ArrayList v, v, v, v;
byte v;
int v, v;
java.lang.String v;
oadd.org.apache.hadoop.util.Progress v, v;
org.slf4j.Logger v;
float v, v, v;
java.lang.Object v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v := @parameter: float;
v = new oadd.org.apache.hadoop.util.Progress;
specialinvoke v.<oadd.org.apache.hadoop.util.Progress: void <init>()>();
v = v.<oadd.org.apache.hadoop.util.Progress: java.util.ArrayList progressWeightagesForPhases>;
v = staticinvoke <java.lang.Float: java.lang.Float valueOf(float)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v.<oadd.org.apache.hadoop.util.Progress: java.util.ArrayList phases>;
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
virtualinvoke v.<oadd.org.apache.hadoop.util.Progress: void setParent(oadd.org.apache.hadoop.util.Progress)>(v);
v = 0.0F;
v = 0;
label:
v = v.<oadd.org.apache.hadoop.util.Progress: java.util.ArrayList phases>;
v = virtualinvoke v.<java.util.ArrayList: int size()>();
if v >= v goto label;
v = v.<oadd.org.apache.hadoop.util.Progress: java.util.ArrayList progressWeightagesForPhases>;
v = virtualinvoke v.<java.util.ArrayList: java.lang.Object get(int)>(v);
v = virtualinvoke v.<java.lang.Float: float floatValue()>();
v = v + v;
v = v + 1;
goto label;
label:
v = v cmpl 1.0;
if v <= 0 goto label;
v = <oadd.org.apache.hadoop.util.Progress: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (float)>(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[])>("Sum of weightages can not be more than 1.0; But sum = \u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
label:
return v;
}
public synchronized void addPhases(int)
{
int v, v, v;
float v;
oadd.org.apache.hadoop.util.Progress v;
java.util.ArrayList v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v := @parameter: int;
v = 0;
label:
if v >= v goto label;
specialinvoke v.<oadd.org.apache.hadoop.util.Progress: oadd.org.apache.hadoop.util.Progress addNewPhase()>();
v = v + 1;
goto label;
label:
v = v.<oadd.org.apache.hadoop.util.Progress: java.util.ArrayList phases>;
v = virtualinvoke v.<java.util.ArrayList: int size()>();
v = 1.0F / v;
v.<oadd.org.apache.hadoop.util.Progress: float progressPerPhase> = v;
v.<oadd.org.apache.hadoop.util.Progress: boolean fixedWeightageForAllPhases> = 1;
return;
}
float getProgressWeightage(int)
{
int v;
float v, v;
java.lang.Object v;
oadd.org.apache.hadoop.util.Progress v;
boolean v;
java.util.ArrayList v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v := @parameter: int;
v = v.<oadd.org.apache.hadoop.util.Progress: boolean fixedWeightageForAllPhases>;
if v == 0 goto label;
v = v.<oadd.org.apache.hadoop.util.Progress: float progressPerPhase>;
return v;
label:
v = v.<oadd.org.apache.hadoop.util.Progress: java.util.ArrayList progressWeightagesForPhases>;
v = virtualinvoke v.<java.util.ArrayList: java.lang.Object get(int)>(v);
v = virtualinvoke v.<java.lang.Float: float floatValue()>();
return v;
}
synchronized oadd.org.apache.hadoop.util.Progress getParent()
{
oadd.org.apache.hadoop.util.Progress v, v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v = v.<oadd.org.apache.hadoop.util.Progress: oadd.org.apache.hadoop.util.Progress parent>;
return v;
}
synchronized void setParent(oadd.org.apache.hadoop.util.Progress)
{
oadd.org.apache.hadoop.util.Progress v, v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v := @parameter: oadd.org.apache.hadoop.util.Progress;
v.<oadd.org.apache.hadoop.util.Progress: oadd.org.apache.hadoop.util.Progress parent> = v;
return;
}
public synchronized void startNextPhase()
{
int v, v;
oadd.org.apache.hadoop.util.Progress v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v = v.<oadd.org.apache.hadoop.util.Progress: int currentPhase>;
v = v + 1;
v.<oadd.org.apache.hadoop.util.Progress: int currentPhase> = v;
return;
}
public synchronized oadd.org.apache.hadoop.util.Progress phase()
{
int v;
java.lang.Object v;
oadd.org.apache.hadoop.util.Progress v;
java.util.ArrayList v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v = v.<oadd.org.apache.hadoop.util.Progress: java.util.ArrayList phases>;
v = v.<oadd.org.apache.hadoop.util.Progress: int currentPhase>;
v = virtualinvoke v.<java.util.ArrayList: java.lang.Object get(int)>(v);
return v;
}
public void complete()
{
java.lang.Throwable v;
oadd.org.apache.hadoop.util.Progress v, v;
v := @this: oadd.org.apache.hadoop.util.Progress;
entermonitor v;
label:
v.<oadd.org.apache.hadoop.util.Progress: float progress> = 1.0F;
v = v.<oadd.org.apache.hadoop.util.Progress: oadd.org.apache.hadoop.util.Progress parent>;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v == null goto label;
virtualinvoke v.<oadd.org.apache.hadoop.util.Progress: void startNextPhase()>();
label:
return;
catch java.lang.Throwable from label to label with label;
}
public synchronized void set(float)
{
org.slf4j.Logger v, v, v, v, v;
byte v, v, v, v;
float v;
oadd.org.apache.hadoop.util.Progress v;
boolean v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v := @parameter: float;
v = staticinvoke <java.lang.Float: boolean isNaN(float)>(v);
if v == 0 goto label;
v = 0.0F;
v = <oadd.org.apache.hadoop.util.Progress: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Illegal progress value found, progress is Float.NaN. Progress will be changed to 0");
goto label;
label:
v = v cmpl #-InfinityF;
if v != 0 goto label;
v = 0.0F;
v = <oadd.org.apache.hadoop.util.Progress: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Illegal progress value found, progress is Float.NEGATIVE_INFINITY. Progress will be changed to 0");
goto label;
label:
v = v cmpg 0.0F;
if v >= 0 goto label;
v = 0.0F;
v = <oadd.org.apache.hadoop.util.Progress: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Illegal progress value found, progress is less than 0. Progress will be changed to 0");
goto label;
label:
v = v cmpl 1.0F;
if v <= 0 goto label;
v = 1.0F;
v = <oadd.org.apache.hadoop.util.Progress: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Illegal progress value found, progress is larger than 1. Progress will be changed to 1");
goto label;
label:
v = v cmpl #InfinityF;
if v != 0 goto label;
v = 1.0F;
v = <oadd.org.apache.hadoop.util.Progress: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Illegal progress value found, progress is Float.POSITIVE_INFINITY. Progress will be changed to 1");
label:
v.<oadd.org.apache.hadoop.util.Progress: float progress> = v;
return;
}
public synchronized float get()
{
float v;
oadd.org.apache.hadoop.util.Progress v, v, v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v = v;
label:
v = virtualinvoke v.<oadd.org.apache.hadoop.util.Progress: oadd.org.apache.hadoop.util.Progress getParent()>();
if v == null goto label;
v = v.<oadd.org.apache.hadoop.util.Progress: oadd.org.apache.hadoop.util.Progress parent>;
goto label;
label:
v = specialinvoke v.<oadd.org.apache.hadoop.util.Progress: float getInternal()>();
return v;
}
public synchronized float getProgress()
{
float v;
oadd.org.apache.hadoop.util.Progress v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v = specialinvoke v.<oadd.org.apache.hadoop.util.Progress: float getInternal()>();
return v;
}
private synchronized float getInternal()
{
java.util.ArrayList v;
int v, v, v, v, v, v;
oadd.org.apache.hadoop.util.Progress v, v;
boolean v;
float v, v, v, v, v, v, v, v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v = v.<oadd.org.apache.hadoop.util.Progress: java.util.ArrayList phases>;
v = virtualinvoke v.<java.util.ArrayList: int size()>();
if v == 0 goto label;
v = 0.0F;
v = v.<oadd.org.apache.hadoop.util.Progress: int currentPhase>;
if v >= v goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.util.Progress: oadd.org.apache.hadoop.util.Progress phase()>();
v = specialinvoke v.<oadd.org.apache.hadoop.util.Progress: float getInternal()>();
v = v.<oadd.org.apache.hadoop.util.Progress: int currentPhase>;
v = virtualinvoke v.<oadd.org.apache.hadoop.util.Progress: float getProgressWeightage(int)>(v);
v = v * v;
label:
v = 0.0F;
v = v.<oadd.org.apache.hadoop.util.Progress: boolean fixedWeightageForAllPhases>;
if v == 0 goto label;
v = v.<oadd.org.apache.hadoop.util.Progress: float progressPerPhase>;
v = v.<oadd.org.apache.hadoop.util.Progress: int currentPhase>;
v = v * v;
goto label;
label:
v = 0;
label:
v = v.<oadd.org.apache.hadoop.util.Progress: int currentPhase>;
if v >= v goto label;
v = virtualinvoke v.<oadd.org.apache.hadoop.util.Progress: float getProgressWeightage(int)>(v);
v = v + v;
v = v + 1;
goto label;
label:
v = v + v;
return v;
label:
v = v.<oadd.org.apache.hadoop.util.Progress: float progress>;
return v;
}
public synchronized void setStatus(java.lang.String)
{
java.lang.String v;
oadd.org.apache.hadoop.util.Progress v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v := @parameter: java.lang.String;
v.<oadd.org.apache.hadoop.util.Progress: java.lang.String status> = v;
return;
}
public java.lang.String toString()
{
java.lang.StringBuilder v;
java.lang.String v;
oadd.org.apache.hadoop.util.Progress v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
specialinvoke v.<oadd.org.apache.hadoop.util.Progress: void toString(java.lang.StringBuilder)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
private synchronized void toString(java.lang.StringBuilder)
{
java.util.ArrayList v, v;
int v, v, v;
java.lang.StringBuilder v;
java.lang.String v;
oadd.org.apache.hadoop.util.Progress v, v;
v := @this: oadd.org.apache.hadoop.util.Progress;
v := @parameter: java.lang.StringBuilder;
v = v.<oadd.org.apache.hadoop.util.Progress: java.lang.String status>;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = v.<oadd.org.apache.hadoop.util.Progress: java.util.ArrayList phases>;
v = virtualinvoke v.<java.util.ArrayList: int size()>();
if v == 0 goto label;
v = v.<oadd.org.apache.hadoop.util.Progress: int currentPhase>;
v = v.<oadd.org.apache.hadoop.util.Progress: java.util.ArrayList phases>;
v = virtualinvoke v.<java.util.ArrayList: int size()>();
if v >= v goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" > ");
v = virtualinvoke v.<oadd.org.apache.hadoop.util.Progress: oadd.org.apache.hadoop.util.Progress phase()>();
specialinvoke v.<oadd.org.apache.hadoop.util.Progress: void toString(java.lang.StringBuilder)>(v);
label:
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/hadoop/util/Progress;");
<oadd.org.apache.hadoop.util.Progress: org.slf4j.Logger LOG> = v;
return;
}
}