org.apache.drill.exec.rpc.security

Class AuthenticationOutcomeListener<T extends com.google.protobuf.Internal.EnumLite,C extends ClientConnection,HS extends com.google.protobuf.MessageLite,HR extends com.google.protobuf.MessageLite>

java.lang.Object

org.apache.drill.exec.rpc.security.AuthenticationOutcomeListener<T,C,HS,HR>

Type Parameters:

T - handshake rpc type

C - Client connection type

HS - Handshake send type

HR - Handshake receive type

All Implemented Interfaces:

RpcOutcomeListener<UserBitShared.SaslMessage>

public class AuthenticationOutcomeListener<T extends com.google.protobuf.Internal.EnumLite,C extends ClientConnection,HS extends com.google.protobuf.MessageLite,HR extends com.google.protobuf.MessageLite>
extends Object
implements RpcOutcomeListener<UserBitShared.SaslMessage>

Handles SASL exchange, on the client-side.

Constructor Summary

Constructors

Constructor and Description
AuthenticationOutcomeListener(BasicClient<T,C,HS,HR> client, C connection, T saslRpcType, org.apache.hadoop.security.UserGroupInformation ugi, RpcOutcomeListener<?> completionListener)

Method Summary

Modifier and Type	Method and Description
void	failed(RpcException ex) Called when an error occurred while waiting for the RPC outcome.
void	initiate(String mechanismName)
void	interrupted(InterruptedException e) Called when the sending thread is interrupted.
void	success(UserBitShared.SaslMessage value, io.netty.buffer.ByteBuf buffer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AuthenticationOutcomeListener

public AuthenticationOutcomeListener(BasicClient<T,C,HS,HR> client,
                                     C connection,
                                     T saslRpcType,
                                     org.apache.hadoop.security.UserGroupInformation ugi,
                                     RpcOutcomeListener<?> completionListener)

Method Detail

initiate

public void initiate(String mechanismName)

failed

public void failed(RpcException ex)

Description copied from interface: RpcOutcomeListener

Called when an error occurred while waiting for the RPC outcome.

Specified by:

failed in interface RpcOutcomeListener<UserBitShared.SaslMessage>

success

public void success(UserBitShared.SaslMessage value,
                    io.netty.buffer.ByteBuf buffer)

Specified by:

success in interface RpcOutcomeListener<UserBitShared.SaslMessage>

interrupted

public void interrupted(InterruptedException e)

Description copied from interface: RpcOutcomeListener

Called when the sending thread is interrupted. Possible when the fragment is cancelled due to query cancellations or failures.

Specified by:

interrupted in interface RpcOutcomeListener<UserBitShared.SaslMessage>