Searched defs:failedServers (Results 1 - 24 of 24) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DAckMsg.java54 * - failedServers:
82 private List<Integer> failedServers = new ArrayList<Integer>(); field in class:AckMsg
101 * @param failedServers The list of failed servers
104 boolean hasWrongStatus, boolean hasReplayError, List<Integer> failedServers)
110 this.failedServers = failedServers;
146 this.failedServers = idList;
194 failedServers.add(serverId);
247 for (Integer sid : failedServers)
295 return failedServers;
103 AckMsg(ChangeNumber changeNumber, boolean hasTimeout, boolean hasWrongStatus, boolean hasReplayError, List<Integer> failedServers) argument
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java65 private List<Integer> failedServers = new ArrayList<Integer>(); field in class:SafeReadExpectedAcksInfo
98 failedServers = wrongStatusServers;
193 failedServers.addAll(ackMsg.getFailedServers());
229 if (!failedServers.contains(serverId))
231 failedServers.add(serverId);
238 ack.setFailedServers(failedServers);
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DAckMsg.java49 * - failedServers:
85 private List<Integer> failedServers = new ArrayList<Integer>(); field in class:AckMsg
104 * @param failedServers The list of failed servers
107 boolean hasReplayError, List<Integer> failedServers)
113 this.failedServers = failedServers;
149 this.failedServers = idList;
180 failedServers.add(scanner.nextIntUTF8());
209 for (int serverId : failedServers)
249 return failedServers;
106 AckMsg(CSN csn, boolean hasTimeout, boolean hasWrongStatus, boolean hasReplayError, List<Integer> failedServers) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java67 private List<Integer> failedServers = new ArrayList<Integer>(); field in class:SafeReadExpectedAcksInfo
100 failedServers = wrongStatusServers;
196 failedServers.addAll(ackMsg.getFailedServers());
233 if (!failedServers.contains(serverId))
235 failedServers.add(serverId);
242 ack.setFailedServers(failedServers);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DAckMsg.java54 * - failedServers:
82 private List<Integer> failedServers = new ArrayList<Integer>(); field in class:AckMsg
101 * @param failedServers The list of failed servers
104 boolean hasWrongStatus, boolean hasReplayError, List<Integer> failedServers)
110 this.failedServers = failedServers;
146 this.failedServers = idList;
194 failedServers.add(serverId);
247 for (Integer sid : failedServers)
295 return failedServers;
103 AckMsg(ChangeNumber changeNumber, boolean hasTimeout, boolean hasWrongStatus, boolean hasReplayError, List<Integer> failedServers) argument
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java65 private List<Integer> failedServers = new ArrayList<Integer>(); field in class:SafeReadExpectedAcksInfo
98 failedServers = wrongStatusServers;
193 failedServers.addAll(ackMsg.getFailedServers());
229 if (!failedServers.contains(serverId))
231 failedServers.add(serverId);
238 ack.setFailedServers(failedServers);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DAckMsg.java54 * - failedServers:
82 private List<Integer> failedServers = new ArrayList<Integer>(); field in class:AckMsg
101 * @param failedServers The list of failed servers
104 boolean hasWrongStatus, boolean hasReplayError, List<Integer> failedServers)
110 this.failedServers = failedServers;
146 this.failedServers = idList;
194 failedServers.add(serverId);
247 for (Integer sid : failedServers)
295 return failedServers;
103 AckMsg(ChangeNumber changeNumber, boolean hasTimeout, boolean hasWrongStatus, boolean hasReplayError, List<Integer> failedServers) argument
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java65 private List<Integer> failedServers = new ArrayList<Integer>(); field in class:SafeReadExpectedAcksInfo
98 failedServers = wrongStatusServers;
193 failedServers.addAll(ackMsg.getFailedServers());
229 if (!failedServers.contains(serverId))
231 failedServers.add(serverId);
238 ack.setFailedServers(failedServers);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DAckMsg.java49 * - failedServers:
85 private List<Integer> failedServers = new ArrayList<Integer>(); field in class:AckMsg
104 * @param failedServers The list of failed servers
107 boolean hasReplayError, List<Integer> failedServers)
113 this.failedServers = failedServers;
149 this.failedServers = idList;
180 failedServers.add(scanner.nextIntUTF8());
209 for (int serverId : failedServers)
249 return failedServers;
106 AckMsg(CSN csn, boolean hasTimeout, boolean hasWrongStatus, boolean hasReplayError, List<Integer> failedServers) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java67 private List<Integer> failedServers = new ArrayList<Integer>(); field in class:SafeReadExpectedAcksInfo
100 failedServers = wrongStatusServers;
196 failedServers.addAll(ackMsg.getFailedServers());
233 if (!failedServers.contains(serverId))
235 failedServers.add(serverId);
242 ack.setFailedServers(failedServers);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DAckMsg.java49 * - failedServers:
85 private List<Integer> failedServers = new ArrayList<>(); field in class:AckMsg
104 * @param failedServers The list of failed servers
107 boolean hasReplayError, List<Integer> failedServers)
113 this.failedServers = failedServers;
149 this.failedServers = idList;
180 failedServers.add(scanner.nextIntUTF8());
209 for (int serverId : failedServers)
249 return failedServers;
106 AckMsg(CSN csn, boolean hasTimeout, boolean hasWrongStatus, boolean hasReplayError, List<Integer> failedServers) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java62 private List<Integer> failedServers = new ArrayList<>(); field in class:SafeReadExpectedAcksInfo
95 failedServers = wrongStatusServers;
191 failedServers.addAll(ackMsg.getFailedServers());
224 if (!ackReceived && !failedServers.contains(serverId))
226 failedServers.add(serverId);
232 ack.setFailedServers(failedServers);
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java1009 boolean hasTimeout, ArrayList<Integer> failedServers) throws Exception
1014 assertEquals(msg.getFailedServers(), failedServers);
1008 oldAckMsgPDUs(String oldPdu, ChangeNumber cn, boolean hasTimeout, ArrayList<Integer> failedServers) argument
H A DSynchronizationMsgTest.java714 boolean hasReplayError, List<Integer> failedServers)
731 msg1 = new AckMsg(cn, hasTimeout, hasWrongStatus, hasReplayError, failedServers);
736 assertEquals(msg1.getFailedServers(), failedServers);
713 ackMsgTest(ChangeNumber cn, boolean hasTimeout, boolean hasWrongStatus, boolean hasReplayError, List<Integer> failedServers) argument
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java924 boolean hasTimeout, ArrayList<Integer> failedServers) throws Exception
929 assertEquals(msg.getFailedServers(), failedServers);
923 oldAckMsgPDUs(String oldPdu, CSN csn, boolean hasTimeout, ArrayList<Integer> failedServers) argument
H A DSynchronizationMsgTest.java582 boolean hasReplayError, List<Integer> failedServers)
599 msg1 = new AckMsg(csn, hasTimeout, hasWrongStatus, hasReplayError, failedServers);
604 assertEquals(msg1.getFailedServers(), failedServers);
581 ackMsgTest(CSN csn, boolean hasTimeout, boolean hasWrongStatus, boolean hasReplayError, List<Integer> failedServers) argument
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java1009 boolean hasTimeout, ArrayList<Integer> failedServers) throws Exception
1014 assertEquals(msg.getFailedServers(), failedServers);
1008 oldAckMsgPDUs(String oldPdu, ChangeNumber cn, boolean hasTimeout, ArrayList<Integer> failedServers) argument
H A DSynchronizationMsgTest.java714 boolean hasReplayError, List<Integer> failedServers)
731 msg1 = new AckMsg(cn, hasTimeout, hasWrongStatus, hasReplayError, failedServers);
736 assertEquals(msg1.getFailedServers(), failedServers);
713 ackMsgTest(ChangeNumber cn, boolean hasTimeout, boolean hasWrongStatus, boolean hasReplayError, List<Integer> failedServers) argument
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java924 boolean hasTimeout, ArrayList<Integer> failedServers) throws Exception
929 assertEquals(msg.getFailedServers(), failedServers);
923 oldAckMsgPDUs(String oldPdu, CSN csn, boolean hasTimeout, ArrayList<Integer> failedServers) argument
H A DSynchronizationMsgTest.java582 boolean hasReplayError, List<Integer> failedServers)
599 msg1 = new AckMsg(csn, hasTimeout, hasWrongStatus, hasReplayError, failedServers);
604 assertEquals(msg1.getFailedServers(), failedServers);
581 ackMsgTest(CSN csn, boolean hasTimeout, boolean hasWrongStatus, boolean hasReplayError, List<Integer> failedServers) argument
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java1009 boolean hasTimeout, ArrayList<Integer> failedServers) throws Exception
1014 assertEquals(msg.getFailedServers(), failedServers);
1008 oldAckMsgPDUs(String oldPdu, ChangeNumber cn, boolean hasTimeout, ArrayList<Integer> failedServers) argument
H A DSynchronizationMsgTest.java714 boolean hasReplayError, List<Integer> failedServers)
731 msg1 = new AckMsg(cn, hasTimeout, hasWrongStatus, hasReplayError, failedServers);
736 assertEquals(msg1.getFailedServers(), failedServers);
713 ackMsgTest(ChangeNumber cn, boolean hasTimeout, boolean hasWrongStatus, boolean hasReplayError, List<Integer> failedServers) argument
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java928 boolean hasTimeout, ArrayList<Integer> failedServers) throws Exception
933 assertEquals(msg.getFailedServers(), failedServers);
927 oldAckMsgPDUs(String oldPdu, CSN csn, boolean hasTimeout, ArrayList<Integer> failedServers) argument
H A DSynchronizationMsgTest.java579 boolean hasReplayError, List<Integer> failedServers)
596 msg1 = new AckMsg(csn, hasTimeout, hasWrongStatus, hasReplayError, failedServers);
601 assertEquals(msg1.getFailedServers(), failedServers);
578 ackMsgTest(CSN csn, boolean hasTimeout, boolean hasWrongStatus, boolean hasReplayError, List<Integer> failedServers) argument

Completed in 85 milliseconds