/dports/databases/xtrabackup/boost_1_59_0/libs/lockfree/test/ |
H A D | test_common.hpp | 29 const int writer_threads; member 40 reader_threads(reader), writer_threads(writer), push_count(0), pop_count(0) in queue_stress_tester() 90 if ( writers_finished.load() == writer_threads ) in get_items() 111 for (int i = 0; i != writer_threads; ++i) in run() 129 BOOST_REQUIRE_EQUAL(push_count, writer_threads * node_count); in run()
|
/dports/databases/percona57-pam-for-mysql/boost_1_59_0/libs/lockfree/test/ |
H A D | test_common.hpp | 29 const int writer_threads; member 40 reader_threads(reader), writer_threads(writer), push_count(0), pop_count(0) in queue_stress_tester() 90 if ( writers_finished.load() == writer_threads ) in get_items() 111 for (int i = 0; i != writer_threads; ++i) in run() 129 BOOST_REQUIRE_EQUAL(push_count, writer_threads * node_count); in run()
|
/dports/databases/percona57-server/boost_1_59_0/libs/lockfree/test/ |
H A D | test_common.hpp | 29 const int writer_threads; member 40 reader_threads(reader), writer_threads(writer), push_count(0), pop_count(0) in queue_stress_tester() 90 if ( writers_finished.load() == writer_threads ) in get_items() 111 for (int i = 0; i != writer_threads; ++i) in run() 129 BOOST_REQUIRE_EQUAL(push_count, writer_threads * node_count); in run()
|
/dports/databases/percona57-client/boost_1_59_0/libs/lockfree/test/ |
H A D | test_common.hpp | 29 const int writer_threads; member 40 reader_threads(reader), writer_threads(writer), push_count(0), pop_count(0) in queue_stress_tester() 90 if ( writers_finished.load() == writer_threads ) in get_items() 111 for (int i = 0; i != writer_threads; ++i) in run() 129 BOOST_REQUIRE_EQUAL(push_count, writer_threads * node_count); in run()
|
/dports/databases/mysqlwsrep57-server/boost_1_59_0/libs/lockfree/test/ |
H A D | test_common.hpp | 29 const int writer_threads; member 40 reader_threads(reader), writer_threads(writer), push_count(0), pop_count(0) in queue_stress_tester() 90 if ( writers_finished.load() == writer_threads ) in get_items() 111 for (int i = 0; i != writer_threads; ++i) in run() 129 BOOST_REQUIRE_EQUAL(push_count, writer_threads * node_count); in run()
|
/dports/devel/boost-docs/boost_1_72_0/libs/lockfree/test/ |
H A D | test_common.hpp | 30 const int writer_threads; member 41 reader_threads(reader), writer_threads(writer), push_count(0), pop_count(0) in queue_stress_tester() 97 if ( writers_finished.load() == writer_threads ) in get_items() 122 for (int i = 0; i != writer_threads; ++i) in run() 139 BOOST_REQUIRE_EQUAL(push_count, writer_threads * node_count); in run()
|
/dports/devel/boost-python-libs/boost_1_72_0/libs/lockfree/test/ |
H A D | test_common.hpp | 30 const int writer_threads; member 41 reader_threads(reader), writer_threads(writer), push_count(0), pop_count(0) in queue_stress_tester() 97 if ( writers_finished.load() == writer_threads ) in get_items() 122 for (int i = 0; i != writer_threads; ++i) in run() 139 BOOST_REQUIRE_EQUAL(push_count, writer_threads * node_count); in run()
|
/dports/devel/boost-libs/boost_1_72_0/libs/lockfree/test/ |
H A D | test_common.hpp | 30 const int writer_threads; member 41 reader_threads(reader), writer_threads(writer), push_count(0), pop_count(0) in queue_stress_tester() 97 if ( writers_finished.load() == writer_threads ) in get_items() 122 for (int i = 0; i != writer_threads; ++i) in run() 139 BOOST_REQUIRE_EQUAL(push_count, writer_threads * node_count); in run()
|
/dports/devel/hyperscan/boost_1_75_0/libs/lockfree/test/ |
H A D | test_common.hpp | 30 const int writer_threads; member 41 reader_threads(reader), writer_threads(writer), push_count(0), pop_count(0) in queue_stress_tester() 97 if ( writers_finished.load() == writer_threads ) in get_items() 122 for (int i = 0; i != writer_threads; ++i) in run() 139 BOOST_REQUIRE_EQUAL(push_count, writer_threads * node_count); in run()
|
/dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/tokudb/PerconaFT/util/tests/ |
H A D | test_partitioned_counter.cc | 353 pthread_t *writer_threads[NGROUPS]; in do_testit() local 362 MALLOC_N(n_writers[i], writer_threads[i]); in do_testit() 364 pt_create(&writer_threads[i][j], writer_test_fun, &tas[i]); in do_testit() 371 pt_join(writer_threads[i][j], &tas[i]); in do_testit() 373 toku_free(writer_threads[i]); in do_testit()
|
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/storage/tokudb/PerconaFT/util/tests/ |
H A D | test_partitioned_counter.cc | 353 pthread_t *writer_threads[NGROUPS]; in do_testit() local 362 MALLOC_N(n_writers[i], writer_threads[i]); in do_testit() 364 pt_create(&writer_threads[i][j], writer_test_fun, &tas[i]); in do_testit() 371 pt_join(writer_threads[i][j], &tas[i]); in do_testit() 373 toku_free(writer_threads[i]); in do_testit()
|
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/tokudb/PerconaFT/util/tests/ |
H A D | test_partitioned_counter.cc | 353 pthread_t *writer_threads[NGROUPS]; in do_testit() local 362 MALLOC_N(n_writers[i], writer_threads[i]); in do_testit() 364 pt_create(&writer_threads[i][j], writer_test_fun, &tas[i]); in do_testit() 371 pt_join(writer_threads[i][j], &tas[i]); in do_testit() 373 toku_free(writer_threads[i]); in do_testit()
|
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/tokudb/PerconaFT/util/tests/ |
H A D | test_partitioned_counter.cc | 353 pthread_t *writer_threads[NGROUPS]; in do_testit() local 362 MALLOC_N(n_writers[i], writer_threads[i]); in do_testit() 364 pt_create(&writer_threads[i][j], writer_test_fun, &tas[i]); in do_testit() 371 pt_join(writer_threads[i][j], &tas[i]); in do_testit() 373 toku_free(writer_threads[i]); in do_testit()
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/tokudb/PerconaFT/util/tests/ |
H A D | test_partitioned_counter.cc | 353 pthread_t *writer_threads[NGROUPS]; in do_testit() local 362 MALLOC_N(n_writers[i], writer_threads[i]); in do_testit() 364 pt_create(&writer_threads[i][j], writer_test_fun, &tas[i]); in do_testit() 371 pt_join(writer_threads[i][j], &tas[i]); in do_testit() 373 toku_free(writer_threads[i]); in do_testit()
|
/dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/tokudb/PerconaFT/util/tests/ |
H A D | test_partitioned_counter.cc | 353 pthread_t *writer_threads[NGROUPS]; in do_testit() local 362 MALLOC_N(n_writers[i], writer_threads[i]); in do_testit() 364 pt_create(&writer_threads[i][j], writer_test_fun, &tas[i]); in do_testit() 371 pt_join(writer_threads[i][j], &tas[i]); in do_testit() 373 toku_free(writer_threads[i]); in do_testit()
|
/dports/databases/mariadb104-server/mariadb-10.4.24/storage/tokudb/PerconaFT/util/tests/ |
H A D | test_partitioned_counter.cc | 353 pthread_t *writer_threads[NGROUPS]; in do_testit() local 362 MALLOC_N(n_writers[i], writer_threads[i]); in do_testit() 364 pt_create(&writer_threads[i][j], writer_test_fun, &tas[i]); in do_testit() 371 pt_join(writer_threads[i][j], &tas[i]); in do_testit() 373 toku_free(writer_threads[i]); in do_testit()
|
/dports/databases/mariadb104-client/mariadb-10.4.24/storage/tokudb/PerconaFT/util/tests/ |
H A D | test_partitioned_counter.cc | 353 pthread_t *writer_threads[NGROUPS]; in do_testit() local 362 MALLOC_N(n_writers[i], writer_threads[i]); in do_testit() 364 pt_create(&writer_threads[i][j], writer_test_fun, &tas[i]); in do_testit() 371 pt_join(writer_threads[i][j], &tas[i]); in do_testit() 373 toku_free(writer_threads[i]); in do_testit()
|
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/tokudb/PerconaFT/util/tests/ |
H A D | test_partitioned_counter.cc | 353 pthread_t *writer_threads[NGROUPS]; in do_testit() local 362 MALLOC_N(n_writers[i], writer_threads[i]); in do_testit() 364 pt_create(&writer_threads[i][j], writer_test_fun, &tas[i]); in do_testit() 371 pt_join(writer_threads[i][j], &tas[i]); in do_testit() 373 toku_free(writer_threads[i]); in do_testit()
|
/dports/databases/mariadb103-client/mariadb-10.3.34/storage/tokudb/PerconaFT/util/tests/ |
H A D | test_partitioned_counter.cc | 353 pthread_t *writer_threads[NGROUPS]; in do_testit() local 362 MALLOC_N(n_writers[i], writer_threads[i]); in do_testit() 364 pt_create(&writer_threads[i][j], writer_test_fun, &tas[i]); in do_testit() 371 pt_join(writer_threads[i][j], &tas[i]); in do_testit() 373 toku_free(writer_threads[i]); in do_testit()
|
/dports/databases/mariadb103-server/mariadb-10.3.34/storage/tokudb/PerconaFT/util/tests/ |
H A D | test_partitioned_counter.cc | 353 pthread_t *writer_threads[NGROUPS]; 362 MALLOC_N(n_writers[i], writer_threads[i]); 364 pt_create(&writer_threads[i][j], writer_test_fun, &tas[i]); 371 pt_join(writer_threads[i][j], &tas[i]); 373 toku_free(writer_threads[i]);
|
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/tokudb/PerconaFT/util/tests/ |
H A D | test_partitioned_counter.cc | 353 pthread_t *writer_threads[NGROUPS]; in do_testit() local 362 MALLOC_N(n_writers[i], writer_threads[i]); in do_testit() 364 pt_create(&writer_threads[i][j], writer_test_fun, &tas[i]); in do_testit() 371 pt_join(writer_threads[i][j], &tas[i]); in do_testit() 373 toku_free(writer_threads[i]); in do_testit()
|
/dports/biology/subread/subread-2.0.2-source/src/ |
H A D | sambam-file.c | 2018 if(writer -> writer_threads[thread_no].last_job_done){ in SamBam_thread_wait_merge_write() 2023 …int rlen = fwrite( writer -> writer_threads[thread_no].zipped_bin ,1, writer -> writer_threads[thr… in SamBam_thread_wait_merge_write() 2024 if(rlen != writer -> writer_threads[thread_no].bin_size){ in SamBam_thread_wait_merge_write() 2031 writer -> writer_threads[thread_no].text_size = 0; in SamBam_thread_wait_merge_write() 2032 writer -> writer_threads[thread_no].bin_size = 0; in SamBam_thread_wait_merge_write() 2033 writer -> writer_threads[thread_no].bam_block_no = -1; in SamBam_thread_wait_merge_write() 2034 writer -> writer_threads[thread_no].last_job_done = 0; in SamBam_thread_wait_merge_write() 2394 memset(&(writer -> writer_threads[thread_i].strm),0,sizeof(z_stream)); in SamBam_writer_sort_bins_to_BAM() 2460 pthread_join(writer -> writer_threads[thread_i].thread_stub, NULL); in SamBam_writer_sort_bins_to_BAM() 2461 deflateEnd(&(writer -> writer_threads[thread_i].strm)); in SamBam_writer_sort_bins_to_BAM() [all …]
|
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/rocksdb/rocksdb/db/ |
H A D | db_write_buffer_manager_test.cc | 348 std::vector<port::Thread> writer_threads; in TEST_P() local 422 writer_threads.emplace_back(write_cf, i % 3); in TEST_P() 429 for (auto& t : writer_threads) { in TEST_P() 652 std::vector<port::Thread> writer_threads; in TEST_P() local 747 writer_threads.emplace_back(write_slow_down, db_); in TEST_P() 748 writer_threads.emplace_back(write_no_slow_down, db_); in TEST_P() 758 for (auto& t : writer_threads) { in TEST_P()
|
/dports/databases/rocksdb-lite/rocksdb-6.26.1/db/ |
H A D | db_write_buffer_manager_test.cc | 348 std::vector<port::Thread> writer_threads; in TEST_P() local 422 writer_threads.emplace_back(write_cf, i % 3); in TEST_P() 429 for (auto& t : writer_threads) { in TEST_P() 652 std::vector<port::Thread> writer_threads; in TEST_P() local 747 writer_threads.emplace_back(write_slow_down, db_); in TEST_P() 748 writer_threads.emplace_back(write_no_slow_down, db_); in TEST_P() 758 for (auto& t : writer_threads) { in TEST_P()
|
/dports/databases/rocksdb/rocksdb-6.26.1/db/ |
H A D | db_write_buffer_manager_test.cc | 348 std::vector<port::Thread> writer_threads; in TEST_P() local 422 writer_threads.emplace_back(write_cf, i % 3); in TEST_P() 429 for (auto& t : writer_threads) { in TEST_P() 652 std::vector<port::Thread> writer_threads; in TEST_P() local 747 writer_threads.emplace_back(write_slow_down, db_); in TEST_P() 748 writer_threads.emplace_back(write_no_slow_down, db_); in TEST_P() 758 for (auto& t : writer_threads) { in TEST_P()
|