class org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3 extends java.lang.Object implements org.apache.kafkaesqueesque.clients.consumer.internals.RequestFutureListener
{
final java.util.Map val$fetchPostitions;
final org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher this$0;
void <init>(org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher, java.util.Map)
{
org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3 v;
org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3;
v := @parameter: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher;
v := @parameter: java.util.Map;
v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher this$0> = v;
v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3: java.util.Map val$fetchPostitions> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void onSuccess(org.apache.kafkaesqueesque.clients.consumer.internals.OffsetsForLeaderEpochClient$OffsetForEpochResult)
{
org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata v;
java.util.HashMap v;
long v, v, v;
org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3 v;
org.apache.kafkaesqueesque.common.utils.Time v;
java.util.Map v, v;
java.util.function.BiConsumer v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
boolean v, v;
java.util.Set v, v;
org.apache.kafkaesqueesque.clients.consumer.LogTruncationException v;
org.apache.kafkaesqueesque.clients.consumer.internals.OffsetsForLeaderEpochClient$OffsetForEpochResult v;
org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v, v, v, v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3;
v := @parameter: org.apache.kafkaesqueesque.clients.consumer.internals.OffsetsForLeaderEpochClient$OffsetForEpochResult;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.OffsetsForLeaderEpochClient$OffsetForEpochResult: java.util.Set partitionsToRetry()>();
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.OffsetsForLeaderEpochClient$OffsetForEpochResult: java.util.Set partitionsToRetry()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher: long retryBackoffMs>;
v = v + v;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void setNextAllowedRetry(java.util.Set,long)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher: org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata metadata>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata: int requestUpdate()>();
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.OffsetsForLeaderEpochClient$OffsetForEpochResult: java.util.Map endOffsets()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3: java.util.Map val$fetchPostitions>;
v = staticinvoke <org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3$lambda_onSuccess_1__184: java.util.function.BiConsumer bootstrap$(org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3,java.util.Map,java.util.Map)>(v, v, v);
interfaceinvoke v.<java.util.Map: void forEach(java.util.function.BiConsumer)>(v);
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v != 0 goto label;
v = new org.apache.kafkaesqueesque.clients.consumer.LogTruncationException;
specialinvoke v.<org.apache.kafkaesqueesque.clients.consumer.LogTruncationException: void <init>(java.util.Map)>(v);
throw v;
label:
return;
}
public void onFailure(java.lang.RuntimeException)
{
org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata v;
long v, v, v;
org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3 v;
java.util.concurrent.atomic.AtomicReference v;
org.apache.kafkaesqueesque.common.utils.Time v;
java.util.Map v;
org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState v;
boolean v, v;
org.slf4j.Logger v;
java.util.Set v;
java.lang.RuntimeException v;
org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3;
v := @parameter: java.lang.RuntimeException;
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher: org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState subscriptions>;
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3: java.util.Map val$fetchPostitions>;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher: org.apache.kafkaesqueesque.common.utils.Time time>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.utils.Time: long milliseconds()>();
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher: long retryBackoffMs>;
v = v + v;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.SubscriptionState: void requestFailed(java.util.Set,long)>(v, v);
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher: org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata metadata>;
virtualinvoke v.<org.apache.kafkaesqueesque.clients.consumer.internals.ConsumerMetadata: int requestUpdate()>();
v = v instanceof org.apache.kafkaesqueesque.common.errors.RetriableException;
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher$3: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher: java.util.concurrent.atomic.AtomicReference cachedOffsetForLeaderException>;
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.kafkaesqueesque.clients.consumer.internals.Fetcher$3: org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher this$0>;
v = v.<org.apache.kafkaesqueesque.clients.consumer.internals.Fetcher: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Discarding error in OffsetsForLeaderEpoch because another error is pending", v);
label:
return;
}
}