public class WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource extends org.apache.nifi.web.api.ApplicationResource
{
private static final org.slf4j.Logger logger;
private org.apache.nifi.web.NiFiServiceFacade serviceFacade;
private org.apache.nifi.cluster.coordination.ClusterCoordinator clusterCoordinator;
private org.apache.nifi.authorization.Authorizer authorizer;
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.remote.PeerDescriptionModifier peerDescriptionModifier;
public void <init>(org.apache.nifi.util.NiFiProperties)
{
org.apache.nifi.web.api.ApplicationResource$ResponseCreator v;
org.apache.nifi.util.NiFiProperties v;
int[] v;
WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource v;
org.apache.nifi.remote.client.http.TransportProtocolVersionNegotiator v;
org.apache.nifi.remote.PeerDescriptionModifier v;
org.apache.nifi.remote.HttpRemoteSiteListener v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource;
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.SiteToSiteResource: 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.SiteToSiteResource: org.apache.nifi.remote.VersionNegotiator transportProtocolVersionNegotiator> = 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.SiteToSiteResource: org.apache.nifi.remote.HttpRemoteSiteListener transactionManager> = v;
v = new org.apache.nifi.remote.PeerDescriptionModifier;
specialinvoke v.<org.apache.nifi.remote.PeerDescriptionModifier: void <init>(org.apache.nifi.util.NiFiProperties)>(v);
v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.remote.PeerDescriptionModifier peerDescriptionModifier> = v;
return;
}
protected void authorizeSiteToSite()
{
WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource v;
org.apache.nifi.authorization.AuthorizeAccess v;
org.apache.nifi.web.NiFiServiceFacade v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource;
v = v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource$lambda_authorizeSiteToSite_0__873: org.apache.nifi.authorization.AuthorizeAccess bootstrap$(org.apache.nifi.web.api.SiteToSiteResource)>(v);
interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: void authorizeAccess(org.apache.nifi.authorization.AuthorizeAccess)>(v);
return;
}
public javax.ws.rs.core.Response getSiteToSiteDetails(javax.servlet.http.HttpServletRequest)
{
java.lang.Integer v, v, v, v;
org.apache.nifi.web.api.entity.ControllerEntity v;
java.util.Map v;
boolean v, v, v, v, v, v, v;
javax.ws.rs.core.Response v;
javax.ws.rs.core.Response$ResponseBuilder v, v;
org.apache.nifi.remote.PeerDescriptionModifier$RequestType v, v;
org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol v, v, v, v;
java.util.HashMap v, v;
javax.servlet.http.HttpServletRequest v;
int v, v, v, v;
java.lang.Boolean v, v, v;
org.apache.nifi.remote.PeerDescriptionModifier v, v, v, v;
java.lang.String v, v;
org.apache.nifi.web.NiFiServiceFacade v;
org.slf4j.Logger v;
org.apache.nifi.remote.PeerDescription v, v, v, v, v;
org.apache.nifi.web.api.dto.ControllerDTO v;
WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
virtualinvoke v.<org.apache.nifi.web.api.SiteToSiteResource: void authorizeSiteToSite()>();
v = v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade>;
v = interfaceinvoke v.<org.apache.nifi.web.NiFiServiceFacade: org.apache.nifi.web.api.dto.ControllerDTO getSiteToSiteDetails()>();
v = v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.remote.PeerDescriptionModifier peerDescriptionModifier>;
v = <org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol: org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol RAW>;
v = virtualinvoke v.<org.apache.nifi.remote.PeerDescriptionModifier: boolean isModificationNeeded(org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol)>(v);
v = v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.remote.PeerDescriptionModifier peerDescriptionModifier>;
v = <org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol: org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol HTTP>;
v = virtualinvoke v.<org.apache.nifi.remote.PeerDescriptionModifier: boolean isModificationNeeded(org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol)>(v);
if v != 0 goto label;
if v == 0 goto label;
label:
v = specialinvoke v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.remote.PeerDescription getSourcePeerDescription(javax.servlet.http.HttpServletRequest)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerDTO: java.lang.Boolean isSiteToSiteSecure()>();
v = specialinvoke v.<org.apache.nifi.web.api.SiteToSiteResource: java.lang.String getSiteToSiteHostname(javax.servlet.http.HttpServletRequest)>(v);
v = specialinvoke v.<org.apache.nifi.web.api.SiteToSiteResource: java.util.Map getHttpHeaders(javax.servlet.http.HttpServletRequest)>(v);
if v == 0 goto label;
v = new org.apache.nifi.remote.PeerDescription;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerDTO: java.lang.Integer getRemoteSiteListeningPort()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
specialinvoke v.<org.apache.nifi.remote.PeerDescription: void <init>(java.lang.String,int,boolean)>(v, v, v);
v = v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.remote.PeerDescriptionModifier peerDescriptionModifier>;
v = <org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol: org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol RAW>;
v = <org.apache.nifi.remote.PeerDescriptionModifier$RequestType: org.apache.nifi.remote.PeerDescriptionModifier$RequestType SiteToSiteDetail>;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = virtualinvoke v.<org.apache.nifi.remote.PeerDescriptionModifier: org.apache.nifi.remote.PeerDescription modify(org.apache.nifi.remote.PeerDescription,org.apache.nifi.remote.PeerDescription,org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol,org.apache.nifi.remote.PeerDescriptionModifier$RequestType,java.util.Map)>(v, v, v, v, v);
v = virtualinvoke v.<org.apache.nifi.remote.PeerDescription: int getPort()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerDTO: void setRemoteSiteListeningPort(java.lang.Integer)>(v);
label:
if v == 0 goto label;
v = new org.apache.nifi.remote.PeerDescription;
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerDTO: java.lang.Integer getRemoteSiteHttpListeningPort()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
specialinvoke v.<org.apache.nifi.remote.PeerDescription: void <init>(java.lang.String,int,boolean)>(v, v, v);
v = v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.remote.PeerDescriptionModifier peerDescriptionModifier>;
v = <org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol: org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol HTTP>;
v = <org.apache.nifi.remote.PeerDescriptionModifier$RequestType: org.apache.nifi.remote.PeerDescriptionModifier$RequestType SiteToSiteDetail>;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = virtualinvoke v.<org.apache.nifi.remote.PeerDescriptionModifier: org.apache.nifi.remote.PeerDescription modify(org.apache.nifi.remote.PeerDescription,org.apache.nifi.remote.PeerDescription,org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol,org.apache.nifi.remote.PeerDescriptionModifier$RequestType,java.util.Map)>(v, v, v, v, v);
v = virtualinvoke v.<org.apache.nifi.remote.PeerDescription: int getPort()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerDTO: void setRemoteSiteHttpListeningPort(java.lang.Integer)>(v);
v = virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerDTO: java.lang.Boolean isSiteToSiteSecure()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.nifi.remote.PeerDescription: boolean isSecure()>();
if v == 0 goto label;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(1);
virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerDTO: void setSiteToSiteSecure(java.lang.Boolean)>(v);
label:
v = new org.apache.nifi.web.api.entity.ControllerEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.ControllerEntity: void <init>()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.ControllerEntity: void setController(org.apache.nifi.web.api.dto.ControllerDTO)>(v);
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getHeader(java.lang.String)>("x-nifi-site-to-site-protocol-version");
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = <org.apache.nifi.web.api.SiteToSiteResource: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Converting result to provide backward compatibility...");
virtualinvoke v.<org.apache.nifi.web.api.dto.ControllerDTO: void setRemoteSiteHttpListeningPort(java.lang.Integer)>(null);
label:
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.SiteToSiteResource: 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;
}
private org.apache.nifi.remote.PeerDescription getSourcePeerDescription(javax.servlet.http.HttpServletRequest)
{
javax.servlet.http.HttpServletRequest v;
org.apache.nifi.remote.PeerDescription v;
WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource v;
int v;
java.lang.String v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v = new org.apache.nifi.remote.PeerDescription;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getRemoteHost()>();
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: int getRemotePort()>();
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);
return v;
}
private java.util.Map getHttpHeaders(javax.servlet.http.HttpServletRequest)
{
javax.servlet.http.HttpServletRequest v;
java.util.Enumeration v;
WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource v;
java.lang.Object v;
java.util.HashMap v;
java.lang.String v;
boolean v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.util.Enumeration getHeaderNames()>();
label:
v = interfaceinvoke v.<java.util.Enumeration: boolean hasMoreElements()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Enumeration: java.lang.Object nextElement()>();
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getHeader(java.lang.String)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
return v;
}
public javax.ws.rs.core.Response getPeers(javax.servlet.http.HttpServletRequest)
{
java.lang.Integer v, v;
org.apache.nifi.web.api.entity.PeersEntity v;
java.util.Map v, v;
boolean v, v, v, v, v;
org.apache.nifi.remote.HttpRemoteSiteListener v;
javax.ws.rs.core.Response v, v, v;
javax.ws.rs.core.Response$ResponseBuilder v, v, v;
org.apache.nifi.web.api.dto.remote.PeerDTO v;
org.apache.nifi.remote.PeerDescriptionModifier$RequestType v;
java.lang.Throwable v;
org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol v, v;
java.util.HashMap v;
java.util.ArrayList v;
javax.servlet.http.HttpServletRequest v;
org.apache.nifi.web.api.ApplicationResource$ResponseCreator v, v;
int v, v;
java.util.function.BiConsumer v;
org.apache.nifi.cluster.coordination.ClusterCoordinator v;
java.lang.Boolean v, v;
org.apache.nifi.remote.PeerDescriptionModifier v, v;
java.lang.String v, v, v;
org.apache.nifi.remote.VersionNegotiator v;
org.apache.nifi.remote.PeerDescription v, v, v;
java.io.IOException v;
java.lang.RuntimeException v;
org.apache.nifi.util.NiFiProperties v, v, v, v;
WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
virtualinvoke v.<org.apache.nifi.web.api.SiteToSiteResource: void authorizeSiteToSite()>();
v = v.<org.apache.nifi.web.api.SiteToSiteResource: 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.SiteToSiteResource: org.apache.nifi.web.api.ApplicationResource$ResponseCreator responseCreator>;
v = virtualinvoke v.<org.apache.nifi.web.api.ApplicationResource$ResponseCreator: javax.ws.rs.core.Response httpSiteToSiteIsNotEnabledResponse()>();
return v;
label:
v = v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.remote.VersionNegotiator transportProtocolVersionNegotiator>;
v = virtualinvoke v.<org.apache.nifi.web.api.SiteToSiteResource: java.lang.Integer negotiateTransportProtocolVersion(javax.servlet.http.HttpServletRequest,org.apache.nifi.remote.VersionNegotiator)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = v.<org.apache.nifi.web.api.SiteToSiteResource: 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 = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = specialinvoke v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.remote.PeerDescription getSourcePeerDescription(javax.servlet.http.HttpServletRequest)>(v);
v = v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.remote.PeerDescriptionModifier peerDescriptionModifier>;
v = <org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol: org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol HTTP>;
v = virtualinvoke v.<org.apache.nifi.remote.PeerDescriptionModifier: boolean isModificationNeeded(org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol)>(v);
if v == 0 goto label;
v = specialinvoke v.<org.apache.nifi.web.api.SiteToSiteResource: java.util.Map getHttpHeaders(javax.servlet.http.HttpServletRequest)>(v);
goto label;
label:
v = null;
label:
v = v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.util.NiFiProperties properties>;
v = virtualinvoke v.<org.apache.nifi.util.NiFiProperties: boolean isNode()>();
if v == 0 goto label;
label:
v = v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.cluster.coordination.ClusterCoordinator clusterCoordinator>;
v = interfaceinvoke v.<org.apache.nifi.cluster.coordination.ClusterCoordinator: java.util.Map getClusterWorkload()>();
v = staticinvoke <WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource$lambda_getPeers_1__874: java.util.function.BiConsumer bootstrap$(org.apache.nifi.web.api.SiteToSiteResource,boolean,org.apache.nifi.remote.PeerDescription,java.util.Map,java.util.List)>(v, v, v, v, v);
interfaceinvoke v.<java.util.Map: void forEach(java.util.function.BiConsumer)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.io.IOException)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to retrieve cluster workload due to \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v = new org.apache.nifi.web.api.dto.remote.PeerDTO;
specialinvoke v.<org.apache.nifi.web.api.dto.remote.PeerDTO: void <init>()>();
v = specialinvoke v.<org.apache.nifi.web.api.SiteToSiteResource: java.lang.String getSiteToSiteHostname(javax.servlet.http.HttpServletRequest)>(v);
v = new org.apache.nifi.remote.PeerDescription;
v = v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.util.NiFiProperties properties>;
v = virtualinvoke v.<org.apache.nifi.util.NiFiProperties: java.lang.Integer getRemoteInputHttpPort()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.util.NiFiProperties properties>;
v = virtualinvoke v.<org.apache.nifi.util.NiFiProperties: java.lang.Boolean isSiteToSiteSecure()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
specialinvoke v.<org.apache.nifi.remote.PeerDescription: void <init>(java.lang.String,int,boolean)>(v, v, v);
v = v;
if v == 0 goto label;
v = v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.remote.PeerDescriptionModifier peerDescriptionModifier>;
v = <org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol: org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol HTTP>;
v = <org.apache.nifi.remote.PeerDescriptionModifier$RequestType: org.apache.nifi.remote.PeerDescriptionModifier$RequestType Peers>;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = virtualinvoke v.<org.apache.nifi.remote.PeerDescriptionModifier: org.apache.nifi.remote.PeerDescription modify(org.apache.nifi.remote.PeerDescription,org.apache.nifi.remote.PeerDescription,org.apache.nifi.remote.protocol.SiteToSiteTransportProtocol,org.apache.nifi.remote.PeerDescriptionModifier$RequestType,java.util.Map)>(v, v, v, v, v);
label:
v = virtualinvoke v.<org.apache.nifi.remote.PeerDescription: java.lang.String getHostname()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.remote.PeerDTO: void setHostname(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.nifi.remote.PeerDescription: int getPort()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.remote.PeerDTO: void setPort(int)>(v);
v = virtualinvoke v.<org.apache.nifi.remote.PeerDescription: boolean isSecure()>();
virtualinvoke v.<org.apache.nifi.web.api.dto.remote.PeerDTO: void setSecure(boolean)>(v);
virtualinvoke v.<org.apache.nifi.web.api.dto.remote.PeerDTO: void setFlowFileCount(int)>(0);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = new org.apache.nifi.web.api.entity.PeersEntity;
specialinvoke v.<org.apache.nifi.web.api.entity.PeersEntity: void <init>()>();
virtualinvoke v.<org.apache.nifi.web.api.entity.PeersEntity: void setPeers(java.util.Collection)>(v);
v = staticinvoke <javax.ws.rs.core.Response: javax.ws.rs.core.Response$ResponseBuilder ok(java.lang.Object)>(v);
v = v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.remote.HttpRemoteSiteListener transactionManager>;
v = virtualinvoke v.<org.apache.nifi.web.api.SiteToSiteResource: 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.SiteToSiteResource: 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.BadRequestException from label to label with label;
catch java.io.IOException from label to label with label;
}
private java.lang.String getSiteToSiteHostname(javax.servlet.http.HttpServletRequest)
{
org.slf4j.Logger v, v;
java.net.UnknownHostException v;
java.net.InetAddress v;
javax.servlet.http.HttpServletRequest v;
org.apache.nifi.util.NiFiProperties v;
WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource v;
java.lang.String v, v, v;
boolean v, v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource;
v := @parameter: javax.servlet.http.HttpServletRequest;
v = v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.util.NiFiProperties properties>;
v = virtualinvoke v.<org.apache.nifi.util.NiFiProperties: java.lang.String getRemoteInputHost()>();
label:
v = staticinvoke <java.net.InetAddress: java.net.InetAddress getLocalHost()>();
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostName()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.nifi.web.api.SiteToSiteResource: org.slf4j.Logger logger>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <org.apache.nifi.web.api.SiteToSiteResource: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>("Failed to get local host name using InetAddress.", v);
label:
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getLocalName()>();
label:
v = staticinvoke <org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = v;
goto label;
label:
v = v;
label:
return v;
catch java.net.UnknownHostException from label to label with label;
}
public void setServiceFacade(org.apache.nifi.web.NiFiServiceFacade)
{
WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource v;
org.apache.nifi.web.NiFiServiceFacade v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource;
v := @parameter: org.apache.nifi.web.NiFiServiceFacade;
v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.web.NiFiServiceFacade serviceFacade> = v;
return;
}
public void setAuthorizer(org.apache.nifi.authorization.Authorizer)
{
WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource v;
org.apache.nifi.authorization.Authorizer v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource;
v := @parameter: org.apache.nifi.authorization.Authorizer;
v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.authorization.Authorizer authorizer> = v;
return;
}
public void setClusterCoordinator(org.apache.nifi.cluster.coordination.ClusterCoordinator)
{
WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource v;
org.apache.nifi.cluster.coordination.ClusterCoordinator v;
v := @this: WEB-INF.classes.org.apache.nifi.web.api.SiteToSiteResource;
v := @parameter: org.apache.nifi.cluster.coordination.ClusterCoordinator;
specialinvoke v.<org.apache.nifi.web.api.ApplicationResource: void setClusterCoordinator(org.apache.nifi.cluster.coordination.ClusterCoordinator)>(v);
v.<org.apache.nifi.web.api.SiteToSiteResource: org.apache.nifi.cluster.coordination.ClusterCoordinator clusterCoordinator> = 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/SiteToSiteResource;");
<org.apache.nifi.web.api.SiteToSiteResource: org.slf4j.Logger logger> = v;
return;
}
}