Searched refs:THREADS (Results 1 - 6 of 6) sorted by relevance
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerTest.java | 559 * but can be changed using TOTAL_MSG and THREADS consts. 566 final int THREADS = 2; // number of threads that will produce 569 BrokerWriter producer[] = new BrokerWriter[THREADS]; 570 BrokerReader reader[] = new BrokerReader[THREADS]; 571 ReplicationBroker broker[] = new ReplicationBroker[THREADS]; 581 for (int i = 0; i< THREADS; i++) 588 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS); 589 reader[i] = new BrokerReader(broker[i], (TOTAL_MSG/THREADS)*(THREADS-1));
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerTest.java | 559 * but can be changed using TOTAL_MSG and THREADS consts. 566 final int THREADS = 2; // number of threads that will produce 569 BrokerWriter producer[] = new BrokerWriter[THREADS]; 570 BrokerReader reader[] = new BrokerReader[THREADS]; 571 ReplicationBroker broker[] = new ReplicationBroker[THREADS]; 581 for (int i = 0; i< THREADS; i++) 588 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS); 589 reader[i] = new BrokerReader(broker[i], (TOTAL_MSG/THREADS)*(THREADS-1));
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/ |
H A D | ReplicationServerTest.java | 555 * but can be changed using TOTAL_MSG and THREADS consts. 562 final int THREADS = 2; // number of threads that will produce 565 BrokerWriter producer[] = new BrokerWriter[THREADS]; 566 BrokerReader reader[] = new BrokerReader[THREADS]; 567 ReplicationBroker broker[] = new ReplicationBroker[THREADS]; 577 for (int i = 0; i< THREADS; i++) 584 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS); 585 reader[i] = new BrokerReader(broker[i], (TOTAL_MSG/THREADS)*(THREADS-1));
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerTest.java | 620 * but can be changed using TOTAL_MSG and THREADS consts. 627 final int THREADS = 2; // number of threads that will produce 630 BrokerWriter producer[] = new BrokerWriter[THREADS]; 631 BrokerReader reader[] = new BrokerReader[THREADS]; 632 ReplicationBroker broker[] = new ReplicationBroker[THREADS]; 642 for (int i = 0; i< THREADS; i++) 652 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS); 653 reader[i] = new BrokerReader(broker[i], (TOTAL_MSG/THREADS)*(THREADS-1));
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerTest.java | 620 * but can be changed using TOTAL_MSG and THREADS consts. 627 final int THREADS = 2; // number of threads that will produce 630 BrokerWriter producer[] = new BrokerWriter[THREADS]; 631 BrokerReader reader[] = new BrokerReader[THREADS]; 632 ReplicationBroker broker[] = new ReplicationBroker[THREADS]; 642 for (int i = 0; i< THREADS; i++) 652 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS); 653 reader[i] = new BrokerReader(broker[i], (TOTAL_MSG/THREADS)*(THREADS-1));
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerTest.java | 620 * but can be changed using TOTAL_MSG and THREADS consts. 627 final int THREADS = 2; // number of threads that will produce 630 BrokerWriter producer[] = new BrokerWriter[THREADS]; 631 BrokerReader reader[] = new BrokerReader[THREADS]; 632 ReplicationBroker broker[] = new ReplicationBroker[THREADS]; 642 for (int i = 0; i< THREADS; i++) 652 producer[i] = new BrokerWriter(broker[i], gen, TOTAL_MSG/THREADS); 653 reader[i] = new BrokerReader(broker[i], (TOTAL_MSG/THREADS)*(THREADS-1));
|
Completed in 851 milliseconds