Package 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
@Private
class SimpleServerRpcConnection
extends ServerRpcConnection

Deprecated.

Reads calls from a connection and queues them for handling.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.ipc.ServerRpcConnection

ServerRpcConnection.PreambleResponse

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final 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) final SimpleRpcServerResponder	responder	Deprecated.
(package private) final ConcurrentLinkedDeque<RpcResponse>	responseQueue	Deprecated.
(package private) final Lock	responseWriteLock	Deprecated.
private final LongAdder	rpcCount	Deprecated.
private boolean	saslContextEstablished	Deprecated.
private final Socket	socket	Deprecated.
private ByteBuffer	unwrappedData	Deprecated.
private ByteBuffer	unwrappedDataLengthBuffer	Deprecated.
(package private) boolean	useWrap	Deprecated.

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

addr, authenticatedWithFallback, callCleanup, clientCertificateChain, codec, compressionCodec, connectionAttributes, connectionHeader, connectionHeaderRead, hostAddress, provider, remotePort, retryImmediatelySupported, rpcServer, saslProviders, saslServer, service, skipInitialSaslHandshake, ugi, user, useSasl

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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, ExtendedCellScanner 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 void	processUnwrappedData(byte[] inBuf)	Deprecated.
private int	read4Bytes()	Deprecated.
int	readAndProcess()	Deprecated. Read off the wire.
private int	readPreamble()	Deprecated.
private void	saslReadAndProcess(ByteBuff saslToken)	Deprecated.
void	setLastContact(long lastContact)	Deprecated.

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

callCleanupIfNeeded, disposeSasl, doRawSaslReply, finishSaslNegotiation, getErrorResponse, getHostAddress, getHostInetAddress, getOrCreateSaslServer, getRemotePort, getVersionInfo, isSimpleAuthentication, processOneRpc, processPreamble, processRequest, toString

Methods inherited from class java.lang.Object

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

Field Details

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.

saslContextEstablished

private boolean saslContextEstablished

Deprecated.

unwrappedData

private ByteBuffer unwrappedData

Deprecated.

unwrappedDataLengthBuffer

private ByteBuffer unwrappedDataLengthBuffer

Deprecated.

useWrap

boolean useWrap

Deprecated.

responseQueue

final ConcurrentLinkedDeque<RpcResponse> responseQueue

Deprecated.

responseWriteLock

final Lock responseWriteLock

Deprecated.

lastSentTime

long lastSentTime

Deprecated.

Constructor Details

SimpleServerRpcConnection

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

Deprecated.

Method Details

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

processUnwrappedData

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

Deprecated.

Throws:

IOException

InterruptedException

saslReadAndProcess

private void saslReadAndProcess(ByteBuff saslToken)
                         throws IOException,
InterruptedException

Deprecated.

Throws:

IOException

InterruptedException

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.

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,
 ExtendedCellScanner 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