/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | GenerationIdTest.java | 95 private ReplicationBroker broker2 = null; field in class:GenerationIdTest 756 broker2 = openReplicationSession(baseDn, 780 broker2.publish(createAddMsg()); 822 broker2.stop(); 823 broker2 = null; 858 debugInfo("Create again broker2"); 859 broker2 = openReplicationSession(baseDn, 861 assertTrue(broker2.isConnected(), "Broker2 failed to connect to replication server"); 895 ChangeStatusMsg csMsg = (ChangeStatusMsg)waitForSpecificMsg(broker2, 954 ReplicationMsg msg = broker2 [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | MonitorTest.java | 89 private ReplicationBroker broker2 = null; field in class:MonitorTest 381 debugInfo("Connecting broker2 to replServer1"); 382 broker2 = openReplicationSession(baseDn, 462 if (broker2 != null) 463 broker2.stop(); 464 broker2 = null;
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | MonitorTest.java | 81 private ReplicationBroker broker2; field in class:MonitorTest 327 debugInfo("Connecting broker2 to replServer1"); 328 broker2 = openReplicationSession(baseDN, 398 stop(broker2, broker3, broker4); 399 broker2 = broker3 = broker4 = null;
|
H A D | ReplicationServerTest.java | 654 ReplicationBroker broker2 = null; 682 broker2 = openReplicationSession(TEST_ROOT_DN, brokerIds[1], 100, changelogPorts[0], 1000); 721 List<ReplicationMsg> msgs = receiveReplicationMsgs(broker2, 4); 728 stop(broker1, broker2); 752 ReplicationBroker broker2 = null; 821 broker2 = openReplicationSession(TEST_ROOT_DN, 825 List<ReplicationMsg> msgs = receiveReplicationMsgs(broker2, 4); 832 stop(broker1, broker2); 837 private List<ReplicationMsg> receiveReplicationMsgs(ReplicationBroker broker2, int nbMessagesExpected) argument 844 ReplicationMsg msg = broker2 1203 assertOnlyTopologyMsgsReceived(ReplicationBroker broker2) argument [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | GenerationIdTest.java | 95 private ReplicationBroker broker2 = null; field in class:GenerationIdTest 756 broker2 = openReplicationSession(baseDn, 780 broker2.publish(createAddMsg()); 822 broker2.stop(); 823 broker2 = null; 858 debugInfo("Create again broker2"); 859 broker2 = openReplicationSession(baseDn, 861 assertTrue(broker2.isConnected(), "Broker2 failed to connect to replication server"); 895 ChangeStatusMsg csMsg = (ChangeStatusMsg)waitForSpecificMsg(broker2, 954 ReplicationMsg msg = broker2 [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | MonitorTest.java | 89 private ReplicationBroker broker2 = null; field in class:MonitorTest 381 debugInfo("Connecting broker2 to replServer1"); 382 broker2 = openReplicationSession(baseDn, 462 if (broker2 != null) 463 broker2.stop(); 464 broker2 = null;
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | MonitorTest.java | 81 private ReplicationBroker broker2; field in class:MonitorTest 327 debugInfo("Connecting broker2 to replServer1"); 328 broker2 = openReplicationSession(baseDN, 398 stop(broker2, broker3, broker4); 399 broker2 = broker3 = broker4 = null;
|
H A D | ReplicationServerTest.java | 654 ReplicationBroker broker2 = null; 682 broker2 = openReplicationSession(TEST_ROOT_DN, brokerIds[1], 100, changelogPorts[0], 1000); 721 List<ReplicationMsg> msgs = receiveReplicationMsgs(broker2, 4); 728 stop(broker1, broker2); 752 ReplicationBroker broker2 = null; 821 broker2 = openReplicationSession(TEST_ROOT_DN, 825 List<ReplicationMsg> msgs = receiveReplicationMsgs(broker2, 4); 832 stop(broker1, broker2); 837 private List<ReplicationMsg> receiveReplicationMsgs(ReplicationBroker broker2, int nbMessagesExpected) argument 844 ReplicationMsg msg = broker2 1203 assertOnlyTopologyMsgsReceived(ReplicationBroker broker2) argument [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | GenerationIdTest.java | 95 private ReplicationBroker broker2 = null; field in class:GenerationIdTest 756 broker2 = openReplicationSession(baseDn, 780 broker2.publish(createAddMsg()); 822 broker2.stop(); 823 broker2 = null; 858 debugInfo("Create again broker2"); 859 broker2 = openReplicationSession(baseDn, 861 assertTrue(broker2.isConnected(), "Broker2 failed to connect to replication server"); 895 ChangeStatusMsg csMsg = (ChangeStatusMsg)waitForSpecificMsg(broker2, 954 ReplicationMsg msg = broker2 [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | MonitorTest.java | 89 private ReplicationBroker broker2 = null; field in class:MonitorTest 381 debugInfo("Connecting broker2 to replServer1"); 382 broker2 = openReplicationSession(baseDn, 462 if (broker2 != null) 463 broker2.stop(); 464 broker2 = null;
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/ |
H A D | MonitorTest.java | 81 private ReplicationBroker broker2; field in class:MonitorTest 329 debugInfo("Connecting broker2 to replServer1"); 330 broker2 = openReplicationSession(baseDN, 400 stop(broker2, broker3, broker4); 401 broker2 = broker3 = broker4 = null;
|
H A D | ReplicationServerTest.java | 652 ReplicationBroker broker2 = null; 680 broker2 = openReplicationSession(TEST_ROOT_DN, brokerIds[1], 100, changelogPorts[0], 1000); 719 List<ReplicationMsg> msgs = receiveReplicationMsgs(broker2, 4); 726 stop(broker1, broker2); 750 ReplicationBroker broker2 = null; 819 broker2 = openReplicationSession(TEST_ROOT_DN, 823 List<ReplicationMsg> msgs = receiveReplicationMsgs(broker2, 4); 830 stop(broker1, broker2); 835 private List<ReplicationMsg> receiveReplicationMsgs(ReplicationBroker broker2, int nbMessagesExpected) argument 842 ReplicationMsg msg = broker2 1206 assertOnlyTopologyMsgsReceived(ReplicationBroker broker2) argument [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | GenerationIdTest.java | 93 private ReplicationBroker broker2; field in class:GenerationIdTest 650 broker2 = 664 broker2.publish(createAddMsg()); 692 stop(broker2, broker3); 693 broker2 = broker3 = null; 719 debugInfo("Create again broker2"); 720 broker2 = openReplicationSession(baseDN, 722 assertTrue(broker2.isConnected(), "Broker2 failed to connect to replication server"); 742 ChangeStatusMsg csMsg = waitForSpecificMsg(broker2, ChangeStatusMsg.class); 784 assertNoMessageReceived(broker2, "broker [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | GenerationIdTest.java | 93 private ReplicationBroker broker2; field in class:GenerationIdTest 650 broker2 = 664 broker2.publish(createAddMsg()); 692 stop(broker2, broker3); 693 broker2 = broker3 = null; 719 debugInfo("Create again broker2"); 720 broker2 = openReplicationSession(baseDN, 722 assertTrue(broker2.isConnected(), "Broker2 failed to connect to replication server"); 742 ChangeStatusMsg csMsg = waitForSpecificMsg(broker2, ChangeStatusMsg.class); 784 assertNoMessageReceived(broker2, "broker [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/ |
H A D | GenerationIdTest.java | 106 private ReplicationBroker broker2; field in class:GenerationIdTest 635 broker2 = openReplicationSession(server2ID, replServer1, dsGenId + 1); 645 broker2.publish(createAddMsg()); 673 stop(broker2, broker3); 674 broker2 = broker3 = null; 700 debugInfo("Create again broker2"); 701 broker2 = openReplicationSession(server2ID, replServer1, dsGenId); 702 assertTrue(broker2.isConnected(), "Broker2 failed to connect to replication server"); 721 ChangeStatusMsg csMsg = waitForSpecificMsg(broker2, ChangeStatusMsg.class); 765 assertNoMessageReceived(broker2, "broker [all...] |