/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-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/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-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/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-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/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);
|
H A D | SafeDataExpectedAcksInfo.java | 129 List<Integer> failedServers = new ArrayList<Integer>(); 137 failedServers.add(serverId); 141 ack.setFailedServers(failedServers);
|
/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);
|
H A D | SafeDataExpectedAcksInfo.java | 133 List<Integer> failedServers = new ArrayList<Integer>(); 141 failedServers.add(serverId); 145 ack.setFailedServers(failedServers);
|
/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);
|
H A D | SafeDataExpectedAcksInfo.java | 129 List<Integer> failedServers = new ArrayList<Integer>(); 137 failedServers.add(serverId); 141 ack.setFailedServers(failedServers);
|
/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);
|
H A D | SafeDataExpectedAcksInfo.java | 129 List<Integer> failedServers = new ArrayList<Integer>(); 137 failedServers.add(serverId); 141 ack.setFailedServers(failedServers);
|
/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);
|
H A D | SafeDataExpectedAcksInfo.java | 133 List<Integer> failedServers = new ArrayList<Integer>(); 141 failedServers.add(serverId); 145 ack.setFailedServers(failedServers);
|
/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);
|
H A D | SafeDataExpectedAcksInfo.java | 127 List<Integer> failedServers = new ArrayList<>(); 135 failedServers.add(serverId); 139 ack.setFailedServers(failedServers);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 944 List<Integer> failedServers = ack.getFailedServers(); 957 if (failedServers != null) // This should always be the case ! 959 for(Integer sid : failedServers) 970 if (failedServers != null) // This should always be the case ! 972 for(Integer sid : failedServers)
|
/forgerock/opendj2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 978 List<Integer> failedServers = ack.getFailedServers(); 997 if (failedServers != null) // This should always be the case ! 999 for(Integer sid : failedServers) 1012 if (failedServers != null) // This should always be the case ! 1014 for(Integer sid : failedServers)
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 945 List<Integer> failedServers = ack.getFailedServers(); 958 if (failedServers != null) // This should always be the case ! 960 for(Integer sid : failedServers) 971 if (failedServers != null) // This should always be the case ! 973 for(Integer sid : failedServers)
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 944 List<Integer> failedServers = ack.getFailedServers(); 957 if (failedServers != null) // This should always be the case ! 959 for(Integer sid : failedServers) 970 if (failedServers != null) // This should always be the case ! 972 for(Integer sid : failedServers)
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 978 List<Integer> failedServers = ack.getFailedServers(); 997 if (failedServers != null) // This should always be the case ! 999 for(Integer sid : failedServers) 1012 if (failedServers != null) // This should always be the case ! 1014 for(Integer sid : failedServers)
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 948 List<Integer> failedServers = ack.getFailedServers(); 967 if (failedServers != null) // This should always be the case ! 969 for(Integer sid : failedServers) 982 if (failedServers != null) // This should always be the case ! 984 for(Integer sid : failedServers)
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | AssuredReplicationServerTest.java | 1015 List<Integer> failedServers = new ArrayList<Integer>(); 1016 failedServers.add(serverId + 10); 1017 ackMsg.setFailedServers(failedServers); 1028 List<Integer> failedServers = new ArrayList<Integer>(); 1029 failedServers.add((serverId + 10)); 1030 ackMsg.setFailedServers(failedServers); 1041 List<Integer> failedServers = new ArrayList<Integer>(); 1042 failedServers.add((serverId + 10)); 1043 ackMsg.setFailedServers(failedServers);
|