public class WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource extends org.apache.nifi.web.api.ApplicationResource
{
private static final org.slf4j.Logger logger;
public static final java.lang.String CHECK_SUM;
public static final java.lang.String RESPONSE_CODE;
private static final java.lang.String PORT_TYPE_INPUT;
private static final java.lang.String PORT_TYPE_OUTPUT;
private org.apache.nifi.web.NiFiServiceFacade serviceFacade;
private final org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator;
private final org.apache.nifi.remote.VersionNegotiator transportProtocolVersionNegotiator;
private final org.apache.nifi.remote.HttpRemoteSiteListener transactionManager;
private final org.apache.nifi.util.NiFiProperties nifiProperties;
public void <init>(org.apache.nifi.util.NiFiProperties)
{
org.apache.nifi.web.api.ApplicationResource$ResponseCreator v;
org.apache.nifi.util.NiFiProperties v;
int[] v;
org.apache.nifi.remote.client.http.TransportProtocolVersionNegotiator v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
org.apache.nifi.remote.HttpRemoteSiteListener v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: org.apache.nifi.util.NiFiProperties;
specialinvoke v.<org.apache.nifi.web.api.ApplicationResource: void <init>()>();
v = new org.apache.nifi.web.api.ApplicationResource$ResponseCreator;
specialinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: void <init>(org.apache.nifi.web.api.ApplicationResource)>(v);
v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator> = v;
v = new org.apache.nifi.remote.client.http.TransportProtocolVersionNegotiator;
v = newarray (int)[1];
v[0] = 1;
specialinvoke v.<org.apache.nifi.remote.client.http.TransportProtocolVersionNegotiator: void <init>(int[])>(v);
v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.VersionNegotiator transportProtocolVersionNegotiator> = v;
v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.util.NiFiProperties nifiProperties> = v;
v = staticinvoke <org.apache.nifi.remote.HttpRemoteSiteListener: org.apache.nifi.remote.HttpRemoteSiteListener getInstance(org.apache.nifi.util.NiFiProperties)>(v);
v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.HttpRemoteSiteListener transactionManager> = v;
return;
}
protected void authorizeDataTransfer(org.apache.nifi.authorization.AuthorizableLookup, org.apache.nifi.authorization.resource.ResourceType, java.lang.String)
{
org.apache.nifi.authorization.AccessDeniedException v;
org.apache.nifi.authorization.AuthorizationResult$Result v, v;
org.apache.nifi.authorization.resource.ResourceType v, v, v, v;
org.apache.nifi.authorization.user.NiFiUser v;
org.apache.nifi.authorization.AuthorizationResult v;
java.lang.String v, v;
org.apache.nifi.authorization.PublicPortAuthorizable v;
boolean v, v, v, v;
org.apache.nifi.authorization.AuthorizableLookup v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
java.lang.IllegalArgumentException v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: org.apache.nifi.authorization.AuthorizableLookup;
v := @parameter: org.apache.nifi.authorization.resource.ResourceType;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.nifi.authorization.user.NiFiUserUtils: org.apache.nifi.authorization.user.NiFiUser getNiFiUser()>();
v = <org.apache.nifi.authorization.resource.ResourceType: org.apache.nifi.authorization.resource.ResourceType InputPort>;
v = virtualinvoke v.<org.apache.nifi.authorization.resource.ResourceType: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = <org.apache.nifi.authorization.resource.ResourceType: org.apache.nifi.authorization.resource.ResourceType OutputPort>;
v = virtualinvoke v.<org.apache.nifi.authorization.resource.ResourceType: 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)>("The resource must be an Input or Output Port.");
throw v;
label:
v = <org.apache.nifi.authorization.resource.ResourceType: org.apache.nifi.authorization.resource.ResourceType InputPort>;
v = virtualinvoke v.<org.apache.nifi.authorization.resource.ResourceType: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.nifi.authorization.AuthorizableLookup: org.apache.nifi.authorization.PublicPortAuthorizable getPublicInputPort(java.lang.String)>(v);
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.authorization.AuthorizableLookup: org.apache.nifi.authorization.PublicPortAuthorizable getPublicOutputPort(java.lang.String)>(v);
label:
v = interfaceinvoke v.<org.apache.nifi.authorization.PublicPortAuthorizable: org.apache.nifi.authorization.AuthorizationResult checkAuthorization(org.apache.nifi.authorization.user.NiFiUser)>(v);
v = <org.apache.nifi.authorization.AuthorizationResult$Result: org.apache.nifi.authorization.AuthorizationResult$Result Approved>;
v = virtualinvoke v.<org.apache.nifi.authorization.AuthorizationResult: org.apache.nifi.authorization.AuthorizationResult$Result getResult()>();
v = virtualinvoke v.<org.apache.nifi.authorization.AuthorizationResult$Result: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new org.apache.nifi.authorization.AccessDeniedException;
v = virtualinvoke v.<org.apache.nifi.authorization.AuthorizationResult: java.lang.String getExplanation()>();
specialinvoke v.<org.apache.nifi.authorization.AccessDeniedException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public javax.ws.rs.core.Response createPortTransaction(java.lang.String, java.lang.String, javax.servlet.http.HttpServletRequest, javax.servlet.ServletContext, javax.ws.rs.core.UriInfo, java.io.InputStream)
{
java.lang.Integer v, v, v;
org.apache.nifi.authorization.AuthorizeAccess v;
org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult v;
boolean v, v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
org.apache.nifi.remote.protocol.ResponseCode v;
java.lang.Exception v;
org.apache.nifi.remote.HttpRemoteSiteListener v, v, v, v;
javax.ws.rs.core.Response v, v, v, v, v, v;
javax.ws.rs.core.UriInfo v;
java.lang.Throwable v;
java.io.ByteArrayOutputStream v;
org.apache.nifi.web.api.entity.TransactionResultEntity v;
javax.servlet.http.HttpServletRequest v;
org.apache.nifi.web.api.ApplicationResource$ResponseCreator v, v, v, v;
int v, v;
java.lang.String v, v, v, v, v, v;
org.apache.nifi.web.NiFiServiceFacade v;
javax.servlet.ServletContext v;
org.apache.nifi.remote.Peer v;
java.io.InputStream v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: javax.servlet.ServletContext;
v := @parameter: javax.ws.rs.core.UriInfo;
v := @parameter: java.io.InputStream;
v = "input-ports";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = "output-ports";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response wrongPortTypeResponse(java.lang.String,java.lang.String)>(v, v);
return v;
label:
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource$lambda_createPortTransaction_0__481: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.DataTransferResource,java.lang.String,java.lang.String)>(v, v, v);
interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: void authorizeAccess(org.apache.nifi.authorization.AuthorizeAccess)>(v);
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult validateResult(javax.servlet.http.HttpServletRequest,java.lang.String)>(v, v);
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: javax.ws.rs.core.Response access$000(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
if v == null goto label;
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: javax.ws.rs.core.Response access$000(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
return v;
label:
v = new java.io.ByteArrayOutputStream;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>()>();
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.HttpRemoteSiteListener transactionManager>;
v = virtualinvoke v.<org.apache.nifi.remote.HttpRemoteSiteListener: java.lang.String createTransaction()>();
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.Peer constructPeer(javax.servlet.http.HttpServletRequest,java.io.InputStream,java.io.OutputStream,java.lang.String,java.lang.String)>(v, v, v, v, v);
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: java.lang.Integer access$100(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol initiateServerProtocol(javax.servlet.http.HttpServletRequest,org.apache.nifi.remote.Peer,java.lang.Integer)>(v, v, v);
v = new org.apache.nifi.web.api.entity.TransactionResultEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void <init>()>();
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode PROPERTIES_OK>;
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setResponseCode(int)>(v);
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[])>("Handshake properties are valid, and port is running. A transaction is created:\u0001");
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setMessage(java.lang.String)>(v);
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.HttpRemoteSiteListener transactionManager>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response locationResponse(javax.ws.rs.core.UriInfo,java.lang.String,java.lang.String,java.lang.String,java.lang.Object,java.lang.Integer,org.apache.nifi.remote.HttpRemoteSiteListener)>(v, v, v, v, v, v, v);
label:
return v;
label:
v := @caughtexception;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.HttpRemoteSiteListener transactionManager>;
virtualinvoke v.<org.apache.nifi.remote.HttpRemoteSiteListener: void cancelTransaction(java.lang.String)>(v);
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response handshakeExceptionResponse(org.apache.nifi.remote.exception.HandshakeException)>(v);
return v;
label:
v := @caughtexception;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.HttpRemoteSiteListener transactionManager>;
virtualinvoke v.<org.apache.nifi.remote.HttpRemoteSiteListener: void cancelTransaction(java.lang.String)>(v);
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response unexpectedErrorResponse(java.lang.String,java.lang.Exception)>(v, v);
return v;
catch org.apache.nifi.remote.exception.HandshakeException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public javax.ws.rs.core.Response receiveFlowFiles(java.lang.String, java.lang.String, javax.servlet.http.HttpServletRequest, javax.servlet.ServletContext, java.io.InputStream)
{
java.lang.Integer v, v, v, v;
org.apache.nifi.authorization.AuthorizeAccess v;
org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult v;
javax.ws.rs.core.Response$Status v;
org.apache.nifi.remote.protocol.CommunicationsSession v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
java.lang.Exception v;
org.apache.nifi.remote.HttpRemoteSiteListener v;
javax.ws.rs.core.Response v, v, v, v, v, v, v, v;
javax.ws.rs.core.Response$ResponseBuilder v, v;
java.lang.Throwable v, v, v;
java.io.ByteArrayOutputStream v;
javax.servlet.http.HttpServletRequest v;
org.apache.nifi.web.api.ApplicationResource$ResponseCreator v, v, v, v, v;
int v, v;
java.lang.String v, v, v;
org.apache.nifi.web.NiFiServiceFacade v;
org.slf4j.Logger v, v;
org.apache.nifi.remote.PublicPort v;
org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol v;
javax.servlet.ServletContext v;
org.apache.nifi.remote.Peer v;
java.io.InputStream v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: javax.servlet.ServletContext;
v := @parameter: java.io.InputStream;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource$lambda_receiveFlowFiles_1__482: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.DataTransferResource,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: void authorizeAccess(org.apache.nifi.authorization.AuthorizeAccess)>(v);
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult validateResult(javax.servlet.http.HttpServletRequest,java.lang.String,java.lang.String)>(v, v, v);
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: javax.ws.rs.core.Response access$000(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
if v == null goto label;
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: javax.ws.rs.core.Response access$000(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
return v;
label:
v = <org.apache.nifi.web.api.DataTransferResource: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("receiveFlowFiles request: portId={}", v);
v = new java.io.ByteArrayOutputStream;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>()>();
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.Peer constructPeer(javax.servlet.http.HttpServletRequest,java.io.InputStream,java.io.OutputStream,java.lang.String,java.lang.String)>(v, v, v, v, v);
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: java.lang.Integer access$100(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol initiateServerProtocol(javax.servlet.http.HttpServletRequest,org.apache.nifi.remote.Peer,java.lang.Integer)>(v, v, v);
v = interfaceinvoke v.<org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol: org.apache.nifi.remote.PublicPort getPort()>();
v = interfaceinvoke v.<org.apache.nifi.remote.PublicPort: int receiveFlowFiles(org.apache.nifi.remote.Peer,org.apache.nifi.remote.protocol.ServerProtocol)>(v, v);
v = <org.apache.nifi.web.api.DataTransferResource: org.slf4j.Logger logger>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("finished receiving flow files, numOfFlowFiles={}", v);
if v >= 1 goto label;
v = <javax.ws.rs.core.Response$Status: javax.ws.rs.core.Response$Status BAD_REQUEST>;
v = staticinvoke <javax.ws.rs.core.Response: javax.ws.rs.core.Response$ResponseBuilder status(javax.ws.rs.core.Response$Status)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response$ResponseBuilder entity(java.lang.Object)>("Client should send request when there is data to send. There was no flow file sent.");
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
label:
return v;
label:
v := @caughtexception;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response handshakeExceptionResponse(org.apache.nifi.remote.exception.HandshakeException)>(v);
return v;
label:
v := @caughtexception;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response unauthorizedResponse(org.apache.nifi.remote.exception.NotAuthorizedException)>(v);
return v;
label:
v := @caughtexception;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response badRequestResponse(java.lang.Exception)>(v);
return v;
label:
v := @caughtexception;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response unexpectedErrorResponse(java.lang.String,java.lang.Exception)>(v, v);
return v;
label:
v = virtualinvoke v.<org.apache.nifi.remote.Peer: org.apache.nifi.remote.protocol.CommunicationsSession getCommunicationsSession()>();
v = virtualinvoke v.<org.apache.nifi.remote.io.http.HttpServerCommunicationsSession: java.lang.String getChecksum()>();
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.HttpRemoteSiteListener transactionManager>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response acceptedResponse(org.apache.nifi.remote.HttpRemoteSiteListener,java.lang.Object,java.lang.Integer)>(v, v, v);
return v;
catch org.apache.nifi.remote.exception.HandshakeException from label to label with label;
catch org.apache.nifi.remote.exception.NotAuthorizedException from label to label with label;
catch org.apache.nifi.remote.exception.BadRequestException from label to label with label;
catch org.apache.nifi.remote.exception.RequestExpiredException from label to label with label;
catch java.lang.Exception from label to label with label;
}
private org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol initiateServerProtocol(javax.servlet.http.HttpServletRequest, org.apache.nifi.remote.Peer, java.lang.Integer) throws java.io.IOException
{
java.lang.Integer v;
javax.servlet.http.HttpServletRequest v;
int[] v, v;
java.lang.StringBuffer v;
int v, v;
java.lang.String v;
org.apache.nifi.remote.protocol.CommunicationsSession v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
org.apache.nifi.remote.HttpRemoteSiteListener v;
org.apache.nifi.util.NiFiProperties v;
org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol v;
org.apache.nifi.remote.client.http.TransportProtocolVersionNegotiator v;
org.apache.nifi.remote.StandardVersionNegotiator v;
org.apache.nifi.remote.Peer v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: org.apache.nifi.remote.Peer;
v := @parameter: java.lang.Integer;
v = new org.apache.nifi.remote.client.http.TransportProtocolVersionNegotiator;
v = newarray (int)[1];
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v[0] = v;
specialinvoke v.<org.apache.nifi.remote.client.http.TransportProtocolVersionNegotiator: void <init>(int[])>(v);
v = new org.apache.nifi.remote.StandardVersionNegotiator;
v = newarray (int)[1];
v = virtualinvoke v.<org.apache.nifi.remote.client.http.TransportProtocolVersionNegotiator: int getTransactionProtocolVersion()>();
v[0] = v;
specialinvoke v.<org.apache.nifi.remote.StandardVersionNegotiator: void <init>(int[])>(v);
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.StringBuffer getRequestURL()>();
v = virtualinvoke v.<java.lang.StringBuffer: java.lang.String toString()>();
v = virtualinvoke v.<org.apache.nifi.remote.Peer: org.apache.nifi.remote.protocol.CommunicationsSession getCommunicationsSession()>();
virtualinvoke v.<org.apache.nifi.remote.io.http.HttpCommunicationsSession: void setDataTransferUrl(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol getHttpFlowFileServerProtocol(org.apache.nifi.remote.VersionNegotiator)>(v);
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.util.NiFiProperties nifiProperties>;
v = staticinvoke <org.apache.nifi.remote.HttpRemoteSiteListener: org.apache.nifi.remote.HttpRemoteSiteListener getInstance(org.apache.nifi.util.NiFiProperties)>(v);
virtualinvoke v.<org.apache.nifi.remote.HttpRemoteSiteListener: void setupServerProtocol(org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol)>(v);
interfaceinvoke v.<org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol: void handshake(org.apache.nifi.remote.Peer)>(v);
return v;
}
org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol getHttpFlowFileServerProtocol(org.apache.nifi.remote.VersionNegotiator)
{
org.apache.nifi.remote.protocol.http.StandardHttpFlowFileServerProtocol v;
org.apache.nifi.util.NiFiProperties v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
org.apache.nifi.remote.VersionNegotiator v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: org.apache.nifi.remote.VersionNegotiator;
v = new org.apache.nifi.remote.protocol.http.StandardHttpFlowFileServerProtocol;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.util.NiFiProperties nifiProperties>;
specialinvoke v.<org.apache.nifi.remote.protocol.http.StandardHttpFlowFileServerProtocol: void <init>(org.apache.nifi.remote.VersionNegotiator,org.apache.nifi.util.NiFiProperties)>(v, v);
return v;
}
private org.apache.nifi.remote.Peer constructPeer(javax.servlet.http.HttpServletRequest, java.io.InputStream, java.io.OutputStream, java.lang.String, java.lang.String)
{
java.net.InetAddress v;
org.apache.nifi.remote.io.http.HttpServerCommunicationsSession v;
boolean v, v, v, v, v, v, v, v, v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
javax.servlet.http.HttpServletRequest v;
org.apache.nifi.authorization.user.NiFiUser v, v;
int v, v;
java.lang.Boolean v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.io.OutputStream v;
org.slf4j.Logger v, v;
org.apache.nifi.remote.PeerDescription v;
java.net.UnknownHostException v;
org.apache.nifi.remote.protocol.HandshakeProperty v, v, v, v, v, v;
org.apache.nifi.remote.Peer v;
java.io.InputStream v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: java.io.InputStream;
v := @parameter: java.io.OutputStream;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getRemoteHost()>();
label:
v = staticinvoke <java.net.InetAddress: java.net.InetAddress getByName(java.lang.String)>(v);
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostName()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.nifi.web.api.DataTransferResource: org.slf4j.Logger logger>;
v = virtualinvoke v.<java.net.UnknownHostException: java.lang.String getMessage()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to resolve client hostname {}, due to {}", v, v);
label:
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: int getRemotePort()>();
v = new org.apache.nifi.remote.PeerDescription;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: boolean isSecure()>();
specialinvoke v.<org.apache.nifi.remote.PeerDescription: void <init>(java.lang.String,int,boolean)>(v, v, v);
v = staticinvoke <org.apache.nifi.authorization.user.NiFiUserUtils: org.apache.nifi.authorization.user.NiFiUser getNiFiUser()>();
if v != null goto label;
v = null;
goto label;
label:
v = interfaceinvoke v.<org.apache.nifi.authorization.user.NiFiUser: java.lang.String getIdentity()>();
label:
v = new org.apache.nifi.remote.io.http.HttpServerCommunicationsSession;
specialinvoke v.<org.apache.nifi.remote.io.http.HttpServerCommunicationsSession: void <init>(java.io.InputStream,java.io.OutputStream,java.lang.String,java.lang.String)>(v, v, v, v);
v = 0;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getHeader(java.lang.String)>("x-nifi-site-to-site-use-compression");
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v == 0 goto label;
v = 1;
label:
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getHeader(java.lang.String)>("x-nifi-site-to-site-request-expiration");
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getHeader(java.lang.String)>("x-nifi-site-to-site-batch-count");
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getHeader(java.lang.String)>("x-nifi-site-to-site-batch-size");
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getHeader(java.lang.String)>("x-nifi-site-to-site-batch-duration");
v = <org.apache.nifi.remote.protocol.HandshakeProperty: org.apache.nifi.remote.protocol.HandshakeProperty PORT_IDENTIFIER>;
virtualinvoke v.<org.apache.nifi.remote.io.http.HttpServerCommunicationsSession: void putHandshakeParam(org.apache.nifi.remote.protocol.HandshakeProperty,java.lang.String)>(v, v);
v = <org.apache.nifi.remote.protocol.HandshakeProperty: org.apache.nifi.remote.protocol.HandshakeProperty GZIP>;
v = staticinvoke <java.lang.String: java.lang.String valueOf(boolean)>(v);
virtualinvoke v.<org.apache.nifi.remote.io.http.HttpServerCommunicationsSession: void putHandshakeParam(org.apache.nifi.remote.protocol.HandshakeProperty,java.lang.String)>(v, v);
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = <org.apache.nifi.remote.protocol.HandshakeProperty: org.apache.nifi.remote.protocol.HandshakeProperty REQUEST_EXPIRATION_MILLIS>;
virtualinvoke v.<org.apache.nifi.remote.io.http.HttpServerCommunicationsSession: void putHandshakeParam(org.apache.nifi.remote.protocol.HandshakeProperty,java.lang.String)>(v, v);
label:
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = <org.apache.nifi.remote.protocol.HandshakeProperty: org.apache.nifi.remote.protocol.HandshakeProperty BATCH_COUNT>;
virtualinvoke v.<org.apache.nifi.remote.io.http.HttpServerCommunicationsSession: void putHandshakeParam(org.apache.nifi.remote.protocol.HandshakeProperty,java.lang.String)>(v, v);
label:
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = <org.apache.nifi.remote.protocol.HandshakeProperty: org.apache.nifi.remote.protocol.HandshakeProperty BATCH_SIZE>;
virtualinvoke v.<org.apache.nifi.remote.io.http.HttpServerCommunicationsSession: void putHandshakeParam(org.apache.nifi.remote.protocol.HandshakeProperty,java.lang.String)>(v, v);
label:
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = <org.apache.nifi.remote.protocol.HandshakeProperty: org.apache.nifi.remote.protocol.HandshakeProperty BATCH_DURATION>;
virtualinvoke v.<org.apache.nifi.remote.io.http.HttpServerCommunicationsSession: void putHandshakeParam(org.apache.nifi.remote.protocol.HandshakeProperty,java.lang.String)>(v, v);
label:
v = virtualinvoke v.<org.apache.nifi.remote.PeerDescription: boolean isSecure()>();
if v == 0 goto label;
v = staticinvoke <org.apache.nifi.authorization.user.NiFiUserUtils: org.apache.nifi.authorization.user.NiFiUser getNiFiUser()>();
v = <org.apache.nifi.web.api.DataTransferResource: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("initiating peer, nifiUser={}", v);
v = interfaceinvoke v.<org.apache.nifi.authorization.user.NiFiUser: java.lang.String getIdentity()>();
virtualinvoke v.<org.apache.nifi.remote.io.http.HttpServerCommunicationsSession: void setUserDn(java.lang.String)>(v);
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,int)>(v, 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[])>("nifi://\u0001:\u0001");
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: int getLocalPort()>();
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[])>("nifi://localhost:\u0001");
v = new org.apache.nifi.remote.Peer;
specialinvoke v.<org.apache.nifi.remote.Peer: void <init>(org.apache.nifi.remote.PeerDescription,org.apache.nifi.remote.protocol.CommunicationsSession,java.lang.String,java.lang.String)>(v, v, v, v);
return v;
catch java.net.UnknownHostException from label to label with label;
}
public javax.ws.rs.core.Response commitOutputPortTransaction(java.lang.Integer, java.lang.String, java.lang.String, java.lang.String, javax.servlet.http.HttpServletRequest, javax.servlet.ServletContext, java.io.InputStream)
{
java.lang.Integer v, v, v, v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.ws.rs.core.Response$Status v, v;
org.apache.nifi.remote.protocol.ResponseCode v, v, v, v, v, v, v, v;
java.lang.Exception v;
javax.ws.rs.core.Response$ResponseBuilder v, v, v, v, v, v, v, v;
java.lang.Throwable v;
java.io.ByteArrayOutputStream v;
javax.servlet.http.HttpServletRequest v;
org.apache.nifi.web.api.ApplicationResource$ResponseCreator v, v;
java.lang.String v, v, v, v, v;
org.apache.nifi.web.NiFiServiceFacade v;
javax.servlet.ServletContext v;
org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult v;
org.apache.nifi.remote.protocol.CommunicationsSession v;
boolean v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
org.apache.nifi.remote.HttpRemoteSiteListener v;
javax.ws.rs.core.Response v, v, v, v, v, v, v, v;
org.apache.nifi.web.api.entity.TransactionResultEntity v;
int v, v, v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v;
org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol v;
org.apache.nifi.remote.Peer v;
java.io.InputStream v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: java.lang.Integer;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: javax.servlet.ServletContext;
v := @parameter: java.io.InputStream;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource$lambda_commitOutputPortTransaction_2__483: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.DataTransferResource,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: void authorizeAccess(org.apache.nifi.authorization.AuthorizeAccess)>(v);
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult validateResult(javax.servlet.http.HttpServletRequest,java.lang.String,java.lang.String)>(v, v, v);
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: javax.ws.rs.core.Response access$000(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
if v == null goto label;
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: javax.ws.rs.core.Response access$000(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
return v;
label:
v = <org.apache.nifi.web.api.DataTransferResource: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("commitOutputPortTransaction request: portId={}, transactionId={}", v, v);
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: java.lang.Integer access$100(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = new java.io.ByteArrayOutputStream;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>()>();
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.Peer constructPeer(javax.servlet.http.HttpServletRequest,java.io.InputStream,java.io.OutputStream,java.lang.String,java.lang.String)>(v, v, v, v, v);
v = new org.apache.nifi.web.api.entity.TransactionResultEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void <init>()>();
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol initiateServerProtocol(javax.servlet.http.HttpServletRequest,org.apache.nifi.remote.Peer,java.lang.Integer)>(v, v, v);
v = null;
if v != null goto label;
v = "responseCode is required.";
goto label;
label:
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode CONFIRM_TRANSACTION>;
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v == v goto label;
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode CANCEL_TRANSACTION>;
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v == v goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Integer)>(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[])>("responseCode \u is invalid. ");
label:
if v == null goto label;
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setMessage(java.lang.String)>(v);
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode ABORT>;
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setResponseCode(int)>(v);
v = <javax.ws.rs.core.Response$Status: javax.ws.rs.core.Response$Status BAD_REQUEST>;
v = staticinvoke <javax.ws.rs.core.Response: javax.ws.rs.core.Response$ResponseBuilder status(javax.ws.rs.core.Response$Status)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response$ResponseBuilder entity(java.lang.Object)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
label:
return v;
label:
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode CANCEL_TRANSACTION>;
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v != v goto label;
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: javax.ws.rs.core.Response cancelTransaction(java.lang.String,org.apache.nifi.web.api.entity.TransactionResultEntity)>(v, v);
label:
return v;
label:
v = interfaceinvoke v.<org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol: int commitTransferTransaction(org.apache.nifi.remote.Peer,java.lang.String)>(v, v);
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode CONFIRM_TRANSACTION>;
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setResponseCode(int)>(v);
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setFlowFileSent(int)>(v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response handshakeExceptionResponse(org.apache.nifi.remote.exception.HandshakeException)>(v);
return v;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.remote.Peer: org.apache.nifi.remote.protocol.CommunicationsSession getCommunicationsSession()>();
v = <org.apache.nifi.web.api.DataTransferResource: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Failed to process the request", v);
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode BAD_CHECKSUM>;
v = virtualinvoke v.<org.apache.nifi.remote.io.http.HttpServerCommunicationsSession: org.apache.nifi.remote.protocol.ResponseCode getResponseCode()>();
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.nifi.remote.io.http.HttpServerCommunicationsSession: org.apache.nifi.remote.protocol.ResponseCode getResponseCode()>();
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setResponseCode(int)>(v);
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setMessage(java.lang.String)>(v);
v = <javax.ws.rs.core.Response$Status: javax.ws.rs.core.Response$Status BAD_REQUEST>;
v = staticinvoke <javax.ws.rs.core.Response: javax.ws.rs.core.Response$ResponseBuilder status(javax.ws.rs.core.Response$Status)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response$ResponseBuilder entity(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.DataTransferResource: javax.ws.rs.core.Response$ResponseBuilder noCache(javax.ws.rs.core.Response$ResponseBuilder)>(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.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response unexpectedErrorResponse(java.lang.String,java.lang.String,java.lang.Exception)>(v, v, v);
return v;
label:
v = staticinvoke <javax.ws.rs.core.Response: javax.ws.rs.core.Response$ResponseBuilder ok(java.lang.Object)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.HttpRemoteSiteListener transactionManager>;
v = virtualinvoke v.<org.apache.nifi.web.api.DataTransferResource: javax.ws.rs.core.Response$ResponseBuilder setCommonHeaders(javax.ws.rs.core.Response$ResponseBuilder,java.lang.Integer,org.apache.nifi.remote.HttpRemoteSiteListener)>(v, v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.DataTransferResource: javax.ws.rs.core.Response$ResponseBuilder noCache(javax.ws.rs.core.Response$ResponseBuilder)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
catch org.apache.nifi.remote.exception.HandshakeException from label to label with label;
catch org.apache.nifi.remote.exception.HandshakeException from label to label with label;
catch org.apache.nifi.remote.exception.HandshakeException from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
public javax.ws.rs.core.Response commitInputPortTransaction(java.lang.Integer, java.lang.String, java.lang.String, javax.servlet.http.HttpServletRequest, javax.servlet.ServletContext, java.io.InputStream)
{
java.lang.Integer v, v, v, v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.ws.rs.core.Response$Status v;
org.apache.nifi.remote.protocol.ResponseCode v, v, v, v, v, v, v, v, v;
java.lang.Exception v;
javax.ws.rs.core.Response$ResponseBuilder v, v, v, v, v, v, v;
java.lang.Throwable v;
java.lang.Object[] v;
java.io.ByteArrayOutputStream v;
javax.servlet.http.HttpServletRequest v;
org.apache.nifi.web.api.ApplicationResource$ResponseCreator v, v, v;
java.lang.String v, v, v, v;
org.apache.nifi.web.NiFiServiceFacade v;
java.io.IOException v;
javax.servlet.ServletContext v;
org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult v;
org.apache.nifi.remote.protocol.CommunicationsSession v;
boolean v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
org.apache.nifi.remote.HttpRemoteSiteListener v;
javax.ws.rs.core.Response v, v, v, v, v, v, v, v, v;
org.apache.nifi.web.api.entity.TransactionResultEntity v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v;
org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol v;
org.apache.nifi.remote.Peer v;
java.io.InputStream v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: java.lang.Integer;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: javax.servlet.ServletContext;
v := @parameter: java.io.InputStream;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource$lambda_commitInputPortTransaction_3__484: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.DataTransferResource,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: void authorizeAccess(org.apache.nifi.authorization.AuthorizeAccess)>(v);
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult validateResult(javax.servlet.http.HttpServletRequest,java.lang.String,java.lang.String)>(v, v, v);
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: javax.ws.rs.core.Response access$000(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
if v == null goto label;
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: javax.ws.rs.core.Response access$000(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
return v;
label:
v = <org.apache.nifi.web.api.DataTransferResource: org.slf4j.Logger logger>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("commitInputPortTransaction request: portId={}, transactionId={}, responseCode={}", v);
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: java.lang.Integer access$100(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = new java.io.ByteArrayOutputStream;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>()>();
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.Peer constructPeer(javax.servlet.http.HttpServletRequest,java.io.InputStream,java.io.OutputStream,java.lang.String,java.lang.String)>(v, v, v, v, v);
v = new org.apache.nifi.web.api.entity.TransactionResultEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void <init>()>();
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol initiateServerProtocol(javax.servlet.http.HttpServletRequest,org.apache.nifi.remote.Peer,java.lang.Integer)>(v, v, v);
v = virtualinvoke v.<org.apache.nifi.remote.Peer: org.apache.nifi.remote.protocol.CommunicationsSession getCommunicationsSession()>();
v = null;
if v != null goto label;
v = "responseCode is required.";
goto label;
label:
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode BAD_CHECKSUM>;
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v == v goto label;
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode CONFIRM_TRANSACTION>;
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v == v goto label;
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode CANCEL_TRANSACTION>;
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v == v goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Integer)>(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[])>("responseCode \u is invalid. ");
label:
if v == null goto label;
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setMessage(java.lang.String)>(v);
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode ABORT>;
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setResponseCode(int)>(v);
v = <javax.ws.rs.core.Response$Status: javax.ws.rs.core.Response$Status BAD_REQUEST>;
v = staticinvoke <javax.ws.rs.core.Response: javax.ws.rs.core.Response$ResponseBuilder status(javax.ws.rs.core.Response$Status)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response$ResponseBuilder entity(java.lang.Object)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
label:
return v;
label:
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode CANCEL_TRANSACTION>;
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v != v goto label;
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: javax.ws.rs.core.Response cancelTransaction(java.lang.String,org.apache.nifi.web.api.entity.TransactionResultEntity)>(v, v);
label:
return v;
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = staticinvoke <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode fromCode(int)>(v);
virtualinvoke v.<org.apache.nifi.remote.io.http.HttpServerCommunicationsSession: void setResponseCode(org.apache.nifi.remote.protocol.ResponseCode)>(v);
label:
v = interfaceinvoke v.<org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol: int commitReceiveTransaction(org.apache.nifi.remote.Peer)>(v);
v = virtualinvoke v.<org.apache.nifi.remote.io.http.HttpServerCommunicationsSession: org.apache.nifi.remote.protocol.ResponseCode getResponseCode()>();
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setResponseCode(int)>(v);
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setFlowFileSent(int)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode BAD_CHECKSUM>;
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v != v goto label;
v = virtualinvoke v.<java.io.IOException: java.lang.String getMessage()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("Received a BadChecksum response");
if v == 0 goto label;
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode CANCEL_TRANSACTION>;
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setResponseCode(int)>(v);
v = staticinvoke <javax.ws.rs.core.Response: javax.ws.rs.core.Response$ResponseBuilder ok(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.DataTransferResource: javax.ws.rs.core.Response$ResponseBuilder noCache(javax.ws.rs.core.Response$ResponseBuilder)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
label:
return v;
label:
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response unexpectedErrorResponse(java.lang.String,java.lang.String,java.lang.Exception)>(v, v, v);
label:
return v;
label:
v := @caughtexception;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response handshakeExceptionResponse(org.apache.nifi.remote.exception.HandshakeException)>(v);
return v;
label:
v := @caughtexception;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response unexpectedErrorResponse(java.lang.String,java.lang.String,java.lang.Exception)>(v, v, v);
return v;
label:
v = staticinvoke <javax.ws.rs.core.Response: javax.ws.rs.core.Response$ResponseBuilder ok(java.lang.Object)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.HttpRemoteSiteListener transactionManager>;
v = virtualinvoke v.<org.apache.nifi.web.api.DataTransferResource: javax.ws.rs.core.Response$ResponseBuilder setCommonHeaders(javax.ws.rs.core.Response$ResponseBuilder,java.lang.Integer,org.apache.nifi.remote.HttpRemoteSiteListener)>(v, v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.DataTransferResource: javax.ws.rs.core.Response$ResponseBuilder noCache(javax.ws.rs.core.Response$ResponseBuilder)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
return v;
catch java.io.IOException from label to label with label;
catch org.apache.nifi.remote.exception.HandshakeException from label to label with label;
catch org.apache.nifi.remote.exception.HandshakeException from label to label with label;
catch org.apache.nifi.remote.exception.HandshakeException from label to label with label;
catch org.apache.nifi.remote.exception.HandshakeException from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
private javax.ws.rs.core.Response cancelTransaction(java.lang.String, org.apache.nifi.web.api.entity.TransactionResultEntity)
{
org.apache.nifi.web.api.entity.TransactionResultEntity v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
org.apache.nifi.remote.protocol.ResponseCode v;
org.apache.nifi.remote.HttpRemoteSiteListener v;
javax.ws.rs.core.Response v;
javax.ws.rs.core.Response$ResponseBuilder v;
int v;
java.lang.String v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: java.lang.String;
v := @parameter: org.apache.nifi.web.api.entity.TransactionResultEntity;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.HttpRemoteSiteListener transactionManager>;
virtualinvoke v.<org.apache.nifi.remote.HttpRemoteSiteListener: void cancelTransaction(java.lang.String)>(v);
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setMessage(java.lang.String)>("Transaction has been canceled.");
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode CANCEL_TRANSACTION>;
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setResponseCode(int)>(v);
v = staticinvoke <javax.ws.rs.core.Response: javax.ws.rs.core.Response$ResponseBuilder ok(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 transferFlowFiles(java.lang.String, java.lang.String, javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse, javax.servlet.ServletContext, java.io.InputStream)
{
java.lang.Throwable v;
java.io.ByteArrayOutputStream v;
java.lang.Integer v, v, v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.servlet.http.HttpServletRequest v;
org.apache.nifi.web.api.ApplicationResource$ResponseCreator v, v, v;
org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult v;
int v;
java.lang.String v, v;
org.apache.nifi.web.api.DataTransferResource$1 v;
org.apache.nifi.web.NiFiServiceFacade v;
org.slf4j.Logger v;
javax.servlet.http.HttpServletResponse v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
java.lang.Exception v;
org.apache.nifi.remote.HttpRemoteSiteListener v;
javax.ws.rs.core.Response v, v, v, v, v;
org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol v;
javax.servlet.ServletContext v;
org.apache.nifi.remote.Peer v;
java.io.InputStream v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: javax.servlet.http.HttpServletResponse;
v := @parameter: javax.servlet.ServletContext;
v := @parameter: java.io.InputStream;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource$lambda_transferFlowFiles_4__485: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.DataTransferResource,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: void authorizeAccess(org.apache.nifi.authorization.AuthorizeAccess)>(v);
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult validateResult(javax.servlet.http.HttpServletRequest,java.lang.String,java.lang.String)>(v, v, v);
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: javax.ws.rs.core.Response access$000(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
if v == null goto label;
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: javax.ws.rs.core.Response access$000(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
return v;
label:
v = <org.apache.nifi.web.api.DataTransferResource: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("transferFlowFiles request: portId={}", v);
v = new java.io.ByteArrayOutputStream;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>()>();
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.Peer constructPeer(javax.servlet.http.HttpServletRequest,java.io.InputStream,java.io.OutputStream,java.lang.String,java.lang.String)>(v, v, v, v, v);
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: java.lang.Integer access$100(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol initiateServerProtocol(javax.servlet.http.HttpServletRequest,org.apache.nifi.remote.Peer,java.lang.Integer)>(v, v, v);
v = new org.apache.nifi.web.api.DataTransferResource$1;
specialinvoke v.<org.apache.nifi.web.api.DataTransferResource$1: void <init>(org.apache.nifi.web.api.DataTransferResource,org.apache.nifi.remote.Peer,org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol)>(v, v, v);
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.HttpRemoteSiteListener transactionManager>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response acceptedResponse(org.apache.nifi.remote.HttpRemoteSiteListener,java.lang.Object,java.lang.Integer)>(v, v, v);
label:
return v;
label:
v := @caughtexception;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response handshakeExceptionResponse(org.apache.nifi.remote.exception.HandshakeException)>(v);
return v;
label:
v := @caughtexception;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response unexpectedErrorResponse(java.lang.String,java.lang.Exception)>(v, v);
return v;
catch org.apache.nifi.remote.exception.HandshakeException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public javax.ws.rs.core.Response extendInputPortTransactionTTL(java.lang.String, java.lang.String, javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse, javax.servlet.ServletContext, javax.ws.rs.core.UriInfo, java.io.InputStream)
{
org.apache.nifi.web.NiFiServiceFacade v;
javax.servlet.http.HttpServletResponse v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.servlet.http.HttpServletRequest v;
javax.ws.rs.core.Response v;
javax.servlet.ServletContext v;
java.lang.String v, v;
javax.ws.rs.core.UriInfo v;
java.io.InputStream v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: javax.servlet.http.HttpServletResponse;
v := @parameter: javax.servlet.ServletContext;
v := @parameter: javax.ws.rs.core.UriInfo;
v := @parameter: java.io.InputStream;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource$lambda_extendInputPortTransactionTTL_5__486: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.DataTransferResource,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: void authorizeAccess(org.apache.nifi.authorization.AuthorizeAccess)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.DataTransferResource: javax.ws.rs.core.Response extendPortTransactionTTL(java.lang.String,java.lang.String,java.lang.String,javax.servlet.http.HttpServletRequest,javax.servlet.http.HttpServletResponse,javax.servlet.ServletContext,javax.ws.rs.core.UriInfo,java.io.InputStream)>("input-ports", v, v, v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response extendOutputPortTransactionTTL(java.lang.String, java.lang.String, javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse, javax.servlet.ServletContext, javax.ws.rs.core.UriInfo, java.io.InputStream)
{
org.apache.nifi.web.NiFiServiceFacade v;
javax.servlet.http.HttpServletResponse v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
org.apache.nifi.authorization.AuthorizeAccess v;
javax.servlet.http.HttpServletRequest v;
javax.ws.rs.core.Response v;
javax.servlet.ServletContext v;
java.lang.String v, v;
javax.ws.rs.core.UriInfo v;
java.io.InputStream v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: javax.servlet.http.HttpServletResponse;
v := @parameter: javax.servlet.ServletContext;
v := @parameter: javax.ws.rs.core.UriInfo;
v := @parameter: java.io.InputStream;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource$lambda_extendOutputPortTransactionTTL_6__487: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.DataTransferResource,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: void authorizeAccess(org.apache.nifi.authorization.AuthorizeAccess)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.DataTransferResource: javax.ws.rs.core.Response extendPortTransactionTTL(java.lang.String,java.lang.String,java.lang.String,javax.servlet.http.HttpServletRequest,javax.servlet.http.HttpServletResponse,javax.servlet.ServletContext,javax.ws.rs.core.UriInfo,java.io.InputStream)>("output-ports", v, v, v, v, v, v, v);
return v;
}
public javax.ws.rs.core.Response extendPortTransactionTTL(java.lang.String, java.lang.String, java.lang.String, javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse, javax.servlet.ServletContext, javax.ws.rs.core.UriInfo, java.io.InputStream)
{
java.lang.Integer v, v, v;
org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult v;
boolean v, v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
org.apache.nifi.remote.protocol.ResponseCode v;
java.lang.Exception v;
org.apache.nifi.remote.HttpRemoteSiteListener v, v;
javax.ws.rs.core.Response v, v, v, v, v, v;
javax.ws.rs.core.Response$ResponseBuilder v, v, v;
javax.ws.rs.core.UriInfo v;
java.lang.Throwable v;
java.lang.Object[] v;
java.io.ByteArrayOutputStream v;
org.apache.nifi.web.api.entity.TransactionResultEntity v;
javax.servlet.http.HttpServletRequest v;
org.apache.nifi.web.api.ApplicationResource$ResponseCreator v, v, v;
int v, v;
java.lang.String v, v, v, v, v;
org.slf4j.Logger v;
javax.servlet.http.HttpServletResponse v;
javax.servlet.ServletContext v;
org.apache.nifi.remote.Peer v;
java.io.InputStream v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: javax.servlet.http.HttpServletResponse;
v := @parameter: javax.servlet.ServletContext;
v := @parameter: javax.ws.rs.core.UriInfo;
v := @parameter: java.io.InputStream;
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult validateResult(javax.servlet.http.HttpServletRequest,java.lang.String,java.lang.String)>(v, v, v);
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: javax.ws.rs.core.Response access$000(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
if v == null goto label;
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: javax.ws.rs.core.Response access$000(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
return v;
label:
v = "input-ports";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = "output-ports";
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response wrongPortTypeResponse(java.lang.String,java.lang.String)>(v, v);
return v;
label:
v = <org.apache.nifi.web.api.DataTransferResource: org.slf4j.Logger logger>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("extendOutputPortTransactionTTL request: portType={}, portId={}, transactionId={}", v);
v = staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: java.lang.Integer access$100(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = new java.io.ByteArrayOutputStream;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>()>();
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.Peer constructPeer(javax.servlet.http.HttpServletRequest,java.io.InputStream,java.io.OutputStream,java.lang.String,java.lang.String)>(v, v, v, v, v);
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.protocol.http.HttpFlowFileServerProtocol initiateServerProtocol(javax.servlet.http.HttpServletRequest,org.apache.nifi.remote.Peer,java.lang.Integer)>(v, v, v);
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.HttpRemoteSiteListener transactionManager>;
virtualinvoke v.<org.apache.nifi.remote.HttpRemoteSiteListener: void extendTransaction(java.lang.String)>(v);
v = new org.apache.nifi.web.api.entity.TransactionResultEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void <init>()>();
v = <org.apache.nifi.remote.protocol.ResponseCode: org.apache.nifi.remote.protocol.ResponseCode CONTINUE_TRANSACTION>;
v = virtualinvoke v.<org.apache.nifi.remote.protocol.ResponseCode: int getCode()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setResponseCode(int)>(v);
virtualinvoke v.<org.apache.nifi.web.api.entity.TransactionResultEntity: void setMessage(java.lang.String)>("Extended TTL.");
v = staticinvoke <javax.ws.rs.core.Response: javax.ws.rs.core.Response$ResponseBuilder ok(java.lang.Object)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.HttpRemoteSiteListener transactionManager>;
v = virtualinvoke v.<org.apache.nifi.web.api.DataTransferResource: javax.ws.rs.core.Response$ResponseBuilder setCommonHeaders(javax.ws.rs.core.Response$ResponseBuilder,java.lang.Integer,org.apache.nifi.remote.HttpRemoteSiteListener)>(v, v, v);
v = virtualinvoke v.<org.apache.nifi.web.api.DataTransferResource: javax.ws.rs.core.Response$ResponseBuilder noCache(javax.ws.rs.core.Response$ResponseBuilder)>(v);
v = virtualinvoke v.<javax.ws.rs.core.Response$ResponseBuilder: javax.ws.rs.core.Response build()>();
label:
return v;
label:
v := @caughtexception;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response handshakeExceptionResponse(org.apache.nifi.remote.exception.HandshakeException)>(v);
return v;
label:
v := @caughtexception;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response unexpectedErrorResponse(java.lang.String,java.lang.String,java.lang.Exception)>(v, v, v);
return v;
catch org.apache.nifi.remote.exception.HandshakeException from label to label with label;
catch java.lang.Exception from label to label with label;
}
private org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult validateResult(javax.servlet.http.HttpServletRequest, java.lang.String)
{
javax.servlet.http.HttpServletRequest v;
org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
java.lang.String v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: java.lang.String;
v = specialinvoke v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult validateResult(javax.servlet.http.HttpServletRequest,java.lang.String,java.lang.String)>(v, v, null);
return v;
}
private org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult validateResult(javax.servlet.http.HttpServletRequest, java.lang.String, java.lang.String)
{
java.lang.Throwable v;
java.lang.Integer v;
javax.servlet.http.HttpServletRequest v;
org.apache.nifi.web.api.ApplicationResource$ResponseCreator v, v, v;
org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult v;
java.lang.Boolean v;
java.lang.String v, v;
org.apache.nifi.remote.VersionNegotiator v;
boolean v, v, v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
org.apache.nifi.remote.HttpRemoteSiteListener v;
javax.ws.rs.core.Response v, v, v;
org.apache.nifi.util.NiFiProperties v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult;
specialinvoke v.<org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: void <init>(org.apache.nifi.web.api.DataTransferResource,org.apache.nifi.web.api.DataTransferResource$1)>(v, null);
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.util.NiFiProperties properties>;
v = virtualinvoke v.<org.apache.nifi.util.NiFiProperties: java.lang.Boolean isSiteToSiteHttpEnabled()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v != 0 goto label;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response httpSiteToSiteIsNotEnabledResponse()>();
staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: javax.ws.rs.core.Response access$002(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult,javax.ws.rs.core.Response)>(v, v);
return v;
label:
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.VersionNegotiator transportProtocolVersionNegotiator>;
v = virtualinvoke v.<org.apache.nifi.web.api.DataTransferResource: java.lang.Integer negotiateTransportProtocolVersion(javax.servlet.http.HttpServletRequest,org.apache.nifi.remote.VersionNegotiator)>(v, v);
staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: java.lang.Integer access$102(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult,java.lang.Integer)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response badRequestResponse(java.lang.Exception)>(v);
staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: javax.ws.rs.core.Response access$002(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult,javax.ws.rs.core.Response)>(v, v);
return v;
label:
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v != 0 goto label;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.remote.HttpRemoteSiteListener transactionManager>;
v = virtualinvoke v.<org.apache.nifi.remote.HttpRemoteSiteListener: boolean isTransactionActive(java.lang.String)>(v);
if v != 0 goto label;
v = v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response transactionNotFoundResponse(java.lang.String,java.lang.String)>(v, v);
staticinvoke <org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult: javax.ws.rs.core.Response access$002(org.apache.nifi.web.api.DataTransferResource$ValidateRequestResult,javax.ws.rs.core.Response)>(v, v);
return v;
label:
return v;
catch org.apache.nifi.remote.exception.BadRequestException from label to label with label;
}
public void setServiceFacade(org.apache.nifi.web.NiFiServiceFacade)
{
org.apache.nifi.web.NiFiServiceFacade v;
WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.DataTransferResource;
v := @parameter: org.apache.nifi.web.NiFiServiceFacade;
v.<org.apache.nifi.web.api.DataTransferResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade> = 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/DataTransferResource;");
<org.apache.nifi.web.api.DataTransferResource: org.slf4j.Logger logger> = v;
return;
}
}