org.apache.hadoop.hbase.ipc

Class ServerCall<T extends ServerRpcConnection>

java.lang.Object

org.apache.hadoop.hbase.ipc.ServerCall<T>

All Implemented Interfaces:

RpcCall, RpcCallContext, RpcResponse

Direct Known Subclasses:

NettyServerCall, SimpleServerCall

@InterfaceAudience.Private
public abstract class ServerCall<T extends ServerRpcConnection>
extends Object
implements RpcCall, RpcResponse

Datastructure that holds all necessary to a method invocation and then afterward, carries the result.

Field Summary

Fields

Modifier and Type	Field and Description
protected ByteBuffAllocator	bbAllocator
protected CellBlockBuilder	cellBlockBuilder
protected ByteBufferListOutputStream	cellBlockStream
protected CellScanner	cellScanner
protected T	connection
protected long	deadline
private long	exceptionSize
protected org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader	header
protected int	id
protected boolean	isError
protected org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor	md
protected org.apache.hbase.thirdparty.com.google.protobuf.Message	param
protected long	receiveTime
private AtomicInteger	reference
protected InetAddress	remoteAddress
protected RpcServer.CallCleanup	reqCleanup
protected BufferChain	response Chain of buffers to send as response.
private long	responseBlockSize
private long	responseCellSize
private boolean	retryImmediatelySupported
protected RpcCallback	rpcCallback
protected org.apache.hbase.thirdparty.com.google.protobuf.BlockingService	service
protected long	size
protected long	startTime
protected int	timeout
protected User	user

Constructor Summary

Constructors

Constructor and Description

ServerCall(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, T connection, long size, InetAddress remoteAddress, long receiveTime, int timeout, ByteBuffAllocator byteBuffAllocator, CellBlockBuilder cellBlockBuilder, RpcServer.CallCleanup reqCleanup)

Method Summary

Modifier and Type	Method and Description
void	cleanup() Do the necessary cleanup after the call if needed.
private static ByteBuffer	createHeaderAndMessageBytes(org.apache.hbase.thirdparty.com.google.protobuf.Message result, org.apache.hbase.thirdparty.com.google.protobuf.Message header, int totalSize, int totalPBSize)
(package private) static ByteBuffer	createHeaderAndMessageBytes(org.apache.hbase.thirdparty.com.google.protobuf.Message result, org.apache.hbase.thirdparty.com.google.protobuf.Message header, int cellBlockSize, List<ByteBuffer> cellBlock)
long	disconnectSince() Check if the caller who made this IPC call has disconnected.
void	done() Call is done.
CellScanner	getCellScanner()
org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.VersionInfo	getClientVersionInfo()
long	getDeadline() Return the deadline of this call.
org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader	getHeader()
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor	getMethod()
org.apache.hbase.thirdparty.com.google.protobuf.Message	getParam()
int	getPriority()
long	getReceiveTime()
InetAddress	getRemoteAddress()
int	getRemotePort()
Optional<User>	getRequestUser() Returns the user credentials associated with the current RPC request or not present if no credentials were provided.
BufferChain	getResponse()
long	getResponseBlockSize()
long	getResponseCellSize() The size of response cells that have been accumulated so far.
long	getResponseExceptionSize()
org.apache.hbase.thirdparty.com.google.protobuf.BlockingService	getService()
long	getSize() Used to calculate the request call queue size.
long	getStartTime()
int	getTimeout()
void	incrementResponseBlockSize(long blockSize)
void	incrementResponseCellSize(long cellSize) Add on the given amount to the retained cell size.
void	incrementResponseExceptionSize(long exSize)
boolean	isClientCellBlockSupported() If the client connected and specified a codec to use, then we will use this codec making cellblocks to return.
boolean	isRetryImmediatelySupported()
private void	release(int mask)
void	releaseByWAL()
void	retainByWAL()
void	setCallBack(RpcCallback callback) Sets a callback which has to be executed at the end of this RPC call.
(package private) static void	setExceptionResponse(Throwable t, String errorMsg, org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ResponseHeader.Builder headerBuilder)
void	setResponse(org.apache.hbase.thirdparty.com.google.protobuf.Message m, CellScanner cells, Throwable t, String errorMsg) Set the response resulting from this RPC call.
void	setStartTime(long t) Set the time when the call starts to be executed.
String	toShortString()
String	toString()
protected BufferChain	wrapWithSasl(BufferChain bc)
private static void	writeToCOS(org.apache.hbase.thirdparty.com.google.protobuf.Message result, org.apache.hbase.thirdparty.com.google.protobuf.Message header, int totalSize, ByteBuffer pbBuf)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.ipc.RpcCall

sendResponseIfReady

Methods inherited from interface org.apache.hadoop.hbase.ipc.RpcCallContext

getRequestUserName

Field Detail

id

protected final int id

service

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

md

protected final org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md

header

protected final org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header

param

protected org.apache.hbase.thirdparty.com.google.protobuf.Message param

cellScanner

protected final CellScanner cellScanner

connection

protected final T extends ServerRpcConnection connection

receiveTime

protected final long receiveTime

timeout

protected final int timeout

startTime

protected long startTime

deadline

protected final long deadline

bbAllocator

protected final ByteBuffAllocator bbAllocator

cellBlockBuilder

protected final CellBlockBuilder cellBlockBuilder

response

protected BufferChain response

Chain of buffers to send as response.

size

protected final long size

isError

protected boolean isError

cellBlockStream

protected ByteBufferListOutputStream cellBlockStream

reqCleanup

protected RpcServer.CallCleanup reqCleanup

user

protected final User user

remoteAddress

protected final InetAddress remoteAddress

rpcCallback

protected RpcCallback rpcCallback

responseCellSize

private long responseCellSize

responseBlockSize

private long responseBlockSize

exceptionSize

private long exceptionSize

retryImmediatelySupported

private final boolean retryImmediatelySupported

reference

private final AtomicInteger reference

Constructor Detail

ServerCall

ServerCall(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,
           T connection,
           long size,
           InetAddress remoteAddress,
           long receiveTime,
           int timeout,
           ByteBuffAllocator byteBuffAllocator,
           CellBlockBuilder cellBlockBuilder,
           RpcServer.CallCleanup reqCleanup)

Method Detail

done

public void done()

Call is done. Execution happened and we returned results to client. It is now safe to cleanup.

Specified by:

done in interface RpcResponse

release

private void release(int mask)

cleanup

public void cleanup()

Description copied from interface: RpcCall

Do the necessary cleanup after the call if needed.

Specified by:

cleanup in interface RpcCall

retainByWAL

public void retainByWAL()

releaseByWAL

public void releaseByWAL()

toString

public String toString()

Overrides:

toString in class Object

getHeader

public org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader getHeader()

Specified by:

getHeader in interface RpcCall

Returns:

The request header of this call.

getPriority

public int getPriority()

Specified by:

getPriority in interface RpcCall

Returns:

The Priority of this call.

toShortString

public String toShortString()

Specified by:

toShortString in interface RpcCall

Returns:

A short string format of this call without possibly lengthy params

setResponse

public void setResponse(org.apache.hbase.thirdparty.com.google.protobuf.Message m,
                        CellScanner cells,
                        Throwable t,
                        String errorMsg)

Description copied from interface: RpcCall

Set the response resulting from this RPC call.

Specified by:

setResponse in interface RpcCall

Parameters:

m - The result message as response.

cells - The CellScanner that possibly carries the payload.

t - The error Throwable resulting from the call.

errorMsg - Extra error message.

setExceptionResponse

static void setExceptionResponse(Throwable t,
                                 String errorMsg,
                                 org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ResponseHeader.Builder headerBuilder)

createHeaderAndMessageBytes

static ByteBuffer createHeaderAndMessageBytes(org.apache.hbase.thirdparty.com.google.protobuf.Message result,
                                              org.apache.hbase.thirdparty.com.google.protobuf.Message header,
                                              int cellBlockSize,
                                              List<ByteBuffer> cellBlock)
                                       throws IOException

Throws:

IOException

writeToCOS

private static void writeToCOS(org.apache.hbase.thirdparty.com.google.protobuf.Message result,
                               org.apache.hbase.thirdparty.com.google.protobuf.Message header,
                               int totalSize,
                               ByteBuffer pbBuf)
                        throws IOException

Throws:

IOException

createHeaderAndMessageBytes

private static ByteBuffer createHeaderAndMessageBytes(org.apache.hbase.thirdparty.com.google.protobuf.Message result,
                                                      org.apache.hbase.thirdparty.com.google.protobuf.Message header,
                                                      int totalSize,
                                                      int totalPBSize)
                                               throws IOException

Throws:

IOException

wrapWithSasl

protected BufferChain wrapWithSasl(BufferChain bc)
                            throws IOException

Throws:

IOException

disconnectSince

public long disconnectSince()

Description copied from interface: RpcCallContext

Check if the caller who made this IPC call has disconnected. If called from outside the context of IPC, this does nothing.

Specified by:

disconnectSince in interface RpcCallContext

Returns:

< 0 if the caller is still connected. The time in ms since the disconnection otherwise

isClientCellBlockSupported

public boolean isClientCellBlockSupported()

Description copied from interface: RpcCallContext

If the client connected and specified a codec to use, then we will use this codec making cellblocks to return. If the client did not specify a codec, we assume it does not support cellblocks and will return all content protobuf'd (though it makes our serving slower). We need to ask this question per call because a server could be hosting both clients that support cellblocks while fielding requests from clients that do not.

Specified by:

isClientCellBlockSupported in interface RpcCallContext

Returns:

True if the client supports cellblocks, else return all content in pb

getResponseCellSize

public long getResponseCellSize()

Description copied from interface: RpcCallContext

The size of response cells that have been accumulated so far. This along with the corresponding increment call is used to ensure that multi's or scans dont get too excessively large

Specified by:

getResponseCellSize in interface RpcCallContext

incrementResponseCellSize

public void incrementResponseCellSize(long cellSize)

Description copied from interface: RpcCallContext

Add on the given amount to the retained cell size. This is not thread safe and not synchronized at all. If this is used by more than one thread then everything will break. Since this is called for every row synchronization would be too onerous.

Specified by:

incrementResponseCellSize in interface RpcCallContext

getResponseBlockSize

public long getResponseBlockSize()

Specified by:

getResponseBlockSize in interface RpcCallContext

incrementResponseBlockSize

public void incrementResponseBlockSize(long blockSize)

Specified by:

incrementResponseBlockSize in interface RpcCallContext

getResponseExceptionSize

public long getResponseExceptionSize()

Specified by:

getResponseExceptionSize in interface RpcCallContext

incrementResponseExceptionSize

public void incrementResponseExceptionSize(long exSize)

Specified by:

incrementResponseExceptionSize in interface RpcCallContext

getSize

public long getSize()

Description copied from interface: RpcCall

Used to calculate the request call queue size. If the total request call size exceeds a limit, the call will be rejected.

Specified by:

getSize in interface RpcCall

Returns:

The raw size of this call.

getDeadline

public long getDeadline()

Description copied from interface: RpcCall

Return the deadline of this call. If we can not complete this call in time, we can throw a TimeoutIOException and RPCServer will drop it.

Specified by:

getDeadline in interface RpcCall

Returns:

The system timestamp of deadline.

getRequestUser

public Optional<User> getRequestUser()

Description copied from interface: RpcCallContext

Returns the user credentials associated with the current RPC request or not present if no credentials were provided.

Specified by:

getRequestUser in interface RpcCallContext

Returns:

A User

getRemoteAddress

public InetAddress getRemoteAddress()

Specified by:

getRemoteAddress in interface RpcCallContext

Returns:

Address of remote client in this call

getClientVersionInfo

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

Specified by:

getClientVersionInfo in interface RpcCallContext

Returns:

the client version info, or null if the information is not present

setCallBack

public void setCallBack(RpcCallback callback)

Description copied from interface: RpcCallContext

Sets a callback which has to be executed at the end of this RPC call. Such a callback is an optional one for any Rpc call.

Specified by:

setCallBack in interface RpcCallContext

isRetryImmediatelySupported

public boolean isRetryImmediatelySupported()

Specified by:

isRetryImmediatelySupported in interface RpcCallContext

getService

public org.apache.hbase.thirdparty.com.google.protobuf.BlockingService getService()

Specified by:

getService in interface RpcCall

Returns:

The service of this call.

getMethod

public org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor getMethod()

Specified by:

getMethod in interface RpcCall

Returns:

The service method.

getParam

public org.apache.hbase.thirdparty.com.google.protobuf.Message getParam()

Specified by:

getParam in interface RpcCall

Returns:

The call parameter message.

getCellScanner

public CellScanner getCellScanner()

Specified by:

getCellScanner in interface RpcCall

Returns:

The CellScanner that can carry input and result payload.

getReceiveTime

public long getReceiveTime()

Specified by:

getReceiveTime in interface RpcCall

Returns:

The timestamp when the call is constructed.

getStartTime

public long getStartTime()

Specified by:

getStartTime in interface RpcCall

Returns:

The time when the call starts to be executed.

setStartTime

public void setStartTime(long t)

Description copied from interface: RpcCall

Set the time when the call starts to be executed.

Specified by:

setStartTime in interface RpcCall

getTimeout

public int getTimeout()

Specified by:

getTimeout in interface RpcCall

Returns:

The timeout of this call.

getRemotePort

public int getRemotePort()

Specified by:

getRemotePort in interface RpcCall

Returns:

Port of remote address in this call

getResponse

public BufferChain getResponse()

Specified by:

getResponse in interface RpcResponse