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 DReplicationServerTest.java559 * 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 DReplicationServerTest.java559 * 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 DReplicationServerTest.java555 * 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 DReplicationServerTest.java620 * 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 DReplicationServerTest.java620 * 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 DReplicationServerTest.java620 * 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