Searched refs:ReplicationBroker (Results 1 - 25 of 117) sorted by relevance

12345

/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/
H A DReplicationServerDynamicConfTest.java34 import org.opends.server.replication.service.ReplicationBroker;
69 ReplicationBroker broker = openReplicationSession(
H A DReplicationServerTest.java51 import org.opends.server.replication.service.ReplicationBroker;
152 ReplicationBroker[] brokers1And2 = null;
180 ReplicationBroker[] brokers1And2 = null;
196 private ReplicationBroker[] createReplicationBrokers1And2() throws Exception {
197 return new ReplicationBroker[] {
204 protected ReplicationBroker openReplicationSession(final DN baseDN,
207 ReplicationBroker broker = super.openReplicationSession(baseDN, serverId, windowSize, port, timeout);
222 private ReplicationBroker[] changelogBasic() throws Exception
226 ReplicationBroker[] brokers1And2 = createReplicationBrokers1And2();
227 ReplicationBroker server
[all...]
H A DMonitorTest.java51 import org.opends.server.replication.service.ReplicationBroker;
81 private ReplicationBroker broker2;
82 private ReplicationBroker broker3;
83 private ReplicationBroker broker4;
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java50 import org.opends.server.replication.service.ReplicationBroker;
155 ReplicationBroker[] brokers1And2 = null;
183 ReplicationBroker[] brokers1And2 = null;
199 private ReplicationBroker[] createReplicationBrokers1And2() throws Exception {
200 return new ReplicationBroker[] {
207 protected ReplicationBroker openReplicationSession(final DN baseDN,
210 ReplicationBroker broker = super.openReplicationSession(baseDN, serverId, windowSize, port, timeout);
225 private ReplicationBroker[] changelogBasic() throws Exception
229 ReplicationBroker[] brokers1And2 = createReplicationBrokers1And2();
230 ReplicationBroker server
[all...]
H A DReplicationServerDynamicConfTest.java31 import org.opends.server.replication.service.ReplicationBroker;
74 ReplicationBroker broker = openReplicationSession(
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java50 import org.opends.server.replication.service.ReplicationBroker;
155 ReplicationBroker[] brokers1And2 = null;
183 ReplicationBroker[] brokers1And2 = null;
199 private ReplicationBroker[] createReplicationBrokers1And2() throws Exception {
200 return new ReplicationBroker[] {
207 protected ReplicationBroker openReplicationSession(final DN baseDN,
210 ReplicationBroker broker = super.openReplicationSession(baseDN, serverId, windowSize, port, timeout);
225 private ReplicationBroker[] changelogBasic() throws Exception
229 ReplicationBroker[] brokers1And2 = createReplicationBrokers1And2();
230 ReplicationBroker server
[all...]
H A DReplicationServerDynamicConfTest.java31 import org.opends.server.replication.service.ReplicationBroker;
74 ReplicationBroker broker = openReplicationSession(
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerDynamicConfTest.java35 import org.opends.server.replication.service.ReplicationBroker;
83 ReplicationBroker broker = openReplicationSession(
H A DReplicationServerTest.java64 import org.opends.server.replication.service.ReplicationBroker;
218 ReplicationBroker server1 = null;
219 ReplicationBroker server2 = null;
331 ReplicationBroker broker = null;
362 ReplicationBroker broker = null;
512 * Stress test from client using the ReplicationBroker API
529 ReplicationBroker server = null;
537 ReplicationBroker clientBroker[] = new ReplicationBroker[CLIENT_THREADS];
601 for (ReplicationBroker broke
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerDynamicConfTest.java35 import org.opends.server.replication.service.ReplicationBroker;
83 ReplicationBroker broker = openReplicationSession(
H A DReplicationServerTest.java64 import org.opends.server.replication.service.ReplicationBroker;
218 ReplicationBroker server1 = null;
219 ReplicationBroker server2 = null;
331 ReplicationBroker broker = null;
362 ReplicationBroker broker = null;
512 * Stress test from client using the ReplicationBroker API
529 ReplicationBroker server = null;
537 ReplicationBroker clientBroker[] = new ReplicationBroker[CLIENT_THREADS];
601 for (ReplicationBroker broke
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerDynamicConfTest.java35 import org.opends.server.replication.service.ReplicationBroker;
83 ReplicationBroker broker = openReplicationSession(
H A DReplicationServerTest.java64 import org.opends.server.replication.service.ReplicationBroker;
218 ReplicationBroker server1 = null;
219 ReplicationBroker server2 = null;
331 ReplicationBroker broker = null;
362 ReplicationBroker broker = null;
512 * Stress test from client using the ReplicationBroker API
529 ReplicationBroker server = null;
537 ReplicationBroker clientBroker[] = new ReplicationBroker[CLIENT_THREADS];
601 for (ReplicationBroker broke
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/
H A DSchemaReplicationTest.java51 import org.opends.server.replication.service.ReplicationBroker;
126 ReplicationBroker broker =
172 ReplicationBroker broker =
206 ReplicationBroker broker =
270 private ModifyMsg receiveModifyMsg(ReplicationBroker broker) throws SocketTimeoutException
H A DStressTest.java49 import org.opends.server.replication.service.ReplicationBroker;
55 * Stress test for the synchronization code using the ReplicationBroker API.
76 * Stress test from LDAP server to client using the ReplicationBroker API.
86 ReplicationBroker broker =
246 private ReplicationBroker broker;
253 public BrokerReader(ReplicationBroker broker)
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java58 import org.opends.server.replication.service.ReplicationBroker;
97 private ReplicationBroker ds2 = null;
98 private ReplicationBroker ds3 = null;
187 ReplicationBroker rb = null;
324 private ReplicationBroker createReplicationBroker(int dsId,
328 ReplicationBroker broker = new ReplicationBroker(null,
343 private ReplicationBroker createReplicationBroker(int dsId,
868 private void resetGenId(ReplicationBroker rb, long newGenId)
884 private ReplicationBroker r
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java58 import org.opends.server.replication.service.ReplicationBroker;
97 private ReplicationBroker ds2 = null;
98 private ReplicationBroker ds3 = null;
187 ReplicationBroker rb = null;
324 private ReplicationBroker createReplicationBroker(int dsId,
328 ReplicationBroker broker = new ReplicationBroker(null,
343 private ReplicationBroker createReplicationBroker(int dsId,
868 private void resetGenId(ReplicationBroker rb, long newGenId)
884 private ReplicationBroker r
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java58 import org.opends.server.replication.service.ReplicationBroker;
97 private ReplicationBroker ds2 = null;
98 private ReplicationBroker ds3 = null;
187 ReplicationBroker rb = null;
324 private ReplicationBroker createReplicationBroker(int dsId,
328 ReplicationBroker broker = new ReplicationBroker(null,
343 private ReplicationBroker createReplicationBroker(int dsId,
868 private void resetGenId(ReplicationBroker rb, long newGenId)
884 private ReplicationBroker r
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java51 import org.opends.server.replication.service.ReplicationBroker;
68 * Stress test for the synchronization code using the ReplicationBroker API.
86 * Stress test from LDAP server to client using the ReplicationBroker API.
97 ReplicationBroker broker =
281 private ReplicationBroker broker;
289 public BrokerReader(ReplicationBroker broker)
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DSchemaReplicationTest.java48 import org.opends.server.replication.service.ReplicationBroker;
121 ReplicationBroker broker =
189 ReplicationBroker broker =
226 ReplicationBroker broker =
H A DStressTest.java46 import org.opends.server.replication.service.ReplicationBroker;
56 * Stress test for the synchronization code using the ReplicationBroker API.
76 * Stress test from LDAP server to client using the ReplicationBroker API.
87 ReplicationBroker broker =
251 private ReplicationBroker broker;
258 public BrokerReader(ReplicationBroker broker)
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java51 import org.opends.server.replication.service.ReplicationBroker;
68 * Stress test for the synchronization code using the ReplicationBroker API.
86 * Stress test from LDAP server to client using the ReplicationBroker API.
97 ReplicationBroker broker =
281 private ReplicationBroker broker;
289 public BrokerReader(ReplicationBroker broker)
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DSchemaReplicationTest.java48 import org.opends.server.replication.service.ReplicationBroker;
121 ReplicationBroker broker =
189 ReplicationBroker broker =
226 ReplicationBroker broker =
H A DStressTest.java46 import org.opends.server.replication.service.ReplicationBroker;
56 * Stress test for the synchronization code using the ReplicationBroker API.
76 * Stress test from LDAP server to client using the ReplicationBroker API.
87 ReplicationBroker broker =
251 private ReplicationBroker broker;
258 public BrokerReader(ReplicationBroker broker)
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java51 import org.opends.server.replication.service.ReplicationBroker;
68 * Stress test for the synchronization code using the ReplicationBroker API.
86 * Stress test from LDAP server to client using the ReplicationBroker API.
97 ReplicationBroker broker =
281 private ReplicationBroker broker;
289 public BrokerReader(ReplicationBroker broker)

Completed in 49 milliseconds

12345