public class org.apache.helix.rest.server.resources.helix.ClusterAccessor extends org.apache.helix.rest.server.resources.helix.AbstractHelixResource { private static org.slf4j.Logger LOG; public void () { org.apache.helix.rest.server.resources.helix.ClusterAccessor v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; specialinvoke v.()>(); return; } public javax.ws.rs.core.Response getClusters() { java.util.List v; org.apache.helix.HelixAdmin v; javax.ws.rs.core.Response v; java.util.HashMap v; java.lang.String v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; org.apache.helix.rest.server.resources.helix.ClusterAccessor$ClusterProperties v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(v); return v; } public javax.ws.rs.core.Response getClusterInfo(java.lang.String) { org.apache.helix.PropertyKey v, v, v, v, v; org.apache.helix.HelixDataAccessor v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; boolean v, v, v; org.apache.helix.rest.server.resources.AbstractResource$Properties v; org.apache.helix.rest.server.resources.helix.ClusterAccessor$ClusterProperties v, v, v, v, v, v, v; java.util.List v, v, v; javax.ws.rs.core.Response v, v; org.apache.helix.BaseDataAccessor v; org.apache.helix.PropertyKey$Builder v; java.util.HashMap v; org.apache.helix.HelixProperty v; int v; java.lang.Boolean v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; org.apache.helix.HelixAdmin v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v = specialinvoke v.(v); if v != 0 goto label; v = virtualinvoke v.(); return v; label: v = virtualinvoke v.(v); v = interfaceinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v); goto label; label: v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, "No Lead Controller!"); label: v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v, v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = ; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(v); return v; } public javax.ws.rs.core.Response createCluster(java.lang.String, java.lang.String, java.lang.String, java.lang.String) { java.lang.Throwable v; org.apache.helix.model.CloudConfig$Builder v; java.lang.String v, v, v, v, v, v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; boolean v, v; org.slf4j.Logger v, v; org.apache.helix.model.CloudConfig v; org.apache.helix.tools.ClusterSetup v; java.lang.Exception v; org.apache.helix.zookeeper.datamodel.ZNRecord v; javax.ws.rs.core.Response v, v, v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = staticinvoke (v); v = staticinvoke (v); v = virtualinvoke v.(); v = null; if v == 0 goto label; label: v = staticinvoke (v); v = new org.apache.helix.model.CloudConfig$Builder; specialinvoke v.(org.apache.helix.zookeeper.datamodel.ZNRecord)>(v); v = virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to generate a valid CloudConfig from \u0001"); v = ; interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u Exception: \u0001"); v = virtualinvoke v.(v); return v; label: virtualinvoke v.(v, v, v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to create cluster {}. Exception: {}.", v, v); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); return v; catch java.io.IOException from label to label with label; catch org.apache.helix.HelixException from label to label with label; catch java.lang.Exception from label to label with label; } public javax.ws.rs.core.Response deleteCluster(java.lang.String) { java.lang.Throwable v; org.slf4j.Logger v, v; org.apache.helix.tools.ClusterSetup v; java.lang.Exception v; javax.ws.rs.core.Response v, v, v; java.lang.String v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v = virtualinvoke v.(); label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to delete cluster {}, cluster is still in use. Exception: {}.", v, v); v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to delete cluster {}. Exception: {}.", v, v); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); return v; catch org.apache.helix.HelixException from label to label with label; catch java.lang.Exception from label to label with label; } public javax.ws.rs.core.Response updateCluster(java.lang.String, java.lang.String, java.lang.String, java.lang.Long, java.lang.String) { byte v; int[] v; java.lang.Long v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; boolean v; org.apache.helix.tools.ClusterSetup v; java.lang.Exception v, v, v, v, v, v, v; java.util.List v; javax.ws.rs.core.Response v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Throwable v, v, v; java.lang.Object[] v, v; long v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor$1 v; int v, v; java.lang.String v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v; com.fasterxml.jackson.databind.ObjectMapper v; java.lang.IllegalArgumentException v; org.apache.helix.rest.server.resources.AbstractResource$Command v, v; org.apache.helix.HelixAdmin v; java.lang.Object v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.Long; v := @parameter: java.lang.String; label: v = virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; case 7: goto label; case 8: goto label; case 9: goto label; case 10: goto label; default: goto label; }; label: if v != null goto label; v = virtualinvoke v.("Super Cluster name is missing!"); return v; label: virtualinvoke v.(v, v, 1); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to add cluster {} to super cluster {}.", v, v); v = virtualinvoke v.(v); return v; label: if v != null goto label; v = virtualinvoke v.("Super Cluster name is missing!"); return v; label: virtualinvoke v.(v, v, 0); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to deactivate cluster {} from super cluster {}.", v, v); v = virtualinvoke v.(v); return v; label: specialinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to parse json string: {}", v, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("Invalid payload json body: \u0001"); v = virtualinvoke v.(v); return v; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v[2] = v; interfaceinvoke v.("Illegal input {} for command {}.", v); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; v = staticinvoke ("Illegal input %s for command %s", v); v = virtualinvoke v.(v); return v; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to add virtual topology group to cluster {}", v, v); v = virtualinvoke v.(v); return v; label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to expand cluster {}.", v); v = virtualinvoke v.(v); return v; label: interfaceinvoke v.(v, 1); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to enable cluster {}.", v); v = virtualinvoke v.(v); return v; label: interfaceinvoke v.(v, 0); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to disable cluster {}.", v); v = virtualinvoke v.(v); return v; label: v = ; v = new org.apache.helix.rest.server.resources.helix.ClusterAccessor$1; specialinvoke v.(org.apache.helix.rest.server.resources.helix.ClusterAccessor)>(v); v = virtualinvoke v.(v, v); v = null; label: goto label; label: v := @caughtexception; label: v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: interfaceinvoke v.(v, v, v, v); goto label; label: v = interfaceinvoke v.(v); label: interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; label: if v == null goto label; v = virtualinvoke v.(); v = v cmp 0L; if v >= 0 goto label; label: interfaceinvoke v.(v, -1L); goto label; label: v = virtualinvoke v.(); interfaceinvoke v.(v, v); goto label; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("Unsupported command {}.\u0001"); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); return v; catch org.apache.helix.HelixException from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch com.fasterxml.jackson.core.JsonProcessingException from label to label with label; catch java.lang.IllegalArgumentException from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch org.apache.helix.HelixException from label to label with label; } private void addVirtualTopologyGroup(java.lang.String, java.lang.String) throws com.fasterxml.jackson.core.JsonProcessingException { com.fasterxml.jackson.databind.ObjectMapper v; org.apache.helix.rest.server.service.ClusterServiceImpl v; org.apache.helix.HelixDataAccessor v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor$2 v; org.apache.helix.ConfigAccessor v, v; org.apache.helix.HelixAdmin v; java.lang.Object v; java.lang.String v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; org.apache.helix.rest.server.service.VirtualTopologyGroupService v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = new org.apache.helix.rest.server.service.ClusterServiceImpl; v = virtualinvoke v.(v); v = virtualinvoke v.(); specialinvoke v.(org.apache.helix.HelixDataAccessor,org.apache.helix.ConfigAccessor)>(v, v); v = new org.apache.helix.rest.server.service.VirtualTopologyGroupService; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); specialinvoke v.(org.apache.helix.HelixAdmin,org.apache.helix.rest.server.service.ClusterService,org.apache.helix.ConfigAccessor,org.apache.helix.HelixDataAccessor)>(v, v, v, v); v = ; v = new org.apache.helix.rest.server.resources.helix.ClusterAccessor$2; specialinvoke v.(org.apache.helix.rest.server.resources.helix.ClusterAccessor)>(v); v = virtualinvoke v.(v, v); virtualinvoke v.(v, v); return; } public javax.ws.rs.core.Response getClusterManagementMode(java.lang.String, boolean) { org.apache.helix.api.status.ClusterManagementMode$Type v; java.util.HashMap v; org.apache.helix.api.status.ClusterManagementMode v; org.apache.helix.HelixAdmin v; javax.ws.rs.core.Response v, v; java.util.Map v; java.lang.String v, v; org.apache.helix.api.status.ClusterManagementMode$Status v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; boolean v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v := @parameter: boolean; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != null goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cluster \u is not in management mode"); v = virtualinvoke v.(v); return v; label: v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("cluster", v); v = virtualinvoke v.(); interfaceinvoke v.("mode", v); v = virtualinvoke v.(); interfaceinvoke v.("status", v); if v == 0 goto label; v = specialinvoke v.(v, v); interfaceinvoke v.("details", v); label: v = virtualinvoke v.(v); return v; } private java.util.Map getManagementModeDetails(java.lang.String, org.apache.helix.api.status.ClusterManagementMode) { org.apache.helix.PropertyKey v, v; org.apache.zookeeper.data.Stat v; org.apache.helix.HelixDataAccessor v; org.apache.helix.api.status.ClusterManagementMode v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; boolean v, v, v, v, v, v, v, v, v; com.google.common.collect.ImmutableMap v; org.apache.helix.api.status.ClusterManagementMode$Type v, v, v, v, v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor$ClusterProperties v; java.util.List v; org.apache.helix.BaseDataAccessor v; org.apache.helix.api.status.ClusterManagementMode$Status v, v; org.apache.helix.PropertyKey$Builder v; java.util.HashMap v, v; org.apache.helix.model.LiveInstance$LiveInstanceStatus v, v, v, v; java.util.HashSet v; int v, v; java.lang.Boolean v; java.lang.String v, v, v, v, v, v, v; java.util.Iterator v, v; java.lang.Object v, v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v := @parameter: org.apache.helix.api.status.ClusterManagementMode; v = new java.util.HashMap; specialinvoke v.()>(); v = new java.util.HashMap; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke ("cluster", v, "status", v); interfaceinvoke v.("cluster", v); v = 0; v = new java.util.HashSet; specialinvoke v.()>(); v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; 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.(v); if v != 0 goto label; interfaceinvoke v.(v); label: v = virtualinvoke v.(v); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v, v); v = virtualinvoke v.(); if v <= 0 goto label; v = 1; interfaceinvoke v.(v); goto label; label: v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); interfaceinvoke v.("status", v); interfaceinvoke v.("liveInstancesInProgress", v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = staticinvoke (v); interfaceinvoke v.("hasPendingStateTransition", v); label: v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); return v; } public javax.ws.rs.core.Response updateClusterManagementMode(java.lang.String, java.lang.String) { com.fasterxml.jackson.databind.ObjectReader v; javax.ws.rs.core.Response$Status v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; boolean v; com.google.common.collect.ImmutableMap v; org.apache.helix.api.status.ClusterManagementMode$Type v; javax.ws.rs.core.Response v, v, v, v; javax.ws.rs.core.Response$ResponseBuilder v, v; java.lang.Throwable v, v, v; org.apache.helix.api.status.ClusterManagementModeRequest v; java.lang.Boolean v; java.lang.String v, v, v, v, v, v; org.slf4j.Logger v; com.fasterxml.jackson.databind.ObjectMapper v; org.apache.helix.api.status.ClusterManagementModeRequest$Builder v, v, v, v, v; org.apache.helix.HelixAdmin v; java.lang.Object v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v := @parameter: java.lang.String; label: v = ; v = virtualinvoke v.(class "Lorg/apache/helix/api/status/ClusterManagementModeRequest;"); v = virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to parse json string: {}", v, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("Invalid payload json body: \u0001"); v = virtualinvoke v.(v); return v; label: v = staticinvoke (); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); label: v = virtualinvoke v.(); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); return v; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; label: v = staticinvoke (1); v = staticinvoke ("acknowledged", v); v = virtualinvoke v.(v); return v; catch com.fasterxml.jackson.core.JsonProcessingException from label to label with label; catch org.apache.helix.api.exceptions.HelixConflictException from label to label with label; catch org.apache.helix.HelixException from label to label with label; } public javax.ws.rs.core.Response getClusterConfig(java.lang.String) { java.lang.Throwable v; org.slf4j.Logger v, v; java.lang.Exception v; org.apache.helix.zookeeper.datamodel.ZNRecord v; org.apache.helix.ConfigAccessor v; javax.ws.rs.core.Response v, v, v; java.lang.String v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; org.apache.helix.model.ClusterConfig v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v = virtualinvoke v.(); v = null; label: v = virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to get cluster config for cluster {}, cluster not found. Exception: {}.", v, v); goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to get cluster config for cluster {}. Exception: {}", v, v); v = virtualinvoke v.(v); return v; label: if v != null goto label; v = virtualinvoke v.(); return v; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; catch org.apache.helix.HelixException from label to label with label; catch java.lang.Exception from label to label with label; } public javax.ws.rs.core.Response addCustomizedStateConfig(java.lang.String, java.lang.String) { java.lang.Object[] v; java.lang.String v, v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; boolean v; org.slf4j.Logger v; java.io.IOException v; org.apache.helix.model.CustomizedStateConfig$Builder v; java.lang.Exception v; org.apache.helix.zookeeper.datamodel.ZNRecord v; org.apache.helix.model.CustomizedStateConfig v; org.apache.helix.HelixAdmin v; javax.ws.rs.core.Response v, v, v, v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = specialinvoke v.(v); if v != 0 goto label; v = newarray (java.lang.Object)[1]; v[0] = v; v = staticinvoke ("Cluster %s does not exist", v); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); label: v = staticinvoke (v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.("Input is not a vaild ZNRecord!"); return v; label: v = new org.apache.helix.model.CustomizedStateConfig$Builder; specialinvoke v.(org.apache.helix.zookeeper.datamodel.ZNRecord)>(v); v = virtualinvoke v.(); interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Cannot add CustomizedStateConfig to cluster: {} Exception: {}", v, v); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); return v; catch java.io.IOException from label to label with label; catch java.lang.Exception from label to label with label; } public javax.ws.rs.core.Response removeCustomizedStateConfig(java.lang.String) { java.lang.Object[] v; org.slf4j.Logger v; java.lang.Exception v; org.apache.helix.HelixAdmin v; javax.ws.rs.core.Response v, v, v; java.lang.String v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; boolean v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v = specialinvoke v.(v); if v != 0 goto label; v = newarray (java.lang.Object)[1]; v[0] = v; v = staticinvoke ("Cluster %s does not exist", v); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); label: interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Cannot remove CustomizedStateConfig from cluster: {}, Exception: {}", v, v); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); return v; catch java.lang.Exception from label to label with label; } public javax.ws.rs.core.Response getCustomizedStateConfig(java.lang.String) { java.lang.Object[] v; org.apache.helix.zookeeper.datamodel.ZNRecord v; org.apache.helix.ConfigAccessor v; org.apache.helix.model.CustomizedStateConfig v; javax.ws.rs.core.Response v, v, v; java.lang.String v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; boolean v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v = specialinvoke v.(v); if v != 0 goto label; v = newarray (java.lang.Object)[1]; v[0] = v; v = staticinvoke ("Cluster %s does not exist", v); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); return v; } public javax.ws.rs.core.Response updateCustomizedStateConfig(java.lang.String, java.lang.String, java.lang.String) { java.lang.Throwable v; java.lang.Object[] v, v; int[] v; int v, v; java.lang.String v, v, v, v, v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; boolean v, v; org.slf4j.Logger v; java.lang.Exception v; org.apache.helix.rest.server.resources.AbstractResource$Command v; org.apache.helix.HelixAdmin v; javax.ws.rs.core.Response v, v, v, v, v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = specialinvoke v.(v); if v != 0 goto label; v = newarray (java.lang.Object)[1]; v[0] = v; v = staticinvoke ("Cluster %s does not exist", v); v = virtualinvoke v.(v); return v; label: if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = ; goto label; label: v = virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); label: v = ; v = virtualinvoke v.(); v = v[v]; lookupswitch(v) { case 11: goto label; case 12: goto label; default: goto label; }; label: interfaceinvoke v.(v, v); goto label; label: interfaceinvoke v.(v, v); goto label; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("Unsupported command \u0001"); v = virtualinvoke v.(v); label: return v; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[4]; v[0] = v; v[1] = v; v[2] = v; v[3] = v; interfaceinvoke v.("Failed to {} CustomizedStateConfig for cluster {} new type: {}, Exception: {}", v); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); return v; catch org.apache.helix.HelixException from label to label with label; catch java.lang.Exception from label to label with label; } public javax.ws.rs.core.Response getClusterTopology(java.lang.String) throws java.io.IOException { org.apache.helix.rest.server.json.cluster.ClusterTopology v; com.fasterxml.jackson.databind.ObjectMapper v; org.apache.helix.rest.server.service.ClusterServiceImpl v; org.apache.helix.HelixDataAccessor v; org.apache.helix.ConfigAccessor v; javax.ws.rs.core.Response v; java.lang.String v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v = new org.apache.helix.rest.server.service.ClusterServiceImpl; v = virtualinvoke v.(v); v = virtualinvoke v.(); specialinvoke v.(org.apache.helix.HelixDataAccessor,org.apache.helix.ConfigAccessor)>(v, v); v = new com.fasterxml.jackson.databind.ObjectMapper; specialinvoke v.()>(); v = interfaceinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(v); return v; } public javax.ws.rs.core.Response getClusterTopologyMap(java.lang.String) { java.lang.Throwable v; org.apache.helix.HelixAdmin v; javax.ws.rs.core.Response v, v; java.util.Map v; org.apache.helix.api.topology.ClusterTopology v; java.lang.String v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v = virtualinvoke v.(); label: v = interfaceinvoke v.(v); v = virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(v); return v; catch org.apache.helix.HelixException from label to label with label; } public javax.ws.rs.core.Response getClusterFaultZoneMap(java.lang.String) { java.lang.Throwable v; org.apache.helix.HelixAdmin v; javax.ws.rs.core.Response v, v; java.util.Map v; org.apache.helix.api.topology.ClusterTopology v; java.lang.String v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v = virtualinvoke v.(); label: v = interfaceinvoke v.(v); v = virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(v); return v; catch org.apache.helix.HelixException from label to label with label; } public javax.ws.rs.core.Response updateClusterConfig(java.lang.String, java.lang.String, java.lang.String) { org.apache.helix.model.HelixConfigScope$ConfigScopeProperty v; int[] v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; boolean v; org.apache.helix.model.builder.HelixConfigScopeBuilder v, v; java.lang.Exception v; org.apache.helix.zookeeper.datamodel.ZNRecord v, v; org.apache.helix.ConfigAccessor v; javax.ws.rs.core.Response v, v, v, v, v, v, v; java.lang.Throwable v, v; java.lang.Object[] v; org.apache.helix.model.HelixConfigScope v; int v, v; java.lang.String v, v, v, v, v, v, v; org.slf4j.Logger v, v; java.io.IOException v; org.apache.helix.rest.server.resources.AbstractResource$Command v; org.apache.helix.model.ClusterConfig v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; label: v = virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; label: v = staticinvoke (v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to deserialize user\'s input {}. Exception: {}.", v, v); v = virtualinvoke v.("Input is not a valid ZNRecord!"); return v; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; v = virtualinvoke v.("ID does not match the cluster name in input!"); return v; label: v = new org.apache.helix.model.ClusterConfig; specialinvoke v.(org.apache.helix.zookeeper.datamodel.ZNRecord)>(v); v = virtualinvoke v.(); label: v = ; v = virtualinvoke v.(); v = v[v]; lookupswitch(v) { case 11: goto label; case 13: goto label; default: goto label; }; label: virtualinvoke v.(v, v); goto label; label: v = new org.apache.helix.model.builder.HelixConfigScopeBuilder; v = ; specialinvoke v.(org.apache.helix.model.HelixConfigScope$ConfigScopeProperty)>(v); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("Unsupported command \u0001"); v = virtualinvoke v.(v); label: return v; label: v := @caughtexception; v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; label: v := @caughtexception; v = ; v = newarray (java.lang.Object)[4]; v[0] = v; v[1] = v; v[2] = v; v[3] = v; interfaceinvoke v.("Failed to {} cluster config, cluster {}, new config: {}. Exception: {}.", v); v = virtualinvoke v.(v); return v; label: v = virtualinvoke v.(); return v; catch org.apache.helix.HelixException from label to label with label; catch java.io.IOException from label to label with label; catch org.apache.helix.HelixException from label to label with label; catch java.lang.Exception from label to label with label; } public javax.ws.rs.core.Response getClusterController(java.lang.String) { org.apache.helix.PropertyKey v; org.apache.helix.PropertyKey$Builder v; java.util.HashMap v; org.apache.helix.HelixDataAccessor v; org.apache.helix.HelixProperty v; java.util.Map v; java.lang.String v, v, v, v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; org.apache.helix.rest.server.resources.AbstractResource$Properties v; org.apache.helix.rest.server.resources.helix.ClusterAccessor$ClusterProperties v, v; org.apache.helix.zookeeper.datamodel.ZNRecord v; javax.ws.rs.core.Response v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v = virtualinvoke v.(v); v = new java.util.HashMap; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); goto label; label: v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, "No Lead Controller!"); label: v = virtualinvoke v.(v); return v; } public javax.ws.rs.core.Response getClusterControllerLeadershipHistory(java.lang.String) { javax.ws.rs.core.Response v; java.util.Map v; java.lang.String v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; org.apache.helix.model.ControllerHistory$HistoryType v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v = ; v = specialinvoke v.(v, v); v = virtualinvoke v.(v); return v; } public javax.ws.rs.core.Response getClusterMaintenanceHistory(java.lang.String) { javax.ws.rs.core.Response v; java.util.Map v; java.lang.String v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; org.apache.helix.model.ControllerHistory$HistoryType v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v = ; v = specialinvoke v.(v, v); v = virtualinvoke v.(v); return v; } public javax.ws.rs.core.Response getClusterMaintenanceSignal(java.lang.String) { java.lang.Object[] v; org.apache.helix.PropertyKey v; org.apache.helix.PropertyKey$Builder v; org.apache.helix.HelixDataAccessor v; org.apache.helix.rest.server.resources.helix.ClusterAccessor$ClusterProperties v; org.apache.helix.zookeeper.datamodel.ZNRecord v; org.apache.helix.HelixProperty v; javax.ws.rs.core.Response v, v; java.util.Map v; java.lang.String v, v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v = virtualinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(v); return v; label: v = newarray (java.lang.Object)[1]; v[0] = v; v = staticinvoke ("Cluster %s is not in maintenance mode!", v); v = virtualinvoke v.(v); return v; } public javax.ws.rs.core.Response getClusterControllerMessages(java.lang.String) { org.apache.helix.PropertyKey v; org.apache.helix.PropertyKey$Builder v; java.util.HashMap v; java.lang.Integer v; org.apache.helix.HelixDataAccessor v; int v; java.lang.String v, v, v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor v; org.apache.helix.rest.server.resources.AbstractResource$Properties v, v; org.apache.helix.rest.server.resources.helix.ClusterAccessor$ClusterProperties v; java.util.List v; javax.ws.rs.core.Response v; v := @this: org.apache.helix.rest.server.resources.helix.ClusterAccessor; v := @parameter: java.lang.String; v = virtualinvoke v.(v); v = new java.util.HashMap; specialinvoke v.()>(); v =