@InterfaceAudience.Private class NettyServerCall extends ServerCall<NettyServerRpcConnection>
bbAllocator, cellBlockBuilder, cellBlockStream, cellScanner, connection, deadline, header, id, isError, md, param, receiveTime, remoteAddress, reqCleanup, response, rpcCallback, service, size, startTime, timeout, user
Constructor and 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,
CellScanner cellScanner,
NettyServerRpcConnection connection,
long size,
InetAddress remoteAddress,
long receiveTime,
int timeout,
ByteBuffAllocator bbAllocator,
CellBlockBuilder cellBlockBuilder,
RpcServer.CallCleanup reqCleanup) |
Modifier and Type | Method and Description |
---|---|
void |
sendResponseIfReady()
If we have a response, and delay is not set, then respond immediately.
|
cleanup, createHeaderAndMessageBytes, disconnectSince, done, getCallBack, 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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getRequestUserName
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, CellScanner cellScanner, NettyServerRpcConnection connection, long size, InetAddress remoteAddress, long receiveTime, int timeout, ByteBuffAllocator bbAllocator, CellBlockBuilder cellBlockBuilder, RpcServer.CallCleanup reqCleanup)
public void sendResponseIfReady() throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.