public class org.apache.kafkaesqueesque.common.requests.RequestContext extends java.lang.Object implements org.apache.kafkaesqueesque.server.authorizer.AuthorizableRequestContext
{
public final org.apache.kafkaesqueesque.common.requests.RequestHeader header;
public final java.lang.String connectionId;
public final java.net.InetAddress clientAddress;
public final org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal principal;
public final org.apache.kafkaesqueesque.common.network.ListenerName listenerName;
public final org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol securityProtocol;
public final org.apache.kafkaesqueesque.common.network.ClientInformation clientInformation;
public void <init>(org.apache.kafkaesqueesque.common.requests.RequestHeader, java.lang.String, java.net.InetAddress, org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal, org.apache.kafkaesqueesque.common.network.ListenerName, org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol, org.apache.kafkaesqueesque.common.network.ClientInformation)
{
org.apache.kafkaesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesque.common.requests.RequestContext v;
org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal v;
org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol v;
org.apache.kafkaesqueesque.common.network.ClientInformation v;
java.net.InetAddress v;
org.apache.kafkaesqueesque.common.network.ListenerName v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesque.common.requests.RequestContext;
v := @parameter: org.apache.kafkaesqueesque.common.requests.RequestHeader;
v := @parameter: java.lang.String;
v := @parameter: java.net.InetAddress;
v := @parameter: org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal;
v := @parameter: org.apache.kafkaesqueesque.common.network.ListenerName;
v := @parameter: org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol;
v := @parameter: org.apache.kafkaesqueesque.common.network.ClientInformation;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.requests.RequestHeader header> = v;
v.<org.apache.kafkaesqueesque.common.requests.RequestContext: java.lang.String connectionId> = v;
v.<org.apache.kafkaesqueesque.common.requests.RequestContext: java.net.InetAddress clientAddress> = v;
v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal principal> = v;
v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.network.ListenerName listenerName> = v;
v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol securityProtocol> = v;
v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.network.ClientInformation clientInformation> = v;
return;
}
public org.apache.kafkaesqueesque.common.requests.RequestAndSize parseRequest(java.nio.ByteBuffer)
{
java.lang.Throwable v;
org.apache.kafkaesqueesque.common.requests.RequestHeader v, v, v, v;
org.apache.kafkaesqueesque.common.requests.ApiVersionsRequest v;
org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal v;
org.apache.kafkaesqueesque.common.requests.RequestAndSize v, v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
java.nio.ByteBuffer v;
short v, v, v;
java.lang.Short v;
org.apache.kafkaesqueesque.common.network.ListenerName v;
int v;
java.lang.String v, v;
boolean v;
org.apache.kafkaesqueesque.common.protocol.ApiKeys v;
org.apache.kafkaesqueesque.common.requests.AbstractRequest v;
org.apache.kafkaesqueesque.common.requests.RequestContext v;
org.apache.kafkaesqueesque.common.errors.InvalidRequestException v;
org.apache.kafkaesqueesque.common.message.ApiVersionsRequestData v;
v := @this: org.apache.kafkaesqueesque.common.requests.RequestContext;
v := @parameter: java.nio.ByteBuffer;
v = specialinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestContext: boolean isUnsupportedApiVersionsRequest()>();
if v == 0 goto label;
v = new org.apache.kafkaesqueesque.common.requests.ApiVersionsRequest;
v = new org.apache.kafkaesqueesque.common.message.ApiVersionsRequestData;
specialinvoke v.<org.apache.kafkaesqueesque.common.message.ApiVersionsRequestData: void <init>()>();
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.requests.RequestHeader header>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestHeader: short apiVersion()>();
v = staticinvoke <java.lang.Short: java.lang.Short valueOf(short)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.ApiVersionsRequest: void <init>(org.apache.kafkaesqueesque.common.message.ApiVersionsRequestData,short,java.lang.Short)>(v, 0, v);
v = new org.apache.kafkaesqueesque.common.requests.RequestAndSize;
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestAndSize: void <init>(org.apache.kafkaesqueesque.common.requests.AbstractRequest,int)>(v, 0);
return v;
label:
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.requests.RequestHeader header>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestHeader: org.apache.kafkaesqueesque.common.protocol.ApiKeys apiKey()>();
label:
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.requests.RequestHeader header>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestHeader: short apiVersion()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesque.common.protocol.types.Struct parseRequest(short,java.nio.ByteBuffer)>(v, v);
v = staticinvoke <org.apache.kafkaesqueesque.common.requests.AbstractRequest: org.apache.kafkaesqueesque.common.requests.AbstractRequest parseRequest(org.apache.kafkaesqueesque.common.protocol.ApiKeys,short,org.apache.kafkaesqueesque.common.protocol.types.Struct)>(v, v, v);
v = new org.apache.kafkaesqueesque.common.requests.RequestAndSize;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: int sizeOf()>();
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestAndSize: void <init>(org.apache.kafkaesqueesque.common.requests.AbstractRequest,int)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = new org.apache.kafkaesqueesque.common.errors.InvalidRequestException;
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.requests.RequestHeader header>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestHeader: short apiVersion()>();
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: java.lang.String connectionId>;
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.network.ListenerName listenerName>;
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal principal>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesqueesque.common.protocol.ApiKeys,short,java.lang.String,org.apache.kafkaesqueesque.common.network.ListenerName,org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal)>(v, v, v, v, 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[])>("Error getting request for apiKey: \u, apiVersion: \u, connectionId: \u, listenerName: \u, principal: \u0001");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.InvalidRequestException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.Throwable from label to label with label;
}
public org.apache.kafkaesqueesque.common.network.Send buildResponse(org.apache.kafkaesqueesque.common.requests.AbstractResponse)
{
org.apache.kafkaesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesque.common.requests.RequestContext v;
short v;
org.apache.kafkaesqueesque.common.requests.AbstractResponse v;
org.apache.kafkaesqueesque.common.requests.ResponseHeader v;
java.lang.String v;
org.apache.kafkaesqueesque.common.network.Send v;
v := @this: org.apache.kafkaesqueesque.common.requests.RequestContext;
v := @parameter: org.apache.kafkaesqueesque.common.requests.AbstractResponse;
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.requests.RequestHeader header>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestHeader: org.apache.kafkaesqueesque.common.requests.ResponseHeader toResponseHeader()>();
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: java.lang.String connectionId>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestContext: short apiVersion()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.AbstractResponse: org.apache.kafkaesqueesque.common.network.Send toSend(java.lang.String,org.apache.kafkaesqueesque.common.requests.ResponseHeader,short)>(v, v, v);
return v;
}
private boolean isUnsupportedApiVersionsRequest()
{
org.apache.kafkaesqueesque.common.protocol.ApiKeys v, v, v;
org.apache.kafkaesqueesque.common.requests.RequestHeader v, v;
org.apache.kafkaesqueesque.common.requests.RequestContext v;
short v;
boolean v, v;
v := @this: org.apache.kafkaesqueesque.common.requests.RequestContext;
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.requests.RequestHeader header>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestHeader: org.apache.kafkaesqueesque.common.protocol.ApiKeys apiKey()>();
v = <org.apache.kafkaesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesque.common.protocol.ApiKeys API_VERSIONS>;
if v != v goto label;
v = <org.apache.kafkaesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesque.common.protocol.ApiKeys API_VERSIONS>;
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.requests.RequestHeader header>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestHeader: short apiVersion()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.ApiKeys: boolean isVersionSupported(short)>(v);
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public short apiVersion()
{
org.apache.kafkaesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesque.common.requests.RequestContext v;
short v;
boolean v;
v := @this: org.apache.kafkaesqueesque.common.requests.RequestContext;
v = specialinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestContext: boolean isUnsupportedApiVersionsRequest()>();
if v == 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.requests.RequestHeader header>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestHeader: short apiVersion()>();
return v;
}
public java.lang.String listenerName()
{
org.apache.kafkaesqueesque.common.requests.RequestContext v;
java.lang.String v;
org.apache.kafkaesqueesque.common.network.ListenerName v;
v := @this: org.apache.kafkaesqueesque.common.requests.RequestContext;
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.network.ListenerName listenerName>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.network.ListenerName: java.lang.String value()>();
return v;
}
public org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol securityProtocol()
{
org.apache.kafkaesqueesque.common.requests.RequestContext v;
org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol v;
v := @this: org.apache.kafkaesqueesque.common.requests.RequestContext;
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol securityProtocol>;
return v;
}
public org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal principal()
{
org.apache.kafkaesqueesque.common.requests.RequestContext v;
org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal v;
v := @this: org.apache.kafkaesqueesque.common.requests.RequestContext;
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal principal>;
return v;
}
public java.net.InetAddress clientAddress()
{
java.net.InetAddress v;
org.apache.kafkaesqueesque.common.requests.RequestContext v;
v := @this: org.apache.kafkaesqueesque.common.requests.RequestContext;
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: java.net.InetAddress clientAddress>;
return v;
}
public int requestType()
{
org.apache.kafkaesqueesque.common.protocol.ApiKeys v;
org.apache.kafkaesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesque.common.requests.RequestContext v;
short v;
v := @this: org.apache.kafkaesqueesque.common.requests.RequestContext;
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.requests.RequestHeader header>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestHeader: org.apache.kafkaesqueesque.common.protocol.ApiKeys apiKey()>();
v = v.<org.apache.kafkaesqueesque.common.protocol.ApiKeys: short id>;
return v;
}
public int requestVersion()
{
org.apache.kafkaesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesque.common.requests.RequestContext v;
short v;
v := @this: org.apache.kafkaesqueesque.common.requests.RequestContext;
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.requests.RequestHeader header>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestHeader: short apiVersion()>();
return v;
}
public java.lang.String clientId()
{
org.apache.kafkaesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesque.common.requests.RequestContext v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesque.common.requests.RequestContext;
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.requests.RequestHeader header>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestHeader: java.lang.String clientId()>();
return v;
}
public int correlationId()
{
int v;
org.apache.kafkaesqueesque.common.requests.RequestHeader v;
org.apache.kafkaesqueesque.common.requests.RequestContext v;
v := @this: org.apache.kafkaesqueesque.common.requests.RequestContext;
v = v.<org.apache.kafkaesqueesque.common.requests.RequestContext: org.apache.kafkaesqueesque.common.requests.RequestHeader header>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.RequestHeader: int correlationId()>();
return v;
}
}