public class org.apache.kafkaesque.clients.NetworkClient extends java.lang.Object implements org.apache.kafkaesque.clients.KafkaClient { private final org.slf4j.Logger log; private final org.apache.kafkaesque.common.network.Selectable selector; private final org.apache.kafkaesque.clients.MetadataUpdater metadataUpdater; private final java.util.Random randOffset; private final org.apache.kafkaesque.clients.ClusterConnectionStates connectionStates; private final org.apache.kafkaesque.clients.InFlightRequests inFlightRequests; private final int socketSendBuffer; private final int socketReceiveBuffer; private final java.lang.String clientId; private int correlation; private final int defaultRequestTimeoutMs; private final long reconnectBackoffMs; private final org.apache.kafkaesque.clients.ClientDnsLookup clientDnsLookup; private final org.apache.kafkaesque.common.utils.Time time; private final boolean discoverBrokerVersions; private final org.apache.kafkaesque.clients.ApiVersions apiVersions; private final java.util.Map nodesNeedingApiVersionsFetch; private final java.util.List abortedSends; private final org.apache.kafkaesque.common.metrics.Sensor throttleTimeSensor; private final java.util.concurrent.atomic.AtomicReference state; public void (org.apache.kafkaesque.common.network.Selectable, org.apache.kafkaesque.clients.Metadata, java.lang.String, int, long, long, int, int, int, org.apache.kafkaesque.clients.ClientDnsLookup, org.apache.kafkaesque.common.utils.Time, boolean, org.apache.kafkaesque.clients.ApiVersions, org.apache.kafkaesque.common.utils.LogContext) { org.apache.kafkaesque.common.utils.LogContext v; org.apache.kafkaesque.common.network.Selectable v; long v, v; org.apache.kafkaesque.clients.Metadata v; int v, v, v, v; org.apache.kafkaesque.common.utils.Time v; java.lang.String v; org.apache.kafkaesque.clients.ClientDnsLookup v; org.apache.kafkaesque.clients.ApiVersions v; org.apache.kafkaesque.clients.NetworkClient v; boolean v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.common.network.Selectable; v := @parameter: org.apache.kafkaesque.clients.Metadata; v := @parameter: java.lang.String; v := @parameter: int; v := @parameter: long; v := @parameter: long; v := @parameter: int; v := @parameter: int; v := @parameter: int; v := @parameter: org.apache.kafkaesque.clients.ClientDnsLookup; v := @parameter: org.apache.kafkaesque.common.utils.Time; v := @parameter: boolean; v := @parameter: org.apache.kafkaesque.clients.ApiVersions; v := @parameter: org.apache.kafkaesque.common.utils.LogContext; specialinvoke v.(org.apache.kafkaesque.clients.MetadataUpdater,org.apache.kafkaesque.clients.Metadata,org.apache.kafkaesque.common.network.Selectable,java.lang.String,int,long,long,int,int,int,org.apache.kafkaesque.clients.ClientDnsLookup,org.apache.kafkaesque.common.utils.Time,boolean,org.apache.kafkaesque.clients.ApiVersions,org.apache.kafkaesque.common.metrics.Sensor,org.apache.kafkaesque.common.utils.LogContext)>(null, v, v, v, v, v, v, v, v, v, v, v, v, v, null, v); return; } public void (org.apache.kafkaesque.common.network.Selectable, org.apache.kafkaesque.clients.Metadata, java.lang.String, int, long, long, int, int, int, org.apache.kafkaesque.clients.ClientDnsLookup, org.apache.kafkaesque.common.utils.Time, boolean, org.apache.kafkaesque.clients.ApiVersions, org.apache.kafkaesque.common.metrics.Sensor, org.apache.kafkaesque.common.utils.LogContext) { org.apache.kafkaesque.common.metrics.Sensor v; org.apache.kafkaesque.common.utils.LogContext v; org.apache.kafkaesque.common.network.Selectable v; long v, v; org.apache.kafkaesque.clients.Metadata v; int v, v, v, v; org.apache.kafkaesque.common.utils.Time v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; boolean v; org.apache.kafkaesque.clients.ClientDnsLookup v; org.apache.kafkaesque.clients.ApiVersions v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.common.network.Selectable; v := @parameter: org.apache.kafkaesque.clients.Metadata; v := @parameter: java.lang.String; v := @parameter: int; v := @parameter: long; v := @parameter: long; v := @parameter: int; v := @parameter: int; v := @parameter: int; v := @parameter: org.apache.kafkaesque.clients.ClientDnsLookup; v := @parameter: org.apache.kafkaesque.common.utils.Time; v := @parameter: boolean; v := @parameter: org.apache.kafkaesque.clients.ApiVersions; v := @parameter: org.apache.kafkaesque.common.metrics.Sensor; v := @parameter: org.apache.kafkaesque.common.utils.LogContext; specialinvoke v.(org.apache.kafkaesque.clients.MetadataUpdater,org.apache.kafkaesque.clients.Metadata,org.apache.kafkaesque.common.network.Selectable,java.lang.String,int,long,long,int,int,int,org.apache.kafkaesque.clients.ClientDnsLookup,org.apache.kafkaesque.common.utils.Time,boolean,org.apache.kafkaesque.clients.ApiVersions,org.apache.kafkaesque.common.metrics.Sensor,org.apache.kafkaesque.common.utils.LogContext)>(null, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v); return; } public void (org.apache.kafkaesque.common.network.Selectable, org.apache.kafkaesque.clients.MetadataUpdater, java.lang.String, int, long, long, int, int, int, org.apache.kafkaesque.clients.ClientDnsLookup, org.apache.kafkaesque.common.utils.Time, boolean, org.apache.kafkaesque.clients.ApiVersions, org.apache.kafkaesque.common.utils.LogContext) { org.apache.kafkaesque.common.utils.LogContext v; org.apache.kafkaesque.common.network.Selectable v; org.apache.kafkaesque.clients.MetadataUpdater v; long v, v; int v, v, v, v; org.apache.kafkaesque.common.utils.Time v; java.lang.String v; org.apache.kafkaesque.clients.ClientDnsLookup v; org.apache.kafkaesque.clients.ApiVersions v; org.apache.kafkaesque.clients.NetworkClient v; boolean v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.common.network.Selectable; v := @parameter: org.apache.kafkaesque.clients.MetadataUpdater; v := @parameter: java.lang.String; v := @parameter: int; v := @parameter: long; v := @parameter: long; v := @parameter: int; v := @parameter: int; v := @parameter: int; v := @parameter: org.apache.kafkaesque.clients.ClientDnsLookup; v := @parameter: org.apache.kafkaesque.common.utils.Time; v := @parameter: boolean; v := @parameter: org.apache.kafkaesque.clients.ApiVersions; v := @parameter: org.apache.kafkaesque.common.utils.LogContext; specialinvoke v.(org.apache.kafkaesque.clients.MetadataUpdater,org.apache.kafkaesque.clients.Metadata,org.apache.kafkaesque.common.network.Selectable,java.lang.String,int,long,long,int,int,int,org.apache.kafkaesque.clients.ClientDnsLookup,org.apache.kafkaesque.common.utils.Time,boolean,org.apache.kafkaesque.clients.ApiVersions,org.apache.kafkaesque.common.metrics.Sensor,org.apache.kafkaesque.common.utils.LogContext)>(v, null, v, v, v, v, v, v, v, v, v, v, v, v, null, v); return; } private void (org.apache.kafkaesque.clients.MetadataUpdater, org.apache.kafkaesque.clients.Metadata, org.apache.kafkaesque.common.network.Selectable, java.lang.String, int, long, long, int, int, int, org.apache.kafkaesque.clients.ClientDnsLookup, org.apache.kafkaesque.common.utils.Time, boolean, org.apache.kafkaesque.clients.ApiVersions, org.apache.kafkaesque.common.metrics.Sensor, org.apache.kafkaesque.common.utils.LogContext) { org.apache.kafkaesque.common.metrics.Sensor v; org.apache.kafkaesque.common.utils.LogContext v; org.apache.kafkaesque.clients.NetworkClient$DefaultMetadataUpdater v; org.apache.kafkaesque.common.network.Selectable v; org.apache.kafkaesque.clients.MetadataUpdater v; java.util.HashMap v; java.util.Random v; long v, v; java.util.concurrent.atomic.AtomicReference v; org.apache.kafkaesque.clients.Metadata v; org.apache.kafkaesque.clients.InFlightRequests v; int v, v, v, v; org.apache.kafkaesque.common.utils.Time v; java.lang.String v; java.util.LinkedList v; org.apache.kafkaesque.clients.NetworkClient v; boolean v; org.slf4j.Logger v; java.lang.IllegalArgumentException v; org.apache.kafkaesque.clients.ClusterConnectionStates v; org.apache.kafkaesque.clients.ClientDnsLookup v; org.apache.kafkaesque.clients.ApiVersions v; org.apache.kafkaesque.clients.NetworkClient$State v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.clients.MetadataUpdater; v := @parameter: org.apache.kafkaesque.clients.Metadata; v := @parameter: org.apache.kafkaesque.common.network.Selectable; v := @parameter: java.lang.String; v := @parameter: int; v := @parameter: long; v := @parameter: long; v := @parameter: int; v := @parameter: int; v := @parameter: int; v := @parameter: org.apache.kafkaesque.clients.ClientDnsLookup; v := @parameter: org.apache.kafkaesque.common.utils.Time; v := @parameter: boolean; v := @parameter: org.apache.kafkaesque.clients.ApiVersions; v := @parameter: org.apache.kafkaesque.common.metrics.Sensor; v := @parameter: org.apache.kafkaesque.common.utils.LogContext; specialinvoke v.()>(); v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.LinkedList; specialinvoke v.()>(); v. = v; if v != null goto label; if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("`metadata` must not be null"); throw v; label: v = new org.apache.kafkaesque.clients.NetworkClient$DefaultMetadataUpdater; specialinvoke v.(org.apache.kafkaesque.clients.NetworkClient,org.apache.kafkaesque.clients.Metadata)>(v, v); v. = v; goto label; label: v. = v; label: v. = v; v. = v; v = new org.apache.kafkaesque.clients.InFlightRequests; specialinvoke v.(int)>(v); v. = v; v = new org.apache.kafkaesque.clients.ClusterConnectionStates; specialinvoke v.(long,long,org.apache.kafkaesque.common.utils.LogContext)>(v, v, v); v. = v; v. = v; v. = v; v. = 0; v = new java.util.Random; specialinvoke v.()>(); v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v. = v; v = virtualinvoke v.(class "Lorg/apache/kafkaesque/clients/NetworkClient;"); v. = v; v. = v; v = new java.util.concurrent.atomic.AtomicReference; v = ; specialinvoke v.(java.lang.Object)>(v); v. = v; return; } public boolean ready(org.apache.kafkaesque.common.Node, long) { long v; java.lang.IllegalArgumentException v; org.apache.kafkaesque.common.Node v; org.apache.kafkaesque.clients.ClusterConnectionStates v; java.lang.String v, v; org.apache.kafkaesque.clients.NetworkClient v; boolean v, v, v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.common.Node; v := @parameter: long; v = virtualinvoke v.(); if v == 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot connect to empty node \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(v, v); if v == 0 goto label; return 1; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); if v == 0 goto label; specialinvoke v.(v, v); label: return 0; } boolean canConnect(org.apache.kafkaesque.common.Node, long) { org.apache.kafkaesque.common.Node v; org.apache.kafkaesque.clients.ClusterConnectionStates v; long v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; boolean v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.common.Node; v := @parameter: long; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); return v; } public void disconnect(java.lang.String) { org.slf4j.Logger v, v; org.apache.kafkaesque.common.network.Selectable v; long v; java.util.List v; org.apache.kafkaesque.clients.InFlightRequests v; org.apache.kafkaesque.clients.ClusterConnectionStates v, v; org.apache.kafkaesque.common.utils.Time v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; boolean v, v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: java.lang.String; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; return; label: v = v.; interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); v = v.; specialinvoke v.(v, v, v); v = v.; virtualinvoke v.(v, v); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = v.; interfaceinvoke v.("Manually disconnected from {}. Aborted in-flight requests: {}.", v, v); label: return; } private void cancelInFlightRequests(java.lang.String, long, java.util.Collection) { java.lang.Object[] v; org.apache.kafkaesque.clients.MetadataUpdater v; long v; org.apache.kafkaesque.common.protocol.ApiKeys v, v, v; java.lang.Integer v; java.lang.Iterable v; org.apache.kafkaesque.common.requests.AbstractRequest v; org.apache.kafkaesque.clients.InFlightRequests v; int v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; boolean v, v; org.slf4j.Logger v; java.util.Iterator v; java.util.Collection v; org.apache.kafkaesque.clients.ClientResponse v; org.apache.kafkaesque.common.requests.RequestHeader v, v, v; java.util.Optional v; java.lang.Object v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: java.lang.String; v := @parameter: long; v := @parameter: java.util.Collection; v = v.; v = virtualinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = newarray (java.lang.Object)[4]; v = v.; v = virtualinvoke v.(); v[0] = v; v = v.; v[1] = v; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; v[3] = v; interfaceinvoke v.("Cancelled request {} {} with correlation id {} due to node {} being disconnected", v); v = v.; if v != 0 goto label; if v == null goto label; v = virtualinvoke v.(v, null); interfaceinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); v = ; if v != v goto label; v = v.; v = staticinvoke (); interfaceinvoke v.(v, v); goto label; label: return; } public void close(java.lang.String) { org.apache.kafkaesque.common.network.Selectable v; org.apache.kafkaesque.clients.ClusterConnectionStates v; long v; org.apache.kafkaesque.common.utils.Time v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: java.lang.String; v = v.; interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); specialinvoke v.(v, v, null); v = v.; virtualinvoke v.(v); return; } public long connectionDelay(org.apache.kafkaesque.common.Node, long) { org.apache.kafkaesque.common.Node v; org.apache.kafkaesque.clients.ClusterConnectionStates v; long v, v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.common.Node; v := @parameter: long; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); return v; } public long throttleDelayMs(org.apache.kafkaesque.common.Node, long) { org.apache.kafkaesque.common.Node v; org.apache.kafkaesque.clients.ClusterConnectionStates v; long v, v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.common.Node; v := @parameter: long; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); return v; } public long pollDelayMs(org.apache.kafkaesque.common.Node, long) { org.apache.kafkaesque.common.Node v; org.apache.kafkaesque.clients.ClusterConnectionStates v; long v, v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.common.Node; v := @parameter: long; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); return v; } public boolean connectionFailed(org.apache.kafkaesque.common.Node) { org.apache.kafkaesque.common.Node v; org.apache.kafkaesque.clients.ClusterConnectionStates v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; boolean v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.common.Node; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; } public org.apache.kafkaesque.common.errors.AuthenticationException authenticationException(org.apache.kafkaesque.common.Node) { org.apache.kafkaesque.common.Node v; org.apache.kafkaesque.clients.ClusterConnectionStates v; org.apache.kafkaesque.common.errors.AuthenticationException v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.common.Node; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); return v; } public boolean isReady(org.apache.kafkaesque.common.Node, long) { org.apache.kafkaesque.clients.MetadataUpdater v; long v; org.apache.kafkaesque.common.Node v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; boolean v, v, v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.common.Node; v := @parameter: long; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; v = virtualinvoke v.(); v = specialinvoke v.(v, v); if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } private boolean canSendRequest(java.lang.String, long) { org.apache.kafkaesque.common.network.Selectable v; long v; org.apache.kafkaesque.clients.InFlightRequests v; org.apache.kafkaesque.clients.ClusterConnectionStates v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; boolean v, v, v, v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: java.lang.String; v := @parameter: long; v = v.; v = virtualinvoke v.(v, v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public void send(org.apache.kafkaesque.clients.ClientRequest, long) { org.apache.kafkaesque.clients.ClientRequest v; long v; org.apache.kafkaesque.clients.NetworkClient v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.clients.ClientRequest; v := @parameter: long; specialinvoke v.(v, 0, v); return; } void sendInternalMetadataRequest(org.apache.kafkaesque.common.requests.MetadataRequest$Builder, java.lang.String, long) { org.apache.kafkaesque.clients.ClientRequest v; org.apache.kafkaesque.common.requests.MetadataRequest$Builder v; long v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.common.requests.MetadataRequest$Builder; v := @parameter: java.lang.String; v := @parameter: long; v = virtualinvoke v.(v, v, v, 1); specialinvoke v.(v, 1, v); return; } private void doSend(org.apache.kafkaesque.clients.ClientRequest, boolean, long) { java.lang.IllegalStateException v; org.apache.kafkaesque.common.protocol.ApiKeys v, v, v, v; java.lang.Integer v, v; org.apache.kafkaesque.clients.ClientRequest v; java.lang.Short v; org.apache.kafkaesque.clients.NodeApiVersions v; org.apache.kafkaesque.clients.NetworkClient v; boolean v, v, v, v; org.apache.kafkaesque.clients.ClientResponse v; org.apache.kafkaesque.common.requests.AbstractRequest$Builder v; java.util.List v; java.util.Optional v; org.apache.kafkaesque.clients.ApiVersions v; java.lang.Object[] v, v; org.apache.kafkaesque.clients.MetadataUpdater v; org.apache.kafkaesque.clients.RequestCompletionHandler v; long v; org.apache.kafkaesque.common.requests.AbstractRequest v; short v, v, v, v; int v, v; java.lang.String v, v, v, v; org.slf4j.Logger v, v, v; org.apache.kafkaesque.common.errors.UnsupportedVersionException v; org.apache.kafkaesque.common.requests.RequestHeader v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.clients.ClientRequest; v := @parameter: boolean; v := @parameter: long; specialinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = specialinvoke v.(v, v); if v != 0 goto label; v = new java.lang.IllegalStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempt to send a request to node \u which is not ready."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(v); if v != null goto label; v = virtualinvoke v.(); v = v.; if v == 0 goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = newarray (java.lang.Object)[4]; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[1] = v; v[2] = v; v = staticinvoke (v); v[3] = v; interfaceinvoke v.("No version information found when sending {} with correlation id {} to node {}. Assuming version {}.", v); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v, v); label: v = virtualinvoke v.(v); specialinvoke v.(v, v, v, v); label: goto label; label: v := @caughtexception; v = v.; v = newarray (java.lang.Object)[4]; v[0] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[1] = v; v = virtualinvoke v.(); v[2] = v; v[3] = v; interfaceinvoke v.("Version mismatch when attempting to send {} with correlation id {} to {}", v); v = new org.apache.kafkaesque.clients.ClientResponse; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(org.apache.kafkaesque.common.requests.RequestHeader,org.apache.kafkaesque.clients.RequestCompletionHandler,java.lang.String,long,long,boolean,org.apache.kafkaesque.common.errors.UnsupportedVersionException,org.apache.kafkaesque.common.errors.AuthenticationException,org.apache.kafkaesque.common.requests.AbstractResponse)>(v, v, v, v, v, 0, v, null, null); if v != 0 goto label; v = v.; interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = ; if v != v goto label; v = v.; v = staticinvoke (v); interfaceinvoke v.(v, v); label: return; catch org.apache.kafkaesque.common.errors.UnsupportedVersionException from label to label with label; } private void doSend(org.apache.kafkaesque.clients.ClientRequest, boolean, long, org.apache.kafkaesque.common.requests.AbstractRequest) { java.lang.Object[] v, v; org.apache.kafkaesque.common.network.Selectable v; long v; org.apache.kafkaesque.common.protocol.ApiKeys v, v, v; java.lang.Integer v, v; org.apache.kafkaesque.common.requests.AbstractRequest v; org.apache.kafkaesque.clients.ClientRequest v; short v, v, v, v; java.lang.Short v; org.apache.kafkaesque.clients.InFlightRequests v; int v, v; org.apache.kafkaesque.clients.NetworkClient$InFlightRequest v; org.apache.kafkaesque.common.network.Send v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; boolean v, v; org.slf4j.Logger v, v, v; org.apache.kafkaesque.common.requests.RequestHeader v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.clients.ClientRequest; v := @parameter: boolean; v := @parameter: long; v := @parameter: org.apache.kafkaesque.common.requests.AbstractRequest; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != v goto label; v = v.; v = newarray (java.lang.Object)[4]; v = virtualinvoke v.(); v[0] = v; v[1] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; v[3] = v; interfaceinvoke v.("Sending {} {} with correlation id {} to node {}", v); goto label; label: v = v.; v = newarray (java.lang.Object)[5]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = virtualinvoke v.(); v[1] = v; v[2] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[3] = v; v[4] = v; interfaceinvoke v.("Using older server API v{} to send {} {} with correlation id {} to node {}", v); label: v = virtualinvoke v.(v, v); v = new org.apache.kafkaesque.clients.NetworkClient$InFlightRequest; specialinvoke v.(org.apache.kafkaesque.clients.ClientRequest,org.apache.kafkaesque.common.requests.RequestHeader,boolean,org.apache.kafkaesque.common.requests.AbstractRequest,org.apache.kafkaesque.common.network.Send,long)>(v, v, v, v, v, v); v = v.; virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); return; } public java.util.List poll(long, long) { org.apache.kafkaesque.common.network.Selectable v; org.apache.kafkaesque.clients.MetadataUpdater v; long v, v, v, v, v; java.util.ArrayList v, v; long[] v; int v; org.apache.kafkaesque.common.utils.Time v; org.apache.kafkaesque.clients.NetworkClient v; boolean v; org.slf4j.Logger v; java.io.IOException v; java.util.List v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: long; v := @parameter: long; specialinvoke v.(); v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = new java.util.ArrayList; specialinvoke v.()>(); specialinvoke v.(v); specialinvoke v.(v); return v; label: v = v.; v = interfaceinvoke v.(v); label: v = v.; v = newarray (long)[2]; v[0] = v; v = v.; v[1] = v; v = staticinvoke (v, v); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.("Unexpected error during I/O", v); label: v = v.; v = interfaceinvoke v.(); v = new java.util.ArrayList; specialinvoke v.()>(); specialinvoke v.(v, v); specialinvoke v.(v, v); specialinvoke v.(v, v); specialinvoke v.(); specialinvoke v.(v); specialinvoke v.(v, v); specialinvoke v.(v); return v; catch java.io.IOException from label to label with label; } private void completeResponses(java.util.List) { java.util.List v; org.slf4j.Logger v; java.util.Iterator v; java.lang.Object v; org.apache.kafkaesque.clients.NetworkClient v; java.lang.Exception v; boolean v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: java.util.List; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.("Uncaught error in request completion:", v); goto label; label: return; catch java.lang.Exception from label to label with label; } public int inFlightRequestCount() { int v; org.apache.kafkaesque.clients.NetworkClient v; org.apache.kafkaesque.clients.InFlightRequests v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v = v.; v = virtualinvoke v.(); return v; } public boolean hasInFlightRequests() { org.apache.kafkaesque.clients.InFlightRequests v; org.apache.kafkaesque.clients.NetworkClient v; boolean v, v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public int inFlightRequestCount(java.lang.String) { org.apache.kafkaesque.clients.InFlightRequests v; int v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: java.lang.String; v = v.; v = virtualinvoke v.(v); return v; } public boolean hasInFlightRequests(java.lang.String) { org.apache.kafkaesque.clients.InFlightRequests v; java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; boolean v, v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: java.lang.String; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public boolean hasReadyNodes(long) { org.apache.kafkaesque.clients.ClusterConnectionStates v; long v; org.apache.kafkaesque.clients.NetworkClient v; boolean v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: long; v = v.; v = virtualinvoke v.(v); return v; } public void wakeup() { org.apache.kafkaesque.clients.NetworkClient v; org.apache.kafkaesque.common.network.Selectable v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v = v.; interfaceinvoke v.(); return; } public void initiateClose() { org.apache.kafkaesque.clients.NetworkClient v; org.apache.kafkaesque.clients.NetworkClient$State v, v; java.util.concurrent.atomic.AtomicReference v; boolean v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v = v.; v = ; v = ; v = virtualinvoke v.(v, v); if v == 0 goto label; virtualinvoke v.(); label: return; } public boolean active() { java.lang.Object v; org.apache.kafkaesque.clients.NetworkClient v; org.apache.kafkaesque.clients.NetworkClient$State v; java.util.concurrent.atomic.AtomicReference v; boolean v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v = v.; v = virtualinvoke v.(); v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: return v; } private void ensureActive() { java.lang.String v; org.apache.kafkaesque.clients.NetworkClient v; java.util.concurrent.atomic.AtomicReference v; org.apache.kafkaesque.common.errors.DisconnectException v; boolean v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v = virtualinvoke v.(); if v != 0 goto label; v = new org.apache.kafkaesque.common.errors.DisconnectException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("NetworkClient is no longer active, state is \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } public void close() { org.slf4j.Logger v; org.apache.kafkaesque.common.network.Selectable v; org.apache.kafkaesque.clients.MetadataUpdater v; java.util.concurrent.atomic.AtomicReference v, v; org.apache.kafkaesque.clients.NetworkClient v; org.apache.kafkaesque.clients.NetworkClient$State v, v, v, v; boolean v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v = v.; v = ; v = ; virtualinvoke v.(v, v); v = v.; v = ; v = ; v = virtualinvoke v.(v, v); if v == 0 goto label; v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(); goto label; label: v = v.; interfaceinvoke v.("Attempting to close NetworkClient that has already been closed."); label: return; } public org.apache.kafkaesque.common.Node leastLoadedNode(long) { java.lang.IllegalStateException v; java.util.Random v; java.lang.Integer v; org.apache.kafkaesque.clients.InFlightRequests v; org.apache.kafkaesque.clients.NetworkClient v; boolean v, v, v, v; java.util.List v; org.apache.kafkaesque.clients.ClusterConnectionStates v; org.apache.kafkaesque.clients.MetadataUpdater v; long v; org.apache.kafkaesque.common.Node v, v, v; int v, v, v, v, v, v, v, v, v; java.lang.String v, v, v; org.slf4j.Logger v, v, v, v, v, v; java.lang.Object v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: long; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("There are no nodes in the Kafka cluster"); throw v; label: v = 2147483647; v = null; v = null; v = null; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = 0; label: v = interfaceinvoke v.(); if v >= v goto label; v = v + v; v = interfaceinvoke v.(); v = v % v; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = specialinvoke v.(v, v); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; v = v.; interfaceinvoke v.("Found least loaded node {} connected with no in-flight requests", v); return v; label: if v >= v goto label; v = v; v = v; goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = v; goto label; label: v = virtualinvoke v.(v, v); if v == 0 goto label; v = v; goto label; label: v = v.; interfaceinvoke v.("Removing node {} from least loaded node selection since it is neither ready for sending or connecting", v); label: v = v + 1; goto label; label: if v == null goto label; v = v.; v = staticinvoke (v); interfaceinvoke v.("Found least loaded node {} with {} inflight requests", v, v); return v; label: if v == null goto label; v = v.; interfaceinvoke v.("Found least loaded connecting node {}", v); return v; label: if v == null goto label; v = v.; interfaceinvoke v.("Found least loaded node {} with no active connection", v); return v; label: v = v.; interfaceinvoke v.("Least loaded node selection failed to find an available node"); return null; } public static org.apache.kafkaesque.common.requests.AbstractResponse parseResponse(java.nio.ByteBuffer, org.apache.kafkaesque.common.requests.RequestHeader) { org.apache.kafkaesque.common.requests.RequestHeader v; org.apache.kafkaesque.common.protocol.ApiKeys v; java.nio.BufferUnderflowException v; java.nio.ByteBuffer v; org.apache.kafkaesque.common.protocol.types.Struct v; short v; org.apache.kafkaesque.common.protocol.types.SchemaException v; java.lang.String v; org.apache.kafkaesque.common.requests.AbstractResponse v; v := @parameter: java.nio.ByteBuffer; v := @parameter: org.apache.kafkaesque.common.requests.RequestHeader; label: v = staticinvoke (v, v, null, 0L); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v, v); label: return v; label: v := @caughtexception; v = new org.apache.kafkaesque.common.protocol.types.SchemaException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Buffer underflow while parsing response for request with header \u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; catch java.nio.BufferUnderflowException from label to label with label; } private static org.apache.kafkaesque.common.protocol.types.Struct parseStructMaybeUpdateThrottleTimeMetrics(java.nio.ByteBuffer, org.apache.kafkaesque.common.requests.RequestHeader, org.apache.kafkaesque.common.metrics.Sensor, long) { org.apache.kafkaesque.common.metrics.Sensor v; long v; org.apache.kafkaesque.common.protocol.ApiKeys v, v; java.lang.Integer v; org.apache.kafkaesque.common.requests.ResponseHeader v; java.nio.ByteBuffer v; short v, v, v; int v; boolean v; org.apache.kafkaesque.common.protocol.types.Field$Int v, v; org.apache.kafkaesque.common.requests.RequestHeader v; org.apache.kafkaesque.common.protocol.types.Struct v; v := @parameter: java.nio.ByteBuffer; v := @parameter: org.apache.kafkaesque.common.requests.RequestHeader; v := @parameter: org.apache.kafkaesque.common.metrics.Sensor; v := @parameter: long; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = staticinvoke (v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v); staticinvoke (v, v); if v == null goto label; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = ; v = virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v, v); label: return v; } private void processDisconnection(java.util.List, java.lang.String, long, org.apache.kafkaesque.common.network.ChannelState) { java.lang.Object[] v; org.apache.kafkaesque.clients.MetadataUpdater v; long v; org.apache.kafkaesque.common.network.ChannelState v; int[] v; java.util.Map v; int v, v; java.lang.String v, v, v, v, v; org.apache.kafkaesque.clients.NetworkClient v; org.slf4j.Logger v, v, v; org.apache.kafkaesque.common.errors.AuthenticationException v, v; java.util.List v; java.util.Optional v; org.apache.kafkaesque.clients.ClusterConnectionStates v, v; org.apache.kafkaesque.common.network.ChannelState$State v; org.apache.kafkaesque.clients.ApiVersions v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: java.util.List; v := @parameter: java.lang.String; v := @parameter: long; v := @parameter: org.apache.kafkaesque.common.network.ChannelState; v = v.; virtualinvoke v.(v, v); v = v.; virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; default: goto label; }; label: v = virtualinvoke v.(); v = v.; virtualinvoke v.(v, v, v); v = v.; v = newarray (java.lang.Object)[3]; v[0] = v; v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Connection to node {} ({}) failed authentication due to: {}", v); goto label; label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.("Connection to node {} ({}) terminated during authentication. This may happen due to any of the following reasons: (1) Authentication failed due to invalid credentials with brokers older than 1.0.0, (2) Firewall blocking Kafka TLS traffic (eg it may only allow HTTPS traffic), (3) Transient network issue.", v, v); goto label; label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.("Connection to node {} ({}) could not be established. Broker may not be available.", v, v); label: specialinvoke v.(v, v, v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v, v); return; } private void handleTimedOutRequests(java.util.List, long) { org.slf4j.Logger v; java.util.Iterator v; org.apache.kafkaesque.common.network.Selectable v; long v; org.apache.kafkaesque.common.network.ChannelState v; java.util.List v, v; org.apache.kafkaesque.clients.InFlightRequests v; java.lang.Object v; org.apache.kafkaesque.clients.NetworkClient v; boolean v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: java.util.List; v := @parameter: long; v = v.; v = virtualinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.("Disconnecting from node {} due to request timeout.", v); v = ; specialinvoke v.(v, v, v, v); goto label; label: return; } private void handleAbortedSends(java.util.List) { java.util.List v, v, v; org.apache.kafkaesque.clients.NetworkClient v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: java.util.List; v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); return; } private void handleCompletedSends(java.util.List, long) { java.util.Iterator v; org.apache.kafkaesque.common.network.Selectable v; org.apache.kafkaesque.clients.ClientResponse v; long v; java.util.List v, v; org.apache.kafkaesque.clients.InFlightRequests v, v; org.apache.kafkaesque.clients.NetworkClient$InFlightRequest v; java.lang.Object v; java.lang.String v, v; org.apache.kafkaesque.clients.NetworkClient v; boolean v, v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: java.util.List; v := @parameter: long; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); v = v.; if v != 0 goto label; v = v.; v = interfaceinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(null, v); interfaceinvoke v.(v); goto label; label: return; } private void maybeThrottle(org.apache.kafkaesque.common.requests.AbstractResponse, short, java.lang.String, long) { java.lang.Object[] v; org.slf4j.Logger v; long v, v, v; java.lang.Integer v; short v; java.lang.Long v; int v; org.apache.kafkaesque.clients.ClusterConnectionStates v; java.lang.String v; org.apache.kafkaesque.common.requests.AbstractResponse v; org.apache.kafkaesque.clients.NetworkClient v; boolean v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: org.apache.kafkaesque.common.requests.AbstractResponse; v := @parameter: short; v := @parameter: java.lang.String; v := @parameter: long; v = virtualinvoke v.(); if v <= 0 goto label; v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = v + v; virtualinvoke v.(v, v); v = v.; v = newarray (java.lang.Object)[3]; v[0] = v; v = staticinvoke (v); v[1] = v; v = v + v; v = staticinvoke (v); v[2] = v; interfaceinvoke v.("Connection to node {} is throttled for {} ms until timestamp {}", v); label: return; } private void handleCompletedReceives(java.util.List, long) { org.apache.kafkaesque.common.network.Selectable v; org.apache.kafkaesque.common.protocol.ApiKeys v, v; java.lang.Integer v; java.nio.ByteBuffer v; org.apache.kafkaesque.clients.InFlightRequests v; org.apache.kafkaesque.clients.NetworkClient$InFlightRequest v; org.apache.kafkaesque.clients.NetworkClient v; boolean v, v, v, v, v, v; java.util.Collection v; org.apache.kafkaesque.clients.ClientResponse v; java.util.List v; org.apache.kafkaesque.common.metrics.Sensor v; java.lang.Object[] v; org.apache.kafkaesque.clients.MetadataUpdater v; long v; short v, v; int v; java.lang.String v, v, v; org.slf4j.Logger v, v; java.util.Iterator v; org.apache.kafkaesque.common.requests.RequestHeader v, v, v, v, v, v, v; org.apache.kafkaesque.common.protocol.types.Struct v; java.lang.Object v; org.apache.kafkaesque.common.requests.AbstractResponse v; v := @this: org.apache.kafkaesque.clients.NetworkClient; v := @parameter: java.util.List; v := @parameter: long; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = v.; v = v.; v = staticinvoke (v, v, v, v); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = newarray (java.lang.Object)[4]; v = v.; v[0] = v; v = v.; v = virtualinvoke v.(); v[1] = v; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; v[3] = v; interfaceinvoke v.("Completed receive from node {} for {} with correlation id {}, received {}", v); label: v = v.; v = virtualinvoke v.