Searched defs:BrokerReader (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.java75 private BrokerReader reader = null;
135 reader = new BrokerReader(broker);
279 private class BrokerReader extends Thread class in class:StressTest
289 public BrokerReader(ReplicationBroker broker) method in class:StressTest.BrokerReader
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java65 private BrokerReader reader;
117 reader = new BrokerReader(broker);
249 private class BrokerReader extends Thread class in class:StressTest
258 public BrokerReader(ReplicationBroker broker) method in class:StressTest.BrokerReader
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java75 private BrokerReader reader = null;
135 reader = new BrokerReader(broker);
279 private class BrokerReader extends Thread class in class:StressTest
289 public BrokerReader(ReplicationBroker broker) method in class:StressTest.BrokerReader
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java65 private BrokerReader reader;
117 reader = new BrokerReader(broker);
249 private class BrokerReader extends Thread class in class:StressTest
258 public BrokerReader(ReplicationBroker broker) method in class:StressTest.BrokerReader
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DStressTest.java75 private BrokerReader reader = null;
135 reader = new BrokerReader(broker);
279 private class BrokerReader extends Thread class in class:StressTest
289 public BrokerReader(ReplicationBroker broker) method in class:StressTest.BrokerReader
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/
H A DStressTest.java67 private BrokerReader reader;
116 reader = new BrokerReader(broker);
244 private class BrokerReader extends Thread class in class:StressTest
253 public BrokerReader(ReplicationBroker broker) method in class:StressTest.BrokerReader
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java429 BrokerReader br3 = null;
430 BrokerReader br2 = null;
453 br3 = new BrokerReader(ds3, DS3_ID);
524 br2 = new BrokerReader(ds2, DS2_ID);
578 BrokerReader br = null;
595 br = new BrokerReader(ds2, DS2_ID);
638 br = new BrokerReader(ds2, DS2_ID);
672 br = new BrokerReader(ds2, DS2_ID);
715 br = new BrokerReader(ds2, DS2_ID);
754 br = new BrokerReader(ds
1307 private class BrokerReader extends Thread class in class:StateMachineTest
1315 public BrokerReader(ReplicationBroker rb, int serverId) method in class:StateMachineTest.BrokerReader
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java530 BrokerReader reader = null;
536 BrokerReader client[] = new BrokerReader[CLIENT_THREADS];
550 reader = new BrokerReader(server, TOTAL_MSG);
561 client[i] = new BrokerReader(clientBroker[i], TOTAL_MSG);
564 for (BrokerReader c : client)
593 for (BrokerReader c : client)
631 BrokerReader reader[] = new BrokerReader[THREADS];
653 reader[i] = new BrokerReader(broke
1060 private class BrokerReader extends Thread class in class:ReplicationServerTest
1071 public BrokerReader(ReplicationBroker broker, int numMsgExpected) method in class:ReplicationServerTest.BrokerReader
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java319 BrokerReader br3 = null;
320 BrokerReader br2 = null;
343 br3 = new BrokerReader(ds3, DS3_ID);
392 br2 = new BrokerReader(ds2, DS2_ID);
441 BrokerReader br = null;
454 br = new BrokerReader(ds2, DS2_ID);
495 br = new BrokerReader(ds2, DS2_ID);
529 br = new BrokerReader(ds2, DS2_ID);
572 br = new BrokerReader(ds2, DS2_ID);
611 br = new BrokerReader(ds
1112 private class BrokerReader extends Thread class in class:StateMachineTest
1120 public BrokerReader(ReplicationBroker rb, int serverId) method in class:StateMachineTest.BrokerReader
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java490 BrokerReader reader = null;
496 BrokerReader client[] = new BrokerReader[CLIENT_THREADS];
505 reader = new BrokerReader(server, TOTAL_MSG);
514 client[i] = new BrokerReader(clientBroker[i], TOTAL_MSG);
517 for (BrokerReader c : client)
570 BrokerReader reader[] = new BrokerReader[THREADS];
589 reader[i] = new BrokerReader(broker[i], (TOTAL_MSG/THREADS)*(THREADS-1));
597 for (BrokerReader
985 private class BrokerReader extends Thread class in class:ReplicationServerTest
996 public BrokerReader(ReplicationBroker broker, int numMsgExpected) method in class:ReplicationServerTest.BrokerReader
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java429 BrokerReader br3 = null;
430 BrokerReader br2 = null;
453 br3 = new BrokerReader(ds3, DS3_ID);
524 br2 = new BrokerReader(ds2, DS2_ID);
578 BrokerReader br = null;
595 br = new BrokerReader(ds2, DS2_ID);
638 br = new BrokerReader(ds2, DS2_ID);
672 br = new BrokerReader(ds2, DS2_ID);
715 br = new BrokerReader(ds2, DS2_ID);
754 br = new BrokerReader(ds
1307 private class BrokerReader extends Thread class in class:StateMachineTest
1315 public BrokerReader(ReplicationBroker rb, int serverId) method in class:StateMachineTest.BrokerReader
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java530 BrokerReader reader = null;
536 BrokerReader client[] = new BrokerReader[CLIENT_THREADS];
550 reader = new BrokerReader(server, TOTAL_MSG);
561 client[i] = new BrokerReader(clientBroker[i], TOTAL_MSG);
564 for (BrokerReader c : client)
593 for (BrokerReader c : client)
631 BrokerReader reader[] = new BrokerReader[THREADS];
653 reader[i] = new BrokerReader(broke
1060 private class BrokerReader extends Thread class in class:ReplicationServerTest
1071 public BrokerReader(ReplicationBroker broker, int numMsgExpected) method in class:ReplicationServerTest.BrokerReader
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java319 BrokerReader br3 = null;
320 BrokerReader br2 = null;
343 br3 = new BrokerReader(ds3, DS3_ID);
392 br2 = new BrokerReader(ds2, DS2_ID);
441 BrokerReader br = null;
454 br = new BrokerReader(ds2, DS2_ID);
495 br = new BrokerReader(ds2, DS2_ID);
529 br = new BrokerReader(ds2, DS2_ID);
572 br = new BrokerReader(ds2, DS2_ID);
611 br = new BrokerReader(ds
1112 private class BrokerReader extends Thread class in class:StateMachineTest
1120 public BrokerReader(ReplicationBroker rb, int serverId) method in class:StateMachineTest.BrokerReader
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java490 BrokerReader reader = null;
496 BrokerReader client[] = new BrokerReader[CLIENT_THREADS];
505 reader = new BrokerReader(server, TOTAL_MSG);
514 client[i] = new BrokerReader(clientBroker[i], TOTAL_MSG);
517 for (BrokerReader c : client)
570 BrokerReader reader[] = new BrokerReader[THREADS];
589 reader[i] = new BrokerReader(broker[i], (TOTAL_MSG/THREADS)*(THREADS-1));
597 for (BrokerReader
985 private class BrokerReader extends Thread class in class:ReplicationServerTest
996 public BrokerReader(ReplicationBroker broker, int numMsgExpected) method in class:ReplicationServerTest.BrokerReader
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java429 BrokerReader br3 = null;
430 BrokerReader br2 = null;
453 br3 = new BrokerReader(ds3, DS3_ID);
524 br2 = new BrokerReader(ds2, DS2_ID);
578 BrokerReader br = null;
595 br = new BrokerReader(ds2, DS2_ID);
638 br = new BrokerReader(ds2, DS2_ID);
672 br = new BrokerReader(ds2, DS2_ID);
715 br = new BrokerReader(ds2, DS2_ID);
754 br = new BrokerReader(ds
1307 private class BrokerReader extends Thread class in class:StateMachineTest
1315 public BrokerReader(ReplicationBroker rb, int serverId) method in class:StateMachineTest.BrokerReader
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java530 BrokerReader reader = null;
536 BrokerReader client[] = new BrokerReader[CLIENT_THREADS];
550 reader = new BrokerReader(server, TOTAL_MSG);
561 client[i] = new BrokerReader(clientBroker[i], TOTAL_MSG);
564 for (BrokerReader c : client)
593 for (BrokerReader c : client)
631 BrokerReader reader[] = new BrokerReader[THREADS];
653 reader[i] = new BrokerReader(broke
1060 private class BrokerReader extends Thread class in class:ReplicationServerTest
1071 public BrokerReader(ReplicationBroker broker, int numMsgExpected) method in class:ReplicationServerTest.BrokerReader
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DStateMachineTest.java109 private static void shutdown(BrokerReader reader)
310 BrokerReader br3 = null;
311 BrokerReader br2 = null;
329 br3 = new BrokerReader(ds3, DS3_ID);
377 br2 = new BrokerReader(ds2, DS2_ID);
425 BrokerReader br = null;
437 br = new BrokerReader(ds2, DS2_ID);
472 br = new BrokerReader(ds2, DS2_ID);
499 br = new BrokerReader(ds2, DS2_ID);
540 br = new BrokerReader(ds
1054 private class BrokerReader extends Thread class in class:StateMachineTest
1061 public BrokerReader(ReplicationBroker rb, int serverId) method in class:StateMachineTest.BrokerReader
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/
H A DReplicationServerTest.java487 BrokerReader reader = null;
493 BrokerReader client[] = new BrokerReader[CLIENT_THREADS];
502 reader = new BrokerReader(server, TOTAL_MSG);
510 client[i] = new BrokerReader(clientBroker[i], TOTAL_MSG);
513 for (BrokerReader c : client)
566 BrokerReader reader[] = new BrokerReader[THREADS];
585 reader[i] = new BrokerReader(broker[i], (TOTAL_MSG/THREADS)*(THREADS-1));
593 for (BrokerReader
987 private class BrokerReader extends Thread class in class:ReplicationServerTest
998 public BrokerReader(ReplicationBroker broker, int numMsgExpected) method in class:ReplicationServerTest.BrokerReader
[all...]

Completed in 121 milliseconds