public class org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse extends org.apache.kafkaesqueesque.common.requests.AbstractResponse
{
public static final org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse DEFAULT_API_VERSIONS_RESPONSE;
public final org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData data;
public void <init>(org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData)
{
org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData v;
org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse v;
v := @this: org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse;
v := @parameter: org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData;
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.AbstractResponse: void <init>()>();
v.<org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData data> = v;
return;
}
public void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct)
{
org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
int v, v;
org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse v;
org.apache.kafkaesqueesque.common.protocol.types.Schema[] v;
v := @this: org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct;
v = new org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData;
v = <org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData: org.apache.kafkaesqueesque.common.protocol.types.Schema[] SCHEMAS>;
v = lengthof v;
v = v - 1;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: void <init>(org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData)>(v);
return;
}
public void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct, short)
{
short v;
org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse v;
v := @this: org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct;
v := @parameter: short;
v = new org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: void <init>(org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData)>(v);
return;
}
protected org.apache.kafkaesqueesque.common.protocol.types.Struct toStruct(short)
{
short v;
org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse v;
v := @this: org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse;
v := @parameter: short;
v = v.<org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData data>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData: org.apache.kafkaesqueesque.common.protocol.types.Struct toStruct(short)>(v);
return v;
}
public org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKey apiVersion(short)
{
short v;
org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData v;
org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKey v;
org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKeyCollection v;
org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse v;
v := @this: org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse;
v := @parameter: short;
v = v.<org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData data>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData: org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKeyCollection apiKeys()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKeyCollection: org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKey find(short)>(v);
return v;
}
public java.util.Map errorCounts()
{
short v;
org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData v;
java.util.Map v;
org.apache.kafkaesqueesque.common.protocol.Errors v;
org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse v;
v := @this: org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse;
v = v.<org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData data>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData: short errorCode()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors forCode(short)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: java.util.Map errorCounts(org.apache.kafkaesqueesque.common.protocol.Errors)>(v);
return v;
}
public int throttleTimeMs()
{
int v;
org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData v;
org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse v;
v := @this: org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse;
v = v.<org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData data>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData: int throttleTimeMs()>();
return v;
}
public boolean shouldClientThrottle(short)
{
short v;
org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse v;
boolean v;
v := @this: org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse;
v := @parameter: short;
if v < 2 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public static org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse parse(java.nio.ByteBuffer, short)
{
org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData v, v;
org.apache.kafkaesqueesque.common.protocol.ByteBufferAccessor v, v;
java.lang.RuntimeException v;
java.nio.ByteBuffer v;
short v;
int v;
org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse v, v;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: short;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
label:
v = new org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse;
v = new org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData;
v = new org.apache.kafkaesqueesque.common.protocol.ByteBufferAccessor;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.ByteBufferAccessor: void <init>(java.nio.ByteBuffer)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData: void <init>(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v);
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: void <init>(org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData)>(v);
label:
return v;
label:
v := @caughtexception;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer position(int)>(v);
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse;
v = new org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData;
v = new org.apache.kafkaesqueesque.common.protocol.ByteBufferAccessor;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.ByteBufferAccessor: void <init>(java.nio.ByteBuffer)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData: void <init>(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, 0);
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: void <init>(org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData)>(v);
return v;
label:
throw v;
catch java.lang.RuntimeException from label to label with label;
}
public static org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse fromStruct(org.apache.kafkaesqueesque.common.protocol.types.Struct, short)
{
org.apache.kafkaesqueesque.common.protocol.types.SchemaException v;
short v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse v, v;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct;
v := @parameter: short;
label:
v = new org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse;
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v);
label:
return v;
label:
v := @caughtexception;
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse;
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, 0);
return v;
label:
throw v;
catch org.apache.kafkaesqueesque.common.protocol.types.SchemaException from label to label with label;
}
public static org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse apiVersionsResponse(int, byte)
{
byte v;
int v;
org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse v, v;
v := @parameter: int;
v := @parameter: byte;
if v != 2 goto label;
if v != 0 goto label;
v = <org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse DEFAULT_API_VERSIONS_RESPONSE>;
return v;
label:
v = staticinvoke <org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse createApiVersionsResponse(int,byte)>(v, v);
return v;
}
public static org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse createApiVersionsResponse(int, byte)
{
org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData v;
org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKeyCollection v;
short v, v, v, v;
byte v, v;
int v, v, v;
org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKey v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.Errors v;
org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse v;
org.apache.kafkaesqueesque.common.protocol.ApiKeys v;
org.apache.kafkaesqueesque.common.protocol.ApiKeys[] v;
v := @parameter: int;
v := @parameter: byte;
v = new org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKeyCollection;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKeyCollection: void <init>()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesque.common.protocol.ApiKeys[] values()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesque.common.protocol.ApiKeys: byte minRequiredInterBrokerMagic>;
if v > v goto label;
v = new org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKey;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKey: void <init>()>();
v = v.<org.apache.kafkaesqueesque.common.protocol.ApiKeys: short id>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKey: org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKey setApiKey(short)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.ApiKeys: short oldestVersion()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKey: org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKey setMinVersion(short)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.ApiKeys: short latestVersion()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKey: org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKey setMaxVersion(short)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKeyCollection: boolean add(org.apache.kafkaesqueesque.common.utils.ImplicitLinkedHashCollection$Element)>(v);
label:
v = v + 1;
goto label;
label:
v = new org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData: org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData setThrottleTimeMs(int)>(v);
v = <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors NONE>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.Errors: short code()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData: org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData setErrorCode(short)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData: org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData setApiKeys(org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData$ApiVersionsResponseKeyCollection)>(v);
v = new org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse;
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: void <init>(org.apache.kafkaesqueesque.common.message.ApiVersionsResponseData)>(v);
return v;
}
static void <clinit>()
{
org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse v;
v = staticinvoke <org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse createApiVersionsResponse(int,byte)>(0, 2);
<org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse: org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse DEFAULT_API_VERSIONS_RESPONSE> = v;
return;
}
}