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 typeC
- Client connection typeHS
- Handshake send typeHR
- 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
ConstructorDescriptionAuthenticationOutcomeListener
(BasicClient<T, C, HS, HR> client, C connection, T saslRpcType, org.apache.hadoop.security.UserGroupInformation ugi, RpcOutcomeListener<?> completionListener) -
Method Summary
Modifier and TypeMethodDescriptionvoid
failed
(RpcException ex) Called when an error occurred while waiting for the RPC outcome.void
void
Called when the sending thread is interrupted.void
success
(UserBitShared.SaslMessage value, io.netty.buffer.ByteBuf buffer)
-
Constructor Details
-
AuthenticationOutcomeListener
public AuthenticationOutcomeListener(BasicClient<T, C, HS, HR> client, C connection, T saslRpcType, org.apache.hadoop.security.UserGroupInformation ugi, RpcOutcomeListener<?> completionListener)
-
-
Method Details
-
initiate
-
failed
Description copied from interface:RpcOutcomeListener
Called when an error occurred while waiting for the RPC outcome.- Specified by:
failed
in interfaceRpcOutcomeListener<T extends com.google.protobuf.Internal.EnumLite>
-
interrupted
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 interfaceRpcOutcomeListener<T extends com.google.protobuf.Internal.EnumLite>
-