class org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2 extends java.lang.Object implements org.apache.kafkaesqueesqueesque.clients.consumer.internals.RequestFutureListener
{
final java.util.Map val$resetTimestamps;
final org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher this$0;
void <init>(org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher, java.util.Map)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2 v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher;
v := @parameter: java.util.Map;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher this$0> = v;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: java.util.Map val$resetTimestamps> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void onSuccess(org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$ListOffsetResult)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerMetadata v;
long v, v, v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2 v;
java.util.Map v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.OffsetResetStrategy v;
boolean v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$ListOffsetResult v;
java.util.Iterator v;
java.util.Set v, v, v;
java.lang.Object v, v, v, v;
org.apache.kafkaesqueesqueesque.common.utils.Time v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$ListOffsetResult;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$ListOffsetResult: java.util.Set partitionsToRetry>;
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$ListOffsetResult: java.util.Set partitionsToRetry>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher: org.apache.kafkaesqueesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher: long retryBackoffMs>;
v = v + v;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState: void requestFailed(java.util.Set,long)>(v, v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerMetadata metadata>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerMetadata: int requestUpdate()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$ListOffsetResult: java.util.Map fetchedOffsets>;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: java.util.Map val$resetTimestamps>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesqueesque.common.requests.ListOffsetRequest$PartitionData: long timestamp>;
v = specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher: org.apache.kafkaesqueesqueesque.clients.consumer.OffsetResetStrategy timestampToOffsetResetStrategy(long)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher: void resetOffsetIfNeeded(org.apache.kafkaesqueesqueesque.common.TopicPartition,org.apache.kafkaesqueesqueesque.clients.consumer.OffsetResetStrategy,org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$ListOffsetData)>(v, v, v);
goto label;
label:
return;
}
public void onFailure(java.lang.RuntimeException)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerMetadata v;
long v, v, v;
java.util.concurrent.atomic.AtomicReference v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2 v;
java.util.Map v;
boolean v, v;
org.slf4j.Logger v;
java.util.Set v;
java.lang.RuntimeException v;
org.apache.kafkaesqueesqueesque.common.utils.Time v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2;
v := @parameter: java.lang.RuntimeException;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: java.util.Map val$resetTimestamps>;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher: org.apache.kafkaesqueesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher: long retryBackoffMs>;
v = v + v;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState: void requestFailed(java.util.Set,long)>(v, v);
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher: org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerMetadata metadata>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.ConsumerMetadata: int requestUpdate()>();
v = v instanceof org.apache.kafkaesqueesqueesque.common.errors.RetriableException;
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher: java.util.concurrent.atomic.AtomicReference cachedListOffsetsException>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: boolean compareAndSet(java.lang.Object,java.lang.Object)>(null, v);
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher$2: org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.Fetcher: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Discarding error in ListOffsetResponse because another error is pending", v);
label:
return;
}
}