public class WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource extends org.apache.nifi.web.api.ApplicationResource
{
private static final org.slf4j.Logger logger;
private static final java.lang.String VERIFICATION_REQUEST_TYPE;
private org.apache.nifi.web.api.concurrent.RequestManager configVerificationRequestManager;
private org.apache.nifi.web.NiFiServiceFacade serviceFacade;
private org.apache.nifi.authorization.Authorizer authorizer;
private javax.servlet.ServletContext servletContext;
public void <init>()
{
java.util.concurrent.TimeUnit v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
long v;
org.apache.nifi.web.api.concurrent.AsyncRequestManager v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
specialinvoke v.<org.apache.nifi.web.api.ApplicationResource: void <init>()>();
v = new org.apache.nifi.web.api.concurrent.AsyncRequestManager;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MINUTES>;
v = virtualinvoke v.<java.util.concurrent.TimeUnit: long toMillis(long)>(1L);
specialinvoke v.<org.apache.nifi.web.api.concurrent.AsyncRequestManager: void <init>(int,long,java.lang.String)>(100, v, "Verify Reporting Task Config Thread");
v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.api.concurrent.RequestManager configVerificationRequestManager> = v;
return;
}
public java.util.Set populateRemainingReportingTaskEntitiesContent(java.util.Set)
{
java.util.Iterator v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
java.util.Set v;
java.lang.Object v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: java.util.Set;
v = interfaceinvoke v.<java.util.Set: 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()>();
virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.api.entity.ReportingTaskEntity populateRemainingReportingTaskEntityContent(org.apache.nifi.web.api.entity.ReportingTaskEntity)>(v);
goto label;
label:
return v;
}
public org.apache.nifi.web.api.entity.ReportingTaskEntity populateRemainingReportingTaskEntityContent(org.apache.nifi.web.api.entity.ReportingTaskEntity)
{
org.apache.nifi.web.api.entity.ReportingTaskEntity v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
java.lang.String[] v;
java.lang.String v, v;
org.apache.nifi.web.api.dto.ReportingTaskDTO v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: org.apache.nifi.web.api.entity.ReportingTaskEntity;
v = newarray (java.lang.String)[2];
v[0] = "reporting-tasks";
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskEntity: java.lang.String getId()>();
v[1] = v;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: java.lang.String generateResourceUri(java.lang.String[])>(v);
virtualinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskEntity: void setUri(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskEntity: org.apache.nifi.web.api.dto.ReportingTaskDTO getComponent()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskEntity: org.apache.nifi.web.api.dto.ReportingTaskDTO getComponent()>();
virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.api.dto.ReportingTaskDTO populateRemainingReportingTaskContent(org.apache.nifi.web.api.dto.ReportingTaskDTO)>(v);
label:
return v;
}
public org.apache.nifi.web.api.dto.ReportingTaskDTO populateRemainingReportingTaskContent(org.apache.nifi.web.api.dto.ReportingTaskDTO)
{
org.apache.nifi.web.api.dto.BundleDTO v;
org.apache.nifi.web.UiExtensionType v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
boolean v, v, v;
java.util.Iterator v;
java.util.List v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
java.lang.Object v, v;
javax.servlet.ServletContext v;
org.apache.nifi.web.api.dto.ReportingTaskDTO v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: org.apache.nifi.web.api.dto.ReportingTaskDTO;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ReportingTaskDTO: org.apache.nifi.web.api.dto.BundleDTO getBundle()>();
if v != null goto label;
return v;
label:
v = v.<org.apache.nifi.web.api.ReportingTaskResource: javax.servlet.ServletContext servletContext>;
v = interfaceinvoke v.<javax.servlet.ServletContext: java.lang.Object getAttribute(java.lang.String)>("nifi-ui-extensions");
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ReportingTaskDTO: java.lang.String getType()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BundleDTO: java.lang.String getGroup()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BundleDTO: java.lang.String getArtifact()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BundleDTO: java.lang.String getVersion()>();
v = virtualinvoke v.<org.apache.nifi.ui.extension.UiExtensionMapping: boolean hasUiExtension(java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ReportingTaskDTO: java.lang.String getType()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BundleDTO: java.lang.String getGroup()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BundleDTO: java.lang.String getArtifact()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.BundleDTO: java.lang.String getVersion()>();
v = virtualinvoke v.<org.apache.nifi.ui.extension.UiExtensionMapping: java.util.List getUiExtension(java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, 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 = <org.apache.nifi.web.UiExtensionType: org.apache.nifi.web.UiExtensionType ReportingTaskConfiguration>;
v = virtualinvoke v.<org.apache.nifi.ui.extension.UiExtension: org.apache.nifi.web.UiExtensionType getExtensionType()>();
v = virtualinvoke v.<org.apache.nifi.web.UiExtensionType: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.ui.extension.UiExtension: java.lang.String getContextPath()>();
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[])>("\u0001/configure");
virtualinvoke v.<org.apache.nifi.web.api.dto.ReportingTaskDTO: void setCustomUiUrl(java.lang.String)>(v);
goto label;
label:
return v;
}
public javax.ws.rs.core.Response getReportingTask(java.lang.String)
{
org.apache.nifi.web.NiFiServiceFacade v, v;
org.apache.nifi.web.api.entity.ReportingTaskEntity v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.ws.rs.core.Response v, v;
javax.ws.rs.core.Response$ResponseBuilder v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
java.lang.String v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response replicate(java.lang.String)>("GET");
return v;
label:
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_getReportingTask_0__850: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: void authorizeAccess(org.apache.nifi.authorization.AuthorizeAccess)>(v);
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: org.apache.nifi.web.api.entity.ReportingTaskEntity getReportingTask(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.api.entity.ReportingTaskEntity populateRemainingReportingTaskEntityContent(org.apache.nifi.web.api.entity.ReportingTaskEntity)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response$ResponseBuilder generateOkResponse(java.lang.Object)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
}
public javax.ws.rs.core.Response getPropertyDescriptor(java.lang.String, java.lang.String, boolean)
{
org.apache.nifi.web.NiFiServiceFacade v, v;
org.apache.nifi.web.api.entity.PropertyDescriptorEntity v;
java.lang.IllegalArgumentException v;
org.apache.nifi.authorization.AuthorizeAccess v;
org.apache.nifi.web.api.dto.PropertyDescriptorDTO v;
javax.ws.rs.core.Response v, v;
javax.ws.rs.core.Response$ResponseBuilder v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
java.lang.String v, v;
boolean v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("The property name must be specified.");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response replicate(java.lang.String)>("GET");
return v;
label:
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_getPropertyDescriptor_1__851: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: void authorizeAccess(org.apache.nifi.authorization.AuthorizeAccess)>(v);
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: org.apache.nifi.web.api.dto.PropertyDescriptorDTO getReportingTaskPropertyDescriptor(java.lang.String,java.lang.String,boolean)>(v, v, v);
v = new org.apache.nifi.web.api.entity.PropertyDescriptorEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.PropertyDescriptorEntity: void <init>()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.PropertyDescriptorEntity: void setPropertyDescriptor(org.apache.nifi.web.api.dto.PropertyDescriptorDTO)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response$ResponseBuilder generateOkResponse(java.lang.Object)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
}
public javax.ws.rs.core.Response getState(java.lang.String)
{
org.apache.nifi.web.NiFiServiceFacade v, v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.ws.rs.core.Response v, v;
javax.ws.rs.core.Response$ResponseBuilder v;
org.apache.nifi.web.api.dto.ComponentStateDTO v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
org.apache.nifi.web.api.entity.ComponentStateEntity v;
java.lang.String v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response replicate(java.lang.String)>("GET");
return v;
label:
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_getState_2__852: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: void authorizeAccess(org.apache.nifi.authorization.AuthorizeAccess)>(v);
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: org.apache.nifi.web.api.dto.ComponentStateDTO getReportingTaskState(java.lang.String)>(v);
v = new org.apache.nifi.web.api.entity.ComponentStateEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.ComponentStateEntity: void <init>()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.ComponentStateEntity: void setComponentState(org.apache.nifi.web.api.dto.ComponentStateDTO)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response$ResponseBuilder generateOkResponse(java.lang.Object)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
}
public javax.ws.rs.core.Response clearState(javax.servlet.http.HttpServletRequest, java.lang.String)
{
org.apache.nifi.web.NiFiServiceFacade v;
org.apache.nifi.web.api.entity.ReportingTaskEntity v;
java.lang.Runnable v;
java.util.function.Function v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.servlet.http.HttpServletRequest v;
javax.ws.rs.core.Response v, v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
java.lang.String v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response replicate(java.lang.String)>("POST");
return v;
label:
v = new org.apache.nifi.web.api.entity.ReportingTaskEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskEntity: void <init>()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskEntity: void setId(java.lang.String)>(v);
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_clearState_3__853: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_clearState_4__854: java.lang.Runnable bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_clearState_5__855: java.util.function.Function bootstrap$(org.apache.nifi.web.api.ReportingTaskResource)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade,org.apache.nifi.web.api.entity.Entity,org.apache.nifi.authorization.AuthorizeAccess,java.lang.Runnable,java.util.function.Function)>(v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response updateReportingTask(javax.servlet.http.HttpServletRequest, java.lang.String, org.apache.nifi.web.api.entity.ReportingTaskEntity)
{
java.lang.Object[] v;
org.apache.nifi.web.Revision v;
java.util.function.BiFunction v;
org.apache.nifi.web.api.dto.RevisionDTO v;
java.lang.Runnable v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.servlet.http.HttpServletRequest v;
java.lang.Boolean v;
java.lang.String v, v, v, v;
boolean v, v, v;
org.apache.nifi.web.NiFiServiceFacade v;
org.apache.nifi.web.api.entity.ReportingTaskEntity v;
java.lang.IllegalArgumentException v, v, v;
javax.ws.rs.core.Response v, v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
org.apache.nifi.web.api.dto.ReportingTaskDTO v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.api.entity.ReportingTaskEntity;
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskEntity: org.apache.nifi.web.api.dto.ReportingTaskDTO getComponent()>();
if v != null goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Reporting task details must be specified.");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskEntity: org.apache.nifi.web.api.dto.RevisionDTO getRevision()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Revision must be specified.");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskEntity: org.apache.nifi.web.api.dto.ReportingTaskDTO getComponent()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ReportingTaskDTO: java.lang.String getId()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new java.lang.IllegalArgumentException;
v = newarray (java.lang.Object)[2];
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ReportingTaskDTO: java.lang.String getId()>();
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("The reporting task id (%s) in the request body does not equal the reporting task id of the requested resource (%s).", v);
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response replicate(java.lang.String,java.lang.Object)>("PUT", v);
return v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isDisconnectedFromCluster()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskEntity: java.lang.Boolean isDisconnectedNodeAcknowledged()>();
virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: void verifyDisconnectedNodeModification(java.lang.Boolean)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.Revision getRevision(org.apache.nifi.web.api.entity.ComponentEntity,java.lang.String)>(v, v);
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_updateReportingTask_6__856: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,java.lang.String,org.apache.nifi.web.api.dto.ReportingTaskDTO)>(v, v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_updateReportingTask_7__857: java.lang.Runnable bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,org.apache.nifi.web.api.dto.ReportingTaskDTO)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_updateReportingTask_8__858: java.util.function.BiFunction bootstrap$(org.apache.nifi.web.api.ReportingTaskResource)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade,org.apache.nifi.web.api.entity.Entity,org.apache.nifi.web.Revision,org.apache.nifi.authorization.AuthorizeAccess,java.lang.Runnable,java.util.function.BiFunction)>(v, v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response removeReportingTask(javax.servlet.http.HttpServletRequest, org.apache.nifi.web.api.request.LongParameter, org.apache.nifi.web.api.request.ClientIdParameter, java.lang.Boolean, java.lang.String)
{
org.apache.nifi.web.Revision v;
java.util.function.BiFunction v;
java.lang.Runnable v;
org.apache.nifi.web.api.request.ClientIdParameter v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.servlet.http.HttpServletRequest v;
java.lang.Long v;
java.lang.Boolean v;
java.lang.String v, v;
boolean v, v;
org.apache.nifi.web.NiFiServiceFacade v;
org.apache.nifi.web.api.entity.ReportingTaskEntity v;
org.apache.nifi.web.api.request.LongParameter v;
javax.ws.rs.core.Response v, v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: org.apache.nifi.web.api.request.LongParameter;
v := @parameter: org.apache.nifi.web.api.request.ClientIdParameter;
v := @parameter: java.lang.Boolean;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response replicate(java.lang.String)>("DELETE");
return v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isDisconnectedFromCluster()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: void verifyDisconnectedNodeModification(java.lang.Boolean)>(v);
label:
v = new org.apache.nifi.web.api.entity.ReportingTaskEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskEntity: void <init>()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskEntity: void setId(java.lang.String)>(v);
v = new org.apache.nifi.web.Revision;
if v != null goto label;
v = null;
goto label;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.request.LongParameter: java.lang.Long getLong()>();
label:
v = virtualinvoke v.<org.apache.nifi.web.api.request.ClientIdParameter: java.lang.String getClientId()>();
specialinvoke v.<org.apache.nifi.web.Revision: void <init>(java.lang.Long,java.lang.String,java.lang.String)>(v, v, v);
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_removeReportingTask_9__859: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_removeReportingTask_10__860: java.lang.Runnable bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_removeReportingTask_11__861: java.util.function.BiFunction bootstrap$(org.apache.nifi.web.api.ReportingTaskResource)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade,org.apache.nifi.web.api.entity.Entity,org.apache.nifi.web.Revision,org.apache.nifi.authorization.AuthorizeAccess,java.lang.Runnable,java.util.function.BiFunction)>(v, v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response updateRunStatus(javax.servlet.http.HttpServletRequest, java.lang.String, org.apache.nifi.web.api.entity.ReportingTaskRunStatusEntity)
{
org.apache.nifi.web.Revision v;
java.util.function.BiFunction v;
org.apache.nifi.web.api.dto.RevisionDTO v, v;
java.lang.Runnable v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.servlet.http.HttpServletRequest v;
java.lang.Boolean v;
java.lang.String v;
boolean v, v;
org.apache.nifi.web.NiFiServiceFacade v;
java.lang.IllegalArgumentException v, v;
org.apache.nifi.web.api.entity.ReportingTaskRunStatusEntity v;
javax.ws.rs.core.Response v, v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.api.entity.ReportingTaskRunStatusEntity;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Reporting task run status must be specified.");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskRunStatusEntity: org.apache.nifi.web.api.dto.RevisionDTO getRevision()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Revision must be specified.");
throw v;
label:
virtualinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskRunStatusEntity: void validateState()>();
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response replicate(java.lang.String,java.lang.Object)>("PUT", v);
return v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isDisconnectedFromCluster()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskRunStatusEntity: java.lang.Boolean isDisconnectedNodeAcknowledged()>();
virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: void verifyDisconnectedNodeModification(java.lang.Boolean)>(v);
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ReportingTaskRunStatusEntity: org.apache.nifi.web.api.dto.RevisionDTO getRevision()>();
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.Revision getRevision(org.apache.nifi.web.api.dto.RevisionDTO,java.lang.String)>(v, v);
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_updateRunStatus_12__862: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_updateRunStatus_13__863: java.lang.Runnable bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,java.lang.String,org.apache.nifi.web.api.entity.ReportingTaskRunStatusEntity)>(v, v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_updateRunStatus_14__864: java.util.function.BiFunction bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade,org.apache.nifi.web.api.entity.Entity,org.apache.nifi.web.Revision,org.apache.nifi.authorization.AuthorizeAccess,java.lang.Runnable,java.util.function.BiFunction)>(v, v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response analyzeConfiguration(java.lang.String, org.apache.nifi.web.api.entity.ConfigurationAnalysisEntity)
{
java.lang.Runnable v;
java.util.function.Function v;
org.apache.nifi.authorization.AuthorizeAccess v;
java.util.Map v;
java.lang.String v, v, v;
boolean v, v;
org.apache.nifi.web.NiFiServiceFacade v;
org.apache.nifi.web.api.dto.ConfigurationAnalysisDTO v, v;
java.lang.IllegalArgumentException v, v, v, v;
javax.ws.rs.core.Response v, v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
org.apache.nifi.web.api.entity.ConfigurationAnalysisEntity v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.api.entity.ConfigurationAnalysisEntity;
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ConfigurationAnalysisEntity: org.apache.nifi.web.api.dto.ConfigurationAnalysisDTO getConfigurationAnalysis()>();
if v != null goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Reporting Tasks\'s configuration must be specified");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.ConfigurationAnalysisEntity: org.apache.nifi.web.api.dto.ConfigurationAnalysisDTO getConfigurationAnalysis()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ConfigurationAnalysisDTO: java.lang.String getComponentId()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Reporting Tasks\'s identifier must be specified in the request");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ConfigurationAnalysisDTO: java.lang.String getComponentId()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Reporting Tasks\'s identifier in the request must match the identifier provided in the URL");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ConfigurationAnalysisDTO: java.util.Map getProperties()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Reporting Tasks\'s properties must be specified in the request");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response replicate(java.lang.String,java.lang.Object)>("POST", v);
return v;
label:
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_analyzeConfiguration_15__865: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_analyzeConfiguration_16__866: java.lang.Runnable bootstrap$()>();
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_analyzeConfiguration_17__867: java.util.function.Function bootstrap$(org.apache.nifi.web.api.ReportingTaskResource)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade,org.apache.nifi.web.api.entity.Entity,org.apache.nifi.authorization.AuthorizeAccess,java.lang.Runnable,java.util.function.Function)>(v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response submitConfigVerificationRequest(java.lang.String, org.apache.nifi.web.api.entity.VerifyConfigRequestEntity)
{
org.apache.nifi.web.api.dto.VerifyConfigRequestDTO v;
java.lang.Runnable v;
java.util.function.Function v;
org.apache.nifi.authorization.AuthorizeAccess v;
org.apache.nifi.authorization.user.NiFiUser v;
java.util.Map v;
java.lang.String v, v, v;
org.apache.nifi.web.api.entity.VerifyConfigRequestEntity v;
boolean v, v;
org.apache.nifi.web.NiFiServiceFacade v;
java.lang.IllegalArgumentException v, v, v, v;
javax.ws.rs.core.Response v, v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.api.entity.VerifyConfigRequestEntity;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Reporting Task\'s configuration must be specified");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.entity.VerifyConfigRequestEntity: org.apache.nifi.web.api.dto.VerifyConfigRequestDTO getRequest()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: java.util.Map getProperties()>();
if v != null goto label;
label:
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Reporting Task Properties must be specified");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: java.lang.String getComponentId()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Reporting Task\'s identifier must be specified in the request");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: java.lang.String getComponentId()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Reporting Task\'s identifier in the request must match the identifier provided in the URL");
throw v;
label:
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response replicate(java.lang.String,java.lang.Object)>("POST", v);
return v;
label:
v = staticinvoke <org.apache.nifi.authorization.user.NiFiUserUtils: org.apache.nifi.authorization.user.NiFiUser getNiFiUser()>();
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_submitConfigVerificationRequest_18__868: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_submitConfigVerificationRequest_19__869: java.lang.Runnable bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,java.lang.String)>(v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_submitConfigVerificationRequest_20__870: java.util.function.Function bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,org.apache.nifi.authorization.user.NiFiUser)>(v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade,org.apache.nifi.web.api.entity.Entity,org.apache.nifi.authorization.AuthorizeAccess,java.lang.Runnable,java.util.function.Function)>(v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response getVerificationRequest(java.lang.String, java.lang.String)
{
javax.ws.rs.core.Response v, v;
org.apache.nifi.authorization.user.NiFiUser v;
javax.ws.rs.core.Response$ResponseBuilder v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
java.lang.String v, v;
org.apache.nifi.web.api.entity.VerifyConfigRequestEntity v;
org.apache.nifi.web.api.concurrent.RequestManager v;
org.apache.nifi.web.api.concurrent.AsynchronousWebRequest v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response replicate(java.lang.String)>("GET");
return v;
label:
v = staticinvoke <org.apache.nifi.authorization.user.NiFiUserUtils: org.apache.nifi.authorization.user.NiFiUser getNiFiUser()>();
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.api.concurrent.RequestManager configVerificationRequestManager>;
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.RequestManager: org.apache.nifi.web.api.concurrent.AsynchronousWebRequest getRequest(java.lang.String,java.lang.String,org.apache.nifi.authorization.user.NiFiUser)>("verification-request", v, v);
v = specialinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.api.entity.VerifyConfigRequestEntity createVerifyReportingTaskConfigRequestEntity(org.apache.nifi.web.api.concurrent.AsynchronousWebRequest,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response$ResponseBuilder generateOkResponse(java.lang.Object)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
}
public javax.ws.rs.core.Response deleteVerificationRequest(java.lang.String, java.lang.String)
{
java.lang.IllegalStateException v;
javax.servlet.http.HttpServletRequest v, v, v, v;
org.apache.nifi.authorization.user.NiFiUser v;
org.apache.nifi.web.ResourceNotFoundException v;
java.lang.String v, v, v;
org.apache.nifi.web.api.entity.VerifyConfigRequestEntity v;
boolean v, v, v, v, v, v;
javax.ws.rs.core.Response v, v, v, v;
javax.ws.rs.core.Response$ResponseBuilder v, v, v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
org.apache.nifi.web.api.concurrent.RequestManager v, v;
org.apache.nifi.web.api.concurrent.AsynchronousWebRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isReplicateRequest()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response replicate(java.lang.String)>("DELETE");
return v;
label:
v = staticinvoke <org.apache.nifi.authorization.user.NiFiUserUtils: org.apache.nifi.authorization.user.NiFiUser getNiFiUser()>();
v = v.<org.apache.nifi.web.api.ReportingTaskResource: javax.servlet.http.HttpServletRequest httpServletRequest>;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isTwoPhaseRequest(javax.servlet.http.HttpServletRequest)>(v);
v = v.<org.apache.nifi.web.api.ReportingTaskResource: javax.servlet.http.HttpServletRequest httpServletRequest>;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isExecutionPhase(javax.servlet.http.HttpServletRequest)>(v);
if v == 0 goto label;
if v == 0 goto label;
label:
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.api.concurrent.RequestManager configVerificationRequestManager>;
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.RequestManager: org.apache.nifi.web.api.concurrent.AsynchronousWebRequest removeRequest(java.lang.String,java.lang.String,org.apache.nifi.authorization.user.NiFiUser)>("verification-request", v, v);
if v != null goto label;
v = new org.apache.nifi.web.ResourceNotFoundException;
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[])>("Could not find request of type verification-request with ID \u0001");
specialinvoke v.<org.apache.nifi.web.ResourceNotFoundException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: boolean isComplete()>();
if v != 0 goto label;
interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: void cancel()>();
label:
v = specialinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.api.entity.VerifyConfigRequestEntity createVerifyReportingTaskConfigRequestEntity(org.apache.nifi.web.api.concurrent.AsynchronousWebRequest,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response$ResponseBuilder generateOkResponse(java.lang.Object)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
label:
v = v.<org.apache.nifi.web.api.ReportingTaskResource: javax.servlet.http.HttpServletRequest httpServletRequest>;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isValidationPhase(javax.servlet.http.HttpServletRequest)>(v);
if v == 0 goto label;
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.api.concurrent.RequestManager configVerificationRequestManager>;
interfaceinvoke v.<org.apache.nifi.web.api.concurrent.RequestManager: org.apache.nifi.web.api.concurrent.AsynchronousWebRequest getRequest(java.lang.String,java.lang.String,org.apache.nifi.authorization.user.NiFiUser)>("verification-request", v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response$ResponseBuilder generateContinueResponse()>();
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
label:
v = v.<org.apache.nifi.web.api.ReportingTaskResource: javax.servlet.http.HttpServletRequest httpServletRequest>;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: boolean isCancellationPhase(javax.servlet.http.HttpServletRequest)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response$ResponseBuilder generateOkResponse()>();
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
label:
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("This request does not appear to be part of the two phase commit.");
throw v;
}
public javax.ws.rs.core.Response performAsyncConfigVerification(org.apache.nifi.web.api.entity.VerifyConfigRequestEntity, org.apache.nifi.authorization.user.NiFiUser)
{
org.apache.nifi.web.api.concurrent.StandardUpdateStep v;
org.apache.nifi.web.api.dto.VerifyConfigRequestDTO v;
org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest v;
java.util.function.Consumer v;
java.util.List v;
javax.ws.rs.core.Response v;
org.apache.nifi.authorization.user.NiFiUser v;
javax.ws.rs.core.Response$ResponseBuilder v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
java.lang.String v, v;
org.apache.nifi.web.api.entity.VerifyConfigRequestEntity v, v;
org.apache.nifi.web.api.concurrent.RequestManager v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: org.apache.nifi.web.api.entity.VerifyConfigRequestEntity;
v := @parameter: org.apache.nifi.authorization.user.NiFiUser;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: java.lang.String generateUuid()>();
v = virtualinvoke v.<org.apache.nifi.web.api.entity.VerifyConfigRequestEntity: org.apache.nifi.web.api.dto.VerifyConfigRequestDTO getRequest()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: java.lang.String getComponentId()>();
v = new org.apache.nifi.web.api.concurrent.StandardUpdateStep;
specialinvoke v.<org.apache.nifi.web.api.concurrent.StandardUpdateStep: void <init>(java.lang.String)>("Verify Reporting Task Configuration");
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
v = new org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest;
specialinvoke v.<org.apache.nifi.web.api.concurrent.StandardAsynchronousWebRequest: void <init>(java.lang.String,java.lang.Object,java.lang.String,org.apache.nifi.authorization.user.NiFiUser,java.util.List)>(v, v, v, v, v);
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource$lambda_performAsyncConfigVerification_21__871: java.util.function.Consumer bootstrap$(org.apache.nifi.web.api.ReportingTaskResource,java.lang.String,org.apache.nifi.web.api.dto.VerifyConfigRequestDTO)>(v, v, v);
v = v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.api.concurrent.RequestManager configVerificationRequestManager>;
interfaceinvoke v.<org.apache.nifi.web.api.concurrent.RequestManager: void submitRequest(java.lang.String,java.lang.String,org.apache.nifi.web.api.concurrent.AsynchronousWebRequest,java.util.function.Consumer)>("verification-request", v, v, v);
v = specialinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.api.entity.VerifyConfigRequestEntity createVerifyReportingTaskConfigRequestEntity(org.apache.nifi.web.api.concurrent.AsynchronousWebRequest,java.lang.String)>(v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: javax.ws.rs.core.Response$ResponseBuilder generateOkResponse(java.lang.Object)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
}
private org.apache.nifi.web.api.entity.VerifyConfigRequestEntity createVerifyReportingTaskConfigRequestEntity(org.apache.nifi.web.api.concurrent.AsynchronousWebRequest, java.lang.String)
{
java.util.Date v;
org.apache.nifi.web.api.dto.VerifyConfigRequestDTO v, v;
java.lang.String[] v;
java.util.Map v;
int v;
java.lang.String v, v, v, v, v, v;
org.apache.nifi.web.api.entity.VerifyConfigRequestEntity v;
boolean v;
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
java.lang.Object v, v;
org.apache.nifi.web.api.concurrent.AsynchronousWebRequest v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: org.apache.nifi.web.api.concurrent.AsynchronousWebRequest;
v := @parameter: java.lang.String;
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: java.lang.Object getRequest()>();
v = virtualinvoke v.<org.apache.nifi.web.api.entity.VerifyConfigRequestEntity: org.apache.nifi.web.api.dto.VerifyConfigRequestDTO getRequest()>();
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: java.lang.Object getResults()>();
v = new org.apache.nifi.web.api.dto.VerifyConfigRequestDTO;
specialinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void <init>()>();
v = virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: java.lang.String getComponentId()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setComponentId(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: java.util.Map getProperties()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setProperties(java.util.Map)>(v);
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setResults(java.util.List)>(v);
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: boolean isComplete()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setComplete(boolean)>(v);
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: java.lang.String getFailureReason()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setFailureReason(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: java.util.Date getLastUpdated()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setLastUpdated(java.util.Date)>(v);
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: int getPercentComplete()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setPercentCompleted(int)>(v);
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setRequestId(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.nifi.web.api.concurrent.AsynchronousWebRequest: java.lang.String getState()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setState(java.lang.String)>(v);
v = newarray (java.lang.String)[5];
v[0] = "reporting-tasks";
v = virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: java.lang.String getComponentId()>();
v[1] = v;
v[2] = "config";
v[3] = "verification-requests";
v[4] = v;
v = virtualinvoke v.<org.apache.nifi.web.api.ReportingTaskResource: java.lang.String generateResourceUri(java.lang.String[])>(v);
virtualinvoke v.<org.apache.nifi.web.api.dto.VerifyConfigRequestDTO: void setUri(java.lang.String)>(v);
v = new org.apache.nifi.web.api.entity.VerifyConfigRequestEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.VerifyConfigRequestEntity: void <init>()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.VerifyConfigRequestEntity: void setRequest(org.apache.nifi.web.api.dto.VerifyConfigRequestDTO)>(v);
return v;
}
private org.apache.nifi.web.api.dto.ReportingTaskDTO createDTOWithDesiredRunStatus(java.lang.String, java.lang.String)
{
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
java.lang.String v, v;
org.apache.nifi.web.api.dto.ReportingTaskDTO v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new org.apache.nifi.web.api.dto.ReportingTaskDTO;
specialinvoke v.<org.apache.nifi.web.api.dto.ReportingTaskDTO: void <init>()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.ReportingTaskDTO: void setId(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.web.api.dto.ReportingTaskDTO: void setState(java.lang.String)>(v);
return v;
}
public void setServiceFacade(org.apache.nifi.web.NiFiServiceFacade)
{
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
org.apache.nifi.web.NiFiServiceFacade v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: org.apache.nifi.web.NiFiServiceFacade;
v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade> = v;
return;
}
public void setAuthorizer(org.apache.nifi.authorization.Authorizer)
{
WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource v;
org.apache.nifi.authorization.Authorizer v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.ReportingTaskResource;
v := @parameter: org.apache.nifi.authorization.Authorizer;
v.<org.apache.nifi.web.api.ReportingTaskResource: org.apache.nifi.authorization.Authorizer authorizer> = v;
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/nifi/web/api/ReportingTaskResource;");
<org.apache.nifi.web.api.ReportingTaskResource: org.slf4j.Logger logger> = v;
return;
}
}