/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | SafeDataExpectedAcksInfo.java | 39 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 D | ExpectedAcksInfo.java | 36 import org.opends.server.replication.protocol.AckMsg; 151 AckMsg ackMsg); 161 public abstract AckMsg createAck(boolean timeout);
|
H A D | SafeReadExpectedAcksInfo.java | 38 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 D | SafeDataExpectedAcksInfo.java | 37 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 D | ExpectedAcksInfo.java | 36 import org.opends.server.replication.protocol.AckMsg; 150 AckMsg ackMsg); 160 public abstract AckMsg createAck(boolean timeout);
|
H A D | SafeReadExpectedAcksInfo.java | 36 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 D | SafeDataExpectedAcksInfo.java | 39 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 D | ExpectedAcksInfo.java | 36 import org.opends.server.replication.protocol.AckMsg; 151 AckMsg ackMsg); 161 public abstract AckMsg createAck(boolean timeout);
|
H A D | SafeReadExpectedAcksInfo.java | 38 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 D | SafeDataExpectedAcksInfo.java | 39 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 D | ExpectedAcksInfo.java | 36 import org.opends.server.replication.protocol.AckMsg; 151 AckMsg ackMsg); 161 public abstract AckMsg createAck(boolean timeout);
|
H A D | SafeReadExpectedAcksInfo.java | 38 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 D | SafeDataExpectedAcksInfo.java | 37 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 D | ExpectedAcksInfo.java | 36 import org.opends.server.replication.protocol.AckMsg; 150 AckMsg ackMsg); 160 public abstract AckMsg createAck(boolean timeout);
|
H A D | SafeReadExpectedAcksInfo.java | 36 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 D | SafeDataExpectedAcksInfo.java | 36 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 D | ExpectedAcksInfo.java | 36 import org.opends.server.replication.protocol.AckMsg; 149 AckMsg ackMsg); 159 public abstract AckMsg createAck(boolean timeout);
|
H A D | SafeReadExpectedAcksInfo.java | 36 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 D | ServerReader.java | 103 if (msg instanceof AckMsg) 106 handler.processAck((AckMsg) msg);
|
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | AckMsg.java | 36 * 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 D | AckMsg.java | 36 * 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 D | AckMsg.java | 36 * 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 D | AckMsg.java | 40 * 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 D | AckMsg.java | 40 * 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 D | AckMsg.java | 40 * 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...] |