| /dports/databases/tiledb/TileDB-2.5.2/tiledb/sm/subarray/ |
| H A D | subarray.h | 300 ThreadPool* compute_tp,
445 ThreadPool* compute_tp);
456 ThreadPool* compute_tp);
467 ThreadPool* compute_tp);
479 ThreadPool* compute_tp);
492 ThreadPool* compute_tp);
503 ThreadPool* compute_tp);
514 ThreadPool* compute_tp);
996 ThreadPool* compute_tp,
1011 ThreadPool* compute_tp,
[all …]
|
| H A D | subarray.cc | 559 ThreadPool* const compute_tp) { in get_est_result_size() argument
612 ThreadPool* const compute_tp) { in get_est_result_size() argument
677 ThreadPool* const compute_tp) { in get_est_result_size_nullable() argument
734 ThreadPool* const compute_tp) { in get_est_result_size_nullable() argument
2032 ThreadPool* const compute_tp, in precompute_tile_overlap() argument
2120 ThreadPool* const compute_tp, in precompute_all_ranges_tile_overlap() argument
2395 ThreadPool* const compute_tp, in compute_relevant_fragments() argument
2443 compute_tp, in compute_relevant_fragments()
2545 ThreadPool* const compute_tp, in compute_relevant_fragments_for_dim() argument
2596 ThreadPool* const compute_tp, in compute_relevant_fragment_tile_overlap() argument
[all …]
|
| H A D | subarray_partitioner.h | 172 ThreadPool* compute_tp,
|
| H A D | subarray_partitioner.cc | 72 ThreadPool* const compute_tp, in SubarrayPartitioner() argument
82 , compute_tp_(compute_tp) { in SubarrayPartitioner()
|
| /dports/databases/tiledb/TileDB-2.5.2/test/src/ |
| H A D | unit-vfs.cc | 43 ThreadPool compute_tp; variable
45 REQUIRE(compute_tp.init(4).ok());
116 &compute_tp,
165 &compute_tp,
191 &compute_tp,
226 ThreadPool compute_tp; variable
228 REQUIRE(compute_tp.init(4).ok());
279 ThreadPool compute_tp; variable
281 REQUIRE(compute_tp.init(4).ok());
333 ThreadPool compute_tp; variable
[all …]
|
| /dports/databases/tiledb/TileDB-2.5.2/tiledb/sm/filter/ |
| H A D | filter_pipeline.h | 181 stats::Stats* writer_stats, Tile* tile, ThreadPool* compute_tp) const;
223 ThreadPool* compute_tp,
286 ThreadPool* compute_tp) const;
301 ThreadPool* compute_tp,
315 ThreadPool* compute_tp,
|
| H A D | filter_pipeline.cc | 102 ThreadPool* const compute_tp) const { in filter_chunks_forward()
119 auto status = parallel_for(compute_tp, 0, nchunks, [&](uint64_t i) { in filter_chunks_forward()
207 status = parallel_for(compute_tp, 0, final_stage_io.size(), [&](uint64_t i) { in filter_chunks_forward()
247 ThreadPool* const compute_tp, in filter_chunks_reverse() argument
264 auto status = parallel_for(compute_tp, 0, input.size(), [&](uint64_t i) { in filter_chunks_reverse()
358 ThreadPool* const compute_tp) const { in run_forward()
371 *tile->buffer(), chunk_size, tile->filtered_buffer(), compute_tp), in run_forward()
384 ThreadPool* const compute_tp, in run_reverse() argument
388 return run_reverse_internal(reader_stats, tile, compute_tp, config); in run_reverse()
394 ThreadPool* const compute_tp, in run_reverse_internal() argument
[all …]
|
| /dports/databases/tiledb/TileDB-2.5.2/tiledb/sm/serialization/ |
| H A D | query.cc | 352 ThreadPool* compute_tp, in subarray_partitioner_from_capnp() argument
377 compute_tp, in subarray_partitioner_from_capnp()
437 compute_tp, in subarray_partitioner_from_capnp()
556 ThreadPool* compute_tp) { in read_state_from_capnp() argument
571 compute_tp, in read_state_from_capnp()
637 ThreadPool* compute_tp) { in dense_read_state_from_capnp() argument
652 compute_tp, in dense_read_state_from_capnp()
848 ThreadPool* compute_tp) { in reader_from_capnp() argument
934 ThreadPool* compute_tp) { in dense_reader_from_capnp() argument
2026 compute_tp); in query_deserialize()
[all …]
|
| H A D | query.h | 157 ThreadPool* compute_tp);
|
| /dports/databases/tiledb/TileDB-2.5.2/tiledb/sm/query/ |
| H A D | reader_base.cc | 235 storage_manager_->compute_tp(), in load_tile_offsets()
287 storage_manager_->compute_tp(), in load_tile_var_sizes()
423 storage_manager_->compute_tp(), in read_tiles()
754 storage_manager_->compute_tp(), in unfilter_tile()
795 storage_manager_->compute_tp(), in unfilter_tile_nullable()
802 storage_manager_->compute_tp(), in unfilter_tile_nullable()
829 storage_manager_->compute_tp(), in unfilter_tile_nullable()
834 storage_manager_->compute_tp(), in unfilter_tile_nullable()
841 storage_manager_->compute_tp(), in unfilter_tile_nullable()
1023 storage_manager_->compute_tp(), in copy_fixed_cells()
[all …]
|
| H A D | writer.cc | 401 storage_manager_->compute_tp(), in check_coord_dups()
497 storage_manager_->compute_tp(), in check_coord_dups()
581 storage_manager_->compute_tp(), in check_coord_oob()
625 storage_manager_->compute_tp(), in check_global_order()
666 storage_manager_->compute_tp(), in check_global_order_hilbert()
785 storage_manager_->compute_tp(), in compute_coord_dups()
876 storage_manager_->compute_tp(), in compute_coord_dups()
1631 auto compute_tp = storage_manager_->compute_tp(); in ordered_write() local
2313 storage_manager_->compute_tp(), in sort_coords()
2321 storage_manager_->compute_tp(), in sort_coords()
[all …]
|
| H A D | reader.cc | 381 storage_manager_->compute_tp(), 0, range_num, [&](uint64_t r) { in compute_range_result_coords()
477 storage_manager_->compute_tp(), 0, fragment_num, [&](uint32_t f) { in compute_range_result_coords()
990 storage_manager_->compute_tp(), in init_read_state()
1042 storage_manager_->compute_tp(), iter_begin, iter_end, RowCmp(domain)); in sort_result_coords()
1045 storage_manager_->compute_tp(), iter_begin, iter_end, ColCmp(domain)); in sort_result_coords()
1051 storage_manager_->compute_tp(), in sort_result_coords()
1058 storage_manager_->compute_tp(), in sort_result_coords()
1199 storage_manager_->compute_tp(), 0, coords_num, [&](uint64_t c) { in calculate_hilbert_values()
|
| H A D | sparse_global_order_reader.cc | 443 storage_manager_->compute_tp(), 0, fragment_num, [&](uint64_t f) { in create_result_tiles()
490 storage_manager_->compute_tp(), 0, fragment_num, [&](uint64_t f) { in create_result_tiles()
773 storage_manager_->compute_tp(), 0, cell_num, [&](uint64_t c) { in calculate_hilbert_values()
830 storage_manager_->compute_tp(), 0, result_tiles_.size(), [&](uint64_t f) { in merge_result_cell_slabs()
1068 storage_manager_->compute_tp(), 0, fragment_num, [&](uint64_t f) { in end_iteration()
|
| H A D | dense_reader.cc | 263 storage_manager_->compute_tp(), in dense_read()
433 storage_manager_->compute_tp(), in init_read_state()
504 storage_manager_->compute_tp(), 0, tile_coords.size(), [&](uint64_t t) { in apply_query_condition()
675 storage_manager_->compute_tp(), 0, tile_coords.size(), [&](uint64_t t) { in read_attributes()
702 storage_manager_->compute_tp(), 0, var_names->size(), [&](uint64_t n) { in read_attributes()
731 storage_manager_->compute_tp(), 0, tile_coords.size(), [&](uint64_t t) { in read_attributes()
781 storage_manager_->compute_tp(), 0, tile_coords.size(), [&](uint64_t t) { in read_attributes()
|
| H A D | query.cc | 391 name, size, &config_, storage_manager_->compute_tp()); in get_est_result_size()
421 name, size_off, size_val, &config_, storage_manager_->compute_tp()); in get_est_result_size()
458 name, size_val, size_validity, &config_, storage_manager_->compute_tp()); in get_est_result_size_nullable()
499 storage_manager_->compute_tp()); in get_est_result_size_nullable()
505 &config_, storage_manager_->compute_tp()); in get_est_result_size_map()
511 &config_, storage_manager_->compute_tp()); in get_max_mem_size_map()
|
| H A D | sparse_index_reader_base.cc | 148 storage_manager_->compute_tp(), &result_tile_ranges_)); in load_initial_data()
|
| H A D | sparse_unordered_with_dups_reader.cc | 671 storage_manager_->compute_tp(), in create_result_cell_slabs()
|
| /dports/databases/tiledb/TileDB-2.5.2/tiledb/sm/storage_manager/ |
| H A D | context.h | 80 ThreadPool* compute_tp() const;
|
| H A D | storage_manager.h | 117 ThreadPool* compute_tp,
648 ThreadPool* compute_tp();
|
| H A D | context.cc | 113 ThreadPool* Context::compute_tp() const { in compute_tp() function in tiledb::sm::Context
|
| /dports/databases/tiledb/TileDB-2.5.2/tiledb/sm/tile/ |
| H A D | generic_tile_io.cc | 112 storage_manager_->compute_tp(), in read_generic()
166 storage_manager_->stats(), tile, storage_manager_->compute_tp())); in write_generic()
|
| /dports/databases/tiledb/TileDB-2.5.2/tiledb/sm/rest/ |
| H A D | rest_client.h | 62 stats::Stats* parent_stats, const Config* config, ThreadPool* compute_tp);
|
| H A D | rest_client.cc | 80 ThreadPool* compute_tp) { in init() argument
88 compute_tp_ = compute_tp; in init()
|
| /dports/databases/tiledb/TileDB-2.5.2/tiledb/sm/filesystem/ |
| H A D | vfs.h | 278 ThreadPool* compute_tp,
|
| H A D | vfs.cc | 918 ThreadPool* const compute_tp, in init() argument
924 assert(compute_tp); in init()
926 compute_tp_ = compute_tp; in init()
|