/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | AckMsg.java | 54 * - 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 D | SafeReadExpectedAcksInfo.java | 65 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 D | AckMsg.java | 49 * - 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 D | SafeReadExpectedAcksInfo.java | 67 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 D | AckMsg.java | 54 * - 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 D | SafeReadExpectedAcksInfo.java | 65 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 D | AckMsg.java | 54 * - 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 D | SafeReadExpectedAcksInfo.java | 65 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 D | AckMsg.java | 49 * - 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 D | SafeReadExpectedAcksInfo.java | 67 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 D | AckMsg.java | 49 * - 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 D | SafeReadExpectedAcksInfo.java | 62 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 D | ProtocolCompatibilityTest.java | 1009 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 D | SynchronizationMsgTest.java | 714 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 D | ProtocolCompatibilityTest.java | 924 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 D | SynchronizationMsgTest.java | 582 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 D | ProtocolCompatibilityTest.java | 1009 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 D | SynchronizationMsgTest.java | 714 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 D | ProtocolCompatibilityTest.java | 924 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 D | SynchronizationMsgTest.java | 582 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 D | ProtocolCompatibilityTest.java | 1009 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 D | SynchronizationMsgTest.java | 714 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 D | ProtocolCompatibilityTest.java | 928 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 D | SynchronizationMsgTest.java | 579 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
|