class org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler extends org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$TxnRequestHandler
{
private final org.apache.kafkaesqueesqueesque.common.requests.AddPartitionsToTxnRequest$Builder builder;
private long retryBackoffMs;
final org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager this$0;
private void <init>(org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager, org.apache.kafkaesqueesqueesque.common.requests.AddPartitionsToTxnRequest$Builder)
{
org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler v;
org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager v;
long v;
org.apache.kafkaesqueesqueesque.common.requests.AddPartitionsToTxnRequest$Builder v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager;
v := @parameter: org.apache.kafkaesqueesqueesque.common.requests.AddPartitionsToTxnRequest$Builder;
v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager this$0> = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$TxnRequestHandler: void <init>(org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager,java.lang.String)>(v, "AddPartitionsToTxn");
v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: org.apache.kafkaesqueesqueesque.common.requests.AddPartitionsToTxnRequest$Builder builder> = v;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager: long retryBackoffMs>;
v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: long retryBackoffMs> = v;
return;
}
org.apache.kafkaesqueesqueesque.common.requests.AddPartitionsToTxnRequest$Builder requestBuilder()
{
org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler v;
org.apache.kafkaesqueesqueesque.common.requests.AddPartitionsToTxnRequest$Builder v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: org.apache.kafkaesqueesqueesque.common.requests.AddPartitionsToTxnRequest$Builder builder>;
return v;
}
org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$Priority priority()
{
org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler v;
org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$Priority v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler;
v = <org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$Priority: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$Priority ADD_PARTITIONS_OR_OFFSETS>;
return v;
}
public void handleResponse(org.apache.kafkaesqueesqueesque.common.requests.AbstractResponse)
{
org.apache.kafkaesqueesqueesque.common.protocol.Errors v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.errors.ApiException v, v, v, v;
org.apache.kafkaesqueesqueesque.common.requests.AbstractResponse v;
java.util.Map v;
boolean v, v, v;
org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.common.KafkaException v, v;
java.util.Set v, v, v, v;
org.apache.kafkaesqueesqueesque.common.errors.TopicAuthorizationException v;
long v;
java.util.HashSet v;
java.lang.String v, v, v;
org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler v;
org.slf4j.Logger v, v, v;
java.util.Iterator v;
org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionalRequestResult v;
java.lang.Object v, v, v;
org.apache.kafkaesqueesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler;
v := @parameter: org.apache.kafkaesqueesqueesque.common.requests.AbstractResponse;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.requests.AddPartitionsToTxnResponse: java.util.Map errors()>();
v = 0;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager: long retryBackoffMs>;
v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: long retryBackoffMs> = v;
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 = <org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.protocol.Errors NONE>;
if v == v goto label;
v = <org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.protocol.Errors COORDINATOR_NOT_AVAILABLE>;
if v == v goto label;
v = <org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.protocol.Errors NOT_COORDINATOR>;
if v != v goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager this$0>;
v = <org.apache.kafkaesqueesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType: org.apache.kafkaesqueesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType TRANSACTION>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager: java.lang.String transactionalId>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager: void lookupCoordinator(org.apache.kafkaesqueesqueesque.common.requests.FindCoordinatorRequest$CoordinatorType,java.lang.String)>(v, v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: void reenqueue()>();
return;
label:
v = <org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.protocol.Errors CONCURRENT_TRANSACTIONS>;
if v != v goto label;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: void maybeOverrideRetryBackoffMs()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: void reenqueue()>();
return;
label:
v = <org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.protocol.Errors COORDINATOR_LOAD_IN_PROGRESS>;
if v == v goto label;
v = <org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.protocol.Errors UNKNOWN_TOPIC_OR_PARTITION>;
if v != v goto label;
label:
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: void reenqueue()>();
return;
label:
v = <org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.protocol.Errors INVALID_PRODUCER_EPOCH>;
if v != v goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.errors.ApiException exception()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: void fatalError(java.lang.RuntimeException)>(v);
return;
label:
v = <org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.protocol.Errors TRANSACTIONAL_ID_AUTHORIZATION_FAILED>;
if v != v goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.errors.ApiException exception()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: void fatalError(java.lang.RuntimeException)>(v);
return;
label:
v = <org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.protocol.Errors INVALID_TXN_STATE>;
if v != v goto label;
v = new org.apache.kafkaesqueesqueesque.common.KafkaException;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.errors.ApiException exception()>();
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.KafkaException: void <init>(java.lang.Throwable)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: void fatalError(java.lang.RuntimeException)>(v);
return;
label:
v = <org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.protocol.Errors TOPIC_AUTHORIZATION_FAILED>;
if v != v goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.TopicPartition: java.lang.String topic()>();
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.protocol.Errors OPERATION_NOT_ATTEMPTED>;
if v != v goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Did not attempt to add partition {} to transaction because other partitions in the batch had errors.", v);
v = 1;
goto label;
label:
v = <org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.protocol.Errors UNKNOWN_PRODUCER_ID>;
if v == v goto label;
v = <org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.protocol.Errors INVALID_PRODUCER_ID_MAPPING>;
if v != v goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Errors: org.apache.kafkaesqueesqueesque.common.errors.ApiException exception()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: void abortableErrorIfPossible(java.lang.RuntimeException)>(v);
return;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Could not add partition {} due to unexpected error {}", v, v);
v = 1;
goto label;
label:
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager: java.util.Set pendingPartitionsInTransaction>;
interfaceinvoke v.<java.util.Set: boolean removeAll(java.util.Collection)>(v);
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v != 0 goto label;
v = new org.apache.kafkaesqueesqueesque.common.errors.TopicAuthorizationException;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.errors.TopicAuthorizationException: void <init>(java.util.Set)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: void abortableError(java.lang.RuntimeException)>(v);
goto label;
label:
if v == 0 goto label;
v = new org.apache.kafkaesqueesqueesque.common.KafkaException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.util.Map)>(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[])>("Could not add partitions to transaction due to errors: \u0001");
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.KafkaException: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: void abortableError(java.lang.RuntimeException)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager: org.slf4j.Logger log>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Successfully added partitions {} to transaction", v);
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager: java.util.Set partitionsInTransaction>;
interfaceinvoke v.<java.util.Set: boolean addAll(java.util.Collection)>(v);
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager this$0>;
v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager: boolean transactionStarted> = 1;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionalRequestResult result>;
virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionalRequestResult: void done()>();
label:
return;
}
public long retryBackoffMs()
{
org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler v;
org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager v;
long v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager: long retryBackoffMs>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: long retryBackoffMs>;
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
return v;
}
private void maybeOverrideRetryBackoffMs()
{
org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler v;
org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager v;
java.util.Set v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager this$0>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager: java.util.Set partitionsInTransaction>;
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v == 0 goto label;
v.<org.apache.kafkaesqueesqueesque.clients.producer.internals.TransactionManager$AddPartitionsToTxnHandler: long retryBackoffMs> = 20L;
label:
return;
}
}