public class SafeDataExpectedAcksInfo extends ExpectedAcksInfo
csn, expectedServersAckStatus, serversInTimeout
Constructor and Description |
---|
SafeDataExpectedAcksInfo(CSN csn,
org.opends.server.replication.server.ServerHandler requesterServerHandler,
byte safeDataLevel,
List<Integer> expectedServers)
Creates a new SafeDataExpectedAcksInfo.
|
Modifier and Type | Method and Description |
---|---|
AckMsg |
createAck(boolean timeout)
Creates the ack message to be returned to the requester server, taking into account the information in the
received acks from every servers.
|
boolean |
processReceivedAck(org.opends.server.replication.server.ServerHandler ackingServer,
AckMsg ackMsg)
Process the received ack from a server we are waiting an ack from.
|
completed, contains, getAssuredMode, getRequesterServer, getTimeoutServers, isCompleted
public SafeDataExpectedAcksInfo(CSN csn, org.opends.server.replication.server.ServerHandler requesterServerHandler, byte safeDataLevel, List<Integer> expectedServers)
csn
- The CSN of the assured update messagerequesterServerHandler
- The server that sent the assured update messagesafeDataLevel
- The Safe Data level requested for the assured update messageexpectedServers
- The list of servers we want an ack frompublic boolean processReceivedAck(org.opends.server.replication.server.ServerHandler ackingServer, AckMsg ackMsg)
ExpectedAcksInfo
processReceivedAck
in class ExpectedAcksInfo
ackingServer
- The server handler of the server that sent the ackackMsg
- The ack message to processpublic AckMsg createAck(boolean timeout)
ExpectedAcksInfo
createAck
in class ExpectedAcksInfo
timeout
- True if we call this method when the timeout occurred, that is we did not received every expected acks
in time, and thus, the timeout flag should also be enabled in the returned ack message.Copyright 2010-2018 ForgeRock AS.