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

Deprecated.

@Deprecated
 @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 Deprecated.
private boolean	connectionPreambleRead Deprecated.
private ByteBuff	data Deprecated.
private ByteBuffer	dataLengthBuffer Deprecated.
private long	lastContact Deprecated.
(package private) long	lastSentTime Deprecated.
private ByteBuffer	preambleBuffer Deprecated.
(package private) SimpleRpcServerResponder	responder Deprecated.
(package private) ConcurrentLinkedDeque<RpcResponse>	responseQueue Deprecated.
(package private) Lock	responseWriteLock Deprecated.
private LongAdder	rpcCount Deprecated.
private Socket	socket Deprecated.

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

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

Constructor Summary

Constructors

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

Method Summary

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

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

callCleanupIfNeeded, disposeSasl, doRawSaslReply, getErrorResponse, getHostAddress, getHostInetAddress, getRemotePort, getVersionInfo, isSimpleAuthentication, 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

Deprecated.

data

private ByteBuff data

Deprecated.

dataLengthBuffer

private ByteBuffer dataLengthBuffer

Deprecated.

preambleBuffer

private ByteBuffer preambleBuffer

Deprecated.

rpcCount

private final LongAdder rpcCount

Deprecated.

lastContact

private long lastContact

Deprecated.

socket

private final Socket socket

Deprecated.

responder

final SimpleRpcServerResponder responder

Deprecated.

connectionPreambleRead

private boolean connectionPreambleRead

Deprecated.

responseQueue

final ConcurrentLinkedDeque<RpcResponse> responseQueue

Deprecated.

responseWriteLock

final Lock responseWriteLock

Deprecated.

lastSentTime

long lastSentTime

Deprecated.

Constructor Detail

SimpleServerRpcConnection

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

Deprecated.

Method Detail

setLastContact

public void setLastContact(long lastContact)

Deprecated.

getLastContact

public long getLastContact()

Deprecated.

isIdle

boolean isIdle()

Deprecated.

decRpcCount

protected void decRpcCount()

Deprecated.

incRpcCount

protected void incRpcCount()

Deprecated.

readPreamble

private int readPreamble()
                  throws IOException

Deprecated.

Throws:

IOException

read4Bytes

private int read4Bytes()
                throws IOException

Deprecated.

Throws:

IOException

readAndProcess

public int readAndProcess()
                   throws IOException,
                          InterruptedException

Deprecated.

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. nn

Throws:

IOException

InterruptedException

initByteBuffToReadInto

private void initByteBuffToReadInto(int length)

Deprecated.

channelDataRead

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

Deprecated.

Throws:

IOException

process

private void process()
              throws IOException,
                     InterruptedException

Deprecated.

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

Throws:

IOException

InterruptedException

close

public void close()

Deprecated.

isConnectionOpen

public boolean isConnectionOpen()

Deprecated.

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)

Deprecated.

Specified by:

createCall in class ServerRpcConnection

doRespond

protected void doRespond(RpcResponse resp)
                  throws IOException

Deprecated.

Specified by:

doRespond in class ServerRpcConnection

Throws:

IOException