class org.apache.kafkaesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider extends java.lang.Object implements org.apache.kafkaesque.clients.admin.KafkaAdminClient$NodeProvider
{
final org.apache.kafkaesque.clients.admin.KafkaAdminClient this$0;
private void <init>(org.apache.kafkaesque.clients.admin.KafkaAdminClient)
{
org.apache.kafkaesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
org.apache.kafkaesque.clients.admin.KafkaAdminClient v;
v := @this: org.apache.kafkaesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
v := @parameter: org.apache.kafkaesque.clients.admin.KafkaAdminClient;
v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: org.apache.kafkaesque.clients.admin.KafkaAdminClient this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public org.apache.kafkaesque.common.Node provide()
{
org.apache.kafkaesque.clients.admin.KafkaAdminClient v, v, v, v;
long v;
org.apache.kafkaesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider v;
org.apache.kafkaesque.clients.admin.internals.AdminMetadataManager v, v;
org.apache.kafkaesque.clients.KafkaClient v;
org.apache.kafkaesque.common.Node v;
org.apache.kafkaesque.common.utils.Time v;
boolean v;
v := @this: org.apache.kafkaesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider;
v = v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: org.apache.kafkaesque.clients.admin.KafkaAdminClient this$0>;
v = v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient: org.apache.kafkaesque.clients.admin.internals.AdminMetadataManager metadataManager>;
v = virtualinvoke v.<org.apache.kafkaesque.clients.admin.internals.AdminMetadataManager: boolean isReady()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: org.apache.kafkaesque.clients.admin.KafkaAdminClient this$0>;
v = v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient: org.apache.kafkaesque.clients.KafkaClient client>;
v = v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: org.apache.kafkaesque.clients.admin.KafkaAdminClient this$0>;
v = v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient: org.apache.kafkaesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesque.common.utils.Time: long milliseconds()>();
v = interfaceinvoke v.<org.apache.kafkaesque.clients.KafkaClient: org.apache.kafkaesque.common.Node leastLoadedNode(long)>(v);
return v;
label:
v = v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient$LeastLoadedNodeProvider: org.apache.kafkaesque.clients.admin.KafkaAdminClient this$0>;
v = v.<org.apache.kafkaesque.clients.admin.KafkaAdminClient: org.apache.kafkaesque.clients.admin.internals.AdminMetadataManager metadataManager>;
virtualinvoke v.<org.apache.kafkaesque.clients.admin.internals.AdminMetadataManager: void requestUpdate()>();
return null;
}
}