class org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState extends java.lang.Object
{
private org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState fetchState;
private org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition position;
private java.lang.Long highWatermark;
private java.lang.Long logStartOffset;
private java.lang.Long lastStableOffset;
private boolean paused;
private org.apache.kafkaesqueesqueesque.clients.consumer.OffsetResetStrategy resetStrategy;
private java.lang.Long nextRetryTimeMs;
private java.lang.Integer preferredReadReplica;
private java.lang.Long preferredReadReplicaExpireTimeMs;
void <init>()
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean paused> = 0;
v = <org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates INITIALIZING>;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState fetchState> = v;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition position> = null;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long highWatermark> = null;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long logStartOffset> = null;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long lastStableOffset> = null;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.OffsetResetStrategy resetStrategy> = null;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long nextRetryTimeMs> = null;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Integer preferredReadReplica> = null;
return;
}
private void transitionState(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState, java.lang.Runnable)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState v, v, v;
java.lang.Runnable v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState;
v := @parameter: java.lang.Runnable;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState fetchState>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState transitionTo(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState)>(v);
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState fetchState> = v;
interfaceinvoke v.<java.lang.Runnable: void run()>();
label:
return;
}
private java.util.Optional preferredReadReplica(long)
{
long v, v;
java.lang.Integer v;
byte v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.lang.Long v, v;
java.util.Optional v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v := @parameter: long;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long preferredReadReplicaExpireTimeMs>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long preferredReadReplicaExpireTimeMs>;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v cmp v;
if v <= 0 goto label;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Integer preferredReadReplica> = null;
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
return v;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Integer preferredReadReplica>;
v = staticinvoke <java.util.Optional: java.util.Optional ofNullable(java.lang.Object)>(v);
return v;
}
private void updatePreferredReadReplica(int, java.util.function.Supplier)
{
java.lang.Integer v, v, v;
java.util.function.Supplier v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
int v, v;
java.lang.Object v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v := @parameter: int;
v := @parameter: java.util.function.Supplier;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Integer preferredReadReplica>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Integer preferredReadReplica>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v == v goto label;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Integer preferredReadReplica> = v;
v = interfaceinvoke v.<java.util.function.Supplier: java.lang.Object get()>();
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long preferredReadReplicaExpireTimeMs> = v;
label:
return;
}
private java.util.Optional clearPreferredReadReplica()
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
int v;
java.util.Optional v, v;
java.lang.Integer v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Integer preferredReadReplica>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Integer preferredReadReplica>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Integer preferredReadReplica> = null;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long preferredReadReplicaExpireTimeMs> = null;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
return v;
label:
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
return v;
}
private void reset(org.apache.kafkaesqueesqueesque.clients.consumer.OffsetResetStrategy)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.lang.Runnable v;
org.apache.kafkaesqueesqueesque.clients.consumer.OffsetResetStrategy v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.consumer.OffsetResetStrategy;
v = <org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates AWAIT_RESET>;
v = staticinvoke <org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState$lambda_reset_0__180: java.lang.Runnable bootstrap$(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState,org.apache.kafkaesqueesqueesque.clients.consumer.OffsetResetStrategy)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void transitionState(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState,java.lang.Runnable)>(v, v);
return;
}
private boolean maybeValidatePosition(org.apache.kafkaesqueesqueesque.clients.Metadata$LeaderAndEpoch)
{
org.apache.kafkaesqueesqueesque.clients.Metadata$LeaderAndEpoch v, v;
long v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
boolean v, v, v, v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates v, v;
java.util.Optional v, v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition v, v, v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.Metadata$LeaderAndEpoch;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState fetchState>;
v = <org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates AWAIT_RESET>;
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.Metadata$LeaderAndEpoch: java.util.Optional leader>;
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.Metadata$LeaderAndEpoch: java.util.Optional epoch>;
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition position>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition position>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition: org.apache.kafkaesqueesqueesque.clients.Metadata$LeaderAndEpoch currentLeader>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.clients.Metadata$LeaderAndEpoch: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = new org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition position>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition: long offset>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition position>;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition: java.util.Optional offsetEpoch>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition: void <init>(long,java.util.Optional,org.apache.kafkaesqueesqueesque.clients.Metadata$LeaderAndEpoch)>(v, v, v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void validatePosition(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition)>(v);
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Integer preferredReadReplica> = null;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState fetchState>;
v = <org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates AWAIT_VALIDATION>;
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
return v;
}
private void validatePosition(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates v, v;
org.apache.kafkaesqueesqueesque.clients.Metadata$LeaderAndEpoch v;
java.lang.Runnable v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.util.Optional v, v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition v;
boolean v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition: java.util.Optional offsetEpoch>;
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition: org.apache.kafkaesqueesqueesque.clients.Metadata$LeaderAndEpoch currentLeader>;
v = v.<org.apache.kafkaesqueesqueesque.clients.Metadata$LeaderAndEpoch: java.util.Optional epoch>;
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v == 0 goto label;
v = <org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates AWAIT_VALIDATION>;
v = staticinvoke <org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState$lambda_validatePosition_1__182: java.lang.Runnable bootstrap$(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState,org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void transitionState(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState,java.lang.Runnable)>(v, v);
goto label;
label:
v = <org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates FETCHING>;
v = staticinvoke <org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState$lambda_validatePosition_2__181: java.lang.Runnable bootstrap$(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState,org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void transitionState(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState,java.lang.Runnable)>(v, v);
label:
return;
}
private void completeValidation()
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.lang.Runnable v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v = specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean hasPosition()>();
if v == 0 goto label;
v = <org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates FETCHING>;
v = staticinvoke <org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState$lambda_completeValidation_3__183: java.lang.Runnable bootstrap$(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void transitionState(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState,java.lang.Runnable)>(v, v);
label:
return;
}
private boolean awaitingValidation()
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState fetchState>;
v = <org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates AWAIT_VALIDATION>;
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
return v;
}
private boolean awaitingRetryBackoff(long)
{
byte v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.lang.Long v, v;
long v, v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v := @parameter: long;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long nextRetryTimeMs>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long nextRetryTimeMs>;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v cmp v;
if v >= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
private boolean awaitingReset()
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState fetchState>;
v = <org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates AWAIT_RESET>;
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
return v;
}
private void setNextAllowedRetry(long)
{
long v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.lang.Long v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v := @parameter: long;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long nextRetryTimeMs> = v;
return;
}
private void requestFailed(long)
{
long v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.lang.Long v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v := @parameter: long;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long nextRetryTimeMs> = v;
return;
}
private boolean hasValidPosition()
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState fetchState>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState: boolean hasValidPosition()>();
return v;
}
private boolean hasPosition()
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState fetchState>;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState: boolean hasPosition()>();
return v;
}
private boolean isPaused()
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean paused>;
return v;
}
private void seekValidated(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition v;
java.lang.Runnable v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition;
v = <org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchStates FETCHING>;
v = staticinvoke <org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState$lambda_seekValidated_4__184: java.lang.Runnable bootstrap$(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState,org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void transitionState(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchState,java.lang.Runnable)>(v, v);
return;
}
private void seekUnvalidated(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void seekValidated(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition)>(v);
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: void validatePosition(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition)>(v);
return;
}
private void position(org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition)
{
java.lang.IllegalStateException v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition;
v = specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean hasValidPosition()>();
if v != 0 goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Cannot set a new position without a valid current position");
throw v;
label:
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition position> = v;
return;
}
private org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition validPosition()
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition v;
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v = specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean hasValidPosition()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$FetchPosition position>;
return v;
label:
return null;
}
private void pause()
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean paused> = 1;
return;
}
private void resume()
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean paused> = 0;
return;
}
private boolean isFetchable()
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
boolean v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean paused>;
if v != 0 goto label;
v = specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: boolean hasValidPosition()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
private void highWatermark(java.lang.Long)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.lang.Long v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v := @parameter: java.lang.Long;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long highWatermark> = v;
return;
}
private void logStartOffset(java.lang.Long)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.lang.Long v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v := @parameter: java.lang.Long;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long logStartOffset> = v;
return;
}
private void lastStableOffset(java.lang.Long)
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
java.lang.Long v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v := @parameter: java.lang.Long;
v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: java.lang.Long lastStableOffset> = v;
return;
}
private org.apache.kafkaesqueesqueesque.clients.consumer.OffsetResetStrategy resetStrategy()
{
org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState v;
org.apache.kafkaesqueesqueesque.clients.consumer.OffsetResetStrategy v;
v := @this: org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState;
v = v.<org.apache.kafkaesqueesqueesque.clients.consumer.internals.SubscriptionState$TopicPartitionState: org.apache.kafkaesqueesqueesque.clients.consumer.OffsetResetStrategy resetStrategy>;
return v;
}
}