/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | StressTest.java | 75 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 D | StressTest.java | 65 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 D | StressTest.java | 75 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 D | StressTest.java | 65 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 D | StressTest.java | 75 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 D | StressTest.java | 67 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 D | StateMachineTest.java | 429 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 D | ReplicationServerTest.java | 530 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 D | StateMachineTest.java | 319 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 D | ReplicationServerTest.java | 490 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 D | StateMachineTest.java | 429 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 D | ReplicationServerTest.java | 530 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 D | StateMachineTest.java | 319 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 D | ReplicationServerTest.java | 490 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 D | StateMachineTest.java | 429 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 D | ReplicationServerTest.java | 530 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 D | StateMachineTest.java | 109 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 D | ReplicationServerTest.java | 487 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...] |