public abstract class WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource extends java.lang.Object { public static final java.lang.String VERSION; public static final java.lang.String CLIENT_ID; public static final java.lang.String DISCONNECTED_NODE_ACKNOWLEDGED; static final java.lang.String LOGIN_ERROR_TITLE; static final java.lang.String LOGOUT_ERROR_TITLE; protected static final java.lang.String NON_GUARANTEED_ENDPOINT; private static final org.slf4j.Logger logger; private static final java.lang.String ROOT_PATH; public static final java.lang.String NODEWISE; protected javax.servlet.http.HttpServletRequest httpServletRequest; protected javax.ws.rs.core.UriInfo uriInfo; protected org.apache.nifi.web.security.cookie.ApplicationCookieService applicationCookieService; protected org.apache.nifi.util.NiFiProperties properties; private org.apache.nifi.cluster.coordination.http.replication.RequestReplicator requestReplicator; private org.apache.nifi.cluster.coordination.ClusterCoordinator clusterCoordinator; private org.apache.nifi.controller.FlowController flowController; private static final int MAX_CACHE_SOFT_LIMIT; private final com.github.benmanes.caffeine.cache.Cache twoPhaseCommitCache; public void () { java.util.concurrent.TimeUnit v; org.apache.nifi.web.security.cookie.StandardApplicationCookieService v; com.github.benmanes.caffeine.cache.Caffeine v, v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; com.github.benmanes.caffeine.cache.Cache v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; specialinvoke v.()>(); v = new org.apache.nifi.web.security.cookie.StandardApplicationCookieService; specialinvoke v.()>(); v. = v; v = staticinvoke (); v = ; v = virtualinvoke v.(1L, v); v = virtualinvoke v.(); v. = v; return; } protected void forwardToLoginMessagePage(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse, java.lang.String) throws java.lang.Exception { javax.servlet.http.HttpServletRequest v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; javax.servlet.http.HttpServletResponse v; java.lang.String v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: javax.servlet.http.HttpServletRequest; v := @parameter: javax.servlet.http.HttpServletResponse; v := @parameter: java.lang.String; virtualinvoke v.(v, v, "Unable to continue login sequence", v); return; } protected void forwardToLogoutMessagePage(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse, java.lang.String) throws java.lang.Exception { javax.servlet.http.HttpServletRequest v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; javax.servlet.http.HttpServletResponse v; java.lang.String v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: javax.servlet.http.HttpServletRequest; v := @parameter: javax.servlet.http.HttpServletResponse; v := @parameter: java.lang.String; virtualinvoke v.(v, v, "Unable to continue logout sequence", v); return; } protected void forwardToMessagePage(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse, java.lang.String, java.lang.String) throws java.lang.Exception { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; javax.servlet.RequestDispatcher v; javax.servlet.http.HttpServletResponse v; javax.servlet.http.HttpServletRequest v; javax.servlet.ServletContext v, v; java.lang.String v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: javax.servlet.http.HttpServletRequest; v := @parameter: javax.servlet.http.HttpServletResponse; v := @parameter: java.lang.String; v := @parameter: java.lang.String; interfaceinvoke v.("title", v); interfaceinvoke v.("messages", v); v = interfaceinvoke v.(); v = interfaceinvoke v.("/nifi"); v = interfaceinvoke v.("/WEB-INF/pages/message-page.jsp"); interfaceinvoke v.(v, v); return; } protected transient java.lang.String generateResourceUri(java.lang.String[]) { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.lang.String[] v; java.lang.String v; java.net.URI v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: java.lang.String[]; v = specialinvoke v.(v); v = virtualinvoke v.(); return v; } protected java.net.URI getCookieResourceUri() { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.lang.Object[] v; javax.ws.rs.core.UriBuilder v, v; java.net.URI v, v; javax.ws.rs.core.UriInfo v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.("/"); v = newarray (java.lang.Object)[0]; v = virtualinvoke v.(v); v = specialinvoke v.(v); return v; } private transient java.net.URI buildResourceUri(java.lang.String[]) { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.lang.Object[] v; java.lang.String[] v; javax.ws.rs.core.UriBuilder v, v; java.net.URI v, v; javax.ws.rs.core.UriInfo v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: java.lang.String[]; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = newarray (java.lang.Object)[0]; v = virtualinvoke v.(v); v = specialinvoke v.(v); return v; } private java.net.URI buildResourceUri(java.net.URI) { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.util.List v; javax.servlet.http.HttpServletRequest v; org.apache.nifi.web.util.RequestUriBuilder v; org.apache.nifi.util.NiFiProperties v; java.lang.String v; java.net.URI v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: java.net.URI; v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); return v; } protected javax.ws.rs.core.Response$ResponseBuilder noCache(javax.ws.rs.core.Response$ResponseBuilder) { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; javax.ws.rs.core.Response$ResponseBuilder v, v; javax.ws.rs.core.CacheControl v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: javax.ws.rs.core.Response$ResponseBuilder; v = new javax.ws.rs.core.CacheControl; specialinvoke v.()>(); virtualinvoke v.(1); virtualinvoke v.(1); virtualinvoke v.(1); v = virtualinvoke v.(v); return v; } protected java.lang.String generateUuid() { byte[] v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; long v; java.nio.charset.Charset v; int v; java.lang.String v; boolean v; org.slf4j.Logger v; java.util.UUID v, v, v; java.lang.Exception v; java.util.Optional v; java.lang.Object v, v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); v = new java.util.UUID; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(long,long)>(v, v); v = v; label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Provided \'seed\' does not represent UUID. Will not be able to extract most significant bits for ID generation."); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); v = staticinvoke (v); goto label; label: v = staticinvoke (); label: v = virtualinvoke v.(); return v; catch java.lang.Exception from label to label with label; } protected java.util.Optional getIdGenerationSeed() { javax.servlet.http.HttpServletRequest v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.util.Optional v, v; java.lang.String v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = v.; v = interfaceinvoke v.("X-Cluster-Id-Generation-Seed"); v = staticinvoke (v); if v == 0 goto label; v = staticinvoke (); return v; label: v = staticinvoke (v); return v; } protected javax.ws.rs.core.Response$ResponseBuilder generateOkResponse() { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; javax.ws.rs.core.Response$ResponseBuilder v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = staticinvoke (); v = virtualinvoke v.(v); return v; } protected javax.ws.rs.core.Response$ResponseBuilder generateOkResponse(java.lang.Object) { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; javax.ws.rs.core.Response$ResponseBuilder v, v; java.lang.Object v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: java.lang.Object; v = staticinvoke (v); v = virtualinvoke v.(v); return v; } protected javax.ws.rs.core.Response$ResponseBuilder generateCreatedResponse(java.net.URI, java.lang.Object) { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; javax.ws.rs.core.Response$ResponseBuilder v, v; java.lang.Object v; java.net.URI v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: java.net.URI; v := @parameter: java.lang.Object; v = staticinvoke (v); v = virtualinvoke v.(v); return v; } protected javax.ws.rs.core.Response$ResponseBuilder generateNotAuthorizedResponse() { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; javax.ws.rs.core.Response$ResponseBuilder v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = staticinvoke (401); return v; } protected javax.ws.rs.core.Response$ResponseBuilder generateContinueResponse() { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; javax.ws.rs.core.Response$ResponseBuilder v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = staticinvoke (202); return v; } protected java.net.URI getAbsolutePath() { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.net.URI v; javax.ws.rs.core.UriInfo v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = v.; v = interfaceinvoke v.(); return v; } protected java.net.URI getRequestUri() { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.net.URI v; javax.ws.rs.core.UriInfo v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = v.; v = interfaceinvoke v.(); return v; } protected javax.ws.rs.core.MultivaluedMap getRequestParameters() { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.util.Iterator v; java.util.Set v; javax.ws.rs.core.MultivaluedHashMap v; javax.servlet.http.HttpServletRequest v; java.util.Map v; int v, v; java.lang.Object v, v, v, v, v; java.lang.String v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = new javax.ws.rs.core.MultivaluedHashMap; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != null goto label; v = interfaceinvoke v.(); interfaceinvoke v.(v, null); goto label; label: v = interfaceinvoke v.(); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = interfaceinvoke v.(); interfaceinvoke v.(v, v); v = v + 1; goto label; label: return v; } protected java.util.Map getHeaders() { java.util.HashMap v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.util.Map v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = new java.util.HashMap; specialinvoke v.()>(); v = virtualinvoke v.(v); return v; } protected java.util.Map getHeaders(java.util.Map) { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.util.Enumeration v; java.lang.String[] v, v, v; java.util.HashMap v; javax.servlet.http.HttpServletRequest v, v, v, v, v; java.util.Map v; int v; java.lang.String v, v, v, v, v, v, v; boolean v, v, v, v; java.util.TreeMap v; java.lang.Object v, v; java.util.Comparator v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: java.util.Map; v = new java.util.HashMap; specialinvoke v.()>(); v = new java.util.TreeMap; v = ; specialinvoke v.(java.util.Comparator)>(v); if v == null goto label; interfaceinvoke v.(v); label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = virtualinvoke v.("content-length"); if v != 0 goto label; label: v = interfaceinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(v); interfaceinvoke v.(v, v); goto label; label: v = v.; v = interfaceinvoke v.(v); interfaceinvoke v.(v, v); goto label; label: v = newarray (java.lang.String)[2]; v[0] = "X-ProxyScheme"; v[1] = "X-Forwarded-Proto"; v = specialinvoke v.(v); if v != null goto label; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.("X-ProxyScheme", v); label: v = newarray (java.lang.String)[2]; v[0] = "X-ProxyHost"; v[1] = "X-Forwarded-Host"; v = specialinvoke v.(v); if v != null goto label; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.("X-ProxyHost", v); label: v = newarray (java.lang.String)[2]; v[0] = "X-ProxyPort"; v[1] = "X-Forwarded-Port"; v = specialinvoke v.(v); if v != null goto label; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("X-ProxyPort", v); label: return v; } private transient java.lang.String getFirstHeaderValue(java.lang.String[]) { javax.servlet.http.HttpServletRequest v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.lang.String[] v; java.lang.String v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: java.lang.String[]; v = v.; v = staticinvoke (v, v); return v; } protected boolean isTwoPhaseRequest(javax.servlet.http.HttpServletRequest) { javax.servlet.http.HttpServletRequest v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.lang.String v; boolean v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: javax.servlet.http.HttpServletRequest; v = interfaceinvoke v.("X-RequestTransactionId"); if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } protected boolean isValidationPhase(javax.servlet.http.HttpServletRequest) { javax.servlet.http.HttpServletRequest v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.lang.String v; boolean v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: javax.servlet.http.HttpServletRequest; v = virtualinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.("X-Validation-Expects"); if v == null goto label; v = 1; goto label; label: v = 0; label: return v; } protected boolean isExecutionPhase(javax.servlet.http.HttpServletRequest) { javax.servlet.http.HttpServletRequest v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.lang.String v; boolean v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: javax.servlet.http.HttpServletRequest; v = virtualinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.("X-Execution-Continue"); if v == null goto label; v = 1; goto label; label: v = 0; label: return v; } protected boolean isCancellationPhase(javax.servlet.http.HttpServletRequest) { javax.servlet.http.HttpServletRequest v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.lang.String v; boolean v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: javax.servlet.http.HttpServletRequest; v = virtualinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.("X-Cancel-Transaction"); if v == null goto label; v = 1; goto label; label: v = 0; label: return v; } boolean isReplicateRequest() { javax.servlet.http.HttpServletRequest v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; org.apache.nifi.util.NiFiProperties v; java.lang.String v; boolean v, v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = v.; v = virtualinvoke v.(); if v != 0 goto label; return 0; label: specialinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; return 0; label: v = v.; v = interfaceinvoke v.("X-Request-Replicated"); if v != null goto label; v = 1; goto label; label: v = 0; label: return v; } protected org.apache.nifi.web.Revision getRevision(org.apache.nifi.web.api.dto.RevisionDTO, java.lang.String) { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; org.apache.nifi.web.Revision v; java.lang.Long v; java.lang.String v, v; org.apache.nifi.web.api.dto.RevisionDTO v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: org.apache.nifi.web.api.dto.RevisionDTO; v := @parameter: java.lang.String; v = new org.apache.nifi.web.Revision; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.Long,java.lang.String,java.lang.String)>(v, v, v); return v; } protected org.apache.nifi.web.Revision getRevision(org.apache.nifi.web.api.entity.ComponentEntity, java.lang.String) { org.apache.nifi.web.api.entity.ComponentEntity v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; org.apache.nifi.web.Revision v; java.lang.String v; org.apache.nifi.web.api.dto.RevisionDTO v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: org.apache.nifi.web.api.entity.ComponentEntity; v := @parameter: java.lang.String; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); return v; } protected void authorizeRestrictions(org.apache.nifi.authorization.Authorizer, org.apache.nifi.authorization.ComponentAuthorizable) { java.util.function.Consumer v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; org.apache.nifi.authorization.Authorizer v; java.util.Set v; org.apache.nifi.authorization.ComponentAuthorizable v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: org.apache.nifi.authorization.Authorizer; v := @parameter: org.apache.nifi.authorization.ComponentAuthorizable; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); return; } protected void authorizeProcessGroup(org.apache.nifi.authorization.ProcessGroupAuthorizable, org.apache.nifi.authorization.Authorizer, org.apache.nifi.authorization.AuthorizableLookup, org.apache.nifi.authorization.RequestAction, boolean, boolean, boolean, boolean, boolean) { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.util.function.Function v, v; org.apache.nifi.authorization.user.NiFiUser v; boolean v, v, v, v, v; org.apache.nifi.authorization.resource.Authorizable v; org.apache.nifi.authorization.AuthorizableLookup v; org.apache.nifi.authorization.RequestAction v; java.util.Set v, v, v, v, v, v, v, v, v, v; java.util.function.Consumer v, v, v; java.util.stream.Stream v, v, v, v; org.apache.nifi.authorization.Authorizer v; org.apache.nifi.authorization.ProcessGroupAuthorizable v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: org.apache.nifi.authorization.ProcessGroupAuthorizable; v := @parameter: org.apache.nifi.authorization.Authorizer; v := @parameter: org.apache.nifi.authorization.AuthorizableLookup; v := @parameter: org.apache.nifi.authorization.RequestAction; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v = staticinvoke (); v = staticinvoke (v, v, v); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v, v, v, v, v, v, v); interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); interfaceinvoke v.(v); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); interfaceinvoke v.(v); v = interfaceinvoke v.(); interfaceinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(v); label: if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (v, v, v, v, v, v, v); interfaceinvoke v.(v); label: return; } protected void authorizeSnippet(org.apache.nifi.authorization.SnippetAuthorizable, org.apache.nifi.authorization.Authorizer, org.apache.nifi.authorization.AuthorizableLookup, org.apache.nifi.authorization.RequestAction, boolean, boolean, boolean) { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; org.apache.nifi.authorization.user.NiFiUser v; boolean v, v, v; org.apache.nifi.authorization.AuthorizableLookup v; org.apache.nifi.authorization.RequestAction v; java.util.Set v, v, v, v, v, v, v, v; org.apache.nifi.authorization.SnippetAuthorizable v; java.util.function.Consumer v, v, v, v; org.apache.nifi.authorization.Authorizer v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: org.apache.nifi.authorization.SnippetAuthorizable; v := @parameter: org.apache.nifi.authorization.Authorizer; v := @parameter: org.apache.nifi.authorization.AuthorizableLookup; v := @parameter: org.apache.nifi.authorization.RequestAction; v := @parameter: boolean; v := @parameter: boolean; v := @parameter: boolean; v = staticinvoke (); v = staticinvoke (v, v, v); v = interfaceinvoke v.(); v = staticinvoke (v, v, v, v, v, v, v); interfaceinvoke v.(v); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v, v, v, v, v, v, v); interfaceinvoke v.(v); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = interfaceinvoke v.(); interfaceinvoke v.(v); return; } protected javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade, org.apache.nifi.web.api.entity.Entity, org.apache.nifi.web.Revision, org.apache.nifi.authorization.AuthorizeAccess, java.lang.Runnable, java.util.function.BiFunction) { org.apache.nifi.web.api.ApplicationResource$Request v; java.lang.IllegalStateException v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; org.apache.nifi.web.Revision v, v; java.util.function.BiFunction v; java.lang.Runnable v; org.apache.nifi.authorization.AuthorizeAccess v; javax.servlet.http.HttpServletRequest v, v, v, v; org.apache.nifi.authorization.user.NiFiUser v; boolean v, v, v, v; org.apache.nifi.web.NiFiServiceFacade v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v, v; java.lang.Object v, v; org.apache.nifi.web.api.entity.Entity v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: org.apache.nifi.web.NiFiServiceFacade; v := @parameter: org.apache.nifi.web.api.entity.Entity; v := @parameter: org.apache.nifi.web.Revision; v := @parameter: org.apache.nifi.authorization.AuthorizeAccess; v := @parameter: java.lang.Runnable; v := @parameter: java.util.function.BiFunction; v = staticinvoke (); v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; interfaceinvoke v.(v); interfaceinvoke v.(v, v); if v == null goto label; interfaceinvoke v.(); label: specialinvoke v.(v, v, null); v = virtualinvoke v.(); v = virtualinvoke v.(); return v; label: v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v); return v; label: v = v.; v = virtualinvoke v.(v); if v == 0 goto label; specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); return v; label: v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("This request does not appear to be part of the two phase commit."); throw v; label: interfaceinvoke v.(v); interfaceinvoke v.(v, v); if v == null goto label; interfaceinvoke v.(); label: v = interfaceinvoke v.(v, v); return v; } protected javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade, org.apache.nifi.web.api.entity.Entity, java.util.Set, org.apache.nifi.authorization.AuthorizeAccess, java.lang.Runnable, java.util.function.BiFunction) { org.apache.nifi.web.api.ApplicationResource$Request v; java.lang.IllegalStateException v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.util.function.BiFunction v; java.lang.Runnable v; org.apache.nifi.authorization.AuthorizeAccess v; javax.servlet.http.HttpServletRequest v, v, v, v; org.apache.nifi.authorization.user.NiFiUser v; boolean v, v, v, v; org.apache.nifi.web.NiFiServiceFacade v; java.util.Set v, v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v, v; java.lang.Object v, v; org.apache.nifi.web.api.entity.Entity v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: org.apache.nifi.web.NiFiServiceFacade; v := @parameter: org.apache.nifi.web.api.entity.Entity; v := @parameter: java.util.Set; v := @parameter: org.apache.nifi.authorization.AuthorizeAccess; v := @parameter: java.lang.Runnable; v := @parameter: java.util.function.BiFunction; v = staticinvoke (); v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; interfaceinvoke v.(v); interfaceinvoke v.(v, v); if v == null goto label; interfaceinvoke v.(); label: specialinvoke v.(v, null, v); v = virtualinvoke v.(); v = virtualinvoke v.(); return v; label: v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v); return v; label: v = v.; v = virtualinvoke v.(v); if v == 0 goto label; specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); return v; label: v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("This request does not appear to be part of the two phase commit."); throw v; label: interfaceinvoke v.(v); interfaceinvoke v.(v, v); if v == null goto label; interfaceinvoke v.(); label: v = interfaceinvoke v.(v, v); return v; } protected javax.ws.rs.core.Response withWriteLock(org.apache.nifi.web.NiFiServiceFacade, org.apache.nifi.web.api.entity.Entity, org.apache.nifi.authorization.AuthorizeAccess, java.lang.Runnable, java.util.function.Function) { org.apache.nifi.web.api.ApplicationResource$Request v; java.lang.IllegalStateException v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; java.lang.Runnable v; java.util.function.Function v; org.apache.nifi.authorization.AuthorizeAccess v; javax.servlet.http.HttpServletRequest v, v, v, v; boolean v, v, v, v; org.apache.nifi.web.NiFiServiceFacade v; javax.ws.rs.core.Response v, v; javax.ws.rs.core.Response$ResponseBuilder v, v; java.lang.Object v, v; org.apache.nifi.web.api.entity.Entity v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: org.apache.nifi.web.NiFiServiceFacade; v := @parameter: org.apache.nifi.web.api.entity.Entity; v := @parameter: org.apache.nifi.authorization.AuthorizeAccess; v := @parameter: java.lang.Runnable; v := @parameter: java.util.function.Function; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; interfaceinvoke v.(v); if v == null goto label; interfaceinvoke v.(); label: specialinvoke v.(v, null, null); v = virtualinvoke v.(); v = virtualinvoke v.(); return v; label: v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = specialinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); return v; label: v = v.; v = virtualinvoke v.(v); if v == 0 goto label; specialinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); return v; label: v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("This request does not appear to be part of the two phase commit."); throw v; label: interfaceinvoke v.(v); if v == null goto label; interfaceinvoke v.(); label: v = interfaceinvoke v.(v); return v; } private void phaseOneStoreTransaction(org.apache.nifi.web.api.entity.Entity, org.apache.nifi.web.Revision, java.util.Set) { java.lang.Throwable v; org.apache.nifi.web.api.ApplicationResource$Request v; java.lang.IllegalStateException v, v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; org.apache.nifi.web.Revision v; long v; com.github.benmanes.caffeine.cache.Cache v, v, v, v; javax.servlet.http.HttpServletRequest v; byte v; org.apache.nifi.authorization.user.NiFiUser v; java.lang.String v, v, v, v; java.net.URI v; org.apache.nifi.web.security.util.CacheKey v; boolean v; java.util.Set v; java.lang.IllegalArgumentException v; java.lang.Object v; org.apache.nifi.web.api.entity.Entity v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: org.apache.nifi.web.api.entity.Entity; v := @parameter: org.apache.nifi.web.Revision; v := @parameter: java.util.Set; v = v.; v = interfaceinvoke v.(); v = v cmp 500L; if v <= 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("The maximum number of requests are in progress."); throw v; label: v = v.; v = interfaceinvoke v.("X-RequestTransactionId"); v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Two phase commit Transaction Id missing."); throw v; label: v = v.; entermonitor v; label: v = new org.apache.nifi.web.security.util.CacheKey; specialinvoke v.(java.lang.String)>(v); v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = new java.lang.IllegalStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Transaction \u is already in progress."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = staticinvoke (); v = new org.apache.nifi.web.api.ApplicationResource$Request; v = staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String,org.apache.nifi.web.Revision,java.util.Set,org.apache.nifi.web.api.entity.Entity)>(v, v, v, v, v); v = v.; interfaceinvoke v.(v, v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } private org.apache.nifi.web.api.ApplicationResource$Request phaseTwoVerifyTransaction() { java.lang.Throwable v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; com.github.benmanes.caffeine.cache.Cache v, v, v; javax.servlet.http.HttpServletRequest v; org.apache.nifi.authorization.user.NiFiUser v; java.lang.String v, v, v, v, v; java.net.URI v; org.apache.nifi.web.security.util.CacheKey v; boolean v, v, v; java.lang.IllegalArgumentException v, v, v, v; java.lang.Object v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = v.; v = interfaceinvoke v.("X-RequestTransactionId"); v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Two phase commit Transaction Id missing."); throw v; label: v = v.; entermonitor v; label: v = new org.apache.nifi.web.security.util.CacheKey; specialinvoke v.(java.lang.String)>(v); v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("The request from phase one is missing."); throw v; label: v = v.; interfaceinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = virtualinvoke v.(); v = staticinvoke (); v = staticinvoke (v); if v == null goto label; v = virtualinvoke v.(v); if v != 0 goto label; label: v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("The same user must issue the request for phase one and two."); throw v; label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; label: v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("The URI must be the same for phase one and two."); throw v; label: return v; catch java.lang.Throwable from label to label with label; } private void cancelTransaction() { java.lang.Throwable v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; com.github.benmanes.caffeine.cache.Cache v, v; java.lang.IllegalArgumentException v; javax.servlet.http.HttpServletRequest v; java.lang.String v; org.apache.nifi.web.security.util.CacheKey v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = v.; v = interfaceinvoke v.("X-RequestTransactionId"); v = staticinvoke (v); if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Two phase commit Transaction Id missing."); throw v; label: v = v.; entermonitor v; label: v = new org.apache.nifi.web.security.util.CacheKey; specialinvoke v.(java.lang.String)>(v); v = v.; interfaceinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } protected javax.ws.rs.core.Response replicate(java.lang.String, java.lang.String) { javax.ws.rs.core.MultivaluedMap v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; javax.ws.rs.core.Response v; java.lang.String v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v); return v; } private void ensureFlowInitialized() { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; org.apache.nifi.cluster.manager.exception.IllegalClusterStateException v; org.apache.nifi.controller.FlowController v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = new org.apache.nifi.cluster.manager.exception.IllegalClusterStateException; specialinvoke v.(java.lang.String)>("The Flow Controller is initializing the Data Flow."); throw v; label: return; } protected javax.ws.rs.core.Response replicate(java.lang.String, java.lang.Object, java.lang.String, java.util.Map) { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; javax.ws.rs.core.Response v; java.util.Map v; java.lang.Object v; java.lang.String v, v; java.net.URI v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: java.lang.String; v := @parameter: java.lang.Object; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v, v, v); return v; } protected javax.ws.rs.core.Response replicate(java.lang.String, java.lang.Object, java.lang.String) { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; javax.ws.rs.core.Response v; java.lang.Object v; java.lang.String v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: java.lang.String; v := @parameter: java.lang.Object; v := @parameter: java.lang.String; v = virtualinvoke v.(v, v, v, null); return v; } protected javax.ws.rs.core.Response replicate(java.net.URI, java.lang.String, java.lang.Object, java.lang.String, java.util.Map) { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; org.apache.nifi.cluster.protocol.NodeIdentifier v, v; java.util.Map v, v; javax.ws.rs.core.Response$Status v; java.net.URI v, v; org.apache.nifi.cluster.coordination.http.replication.RequestReplicator v, v; org.apache.nifi.cluster.manager.NodeResponse v, v; java.util.Set v; org.apache.nifi.cluster.coordination.http.replication.AsyncClusterResponse v, v; javax.ws.rs.core.Response v, v, v; javax.ws.rs.core.Response$ResponseBuilder v, v, v; org.apache.nifi.web.api.ApplicationResource$ReplicationTarget v, v; org.apache.nifi.cluster.coordination.ClusterCoordinator v; java.lang.String v, v, v, v, v; java.lang.IllegalArgumentException v; java.lang.InterruptedException v; java.lang.Object v; org.apache.nifi.cluster.manager.exception.UnknownNodeException v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: java.net.URI; v := @parameter: java.lang.String; v := @parameter: java.lang.Object; v := @parameter: java.lang.String; v := @parameter: java.util.Map; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("The cluster node identifier must be specified."); throw v; label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = new org.apache.nifi.cluster.manager.exception.UnknownNodeException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Cannot replicate request \u \u to node with ID \u because the specified node does not exist."); specialinvoke v.(java.lang.String)>(v); throw v; label: specialinvoke v.(); label: if v != null goto label; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(v); label: v = virtualinvoke v.(); v = ; if v != v goto label; v = staticinvoke (v); v = v.; v = interfaceinvoke v.(v, v, v, v, v, 1, 1); v = interfaceinvoke v.(); v = virtualinvoke v.(); label: return v; label: v = virtualinvoke v.(); interfaceinvoke v.("X-Replication-Target-Id", v); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v, v, v); v = interfaceinvoke v.(); v = virtualinvoke v.(); label: return v; label: v := @caughtexception; v = ; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Request to \u \u was interrupted"); v = virtualinvoke v.(v); v = virtualinvoke v.("text/plain"); v = virtualinvoke v.(); return v; catch java.lang.InterruptedException from label to label with label; catch java.lang.InterruptedException from label to label with label; } protected org.apache.nifi.cluster.protocol.NodeIdentifier getClusterCoordinatorNode() { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; org.apache.nifi.cluster.exception.NoClusterCoordinatorException v; org.apache.nifi.cluster.protocol.NodeIdentifier v; org.apache.nifi.cluster.coordination.ClusterCoordinator v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = v.; v = interfaceinvoke v.(); if v == null goto label; return v; label: v = new org.apache.nifi.cluster.exception.NoClusterCoordinatorException; specialinvoke v.()>(); throw v; } protected java.util.Optional getPrimaryNodeId() { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; org.apache.nifi.cluster.exception.NoClusterCoordinatorException v; org.apache.nifi.cluster.protocol.NodeIdentifier v; org.apache.nifi.cluster.coordination.ClusterCoordinator v; java.util.Optional v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = virtualinvoke v.(); if v != null goto label; v = new org.apache.nifi.cluster.exception.NoClusterCoordinatorException; specialinvoke v.()>(); throw v; label: v = interfaceinvoke v.(); v = staticinvoke (v); return v; } protected org.apache.nifi.web.api.ApplicationResource$ReplicationTarget getReplicationTarget() { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; org.apache.nifi.cluster.coordination.ClusterCoordinator v; org.apache.nifi.web.api.ApplicationResource$ReplicationTarget v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = ; goto label; label: v = ; label: return v; } protected javax.ws.rs.core.Response replicate(java.lang.String, org.apache.nifi.cluster.protocol.NodeIdentifier) { javax.ws.rs.core.MultivaluedMap v; WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; org.apache.nifi.cluster.protocol.NodeIdentifier v; javax.ws.rs.core.Response v; java.lang.String v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.cluster.protocol.NodeIdentifier; v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v); return v; } protected javax.ws.rs.core.Response replicate(java.lang.String, org.apache.nifi.cluster.protocol.NodeIdentifier, java.lang.Object) { WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource v; org.apache.nifi.cluster.protocol.NodeIdentifier v, v; org.apache.nifi.web.api.ApplicationResource$ReplicationTarget v, v; java.util.Map v, v, v; javax.ws.rs.core.Response$Status v; java.lang.String v, v, v; java.net.URI v, v, v; org.apache.nifi.cluster.coordination.http.replication.RequestReplicator v, v; org.apache.nifi.cluster.manager.NodeResponse v, v; java.util.Set v; org.apache.nifi.cluster.coordination.http.replication.AsyncClusterResponse v, v; javax.ws.rs.core.Response v, v, v; java.lang.InterruptedException v; javax.ws.rs.core.Response$ResponseBuilder v, v, v; java.lang.Object v; v := @this: WEB-INF.classes.org.apache.nifi.web.api.ApplicationResource; v := @parameter: java.lang.String; v := @parameter: org.apache.nifi.cluster.protocol.NodeIdentifier; v := @parameter: java.lang.Object; specialinvoke v.(); label: v = virtualinvoke v.(); v = ; if v != v goto label; v = staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v, v, v, 1, 1); v = interfaceinvoke v.(); v = virtualinvoke v.(); label: return v; label: v = virtualinvoke v.(); v = staticinvoke ("X-Replication-Target-Id", v); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v, v, v); v = interfaceinvoke v.(); v = virtualinvoke v.(); label: return v; label: v := @caughtexception; v = ; v = staticinvoke (v); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Request to \u \u was interrupted"); v = virtualinvoke v.(v); v = virtualinvoke v.("text/plain"); v = virtualinvoke v.