Searched defs:ackMsg (Results 1 - 18 of 18) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java82 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
94 + ackingServer.getServerId() + " ack message: " + ackMsg);
106 ackingServerId + " ack message: " + ackMsg);
H A DExpectedAcksInfo.java147 * @param ackMsg The ack message to process
151 AckMsg ackMsg);
150 processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
H A DSafeReadExpectedAcksInfo.java159 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
169 + ackingServerId + " ack message: " + ackMsg);
176 if (ackMsg.hasTimeout())
181 if (ackMsg.hasWrongStatus())
186 if (ackMsg.hasReplayError())
193 failedServers.addAll(ackMsg.getFailedServers());
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java85 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
97 + ackingServer.getServerId() + " ack message: " + ackMsg);
109 ackingServerId + " ack message: " + ackMsg);
H A DExpectedAcksInfo.java146 * @param ackMsg The ack message to process
150 AckMsg ackMsg);
149 processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
H A DSafeReadExpectedAcksInfo.java162 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
172 + ackingServerId + " ack message: " + ackMsg);
179 if (ackMsg.hasTimeout())
184 if (ackMsg.hasWrongStatus())
189 if (ackMsg.hasReplayError())
196 failedServers.addAll(ackMsg.getFailedServers());
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java82 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
94 + ackingServer.getServerId() + " ack message: " + ackMsg);
106 ackingServerId + " ack message: " + ackMsg);
H A DExpectedAcksInfo.java147 * @param ackMsg The ack message to process
151 AckMsg ackMsg);
150 processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
H A DSafeReadExpectedAcksInfo.java159 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
169 + ackingServerId + " ack message: " + ackMsg);
176 if (ackMsg.hasTimeout())
181 if (ackMsg.hasWrongStatus())
186 if (ackMsg.hasReplayError())
193 failedServers.addAll(ackMsg.getFailedServers());
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java82 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
94 + ackingServer.getServerId() + " ack message: " + ackMsg);
106 ackingServerId + " ack message: " + ackMsg);
H A DExpectedAcksInfo.java147 * @param ackMsg The ack message to process
151 AckMsg ackMsg);
150 processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
H A DSafeReadExpectedAcksInfo.java159 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
169 + ackingServerId + " ack message: " + ackMsg);
176 if (ackMsg.hasTimeout())
181 if (ackMsg.hasWrongStatus())
186 if (ackMsg.hasReplayError())
193 failedServers.addAll(ackMsg.getFailedServers());
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java85 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
97 + ackingServer.getServerId() + " ack message: " + ackMsg);
109 ackingServerId + " ack message: " + ackMsg);
H A DExpectedAcksInfo.java146 * @param ackMsg The ack message to process
150 AckMsg ackMsg);
149 processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
H A DSafeReadExpectedAcksInfo.java162 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
172 + ackingServerId + " ack message: " + ackMsg);
179 if (ackMsg.hasTimeout())
184 if (ackMsg.hasWrongStatus())
189 if (ackMsg.hasReplayError())
196 failedServers.addAll(ackMsg.getFailedServers());
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java77 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
90 + ackingServer.getServerId() + " ack message: " + ackMsg);
104 ackingServerId + " ack message: " + ackMsg);
H A DExpectedAcksInfo.java145 * @param ackMsg The ack message to process
149 AckMsg ackMsg);
148 processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
H A DSafeReadExpectedAcksInfo.java155 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
166 + ackingServerId + " ack message: " + ackMsg);
174 if (ackMsg.hasTimeout())
179 if (ackMsg.hasWrongStatus())
184 if (ackMsg.hasReplayError())
191 failedServers.addAll(ackMsg.getFailedServers());

Completed in 108 milliseconds