/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | AckMsg.java | 47 * - 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 D | SafeReadExpectedAcksInfo.java | 54 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/protocol/ |
H A D | AckMsg.java | 42 * - 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/src/server/org/opends/server/replication/server/ |
H A D | SafeReadExpectedAcksInfo.java | 54 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/protocol/ |
H A D | AckMsg.java | 47 * - 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/server/ |
H A D | SafeReadExpectedAcksInfo.java | 54 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/protocol/ |
H A D | AckMsg.java | 47 * - 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/server/ |
H A D | SafeReadExpectedAcksInfo.java | 54 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/protocol/ |
H A D | AckMsg.java | 42 * - 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/server/ |
H A D | SafeReadExpectedAcksInfo.java | 54 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/protocol/ |
H A D | AckMsg.java | 42 * - 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-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | SafeReadExpectedAcksInfo.java | 49 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/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1009 boolean hasTimeout, ArrayList<Integer> failedServers) throws Exception 1013 assertEquals(msg.hasTimeout(), hasTimeout); 1008 oldAckMsgPDUs(String oldPdu, ChangeNumber cn, boolean hasTimeout, ArrayList<Integer> failedServers) argument
|
H A D | SynchronizationMsgTest.java | 713 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/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 924 boolean hasTimeout, ArrayList<Integer> failedServers) throws Exception 928 assertEquals(msg.hasTimeout(), hasTimeout); 923 oldAckMsgPDUs(String oldPdu, CSN csn, boolean hasTimeout, ArrayList<Integer> failedServers) argument
|
H A D | SynchronizationMsgTest.java | 581 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.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1009 boolean hasTimeout, ArrayList<Integer> failedServers) throws Exception 1013 assertEquals(msg.hasTimeout(), hasTimeout); 1008 oldAckMsgPDUs(String oldPdu, ChangeNumber cn, boolean hasTimeout, ArrayList<Integer> failedServers) argument
|
H A D | SynchronizationMsgTest.java | 713 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-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 924 boolean hasTimeout, ArrayList<Integer> failedServers) throws Exception 928 assertEquals(msg.hasTimeout(), hasTimeout); 923 oldAckMsgPDUs(String oldPdu, CSN csn, boolean hasTimeout, ArrayList<Integer> failedServers) argument
|
H A D | SynchronizationMsgTest.java | 581 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-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1009 boolean hasTimeout, ArrayList<Integer> failedServers) throws Exception 1013 assertEquals(msg.hasTimeout(), hasTimeout); 1008 oldAckMsgPDUs(String oldPdu, ChangeNumber cn, boolean hasTimeout, ArrayList<Integer> failedServers) argument
|
H A D | SynchronizationMsgTest.java | 713 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/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 928 boolean hasTimeout, ArrayList<Integer> failedServers) throws Exception 932 assertEquals(msg.hasTimeout(), hasTimeout); 927 oldAckMsgPDUs(String oldPdu, CSN csn, boolean hasTimeout, ArrayList<Integer> failedServers) argument
|
H A D | SynchronizationMsgTest.java | 578 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());
|