public class WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest extends java.lang.Object implements org.apache.nifi.web.api.concurrent.AsynchronousWebRequest
{
private final java.lang.String id;
private final java.lang.String componentId;
private final org.apache.nifi.authorization.user.NiFiUser user;
private final java.util.List updateSteps;
private final java.lang.Object request;
private volatile boolean complete;
private volatile java.util.Date lastUpdated;
private volatile int percentComplete;
private volatile java.lang.String failureReason;
private volatile boolean cancelled;
private volatile java.lang.Object results;
private volatile java.lang.Runnable cancelCallback;
private int currentStepIndex;
public void <init>(java.lang.String, java.lang.Object, java.lang.String, org.apache.nifi.authorization.user.NiFiUser, java.util.List)
{
java.util.List v;
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
org.apache.nifi.authorization.user.NiFiUser v;
java.util.Date v;
java.lang.Object v;
java.lang.String v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.authorization.user.NiFiUser;
v := @parameter: java.util.List;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: boolean complete> = 0;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.util.Date lastUpdated> = v;
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: int currentStepIndex> = 0;
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.String id> = v;
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.String componentId> = v;
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: org.apache.nifi.authorization.user.NiFiUser user> = v;
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.util.List updateSteps> = v;
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.Object request> = v;
return;
}
public synchronized org.apache.nifi.web.api.concurrent.UpdateStep getCurrentStep()
{
java.util.List v, v, v;
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
int v, v, v;
java.lang.Object v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.util.List updateSteps>;
if v == null goto label;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.util.List updateSteps>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: int currentStepIndex>;
if v <= v goto label;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.util.List updateSteps>;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: int currentStepIndex>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
label:
return v;
}
public java.lang.Object getRequest()
{
java.lang.Object v;
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.Object request>;
return v;
}
public java.lang.String getRequestId()
{
java.lang.String v;
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.String id>;
return v;
}
public boolean isComplete()
{
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: boolean complete>;
return v;
}
public java.lang.String getComponentId()
{
java.lang.String v;
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.String componentId>;
return v;
}
public void setCancelCallback(java.lang.Runnable)
{
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
java.lang.Runnable v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v := @parameter: java.lang.Runnable;
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.Runnable cancelCallback> = v;
return;
}
public void markStepComplete()
{
java.lang.Object v;
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.Object results>;
virtualinvoke v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: void markStepComplete(java.lang.Object)>(v);
return;
}
public synchronized void markStepComplete(java.lang.Object)
{
org.apache.nifi.web.api.concurrent.UpdateStep v;
java.util.Date v;
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
int v, v, v, v, v, v, v, v;
boolean v, v, v;
java.util.List v, v;
java.lang.Object v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v := @parameter: java.lang.Object;
v = virtualinvoke v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: boolean isCancelled()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: boolean isComplete()>();
if v == 0 goto label;
label:
return;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: org.apache.nifi.web.api.concurrent.UpdateStep getCurrentStep()>();
if v == null goto label;
interfaceinvoke v.<org.apache.nifi.web.api.concurrent.UpdateStep: void markCompleted()>();
label:
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: int currentStepIndex>;
v = v + 1;
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: int currentStepIndex> = v;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: int currentStepIndex>;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.util.List updateSteps>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v < v goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: boolean complete> = v;
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.Object results> = v;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.util.Date lastUpdated> = v;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: int currentStepIndex>;
v = v * 100;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.util.List updateSteps>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v / v;
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: int percentComplete> = v;
return;
}
public synchronized java.lang.String getState()
{
org.apache.nifi.web.api.concurrent.UpdateStep v;
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
java.lang.String v, v, v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v = virtualinvoke v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: boolean isComplete()>();
if v == 0 goto label;
return "Complete";
label:
v = virtualinvoke v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.String getFailureReason()>();
if v == null goto label;
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[])>("Failed: \u0001");
return v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: org.apache.nifi.web.api.concurrent.UpdateStep getCurrentStep()>();
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.UpdateStep: java.lang.String getDescription()>();
return v;
}
public java.util.Date getLastUpdated()
{
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
java.util.Date v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.util.Date lastUpdated>;
return v;
}
public java.util.List getUpdateSteps()
{
java.util.List v, v;
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.util.List updateSteps>;
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
return v;
}
public int getPercentComplete()
{
int v;
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: int percentComplete>;
return v;
}
public org.apache.nifi.authorization.user.NiFiUser getUser()
{
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
org.apache.nifi.authorization.user.NiFiUser v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: org.apache.nifi.authorization.user.NiFiUser user>;
return v;
}
public synchronized void fail(java.lang.String)
{
org.apache.nifi.web.api.concurrent.UpdateStep v;
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
java.util.Date v;
java.lang.Object v;
java.lang.String v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v := @parameter: java.lang.String;
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.String failureReason> = v;
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: boolean complete> = 1;
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.Object results> = null;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.util.Date lastUpdated> = v;
v = virtualinvoke v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: org.apache.nifi.web.api.concurrent.UpdateStep getCurrentStep()>();
interfaceinvoke v.<org.apache.nifi.web.api.concurrent.UpdateStep: void fail(java.lang.String)>(v);
return;
}
public synchronized java.lang.String getFailureReason()
{
java.lang.String v;
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.String failureReason>;
return v;
}
public java.lang.Object getResults()
{
java.lang.Object v;
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.Object results>;
return v;
}
public void cancel()
{
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
java.lang.Runnable v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: boolean cancelled> = 1;
v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: int percentComplete> = 100;
virtualinvoke v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: void fail(java.lang.String)>("Request cancelled by user");
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.Runnable cancelCallback>;
if v == null goto label;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: java.lang.Runnable cancelCallback>;
interfaceinvoke v.<java.lang.Runnable: void run()>();
label:
return;
}
public boolean isCancelled()
{
WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
v = v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: boolean cancelled>;
return v;
}
}