Searched refs:AckMsg (Results 1 - 25 of 78) sorted by relevance

1234

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java39 import org.opends.server.replication.protocol.AckMsg;
82 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg)
120 public AckMsg createAck(boolean timeout)
122 AckMsg ack = new AckMsg(changeNumber);
H A DExpectedAcksInfo.java36 import org.opends.server.replication.protocol.AckMsg;
151 AckMsg ackMsg);
161 public abstract AckMsg createAck(boolean timeout);
H A DSafeReadExpectedAcksInfo.java38 import org.opends.server.replication.protocol.AckMsg;
159 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg)
207 public AckMsg createAck(boolean timeout)
209 AckMsg ack = new AckMsg(changeNumber);
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java37 import org.opends.server.replication.protocol.AckMsg;
85 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg)
124 public AckMsg createAck(boolean timeout)
126 AckMsg ack = new AckMsg(csn);
H A DExpectedAcksInfo.java36 import org.opends.server.replication.protocol.AckMsg;
150 AckMsg ackMsg);
160 public abstract AckMsg createAck(boolean timeout);
H A DSafeReadExpectedAcksInfo.java36 import org.opends.server.replication.protocol.AckMsg;
162 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg)
211 public AckMsg createAck(boolean timeout)
213 AckMsg ack = new AckMsg(csn);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java39 import org.opends.server.replication.protocol.AckMsg;
82 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg)
120 public AckMsg createAck(boolean timeout)
122 AckMsg ack = new AckMsg(changeNumber);
H A DExpectedAcksInfo.java36 import org.opends.server.replication.protocol.AckMsg;
151 AckMsg ackMsg);
161 public abstract AckMsg createAck(boolean timeout);
H A DSafeReadExpectedAcksInfo.java38 import org.opends.server.replication.protocol.AckMsg;
159 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg)
207 public AckMsg createAck(boolean timeout)
209 AckMsg ack = new AckMsg(changeNumber);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java39 import org.opends.server.replication.protocol.AckMsg;
82 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg)
120 public AckMsg createAck(boolean timeout)
122 AckMsg ack = new AckMsg(changeNumber);
H A DExpectedAcksInfo.java36 import org.opends.server.replication.protocol.AckMsg;
151 AckMsg ackMsg);
161 public abstract AckMsg createAck(boolean timeout);
H A DSafeReadExpectedAcksInfo.java38 import org.opends.server.replication.protocol.AckMsg;
159 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg)
207 public AckMsg createAck(boolean timeout)
209 AckMsg ack = new AckMsg(changeNumber);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java37 import org.opends.server.replication.protocol.AckMsg;
85 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg)
124 public AckMsg createAck(boolean timeout)
126 AckMsg ack = new AckMsg(csn);
H A DExpectedAcksInfo.java36 import org.opends.server.replication.protocol.AckMsg;
150 AckMsg ackMsg);
160 public abstract AckMsg createAck(boolean timeout);
H A DSafeReadExpectedAcksInfo.java36 import org.opends.server.replication.protocol.AckMsg;
162 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg)
211 public AckMsg createAck(boolean timeout)
213 AckMsg ack = new AckMsg(csn);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DSafeDataExpectedAcksInfo.java36 import org.opends.server.replication.protocol.AckMsg;
77 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg)
118 public AckMsg createAck(boolean timeout)
120 AckMsg ack = new AckMsg(csn);
H A DExpectedAcksInfo.java36 import org.opends.server.replication.protocol.AckMsg;
149 AckMsg ackMsg);
159 public abstract AckMsg createAck(boolean timeout);
H A DSafeReadExpectedAcksInfo.java36 import org.opends.server.replication.protocol.AckMsg;
155 public boolean processReceivedAck(ServerHandler ackingServer, AckMsg ackMsg)
204 public AckMsg createAck(boolean timeout)
206 AckMsg ack = new AckMsg(csn);
H A DServerReader.java103 if (msg instanceof AckMsg)
106 handler.processAck((AckMsg) msg);
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DAckMsg.java36 * AckMsg messages are used for acknowledging an update that has been sent
54 * AckMsg messages are sent all along the reverse path of the path followed
57 public class AckMsg extends ReplicationMsg class in inherits:ReplicationMsg
88 * Creates a new AckMsg from a CSN (no errors).
90 * @param csn The CSN used to build the AckMsg.
92 public AckMsg(CSN csn) method in class:AckMsg
98 * Creates a new AckMsg from a CSN (with specified error info).
100 * @param csn The CSN used to build the AckMsg.
106 public AckMsg(CSN csn, boolean hasTimeout, boolean hasWrongStatus, method in class:AckMsg
153 * Creates a new AckMsg b
159 AckMsg(byte[] in) throws DataFormatException method in class:AckMsg
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DAckMsg.java36 * AckMsg messages are used for acknowledging an update that has been sent
54 * AckMsg messages are sent all along the reverse path of the path followed
57 public class AckMsg extends ReplicationMsg class in inherits:ReplicationMsg
88 * Creates a new AckMsg from a CSN (no errors).
90 * @param csn The CSN used to build the AckMsg.
92 public AckMsg(CSN csn) method in class:AckMsg
98 * Creates a new AckMsg from a CSN (with specified error info).
100 * @param csn The CSN used to build the AckMsg.
106 public AckMsg(CSN csn, boolean hasTimeout, boolean hasWrongStatus, method in class:AckMsg
153 * Creates a new AckMsg b
159 AckMsg(byte[] in) throws DataFormatException method in class:AckMsg
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DAckMsg.java36 * AckMsg messages are used for acknowledging an update that has been sent
54 * AckMsg messages are sent all along the reverse path of the path followed
57 public class AckMsg extends ReplicationMsg class in inherits:ReplicationMsg
88 * Creates a new AckMsg from a CSN (no errors).
90 * @param csn The CSN used to build the AckMsg.
92 public AckMsg(CSN csn) method in class:AckMsg
98 * Creates a new AckMsg from a CSN (with specified error info).
100 * @param csn The CSN used to build the AckMsg.
106 public AckMsg(CSN csn, boolean hasTimeout, boolean hasWrongStatus, method in class:AckMsg
153 * Creates a new AckMsg b
159 AckMsg(byte[] in) throws DataFormatException method in class:AckMsg
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DAckMsg.java40 * AckMsg messages are used for acknowledging an update that has been sent
59 * AckMsg messages are sent all along the reverse path of the path followed
62 public class AckMsg extends ReplicationMsg class in inherits:ReplicationMsg
85 * Creates a new AckMsg from a ChangeNumber (no errors).
87 * @param changeNumber The ChangeNumber used to build the AckMsg.
89 public AckMsg(ChangeNumber changeNumber) method in class:AckMsg
95 * Creates a new AckMsg from a ChangeNumber (with specified error info).
97 * @param changeNumber The ChangeNumber used to build the AckMsg.
103 public AckMsg(ChangeNumber changeNumber, boolean hasTimeout, method in class:AckMsg
150 * Creates a new AckMsg b
156 public AckMsg(byte[] in) throws DataFormatException method in class:AckMsg
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DAckMsg.java40 * AckMsg messages are used for acknowledging an update that has been sent
59 * AckMsg messages are sent all along the reverse path of the path followed
62 public class AckMsg extends ReplicationMsg class in inherits:ReplicationMsg
85 * Creates a new AckMsg from a ChangeNumber (no errors).
87 * @param changeNumber The ChangeNumber used to build the AckMsg.
89 public AckMsg(ChangeNumber changeNumber) method in class:AckMsg
95 * Creates a new AckMsg from a ChangeNumber (with specified error info).
97 * @param changeNumber The ChangeNumber used to build the AckMsg.
103 public AckMsg(ChangeNumber changeNumber, boolean hasTimeout, method in class:AckMsg
150 * Creates a new AckMsg b
156 public AckMsg(byte[] in) throws DataFormatException method in class:AckMsg
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DAckMsg.java40 * AckMsg messages are used for acknowledging an update that has been sent
59 * AckMsg messages are sent all along the reverse path of the path followed
62 public class AckMsg extends ReplicationMsg class in inherits:ReplicationMsg
85 * Creates a new AckMsg from a ChangeNumber (no errors).
87 * @param changeNumber The ChangeNumber used to build the AckMsg.
89 public AckMsg(ChangeNumber changeNumber) method in class:AckMsg
95 * Creates a new AckMsg from a ChangeNumber (with specified error info).
97 * @param changeNumber The ChangeNumber used to build the AckMsg.
103 public AckMsg(ChangeNumber changeNumber, boolean hasTimeout, method in class:AckMsg
150 * Creates a new AckMsg b
156 public AckMsg(byte[] in) throws DataFormatException method in class:AckMsg
[all...]

Completed in 61 milliseconds

1234