Searched defs:ack (Results 1 - 22 of 22) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DServerHandler.java1130 * @param ack the message received.
1132 void processAck(AckMsg ack) argument
1134 replicationServerDomain.processAck(ack, this);
H A DReplicationServerDomain.java330 * If this is an assured message (a message requesting ack), we must
333 * have time to post, receive the ack and increment received ack counter
361 * posted to servers we don't want to wait the ack from (not normal status
494 // back the final ack to the requester and remove the object from this map
496 // The following timer will time out and send an timeout ack to the
591 * Servers that are not in this list are servers not eligible for an ack
605 * ack can be sent immediately, it is done here. This will also determine to
606 * which suitable servers an ack should be requested from, and which ones are
607 * not eligible for an ack reques
825 processAck(AckMsg ack, ServerHandler ackingServer) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DServerHandler.java1130 * @param ack the message received.
1132 void processAck(AckMsg ack) argument
1134 replicationServerDomain.processAck(ack, this);
H A DReplicationServerDomain.java330 * If this is an assured message (a message requesting ack), we must
333 * have time to post, receive the ack and increment received ack counter
361 * posted to servers we don't want to wait the ack from (not normal status
494 // back the final ack to the requester and remove the object from this map
496 // The following timer will time out and send an timeout ack to the
591 * Servers that are not in this list are servers not eligible for an ack
605 * ack can be sent immediately, it is done here. This will also determine to
606 * which suitable servers an ack should be requested from, and which ones are
607 * not eligible for an ack reques
825 processAck(AckMsg ack, ServerHandler ackingServer) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DServerHandler.java1107 * @param ack the message received.
1109 void processAck(AckMsg ack) argument
1111 replicationServerDomain.processAck(ack, this);
H A DReplicationServerDomain.java318 * If this is an assured message (a message requesting ack), we must
321 * have time to post, receive the ack and increment received ack counter
349 * posted to servers we don't want to wait the ack from (not normal status
480 // back the final ack to the requester and remove the object from this map
482 // The following timer will time out and send an timeout ack to the
576 * Servers that are not in this list are servers not eligible for an ack
590 * ack can be sent immediately, it is done here. This will also determine to
591 * which suitable servers an ack should be requested from, and which ones are
592 * not eligible for an ack reques
807 processAck(AckMsg ack, ServerHandler ackingServer) argument
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java240 * If this is an assured message (a message requesting ack), we must
243 * have time to post, receive the ack and increment received ack counter
334 // back the final ack to the requester and remove the object from this
337 // The following timer will time out and send an timeout ack to the
359 * posted to servers we don't want to wait the ack from (not normal status
512 * Servers that are not in this list are servers not eligible for an ack
527 * ack can be sent immediately, it is done here. This will also determine to
528 * which suitable servers an ack should be requested from, and which ones are
529 * not eligible for an ack reques
758 processAck(AckMsg ack, ServerHandler ackingServer) argument
[all...]
H A DServerHandler.java1275 * @param ack the message received.
1277 public void processAck(AckMsg ack) argument
1280 replicationServerDomain.processAck(ack, this);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DServerHandler.java1292 * @param ack the message received.
1294 void processAck(AckMsg ack) argument
1297 replicationServerDomain.processAck(ack, this);
H A DReplicationServerDomain.java330 * If this is an assured message (a message requesting ack), we must
333 * have time to post, receive the ack and increment received ack counter
424 // back the final ack to the requester and remove the object from this
427 // The following timer will time out and send an timeout ack to the
449 * posted to servers we don't want to wait the ack from (not normal status
602 * Servers that are not in this list are servers not eligible for an ack
617 * ack can be sent immediately, it is done here. This will also determine to
618 * which suitable servers an ack should be requested from, and which ones are
619 * not eligible for an ack reques
848 processAck(AckMsg ack, ServerHandler ackingServer) argument
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java240 * If this is an assured message (a message requesting ack), we must
243 * have time to post, receive the ack and increment received ack counter
334 // back the final ack to the requester and remove the object from this
337 // The following timer will time out and send an timeout ack to the
359 * posted to servers we don't want to wait the ack from (not normal status
512 * Servers that are not in this list are servers not eligible for an ack
527 * ack can be sent immediately, it is done here. This will also determine to
528 * which suitable servers an ack should be requested from, and which ones are
529 * not eligible for an ack reques
758 processAck(AckMsg ack, ServerHandler ackingServer) argument
[all...]
H A DServerHandler.java1275 * @param ack the message received.
1277 public void processAck(AckMsg ack) argument
1280 replicationServerDomain.processAck(ack, this);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java754 AckMsg ack = (AckMsg) msg;
755 receiveAck(ack);
907 * @param ack The AckMsg that was received.
909 private void receiveAck(AckMsg ack) argument
912 ChangeNumber changeNumber = ack.getChangeNumber();
914 // Remove the message for pending ack list (this may already make the thread
915 // that is waiting for the ack be aware of its reception)
918 // Signal waiting thread ack has been received
926 // Analyze status of embedded in the ack to see if everything went well
927 boolean hasTimeout = ack
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java788 AckMsg ack = (AckMsg) msg;
789 receiveAck(ack);
943 * @param ack The AckMsg that was received.
945 private void receiveAck(AckMsg ack) argument
947 CSN csn = ack.getCSN();
949 // Remove the message for pending ack list (this may already make the thread
950 // that is waiting for the ack be aware of its reception)
953 // Signal waiting thread ack has been received
961 // Analyze status of embedded in the ack to see if everything went well
962 boolean hasTimeout = ack
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java755 AckMsg ack = (AckMsg) msg;
756 receiveAck(ack);
908 * @param ack The AckMsg that was received.
910 private void receiveAck(AckMsg ack) argument
913 ChangeNumber changeNumber = ack.getChangeNumber();
915 // Remove the message for pending ack list (this may already make the thread
916 // that is waiting for the ack be aware of its reception)
919 // Signal waiting thread ack has been received
927 // Analyze status of embedded in the ack to see if everything went well
928 boolean hasTimeout = ack
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java754 AckMsg ack = (AckMsg) msg;
755 receiveAck(ack);
907 * @param ack The AckMsg that was received.
909 private void receiveAck(AckMsg ack) argument
912 ChangeNumber changeNumber = ack.getChangeNumber();
914 // Remove the message for pending ack list (this may already make the thread
915 // that is waiting for the ack be aware of its reception)
918 // Signal waiting thread ack has been received
926 // Analyze status of embedded in the ack to see if everything went well
927 boolean hasTimeout = ack
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java788 AckMsg ack = (AckMsg) msg;
789 receiveAck(ack);
943 * @param ack The AckMsg that was received.
945 private void receiveAck(AckMsg ack) argument
947 CSN csn = ack.getCSN();
949 // Remove the message for pending ack list (this may already make the thread
950 // that is waiting for the ack be aware of its reception)
953 // Signal waiting thread ack has been received
961 // Analyze status of embedded in the ack to see if everything went well
962 boolean hasTimeout = ack
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationDomain.java758 AckMsg ack = (AckMsg) msg;
759 receiveAck(ack);
915 * @param ack The AckMsg that was received.
917 private void receiveAck(AckMsg ack) argument
919 CSN csn = ack.getCSN();
921 // Remove the message for pending ack list (this may already make the thread
922 // that is waiting for the ack be aware of its reception)
925 // Signal waiting thread ack has been received
933 // Analyze status of embedded in the ack to see if everything went well
934 boolean hasTimeout = ack
[all...]
/forgerock/opendj-b2.6/ext/svnkit/
H A Dantlr-runtime.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/antlr/ org/antlr/runtime/ org/antlr/runtime/misc/ ...
/forgerock/opendj2/ext/svnkit/lib/
H A Dantlr-runtime-3.4.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/antlr/ org/antlr/runtime/ org/antlr/runtime/misc/ ...
/forgerock/opendj2.6.2/ext/svnkit/
H A Dantlr-runtime.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/antlr/ org/antlr/runtime/ org/antlr/runtime/misc/ ...
/forgerock/opendj2-hg/ext/svnkit/lib/
H A Dantlr-runtime-3.4.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/antlr/ org/antlr/runtime/ org/antlr/runtime/misc/ ...

Completed in 102 milliseconds