Package org.apache.hadoop.hbase.ipc

Class NettyServerCall

java.lang.Object

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

org.apache.hadoop.hbase.ipc.NettyServerCall

All Implemented Interfaces:

RpcCall, RpcCallContext, RpcResponse

@Private
class NettyServerCall
extends ServerCall<NettyServerRpcConnection>

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

Since:

2.0.0

Field Summary

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

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

Constructor Summary

Constructors

Constructor

Description

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

Method Summary

Modifier and Type	Method	Description
void	sendResponseIfReady()	If we have a response, and delay is not set, then respond immediately.

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

cleanup, createHeaderAndMessageBytes, disconnectSince, done, getBlockBytesScanned, getCellScanner, getClientCertificateChain, getClientVersionInfo, getConnectionAttributes, getDeadline, getFsReadTime, getHeader, getMethod, getParam, getPriority, getReceiveTime, getRemoteAddress, getRemotePort, getRequestAttribute, getRequestAttributes, getRequestUser, getResponse, getResponseCellSize, getResponseExceptionSize, getService, getSize, getStartTime, getTimeout, incrementBlockBytesScanned, incrementResponseCellSize, incrementResponseExceptionSize, isClientCellBlockSupported, isRetryImmediatelySupported, releaseByWAL, retainByWAL, setCallBack, setExceptionResponse, setResponse, setStartTime, toShortString, toString, updateFsReadTime

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

Constructor Details

NettyServerCall

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

Method Details

sendResponseIfReady

public void sendResponseIfReady()
                         throws IOException

If we have a response, and delay is not set, then respond immediately. Otherwise, do not respond to client. This is called by the RPC code in the context of the Handler thread.

Throws:

IOException