public class org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator extends java.lang.Object implements org.apache.kafkaesqueesque.common.network.Authenticator { static final int MAX_RECEIVE_SIZE; private static final org.slf4j.Logger LOG; private final org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol securityProtocol; private final org.apache.kafkaesqueesque.common.network.ListenerName listenerName; private final java.lang.String connectionId; private final java.util.Map subjects; private final org.apache.kafkaesqueesque.common.network.TransportLayer transportLayer; private final java.util.List enabledMechanisms; private final java.util.Map configs; private final org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipalBuilder principalBuilder; private final java.util.Map callbackHandlers; private final java.util.Map connectionsMaxReauthMsByMechanism; private final org.apache.kafkaesqueesque.common.utils.Time time; private final org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$ReauthInfo reauthInfo; private final org.apache.kafkaesqueesque.common.network.ChannelMetadataRegistry metadataRegistry; private org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$SaslState saslState; private org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$SaslState pendingSaslState; private org.apache.kafkaesqueesque.common.errors.AuthenticationException pendingException; private javax.security.sasl.SaslServer saslServer; private java.lang.String saslMechanism; private org.apache.kafkaesqueesque.common.network.NetworkReceive netInBuffer; private org.apache.kafkaesqueesque.common.network.Send netOutBuffer; private org.apache.kafkaesqueesque.common.network.Send authenticationFailureSend; private boolean enableKafkaSaslAuthenticateHeaders; public void (java.util.Map, java.util.Map, java.lang.String, java.util.Map, org.apache.kafkaesqueesque.common.security.kerberos.KerberosShortNamer, org.apache.kafkaesqueesque.common.network.ListenerName, org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol, org.apache.kafkaesqueesque.common.network.TransportLayer, java.util.Map, org.apache.kafkaesqueesque.common.network.ChannelMetadataRegistry, org.apache.kafkaesqueesque.common.utils.Time) { org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; org.apache.kafkaesqueesque.common.security.kerberos.KerberosShortNamer v; org.apache.kafkaesqueesque.common.network.ChannelMetadataRegistry v; org.apache.kafkaesqueesque.common.utils.Time v; java.util.Map v, v, v, v, v; boolean v, v, v, v; org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol v; java.util.List v; org.apache.kafkaesqueesque.common.network.TransportLayer v; java.lang.Object[] v; java.util.ArrayList v; java.util.HashSet v; org.apache.kafkaesqueesque.common.network.ListenerName v; java.lang.String v, v, v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$ReauthInfo v; org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipalBuilder v; org.slf4j.Logger v; java.util.Iterator v; java.lang.IllegalArgumentException v, v, v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$SaslState v; java.lang.Object v, v, v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v := @parameter: java.util.Map; v := @parameter: java.util.Map; v := @parameter: java.lang.String; v := @parameter: java.util.Map; v := @parameter: org.apache.kafkaesqueesque.common.security.kerberos.KerberosShortNamer; v := @parameter: org.apache.kafkaesqueesque.common.network.ListenerName; v := @parameter: org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol; v := @parameter: org.apache.kafkaesqueesque.common.network.TransportLayer; v := @parameter: java.util.Map; v := @parameter: org.apache.kafkaesqueesque.common.network.ChannelMetadataRegistry; v := @parameter: org.apache.kafkaesqueesque.common.utils.Time; specialinvoke v.()>(); v = ; v. = v; v. = null; v. = null; v. = null; v. = v; v. = v; v. = v; v. = v; v. = v; v. = 0; v. = v; v. = v; v. = v; v = new org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$ReauthInfo; specialinvoke v.(org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator)>(v); v. = v; v. = v; v. = v; v = v.; v = interfaceinvoke v.("sasl.enabled.mechanisms"); if v == null goto label; v = interfaceinvoke v.(); if v == 0 goto label; label: v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("No SASL mechanisms are enabled"); throw v; label: v = new java.util.ArrayList; v = new java.util.HashSet; specialinvoke v.(java.util.Collection)>(v); specialinvoke v.(java.util.Collection)>(v); v. = v; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Callback handler not specified for SASL mechanism \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = interfaceinvoke v.(v); if v != 0 goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Subject cannot be null for SASL mechanism \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = ; v = newarray (java.lang.Object)[3]; v[0] = "connections.max.reauth.ms"; v[1] = v; v = interfaceinvoke v.(v); v[2] = v; interfaceinvoke v.("{} for mechanism={}: {}", v); goto label; label: v = staticinvoke (v, null, null, v, null); v. = v; return; } private void createSaslServer(java.lang.String) throws java.io.IOException { java.lang.Throwable v; java.security.PrivilegedActionException v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; java.security.PrivilegedExceptionAction v; javax.security.sasl.SaslException v; java.util.Map v, v, v; java.lang.Object v, v, v; java.lang.String v; javax.security.sasl.SaslServer v; boolean v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v := @parameter: java.lang.String; v. = v; v = v.; v = interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(v); v = virtualinvoke v.("GSSAPI"); if v == 0 goto label; v = v.; v = specialinvoke v.(v, v, v); v. = v; goto label; label: v = staticinvoke (v, v); v = staticinvoke (v, v); v. = v; label: goto label; label: v := @caughtexception; v = new javax.security.sasl.SaslException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.Throwable)>("Kafka Server failed to create a SaslServer to interact with a client during session authentication", v); throw v; label: return; catch java.security.PrivilegedActionException from label to label with label; } private javax.security.sasl.SaslServer createSaslKerberosServer(org.apache.kafkaesqueesque.common.security.auth.AuthenticateCallbackHandler, java.util.Map, javax.security.auth.Subject) throws java.io.IOException { java.lang.Throwable v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; javax.security.sasl.SaslException v; java.util.Map v; java.lang.String v, v, v, v, v; org.apache.kafkaesqueesque.common.security.kerberos.KerberosName v; java.security.PrivilegedActionException v; org.slf4j.Logger v; java.lang.IllegalArgumentException v; java.security.PrivilegedExceptionAction v; javax.security.auth.Subject v; org.apache.kafkaesqueesque.common.KafkaException v; java.lang.Object v; org.apache.kafkaesqueesque.common.security.auth.AuthenticateCallbackHandler v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v := @parameter: org.apache.kafkaesqueesque.common.security.auth.AuthenticateCallbackHandler; v := @parameter: java.util.Map; v := @parameter: javax.security.auth.Subject; v = staticinvoke (v); label: v = staticinvoke (v); label: goto label; label: v := @caughtexception; v = new org.apache.kafkaesqueesque.common.KafkaException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Principal has name with unexpected format \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = v.; interfaceinvoke v.("Creating SaslServer for {} with mechanism {}", v, v); label: v = staticinvoke (v, v, v, v, v); v = staticinvoke (v, v); label: return v; label: v := @caughtexception; v = new javax.security.sasl.SaslException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.Throwable)>("Kafka Server failed to create a SaslServer to interact with a client during session authentication", v); throw v; catch java.lang.IllegalArgumentException from label to label with label; catch java.security.PrivilegedActionException from label to label with label; } public void authenticate() throws java.io.IOException { byte[] v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; java.nio.ByteBuffer v, v, v; org.apache.kafkaesqueesque.common.errors.SaslAuthenticationException v; int[] v; boolean v, v, v, v, v; java.lang.Exception v; org.apache.kafkaesqueesque.common.network.TransportLayer v; org.apache.kafkaesqueesque.common.network.Send v; int v, v, v, v; java.lang.String v, v, v, v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$ReauthInfo v, v; org.apache.kafkaesqueesque.common.network.NetworkReceive v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.errors.AuthenticationException v; org.slf4j.Logger v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$SaslState v, v, v, v, v, v, v; javax.security.sasl.SaslServer v, v, v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v = v.; v = ; if v == v goto label; v = v.; if v == null goto label; v = specialinvoke v.(); if v != 0 goto label; return; label: v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = ; specialinvoke v.(v); return; label: v = v.; if v != null goto label; v = new org.apache.kafkaesqueesque.common.network.NetworkReceive; v = v.; specialinvoke v.(int,java.lang.String)>(524288, v); v. = v; label: v = v.; v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v != 0 goto label; return; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = newarray (byte)[v]; v = v.; v = virtualinvoke v.(); v = lengthof v; virtualinvoke v.(v, 0, v); v. = null; label: v = ; v = v.; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; default: goto label; }; label: specialinvoke v.(v); goto label; label: v = new org.apache.kafkaesqueesque.common.errors.SaslAuthenticationException; v = v.; v = v.; specialinvoke v.(java.lang.String)>(v); throw v; label: v = specialinvoke v.(v); if v != 0 goto label; label: specialinvoke v.(v); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = ; specialinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; specialinvoke v.(v, v); goto label; label: v := @caughtexception; v = ; v. = v; v = ; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("Failed during {}: {}", v, v); throw v; label: return; catch org.apache.kafkaesqueesque.common.errors.AuthenticationException from label to label with label; catch java.lang.Exception from label to label with label; } public org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal principal() { org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal v; org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipalBuilder v; org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; org.apache.kafkaesqueesque.common.security.auth.SaslAuthenticationContext v; java.net.InetAddress v; org.apache.kafkaesqueesque.common.network.ListenerName v; java.lang.Object v; java.lang.String v, v; javax.security.sasl.SaslServer v, v; boolean v, v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v = new org.apache.kafkaesqueesque.common.security.auth.SaslAuthenticationContext; v = v.; v = v.; v = specialinvoke v.(); v = v.; v = virtualinvoke v.(); specialinvoke v.(javax.security.sasl.SaslServer,org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol,java.net.InetAddress,java.lang.String)>(v, v, v, v); v = v.; v = interfaceinvoke v.(v); v = v.; v = staticinvoke (v); if v == 0 goto label; v = v.; v = interfaceinvoke v.("tokenauth"); v = staticinvoke (v); if v == 0 goto label; virtualinvoke v.(1); label: return v; } public boolean complete() { org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$SaslState v, v; boolean v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v = v.; v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: return v; } public void handleAuthenticationFailure() throws java.io.IOException { org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; specialinvoke v.(); return; } public void close() throws java.io.IOException { org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipalBuilder v, v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; javax.security.sasl.SaslServer v, v; boolean v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v = v.; v = v instanceof java.io.Closeable; if v == 0 goto label; v = v.; staticinvoke (v, "principal builder"); label: v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: return; } public void reauthenticate(org.apache.kafkaesqueesque.common.network.ReauthenticationContext) throws java.io.IOException { org.apache.kafkaesqueesque.common.network.Authenticator v; org.apache.kafkaesqueesque.common.network.NetworkReceive v, v; org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal v; org.slf4j.Logger v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; long v; java.lang.IllegalArgumentException v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$SaslState v; java.nio.ByteBuffer v; org.apache.kafkaesqueesque.common.network.ReauthenticationContext v; java.lang.String v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$ReauthInfo v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v := @parameter: org.apache.kafkaesqueesque.common.network.ReauthenticationContext; v = virtualinvoke v.(); if v != null goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Invalid saslHandshakeReceive in server-side re-authentication context: null"); throw v; label: v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v); virtualinvoke v.(); v. = v; v = ; interfaceinvoke v.("Beginning re-authentication: {}", v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); v = ; specialinvoke v.(v); virtualinvoke v.(); return; } public java.lang.Long serverSessionExpirationTimeNanos() { java.lang.Long v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$ReauthInfo v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v = v.; v = v.; return v; } public java.lang.Long reauthenticationLatencyMs() { java.lang.Long v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$ReauthInfo v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v = v.; v = virtualinvoke v.(); return v; } public boolean connectedClientSupportsReauthentication() { org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$ReauthInfo v; boolean v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v = v.; v = v.; return v; } private void setSaslState(org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$SaslState) { org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$SaslState v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v := @parameter: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$SaslState; specialinvoke v.(v, null); return; } private void setSaslState(org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$SaslState, org.apache.kafkaesqueesque.common.errors.AuthenticationException) { org.apache.kafkaesqueesque.common.errors.AuthenticationException v; org.slf4j.Logger v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$SaslState v; java.lang.String v; org.apache.kafkaesqueesque.common.network.Send v, v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$ReauthInfo v; boolean v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v := @parameter: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$SaslState; v := @parameter: org.apache.kafkaesqueesque.common.errors.AuthenticationException; v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v. = v; v. = v; goto label; label: v. = v; v = ; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("Set SASL server state to {} during {}", v, v); v. = null; v. = null; if v == null goto label; throw v; label: return; } private boolean flushNetOutBufferAndUpdateInterestOps() throws java.io.IOException { org.apache.kafkaesqueesque.common.errors.AuthenticationException v; org.apache.kafkaesqueesque.common.network.TransportLayer v, v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$SaslState v, v; boolean v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v = specialinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(4); v = v.; if v == null goto label; v = v.; v = v.; specialinvoke v.(v, v); goto label; label: v = v.; interfaceinvoke v.(4); label: return v; } private boolean flushNetOutBuffer() throws java.io.IOException { org.apache.kafkaesqueesque.common.network.TransportLayer v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; org.apache.kafkaesqueesque.common.network.Send v, v, v; boolean v, v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = v.; interfaceinvoke v.(v); label: v = v.; v = interfaceinvoke v.(); return v; } private java.net.InetAddress serverAddress() { java.net.InetAddress v; java.net.Socket v; java.nio.channels.SocketChannel v; org.apache.kafkaesqueesque.common.network.TransportLayer v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); return v; } private java.net.InetAddress clientAddress() { java.net.InetAddress v; java.net.Socket v; java.nio.channels.SocketChannel v; org.apache.kafkaesqueesque.common.network.TransportLayer v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); return v; } private void handleSaslToken(byte[]) throws java.io.IOException { byte[] v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal v, v, v; org.apache.kafkaesqueesque.common.message.SaslAuthenticateResponseData v, v, v, v, v, v, v, v, v, v; javax.security.sasl.SaslException v; org.apache.kafkaesqueesque.common.errors.SaslAuthenticationException v, v; java.net.InetAddress v; org.apache.kafkaesqueesque.common.requests.SaslAuthenticateResponse v, v, v; org.apache.kafkaesqueesque.common.protocol.Errors v, v, v; org.apache.kafkaesqueesque.common.requests.AbstractResponse v; org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol v; org.apache.kafkaesqueesque.common.network.ClientInformation v; org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v; long v; short v, v, v, v; org.apache.kafkaesqueesque.common.network.ListenerName v; java.lang.String v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$ReauthInfo v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.message.SaslAuthenticateRequestData v; org.apache.kafkaesqueesque.common.requests.RequestAndSize v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; java.nio.ByteBuffer v, v; boolean v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesqueesque.common.protocol.ApiKeys v, v; org.apache.kafkaesqueesque.common.requests.AbstractRequest v, v; org.apache.kafkaesqueesque.common.requests.RequestContext v; org.apache.kafkaesqueesque.common.network.NetworkSend v; org.apache.kafkaesqueesque.common.requests.RequestHeader v; org.apache.kafkaesqueesque.common.security.kerberos.KerberosError v; org.apache.kafkaesqueesque.common.errors.IllegalSaslStateException v; javax.security.sasl.SaslServer v, v, v, v, v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v := @parameter: byte[]; v = v.; if v != 0 goto label; v = v.; v = interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; specialinvoke v.(); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: if v == null goto label; v = new org.apache.kafkaesqueesque.common.network.NetworkSend; v = v.; v = staticinvoke (v); specialinvoke v.(java.lang.String,java.nio.ByteBuffer)>(v, v); v. = v; specialinvoke v.(); goto label; label: v = staticinvoke (v); v = staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = new org.apache.kafkaesqueesque.common.requests.RequestContext; v = v.; v = specialinvoke v.(); v = ; v = v.; v = v.; v = ; specialinvoke v.(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)>(v, v, v, v, v, v, v); v = virtualinvoke v.(v); v = ; if v == v goto label; v = new org.apache.kafkaesqueesque.common.errors.IllegalSaslStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unexpected Kafka request of type \u during SASL authentication."); specialinvoke v.(java.lang.String)>(v); v = v.; v = virtualinvoke v.(v); specialinvoke v.(v, v); throw v; label: v = virtualinvoke v.(v); if v != 0 goto label; v = new org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Version \u is not supported for apiKey \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = v.; if v != 0 goto label; v = v.; if v <= 0 goto label; v = 1; goto label; label: v = 0; label: v. = v; label: v = v.; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: if v != null goto label; v = newarray (byte)[0]; goto label; label: v = v; label: v = v; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = 0L; goto label; label: v = v.; v = specialinvoke v.(); label: v = new org.apache.kafkaesqueesque.common.requests.SaslAuthenticateResponse; v = new org.apache.kafkaesqueesque.common.message.SaslAuthenticateResponseData; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(v); specialinvoke v.(org.apache.kafkaesqueesque.common.message.SaslAuthenticateResponseData)>(v); specialinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = new org.apache.kafkaesqueesque.common.requests.SaslAuthenticateResponse; v = new org.apache.kafkaesqueesque.common.message.SaslAuthenticateResponseData; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); specialinvoke v.(org.apache.kafkaesqueesque.common.message.SaslAuthenticateResponseData)>(v); specialinvoke v.(v, v); throw v; label: v := @caughtexception; v = staticinvoke (v); if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; throw v; label: v = v.; v = virtualinvoke v.(); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Authentication failed during \u due to invalid credentials with SASL mechanism \u0001"); v = new org.apache.kafkaesqueesque.common.requests.SaslAuthenticateResponse; v = new org.apache.kafkaesqueesque.common.message.SaslAuthenticateResponseData; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); specialinvoke v.(org.apache.kafkaesqueesque.common.message.SaslAuthenticateResponseData)>(v); specialinvoke v.(v, v); v = new org.apache.kafkaesqueesque.common.errors.SaslAuthenticationException; specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: return; catch org.apache.kafkaesqueesque.common.errors.SaslAuthenticationException from label to label with label; catch javax.security.sasl.SaslException from label to label with label; } private boolean handleKafkaRequest(byte[]) throws java.io.IOException, org.apache.kafkaesqueesque.common.errors.AuthenticationException { byte[] v; org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipal v; org.apache.kafkaesqueesque.common.requests.RequestAndSize v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; java.lang.Integer v; java.nio.ByteBuffer v; java.net.InetAddress v; byte v; java.lang.Byte v; boolean v, v, v, v, v; org.apache.kafkaesqueesque.common.protocol.ApiKeys v, v, v, v; org.apache.kafkaesqueesque.common.requests.AbstractRequest v, v; org.apache.kafkaesqueesque.common.requests.RequestContext v; org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol v; org.apache.kafkaesqueesque.common.network.ClientInformation v; org.apache.kafkaesqueesque.common.errors.InvalidRequestException v; java.util.List v; java.lang.StringBuilder v; org.apache.kafkaesqueesque.common.requests.RequestHeader v; java.lang.Object[] v; org.apache.kafkaesqueesque.common.errors.UnsupportedSaslMechanismException v; org.apache.kafkaesqueesque.common.network.ListenerName v; int v, v, v, v; java.lang.String v, v, v, v, v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$ReauthInfo v, v, v; org.slf4j.Logger v, v, v, v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$SaslState v, v, v, v, v, v; org.apache.kafkaesqueesque.common.errors.IllegalSaslStateException v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v := @parameter: byte[]; v = 0; v = null; label: v = staticinvoke (v); v = staticinvoke (v); v = virtualinvoke v.(); v = v.; v = ; if v != v goto label; v = ; specialinvoke v.(v); label: v = 1; v = ; if v == v goto label; v = ; if v == v goto label; v = new org.apache.kafkaesqueesque.common.errors.IllegalSaslStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unexpected Kafka request of type \u during SASL handshake."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = ; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("Handling Kafka request {} during {}", v, v); v = new org.apache.kafkaesqueesque.common.requests.RequestContext; v = v.; v = specialinvoke v.(); v = ; v = v.; v = v.; v = ; specialinvoke v.(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)>(v, v, v, v, v, v, v); v = virtualinvoke v.(v); v = ; if v != v goto label; v = v.; specialinvoke v.(v, v); goto label; label: v = v.; v = specialinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = v.; v = ; if v != v goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = new java.lang.StringBuilder; specialinvoke v.()>(); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = newarray (java.lang.Object)[1]; v = staticinvoke (v); v[0] = v; v = staticinvoke ("%02x", v); virtualinvoke v.(v); v = virtualinvoke v.(); if v >= 20 goto label; v = v + 1; goto label; label: v = ; v = lengthof v; v = staticinvoke (v); interfaceinvoke v.("Received client packet of length {} starting with bytes 0x{}, process as GSSAPI packet", v, v); label: v = v.; v = interfaceinvoke v.("GSSAPI"); if v == 0 goto label; v = ; interfaceinvoke v.("First client packet is not a SASL mechanism request, using default mechanism GSSAPI"); v = "GSSAPI"; goto label; label: v = new org.apache.kafkaesqueesque.common.errors.UnsupportedSaslMechanismException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Exception handling first SASL packet from client, GSSAPI is not supported by server", v); throw v; label: throw v; label: if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; label: specialinvoke v.(v); v = ; specialinvoke v.(v); label: return v; catch org.apache.kafkaesqueesque.common.errors.InvalidRequestException from label to label with label; } private java.lang.String handleHandshakeRequest(org.apache.kafkaesqueesque.common.requests.RequestContext, org.apache.kafkaesqueesque.common.requests.SaslHandshakeRequest) throws java.io.IOException, org.apache.kafkaesqueesque.common.errors.UnsupportedSaslMechanismException { org.apache.kafkaesqueesque.common.requests.RequestHeader v; org.apache.kafkaesqueesque.common.requests.SaslHandshakeRequest v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; org.apache.kafkaesqueesque.common.message.SaslHandshakeResponseData v, v, v, v, v, v; org.apache.kafkaesqueesque.common.errors.UnsupportedSaslMechanismException v; org.apache.kafkaesqueesque.common.message.SaslHandshakeRequestData v; short v, v, v; org.apache.kafkaesqueesque.common.protocol.Errors v, v; java.lang.String v, v; boolean v; org.apache.kafkaesqueesque.common.requests.RequestContext v; org.apache.kafkaesqueesque.common.requests.SaslHandshakeResponse v, v; org.slf4j.Logger v, v; java.util.List v, v, v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v := @parameter: org.apache.kafkaesqueesque.common.requests.RequestContext; v := @parameter: org.apache.kafkaesqueesque.common.requests.SaslHandshakeRequest; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v < 1 goto label; virtualinvoke v.(1); label: v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = ; interfaceinvoke v.("Using SASL mechanism \'{}\' provided by client", v); v = new org.apache.kafkaesqueesque.common.requests.SaslHandshakeResponse; v = new org.apache.kafkaesqueesque.common.message.SaslHandshakeResponseData; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v); specialinvoke v.(org.apache.kafkaesqueesque.common.message.SaslHandshakeResponseData)>(v); specialinvoke v.(v, v); return v; label: v = ; interfaceinvoke v.("SASL mechanism \'{}\' requested by client is not supported", v); v = new org.apache.kafkaesqueesque.common.requests.SaslHandshakeResponse; v = new org.apache.kafkaesqueesque.common.message.SaslHandshakeResponseData; specialinvoke v.()>(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v); specialinvoke v.(org.apache.kafkaesqueesque.common.message.SaslHandshakeResponseData)>(v); specialinvoke v.(v, v); v = new org.apache.kafkaesqueesque.common.errors.UnsupportedSaslMechanismException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unsupported SASL mechanism \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; } protected org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse apiVersionsResponse() { org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v = ; return v; } protected void enableKafkaSaslAuthenticateHeaders(boolean) { org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; boolean v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v := @parameter: boolean; v. = v; return; } private void handleApiVersionsRequest(org.apache.kafkaesqueesque.common.requests.RequestContext, org.apache.kafkaesqueesque.common.requests.ApiVersionsRequest) throws java.io.IOException { java.lang.IllegalStateException v; org.apache.kafkaesqueesque.common.requests.ApiVersionsRequest v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator v; org.apache.kafkaesqueesque.common.network.ChannelMetadataRegistry v; org.apache.kafkaesqueesque.common.protocol.Errors v, v; java.lang.String v, v, v; org.apache.kafkaesqueesque.common.requests.ApiVersionsResponse v, v, v; boolean v, v; org.apache.kafkaesqueesque.common.requests.RequestContext v; org.apache.kafkaesqueesque.common.errors.ApiException v, v; org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator$SaslState v, v, v, v; org.apache.kafkaesqueesque.common.network.ClientInformation v; org.apache.kafkaesqueesque.common.message.ApiVersionsRequestData v, v; v := @this: org.apache.kafkaesqueesque.common.security.authenticator.SaslServerAuthenticator; v := @parameter: org.apache.kafkaesqueesque.common.requests.RequestContext; v := @parameter: org.apache.kafkaesqueesque.common.requests.ApiVersionsRequest; v = v.; v = ; if v == v goto label; v = new java.lang.IllegalStateException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Unexpected ApiVersions request received during SASL authentication state \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(0, v); specialinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); if v != 0 goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(0, v); specialinvoke v.(v, v); goto label; label: v = v.; v = new org.apache.kafkaesqueesque.common.network.ClientInformation; v = v.