public class RpcConnectionFlowControl
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
static int |
FLUSH_CMD_LENGTH
Length in bytes of a flush command when marshaled.
|
static java.lang.String |
TRACE_PREFIX |
| Modifier | Constructor and Description |
|---|---|
protected |
RpcConnectionFlowControl() |
| Modifier and Type | Method and Description |
|---|---|
RpcPacket |
respondToFlush1(java.util.Map<java.lang.String,java.lang.Object> resultsMap)
Construct a flush2 response to the passed-in flush1 packet.
|
RpcPacket |
respondToFlush1(RpcPacket flush1)
Construct a flush2 response to the passed-in flush1 packet.
|
public static final java.lang.String TRACE_PREFIX
public static final int FLUSH_CMD_LENGTH
public RpcPacket respondToFlush1(RpcPacket flush1)
flush1 - flush1public RpcPacket respondToFlush1(java.util.Map<java.lang.String,java.lang.Object> resultsMap)
resultsMap - resultsMap