Searched refs:BrokerWriter (Results 1 - 18 of 18) sorted by relevance

/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java144 BrokerWriter writer = new BrokerWriter(count);
242 private class BrokerWriter extends Thread class in class:StressTest
250 public BrokerWriter(int count) method in class:StressTest.BrokerWriter
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java126 BrokerWriter writer = new BrokerWriter(count);
213 private class BrokerWriter extends Thread class in class:StressTest
220 public BrokerWriter(int count) method in class:StressTest.BrokerWriter
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java144 BrokerWriter writer = new BrokerWriter(count);
242 private class BrokerWriter extends Thread class in class:StressTest
250 public BrokerWriter(int count) method in class:StressTest.BrokerWriter
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java126 BrokerWriter writer = new BrokerWriter(count);
213 private class BrokerWriter extends Thread class in class:StressTest
220 public BrokerWriter(int count) method in class:StressTest.BrokerWriter
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java144 BrokerWriter writer = new BrokerWriter(count);
242 private class BrokerWriter extends Thread class in class:StressTest
250 public BrokerWriter(int count) method in class:StressTest.BrokerWriter
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/
H A DStressTest.java125 BrokerWriter writer = new BrokerWriter(count);
212 private class BrokerWriter extends Thread class in class:StressTest
217 public BrokerWriter(int count) method in class:StressTest.BrokerWriter
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java431 BrokerWriter bw = null;
459 bw = new BrokerWriter(ds3, DS3_ID, false);
579 BrokerWriter bw = null;
601 bw = new BrokerWriter(ds2, DS2_ID, false);
650 bw = new BrokerWriter(ds2, DS2_ID, false);
714 bw = new BrokerWriter(ds2, DS2_ID, false);
753 bw = new BrokerWriter(ds2, DS2_ID, false);
1015 private class BrokerWriter extends Thread class in class:StateMachineTest
1034 * If the BrokerWriter is to be used for a lot of changes to send (which is
1043 public BrokerWriter(ReplicationBroke method in class:StateMachineTest.BrokerWriter
1049 public BrokerWriter(ReplicationBroker rb, int serverId, method in class:StateMachineTest.BrokerWriter
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java431 BrokerWriter bw = null;
459 bw = new BrokerWriter(ds3, DS3_ID, false);
579 BrokerWriter bw = null;
601 bw = new BrokerWriter(ds2, DS2_ID, false);
650 bw = new BrokerWriter(ds2, DS2_ID, false);
714 bw = new BrokerWriter(ds2, DS2_ID, false);
753 bw = new BrokerWriter(ds2, DS2_ID, false);
1015 private class BrokerWriter extends Thread class in class:StateMachineTest
1034 * If the BrokerWriter is to be used for a lot of changes to send (which is
1043 public BrokerWriter(ReplicationBroke method in class:StateMachineTest.BrokerWriter
1049 public BrokerWriter(ReplicationBroker rb, int serverId, method in class:StateMachineTest.BrokerWriter
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java431 BrokerWriter bw = null;
459 bw = new BrokerWriter(ds3, DS3_ID, false);
579 BrokerWriter bw = null;
601 bw = new BrokerWriter(ds2, DS2_ID, false);
650 bw = new BrokerWriter(ds2, DS2_ID, false);
714 bw = new BrokerWriter(ds2, DS2_ID, false);
753 bw = new BrokerWriter(ds2, DS2_ID, false);
1015 private class BrokerWriter extends Thread class in class:StateMachineTest
1034 * If the BrokerWriter is to be used for a lot of changes to send (which is
1043 public BrokerWriter(ReplicationBroke method in class:StateMachineTest.BrokerWriter
1049 public BrokerWriter(ReplicationBroker rb, int serverId, method in class:StateMachineTest.BrokerWriter
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DStateMachineTest.java117 private static void shutdown(BrokerWriter writer)
312 BrokerWriter bw = null;
335 bw = new BrokerWriter(ds3, DS3_ID, false);
426 BrokerWriter bw = null;
441 bw = new BrokerWriter(ds2, DS2_ID, false);
480 bw = new BrokerWriter(ds2, DS2_ID, false);
539 bw = new BrokerWriter(ds2, DS2_ID, false);
576 bw = new BrokerWriter(ds2, DS2_ID, false);
807 private class BrokerWriter extends Thread class in class:StateMachineTest
828 * If the BrokerWriter i
837 public BrokerWriter(ReplicationBroker rb, int serverId, method in class:StateMachineTest.BrokerWriter
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java321 BrokerWriter bw = null;
349 bw = new BrokerWriter(ds3, DS3_ID, false);
442 BrokerWriter bw = null;
458 bw = new BrokerWriter(ds2, DS2_ID, false);
507 bw = new BrokerWriter(ds2, DS2_ID, false);
571 bw = new BrokerWriter(ds2, DS2_ID, false);
610 bw = new BrokerWriter(ds2, DS2_ID, false);
855 private class BrokerWriter extends Thread class in class:StateMachineTest
877 * If the BrokerWriter is to be used for a lot of changes to send (which is
886 public BrokerWriter(ReplicationBroke method in class:StateMachineTest.BrokerWriter
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java321 BrokerWriter bw = null;
349 bw = new BrokerWriter(ds3, DS3_ID, false);
442 BrokerWriter bw = null;
458 bw = new BrokerWriter(ds2, DS2_ID, false);
507 bw = new BrokerWriter(ds2, DS2_ID, false);
571 bw = new BrokerWriter(ds2, DS2_ID, false);
610 bw = new BrokerWriter(ds2, DS2_ID, false);
855 private class BrokerWriter extends Thread class in class:StateMachineTest
877 * If the BrokerWriter is to be used for a lot of changes to send (which is
886 public BrokerWriter(ReplicationBroke method in class:StateMachineTest.BrokerWriter
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java569 BrokerWriter producer[] = new BrokerWriter[THREADS];
588 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS);
592 for (BrokerWriter p : producer)
1053 private class BrokerWriter extends Thread class in class:ReplicationServerTest
1059 public BrokerWriter(ReplicationBroker broker, CSNGenerator gen, int count) method in class:ReplicationServerTest.BrokerWriter
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java569 BrokerWriter producer[] = new BrokerWriter[THREADS];
588 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS);
592 for (BrokerWriter p : producer)
1053 private class BrokerWriter extends Thread class in class:ReplicationServerTest
1059 public BrokerWriter(ReplicationBroker broker, CSNGenerator gen, int count) method in class:ReplicationServerTest.BrokerWriter
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/
H A DReplicationServerTest.java565 BrokerWriter producer[] = new BrokerWriter[THREADS];
584 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS);
588 for (BrokerWriter p : producer)
1055 private class BrokerWriter extends Thread class in class:ReplicationServerTest
1061 public BrokerWriter(ReplicationBroker broker, CSNGenerator gen, int count) method in class:ReplicationServerTest.BrokerWriter
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java630 BrokerWriter producer[] = new BrokerWriter[THREADS];
652 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS);
656 for (BrokerWriter p : producer)
670 for (BrokerWriter p : producer)
1128 private class BrokerWriter extends Thread class in class:ReplicationServerTest
1134 public BrokerWriter(ReplicationBroker broker, ChangeNumberGenerator gen, method in class:ReplicationServerTest.BrokerWriter
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java630 BrokerWriter producer[] = new BrokerWriter[THREADS];
652 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS);
656 for (BrokerWriter p : producer)
670 for (BrokerWriter p : producer)
1128 private class BrokerWriter extends Thread class in class:ReplicationServerTest
1134 public BrokerWriter(ReplicationBroker broker, ChangeNumberGenerator gen, method in class:ReplicationServerTest.BrokerWriter
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java630 BrokerWriter producer[] = new BrokerWriter[THREADS];
652 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS);
656 for (BrokerWriter p : producer)
670 for (BrokerWriter p : producer)
1128 private class BrokerWriter extends Thread class in class:ReplicationServerTest
1134 public BrokerWriter(ReplicationBroker broker, ChangeNumberGenerator gen, method in class:ReplicationServerTest.BrokerWriter

Completed in 84 milliseconds