public class org.apache.kafkaesque.clients.producer.internals.TransactionManager extends java.lang.Object { private static final int NO_INFLIGHT_REQUEST_CORRELATION_ID; private static final int NO_LAST_ACKED_SEQUENCE_NUMBER; private final org.slf4j.Logger log; private final java.lang.String transactionalId; private final int transactionTimeoutMs; private final org.apache.kafkaesque.clients.ApiVersions apiVersions; private final org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper topicPartitionBookkeeper; private final java.util.Map pendingTxnOffsetCommits; private final java.util.Map partitionsWithUnresolvedSequences; private final java.util.Set partitionsToRewriteSequences; private final java.util.PriorityQueue pendingRequests; private final java.util.Set newPartitionsInTransaction; private final java.util.Set pendingPartitionsInTransaction; private final java.util.Set partitionsInTransaction; private org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult pendingResult; private final long retryBackoffMs; private static final long ADD_PARTITIONS_RETRY_BACKOFF_MS; private int inFlightRequestCorrelationId; private org.apache.kafkaesque.common.Node transactionCoordinator; private org.apache.kafkaesque.common.Node consumerGroupCoordinator; private boolean coordinatorSupportsBumpingEpoch; private volatile org.apache.kafkaesque.clients.producer.internals.TransactionManager$State currentState; private volatile java.lang.RuntimeException lastError; private volatile org.apache.kafkaesque.common.utils.ProducerIdAndEpoch producerIdAndEpoch; private volatile boolean transactionStarted; private volatile boolean epochBumpRequired; public void (org.apache.kafkaesque.common.utils.LogContext, java.lang.String, int, long, org.apache.kafkaesque.clients.ApiVersions) { org.apache.kafkaesque.common.utils.LogContext v; java.util.PriorityQueue v; java.util.HashMap v, v; long v; java.util.HashSet v, v, v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v; int v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$State v; java.lang.String v; org.apache.kafkaesque.common.utils.ProducerIdAndEpoch v; org.slf4j.Logger v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; java.util.function.ToIntFunction v; java.util.Comparator v; org.apache.kafkaesque.clients.ApiVersions v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.utils.LogContext; v := @parameter: java.lang.String; v := @parameter: int; v := @parameter: long; v := @parameter: org.apache.kafkaesque.clients.ApiVersions; specialinvoke v.()>(); v = (int) -1; v. = v; v = ; v. = v; v. = null; v. = 0; v. = 0; v = ; v. = v; v. = v; v = virtualinvoke v.(class "Lorg/apache/kafkaesque/clients/producer/internals/TransactionManager;"); v. = v; v. = v; v. = null; v. = null; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v = new java.util.PriorityQueue; v = staticinvoke (); v = staticinvoke (v); specialinvoke v.(int,java.util.Comparator)>(10, v); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v. = v; v = new org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper; specialinvoke v.()>(); v. = v; v. = v; return; } public synchronized org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult initializeTransactions() { org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.utils.ProducerIdAndEpoch v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = ; v = virtualinvoke v.(v); return v; } synchronized org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult initializeTransactions(org.apache.kafkaesque.common.utils.ProducerIdAndEpoch) { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$State v; org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult v; java.util.function.Supplier v; org.apache.kafkaesque.common.utils.ProducerIdAndEpoch v, v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.utils.ProducerIdAndEpoch; v = ; if v == v goto label; v = 1; goto label; label: v = 0; label: v = staticinvoke (v, v, v); v = ; v = specialinvoke v.(v, v); return v; } public synchronized void beginTransaction() { org.apache.kafkaesque.clients.producer.internals.TransactionManager$State v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; specialinvoke v.(); specialinvoke v.(); v = ; specialinvoke v.(v); return; } public synchronized org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult beginCommit() { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$State v; org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult v; java.util.function.Supplier v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = staticinvoke (v); v = ; v = specialinvoke v.(v, v); return v; } public synchronized org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult beginAbort() { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$State v; org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult v; java.util.function.Supplier v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = staticinvoke (v); v = ; v = specialinvoke v.(v, v); return v; } private org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult beginCompletingTransaction(org.apache.kafkaesque.common.requests.TransactionResult) { org.apache.kafkaesque.common.requests.EndTxnRequest$Builder v; long v; org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$EndTxnHandler v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TxnRequestHandler v; short v; java.lang.String v; org.apache.kafkaesque.common.utils.ProducerIdAndEpoch v, v, v; boolean v, v, v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; java.util.Set v; org.apache.kafkaesque.common.message.EndTxnRequestData v, v, v, v, v; java.lang.RuntimeException v; org.apache.kafkaesque.common.requests.TransactionResult v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.requests.TransactionResult; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = specialinvoke v.(); specialinvoke v.(v); label: v = v.; v = v instanceof org.apache.kafkaesque.common.errors.InvalidPidMappingException; if v != 0 goto label; v = new org.apache.kafkaesque.common.requests.EndTxnRequest$Builder; v = new org.apache.kafkaesque.common.message.EndTxnRequestData; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v); specialinvoke v.(org.apache.kafkaesque.common.message.EndTxnRequestData)>(v); v = new org.apache.kafkaesque.clients.producer.internals.TransactionManager$EndTxnHandler; specialinvoke v.(org.apache.kafkaesque.clients.producer.internals.TransactionManager,org.apache.kafkaesque.common.requests.EndTxnRequest$Builder)>(v, v); specialinvoke v.(v); v = specialinvoke v.(); if v != 0 goto label; v = v.; return v; label: v = v.; v = virtualinvoke v.(v); return v; } public synchronized org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult sendOffsetsToTransaction(java.util.Map, org.apache.kafkaesque.clients.consumer.ConsumerGroupMetadata) { long v; org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult v; short v; java.util.Map v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$State v, v; org.apache.kafkaesque.common.KafkaException v; java.lang.String v, v; org.apache.kafkaesque.common.utils.ProducerIdAndEpoch v, v; org.slf4j.Logger v; org.apache.kafkaesque.clients.consumer.ConsumerGroupMetadata v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.requests.AddOffsetsToTxnRequest$Builder v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: java.util.Map; v := @parameter: org.apache.kafkaesque.clients.consumer.ConsumerGroupMetadata; specialinvoke v.(); specialinvoke v.(); v = v.; v = ; if v == v goto label; v = new org.apache.kafkaesque.common.KafkaException; specialinvoke v.(java.lang.String)>("Cannot send offsets to transaction either because the producer is not in an active transaction"); throw v; label: v = v.; interfaceinvoke v.("Begin adding offsets {} for consumer group {} to transaction", v, v); v = new org.apache.kafkaesque.common.requests.AddOffsetsToTxnRequest$Builder; v = v.; v = v.; v = v.; v = v.; v = v.; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,long,short,java.lang.String)>(v, v, v, v); v = new org.apache.kafkaesque.clients.producer.internals.TransactionManager$AddOffsetsToTxnHandler; specialinvoke v.(org.apache.kafkaesque.clients.producer.internals.TransactionManager,org.apache.kafkaesque.common.requests.AddOffsetsToTxnRequest$Builder,java.util.Map,org.apache.kafkaesque.clients.consumer.ConsumerGroupMetadata)>(v, v, v, v); specialinvoke v.(v); v = v.; return v; } public synchronized void maybeAddPartitionToTransaction(org.apache.kafkaesque.common.TopicPartition) { org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v; org.slf4j.Logger v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v; java.util.Set v; boolean v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v = virtualinvoke v.(v); if v != 0 goto label; v = virtualinvoke v.(v); if v == 0 goto label; label: return; label: v = v.; interfaceinvoke v.("Begin adding new partition {} to transaction", v); v = v.; specialinvoke v.(v); v = v.; interfaceinvoke v.(v); return; } java.lang.RuntimeException lastError() { java.lang.RuntimeException v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = v.; return v; } public synchronized void failIfNotReadyForSend() { java.lang.IllegalStateException v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; java.lang.RuntimeException v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$State v, v, v; org.apache.kafkaesque.common.KafkaException v; java.lang.String v; boolean v, v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.kafkaesque.common.KafkaException; v = v.; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Cannot perform send because at least one previous transactional or idempotent request has failed with errors.", v); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Cannot perform a \'send\' before completing a call to initTransactions when transactions are enabled."); throw v; label: v = v.; v = ; if v == v goto label; v = new java.lang.IllegalStateException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cannot call send in state \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } synchronized boolean isSendToPartitionAllowed(org.apache.kafkaesque.common.TopicPartition) { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v; java.util.Set v; boolean v, v, v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v = virtualinvoke v.(); if v == 0 goto label; return 0; label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } public java.lang.String transactionalId() { java.lang.String v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = v.; return v; } public boolean hasProducerId() { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.utils.ProducerIdAndEpoch v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = v.; v = virtualinvoke v.(); return v; } public boolean isTransactional() { java.lang.String v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = v.; if v == null goto label; v = 1; goto label; label: v = 0; label: return v; } synchronized boolean hasPartitionsToAdd() { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; java.util.Set v, v; boolean v, v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } synchronized boolean isCompleting() { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$State v, v, v, v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = v.; v = ; if v == v goto label; v = v.; v = ; if v != v goto label; label: v = 1; goto label; label: v = 0; label: return v; } synchronized boolean hasError() { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$State v, v, v, v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = v.; v = ; if v == v goto label; v = v.; v = ; if v != v goto label; label: v = 1; goto label; label: v = 0; label: return v; } synchronized boolean isAborting() { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$State v, v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = v.; v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: return v; } synchronized void transitionToAbortableError(java.lang.RuntimeException) { org.slf4j.Logger v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$State v, v, v; java.lang.RuntimeException v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: java.lang.RuntimeException; v = v.; v = ; if v != v goto label; v = v.; interfaceinvoke v.("Skipping transition to abortable error state since the transaction is already being aborted. Underlying exception: ", v); return; label: v = ; specialinvoke v.(v, v); return; } synchronized void transitionToFatalError(java.lang.RuntimeException) { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$State v; java.lang.RuntimeException v; org.apache.kafkaesque.clients.producer.internals.TransactionalRequestResult v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: java.lang.RuntimeException; v = ; specialinvoke v.(v, v); v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); label: return; } synchronized boolean isPartitionAdded(org.apache.kafkaesque.common.TopicPartition) { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v; java.util.Set v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v = v.; v = interfaceinvoke v.(v); return v; } synchronized boolean isPartitionPendingAdd(org.apache.kafkaesque.common.TopicPartition) { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v; java.util.Set v, v; boolean v, v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } org.apache.kafkaesque.common.utils.ProducerIdAndEpoch producerIdAndEpoch() { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.utils.ProducerIdAndEpoch v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = v.; return v; } boolean hasProducerId(long) { byte v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; long v, v; org.apache.kafkaesque.common.utils.ProducerIdAndEpoch v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: long; v = v.; v = v.; v = v cmp v; if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } boolean matchesProducerIdAndEpoch(org.apache.kafkaesque.clients.producer.internals.ProducerBatch) { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; long v, v; org.apache.kafkaesque.clients.producer.internals.ProducerBatch v; short v, v; byte v; org.apache.kafkaesque.common.utils.ProducerIdAndEpoch v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.clients.producer.internals.ProducerBatch; v = v.; v = v.; v = virtualinvoke v.(); v = v cmp v; if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v != v goto label; v = 1; goto label; label: v = 0; label: return v; } private void setProducerIdAndEpoch(org.apache.kafkaesque.common.utils.ProducerIdAndEpoch) { short v; org.slf4j.Logger v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; java.lang.Long v; java.lang.Short v; long v; org.apache.kafkaesque.common.utils.ProducerIdAndEpoch v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.utils.ProducerIdAndEpoch; v = v.; v = v.; v = staticinvoke (v); v = v.; v = staticinvoke (v); interfaceinvoke v.("ProducerId set to {} with epoch {}", v, v); v. = v; return; } private void resetIdempotentProducerId() { java.lang.IllegalStateException v; org.slf4j.Logger v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$State v; org.apache.kafkaesque.common.utils.ProducerIdAndEpoch v, v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = virtualinvoke v.(); if v == 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Cannot reset producer state for a transactional producer. You must either abort the ongoing transaction or reinitialize the transactional producer instead"); throw v; label: v = v.; v = v.; interfaceinvoke v.("Resetting idempotent producer ID. ID and epoch before reset are {}", v); v = ; specialinvoke v.(v); v = ; specialinvoke v.(v); return; } private void resetSequenceForPartition(org.apache.kafkaesque.common.TopicPartition) { org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v; java.util.Map v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v = v.; v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); return; } private void resetSequenceNumbers() { org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; java.util.Map v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = v.; specialinvoke v.(); v = v.; interfaceinvoke v.(); return; } synchronized void requestEpochBumpForPartition(org.apache.kafkaesque.common.TopicPartition) { java.util.Set v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v. = 1; v = v.; interfaceinvoke v.(v); return; } private boolean shouldBumpEpoch() { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = v.; return v; } private void bumpIdempotentProducerEpoch() { long v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v; short v, v; java.util.Map v; int v; org.apache.kafkaesque.common.utils.ProducerIdAndEpoch v, v, v, v, v, v; boolean v; org.slf4j.Logger v; java.util.Iterator v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; java.util.Set v, v; java.lang.Object v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = v.; v = v.; if v != 32767 goto label; specialinvoke v.(); goto label; label: v = new org.apache.kafkaesque.common.utils.ProducerIdAndEpoch; v = v.; v = v.; v = v.; v = v.; v = v + 1; specialinvoke v.(long,short)>(v, v); specialinvoke v.(v); v = v.; v = v.; interfaceinvoke v.("Incremented producer epoch, current producer ID and epoch are now {}", v); label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v.; specialinvoke v.(v, v); v = v.; interfaceinvoke v.(v); goto label; label: v = v.; interfaceinvoke v.(); v. = 0; return; } synchronized void bumpIdempotentEpochAndResetIdIfNeeded() { org.apache.kafkaesque.common.requests.InitProducerIdRequest$Builder v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$InitProducerIdHandler v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$State v, v, v; org.apache.kafkaesque.common.message.InitProducerIdRequestData v, v, v; boolean v, v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = virtualinvoke v.(); if v != 0 goto label; v = specialinvoke v.(); if v == 0 goto label; specialinvoke v.(); label: v = v.; v = ; if v == v goto label; v = virtualinvoke v.(); if v != 0 goto label; v = ; specialinvoke v.(v); v = new org.apache.kafkaesque.common.message.InitProducerIdRequestData; specialinvoke v.()>(); v = virtualinvoke v.(null); v = virtualinvoke v.(2147483647); v = new org.apache.kafkaesque.clients.producer.internals.TransactionManager$InitProducerIdHandler; v = new org.apache.kafkaesque.common.requests.InitProducerIdRequest$Builder; specialinvoke v.(org.apache.kafkaesque.common.message.InitProducerIdRequestData)>(v); specialinvoke v.(org.apache.kafkaesque.clients.producer.internals.TransactionManager,org.apache.kafkaesque.common.requests.InitProducerIdRequest$Builder,boolean)>(v, v, 0); specialinvoke v.(v); label: return; } synchronized java.lang.Integer sequenceNumber(org.apache.kafkaesque.common.TopicPartition) { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v; java.lang.Integer v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionEntry v; int v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v = virtualinvoke v.(); if v != 0 goto label; v = v.; specialinvoke v.(v); label: v = v.; v = specialinvoke v.(v); v = v.; v = staticinvoke (v); return v; } synchronized void incrementSequenceNumber(org.apache.kafkaesque.common.TopicPartition, int) { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v; java.lang.Integer v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionEntry v; int v, v, v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v := @parameter: int; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v, v); v = staticinvoke (v); v = v.; v = specialinvoke v.(v); v = virtualinvoke v.(); v. = v; return; } synchronized void addInFlightBatch(org.apache.kafkaesque.clients.producer.internals.ProducerBatch) { java.lang.IllegalStateException v; java.util.SortedSet v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v, v; org.apache.kafkaesque.clients.producer.internals.ProducerBatch v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionEntry v; java.lang.String v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.clients.producer.internals.ProducerBatch; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalStateException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Can\'t track batch for partition \u when sequence is not set."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = v.; v = specialinvoke v.(v); v = v.; interfaceinvoke v.(v); return; } synchronized int firstInFlightSequence(org.apache.kafkaesque.common.TopicPartition) { java.util.SortedSet v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionEntry v; int v, v, v; java.lang.Object v; boolean v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v = virtualinvoke v.(v); if v != 0 goto label; v = (int) -1; return v; label: v = v.; v = specialinvoke v.(v); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = (int) -1; return v; label: v = interfaceinvoke v.(); v = virtualinvoke v.(); return v; } synchronized org.apache.kafkaesque.clients.producer.internals.ProducerBatch nextBatchBySequence(org.apache.kafkaesque.common.TopicPartition) { org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionEntry v; java.util.SortedSet v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v; java.lang.Object v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v = v.; v = specialinvoke v.(v); v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); label: return v; } synchronized void removeInFlightBatch(org.apache.kafkaesque.clients.producer.internals.ProducerBatch) { java.util.SortedSet v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v, v; org.apache.kafkaesque.clients.producer.internals.ProducerBatch v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionEntry v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.clients.producer.internals.ProducerBatch; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = v.; v = specialinvoke v.(v); v = v.; interfaceinvoke v.(v); label: return; } private int maybeUpdateLastAckedSequence(org.apache.kafkaesque.common.TopicPartition, int) { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v; java.util.OptionalInt v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionEntry v; int v, v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v := @parameter: int; v = virtualinvoke v.(v); v = (int) -1; v = virtualinvoke v.(v); if v <= v goto label; v = v.; v = specialinvoke v.(v); v. = v; return v; label: return v; } synchronized java.util.OptionalInt lastAckedSequence(org.apache.kafkaesque.common.TopicPartition) { org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v; java.util.OptionalInt v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v = v.; v = specialinvoke v.(v); return v; } synchronized java.util.OptionalLong lastAckedOffset(org.apache.kafkaesque.common.TopicPartition) { org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v; java.util.OptionalLong v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v = v.; v = specialinvoke v.(v); return v; } private void updateLastAckedOffset(org.apache.kafkaesque.common.requests.ProduceResponse$PartitionResponse, org.apache.kafkaesque.clients.producer.internals.ProducerBatch) { org.apache.kafkaesque.common.TopicPartition v, v, v, v; long v, v, v, v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v, v; java.util.OptionalLong v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionEntry v; byte v, v; java.lang.Long v; org.apache.kafkaesque.common.requests.ProduceResponse$PartitionResponse v; int v; boolean v, v; org.slf4j.Logger v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.clients.producer.internals.ProducerBatch v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.requests.ProduceResponse$PartitionResponse; v := @parameter: org.apache.kafkaesque.clients.producer.internals.ProducerBatch; v = v.; v = v cmp -1L; if v != 0 goto label; return; label: v = v.; v = v.; v = v + v; v = v - 1L; v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = v.; specialinvoke v.(v); label: v = virtualinvoke v.(-1L); v = v cmp v; if v <= 0 goto label; v = v.; v = v.; v = specialinvoke v.(v); v. = v; goto label; label: v = v.; v = v.; v = staticinvoke (v); interfaceinvoke v.("Partition {} keeps lastOffset at {}", v, v); label: return; } public synchronized void handleCompletedBatch(org.apache.kafkaesque.clients.producer.internals.ProducerBatch, org.apache.kafkaesque.common.requests.ProduceResponse$PartitionResponse) { java.lang.Object[] v; org.apache.kafkaesque.common.TopicPartition v, v, v, v; long v; java.lang.Integer v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v; java.lang.Long v; org.apache.kafkaesque.common.requests.ProduceResponse$PartitionResponse v; int v, v; org.apache.kafkaesque.common.utils.ProducerIdAndEpoch v; boolean v, v; org.slf4j.Logger v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.clients.producer.internals.ProducerBatch v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.clients.producer.internals.ProducerBatch; v := @parameter: org.apache.kafkaesque.common.requests.ProduceResponse$PartitionResponse; v = v.; v = virtualinvoke v.(); v = specialinvoke v.(v, v); v = v.; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = v.; v[1] = v; v = staticinvoke (v); v[2] = v; interfaceinvoke v.("ProducerId: {}; Set last ack\'d sequence number for topic-partition {} to {}", v); specialinvoke v.(v, v); virtualinvoke v.(v); v = virtualinvoke v.(v); if v != 0 goto label; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = v.; v = v.; v = v.; specialinvoke v.(v, v); label: return; } private void maybeTransitionToErrorState(java.lang.RuntimeException) { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; java.lang.RuntimeException v; boolean v, v, v, v, v, v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: java.lang.RuntimeException; v = v instanceof org.apache.kafkaesque.common.errors.ClusterAuthorizationException; if v != 0 goto label; v = v instanceof org.apache.kafkaesque.common.errors.TransactionalIdAuthorizationException; if v != 0 goto label; v = v instanceof org.apache.kafkaesque.common.errors.ProducerFencedException; if v != 0 goto label; v = v instanceof org.apache.kafkaesque.common.errors.UnsupportedVersionException; if v == 0 goto label; label: virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v. = 1; label: virtualinvoke v.(v); label: return; } synchronized void handleFailedBatch(org.apache.kafkaesque.clients.producer.internals.ProducerBatch, java.lang.RuntimeException, boolean) { java.lang.Object[] v, v; org.apache.kafkaesque.common.TopicPartition v, v, v, v; long v, v; java.lang.Integer v, v; short v, v; java.lang.Long v, v; java.lang.Short v, v; int v, v; boolean v, v, v, v, v, v; org.slf4j.Logger v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; java.lang.RuntimeException v; org.apache.kafkaesque.clients.producer.internals.ProducerBatch v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.clients.producer.internals.ProducerBatch; v := @parameter: java.lang.RuntimeException; v := @parameter: boolean; specialinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(v); if v != 0 goto label; v = v.; v = newarray (java.lang.Object)[5]; v[0] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[1] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[3] = v; v[4] = v; interfaceinvoke v.("Ignoring failed batch {} with producer id {}, epoch {}, and sequence number {} since the producerId has been reset internally", v); return; label: v = v instanceof org.apache.kafkaesque.common.errors.OutOfOrderSequenceException; if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = newarray (java.lang.Object)[5]; v[0] = v; v = v.; v[1] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[3] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[4] = v; interfaceinvoke v.("The broker returned {} for topic-partition {} with producerId {}, epoch {}, and sequence number {}", v); v = v.; virtualinvoke v.(v); goto label; label: v = v instanceof org.apache.kafkaesque.common.errors.UnknownProducerIdException; if v == 0 goto label; v = v.; specialinvoke v.(v); goto label; label: if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = v.; virtualinvoke v.(v); goto label; label: specialinvoke v.(v); label: return; } private void adjustSequencesDueToFailedBatch(org.apache.kafkaesque.clients.producer.internals.ProducerBatch) { java.lang.IllegalStateException v; java.lang.Object[] v; org.apache.kafkaesque.common.TopicPartition v, v, v, v, v, v; long v; java.lang.Integer v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionEntry v; java.lang.Long v; int v, v, v, v; java.lang.String v; boolean v; org.slf4j.Logger v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.clients.producer.internals.ProducerBatch v; java.util.function.Consumer v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.clients.producer.internals.ProducerBatch; v = v.; v = v.; v = specialinvoke v.(v); if v != 0 goto label; return; label: v = v.; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = v.; v[1] = v; v = v.; v = staticinvoke (v); v[2] = v; interfaceinvoke v.("producerId: {}, send to partition {} failed fatally. Reducing future sequence numbers by {}", v); v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = v.; v = v - v; if v >= 0 goto label; v = new java.lang.IllegalStateException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Sequence number for partition \u is going to become negative: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; specialinvoke v.(v, v); v = v.; v = v.; v = specialinvoke v.(v); v = staticinvoke (v, v); virtualinvoke v.(v); return; } synchronized boolean hasInflightBatches(org.apache.kafkaesque.common.TopicPartition) { java.util.SortedSet v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionBookkeeper v, v; org.apache.kafkaesque.clients.producer.internals.TransactionManager$TopicPartitionEntry v; boolean v, v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v = v.; v = specialinvoke v.(v); if v == 0 goto label; v = v.; v = specialinvoke v.(v); v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } synchronized boolean hasUnresolvedSequences() { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; java.util.Map v; boolean v, v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } synchronized boolean hasUnresolvedSequence(org.apache.kafkaesque.common.TopicPartition) { org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v; java.util.Map v; boolean v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.common.TopicPartition; v = v.; v = interfaceinvoke v.(v); return v; } synchronized void markSequenceUnresolved(org.apache.kafkaesque.clients.producer.internals.ProducerBatch) { org.slf4j.Logger v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; org.apache.kafkaesque.common.TopicPartition v, v, v; java.util.function.BiFunction v; org.apache.kafkaesque.clients.producer.internals.ProducerBatch v; java.util.Map v, v; int v, v; java.lang.Object v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v := @parameter: org.apache.kafkaesque.clients.producer.internals.ProducerBatch; v = virtualinvoke v.(); v = v + 1; v = v.; v = v.; v = staticinvoke (v); interfaceinvoke v.(v, v); v = v.; v = v.; v = v.; v = v.; v = interfaceinvoke v.(v); interfaceinvoke v.("Marking partition {} unresolved with next sequence number {}", v, v); return; } synchronized void maybeResolveSequences() { java.lang.Object[] v; java.lang.Integer v, v, v; java.util.OptionalInt v; java.util.Map v; int v, v, v; org.apache.kafkaesque.common.KafkaException v, v; java.lang.String v, v; boolean v, v, v, v, v; org.slf4j.Logger v; java.util.Iterator v; org.apache.kafkaesque.clients.producer.internals.TransactionManager v; java.util.Set v; java.lang.Object v; v := @this: org.apache.kafkaesque.clients.producer.internals.TransactionManager; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.