Searched refs:failedServers (Results 1 - 25 of 39) sorted by relevance

12

/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-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/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-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/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-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/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);
H A DSafeDataExpectedAcksInfo.java129 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 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);
H A DSafeDataExpectedAcksInfo.java133 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 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);
H A DSafeDataExpectedAcksInfo.java129 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 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);
H A DSafeDataExpectedAcksInfo.java129 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 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);
H A DSafeDataExpectedAcksInfo.java133 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 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);
H A DSafeDataExpectedAcksInfo.java127 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 DReplicationDomain.java944 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 DReplicationDomain.java978 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 DReplicationDomain.java945 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 DReplicationDomain.java944 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 DReplicationDomain.java978 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 DReplicationDomain.java948 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 DAssuredReplicationServerTest.java1015 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);

Completed in 98 milliseconds

12