| /oneTBB/src/tbbbind/ |
| H A D | tbb_bind.cpp | 320 …__TBB_ASSERT(max_threads_per_core == -1 || max_threads_per_core > 0, "Wrong max_threads_per_core"); in fill_constraints_affinity_mask()
332 if (max_threads_per_core > 0) { in fill_constraints_affinity_mask()
343 if (++current_threads_per_core > max_threads_per_core) { in fill_constraints_affinity_mask()
369 … int get_default_concurrency(int numa_node_index, int core_type_index, int max_threads_per_core) { in get_default_concurrency() argument
373 …onstraints_affinity_mask(constraints_mask, numa_node_index, core_type_index, max_threads_per_core); in get_default_concurrency()
421 … binding_handler( std::size_t size, int numa_node_id, int core_type_id, int max_threads_per_core ) in binding_handler() argument
427 , my_max_threads_per_core(max_threads_per_core) in binding_handler()
438 (handler_affinity_mask, numa_node_id, core_type_id, max_threads_per_core); in binding_handler()
506 return new binding_handler(number_of_slots, numa_id, core_type_id, max_threads_per_core); in __TBB_internal_allocate_binding_handler()
524 …t __TBB_internal_get_default_concurrency(int numa_id, int core_type_id, int max_threads_per_core) { in __TBB_internal_get_default_concurrency() argument
[all …]
|
| /oneTBB/test/common/ |
| H A D | common_arena_constraints.h | 421 int max_threads_per_core = static_cast<int>(system_info::get_maximal_threads_per_core()); in test_constraints_affinity_and_concurrency() local
423 …if (constraints.max_threads_per_core == tbb::task_arena::automatic || constraints.max_threads_per_… in test_constraints_affinity_and_concurrency()
429 REQUIRE_MESSAGE(constraints.max_threads_per_core < max_threads_per_core, in test_constraints_affinity_and_concurrency()
442 … threads_per_current_core = std::min(threads_per_current_core, constraints.max_threads_per_core); in test_constraints_affinity_and_concurrency()
501 c1.max_threads_per_core == c2.max_threads_per_core); in operator()
534 … for (const auto& max_threads_per_core: system_info::get_available_max_threads_values()) { in generate_constraints_variety() local
537 .set_max_threads_per_core(max_threads_per_core) in generate_constraints_variety()
543 .set_max_threads_per_core(max_threads_per_core) in generate_constraints_variety()
549 .set_max_threads_per_core(max_threads_per_core) in generate_constraints_variety()
556 .set_max_threads_per_core(max_threads_per_core) in generate_constraints_variety()
[all …]
|
| /oneTBB/src/tbb/ |
| H A D | governor.cpp | 338 …_allocate_binding_handler( int slot_num, int numa_id, int core_type_id, int max_threads_per_core );
344 int __TBB_internal_get_default_concurrency( int numa_id, int core_type_id, int max_threads_per_core…
364 …ocate_binding_handler_ptr)( int slot_num, int numa_id, int core_type_id, int max_threads_per_core )
372 int (*get_default_concurrency_ptr)( int numa_id, int core_type_id, int max_threads_per_core )
494 … construct_binding_handler(int slot_num, int numa_id, int core_type_id, int max_threads_per_core) { in construct_binding_handler() argument
496 return allocate_binding_handler_ptr(slot_num, numa_id, core_type_id, max_threads_per_core); in construct_binding_handler()
551 …__TBB_ASSERT_RELEASE(c.max_threads_per_core == system_topology::automatic || c.max_threads_per_cor… in constraints_assertion()
571 if (c.numa_id >= 0 || c.core_type >= 0 || c.max_threads_per_core > 0) { in constraints_default_concurrency()
573 return get_default_concurrency_ptr(c.numa_id, c.core_type, c.max_threads_per_core); in constraints_default_concurrency()
|
| H A D | arena.cpp | 40 … d1::task_arena* ta, int num_slots, int numa_id, core_type_id core_type, int max_threads_per_core ) in numa_binding_observer() argument
42 … my_binding_handler(construct_binding_handler(num_slots, numa_id, core_type, max_threads_per_core)) in numa_binding_observer()
58 …1::task_arena* ta, int num_slots, int numa_id, core_type_id core_type, int max_threads_per_core ) { in construct_binding_observer() argument
60 …&& core_type_count() > 1) || (numa_id >= 0 && numa_node_count() > 1) || max_threads_per_core > 0) { in construct_binding_observer()
61 …binding_observer))) numa_binding_observer(ta, num_slots, numa_id, core_type, max_threads_per_core); in construct_binding_observer()
545 .set_max_threads_per_core(ta.max_threads_per_core()) in initialize()
565 …t<d1::task_arena*>(&ta), a.my_num_slots, ta.my_numa_id, ta.core_type(), ta.max_threads_per_core()); in initialize()
844 .set_max_threads_per_core(ta->max_threads_per_core()); in max_concurrency()
|
| H A D | tcm_adaptor.cpp | 179 constraints.max_threads_per_core != d1::task_arena::automatic) in init()
185 my_permit_constraints.threads_per_core = constraints.max_threads_per_core; in init()
|
| H A D | misc.h | 221 …* construct_binding_handler(int slot_num, int numa_id, int core_type_id, int max_threads_per_core);
|
| /oneTBB/include/oneapi/tbb/ |
| H A D | info.h | 57 max_threads_per_core = threads_number; in set_max_threads_per_core()
64 int max_threads_per_core = -1; member
|
| H A D | task_arena.h | 161 int max_threads_per_core() const { in max_threads_per_core() function
192 , my_max_threads_per_core(constraints_.max_threads_per_core) in task_arena_base()
335 my_max_threads_per_core = constraints_.max_threads_per_core;
|
| /oneTBB/test/tbb/ |
| H A D | test_arena_constraints.cpp | 41 c.max_threads_per_core != tbb::task_arena::automatic; in is_observer_created()
174 constraints assignment_c{}; assignment_c.max_threads_per_core = 1;
|
| /oneTBB/doc/main/tbb_userguide/ |
| H A D | Guiding_Task_Scheduler_Execution.rst | 86 assign the desired value to the ``task_arena::constraints::max_threads_per_core`` field.
|