/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | SafeDataExpectedAcksInfo.java | 82 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument 94 + ackingServer.getServerId() + " ack message: " + ackMsg); 106 ackingServerId + " ack message: " + ackMsg);
|
H A D | ExpectedAcksInfo.java | 147 * @param ackMsg The ack message to process 151 AckMsg ackMsg); 150 processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
|
H A D | SafeReadExpectedAcksInfo.java | 159 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 D | SafeDataExpectedAcksInfo.java | 85 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument 97 + ackingServer.getServerId() + " ack message: " + ackMsg); 109 ackingServerId + " ack message: " + ackMsg);
|
H A D | ExpectedAcksInfo.java | 146 * @param ackMsg The ack message to process 150 AckMsg ackMsg); 149 processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
|
H A D | SafeReadExpectedAcksInfo.java | 162 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 D | SafeDataExpectedAcksInfo.java | 82 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument 94 + ackingServer.getServerId() + " ack message: " + ackMsg); 106 ackingServerId + " ack message: " + ackMsg);
|
H A D | ExpectedAcksInfo.java | 147 * @param ackMsg The ack message to process 151 AckMsg ackMsg); 150 processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
|
H A D | SafeReadExpectedAcksInfo.java | 159 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 D | SafeDataExpectedAcksInfo.java | 82 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument 94 + ackingServer.getServerId() + " ack message: " + ackMsg); 106 ackingServerId + " ack message: " + ackMsg);
|
H A D | ExpectedAcksInfo.java | 147 * @param ackMsg The ack message to process 151 AckMsg ackMsg); 150 processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
|
H A D | SafeReadExpectedAcksInfo.java | 159 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 D | SafeDataExpectedAcksInfo.java | 85 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument 97 + ackingServer.getServerId() + " ack message: " + ackMsg); 109 ackingServerId + " ack message: " + ackMsg);
|
H A D | ExpectedAcksInfo.java | 146 * @param ackMsg The ack message to process 150 AckMsg ackMsg); 149 processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
|
H A D | SafeReadExpectedAcksInfo.java | 162 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 D | SafeDataExpectedAcksInfo.java | 77 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument 90 + ackingServer.getServerId() + " ack message: " + ackMsg); 104 ackingServerId + " ack message: " + ackMsg);
|
H A D | ExpectedAcksInfo.java | 145 * @param ackMsg The ack message to process 149 AckMsg ackMsg); 148 processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg) argument
|
H A D | SafeReadExpectedAcksInfo.java | 155 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());
|