public class org.apache.helix.rest.server.resources.helix.PerInstanceAccessor extends org.apache.helix.rest.server.resources.helix.AbstractHelixResource
{
private static final org.slf4j.Logger LOG;
public void <init>()
{
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
specialinvoke v.<org.apache.helix.rest.server.resources.helix.AbstractHelixResource: void <init>()>();
return;
}
public javax.ws.rs.core.Response getInstanceById(java.lang.String, java.lang.String, java.lang.String, java.lang.String)
{
org.apache.helix.HelixDataAccessor v;
int[] v;
java.util.Map v;
boolean v;
java.lang.Exception v;
org.apache.helix.ConfigAccessor v;
java.util.List v, v;
javax.ws.rs.core.Response v, v, v, v, v, v;
java.lang.Throwable v, v;
org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService v;
int v, v;
org.apache.helix.rest.server.json.instance.InstanceInfo v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
org.slf4j.Logger v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.helix.rest.server.resources.AbstractResource$Command v;
org.apache.helix.HelixAdmin v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
label:
v = staticinvoke <org.apache.helix.rest.server.resources.AbstractResource$Command: org.apache.helix.rest.server.resources.AbstractResource$Command valueOf(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Invalid command : \u0001");
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>(v);
return v;
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$1: int[] $SwitchMap$org$apache$helix$rest$server$resources$AbstractResource$Command>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.AbstractResource$Command: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixDataAccessor getDataAccssor(java.lang.String)>(v);
v = new org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.ConfigAccessor getConfigAccessor()>();
v = staticinvoke <java.lang.Boolean: boolean parseBoolean(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: java.lang.String getNamespace()>();
specialinvoke v.<org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService: void <init>(org.apache.helix.manager.zk.ZKHelixDataAccessor,org.apache.helix.ConfigAccessor,boolean,java.lang.String)>(v, v, v, v);
v = <org.apache.helix.rest.clusterMaintenanceService.HealthCheck: java.util.List STARTED_AND_HEALTH_CHECK_LIST>;
v = virtualinvoke v.<org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService: org.apache.helix.rest.server.json.instance.InstanceInfo getInstanceHealthInfo(java.lang.String,java.lang.String,java.util.List)>(v, v, v);
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.String writeValueAsString(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response serverError(java.lang.Exception)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response OK(java.lang.Object)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixAdmin getHelixAdmin()>();
label:
v = staticinvoke <java.util.Collections: java.util.List singletonList(java.lang.Object)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixAdmin: java.util.Map validateInstancesForWagedRebalance(java.lang.String,java.util.List)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.helix.HelixException: java.lang.String getMessage()>();
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response JSONRepresentation(java.lang.Object)>(v);
return v;
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unsupported command :\u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unsupported command :\u0001");
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>(v);
return v;
catch java.lang.Exception from label to label with label;
catch com.fasterxml.jackson.core.JsonProcessingException from label to label with label;
catch org.apache.helix.HelixException from label to label with label;
}
public javax.ws.rs.core.Response isInstanceStoppable(java.lang.String, java.lang.String, java.lang.String, boolean, boolean) throws java.io.IOException
{
java.lang.Throwable v;
java.lang.Object[] v;
org.apache.helix.rest.server.resources.helix.InstancesAccessor$InstancesProperties v, v;
org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService v;
org.apache.helix.rest.server.json.instance.StoppableCheck v;
org.apache.helix.HelixDataAccessor v;
int v;
com.fasterxml.jackson.databind.JsonNode v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
boolean v, v;
org.slf4j.Logger v;
com.fasterxml.jackson.databind.ObjectMapper v, v;
org.apache.helix.ConfigAccessor v;
javax.ws.rs.core.Response v, v, v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: boolean;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixDataAccessor getDataAccssor(java.lang.String)>(v);
v = new org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.ConfigAccessor getConfigAccessor()>();
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: java.lang.String getNamespace()>();
specialinvoke v.<org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService: void <init>(org.apache.helix.manager.zk.ZKHelixDataAccessor,org.apache.helix.ConfigAccessor,boolean,boolean,java.lang.String)>(v, v, v, v, v);
label:
v = null;
v = virtualinvoke v.<java.lang.String: int length()>();
if v == 0 goto label;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(java.lang.String)>(v);
label:
if v != null goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Invalid input for content : \u0001");
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>(v);
label:
return v;
label:
v = null;
v = <org.apache.helix.rest.server.resources.helix.InstancesAccessor$InstancesProperties: org.apache.helix.rest.server.resources.helix.InstancesAccessor$InstancesProperties customized_values>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.InstancesAccessor$InstancesProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>(v);
if v == null goto label;
v = <org.apache.helix.rest.server.resources.helix.InstancesAccessor$InstancesProperties: org.apache.helix.rest.server.resources.helix.InstancesAccessor$InstancesProperties customized_values>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.InstancesAccessor$InstancesProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String toString()>();
label:
v = virtualinvoke v.<org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService: org.apache.helix.rest.server.json.instance.StoppableCheck getInstanceStoppableCheck(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object[])>("Current cluster: {}, instance: {} has issue with health checks!", v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response serverError(java.lang.Exception)>(v);
return v;
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.String writeValueAsString(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response OK(java.lang.Object)>(v);
return v;
catch org.apache.helix.HelixException from label to label with label;
catch org.apache.helix.HelixException from label to label with label;
}
public javax.ws.rs.core.Response takeSingleInstance(java.lang.String, java.lang.String, java.lang.String)
{
org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementInstanceInfo v;
org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService v;
org.apache.helix.HelixDataAccessor v;
java.util.Map v, v;
java.lang.String v, v, v, v, v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
boolean v, v;
org.slf4j.Logger v;
java.util.Set v;
java.lang.Exception v;
org.apache.helix.ConfigAccessor v;
java.util.List v, v;
javax.ws.rs.core.Response v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
label:
v = specialinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields readMaintenanceInputFromJson(java.lang.String)>(v);
if v != null goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Invalid input for content : \u0001");
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>(v);
label:
return v;
label:
v = new org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixDataAccessor getDataAccssor(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.ConfigAccessor getConfigAccessor()>();
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: boolean skipZKRead>;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Set nonBlockingHelixCheck>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: java.lang.String getNamespace()>();
specialinvoke v.<org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService: void <init>(org.apache.helix.manager.zk.ZKHelixDataAccessor,org.apache.helix.ConfigAccessor,boolean,java.util.Set,java.lang.String)>(v, v, v, v, v);
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.List healthChecks>;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map healthCheckConfig>;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.List operations>;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map operationConfig>;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: boolean performOperation>;
v = virtualinvoke v.<org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService: org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementInstanceInfo takeInstance(java.lang.String,java.lang.String,java.util.List,java.util.Map,java.util.List,java.util.Map,boolean)>(v, v, v, v, v, v, v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response JSONRepresentation(java.lang.Object)>(v);
label:
return v;
label:
v := @caughtexception;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Failed to takeInstances:", v);
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to takeInstances: \u0001");
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>(v);
return v;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
public javax.ws.rs.core.Response freeSingleInstance(java.lang.String, java.lang.String, java.lang.String)
{
org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementInstanceInfo v;
org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService v;
org.apache.helix.HelixDataAccessor v;
java.util.Map v, v;
int v;
java.lang.String v, v, v, v, v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
boolean v, v;
org.slf4j.Logger v, v;
java.util.Set v;
java.lang.Exception v;
org.apache.helix.ConfigAccessor v;
java.util.List v, v, v;
javax.ws.rs.core.Response v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
label:
v = specialinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields readMaintenanceInputFromJson(java.lang.String)>(v);
if v != null goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Invalid input for content : \u0001");
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>(v);
label:
return v;
label:
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.List healthChecks>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v == 0 goto label;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("freeSingleInstance won\'t perform user passed health check.");
label:
v = new org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixDataAccessor getDataAccssor(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.ConfigAccessor getConfigAccessor()>();
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: boolean skipZKRead>;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Set nonBlockingHelixCheck>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: java.lang.String getNamespace()>();
specialinvoke v.<org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService: void <init>(org.apache.helix.manager.zk.ZKHelixDataAccessor,org.apache.helix.ConfigAccessor,boolean,java.util.Set,java.lang.String)>(v, v, v, v, v);
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.List healthChecks>;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map healthCheckConfig>;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.List operations>;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map operationConfig>;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: boolean performOperation>;
v = virtualinvoke v.<org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService: org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementInstanceInfo freeInstance(java.lang.String,java.lang.String,java.util.List,java.util.Map,java.util.List,java.util.Map,boolean)>(v, v, v, v, v, v, v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response JSONRepresentation(java.lang.Object)>(v);
label:
return v;
label:
v := @caughtexception;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Failed to takeInstances:", v);
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to takeInstances: \u0001");
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>(v);
return v;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
private org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields readMaintenanceInputFromJson(java.lang.String) throws java.io.IOException
{
java.util.Map v, v, v, v, v, v, v, v, v, v, v, v;
com.fasterxml.jackson.databind.JsonNode v, v, v, v, v;
boolean v, v, v, v, v;
java.util.List v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties v, v, v, v, v, v, v;
java.util.HashSet v;
int v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
org.slf4j.Logger v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.lang.Object v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v = null;
v = virtualinvoke v.<java.lang.String: int length()>();
if v == 0 goto label;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(java.lang.String)>(v);
label:
if v != null goto label;
return null;
label:
v = new org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields;
specialinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: void <init>()>();
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties continueOnFailures>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties skipZKRead>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties performOperation>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties health_check_list>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>(v);
v = staticinvoke <org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService: java.util.List getListFromJsonPayload(com.fasterxml.jackson.databind.JsonNode)>(v);
v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.List healthChecks> = v;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties health_check_config>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>(v);
v = staticinvoke <org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService: java.util.Map getMapFromJsonPayload(com.fasterxml.jackson.databind.JsonNode)>(v);
v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map healthCheckConfig> = v;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map healthCheckConfig>;
if v == null goto label;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map healthCheckConfig>;
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v == 0 goto label;
v = new java.util.HashSet;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map healthCheckConfig>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = staticinvoke <org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService: java.util.List getListFromJsonPayload(java.lang.String)>(v);
specialinvoke v.<java.util.HashSet: void <init>(java.util.Collection)>(v);
v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Set nonBlockingHelixCheck> = v;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map healthCheckConfig>;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
label:
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map healthCheckConfig>;
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v == 0 goto label;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map healthCheckConfig>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = staticinvoke <java.lang.Boolean: boolean parseBoolean(java.lang.String)>(v);
v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: boolean skipZKRead> = v;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map healthCheckConfig>;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties operation_list>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>(v);
v = staticinvoke <org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService: java.util.List getListFromJsonPayload(com.fasterxml.jackson.databind.JsonNode)>(v);
v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.List operations> = v;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties operation_config>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>(v);
v = staticinvoke <org.apache.helix.rest.clusterMaintenanceService.MaintenanceManagementService: java.util.Map getMapFromJsonPayload(com.fasterxml.jackson.databind.JsonNode)>(v);
v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map operationConfig> = v;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map operationConfig>;
if v == null goto label;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map operationConfig>;
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v == 0 goto label;
v = v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: java.util.Map operationConfig>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = staticinvoke <java.lang.Boolean: boolean parseBoolean(java.lang.String)>(v);
v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$MaintenanceOpInputFields: boolean performOperation> = v;
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Input fields for take/free Instance\u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
return v;
}
public javax.ws.rs.core.Response addInstance(java.lang.String, java.lang.String, java.lang.String)
{
java.lang.String v, v, v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
org.slf4j.Logger v, v;
java.io.IOException v;
org.apache.helix.model.InstanceConfig v;
java.lang.Exception v;
org.apache.helix.zookeeper.datamodel.ZNRecord v;
org.apache.helix.HelixAdmin v;
javax.ws.rs.core.Response v, v, v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixAdmin getHelixAdmin()>();
label:
v = staticinvoke <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.zookeeper.datamodel.ZNRecord toZNRecord(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.io.IOException)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to deserialize user\'s input \u, Exception: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>("Input is not a vaild ZNRecord!");
return v;
label:
v = new org.apache.helix.model.InstanceConfig;
specialinvoke v.<org.apache.helix.model.InstanceConfig: void <init>(org.apache.helix.zookeeper.datamodel.ZNRecord)>(v);
interfaceinvoke v.<org.apache.helix.HelixAdmin: void addInstance(java.lang.String,org.apache.helix.model.InstanceConfig)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Error in adding an instance: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response serverError(java.lang.Exception)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response OK()>();
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 updateInstance(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String)
{
org.apache.helix.constants.InstanceConstants$InstanceDisabledType v;
com.fasterxml.jackson.databind.type.TypeFactory v, v, v, v, v;
com.fasterxml.jackson.databind.JsonNode v, v, v, v, v, v, v, v, v;
com.fasterxml.jackson.databind.type.CollectionType v, v, v, v, v;
java.lang.Exception v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.helix.HelixAdmin v;
int[] v;
boolean v, v, v, v, v;
javax.ws.rs.core.Response v, v, v, v, v, v, v, v;
int v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
org.slf4j.Logger v, v;
java.util.Iterator v, v;
com.fasterxml.jackson.databind.ObjectMapper v, v, v, v, v, v, v, v, v, v, v;
java.lang.IllegalArgumentException v;
org.apache.helix.rest.server.resources.AbstractResource$Command v;
java.lang.Object v, v, v, v, v, v, v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
label:
v = staticinvoke <org.apache.helix.rest.server.resources.AbstractResource$Command: org.apache.helix.rest.server.resources.AbstractResource$Command valueOf(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Invalid command : \u0001");
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixAdmin getHelixAdmin()>();
label:
v = null;
v = virtualinvoke v.<java.lang.String: int length()>();
if v == 0 goto label;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode readTree(java.lang.String)>(v);
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$1: int[] $SwitchMap$org$apache$helix$rest$server$resources$AbstractResource$Command>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.AbstractResource$Command: int ordinal()>();
v = v[v];
tableswitch(v)
{
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:
interfaceinvoke v.<org.apache.helix.HelixAdmin: void enableInstance(java.lang.String,java.lang.String,boolean)>(v, v, 1);
goto label;
label:
v = null;
if v == null goto label;
label:
v = staticinvoke <org.apache.helix.constants.InstanceConstants$InstanceDisabledType: org.apache.helix.constants.InstanceConstants$InstanceDisabledType valueOf(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>("Invalid instanceDisabledType!");
label:
return v;
label:
interfaceinvoke v.<org.apache.helix.HelixAdmin: void enableInstance(java.lang.String,java.lang.String,boolean,org.apache.helix.constants.InstanceConstants$InstanceDisabledType,java.lang.String)>(v, v, 0, v, v);
goto label;
label:
v = specialinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: boolean validInstance(com.fasterxml.jackson.databind.JsonNode,java.lang.String)>(v, v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>("Instance names are not match!");
label:
return v;
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties resource>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String textValue()>();
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties partitions>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String toString()>();
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.type.TypeFactory getTypeFactory()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.type.TypeFactory: com.fasterxml.jackson.databind.type.CollectionType constructCollectionType(java.lang.Class,java.lang.Class)>(class "Ljava/util/List;", class "Ljava/lang/String;");
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,com.fasterxml.jackson.databind.JavaType)>(v, v);
interfaceinvoke v.<org.apache.helix.HelixAdmin: void resetPartition(java.lang.String,java.lang.String,java.lang.String,java.util.List)>(v, v, v, v);
goto label;
label:
v = specialinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: boolean validInstance(com.fasterxml.jackson.databind.JsonNode,java.lang.String)>(v, v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>("Instance names are not match!");
label:
return v;
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties instanceTags>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String toString()>();
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.type.TypeFactory getTypeFactory()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.type.TypeFactory: com.fasterxml.jackson.databind.type.CollectionType constructCollectionType(java.lang.Class,java.lang.Class)>(class "Ljava/util/List;", class "Ljava/lang/String;");
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,com.fasterxml.jackson.databind.JavaType)>(v, v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<org.apache.helix.HelixAdmin: void addInstanceTag(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
goto label;
label:
v = specialinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: boolean validInstance(com.fasterxml.jackson.databind.JsonNode,java.lang.String)>(v, v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>("Instance names are not match!");
label:
return v;
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties instanceTags>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String toString()>();
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.type.TypeFactory getTypeFactory()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.type.TypeFactory: com.fasterxml.jackson.databind.type.CollectionType constructCollectionType(java.lang.Class,java.lang.Class)>(class "Ljava/util/List;", class "Ljava/lang/String;");
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,com.fasterxml.jackson.databind.JavaType)>(v, v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<org.apache.helix.HelixAdmin: void removeInstanceTag(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
goto label;
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties resource>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String textValue()>();
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties partitions>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String toString()>();
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.type.TypeFactory getTypeFactory()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.type.TypeFactory: com.fasterxml.jackson.databind.type.CollectionType constructCollectionType(java.lang.Class,java.lang.Class)>(class "Ljava/util/List;", class "Ljava/lang/String;");
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,com.fasterxml.jackson.databind.JavaType)>(v, v);
interfaceinvoke v.<org.apache.helix.HelixAdmin: void enablePartition(boolean,java.lang.String,java.lang.String,java.lang.String,java.util.List)>(1, v, v, v, v);
goto label;
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties resource>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String textValue()>();
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties partitions>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String toString()>();
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.type.TypeFactory getTypeFactory()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.type.TypeFactory: com.fasterxml.jackson.databind.type.CollectionType constructCollectionType(java.lang.Class,java.lang.Class)>(class "Ljava/util/List;", class "Ljava/lang/String;");
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: java.lang.Object readValue(java.lang.String,com.fasterxml.jackson.databind.JavaType)>(v, v);
interfaceinvoke v.<org.apache.helix.HelixAdmin: void enablePartition(boolean,java.lang.String,java.lang.String,java.lang.String,java.util.List)>(0, v, v, v, v);
goto label;
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unsupported command :\u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unsupported command :\u0001");
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>(v);
label:
return v;
label:
v := @caughtexception;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed in updating instance : \u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response OK()>();
return v;
catch java.lang.Exception 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;
}
public javax.ws.rs.core.Response deleteInstance(java.lang.String, java.lang.String)
{
java.lang.Throwable v;
org.apache.helix.model.InstanceConfig v;
org.apache.helix.HelixAdmin v;
javax.ws.rs.core.Response v, v;
java.lang.String v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixAdmin getHelixAdmin()>();
label:
v = interfaceinvoke v.<org.apache.helix.HelixAdmin: org.apache.helix.model.InstanceConfig getInstanceConfig(java.lang.String,java.lang.String)>(v, v);
interfaceinvoke v.<org.apache.helix.HelixAdmin: void dropInstance(java.lang.String,org.apache.helix.model.InstanceConfig)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.helix.HelixException: java.lang.String getMessage()>();
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response OK()>();
return v;
catch org.apache.helix.HelixException from label to label with label;
}
public javax.ws.rs.core.Response getInstanceConfig(java.lang.String, java.lang.String) throws java.io.IOException
{
org.apache.helix.PropertyKey v;
org.apache.helix.PropertyKey$Builder v;
org.apache.helix.HelixDataAccessor v;
org.apache.helix.zookeeper.datamodel.ZNRecord v;
org.apache.helix.HelixProperty v;
javax.ws.rs.core.Response v, v;
java.lang.String v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixDataAccessor getDataAccssor(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey instanceConfig(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.HelixProperty getProperty(org.apache.helix.PropertyKey)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.helix.model.InstanceConfig: org.apache.helix.zookeeper.datamodel.ZNRecord getRecord()>();
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response JSONRepresentation(java.lang.Object)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response notFound()>();
return v;
}
public javax.ws.rs.core.Response updateInstanceConfig(java.lang.String, java.lang.String, java.lang.String, java.lang.String)
{
org.apache.helix.model.HelixConfigScope$ConfigScopeProperty v;
int[] v;
boolean v;
org.apache.helix.model.builder.HelixConfigScopeBuilder v, 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, v, v, v, v;
java.lang.Throwable v, v;
java.lang.Object[] v, v, v;
org.apache.helix.model.HelixConfigScope v;
int v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
org.slf4j.Logger v, v, v;
java.io.IOException v;
java.lang.IllegalArgumentException v;
org.apache.helix.model.InstanceConfig v;
org.apache.helix.rest.server.resources.AbstractResource$Command v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v == 0 goto label;
label:
v = <org.apache.helix.rest.server.resources.AbstractResource$Command: org.apache.helix.rest.server.resources.AbstractResource$Command update>;
goto label;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.rest.server.resources.AbstractResource$Command getCommand(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.helix.HelixException: java.lang.String getMessage()>();
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>(v);
return v;
label:
v = staticinvoke <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.zookeeper.datamodel.ZNRecord toZNRecord(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.io.IOException)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to deserialize user\'s input \u, Exception: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>("Input is not a vaild ZNRecord!");
return v;
label:
v = new org.apache.helix.model.InstanceConfig;
specialinvoke v.<org.apache.helix.model.InstanceConfig: void <init>(org.apache.helix.zookeeper.datamodel.ZNRecord)>(v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.ConfigAccessor getConfigAccessor()>();
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$1: int[] $SwitchMap$org$apache$helix$rest$server$resources$AbstractResource$Command>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.AbstractResource$Command: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 11: goto label;
case 12: goto label;
default: goto label;
};
label:
specialinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: boolean validateDeltaTopologySettingInInstanceConfig(java.lang.String,java.lang.String,org.apache.helix.ConfigAccessor,org.apache.helix.model.InstanceConfig,org.apache.helix.rest.server.resources.AbstractResource$Command)>(v, v, v, v, v);
virtualinvoke v.<org.apache.helix.ConfigAccessor: void updateInstanceConfig(java.lang.String,java.lang.String,org.apache.helix.model.InstanceConfig)>(v, v, v);
goto label;
label:
specialinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: boolean validateDeltaTopologySettingInInstanceConfig(java.lang.String,java.lang.String,org.apache.helix.ConfigAccessor,org.apache.helix.model.InstanceConfig,org.apache.helix.rest.server.resources.AbstractResource$Command)>(v, v, v, v, v);
v = new org.apache.helix.model.builder.HelixConfigScopeBuilder;
v = <org.apache.helix.model.HelixConfigScope$ConfigScopeProperty: org.apache.helix.model.HelixConfigScope$ConfigScopeProperty PARTICIPANT>;
specialinvoke v.<org.apache.helix.model.builder.HelixConfigScopeBuilder: void <init>(org.apache.helix.model.HelixConfigScope$ConfigScopeProperty)>(v);
v = virtualinvoke v.<org.apache.helix.model.builder.HelixConfigScopeBuilder: org.apache.helix.model.builder.HelixConfigScopeBuilder forCluster(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.helix.model.builder.HelixConfigScopeBuilder: org.apache.helix.model.builder.HelixConfigScopeBuilder forParticipant(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.helix.model.builder.HelixConfigScopeBuilder: org.apache.helix.model.HelixConfigScope build()>();
virtualinvoke v.<org.apache.helix.ConfigAccessor: void remove(org.apache.helix.model.HelixConfigScope,org.apache.helix.zookeeper.datamodel.ZNRecord)>(v, v);
goto label;
label:
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unsupported command: %s", v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response badRequest(java.lang.String)>(v);
label:
return v;
label:
v := @caughtexception;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Invalid topology setting for Instance : {}. Fail the config update", v);
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response serverError(java.lang.Exception)>(v);
return v;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.helix.HelixException: java.lang.String getMessage()>();
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response notFound(java.lang.String)>(v);
return v;
label:
v := @caughtexception;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Error in update instance config for instance: %s", v);
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response serverError(java.lang.Exception)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response OK()>();
return v;
catch org.apache.helix.HelixException from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.IllegalArgumentException 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 getResourcesOnInstance(java.lang.String, java.lang.String) throws java.io.IOException
{
org.apache.helix.PropertyKey v, v, v, v;
org.apache.helix.PropertyKey$Builder v, v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties v;
com.fasterxml.jackson.databind.node.ObjectNode v;
org.apache.helix.HelixDataAccessor v;
org.apache.helix.HelixProperty v;
int v;
com.fasterxml.jackson.databind.JsonNode v;
java.lang.String v, v, v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
boolean v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.helix.rest.server.resources.AbstractResource$Properties v;
com.fasterxml.jackson.databind.node.ArrayNode v;
java.util.List v, v, v;
javax.ws.rs.core.Response v;
com.fasterxml.jackson.databind.node.JsonNodeFactory v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixDataAccessor getDataAccssor(java.lang.String)>(v);
v = <com.fasterxml.jackson.databind.node.JsonNodeFactory: com.fasterxml.jackson.databind.node.JsonNodeFactory instance>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.node.JsonNodeFactory: com.fasterxml.jackson.databind.node.ObjectNode objectNode()>();
v = <org.apache.helix.rest.server.resources.AbstractResource$Properties: org.apache.helix.rest.server.resources.AbstractResource$Properties id>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.AbstractResource$Properties: java.lang.String name()>();
virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.node.ObjectNode put(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties resources>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.node.ArrayNode putArray(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey liveInstances()>();
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: java.util.List getChildNames(org.apache.helix.PropertyKey)>(v);
v = interfaceinvoke v.<java.util.List: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
return null;
label:
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey liveInstance(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.HelixProperty getProperty(org.apache.helix.PropertyKey)>(v);
v = virtualinvoke v.<org.apache.helix.model.LiveInstance: java.lang.String getEphemeralOwner()>();
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey currentStates(java.lang.String,java.lang.String)>(v, v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: java.util.List getChildNames(org.apache.helix.PropertyKey)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey taskCurrentStates(java.lang.String,java.lang.String)>(v, v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: java.util.List getChildNames(org.apache.helix.PropertyKey)>(v);
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 0 goto label;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode valueToTree(java.lang.Object)>(v);
virtualinvoke v.<com.fasterxml.jackson.databind.node.ArrayNode: com.fasterxml.jackson.databind.node.ArrayNode addAll(com.fasterxml.jackson.databind.node.ArrayNode)>(v);
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response JSONRepresentation(java.lang.Object)>(v);
return v;
}
public javax.ws.rs.core.Response getResourceOnInstance(java.lang.String, java.lang.String, java.lang.String) throws java.io.IOException
{
org.apache.helix.PropertyKey v, v, v, v;
org.apache.helix.PropertyKey$Builder v, v, v, v;
org.apache.helix.HelixDataAccessor v;
org.apache.helix.HelixProperty v, v;
java.lang.String v, v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
boolean v;
org.apache.helix.zookeeper.datamodel.ZNRecord v;
java.util.List v;
javax.ws.rs.core.Response v, v, v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixDataAccessor getDataAccssor(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey liveInstances()>();
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: java.util.List getChildNames(org.apache.helix.PropertyKey)>(v);
v = interfaceinvoke v.<java.util.List: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response notFound()>();
return v;
label:
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey liveInstance(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.HelixProperty getProperty(org.apache.helix.PropertyKey)>(v);
v = virtualinvoke v.<org.apache.helix.model.LiveInstance: java.lang.String getEphemeralOwner()>();
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey currentState(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.HelixProperty getProperty(org.apache.helix.PropertyKey)>(v);
if v != null goto label;
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey taskCurrentState(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.HelixProperty getProperty(org.apache.helix.PropertyKey)>(v);
label:
if v == null goto label;
v = virtualinvoke v.<org.apache.helix.model.CurrentState: org.apache.helix.zookeeper.datamodel.ZNRecord getRecord()>();
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response JSONRepresentation(java.lang.Object)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response notFound()>();
return v;
}
public javax.ws.rs.core.Response getErrorsOnInstance(java.lang.String, java.lang.String) throws java.io.IOException
{
org.apache.helix.PropertyKey v, v, v;
org.apache.helix.HelixDataAccessor v;
com.fasterxml.jackson.databind.JsonNode v;
boolean v, v;
org.apache.helix.rest.server.resources.AbstractResource$Properties v;
com.fasterxml.jackson.databind.node.ArrayNode v;
java.util.List v, v, v;
javax.ws.rs.core.Response v, v;
com.fasterxml.jackson.databind.node.JsonNodeFactory v, v, v;
org.apache.helix.PropertyKey$Builder v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties v;
com.fasterxml.jackson.databind.node.ObjectNode v, v, v;
int v;
java.lang.String v, v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
java.util.Iterator v, v;
com.fasterxml.jackson.databind.ObjectMapper v;
java.lang.Object v, v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixDataAccessor getDataAccssor(java.lang.String)>(v);
v = <com.fasterxml.jackson.databind.node.JsonNodeFactory: com.fasterxml.jackson.databind.node.JsonNodeFactory instance>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.node.JsonNodeFactory: com.fasterxml.jackson.databind.node.ObjectNode objectNode()>();
v = <org.apache.helix.rest.server.resources.AbstractResource$Properties: org.apache.helix.rest.server.resources.AbstractResource$Properties id>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.AbstractResource$Properties: java.lang.String name()>();
virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.node.ObjectNode put(java.lang.String,java.lang.String)>(v, v);
v = <com.fasterxml.jackson.databind.node.JsonNodeFactory: com.fasterxml.jackson.databind.node.JsonNodeFactory instance>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.node.JsonNodeFactory: com.fasterxml.jackson.databind.node.ObjectNode objectNode()>();
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey errors(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: java.util.List getChildNames(org.apache.helix.PropertyKey)>(v);
if v == null goto label;
v = interfaceinvoke v.<java.util.List: int size()>();
if v != 0 goto label;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response notFound()>();
return v;
label:
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey errors(java.lang.String,java.lang.String)>(v, v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: java.util.List getChildNames(org.apache.helix.PropertyKey)>(v);
if v == null goto label;
v = <com.fasterxml.jackson.databind.node.JsonNodeFactory: com.fasterxml.jackson.databind.node.JsonNodeFactory instance>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.node.JsonNodeFactory: com.fasterxml.jackson.databind.node.ObjectNode objectNode()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey errors(java.lang.String,java.lang.String,java.lang.String)>(v, v, v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: java.util.List getChildNames(org.apache.helix.PropertyKey)>(v);
if v == null goto label;
v = virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.node.ArrayNode putArray(java.lang.String)>(v);
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode valueToTree(java.lang.Object)>(v);
virtualinvoke v.<com.fasterxml.jackson.databind.node.ArrayNode: com.fasterxml.jackson.databind.node.ArrayNode addAll(com.fasterxml.jackson.databind.node.ArrayNode)>(v);
goto label;
label:
virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.JsonNode put(java.lang.String,com.fasterxml.jackson.databind.JsonNode)>(v, v);
goto label;
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties errors>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.JsonNode put(java.lang.String,com.fasterxml.jackson.databind.JsonNode)>(v, v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response JSONRepresentation(java.lang.Object)>(v);
return v;
}
public javax.ws.rs.core.Response getErrorsOnInstance(java.lang.String, java.lang.String, java.lang.String, java.lang.String, java.lang.String) throws java.io.IOException
{
org.apache.helix.PropertyKey v;
org.apache.helix.PropertyKey$Builder v;
org.apache.helix.HelixDataAccessor v;
org.apache.helix.zookeeper.datamodel.ZNRecord v;
org.apache.helix.HelixProperty v;
javax.ws.rs.core.Response v, v;
java.lang.String v, v, v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixDataAccessor getDataAccssor(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey stateTransitionError(java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.HelixProperty getProperty(org.apache.helix.PropertyKey)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.helix.model.Error: org.apache.helix.zookeeper.datamodel.ZNRecord getRecord()>();
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response JSONRepresentation(java.lang.Object)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response notFound()>();
return v;
}
public javax.ws.rs.core.Response getHistoryOnInstance(java.lang.String, java.lang.String) throws java.io.IOException
{
org.apache.helix.PropertyKey v;
org.apache.helix.PropertyKey$Builder v;
org.apache.helix.HelixDataAccessor v;
org.apache.helix.zookeeper.datamodel.ZNRecord v;
org.apache.helix.HelixProperty v;
javax.ws.rs.core.Response v, v;
java.lang.String v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixDataAccessor getDataAccssor(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey participantHistory(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.HelixProperty getProperty(org.apache.helix.PropertyKey)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.helix.model.ParticipantHistory: org.apache.helix.zookeeper.datamodel.ZNRecord getRecord()>();
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response JSONRepresentation(java.lang.Object)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response notFound()>();
return v;
}
public javax.ws.rs.core.Response getMessagesOnInstance(java.lang.String, java.lang.String, java.lang.String)
{
org.apache.helix.PropertyKey v, v;
org.apache.helix.HelixDataAccessor v;
boolean v, v, v, v, v;
org.apache.helix.rest.server.resources.AbstractResource$Properties v;
com.fasterxml.jackson.databind.node.ArrayNode v, v;
org.apache.helix.model.Message$MessageState v, v, v, v;
java.util.List v;
javax.ws.rs.core.Response v, v;
com.fasterxml.jackson.databind.node.JsonNodeFactory v;
org.apache.helix.PropertyKey$Builder v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties v, v, v, v;
com.fasterxml.jackson.databind.node.ObjectNode v;
org.apache.helix.HelixProperty v;
int v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
org.slf4j.Logger v, v;
java.util.Iterator v;
java.lang.Object v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixDataAccessor getDataAccssor(java.lang.String)>(v);
v = <com.fasterxml.jackson.databind.node.JsonNodeFactory: com.fasterxml.jackson.databind.node.JsonNodeFactory instance>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.node.JsonNodeFactory: com.fasterxml.jackson.databind.node.ObjectNode objectNode()>();
v = <org.apache.helix.rest.server.resources.AbstractResource$Properties: org.apache.helix.rest.server.resources.AbstractResource$Properties id>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.AbstractResource$Properties: java.lang.String name()>();
virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.node.ObjectNode put(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties new_messages>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.node.ArrayNode putArray(java.lang.String)>(v);
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties read_messages>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.node.ArrayNode putArray(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey messages(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: java.util.List getChildNames(org.apache.helix.PropertyKey)>(v);
if v == null goto label;
v = interfaceinvoke v.<java.util.List: int size()>();
if v != 0 goto label;
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unable to get any messages on instance: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response notFound()>();
return v;
label:
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey message(java.lang.String,java.lang.String)>(v, v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.HelixProperty getProperty(org.apache.helix.PropertyKey)>(v);
if v != null goto label;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object)>("Message is deleted given message name: ", v);
goto label;
label:
v = staticinvoke <org.eclipse.jetty.util.StringUtil: boolean isNotBlank(java.lang.String)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.helix.model.Message: java.lang.String getStateModelDef()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = <org.apache.helix.model.Message$MessageState: org.apache.helix.model.Message$MessageState NEW>;
v = virtualinvoke v.<org.apache.helix.model.Message: org.apache.helix.model.Message$MessageState getMsgState()>();
v = virtualinvoke v.<org.apache.helix.model.Message$MessageState: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
virtualinvoke v.<com.fasterxml.jackson.databind.node.ArrayNode: com.fasterxml.jackson.databind.node.ArrayNode add(java.lang.String)>(v);
goto label;
label:
v = <org.apache.helix.model.Message$MessageState: org.apache.helix.model.Message$MessageState READ>;
v = virtualinvoke v.<org.apache.helix.model.Message: org.apache.helix.model.Message$MessageState getMsgState()>();
v = virtualinvoke v.<org.apache.helix.model.Message$MessageState: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
virtualinvoke v.<com.fasterxml.jackson.databind.node.ArrayNode: com.fasterxml.jackson.databind.node.ArrayNode add(java.lang.String)>(v);
goto label;
label:
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties total_message_count>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.node.ArrayNode: int size()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.node.ArrayNode: int size()>();
v = v + v;
virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.node.ObjectNode put(java.lang.String,int)>(v, v);
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties read_message_count>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.node.ArrayNode: int size()>();
virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.node.ObjectNode put(java.lang.String,int)>(v, v);
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response JSONRepresentation(java.lang.Object)>(v);
return v;
}
public javax.ws.rs.core.Response getMessageOnInstance(java.lang.String, java.lang.String, java.lang.String) throws java.io.IOException
{
org.apache.helix.PropertyKey v;
org.apache.helix.PropertyKey$Builder v;
org.apache.helix.HelixDataAccessor v;
org.apache.helix.zookeeper.datamodel.ZNRecord v;
org.apache.helix.HelixProperty v;
javax.ws.rs.core.Response v, v;
java.lang.String v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixDataAccessor getDataAccssor(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey message(java.lang.String,java.lang.String)>(v, v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.HelixProperty getProperty(org.apache.helix.PropertyKey)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.helix.model.Message: org.apache.helix.zookeeper.datamodel.ZNRecord getRecord()>();
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response JSONRepresentation(java.lang.Object)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response notFound()>();
return v;
}
public javax.ws.rs.core.Response getHealthReportsOnInstance(java.lang.String, java.lang.String) throws java.io.IOException
{
org.apache.helix.PropertyKey v;
org.apache.helix.PropertyKey$Builder v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties v;
com.fasterxml.jackson.databind.node.ObjectNode v;
org.apache.helix.HelixDataAccessor v;
int v;
com.fasterxml.jackson.databind.JsonNode v;
java.lang.String v, v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
com.fasterxml.jackson.databind.ObjectMapper v;
org.apache.helix.rest.server.resources.AbstractResource$Properties v;
com.fasterxml.jackson.databind.node.ArrayNode v;
java.util.List v;
javax.ws.rs.core.Response v;
com.fasterxml.jackson.databind.node.JsonNodeFactory v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixDataAccessor getDataAccssor(java.lang.String)>(v);
v = <com.fasterxml.jackson.databind.node.JsonNodeFactory: com.fasterxml.jackson.databind.node.JsonNodeFactory instance>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.node.JsonNodeFactory: com.fasterxml.jackson.databind.node.ObjectNode objectNode()>();
v = <org.apache.helix.rest.server.resources.AbstractResource$Properties: org.apache.helix.rest.server.resources.AbstractResource$Properties id>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.AbstractResource$Properties: java.lang.String name()>();
virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.node.ObjectNode put(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties healthreports>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor$PerInstanceProperties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.node.ObjectNode: com.fasterxml.jackson.databind.node.ArrayNode putArray(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey healthReports(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: java.util.List getChildNames(org.apache.helix.PropertyKey)>(v);
if v == null goto label;
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 0 goto label;
v = <org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: com.fasterxml.jackson.databind.ObjectMapper OBJECT_MAPPER>;
v = virtualinvoke v.<com.fasterxml.jackson.databind.ObjectMapper: com.fasterxml.jackson.databind.JsonNode valueToTree(java.lang.Object)>(v);
virtualinvoke v.<com.fasterxml.jackson.databind.node.ArrayNode: com.fasterxml.jackson.databind.node.ArrayNode addAll(com.fasterxml.jackson.databind.node.ArrayNode)>(v);
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response JSONRepresentation(java.lang.Object)>(v);
return v;
}
public javax.ws.rs.core.Response getHealthReportsOnInstance(java.lang.String, java.lang.String, java.lang.String) throws java.io.IOException
{
org.apache.helix.PropertyKey v;
org.apache.helix.PropertyKey$Builder v;
org.apache.helix.HelixDataAccessor v;
org.apache.helix.HelixProperty v;
javax.ws.rs.core.Response v, v;
java.lang.String v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.apache.helix.HelixDataAccessor getDataAccssor(java.lang.String)>(v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.PropertyKey$Builder keyBuilder()>();
v = virtualinvoke v.<org.apache.helix.PropertyKey$Builder: org.apache.helix.PropertyKey healthReport(java.lang.String,java.lang.String)>(v, v);
v = interfaceinvoke v.<org.apache.helix.HelixDataAccessor: org.apache.helix.HelixProperty getProperty(org.apache.helix.PropertyKey)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response JSONRepresentation(java.lang.Object)>(v);
return v;
label:
v = virtualinvoke v.<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: javax.ws.rs.core.Response notFound()>();
return v;
}
private boolean validInstance(com.fasterxml.jackson.databind.JsonNode, java.lang.String)
{
org.apache.helix.rest.server.resources.AbstractResource$Properties v;
com.fasterxml.jackson.databind.JsonNode v, v;
java.lang.String v, v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
boolean v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: com.fasterxml.jackson.databind.JsonNode;
v := @parameter: java.lang.String;
v = <org.apache.helix.rest.server.resources.AbstractResource$Properties: org.apache.helix.rest.server.resources.AbstractResource$Properties id>;
v = virtualinvoke v.<org.apache.helix.rest.server.resources.AbstractResource$Properties: java.lang.String name()>();
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: com.fasterxml.jackson.databind.JsonNode get(java.lang.String)>(v);
v = virtualinvoke v.<com.fasterxml.jackson.databind.JsonNode: java.lang.String textValue()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
return v;
}
private boolean validateDeltaTopologySettingInInstanceConfig(java.lang.String, java.lang.String, org.apache.helix.ConfigAccessor, org.apache.helix.model.InstanceConfig, org.apache.helix.rest.server.resources.AbstractResource$Command)
{
java.util.Map v, v;
java.lang.String v, v;
org.apache.helix.rest.server.resources.helix.PerInstanceAccessor v;
boolean v, v;
java.util.Iterator v;
java.util.Set v;
org.apache.helix.model.InstanceConfig v, v;
org.apache.helix.rest.server.resources.AbstractResource$Command v, v;
org.apache.helix.zookeeper.datamodel.ZNRecord v, v, v, v;
org.apache.helix.ConfigAccessor v;
java.lang.Object v, v;
org.apache.helix.model.ClusterConfig v;
v := @this: org.apache.helix.rest.server.resources.helix.PerInstanceAccessor;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.helix.ConfigAccessor;
v := @parameter: org.apache.helix.model.InstanceConfig;
v := @parameter: org.apache.helix.rest.server.resources.AbstractResource$Command;
v = virtualinvoke v.<org.apache.helix.ConfigAccessor: org.apache.helix.model.InstanceConfig getInstanceConfig(java.lang.String,java.lang.String)>(v, v);
v = <org.apache.helix.rest.server.resources.AbstractResource$Command: org.apache.helix.rest.server.resources.AbstractResource$Command delete>;
if v != v goto label;
v = virtualinvoke v.<org.apache.helix.model.InstanceConfig: org.apache.helix.zookeeper.datamodel.ZNRecord getRecord()>();
v = virtualinvoke v.<org.apache.helix.zookeeper.datamodel.ZNRecord: java.util.Map getSimpleFields()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.helix.model.InstanceConfig: org.apache.helix.zookeeper.datamodel.ZNRecord getRecord()>();
v = virtualinvoke v.<org.apache.helix.zookeeper.datamodel.ZNRecord: java.util.Map getSimpleFields()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.helix.model.InstanceConfig: org.apache.helix.zookeeper.datamodel.ZNRecord getRecord()>();
v = virtualinvoke v.<org.apache.helix.model.InstanceConfig: org.apache.helix.zookeeper.datamodel.ZNRecord getRecord()>();
virtualinvoke v.<org.apache.helix.zookeeper.datamodel.ZNRecord: void update(org.apache.helix.zookeeper.datamodel.ZNRecord)>(v);
label:
v = virtualinvoke v.<org.apache.helix.ConfigAccessor: org.apache.helix.model.ClusterConfig getClusterConfig(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.helix.model.InstanceConfig: boolean validateTopologySettingInInstanceConfig(org.apache.helix.model.ClusterConfig,java.lang.String)>(v, v);
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/helix/rest/server/resources/helix/PerInstanceAccessor;");
<org.apache.helix.rest.server.resources.helix.PerInstanceAccessor: org.slf4j.Logger LOG> = v;
return;
}
}