Home
last modified time | relevance | path

Searched refs:writer_threads (Results 1 – 25 of 37) sorted by relevance

12

/dports/databases/xtrabackup/boost_1_59_0/libs/lockfree/test/
H A Dtest_common.hpp29 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 Dtest_common.hpp29 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 Dtest_common.hpp29 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 Dtest_common.hpp29 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 Dtest_common.hpp29 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 Dtest_common.hpp30 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 Dtest_common.hpp30 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 Dtest_common.hpp30 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 Dtest_common.hpp30 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 Dtest_partitioned_counter.cc353 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 Dtest_partitioned_counter.cc353 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 Dtest_partitioned_counter.cc353 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 Dtest_partitioned_counter.cc353 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 Dtest_partitioned_counter.cc353 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 Dtest_partitioned_counter.cc353 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 Dtest_partitioned_counter.cc353 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 Dtest_partitioned_counter.cc353 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 Dtest_partitioned_counter.cc353 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 Dtest_partitioned_counter.cc353 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 Dtest_partitioned_counter.cc353 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 Dtest_partitioned_counter.cc353 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 Dsambam-file.c2018 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 Ddb_write_buffer_manager_test.cc348 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 Ddb_write_buffer_manager_test.cc348 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 Ddb_write_buffer_manager_test.cc348 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()

12