public class org.apache.kafkaesque.clients.FetchSessionHandler extends java.lang.Object
{
private final org.slf4j.Logger log;
private final int node;
private org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata;
private java.util.LinkedHashMap sessionPartitions;
public void <init>(org.apache.kafkaesque.common.utils.LogContext, int)
{
java.util.LinkedHashMap v;
org.apache.kafkaesque.common.requests.FetchMetadata v;
org.apache.kafkaesque.common.utils.LogContext v;
org.slf4j.Logger v;
org.apache.kafkaesque.clients.FetchSessionHandler v;
int v;
v := @this: org.apache.kafkaesque.clients.FetchSessionHandler;
v := @parameter: org.apache.kafkaesque.common.utils.LogContext;
v := @parameter: int;
specialinvoke v.<java.lang.Object: void <init>()>();
v = <org.apache.kafkaesque.common.requests.FetchMetadata: org.apache.kafkaesque.common.requests.FetchMetadata INITIAL>;
v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata> = v;
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>(int)>(0);
v.<org.apache.kafkaesque.clients.FetchSessionHandler: java.util.LinkedHashMap sessionPartitions> = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.utils.LogContext: org.slf4j.Logger logger(java.lang.Class)>(class "Lorg/apache/kafkaesque/clients/FetchSessionHandler;");
v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log> = v;
v.<org.apache.kafkaesque.clients.FetchSessionHandler: int node> = v;
return;
}
public org.apache.kafkaesque.clients.FetchSessionHandler$Builder newBuilder()
{
org.apache.kafkaesque.clients.FetchSessionHandler v;
org.apache.kafkaesque.clients.FetchSessionHandler$Builder v;
v := @this: org.apache.kafkaesque.clients.FetchSessionHandler;
v = new org.apache.kafkaesque.clients.FetchSessionHandler$Builder;
specialinvoke v.<org.apache.kafkaesque.clients.FetchSessionHandler$Builder: void <init>(org.apache.kafkaesque.clients.FetchSessionHandler)>(v);
return v;
}
public org.apache.kafkaesque.clients.FetchSessionHandler$Builder newBuilder(int, boolean)
{
org.apache.kafkaesque.clients.FetchSessionHandler v;
int v;
boolean v;
org.apache.kafkaesque.clients.FetchSessionHandler$Builder v;
v := @this: org.apache.kafkaesque.clients.FetchSessionHandler;
v := @parameter: int;
v := @parameter: boolean;
v = new org.apache.kafkaesque.clients.FetchSessionHandler$Builder;
specialinvoke v.<org.apache.kafkaesque.clients.FetchSessionHandler$Builder: void <init>(org.apache.kafkaesque.clients.FetchSessionHandler,int,boolean)>(v, v, v);
return v;
}
private java.lang.String partitionsToLogString(java.util.Collection)
{
java.lang.Object[] v;
org.slf4j.Logger v;
org.apache.kafkaesque.clients.FetchSessionHandler v;
java.util.Collection v;
java.lang.Integer v;
int v;
java.lang.String v, v, v;
boolean v;
v := @this: org.apache.kafkaesque.clients.FetchSessionHandler;
v := @parameter: java.util.Collection;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v != 0 goto label;
v = newarray (java.lang.Object)[1];
v = interfaceinvoke v.<java.util.Collection: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("%d partition(s)", v);
return v;
label:
v = staticinvoke <org.apache.kafkaesque.common.utils.Utils: java.lang.String join(java.util.Collection,java.lang.String)>(v, ", ");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("(\u)");
return v;
}
static java.util.Set findMissing(java.util.Set, java.util.Set)
{
java.util.Iterator v;
java.util.Set v, v;
java.lang.Object v;
java.util.LinkedHashSet v;
boolean v, v;
v := @parameter: java.util.Set;
v := @parameter: java.util.Set;
v = new java.util.LinkedHashSet;
specialinvoke v.<java.util.LinkedHashSet: void <init>()>();
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.Set: boolean contains(java.lang.Object)>(v);
if v != 0 goto label;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
}
java.lang.String verifyFullFetchResponsePartitions(org.apache.kafkaesque.common.requests.FetchResponse)
{
java.util.LinkedHashMap v, v, v, v, v;
java.lang.String v, v, v, v;
boolean v, v, v, v;
org.apache.kafkaesque.clients.FetchSessionHandler v;
org.apache.kafkaesque.common.requests.FetchResponse v;
java.util.Set v, v, v, v, v, v, v;
java.lang.StringBuilder v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesque.clients.FetchSessionHandler;
v := @parameter: org.apache.kafkaesque.common.requests.FetchResponse;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: java.util.LinkedHashMap responseData()>();
v = virtualinvoke v.<java.util.LinkedHashMap: java.util.Set keySet()>();
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: java.util.LinkedHashMap sessionPartitions>;
v = virtualinvoke v.<java.util.LinkedHashMap: java.util.Set keySet()>();
v = staticinvoke <org.apache.kafkaesque.clients.FetchSessionHandler: java.util.Set findMissing(java.util.Set,java.util.Set)>(v, v);
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: java.util.LinkedHashMap sessionPartitions>;
v = virtualinvoke v.<java.util.LinkedHashMap: java.util.Set keySet()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: java.util.LinkedHashMap responseData()>();
v = virtualinvoke v.<java.util.LinkedHashMap: java.util.Set keySet()>();
v = staticinvoke <org.apache.kafkaesque.clients.FetchSessionHandler: java.util.Set findMissing(java.util.Set,java.util.Set)>(v, v);
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v != 0 goto label;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("omitted=(");
v = staticinvoke <org.apache.kafkaesque.common.utils.Utils: java.lang.String join(java.util.Collection,java.lang.String)>(v, ", ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", ");
label:
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v != 0 goto label;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("extra=(");
v = staticinvoke <org.apache.kafkaesque.common.utils.Utils: java.lang.String join(java.util.Collection,java.lang.String)>(v, ", ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", ");
label:
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v != 0 goto label;
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("response=(");
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: java.util.LinkedHashMap responseData()>();
v = virtualinvoke v.<java.util.LinkedHashMap: java.util.Set keySet()>();
v = staticinvoke <org.apache.kafkaesque.common.utils.Utils: java.lang.String join(java.util.Collection,java.lang.String)>(v, ", ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(")");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
label:
return null;
}
java.lang.String verifyIncrementalFetchResponsePartitions(org.apache.kafkaesque.common.requests.FetchResponse)
{
java.util.LinkedHashMap v, v, v;
java.lang.String v, v, v;
boolean v;
org.apache.kafkaesque.clients.FetchSessionHandler v;
org.apache.kafkaesque.common.requests.FetchResponse v;
java.util.Set v, v, v, v;
java.lang.StringBuilder v, v, v, v, v;
v := @this: org.apache.kafkaesque.clients.FetchSessionHandler;
v := @parameter: org.apache.kafkaesque.common.requests.FetchResponse;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: java.util.LinkedHashMap responseData()>();
v = virtualinvoke v.<java.util.LinkedHashMap: java.util.Set keySet()>();
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: java.util.LinkedHashMap sessionPartitions>;
v = virtualinvoke v.<java.util.LinkedHashMap: java.util.Set keySet()>();
v = staticinvoke <org.apache.kafkaesque.clients.FetchSessionHandler: java.util.Set findMissing(java.util.Set,java.util.Set)>(v, v);
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v != 0 goto label;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("extra=(");
v = staticinvoke <org.apache.kafkaesque.common.utils.Utils: java.lang.String join(java.util.Collection,java.lang.String)>(v, ", ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("), ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("response=(");
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: java.util.LinkedHashMap responseData()>();
v = virtualinvoke v.<java.util.LinkedHashMap: java.util.Set keySet()>();
v = staticinvoke <org.apache.kafkaesque.common.utils.Utils: java.lang.String join(java.util.Collection,java.lang.String)>(v, ", ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("), ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
label:
return null;
}
private java.lang.String responseDataToLogString(org.apache.kafkaesque.common.requests.FetchResponse)
{
java.lang.Integer v, v, v;
boolean v, v, v;
org.apache.kafkaesque.common.requests.FetchResponse v;
java.util.Set v, v;
java.lang.StringBuilder v, v, v;
java.lang.Object[] v, v;
java.util.LinkedHashMap v, v, v, v, v, v, v;
int v, v, v, v, v;
java.lang.String v, v, v, v, v, v;
org.slf4j.Logger v;
java.util.Iterator v;
org.apache.kafkaesque.clients.FetchSessionHandler v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.clients.FetchSessionHandler;
v := @parameter: org.apache.kafkaesque.common.requests.FetchResponse;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isTraceEnabled()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: java.util.LinkedHashMap sessionPartitions>;
v = virtualinvoke v.<java.util.LinkedHashMap: int size()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: java.util.LinkedHashMap responseData()>();
v = virtualinvoke v.<java.util.LinkedHashMap: int size()>();
v = v - v;
if v <= 0 goto label;
v = newarray (java.lang.Object)[2];
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: java.util.LinkedHashMap responseData()>();
v = virtualinvoke v.<java.util.LinkedHashMap: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>(" with %d response partition(s), %d implied partition(s)", v);
return v;
label:
v = newarray (java.lang.Object)[1];
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: java.util.LinkedHashMap responseData()>();
v = virtualinvoke v.<java.util.LinkedHashMap: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>(" with %d response partition(s)", v);
return v;
label:
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(" with response=(");
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: java.util.LinkedHashMap responseData()>();
v = virtualinvoke v.<java.util.LinkedHashMap: java.util.Set keySet()>();
v = staticinvoke <org.apache.kafkaesque.common.utils.Utils: java.lang.String join(java.util.Collection,java.lang.String)>(v, ", ");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(")");
v = ", implied=(";
v = "";
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: java.util.LinkedHashMap sessionPartitions>;
v = virtualinvoke v.<java.util.LinkedHashMap: java.util.Set keySet()>();
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 = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: java.util.LinkedHashMap responseData()>();
v = virtualinvoke v.<java.util.LinkedHashMap: boolean containsKey(java.lang.Object)>(v);
if v != 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
v = ", ";
v = ")";
goto label;
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
public boolean handleResponse(org.apache.kafkaesque.common.requests.FetchResponse)
{
org.apache.kafkaesque.common.protocol.Errors v, v, v, v, v;
java.lang.Integer v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object[] v, v, v, v;
java.util.LinkedHashMap v;
java.lang.String v, v, v, v, v, v;
boolean v, v, v, v, v, v, v;
org.apache.kafkaesque.common.requests.FetchResponse v;
org.apache.kafkaesque.common.requests.FetchMetadata v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.clients.FetchSessionHandler v;
v := @this: org.apache.kafkaesque.clients.FetchSessionHandler;
v := @parameter: org.apache.kafkaesque.common.requests.FetchResponse;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.Errors error()>();
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors NONE>;
if v == v goto label;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[3];
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: int node>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata>;
v[1] = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.Errors error()>();
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object[])>("Node {} was unable to process the fetch request with {}: {}.", v);
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.protocol.Errors error()>();
v = <org.apache.kafkaesque.common.protocol.Errors: org.apache.kafkaesque.common.protocol.Errors FETCH_SESSION_ID_NOT_FOUND>;
if v != v goto label;
v = <org.apache.kafkaesque.common.requests.FetchMetadata: org.apache.kafkaesque.common.requests.FetchMetadata INITIAL>;
v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata> = v;
goto label;
label:
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata>;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchMetadata: org.apache.kafkaesque.common.requests.FetchMetadata nextCloseExisting()>();
v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata> = v;
label:
return 0;
label:
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata>;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchMetadata: boolean isFull()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: java.util.LinkedHashMap responseData()>();
v = virtualinvoke v.<java.util.LinkedHashMap: boolean isEmpty()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: int throttleTimeMs()>();
if v <= 0 goto label;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: int node>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: int throttleTimeMs()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Node {} sent a empty full fetch response to indicate that this client should be throttled for {} ms.", v, v);
label:
v = <org.apache.kafkaesque.common.requests.FetchMetadata: org.apache.kafkaesque.common.requests.FetchMetadata INITIAL>;
v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata> = v;
return 0;
label:
v = virtualinvoke v.<org.apache.kafkaesque.clients.FetchSessionHandler: java.lang.String verifyFullFetchResponsePartitions(org.apache.kafkaesque.common.requests.FetchResponse)>(v);
if v == null goto label;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: int node>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Node {} sent an invalid full fetch response with {}", v, v);
v = <org.apache.kafkaesque.common.requests.FetchMetadata: org.apache.kafkaesque.common.requests.FetchMetadata INITIAL>;
v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata> = v;
return 0;
label:
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: int sessionId()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: int node>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = specialinvoke v.<org.apache.kafkaesque.clients.FetchSessionHandler: java.lang.String responseDataToLogString(org.apache.kafkaesque.common.requests.FetchResponse)>(v);
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Node {} sent a full fetch response{}", v, v);
label:
v = <org.apache.kafkaesque.common.requests.FetchMetadata: org.apache.kafkaesque.common.requests.FetchMetadata INITIAL>;
v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata> = v;
return 1;
label:
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[3];
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: int node>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: int sessionId()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = specialinvoke v.<org.apache.kafkaesque.clients.FetchSessionHandler: java.lang.String responseDataToLogString(org.apache.kafkaesque.common.requests.FetchResponse)>(v);
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("Node {} sent a full fetch response that created a new incremental fetch session {}{}", v);
label:
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: int sessionId()>();
v = staticinvoke <org.apache.kafkaesque.common.requests.FetchMetadata: org.apache.kafkaesque.common.requests.FetchMetadata newIncremental(int)>(v);
v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata> = v;
return 1;
label:
v = virtualinvoke v.<org.apache.kafkaesque.clients.FetchSessionHandler: java.lang.String verifyIncrementalFetchResponsePartitions(org.apache.kafkaesque.common.requests.FetchResponse)>(v);
if v == null goto label;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: int node>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Node {} sent an invalid incremental fetch response with {}", v, v);
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata>;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchMetadata: org.apache.kafkaesque.common.requests.FetchMetadata nextCloseExisting()>();
v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata> = v;
return 0;
label:
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: int sessionId()>();
if v != 0 goto label;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[3];
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: int node>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata>;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchMetadata: int sessionId()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = specialinvoke v.<org.apache.kafkaesque.clients.FetchSessionHandler: java.lang.String responseDataToLogString(org.apache.kafkaesque.common.requests.FetchResponse)>(v);
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("Node {} sent an incremental fetch response closing session {}{}", v);
label:
v = <org.apache.kafkaesque.common.requests.FetchMetadata: org.apache.kafkaesque.common.requests.FetchMetadata INITIAL>;
v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata> = v;
return 1;
label:
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[4];
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: int throttleTimeMs()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: int node>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchResponse: int sessionId()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v = specialinvoke v.<org.apache.kafkaesque.clients.FetchSessionHandler: java.lang.String responseDataToLogString(org.apache.kafkaesque.common.requests.FetchResponse)>(v);
v[3] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("Node {} sent an incremental fetch response with throttleTimeMs = {} for session {}{}", v);
label:
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata>;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchMetadata: org.apache.kafkaesque.common.requests.FetchMetadata nextIncremental()>();
v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata> = v;
return 1;
}
public void handleError(java.lang.Throwable)
{
java.lang.Throwable v;
java.lang.Object[] v;
org.slf4j.Logger v;
org.apache.kafkaesque.clients.FetchSessionHandler v;
java.lang.Integer v;
org.apache.kafkaesque.common.requests.FetchMetadata v, v, v;
int v;
v := @this: org.apache.kafkaesque.clients.FetchSessionHandler;
v := @parameter: java.lang.Throwable;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[3];
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata>;
v[0] = v;
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: int node>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object[])>("Error sending fetch request {} to node {}: {}.", v);
v = v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata>;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.FetchMetadata: org.apache.kafkaesque.common.requests.FetchMetadata nextCloseExisting()>();
v.<org.apache.kafkaesque.clients.FetchSessionHandler: org.apache.kafkaesque.common.requests.FetchMetadata nextMetadata> = v;
return;
}
}