org.apache.drill.exec.rpc.security

Class ServerAuthenticationHandler<S extends ServerConnection<S>,T extends com.google.protobuf.Internal.EnumLite>

java.lang.Object

org.apache.drill.exec.rpc.security.ServerAuthenticationHandler<S,T>

Type Parameters:

S - Server connection type

T - RPC type

All Implemented Interfaces:

RequestHandler<S>

public class ServerAuthenticationHandler<S extends ServerConnection<S>,T extends com.google.protobuf.Internal.EnumLite>
extends Object
implements RequestHandler<S>

Handles SASL exchange, on the server-side.

Constructor Summary

Constructors

Constructor and Description
ServerAuthenticationHandler(RequestHandler<S> requestHandler, int saslRequestTypeValue, T saslResponseType)

Method Summary

Modifier and Type	Method and Description
void	handle(S connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender) Handle request of given type (rpcType) with message (pBody) and optional data (dBody) on the connection, and return the appropriate response.

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerAuthenticationHandler

public ServerAuthenticationHandler(RequestHandler<S> requestHandler,
                                   int saslRequestTypeValue,
                                   T saslResponseType)

Method Detail

handle

public void handle(S connection,
                   int rpcType,
                   io.netty.buffer.ByteBuf pBody,
                   io.netty.buffer.ByteBuf dBody,
                   ResponseSender sender)
            throws RpcException

Description copied from interface: RequestHandler

Handle request of given type (rpcType) with message (pBody) and optional data (dBody) on the connection, and return the appropriate response. The method must do one of three things: + use send the response + throw UserRpcException, in which case a response will be sent using send + throw an Exception, in which case, the connection will be dropped

Specified by:

handle in interface RequestHandler<S extends ServerConnection<S>>

Parameters:

connection - remote connection

rpcType - rpc type

pBody - message

dBody - data, maybe null

sender - used to send the response

Throws:

RpcException