Searched refs:server3 (Results 1 - 10 of 10) sorted by relevance

/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DInitOnLineTest.java111 private ReplicationBroker server3; field in class:InitOnLineTest
720 if (server3 == null)
721 server3 = openReplicationSession(baseDN,
731 server3.signalStatusChange(ServerStatus.FULL_UPDATE_STATUS);
734 receiveUpdatedEntries(server3);
1079 if (server3 == null)
1082 server3 = openReplicationSession(baseDN,
1090 server3.publish(initMsg);
1093 waitForInitializeTargetMsg(testCase, server3);
1096 server3
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DInitOnLineTest.java111 private ReplicationBroker server3; field in class:InitOnLineTest
720 if (server3 == null)
721 server3 = openReplicationSession(baseDN,
731 server3.signalStatusChange(ServerStatus.FULL_UPDATE_STATUS);
734 receiveUpdatedEntries(server3);
1079 if (server3 == null)
1082 server3 = openReplicationSession(baseDN,
1090 server3.publish(initMsg);
1093 waitForInitializeTargetMsg(testCase, server3);
1096 server3
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/
H A DInitOnLineTest.java109 private ReplicationBroker server3; field in class:InitOnLineTest
713 if (server3 == null)
715 server3 = openReplicationSession(baseDN,
726 server3.signalStatusChange(ServerStatus.FULL_UPDATE_STATUS);
729 receiveUpdatedEntries(server3);
1077 if (server3 == null)
1080 server3 = openReplicationSession(baseDN,
1088 server3.publish(initMsg);
1091 waitForInitializeTargetMsg(testCase, server3);
1094 server3
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DInitOnLineTest.java141 ReplicationBroker server3 = null; field in class:InitOnLineTest
928 if (server3 == null)
929 server3 = openReplicationSession(DN.decode(EXAMPLE_DN),
941 server3.signalStatusChange(ServerStatus.FULL_UPDATE_STATUS);
944 receiveUpdatedEntries(server3, server3ID, updatedEntries);
1346 if (server3 == null)
1349 server3 = openReplicationSession(DN.decode(EXAMPLE_DN),
1361 server3.publish(initMsg);
1369 msgrcv = server3.receive();
1377 server3
[all...]
H A DExternalChangeLogTest.java480 ReplicationBroker server3 = null;
493 server3 = openReplicationSession(
496 assertTrue(server3.isConnected());
533 msg = server3.receive();
556 if (server3 != null)
557 server3.stop();
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DInitOnLineTest.java141 ReplicationBroker server3 = null; field in class:InitOnLineTest
928 if (server3 == null)
929 server3 = openReplicationSession(DN.decode(EXAMPLE_DN),
941 server3.signalStatusChange(ServerStatus.FULL_UPDATE_STATUS);
944 receiveUpdatedEntries(server3, server3ID, updatedEntries);
1346 if (server3 == null)
1349 server3 = openReplicationSession(DN.decode(EXAMPLE_DN),
1361 server3.publish(initMsg);
1369 msgrcv = server3.receive();
1377 server3
[all...]
H A DExternalChangeLogTest.java480 ReplicationBroker server3 = null;
493 server3 = openReplicationSession(
496 assertTrue(server3.isConnected());
533 msg = server3.receive();
556 if (server3 != null)
557 server3.stop();
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DInitOnLineTest.java141 ReplicationBroker server3 = null; field in class:InitOnLineTest
928 if (server3 == null)
929 server3 = openReplicationSession(DN.decode(EXAMPLE_DN),
941 server3.signalStatusChange(ServerStatus.FULL_UPDATE_STATUS);
944 receiveUpdatedEntries(server3, server3ID, updatedEntries);
1346 if (server3 == null)
1349 server3 = openReplicationSession(DN.decode(EXAMPLE_DN),
1361 server3.publish(initMsg);
1369 msgrcv = server3.receive();
1377 server3
[all...]
H A DExternalChangeLogTest.java480 ReplicationBroker server3 = null;
493 server3 = openReplicationSession(
496 assertTrue(server3.isConnected());
533 msg = server3.receive();
556 if (server3 != null)
557 server3.stop();
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/backends/
H A DChangelogBackendTestCase.java436 final ReplicaId server3 = ReplicaId.of(DN_OTEST2, 1203);
438 CSN csn6 = new CSN(time, seqNum++, server3.getServerId());
440 CSN csn8 = new CSN(time, seqNum++, server3.getServerId());
443 publishUpdateMessages(test, server3, false,
444 generateDeleteMsg(server3, csn6, test, 6));
447 publishUpdateMessages(test, server3, false,
448 generateDeleteMsg(server3, csn8, test, 8));
457 isOldestCSNForReplica(server3, csn6);

Completed in 78 milliseconds