org.apache.hadoop.hbase.ipc

Class ServerRpcConnection

java.lang.Object

org.apache.hadoop.hbase.ipc.ServerRpcConnection

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

NettyServerRpcConnection, SimpleServerRpcConnection

@InterfaceAudience.Private
abstract class ServerRpcConnection
extends Object
implements Closeable

Reads calls from a connection and queues them for handling.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	ServerRpcConnection.ByteBuffByteInput

Field Summary

Fields

Modifier and Type	Field and Description
protected InetAddress	addr
protected boolean	authenticatedWithFallback
protected AuthMethod	authMethod
protected RpcServer.CallCleanup	callCleanup
protected Codec	codec Codec the client asked use.
protected org.apache.hadoop.io.compress.CompressionCodec	compressionCodec Compression codec the client asked us use.
protected org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader	connectionHeader
protected boolean	connectionHeaderRead
protected CryptoAES	cryptoAES
protected String	hostAddress
protected int	remotePort
protected boolean	retryImmediatelySupported
protected RpcServer	rpcServer
protected boolean	saslContextEstablished
protected HBaseSaslRpcServer	saslServer
protected org.apache.hbase.thirdparty.com.google.protobuf.BlockingService	service
protected boolean	skipInitialSaslHandshake
protected org.apache.hadoop.security.UserGroupInformation	ugi
private ByteBuffer	unwrappedData
private ByteBuffer	unwrappedDataLengthBuffer
protected boolean	useCryptoAesWrap
protected User	user
protected boolean	useSasl
protected boolean	useWrap

Constructor Summary

Constructors

Constructor and Description
ServerRpcConnection(RpcServer rpcServer)

Method Summary

Modifier and Type	Method and Description
private boolean	authorizeConnection()
abstract ServerCall<?>	createCall(int id, org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service, org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param, CellScanner cellScanner, long size, InetAddress remoteAddress, int timeout, RpcServer.CallCleanup reqCleanup)
private org.apache.hadoop.security.UserGroupInformation	createUser(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader head)
protected void	disposeSasl()
private void	doBadPreambleHandling(String msg)
private void	doBadPreambleHandling(String msg, Exception e)
protected void	doRawSaslReply(SaslStatus status, org.apache.hadoop.io.Writable rv, String errorClass, String error) No protobuf encoding of raw sasl messages
protected abstract void	doRespond(RpcResponse resp)
private org.apache.hadoop.security.UserGroupInformation	getAuthorizedUgi(String authorizedId)
private org.apache.hbase.thirdparty.com.google.protobuf.ByteString	getByteString(byte[] bytes)
protected RpcResponse	getErrorResponse(String msg, Exception e)
private String	getFatalConnectionString(int version, byte authByte)
String	getHostAddress()
InetAddress	getHostInetAddress()
int	getRemotePort()
org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.VersionInfo	getVersionInfo()
abstract boolean	isConnectionOpen()
private void	processConnectionHeader(ByteBuff buf)
void	processOneRpc(ByteBuff buf)
protected boolean	processPreamble(ByteBuffer preambleBuffer)
protected void	processRequest(ByteBuff buf)
private void	processUnwrappedData(byte[] inBuf)
private void	responseConnectionHeader(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeaderResponse.Builder chrBuilder) Send the response for connection header
void	saslReadAndProcess(ByteBuff saslToken)
private void	setupCellBlockCodecs(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader header) Set up cell block codecs
private void	setupCryptoCipher(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader header, org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeaderResponse.Builder chrBuilder) Set up cipher for rpc encryption with Apache Commons Crypto
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Field Detail

rpcServer

protected final RpcServer rpcServer

connectionHeaderRead

protected boolean connectionHeaderRead

callCleanup

protected RpcServer.CallCleanup callCleanup

hostAddress

protected String hostAddress

remotePort

protected int remotePort

addr

protected InetAddress addr

connectionHeader

protected org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader connectionHeader

codec

protected Codec codec

Codec the client asked use.

compressionCodec

protected org.apache.hadoop.io.compress.CompressionCodec compressionCodec

Compression codec the client asked us use.

service

protected org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service

authMethod

protected AuthMethod authMethod

saslContextEstablished

protected boolean saslContextEstablished

skipInitialSaslHandshake

protected boolean skipInitialSaslHandshake

unwrappedData

private ByteBuffer unwrappedData

unwrappedDataLengthBuffer

private ByteBuffer unwrappedDataLengthBuffer

useSasl

protected boolean useSasl

saslServer

protected HBaseSaslRpcServer saslServer

cryptoAES

protected CryptoAES cryptoAES

useWrap

protected boolean useWrap

useCryptoAesWrap

protected boolean useCryptoAesWrap

authenticatedWithFallback

protected boolean authenticatedWithFallback

retryImmediatelySupported

protected boolean retryImmediatelySupported

user

protected User user

ugi

protected org.apache.hadoop.security.UserGroupInformation ugi

Constructor Detail

ServerRpcConnection

public ServerRpcConnection(RpcServer rpcServer)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getHostAddress

public String getHostAddress()

getHostInetAddress

public InetAddress getHostInetAddress()

getRemotePort

public int getRemotePort()

getVersionInfo

public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.VersionInfo getVersionInfo()

getFatalConnectionString

private String getFatalConnectionString(int version,
                                        byte authByte)

getAuthorizedUgi

private org.apache.hadoop.security.UserGroupInformation getAuthorizedUgi(String authorizedId)
                                                                  throws IOException

Throws:

IOException

setupCellBlockCodecs

private void setupCellBlockCodecs(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader header)
                           throws FatalConnectionException

Set up cell block codecs

Throws:

FatalConnectionException

setupCryptoCipher

private void setupCryptoCipher(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader header,
                               org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeaderResponse.Builder chrBuilder)
                        throws FatalConnectionException

Set up cipher for rpc encryption with Apache Commons Crypto

Throws:

FatalConnectionException

getByteString

private org.apache.hbase.thirdparty.com.google.protobuf.ByteString getByteString(byte[] bytes)

createUser

private org.apache.hadoop.security.UserGroupInformation createUser(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader head)

disposeSasl

protected final void disposeSasl()

doRawSaslReply

protected final void doRawSaslReply(SaslStatus status,
                                    org.apache.hadoop.io.Writable rv,
                                    String errorClass,
                                    String error)
                             throws IOException

No protobuf encoding of raw sasl messages

Throws:

IOException

saslReadAndProcess

public void saslReadAndProcess(ByteBuff saslToken)
                        throws IOException,
                               InterruptedException

Throws:

IOException

InterruptedException

processUnwrappedData

private void processUnwrappedData(byte[] inBuf)
                           throws IOException,
                                  InterruptedException

Throws:

IOException

InterruptedException

processOneRpc

public void processOneRpc(ByteBuff buf)
                   throws IOException,
                          InterruptedException

Throws:

IOException

InterruptedException

authorizeConnection

private boolean authorizeConnection()
                             throws IOException

Throws:

IOException

processConnectionHeader

private void processConnectionHeader(ByteBuff buf)
                              throws IOException

Throws:

IOException

responseConnectionHeader

private void responseConnectionHeader(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeaderResponse.Builder chrBuilder)
                               throws FatalConnectionException

Send the response for connection header

Throws:

FatalConnectionException

doRespond

protected abstract void doRespond(RpcResponse resp)
                           throws IOException

Throws:

IOException

processRequest

protected void processRequest(ByteBuff buf)
                       throws IOException,
                              InterruptedException

Parameters:

buf - Has the request header and the request param and optionally encoded data buffer all in this one array.

Throws:

IOException

InterruptedException

getErrorResponse

protected final RpcResponse getErrorResponse(String msg,
                                             Exception e)
                                      throws IOException

Throws:

IOException

doBadPreambleHandling

private void doBadPreambleHandling(String msg)
                            throws IOException

Throws:

IOException

doBadPreambleHandling

private void doBadPreambleHandling(String msg,
                                   Exception e)
                            throws IOException

Throws:

IOException

processPreamble

protected final boolean processPreamble(ByteBuffer preambleBuffer)
                                 throws IOException

Throws:

IOException

isConnectionOpen

public abstract boolean isConnectionOpen()

createCall

public abstract ServerCall<?> createCall(int id,
                                         org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
                                         org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
                                         org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header,
                                         org.apache.hbase.thirdparty.com.google.protobuf.Message param,
                                         CellScanner cellScanner,
                                         long size,
                                         InetAddress remoteAddress,
                                         int timeout,
                                         RpcServer.CallCleanup reqCleanup)