public class org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient extends java.lang.Object implements java.io.Closeable
{
private static final int MAX_POLL_TIMEOUT_MS;
private final org.slf4j.Logger log;
private final org.apache.kafkaesqueesqueesque.clients.KafkaClient client;
private final org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests unsent;
private final org.apache.kafkaesqueesqueesque.clients.Metadata metadata;
private final org.apache.kafkaesqueesqueesque.common.utils.Time time;
private final long retryBackoffMs;
private final int maxPollTimeoutMs;
private final int requestTimeoutMs;
private final java.util.concurrent.atomic.AtomicBoolean wakeupDisabled;
private final java.util.concurrent.locks.ReentrantLock lock;
private final java.util.concurrent.ConcurrentLinkedQueue pendingCompletion;
private final java.util.concurrent.ConcurrentLinkedQueue pendingDisconnects;
private final java.util.concurrent.atomic.AtomicBoolean wakeup;
public void <init>(org.apache.kafkaesqueesqueesque.common.utils.LogContext, org.apache.kafkaesqueesqueesque.clients.KafkaClient, org.apache.kafkaesqueesqueesque.clients.Metadata, org.apache.kafkaesqueesqueesque.common.utils.Time, long, int, int)
{
org.apache.kafkaesqueesqueesque.clients.Metadata v;
java.util.concurrent.atomic.AtomicBoolean v, v;
long v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
int v, v, v;
org.slf4j.Logger v;
java.util.concurrent.locks.ReentrantLock v;
org.apache.kafkaesqueesqueesque.common.utils.LogContext v;
org.apache.kafkaesqueesqueesque.common.utils.Time v;
java.util.concurrent.ConcurrentLinkedQueue v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.utils.LogContext;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.KafkaClient;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.Metadata;
v := @parameter: org.apache.kafkaesqueesqueesque.common.utils.Time;
v := @parameter: long;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests unsent> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.atomic.AtomicBoolean wakeupDisabled> = v;
v = new java.util.concurrent.locks.ReentrantLock;
specialinvoke v.<java.util.concurrent.locks.ReentrantLock: void <init>(boolean)>(1);
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock> = v;
v = new java.util.concurrent.ConcurrentLinkedQueue;
specialinvoke v.<java.util.concurrent.ConcurrentLinkedQueue: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.ConcurrentLinkedQueue pendingCompletion> = v;
v = new java.util.concurrent.ConcurrentLinkedQueue;
specialinvoke v.<java.util.concurrent.ConcurrentLinkedQueue: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.ConcurrentLinkedQueue pendingDisconnects> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.atomic.AtomicBoolean wakeup> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.LogContext: org.slf4j.Logger logger(java.lang.Class)>(class "Lorg/apache/kafkaesqueesqueesque/clients/consumer/internals/ConsumerNetworkClient;");
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.slf4j.Logger log> = v;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client> = v;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.Metadata metadata> = v;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.common.utils.Time time> = v;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: long retryBackoffMs> = v;
v = staticinvoke <java.lang.Math: int min(int,int)>(v, 5000);
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: int maxPollTimeoutMs> = v;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: int requestTimeoutMs> = v;
return;
}
public org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFuture send(org.apache.kafkaesqueesqueesque.common.Node, org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest$Builder)
{
org.apache.kafkaesqueesqueesque.common.Node v;
org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest$Builder v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
int v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFuture v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.Node;
v := @parameter: org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest$Builder;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: int requestTimeoutMs>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFuture send(org.apache.kafkaesqueesqueesque.common.Node,org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest$Builder,int)>(v, v, v);
return v;
}
public org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFuture send(org.apache.kafkaesqueesqueesque.common.Node, org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest$Builder, int)
{
org.apache.kafkaesqueesqueesque.common.Node v;
org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest$Builder v;
org.apache.kafkaesqueesqueesque.clients.ClientRequest v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFuture v;
long v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
int v;
java.lang.String v;
org.apache.kafkaesqueesqueesque.common.utils.Time v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.Node;
v := @parameter: org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest$Builder;
v := @parameter: int;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Time: long milliseconds()>();
v = new org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: void <init>(org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient)>(v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.Node: java.lang.String idString()>();
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: org.apache.kafkaesqueesqueesque.clients.ClientRequest newClientRequest(java.lang.String,org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest$Builder,long,boolean,int,org.apache.kafkaesqueesqueesque.clients.RequestCompletionHandler)>(v, v, v, 1, v, v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests unsent>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests: void put(org.apache.kafkaesqueesqueesque.common.Node,org.apache.kafkaesqueesqueesque.clients.ClientRequest)>(v, v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: void wakeup()>();
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFuture future>;
return v;
}
public org.apache.kafkaesqueesqueesque.common.Node leastLoadedNode()
{
java.lang.Throwable v;
org.apache.kafkaesqueesqueesque.common.Node v;
java.util.concurrent.locks.ReentrantLock v, v, v;
long v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
org.apache.kafkaesqueesqueesque.common.utils.Time v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Time: long milliseconds()>();
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: org.apache.kafkaesqueesqueesque.common.Node leastLoadedNode(long)>(v);
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
return v;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
public boolean hasReadyNodes(long)
{
java.lang.Throwable v;
java.util.concurrent.locks.ReentrantLock v, v, v;
long v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: long;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: boolean hasReadyNodes(long)>(v);
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
return v;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
public boolean awaitMetadataUpdate(org.apache.kafkaesqueesqueesque.common.utils.Timer)
{
org.apache.kafkaesqueesqueesque.clients.Metadata v, v, v;
org.apache.kafkaesqueesqueesque.common.utils.Timer v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
int v, v, v;
boolean v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.utils.Timer;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.Metadata metadata>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.Metadata: int requestUpdate()>();
label:
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: void poll(org.apache.kafkaesqueesqueesque.common.utils.Timer)>(v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.Metadata metadata>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.Metadata: int updateVersion()>();
if v != v goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Timer: boolean notExpired()>();
if v != 0 goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.Metadata metadata>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.Metadata: int updateVersion()>();
if v <= v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
boolean ensureFreshMetadata(org.apache.kafkaesqueesqueesque.common.utils.Timer)
{
org.apache.kafkaesqueesqueesque.clients.Metadata v, v;
long v, v;
org.apache.kafkaesqueesqueesque.common.utils.Timer v;
byte v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
boolean v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.utils.Timer;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.Metadata metadata>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.Metadata: boolean updateRequested()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.Metadata metadata>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Timer: long currentTimeMs()>();
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.Metadata: long timeToNextUpdate(long)>(v);
v = v cmp 0L;
if v != 0 goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: boolean awaitMetadataUpdate(org.apache.kafkaesqueesqueesque.common.utils.Timer)>(v);
return v;
label:
return 1;
}
public void wakeup()
{
org.slf4j.Logger v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Received user wakeup");
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.atomic.AtomicBoolean wakeup>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(1);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: void wakeup()>();
return;
}
public void poll(org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFuture)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFuture v;
org.apache.kafkaesqueesqueesque.common.utils.Time v;
org.apache.kafkaesqueesqueesque.common.utils.Timer v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFuture;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFuture: boolean isDone()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Time: org.apache.kafkaesqueesqueesque.common.utils.Timer timer(long)>(9223372036854775807L);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: void poll(org.apache.kafkaesqueesqueesque.common.utils.Timer,org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$PollCondition)>(v, v);
goto label;
label:
return;
}
public boolean poll(org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFuture, org.apache.kafkaesqueesqueesque.common.utils.Timer)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFuture v;
org.apache.kafkaesqueesqueesque.common.utils.Timer v;
boolean v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFuture;
v := @parameter: org.apache.kafkaesqueesqueesque.common.utils.Timer;
label:
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: void poll(org.apache.kafkaesqueesqueesque.common.utils.Timer,org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$PollCondition)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFuture: boolean isDone()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Timer: boolean notExpired()>();
if v != 0 goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFuture: boolean isDone()>();
return v;
}
public void poll(org.apache.kafkaesqueesqueesque.common.utils.Timer)
{
org.apache.kafkaesqueesqueesque.common.utils.Timer v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.utils.Timer;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: void poll(org.apache.kafkaesqueesqueesque.common.utils.Timer,org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$PollCondition)>(v, null);
return;
}
public void poll(org.apache.kafkaesqueesqueesque.common.utils.Timer, org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$PollCondition)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$PollCondition v;
org.apache.kafkaesqueesqueesque.common.utils.Timer v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.utils.Timer;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$PollCondition;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: void poll(org.apache.kafkaesqueesqueesque.common.utils.Timer,org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$PollCondition,boolean)>(v, v, 0);
return;
}
public void poll(org.apache.kafkaesqueesqueesque.common.utils.Timer, org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$PollCondition, boolean)
{
java.lang.Throwable v;
org.apache.kafkaesqueesqueesque.clients.Metadata v;
long v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.utils.Timer v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v, v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
int v;
boolean v, v, v;
java.util.concurrent.locks.ReentrantLock v, v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$PollCondition v;
java.util.concurrent.ConcurrentLinkedQueue v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.utils.Timer;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$PollCondition;
v := @parameter: boolean;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: void firePendingCompletedRequests()>();
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: void handlePendingDisconnects()>();
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Timer: long currentTimeMs()>();
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: long trySend(long)>(v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.ConcurrentLinkedQueue pendingCompletion>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentLinkedQueue: boolean isEmpty()>();
if v == 0 goto label;
if v == null goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$PollCondition: boolean shouldBlock()>();
if v == 0 goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Timer: long remainingMs()>();
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: int inFlightRequestCount()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: long retryBackoffMs>;
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Timer: long currentTimeMs()>();
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: java.util.List poll(long,long)>(v, v);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Timer: long currentTimeMs()>();
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: java.util.List poll(long,long)>(0L, v);
label:
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Timer: void update()>();
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Timer: long currentTimeMs()>();
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: void checkDisconnects(long)>(v);
if v != 0 goto label;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: void maybeTriggerWakeup()>();
label:
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: void maybeThrowInterruptException()>();
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Timer: long currentTimeMs()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: long trySend(long)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Timer: long currentTimeMs()>();
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: void failExpiredRequests(long)>(v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests unsent>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests: void clean()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
label:
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: void firePendingCompletedRequests()>();
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.Metadata metadata>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.Metadata: void maybeThrowAnyException()>();
return;
catch java.lang.Throwable from label to label with label;
}
public void pollNoWakeup()
{
org.apache.kafkaesqueesqueesque.common.utils.Time v;
org.apache.kafkaesqueesqueesque.common.utils.Timer v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Time: org.apache.kafkaesqueesqueesque.common.utils.Timer timer(long)>(0L);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: void poll(org.apache.kafkaesqueesqueesque.common.utils.Timer,org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$PollCondition,boolean)>(v, null, 1);
return;
}
public void transmitSends()
{
java.lang.Throwable v;
java.util.concurrent.locks.ReentrantLock v, v, v;
long v, v;
org.apache.kafkaesqueesqueesque.common.utils.Timer v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
org.apache.kafkaesqueesqueesque.common.utils.Time v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Time: org.apache.kafkaesqueesqueesque.common.utils.Timer timer(long)>(0L);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Timer: long currentTimeMs()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: long trySend(long)>(v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Timer: long currentTimeMs()>();
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: java.util.List poll(long,long)>(0L, v);
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public boolean awaitPendingRequests(org.apache.kafkaesqueesqueesque.common.Node, org.apache.kafkaesqueesqueesque.common.utils.Timer)
{
org.apache.kafkaesqueesqueesque.common.Node v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
org.apache.kafkaesqueesqueesque.common.utils.Timer v;
boolean v, v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.Node;
v := @parameter: org.apache.kafkaesqueesqueesque.common.utils.Timer;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: boolean hasPendingRequests(org.apache.kafkaesqueesqueesque.common.Node)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Timer: boolean notExpired()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: void poll(org.apache.kafkaesqueesqueesque.common.utils.Timer)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: boolean hasPendingRequests(org.apache.kafkaesqueesqueesque.common.Node)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public int pendingRequestCount(org.apache.kafkaesqueesqueesque.common.Node)
{
java.lang.Throwable v;
org.apache.kafkaesqueesqueesque.common.Node v;
java.util.concurrent.locks.ReentrantLock v, v, v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
int v, v, v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.Node;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests unsent>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests: int requestCount(org.apache.kafkaesqueesqueesque.common.Node)>(v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.Node: java.lang.String idString()>();
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: int inFlightRequestCount(java.lang.String)>(v);
v = v + v;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
return v;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
public boolean hasPendingRequests(org.apache.kafkaesqueesqueesque.common.Node)
{
java.lang.Throwable v;
org.apache.kafkaesqueesqueesque.common.Node v;
java.util.concurrent.locks.ReentrantLock v, v, v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
java.lang.String v;
boolean v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.Node;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests unsent>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests: boolean hasRequests(org.apache.kafkaesqueesqueesque.common.Node)>(v);
if v == 0 goto label;
return 1;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.Node: java.lang.String idString()>();
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: boolean hasInFlightRequests(java.lang.String)>(v);
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
return v;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
public int pendingRequestCount()
{
java.lang.Throwable v;
java.util.concurrent.locks.ReentrantLock v, v, v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
int v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests unsent>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests: int requestCount()>();
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: int inFlightRequestCount()>();
v = v + v;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
return v;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
public boolean hasPendingRequests()
{
java.lang.Throwable v;
java.util.concurrent.locks.ReentrantLock v, v, v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
boolean v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests unsent>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests: boolean hasRequests()>();
if v == 0 goto label;
return 1;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: boolean hasInFlightRequests()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
return v;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
private void firePendingCompletedRequests()
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
java.lang.Object v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v;
boolean v;
java.util.concurrent.ConcurrentLinkedQueue v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v = 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.ConcurrentLinkedQueue pendingCompletion>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentLinkedQueue: java.lang.Object poll()>();
if v == null goto label;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: void fireCompletion()>();
v = 1;
goto label;
label:
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: void wakeup()>();
label:
return;
}
private void checkDisconnects(long)
{
long v, v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests v, v;
short v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
java.lang.String v;
boolean v, v, v;
org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest$Builder v;
java.util.Iterator v, v;
java.util.Collection v, v;
org.apache.kafkaesqueesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesqueesque.clients.ClientResponse v;
java.lang.Object v, v;
org.apache.kafkaesqueesqueesque.common.errors.AuthenticationException v;
org.apache.kafkaesqueesqueesque.clients.RequestCompletionHandler v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: long;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests unsent>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests: java.util.Collection nodes()>();
v = interfaceinvoke v.<java.util.Collection: 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 = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: boolean connectionFailed(org.apache.kafkaesqueesqueesque.common.Node)>(v);
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests unsent>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests: java.util.Collection remove(org.apache.kafkaesqueesqueesque.common.Node)>(v);
v = interfaceinvoke v.<java.util.Collection: 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.kafkaesqueesqueesque.clients.ClientRequest: org.apache.kafkaesqueesqueesque.clients.RequestCompletionHandler callback()>();
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: org.apache.kafkaesqueesqueesque.common.errors.AuthenticationException authenticationException(org.apache.kafkaesqueesqueesque.common.Node)>(v);
v = new org.apache.kafkaesqueesqueesque.clients.ClientResponse;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.ClientRequest: org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest$Builder requestBuilder()>();
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest$Builder: short latestAllowedVersion()>();
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.ClientRequest: org.apache.kafkaesqueesqueesque.common.requests.RequestHeader makeHeader(short)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.ClientRequest: org.apache.kafkaesqueesqueesque.clients.RequestCompletionHandler callback()>();
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.ClientRequest: java.lang.String destination()>();
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.ClientRequest: long createdTimeMs()>();
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.ClientResponse: void <init>(org.apache.kafkaesqueesqueesque.common.requests.RequestHeader,org.apache.kafkaesqueesqueesque.clients.RequestCompletionHandler,java.lang.String,long,long,boolean,org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException,org.apache.kafkaesqueesqueesque.common.errors.AuthenticationException,org.apache.kafkaesqueesqueesque.common.requests.AbstractResponse)>(v, v, v, v, v, 1, null, v, null);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: void onComplete(org.apache.kafkaesqueesqueesque.clients.ClientResponse)>(v);
goto label;
label:
return;
}
private void handlePendingDisconnects()
{
java.lang.Throwable v;
org.apache.kafkaesqueesqueesque.common.errors.DisconnectException v;
java.util.concurrent.locks.ReentrantLock v, v, v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
java.lang.Object v;
java.lang.String v;
java.util.concurrent.ConcurrentLinkedQueue v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.ConcurrentLinkedQueue pendingDisconnects>;
v = virtualinvoke v.<java.util.concurrent.ConcurrentLinkedQueue: java.lang.Object poll()>();
if v == null goto label;
v = <org.apache.kafkaesqueesqueesque.common.errors.DisconnectException: org.apache.kafkaesqueesqueesque.common.errors.DisconnectException INSTANCE>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: void failUnsentRequests(org.apache.kafkaesqueesqueesque.common.Node,java.lang.RuntimeException)>(v, v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.Node: java.lang.String idString()>();
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: void disconnect(java.lang.String)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void disconnectAsync(org.apache.kafkaesqueesqueesque.common.Node)
{
org.apache.kafkaesqueesqueesque.common.Node v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v;
java.util.concurrent.ConcurrentLinkedQueue v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.Node;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.ConcurrentLinkedQueue pendingDisconnects>;
virtualinvoke v.<java.util.concurrent.ConcurrentLinkedQueue: boolean offer(java.lang.Object)>(v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: void wakeup()>();
return;
}
private void failExpiredRequests(long)
{
java.util.Iterator v;
java.util.Collection v;
long v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
org.apache.kafkaesqueesqueesque.common.errors.TimeoutException v;
int v;
java.lang.Object v;
java.lang.String v;
org.apache.kafkaesqueesqueesque.clients.RequestCompletionHandler v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: long;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests unsent>;
v = specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests: java.util.Collection removeExpiredRequests(long)>(v);
v = interfaceinvoke v.<java.util.Collection: 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.kafkaesqueesqueesque.clients.ClientRequest: org.apache.kafkaesqueesqueesque.clients.RequestCompletionHandler callback()>();
v = new org.apache.kafkaesqueesqueesque.common.errors.TimeoutException;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.ClientRequest: int requestTimeoutMs()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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 send request after \u ms.");
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.errors.TimeoutException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: void onFailure(java.lang.RuntimeException)>(v);
goto label;
label:
return;
}
private void failUnsentRequests(org.apache.kafkaesqueesqueesque.common.Node, java.lang.RuntimeException)
{
java.lang.Throwable v;
org.apache.kafkaesqueesqueesque.common.Node v;
java.util.Iterator v;
java.util.concurrent.locks.ReentrantLock v, v, v;
java.util.Collection v;
java.lang.RuntimeException v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
java.lang.Object v;
org.apache.kafkaesqueesqueesque.clients.RequestCompletionHandler v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.Node;
v := @parameter: java.lang.RuntimeException;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests unsent>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests: java.util.Collection remove(org.apache.kafkaesqueesqueesque.common.Node)>(v);
v = interfaceinvoke v.<java.util.Collection: 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.kafkaesqueesqueesque.clients.ClientRequest: org.apache.kafkaesqueesqueesque.clients.RequestCompletionHandler callback()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler: void onFailure(java.lang.RuntimeException)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
long trySend(long)
{
long v, v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v, v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
int v;
boolean v, v, v, v;
java.util.Iterator v, v;
java.util.Collection v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: long;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: int maxPollTimeoutMs>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests unsent>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests: java.util.Collection nodes()>();
v = interfaceinvoke v.<java.util.Collection: 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 = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests unsent>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient$UnsentRequests: java.util.Iterator requestIterator(org.apache.kafkaesqueesqueesque.common.Node)>(v);
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: long pollDelayMs(org.apache.kafkaesqueesqueesque.common.Node,long)>(v, v);
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
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 = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: boolean ready(org.apache.kafkaesqueesqueesque.common.Node,long)>(v, v);
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: void send(org.apache.kafkaesqueesqueesque.clients.ClientRequest,long)>(v, v);
interfaceinvoke v.<java.util.Iterator: void remove()>();
goto label;
label:
return v;
}
public void maybeTriggerWakeup()
{
org.slf4j.Logger v;
java.util.concurrent.atomic.AtomicBoolean v, v, v;
org.apache.kafkaesqueesqueesque.common.errors.WakeupException v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
boolean v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.atomic.AtomicBoolean wakeupDisabled>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.atomic.AtomicBoolean wakeup>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Raising WakeupException in response to user wakeup");
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.atomic.AtomicBoolean wakeup>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
v = new org.apache.kafkaesqueesqueesque.common.errors.WakeupException;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.errors.WakeupException: void <init>()>();
throw v;
label:
return;
}
private void maybeThrowInterruptException()
{
java.lang.InterruptedException v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
org.apache.kafkaesqueesqueesque.common.errors.InterruptException v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v = staticinvoke <java.lang.Thread: boolean interrupted()>();
if v == 0 goto label;
v = new org.apache.kafkaesqueesqueesque.common.errors.InterruptException;
v = new java.lang.InterruptedException;
specialinvoke v.<java.lang.InterruptedException: void <init>()>();
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.errors.InterruptException: void <init>(java.lang.InterruptedException)>(v);
throw v;
label:
return;
}
public void disableWakeups()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.atomic.AtomicBoolean wakeupDisabled>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(1);
return;
}
public void close() throws java.io.IOException
{
java.lang.Throwable v;
java.util.concurrent.locks.ReentrantLock v, v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: void close()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public boolean isUnavailable(org.apache.kafkaesqueesqueesque.common.Node)
{
java.lang.Throwable v;
org.apache.kafkaesqueesqueesque.common.Node v;
java.util.concurrent.locks.ReentrantLock v, v, v;
long v, v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v, v;
byte v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
org.apache.kafkaesqueesqueesque.common.utils.Time v;
boolean v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.Node;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: boolean connectionFailed(org.apache.kafkaesqueesqueesque.common.Node)>(v);
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Time: long milliseconds()>();
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: long connectionDelay(org.apache.kafkaesqueesqueesque.common.Node,long)>(v, v);
v = v cmp 0L;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
return v;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
catch java.lang.Throwable from label to label with label;
}
public void maybeThrowAuthFailure(org.apache.kafkaesqueesqueesque.common.Node)
{
java.lang.Throwable v;
org.apache.kafkaesqueesqueesque.common.Node v;
java.util.concurrent.locks.ReentrantLock v, v, v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
org.apache.kafkaesqueesqueesque.common.errors.AuthenticationException v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.Node;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: org.apache.kafkaesqueesqueesque.common.errors.AuthenticationException authenticationException(org.apache.kafkaesqueesqueesque.common.Node)>(v);
if v == null goto label;
throw v;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void tryConnect(org.apache.kafkaesqueesqueesque.common.Node)
{
java.lang.Throwable v;
org.apache.kafkaesqueesqueesque.common.Node v;
java.util.concurrent.locks.ReentrantLock v, v, v;
long v;
org.apache.kafkaesqueesqueesque.clients.KafkaClient v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient v;
org.apache.kafkaesqueesqueesque.common.utils.Time v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient;
v := @parameter: org.apache.kafkaesqueesqueesque.common.Node;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void lock()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.clients.KafkaClient client>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: org.apache.kafkaesqueesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Time: long milliseconds()>();
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.KafkaClient: boolean ready(org.apache.kafkaesqueesqueesque.common.Node,long)>(v, v);
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerNetworkClient: java.util.concurrent.locks.ReentrantLock lock>;
virtualinvoke v.<java.util.concurrent.locks.ReentrantLock: void unlock()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
}