public class InitializeRcvAckMsg extends RoutableMsg
A receiving replica should create such a message with a given credit when it wants to open the send window of the replica sending data; a replica should increase its send window when receiving such a message.
destination, senderId
MSG_TYPE_DISK_ENCODING
Constructor and Description |
---|
InitializeRcvAckMsg(ReplicaId sender,
ReplicaId destination,
int numAck)
Create a new message..
|
Modifier and Type | Method and Description |
---|---|
byte[] |
getBytes(short protocolVersion)
Serializes the PDU using the provided replication protocol version.
|
int |
getNumAck()
Get the number of message acknowledged by this message.
|
ReplicaId |
getSenderID()
Get the server ID of the server that sent this message.
|
boolean |
isRetryable()
Returns if in case of I/O error we should try to send this message again.
|
String |
toString() |
getDestination
decodeMsg
public InitializeRcvAckMsg(ReplicaId sender, ReplicaId destination, int numAck)
sender
- The server ID of the server that send this message.destination
- The destination server or servers of this message.numAck
- The number of acknowledged messages. The window will be increase by this credit number.public byte[] getBytes(short protocolVersion)
ReplicationMsg
getBytes
in class ReplicationMsg
protocolVersion
- The protocol version to use for serialization. The version should normally be older than the current
one.null
if the message isn't supported in that protocol version.public String toString()
toString
in class RoutableMsg
public int getNumAck()
public boolean isRetryable()
ReplicationMsg
isRetryable
in class ReplicationMsg
public ReplicaId getSenderID()
RoutableMsg
getSenderID
in class RoutableMsg
Copyright 2010-2022 ForgeRock AS.