Searched refs:expectedServersAckStatus (Results 1 - 18 of 18) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java100 boolean ackReceived = expectedServersAckStatus.get(ackingServerId);
111 expectedServersAckStatus.put(ackingServerId, true);
130 Set<Integer> serverIds = expectedServersAckStatus.keySet();
134 boolean ackReceived = expectedServersAckStatus.get(serverId);
H A DSafeReadExpectedAcksInfo.java69 * Said differently: the number of servers in expectedServersAckStatus whose
70 * value is true. When this value reaches the size of expectedServersAckStatus
163 boolean ackReceived = expectedServersAckStatus.get(ackingServerId);
197 expectedServersAckStatus.put(ackingServerId, true);
201 return (numKnownAckStatus == expectedServersAckStatus.size());
222 Set<Integer> serverIds = expectedServersAckStatus.keySet();
226 boolean ackReceived = expectedServersAckStatus.get(serverId);
H A DExpectedAcksInfo.java79 protected Map<Integer,Boolean> expectedServersAckStatus = field in class:ExpectedAcksInfo
112 expectedServersAckStatus.put(serverId, false);
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java103 boolean ackReceived = expectedServersAckStatus.get(ackingServerId);
114 expectedServersAckStatus.put(ackingServerId, true);
134 Set<Integer> serverIds = expectedServersAckStatus.keySet();
138 boolean ackReceived = expectedServersAckStatus.get(serverId);
H A DSafeReadExpectedAcksInfo.java71 * Said differently: the number of servers in expectedServersAckStatus whose
72 * value is true. When this value reaches the size of expectedServersAckStatus
166 boolean ackReceived = expectedServersAckStatus.get(ackingServerId);
200 expectedServersAckStatus.put(ackingServerId, true);
204 return (numKnownAckStatus == expectedServersAckStatus.size());
226 Set<Integer> serverIds = expectedServersAckStatus.keySet();
230 boolean ackReceived = expectedServersAckStatus.get(serverId);
H A DExpectedAcksInfo.java79 protected Map<Integer,Boolean> expectedServersAckStatus = field in class:ExpectedAcksInfo
111 expectedServersAckStatus.put(serverId, false);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java100 boolean ackReceived = expectedServersAckStatus.get(ackingServerId);
111 expectedServersAckStatus.put(ackingServerId, true);
130 Set<Integer> serverIds = expectedServersAckStatus.keySet();
134 boolean ackReceived = expectedServersAckStatus.get(serverId);
H A DSafeReadExpectedAcksInfo.java69 * Said differently: the number of servers in expectedServersAckStatus whose
70 * value is true. When this value reaches the size of expectedServersAckStatus
163 boolean ackReceived = expectedServersAckStatus.get(ackingServerId);
197 expectedServersAckStatus.put(ackingServerId, true);
201 return (numKnownAckStatus == expectedServersAckStatus.size());
222 Set<Integer> serverIds = expectedServersAckStatus.keySet();
226 boolean ackReceived = expectedServersAckStatus.get(serverId);
H A DExpectedAcksInfo.java79 protected Map<Integer,Boolean> expectedServersAckStatus = field in class:ExpectedAcksInfo
112 expectedServersAckStatus.put(serverId, false);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java100 boolean ackReceived = expectedServersAckStatus.get(ackingServerId);
111 expectedServersAckStatus.put(ackingServerId, true);
130 Set<Integer> serverIds = expectedServersAckStatus.keySet();
134 boolean ackReceived = expectedServersAckStatus.get(serverId);
H A DSafeReadExpectedAcksInfo.java69 * Said differently: the number of servers in expectedServersAckStatus whose
70 * value is true. When this value reaches the size of expectedServersAckStatus
163 boolean ackReceived = expectedServersAckStatus.get(ackingServerId);
197 expectedServersAckStatus.put(ackingServerId, true);
201 return (numKnownAckStatus == expectedServersAckStatus.size());
222 Set<Integer> serverIds = expectedServersAckStatus.keySet();
226 boolean ackReceived = expectedServersAckStatus.get(serverId);
H A DExpectedAcksInfo.java79 protected Map<Integer,Boolean> expectedServersAckStatus = field in class:ExpectedAcksInfo
112 expectedServersAckStatus.put(serverId, false);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java103 boolean ackReceived = expectedServersAckStatus.get(ackingServerId);
114 expectedServersAckStatus.put(ackingServerId, true);
134 Set<Integer> serverIds = expectedServersAckStatus.keySet();
138 boolean ackReceived = expectedServersAckStatus.get(serverId);
H A DSafeReadExpectedAcksInfo.java71 * Said differently: the number of servers in expectedServersAckStatus whose
72 * value is true. When this value reaches the size of expectedServersAckStatus
166 boolean ackReceived = expectedServersAckStatus.get(ackingServerId);
200 expectedServersAckStatus.put(ackingServerId, true);
204 return (numKnownAckStatus == expectedServersAckStatus.size());
226 Set<Integer> serverIds = expectedServersAckStatus.keySet();
230 boolean ackReceived = expectedServersAckStatus.get(serverId);
H A DExpectedAcksInfo.java79 protected Map<Integer,Boolean> expectedServersAckStatus = field in class:ExpectedAcksInfo
111 expectedServersAckStatus.put(serverId, false);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java97 boolean ackReceived = expectedServersAckStatus.get(ackingServerId);
110 expectedServersAckStatus.put(ackingServerId, true);
128 Set<Integer> serverIds = expectedServersAckStatus.keySet();
132 boolean ackReceived = expectedServersAckStatus.get(serverId);
H A DSafeReadExpectedAcksInfo.java66 * Said differently: the number of servers in expectedServersAckStatus whose
67 * value is true. When this value reaches the size of expectedServersAckStatus
159 boolean ackReceived = expectedServersAckStatus.get(ackingServerId);
195 expectedServersAckStatus.put(ackingServerId, true);
199 return numKnownAckStatus == expectedServersAckStatus.size();
219 Set<Integer> serverIds = expectedServersAckStatus.keySet();
223 boolean ackReceived = expectedServersAckStatus.get(serverId);
H A DExpectedAcksInfo.java79 protected Map<Integer,Boolean> expectedServersAckStatus = new HashMap<>(); field in class:ExpectedAcksInfo
110 expectedServersAckStatus.put(serverId, false);

Completed in 39 milliseconds