Searched refs:hasTimeout (Results 1 - 25 of 42) sorted by relevance

12

/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DAckMsg.java42 * - hasTimeout:
66 private boolean hasTimeout = false; field in class:AckMsg
101 * @param hasTimeout The hasTimeout info
106 public AckMsg(CSN csn, boolean hasTimeout, boolean hasWrongStatus, argument
110 this.hasTimeout = hasTimeout;
118 * @param hasTimeout True if some timeout occurred
120 public void setHasTimeout(boolean hasTimeout) argument
122 this.hasTimeout
220 public boolean hasTimeout() method in class:AckMsg
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DAckMsg.java42 * - hasTimeout:
66 private boolean hasTimeout = false; field in class:AckMsg
101 * @param hasTimeout The hasTimeout info
106 public AckMsg(CSN csn, boolean hasTimeout, boolean hasWrongStatus, argument
110 this.hasTimeout = hasTimeout;
118 * @param hasTimeout True if some timeout occurred
120 public void setHasTimeout(boolean hasTimeout) argument
122 this.hasTimeout
220 public boolean hasTimeout() method in class:AckMsg
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DAckMsg.java42 * - hasTimeout:
66 private boolean hasTimeout; field in class:AckMsg
101 * @param hasTimeout The hasTimeout info
106 public AckMsg(CSN csn, boolean hasTimeout, boolean hasWrongStatus, argument
110 this.hasTimeout = hasTimeout;
118 * @param hasTimeout True if some timeout occurred
120 public void setHasTimeout(boolean hasTimeout) argument
122 this.hasTimeout
220 public boolean hasTimeout() method in class:AckMsg
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DAckMsg.java47 * - hasTimeout:
69 private boolean hasTimeout = false; field in class:AckMsg
98 * @param hasTimeout The hasTimeout info
103 public AckMsg(ChangeNumber changeNumber, boolean hasTimeout, argument
107 this.hasTimeout = hasTimeout;
115 * @param hasTimeout True if some timeout occurred
117 public void setHasTimeout(boolean hasTimeout) argument
119 this.hasTimeout
266 public boolean hasTimeout() method in class:AckMsg
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DAckMsg.java47 * - hasTimeout:
69 private boolean hasTimeout = false; field in class:AckMsg
98 * @param hasTimeout The hasTimeout info
103 public AckMsg(ChangeNumber changeNumber, boolean hasTimeout, argument
107 this.hasTimeout = hasTimeout;
115 * @param hasTimeout True if some timeout occurred
117 public void setHasTimeout(boolean hasTimeout) argument
119 this.hasTimeout
266 public boolean hasTimeout() method in class:AckMsg
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DAckMsg.java47 * - hasTimeout:
69 private boolean hasTimeout = false; field in class:AckMsg
98 * @param hasTimeout The hasTimeout info
103 public AckMsg(ChangeNumber changeNumber, boolean hasTimeout, argument
107 this.hasTimeout = hasTimeout;
115 * @param hasTimeout True if some timeout occurred
117 public void setHasTimeout(boolean hasTimeout) argument
119 this.hasTimeout
266 public boolean hasTimeout() method in class:AckMsg
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java54 private boolean hasTimeout = false; field in class:SafeReadExpectedAcksInfo
104 * @param hasTimeout True if some timeout occurred
106 public void setHasTimeout(boolean hasTimeout) argument
108 this.hasTimeout = hasTimeout;
133 public boolean hasTimeout() method in class:SafeReadExpectedAcksInfo
135 return hasTimeout;
176 if (ackMsg.hasTimeout())
178 hasTimeout = true;
212 ack.setHasTimeout(hasTimeout);
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java54 private boolean hasTimeout = false; field in class:SafeReadExpectedAcksInfo
106 * @param hasTimeout True if some timeout occurred
108 public void setHasTimeout(boolean hasTimeout) argument
110 this.hasTimeout = hasTimeout;
135 public boolean hasTimeout() method in class:SafeReadExpectedAcksInfo
137 return hasTimeout;
179 if (ackMsg.hasTimeout())
181 hasTimeout = true;
216 ack.setHasTimeout(hasTimeout);
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java54 private boolean hasTimeout = false; field in class:SafeReadExpectedAcksInfo
104 * @param hasTimeout True if some timeout occurred
106 public void setHasTimeout(boolean hasTimeout) argument
108 this.hasTimeout = hasTimeout;
133 public boolean hasTimeout() method in class:SafeReadExpectedAcksInfo
135 return hasTimeout;
176 if (ackMsg.hasTimeout())
178 hasTimeout = true;
212 ack.setHasTimeout(hasTimeout);
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java54 private boolean hasTimeout = false; field in class:SafeReadExpectedAcksInfo
104 * @param hasTimeout True if some timeout occurred
106 public void setHasTimeout(boolean hasTimeout) argument
108 this.hasTimeout = hasTimeout;
133 public boolean hasTimeout() method in class:SafeReadExpectedAcksInfo
135 return hasTimeout;
176 if (ackMsg.hasTimeout())
178 hasTimeout = true;
212 ack.setHasTimeout(hasTimeout);
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java54 private boolean hasTimeout = false; field in class:SafeReadExpectedAcksInfo
106 * @param hasTimeout True if some timeout occurred
108 public void setHasTimeout(boolean hasTimeout) argument
110 this.hasTimeout = hasTimeout;
135 public boolean hasTimeout() method in class:SafeReadExpectedAcksInfo
137 return hasTimeout;
179 if (ackMsg.hasTimeout())
181 hasTimeout = true;
216 ack.setHasTimeout(hasTimeout);
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DSafeReadExpectedAcksInfo.java49 private boolean hasTimeout; field in class:SafeReadExpectedAcksInfo
101 * @param hasTimeout True if some timeout occurred
103 public void setHasTimeout(boolean hasTimeout) argument
105 this.hasTimeout = hasTimeout;
130 public boolean hasTimeout() method in class:SafeReadExpectedAcksInfo
132 return hasTimeout;
174 if (ackMsg.hasTimeout())
176 hasTimeout = true;
209 ack.setHasTimeout(hasTimeout);
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java581 public void ackMsgTest(CSN csn, boolean hasTimeout, boolean hasWrongStatus, argument
593 assertFalse(msg1.hasTimeout());
599 msg1 = new AckMsg(csn, hasTimeout, hasWrongStatus, hasReplayError, failedServers);
601 assertEquals(msg1.hasTimeout(), hasTimeout);
609 assertEquals(msg1.hasTimeout(), msg2.hasTimeout());
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java581 public void ackMsgTest(CSN csn, boolean hasTimeout, boolean hasWrongStatus, argument
593 assertFalse(msg1.hasTimeout());
599 msg1 = new AckMsg(csn, hasTimeout, hasWrongStatus, hasReplayError, failedServers);
601 assertEquals(msg1.hasTimeout(), hasTimeout);
609 assertEquals(msg1.hasTimeout(), msg2.hasTimeout());
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java578 public void ackMsgTest(CSN csn, boolean hasTimeout, boolean hasWrongStatus, argument
590 assertFalse(msg1.hasTimeout());
596 msg1 = new AckMsg(csn, hasTimeout, hasWrongStatus, hasReplayError, failedServers);
598 assertEquals(msg1.hasTimeout(), hasTimeout);
606 assertEquals(msg1.hasTimeout(), msg2.hasTimeout());
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java927 boolean hasTimeout = ack.hasTimeout();
933 if ( hasTimeout || hasReplayErrors || hasWrongStatus)
951 if (hasTimeout)
968 if (hasTimeout) // So should always be the case
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java962 boolean hasTimeout = ack.hasTimeout();
968 if ( hasTimeout || hasReplayErrors || hasWrongStatus)
985 if (hasTimeout)
1008 if (hasTimeout) // So should always be the case
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java928 boolean hasTimeout = ack.hasTimeout();
934 if ( hasTimeout || hasReplayErrors || hasWrongStatus)
952 if (hasTimeout)
969 if (hasTimeout) // So should always be the case
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java927 boolean hasTimeout = ack.hasTimeout();
933 if ( hasTimeout || hasReplayErrors || hasWrongStatus)
951 if (hasTimeout)
968 if (hasTimeout) // So should always be the case
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java962 boolean hasTimeout = ack.hasTimeout();
968 if ( hasTimeout || hasReplayErrors || hasWrongStatus)
985 if (hasTimeout)
1008 if (hasTimeout) // So should always be the case
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationDomain.java934 boolean hasTimeout = ack.hasTimeout();
940 if ( hasTimeout || hasReplayErrors || hasWrongStatus)
955 if (hasTimeout)
978 if (hasTimeout) // So should always be the case
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java713 public void ackMsgTest(ChangeNumber cn, boolean hasTimeout, boolean hasWrongStatus, argument
725 assertFalse(msg1.hasTimeout());
731 msg1 = new AckMsg(cn, hasTimeout, hasWrongStatus, hasReplayError, failedServers);
733 assertTrue(msg1.hasTimeout() == hasTimeout);
741 assertTrue(msg1.hasTimeout() == msg2.hasTimeout());
H A DProtocolCompatibilityTest.java1009 boolean hasTimeout, ArrayList<Integer> failedServers) throws Exception
1013 assertEquals(msg.hasTimeout(), hasTimeout);
1008 oldAckMsgPDUs(String oldPdu, ChangeNumber cn, boolean hasTimeout, ArrayList<Integer> failedServers) argument
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java713 public void ackMsgTest(ChangeNumber cn, boolean hasTimeout, boolean hasWrongStatus, argument
725 assertFalse(msg1.hasTimeout());
731 msg1 = new AckMsg(cn, hasTimeout, hasWrongStatus, hasReplayError, failedServers);
733 assertTrue(msg1.hasTimeout() == hasTimeout);
741 assertTrue(msg1.hasTimeout() == msg2.hasTimeout());
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java713 public void ackMsgTest(ChangeNumber cn, boolean hasTimeout, boolean hasWrongStatus, argument
725 assertFalse(msg1.hasTimeout());
731 msg1 = new AckMsg(cn, hasTimeout, hasWrongStatus, hasReplayError, failedServers);
733 assertTrue(msg1.hasTimeout() == hasTimeout);
741 assertTrue(msg1.hasTimeout() == msg2.hasTimeout());

Completed in 117 milliseconds

12