Searched defs:waitingAckMsgs (Results 1 - 6 of 6) sorted by relevance
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 144 private final Map<ChangeNumber, UpdateMsg> waitingAckMsgs = field in class:ReplicationDomain 916 update = waitingAckMsgs.remove(changeNumber); 3297 waitingAckMsgs.put(msg.getChangeNumber(), msg); 3343 while (waitingAckMsgs.containsKey(cn)) 3370 update = waitingAckMsgs.remove(cn);
|
/forgerock/opendj2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 245 private final Map<CSN, UpdateMsg> waitingAckMsgs = field in class:ReplicationDomain 951 UpdateMsg update = waitingAckMsgs.remove(csn); 3309 waitingAckMsgs.put(msg.getCSN(), msg); 3356 while (waitingAckMsgs.containsKey(csn)) 3382 final UpdateMsg update = waitingAckMsgs.remove(csn);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 145 private final Map<ChangeNumber, UpdateMsg> waitingAckMsgs = field in class:ReplicationDomain 917 update = waitingAckMsgs.remove(changeNumber); 3301 waitingAckMsgs.put(msg.getChangeNumber(), msg); 3347 while (waitingAckMsgs.containsKey(cn)) 3374 update = waitingAckMsgs.remove(cn);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 144 private final Map<ChangeNumber, UpdateMsg> waitingAckMsgs = field in class:ReplicationDomain 916 update = waitingAckMsgs.remove(changeNumber); 3297 waitingAckMsgs.put(msg.getChangeNumber(), msg); 3343 while (waitingAckMsgs.containsKey(cn)) 3370 update = waitingAckMsgs.remove(cn);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 245 private final Map<CSN, UpdateMsg> waitingAckMsgs = field in class:ReplicationDomain 951 UpdateMsg update = waitingAckMsgs.remove(csn); 3309 waitingAckMsgs.put(msg.getCSN(), msg); 3356 while (waitingAckMsgs.containsKey(csn)) 3382 final UpdateMsg update = waitingAckMsgs.remove(csn);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 234 private final Map<CSN, UpdateMsg> waitingAckMsgs = new ConcurrentHashMap<>(); field in class:ReplicationDomain 923 UpdateMsg update = waitingAckMsgs.remove(csn); 3268 waitingAckMsgs.put(msg.getCSN(), msg); 3315 while (waitingAckMsgs.containsKey(csn)) 3341 final UpdateMsg update = waitingAckMsgs.remove(csn);
|
Completed in 74 milliseconds