public class WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle extends java.lang.Object implements org.apache.nifi.web.util.ComponentLifecycle { private static final org.slf4j.Logger logger; private org.apache.nifi.cluster.coordination.ClusterCoordinator clusterCoordinator; private org.apache.nifi.cluster.coordination.http.replication.RequestReplicator requestReplicator; private org.apache.nifi.web.NiFiServiceFacade serviceFacade; private org.apache.nifi.web.api.dto.DtoFactory dtoFactory; public void () { WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle v; v := @this: WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle; specialinvoke v.()>(); return; } public java.util.Set scheduleComponents(java.net.URI, java.lang.String, java.util.Set, org.apache.nifi.controller.ScheduledState, org.apache.nifi.web.util.Pause, org.apache.nifi.web.util.InvalidComponentAction) throws org.apache.nifi.web.util.LifecycleManagementException { java.lang.Thread v, v; java.util.Map v; javax.ws.rs.core.Response$Status v; java.util.stream.Collector v, v, v, v; org.apache.nifi.web.util.LifecycleManagementException v, v, v, v; java.util.Set v, v, v; java.util.stream.Stream v, v, v, v, v, v; org.apache.nifi.controller.ScheduledState v, v; org.apache.nifi.web.util.InvalidComponentAction v; org.apache.nifi.authorization.user.NiFiUser v; java.lang.String v, v, v, v, v, v, v, v, v, v; java.lang.RuntimeException v; org.apache.nifi.web.api.entity.ScheduleComponentsEntity v; org.apache.nifi.cluster.protocol.NodeIdentifier v; java.net.URISyntaxException v; java.net.URI v, v; org.apache.nifi.cluster.coordination.http.replication.RequestReplicator v, v; org.apache.nifi.cluster.manager.NodeResponse v; boolean v, v; org.apache.nifi.cluster.coordination.http.replication.AsyncClusterResponse v, v; org.apache.nifi.web.util.Pause v; WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle v; java.util.HashMap v; org.apache.nifi.web.api.ApplicationResource$ReplicationTarget v, v; java.util.function.Function v, v, v, v, v, v; int v, v, v; org.slf4j.Logger v; java.lang.InterruptedException v, v; java.lang.Object v, v, v, v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle; v := @parameter: java.net.URI; v := @parameter: java.lang.String; v := @parameter: java.util.Set; v := @parameter: org.apache.nifi.controller.ScheduledState; v := @parameter: org.apache.nifi.web.util.Pause; v := @parameter: org.apache.nifi.web.util.InvalidComponentAction; v = interfaceinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("No components to schedule for group {} so will not issue request", v); v = staticinvoke (); return v; label: v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = staticinvoke (); v = staticinvoke (v, v); v = interfaceinvoke v.(v); v = specialinvoke v.(v, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = staticinvoke (v); v = staticinvoke (v, v); v = interfaceinvoke v.(v); v = new org.apache.nifi.web.api.entity.ScheduleComponentsEntity; specialinvoke v.()>(); virtualinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); label: v = new java.net.URI; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("/nifi-api/flow/process-groups/\u0001"); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String,java.lang.String,int,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v, null, v); label: goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("content-type", "application/json"); v = staticinvoke (); v = ; if v != v goto label; label: specialinvoke v.(v, v, v, v, v); label: goto label; label: v := @caughtexception; v = staticinvoke (); virtualinvoke v.(); v = new org.apache.nifi.web.util.LifecycleManagementException; specialinvoke v.(java.lang.String)>("Interrupted while waiting for processors to complete validation"); throw v; label: v = specialinvoke v.(); v = ; if v != v goto label; v = specialinvoke v.(); v = interfaceinvoke v.(v, "PUT", v, v, v); v = interfaceinvoke v.(); goto label; label: v = specialinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, "PUT", v, v, v); v = interfaceinvoke v.(); label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); if v == v goto label; v = specialinvoke v.(v, class "Ljava/lang/String;"); v = new org.apache.nifi.web.util.LifecycleManagementException; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Failed to transition components to a state of \u due to \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = specialinvoke v.(v, v, v, v, v, v, v); if v != 0 goto label; v = new org.apache.nifi.web.util.LifecycleManagementException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed while waiting for components to transition to state of \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v := @caughtexception; v = staticinvoke (); virtualinvoke v.(); v = new org.apache.nifi.web.util.LifecycleManagementException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Interrupted while attempting to transition components to state of \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; catch java.net.URISyntaxException from label to label with label; catch java.lang.InterruptedException from label to label with label; catch java.lang.InterruptedException from label to label with label; } private org.apache.nifi.web.api.ApplicationResource$ReplicationTarget getReplicationTarget() { WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle 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.util.ClusterReplicationComponentLifecycle; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = ; goto label; label: v = ; label: return v; } private org.apache.nifi.cluster.coordination.http.replication.RequestReplicator getRequestReplicator() { WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle v; org.apache.nifi.cluster.coordination.http.replication.RequestReplicator v; v := @this: WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle; v = v.; return v; } protected org.apache.nifi.cluster.protocol.NodeIdentifier getClusterCoordinatorNode() { WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle 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.util.ClusterReplicationComponentLifecycle; 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; } private java.util.Map getRevisions(java.lang.String, java.util.Set) { WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle v; org.apache.nifi.web.NiFiServiceFacade v; java.util.Set v, v; java.util.function.Function v, v, v; java.util.stream.Stream v; java.lang.Object v; java.lang.String v; java.util.stream.Collector v; v := @this: WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle; v := @parameter: java.lang.String; v := @parameter: java.util.Set; v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v, v); v = interfaceinvoke v.(); v = staticinvoke (); v = staticinvoke (); v = staticinvoke (v, v); v = interfaceinvoke v.(v); return v; } private boolean waitForProcessorValidation(org.apache.nifi.authorization.user.NiFiUser, java.net.URI, java.lang.String, java.util.Map, org.apache.nifi.web.util.Pause) throws java.lang.InterruptedException { org.apache.nifi.cluster.protocol.NodeIdentifier v; java.net.URISyntaxException v; org.apache.nifi.web.api.entity.RunStatusDetailsRequestEntity v; java.lang.Integer v; java.util.Map v; javax.ws.rs.core.Response$Status v; java.net.URI v, v; java.util.stream.Collector v; org.apache.nifi.cluster.coordination.http.replication.RequestReplicator v, v; org.apache.nifi.cluster.manager.NodeResponse v; boolean v, v, v; java.util.Collection v; org.apache.nifi.cluster.coordination.http.replication.AsyncClusterResponse v, v; java.util.stream.Stream v, v; org.apache.nifi.web.util.Pause v; WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle v; java.util.HashMap v; org.apache.nifi.web.api.ApplicationResource$ReplicationTarget v, v; java.util.function.Function v; org.apache.nifi.authorization.user.NiFiUser v; int v, v, v, v; java.lang.String v, v, v, v, v; org.slf4j.Logger v, v; java.lang.RuntimeException v; java.lang.Object v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle; v := @parameter: org.apache.nifi.authorization.user.NiFiUser; v := @parameter: java.net.URI; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v := @parameter: org.apache.nifi.web.util.Pause; v = interfaceinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("No processors to wait for so will not wait for Processor Validation"); return 1; label: v = new java.net.URI; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String,java.lang.String,int,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, "/nifi-api/processors/run-status-details/queries", null, v); label: goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = new java.util.HashMap; specialinvoke v.()>(); v = new org.apache.nifi.web.api.entity.RunStatusDetailsRequestEntity; specialinvoke v.()>(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); virtualinvoke v.(v); v = 1; label: if v == 0 goto label; v = specialinvoke v.(); v = ; if v != v goto label; v = specialinvoke v.(); v = interfaceinvoke v.(v, "POST", v, v, v); v = interfaceinvoke v.(); goto label; label: v = specialinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, "POST", v, v, v); v = interfaceinvoke v.(); label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); if v == v goto label; return 0; label: v = specialinvoke v.(v, class "Lorg/apache/nifi/web/api/entity/ProcessorsRunStatusDetailsEntity;"); v = specialinvoke v.(v, v); if v == 0 goto label; v = ; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("All {} processors of interest now have been validated: {}", v, v); return 1; label: v = interfaceinvoke v.(); goto label; label: return 0; catch java.net.URISyntaxException from label to label with label; } private boolean isProcessorValidationComplete(org.apache.nifi.web.api.entity.ProcessorsRunStatusDetailsEntity, java.util.Map) { WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle v; org.apache.nifi.web.api.dto.ProcessorRunStatusDetailsDTO v; java.util.Map v; java.lang.String v, v, v, v, v; org.apache.nifi.web.api.entity.ProcessorsRunStatusDetailsEntity v; boolean v, v, v; org.slf4j.Logger v; java.util.Iterator v; java.util.List v, v; java.lang.Object v; v := @this: WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle; v := @parameter: org.apache.nifi.web.api.entity.ProcessorsRunStatusDetailsEntity; v := @parameter: java.util.Map; v = virtualinvoke v.(); specialinvoke v.(v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("Processor {} now has Run Status of {}", v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == 0 goto label; v = "Validating"; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; return 0; label: return 1; } private boolean waitForProcessorStatus(org.apache.nifi.authorization.user.NiFiUser, java.net.URI, java.lang.String, java.util.Map, org.apache.nifi.controller.ScheduledState, org.apache.nifi.web.util.Pause, org.apache.nifi.web.util.InvalidComponentAction) throws java.lang.InterruptedException, org.apache.nifi.web.util.LifecycleManagementException { org.apache.nifi.cluster.protocol.NodeIdentifier v; java.net.URISyntaxException v; org.apache.nifi.web.api.entity.RunStatusDetailsRequestEntity v; java.lang.Integer v; java.util.Map v; javax.ws.rs.core.Response$Status v; java.net.URI v, v; java.util.stream.Collector v; org.apache.nifi.cluster.coordination.http.replication.RequestReplicator v, v; org.apache.nifi.cluster.manager.NodeResponse v; boolean v, v, v; java.util.Collection v; org.apache.nifi.cluster.coordination.http.replication.AsyncClusterResponse v, v; java.util.stream.Stream v, v; org.apache.nifi.controller.ScheduledState v; org.apache.nifi.web.util.InvalidComponentAction v; org.apache.nifi.web.util.Pause v; WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle v; java.util.HashMap v; org.apache.nifi.web.api.ApplicationResource$ReplicationTarget v, v; java.util.function.Function v; org.apache.nifi.authorization.user.NiFiUser v; int v, v, v, v; java.lang.String v, v, v, v, v; org.slf4j.Logger v, v; java.lang.RuntimeException v; java.lang.Object v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle; v := @parameter: org.apache.nifi.authorization.user.NiFiUser; v := @parameter: java.net.URI; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v := @parameter: org.apache.nifi.controller.ScheduledState; v := @parameter: org.apache.nifi.web.util.Pause; v := @parameter: org.apache.nifi.web.util.InvalidComponentAction; v = interfaceinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("No processors to wait for, so will not wait for processors to reach state of {}", v); return 1; label: v = new java.net.URI; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String,java.lang.String,int,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, "/nifi-api/processors/run-status-details/queries", null, v); label: goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = new java.util.HashMap; specialinvoke v.()>(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = new org.apache.nifi.web.api.entity.RunStatusDetailsRequestEntity; specialinvoke v.()>(); virtualinvoke v.(v); v = 1; label: if v == 0 goto label; v = specialinvoke v.(); v = ; if v != v goto label; v = specialinvoke v.(); v = interfaceinvoke v.(v, "POST", v, v, v); v = interfaceinvoke v.(); goto label; label: v = specialinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, "POST", v, v, v); v = interfaceinvoke v.(); label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); if v == v goto label; return 0; label: v = specialinvoke v.(v, class "Lorg/apache/nifi/web/api/entity/ProcessorsRunStatusDetailsEntity;"); v = specialinvoke v.(v, v, v, v); if v == 0 goto label; v = ; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("All {} processors of interest now have the desired state of {}", v, v); return 1; label: v = interfaceinvoke v.(); goto label; label: return 0; catch java.net.URISyntaxException from label to label with label; } private java.lang.Object getResponseEntity(org.apache.nifi.cluster.manager.NodeResponse, java.lang.Class) { WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle v; javax.ws.rs.core.Response v; java.lang.Class v; java.lang.Object v; org.apache.nifi.cluster.manager.NodeResponse v; v := @this: WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle; v := @parameter: org.apache.nifi.cluster.manager.NodeResponse; v := @parameter: java.lang.Class; v = virtualinvoke v.(); if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); label: return v; } private void updateAffectedProcessors(java.util.Collection, java.util.Map) { WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle v; java.util.function.Consumer v; java.util.stream.Stream v, v; java.util.function.Predicate v; java.util.Collection v; java.util.Map v; v := @this: WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle; v := @parameter: java.util.Collection; v := @parameter: java.util.Map; v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (v); interfaceinvoke v.(v); return; } private boolean isProcessorActionComplete(org.apache.nifi.web.api.entity.ProcessorsRunStatusDetailsEntity, java.util.Map, org.apache.nifi.controller.ScheduledState, org.apache.nifi.web.util.InvalidComponentAction) throws org.apache.nifi.web.util.LifecycleManagementException { org.apache.nifi.web.api.dto.ProcessorRunStatusDetailsDTO v; java.lang.Integer v, v; int[] v; java.util.Map v; org.apache.nifi.web.api.entity.ProcessorsRunStatusDetailsEntity v; boolean v, v, v, v, v; org.apache.nifi.web.util.LifecycleManagementException v; java.util.Set v; java.util.List v, v, v; org.apache.nifi.controller.ScheduledState v, v, v; org.apache.nifi.web.util.InvalidComponentAction v; WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle v; java.lang.Object[] v; int v, v, v, v, v; java.lang.Boolean v; java.lang.String v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v; java.util.Iterator v; java.lang.Object v; v := @this: WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle; v := @parameter: org.apache.nifi.web.api.entity.ProcessorsRunStatusDetailsEntity; v := @parameter: java.util.Map; v := @parameter: org.apache.nifi.controller.ScheduledState; v := @parameter: org.apache.nifi.web.util.InvalidComponentAction; v = virtualinvoke v.(); specialinvoke v.(v, v); v = 1; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == 0 goto label; v = specialinvoke v.(v, v); v = ; v = newarray (java.lang.Object)[8]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[3] = v; v = virtualinvoke v.(); v[4] = v; v[5] = v; v[6] = v; v = staticinvoke (v); v[7] = v; interfaceinvoke v.("Processor[id={}, name={}] now has a state of {} with {} Active Threads, Validation Errors: {}; desired state = {}; invalid component action: {}; desired state reached = {}", v); if v != 0 goto label; v = ; if v != v goto label; v = virtualinvoke v.(); if v == 0 goto label; return 0; label: v = "Invalid"; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; default: goto label; }; label: v = ; if v != v goto label; v = "start"; goto label; label: v = "stop"; label: v = new org.apache.nifi.web.util.LifecycleManagementException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Could not \u \u because it is invalid"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = 0; goto label; label: if v == 0 goto label; v = ; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("All {} Processors of interest now have the desired state of {}", v, v); return 1; label: return 0; } private boolean isDesiredProcessorStateReached(org.apache.nifi.web.api.dto.ProcessorRunStatusDetailsDTO, org.apache.nifi.controller.ScheduledState) { WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle v; org.apache.nifi.web.api.dto.ProcessorRunStatusDetailsDTO v; org.apache.nifi.controller.ScheduledState v, v; int v; java.lang.String v, v; boolean v; v := @this: WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle; v := @parameter: org.apache.nifi.web.api.dto.ProcessorRunStatusDetailsDTO; v := @parameter: org.apache.nifi.controller.ScheduledState; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; return 0; label: v = ; if v != v goto label; v = virtualinvoke v.(); if v == 0 goto label; return 0; label: return 1; } public java.util.Set activateControllerServices(java.net.URI, java.lang.String, java.util.Set, java.util.Set, org.apache.nifi.controller.service.ControllerServiceState, org.apache.nifi.web.util.Pause, org.apache.nifi.web.util.InvalidComponentAction) throws org.apache.nifi.web.util.LifecycleManagementException { java.lang.Thread v, v; java.util.Map v; javax.ws.rs.core.Response$Status v; java.util.stream.Collector v, v, v, v; org.apache.nifi.web.util.LifecycleManagementException v, v, v, v; java.util.Set v, v, v, v; java.util.stream.Stream v, v, v, v, v, v, v, v; org.apache.nifi.web.api.dto.DtoFactory v; org.apache.nifi.web.util.InvalidComponentAction v; org.apache.nifi.authorization.user.NiFiUser v; java.lang.String v, v, v, v, v, v, v, v, v, v; java.lang.RuntimeException v; org.apache.nifi.cluster.protocol.NodeIdentifier v; java.net.URISyntaxException v; org.apache.nifi.web.api.entity.ActivateControllerServicesEntity v; java.net.URI v, v; org.apache.nifi.cluster.coordination.http.replication.RequestReplicator v, v; org.apache.nifi.cluster.manager.NodeResponse v; boolean v, v, v; org.apache.nifi.cluster.coordination.http.replication.AsyncClusterResponse v, v; org.apache.nifi.controller.service.ControllerServiceState v, v; org.apache.nifi.web.util.Pause v; WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle v; java.util.HashMap v; org.apache.nifi.web.api.ApplicationResource$ReplicationTarget v, v; java.util.function.Function v, v, v, v, v, v; int v, v, v; org.slf4j.Logger v; java.lang.InterruptedException v, v; java.lang.Object v, v, v, v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle; v := @parameter: java.net.URI; v := @parameter: java.lang.String; v := @parameter: java.util.Set; v := @parameter: java.util.Set; v := @parameter: org.apache.nifi.controller.service.ControllerServiceState; v := @parameter: org.apache.nifi.web.util.Pause; v := @parameter: org.apache.nifi.web.util.InvalidComponentAction; v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("No Controller Services to activate for group {} so will not issue request", v); v = staticinvoke (); return v; label: v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = specialinvoke v.(v, v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = staticinvoke (v); v = staticinvoke (v, v); v = interfaceinvoke v.(v); v = new org.apache.nifi.web.api.entity.ActivateControllerServicesEntity; specialinvoke v.()>(); virtualinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); label: v = new java.net.URI; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("/nifi-api/flow/process-groups/\u0001/controller-services"); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String,java.lang.String,int,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v, null, v); label: goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("content-type", "application/json"); v = staticinvoke (); v = ; if v != v goto label; label: specialinvoke v.(v, v, v, v, v); label: goto label; label: v := @caughtexception; v = staticinvoke (); virtualinvoke v.(); v = new org.apache.nifi.web.util.LifecycleManagementException; specialinvoke v.(java.lang.String)>("Interrupted while waiting for Controller Services to complete validation"); throw v; label: v = specialinvoke v.(); v = ; if v != v goto label; v = specialinvoke v.(); v = interfaceinvoke v.(v, "PUT", v, v, v); v = interfaceinvoke v.(); goto label; label: v = specialinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, "PUT", v, v, v); v = interfaceinvoke v.(); label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); if v == v goto label; v = specialinvoke v.(v, class "Ljava/lang/String;"); v = new org.apache.nifi.web.util.LifecycleManagementException; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Failed to update Controller Services to a state of \u due to \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = specialinvoke v.(v, v, v, v, v, v, v); if v != 0 goto label; v = new org.apache.nifi.web.util.LifecycleManagementException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed while waiting for Controller Services to finish transitioning to a state of \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v := @caughtexception; v = staticinvoke (); virtualinvoke v.(); v = new org.apache.nifi.web.util.LifecycleManagementException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Interrupted while transitioning Controller Services to a state of \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); return v; catch java.net.URISyntaxException from label to label with label; catch java.lang.InterruptedException from label to label with label; catch java.lang.InterruptedException from label to label with label; } private boolean waitForControllerServiceValidation(org.apache.nifi.authorization.user.NiFiUser, java.net.URI, java.lang.String, java.util.Set, org.apache.nifi.web.util.Pause) throws java.lang.InterruptedException { org.apache.nifi.cluster.protocol.NodeIdentifier v; java.net.URISyntaxException v; java.lang.Integer v; javax.ws.rs.core.Response$Status v; java.net.URI v, v; java.util.stream.Collector v; org.apache.nifi.cluster.coordination.http.replication.RequestReplicator v, v; org.apache.nifi.cluster.manager.NodeResponse v; boolean v, v; java.util.function.Predicate v; java.util.Set v, v; org.apache.nifi.cluster.coordination.http.replication.AsyncClusterResponse v, v; java.util.stream.Stream v, v; org.apache.nifi.web.api.dto.DtoFactory v; org.apache.nifi.web.util.Pause v; WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle v; java.util.HashMap v; org.apache.nifi.web.api.ApplicationResource$ReplicationTarget v, v; java.util.function.Function v, v; org.apache.nifi.authorization.user.NiFiUser v; int v, v, v, v; java.lang.String v, v, v, v, v, v; org.slf4j.Logger v; java.lang.RuntimeException v; javax.ws.rs.core.MultivaluedHashMap v; java.lang.Object v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle; v := @parameter: org.apache.nifi.authorization.user.NiFiUser; v := @parameter: java.net.URI; v := @parameter: java.lang.String; v := @parameter: java.util.Set; v := @parameter: org.apache.nifi.web.util.Pause; label: v = new java.net.URI; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("/nifi-api/flow/process-groups/\u0001/controller-services"); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String,java.lang.String,int,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v, "includeAncestorGroups=false&includeDescendantGroups=true&includeReferencingComponents=false", v); label: goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = new java.util.HashMap; specialinvoke v.()>(); v = new javax.ws.rs.core.MultivaluedHashMap; specialinvoke v.()>(); v = 1; label: if v == 0 goto label; v = specialinvoke v.(); v = ; if v != v goto label; v = specialinvoke v.(); v = interfaceinvoke v.(v, "GET", v, v, v); v = interfaceinvoke v.(); goto label; label: v = specialinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, "GET", v, v, v); v = interfaceinvoke v.(); label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); if v == v goto label; return 0; label: v = specialinvoke v.(v, class "Lorg/apache/nifi/web/api/entity/ControllerServicesEntity;"); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = staticinvoke (); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v, v); v = interfaceinvoke v.(v); v = specialinvoke v.(v, v); if v == 0 goto label; v = ; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("All {} controller services of interest have completed validation", v); return 1; label: v = interfaceinvoke v.(); goto label; label: return 0; catch java.net.URISyntaxException from label to label with label; } private boolean isControllerServiceValidationComplete(java.util.Set, java.util.Map) { WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle v; java.util.Iterator v; org.apache.nifi.web.api.dto.ControllerServiceDTO v; java.util.Set v; java.util.Map v; java.lang.Object v; java.lang.String v, v, v; boolean v, v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle; v := @parameter: java.util.Set; v := @parameter: java.util.Map; specialinvoke v.(v, v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == 0 goto label; v = "VALIDATING"; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; return 0; label: return 1; } private boolean waitForControllerServiceStatus(org.apache.nifi.authorization.user.NiFiUser, java.net.URI, java.lang.String, java.util.Set, org.apache.nifi.controller.service.ControllerServiceState, org.apache.nifi.web.util.Pause, org.apache.nifi.web.util.InvalidComponentAction) throws java.lang.InterruptedException, org.apache.nifi.web.util.LifecycleManagementException { java.lang.Integer v; javax.ws.rs.core.Response$Status v; java.util.stream.Collector v; org.apache.nifi.web.util.LifecycleManagementException v; java.util.Set v, v; java.util.stream.Stream v; org.apache.nifi.web.api.dto.DtoFactory v; org.apache.nifi.web.util.InvalidComponentAction v; java.lang.Object[] v; org.apache.nifi.authorization.user.NiFiUser v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.RuntimeException v; org.apache.nifi.cluster.protocol.NodeIdentifier v; java.net.URISyntaxException v; int[] v; java.net.URI v, v; org.apache.nifi.cluster.coordination.http.replication.RequestReplicator v, v; org.apache.nifi.cluster.manager.NodeResponse v; boolean v, v, v, v, v, v, v; org.apache.nifi.web.api.dto.ControllerServiceDTO v, v; org.apache.nifi.cluster.coordination.http.replication.AsyncClusterResponse v, v; org.apache.nifi.controller.service.ControllerServiceState v, v; org.apache.nifi.web.util.Pause v; WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle v; java.util.HashMap v; org.apache.nifi.web.api.ApplicationResource$ReplicationTarget v, v; java.util.function.Function v, v; int v, v, v, v, v, v; java.lang.Boolean v; org.slf4j.Logger v, v; java.util.Iterator v; javax.ws.rs.core.MultivaluedHashMap v; java.lang.Object v, v, v; v := @this: WEB-INF.classes.org.apache.nifi.web.util.ClusterReplicationComponentLifecycle; v := @parameter: org.apache.nifi.authorization.user.NiFiUser; v := @parameter: java.net.URI; v := @parameter: java.lang.String; v := @parameter: java.util.Set; v := @parameter: org.apache.nifi.controller.service.ControllerServiceState; v := @parameter: org.apache.nifi.web.util.Pause; v := @parameter: org.apache.nifi.web.util.InvalidComponentAction; v = interfaceinvoke v.(); if v == 0 goto label; return 1; label: v = new java.net.URI; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("/nifi-api/flow/process-groups/\u0001/controller-services"); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String,java.lang.String,int,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v, v, "includeAncestorGroups=false&includeDescendantGroups=true&includeReferencingComponents=false", v); label: goto label; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = new java.util.HashMap; specialinvoke v.()>(); v = new javax.ws.rs.core.MultivaluedHashMap; specialinvoke v.()>(); v = 1; label: if v == 0 goto label; v = specialinvoke v.(); v = ; if v != v goto label; v = specialinvoke v.(); v = interfaceinvoke v.(v, "GET", v, v, v); v = interfaceinvoke v.(); goto label; label: v = specialinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, "GET", v, v, v); v = interfaceinvoke v.(); label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); if v == v goto label; return 0; label: v = specialinvoke v.(v, class "Lorg/apache/nifi/web/api/entity/ControllerServicesEntity;"); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = v.; virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v, v); v = interfaceinvoke v.(v); specialinvoke v.(v, v); v = virtualinvoke v.(); v = 1; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.