org.apache.hadoop.hbase.ipc

Class SimpleServerRpcConnection

java.lang.Object

org.apache.hadoop.hbase.ipc.ServerRpcConnection

org.apache.hadoop.hbase.ipc.SimpleServerRpcConnection

All Implemented Interfaces:

Closeable, AutoCloseable

@InterfaceAudience.Private
class SimpleServerRpcConnection
extends ServerRpcConnection

Reads calls from a connection and queues them for handling.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) SocketChannel	channel
private boolean	connectionPreambleRead
private ByteBuff	data
private ByteBuffer	dataLengthBuffer
private long	lastContact
(package private) long	lastSentTime
private ByteBuffer	preambleBuffer
(package private) SimpleRpcServerResponder	responder
(package private) ConcurrentLinkedDeque<RpcResponse>	responseQueue
(package private) Lock	responseWriteLock
private LongAdder	rpcCount
private Socket	socket

Fields inherited from class org.apache.hadoop.hbase.ipc.ServerRpcConnection

addr, authenticatedWithFallback, authMethod, callCleanup, codec, compressionCodec, connectionHeader, connectionHeaderRead, cryptoAES, hostAddress, remotePort, retryImmediatelySupported, rpcServer, saslContextEstablished, saslServer, service, skipInitialSaslHandshake, ugi, useCryptoAesWrap, user, useSasl, useWrap

Constructor Summary

Constructors

Constructor and Description
SimpleServerRpcConnection(SimpleRpcServer rpcServer, SocketChannel channel, long lastContact)

Method Summary

Modifier and Type	Method and Description
protected int	channelDataRead(ReadableByteChannel channel, ByteBuff buf)
void	close()
SimpleServerCall	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)
protected void	decRpcCount()
protected void	doRespond(RpcResponse resp)
long	getLastContact()
protected void	incRpcCount()
private void	initByteBuffToReadInto(int length)
boolean	isConnectionOpen()
(package private) boolean	isIdle()
private void	process() Process the data buffer and clean the connection state for the next call.
private int	read4Bytes()
int	readAndProcess() Read off the wire.
private int	readPreamble()
void	setLastContact(long lastContact)

Methods inherited from class org.apache.hadoop.hbase.ipc.ServerRpcConnection

disposeSasl, doRawSaslReply, getErrorResponse, getHostAddress, getHostInetAddress, getRemotePort, getVersionInfo, processOneRpc, processPreamble, processRequest, saslReadAndProcess, toString

Methods inherited from class java.lang.Object

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

Field Detail

channel

final SocketChannel channel

data

private ByteBuff data

dataLengthBuffer

private ByteBuffer dataLengthBuffer

preambleBuffer

private ByteBuffer preambleBuffer

rpcCount

private final LongAdder rpcCount

lastContact

private long lastContact

socket

private final Socket socket

responder

final SimpleRpcServerResponder responder

connectionPreambleRead

private boolean connectionPreambleRead

responseQueue

final ConcurrentLinkedDeque<RpcResponse> responseQueue

responseWriteLock

final Lock responseWriteLock

lastSentTime

long lastSentTime

Constructor Detail

SimpleServerRpcConnection

public SimpleServerRpcConnection(SimpleRpcServer rpcServer,
                                 SocketChannel channel,
                                 long lastContact)

Method Detail

setLastContact

public void setLastContact(long lastContact)

getLastContact

public long getLastContact()

isIdle

boolean isIdle()

decRpcCount

protected void decRpcCount()

incRpcCount

protected void incRpcCount()

readPreamble

private int readPreamble()
                  throws IOException

Throws:

IOException

read4Bytes

private int read4Bytes()
                throws IOException

Throws:

IOException

readAndProcess

public int readAndProcess()
                   throws IOException,
                          InterruptedException

Read off the wire. If there is not enough data to read, update the connection state with what we have and returns.

Returns:

Returns -1 if failure (and caller will close connection), else zero or more.

Throws:

IOException

InterruptedException

initByteBuffToReadInto

private void initByteBuffToReadInto(int length)

channelDataRead

protected int channelDataRead(ReadableByteChannel channel,
                              ByteBuff buf)
                       throws IOException

Throws:

IOException

process

private void process()
              throws IOException,
                     InterruptedException

Process the data buffer and clean the connection state for the next call.

Throws:

IOException

InterruptedException

close

public void close()

isConnectionOpen

public boolean isConnectionOpen()

Specified by:

isConnectionOpen in class ServerRpcConnection

createCall

public SimpleServerCall 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)

Specified by:

createCall in class ServerRpcConnection

doRespond

protected void doRespond(RpcResponse resp)
                  throws IOException

Specified by:

doRespond in class ServerRpcConnection

Throws:

IOException