org.apache.hadoop.hbase.ipc

Class SimpleServerCall

java.lang.Object

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

org.apache.hadoop.hbase.ipc.SimpleServerCall

All Implemented Interfaces:

RpcCall, RpcCallContext, RpcResponse

@InterfaceAudience.Private
class SimpleServerCall
extends ServerCall<SimpleServerRpcConnection>

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

Field Summary

Fields

Modifier and Type	Field and Description
(package private) SimpleRpcServerResponder	responder

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

cellBlockBuilder, cellBlockStream, cellScanner, connection, deadline, header, id, isError, md, param, receiveTime, remoteAddress, reqCleanup, reservoir, response, rpcCallback, service, size, startTime, timeout, user

Constructor Summary

Constructors

Constructor and Description

SimpleServerCall(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, SimpleServerRpcConnection connection, long size, InetAddress remoteAddress, long receiveTime, int timeout, ByteBufferPool reservoir, CellBlockBuilder cellBlockBuilder, RpcServer.CallCleanup reqCleanup, SimpleRpcServerResponder responder)

Method Summary

Modifier and Type	Method and Description
void	done() Call is done.
(package private) SimpleServerRpcConnection	getConnection()
void	sendResponseIfReady() Send the response of this RPC call.

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

cleanup, createHeaderAndMessageBytes, disconnectSince, getCellScanner, getClientVersionInfo, getDeadline, getHeader, getMethod, getParam, getPriority, getReceiveTime, getRemoteAddress, getRemotePort, getRequestUser, getResponse, getResponseBlockSize, getResponseCellSize, getResponseExceptionSize, getService, getSize, getStartTime, getTimeout, incrementResponseBlockSize, incrementResponseCellSize, incrementResponseExceptionSize, isClientCellBlockSupported, isRetryImmediatelySupported, releaseByWAL, retainByWAL, setCallBack, setExceptionResponse, setResponse, setStartTime, toShortString, toString, wrapWithSasl

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

getRequestUserName

Field Detail

responder

final SimpleRpcServerResponder responder

Constructor Detail

SimpleServerCall

SimpleServerCall(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,
                 SimpleServerRpcConnection connection,
                 long size,
                 InetAddress remoteAddress,
                 long receiveTime,
                 int timeout,
                 ByteBufferPool reservoir,
                 CellBlockBuilder cellBlockBuilder,
                 RpcServer.CallCleanup reqCleanup,
                 SimpleRpcServerResponder responder)

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

Overrides:

done in class ServerCall<SimpleServerRpcConnection>

sendResponseIfReady

public void sendResponseIfReady()
                         throws IOException

Description copied from interface: RpcCall

Send the response of this RPC call. Implementation provides the underlying facility (connection, etc) to send.

Throws:

IOException

getConnection

SimpleServerRpcConnection getConnection()