@InterfaceAudience.Private @InterfaceStability.Evolving public class PipelineAck extends Object
Modifier and Type | Field and Description |
---|---|
static long |
UNKOWN_SEQNO |
Constructor and Description |
---|
PipelineAck()
default constructor
|
PipelineAck(long seqno,
DataTransferProtos.Status[] replies)
Constructor assuming no next DN in pipeline
|
PipelineAck(long seqno,
DataTransferProtos.Status[] replies,
long downstreamAckTimeNanos)
Constructor
|
Modifier and Type | Method and Description |
---|---|
long |
getDownstreamAckTimeNanos()
Get the time elapsed for downstream ack RTT in nanoseconds
|
short |
getNumOfReplies()
Get the number of replies
|
DataTransferProtos.Status |
getReply(int i)
get the ith reply
|
long |
getSeqno()
Get the sequence number
|
boolean |
isSuccess()
Check if this ack contains error status
|
void |
readFields(InputStream in)
Writable interface
|
String |
toString() |
void |
write(OutputStream out) |
public static final long UNKOWN_SEQNO
public PipelineAck()
public PipelineAck(long seqno, DataTransferProtos.Status[] replies)
seqno
- sequence numberreplies
- an array of repliespublic PipelineAck(long seqno, DataTransferProtos.Status[] replies, long downstreamAckTimeNanos)
seqno
- sequence numberreplies
- an array of repliesdownstreamAckTimeNanos
- ack RTT in nanoseconds, 0 if no next DN in pipelinepublic long getSeqno()
public short getNumOfReplies()
public DataTransferProtos.Status getReply(int i)
public long getDownstreamAckTimeNanos()
public boolean isSuccess()
public void readFields(InputStream in) throws IOException
IOException
public void write(OutputStream out) throws IOException
IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.