@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"}) @InterfaceStability.Evolving public class RpcServer.Call extends Object implements RpcCallContext
Modifier and Type | Field and Description |
---|---|
protected CellScanner |
cellScanner |
protected RpcServer.Connection |
connection |
protected long |
deadline |
protected org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader |
header |
protected int |
id |
protected boolean |
isError |
protected com.google.protobuf.Descriptors.MethodDescriptor |
md |
protected com.google.protobuf.Message |
param |
protected RpcServer.Responder |
responder |
protected org.apache.hadoop.hbase.ipc.BufferChain |
response
Chain of buffers to send as response.
|
protected com.google.protobuf.BlockingService |
service |
protected long |
size |
protected long |
startTime |
protected int |
timeout |
protected long |
timestamp |
protected org.apache.htrace.TraceInfo |
tinfo |
Modifier and Type | Method and Description |
---|---|
long |
disconnectSince()
Check if the caller who made this IPC call has disconnected.
|
org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.VersionInfo |
getClientVersionInfo() |
long |
getDeadline()
Return the deadline of this call.
|
protected org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader |
getHeader() |
int |
getPriority() |
InetAddress |
getRemoteAddress() |
org.apache.hadoop.security.UserGroupInformation |
getRemoteUser() |
User |
getRequestUser()
Returns the user credentials associated with the current RPC request or
null if no credentials were provided. |
String |
getRequestUserName() |
long |
getResponseBlockSize() |
long |
getResponseCellSize()
The size of response cells that have been accumulated so far.
|
long |
getResponseExceptionSize() |
long |
getSize() |
boolean |
hasPriority() |
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() |
void |
sendResponseIfReady() |
protected void |
setResponse(Object m,
CellScanner cells,
Throwable t,
String errorMsg) |
protected void |
setSaslTokenResponse(ByteBuffer response) |
String |
toString() |
protected int id
protected com.google.protobuf.BlockingService service
protected com.google.protobuf.Descriptors.MethodDescriptor md
protected org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader header
protected com.google.protobuf.Message param
protected CellScanner cellScanner
protected RpcServer.Connection connection
protected long timestamp
protected int timeout
protected long startTime
protected long deadline
protected org.apache.hadoop.hbase.ipc.BufferChain response
protected RpcServer.Responder responder
protected long size
protected boolean isError
protected org.apache.htrace.TraceInfo tinfo
protected org.apache.hadoop.hbase.protobuf.generated.RPCProtos.RequestHeader getHeader()
public boolean hasPriority()
public int getPriority()
protected void setSaslTokenResponse(ByteBuffer response)
protected void setResponse(Object m, CellScanner cells, Throwable t, String errorMsg)
public boolean isClientCellBlockSupported()
RpcCallContext
isClientCellBlockSupported
in interface RpcCallContext
public long disconnectSince()
RpcCallContext
disconnectSince
in interface RpcCallContext
public long getResponseExceptionSize()
getResponseExceptionSize
in interface RpcCallContext
public void incrementResponseExceptionSize(long exSize)
incrementResponseExceptionSize
in interface RpcCallContext
public long getSize()
public long getResponseCellSize()
RpcCallContext
getResponseCellSize
in interface RpcCallContext
public void incrementResponseCellSize(long cellSize)
RpcCallContext
incrementResponseCellSize
in interface RpcCallContext
public long getResponseBlockSize()
getResponseBlockSize
in interface RpcCallContext
public void incrementResponseBlockSize(long blockSize)
incrementResponseBlockSize
in interface RpcCallContext
public long getDeadline()
RpcCallContext
getDeadline
in interface RpcCallContext
public void sendResponseIfReady() throws IOException
IOException
public org.apache.hadoop.security.UserGroupInformation getRemoteUser()
public User getRequestUser()
RpcCallContext
null
if no credentials were provided.getRequestUser
in interface RpcCallContext
public String getRequestUserName()
getRequestUserName
in interface RpcCallContext
public InetAddress getRemoteAddress()
getRemoteAddress
in interface RpcCallContext
public org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.VersionInfo getClientVersionInfo()
getClientVersionInfo
in interface RpcCallContext
public boolean isRetryImmediatelySupported()
isRetryImmediatelySupported
in interface RpcCallContext
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.