Home
last modified time | relevance | path

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

12

/oneTBB/examples/migration/recursive_fibonacci/
H A Dtask_emulation_layer.h95 F create_child(Args&&... args) { in create_child() argument
100 F create_child_and_increment(Args&&... args) { in create_child_and_increment() argument
106 F* allocate_child(Args&&... args) { in allocate_child() argument
111 F* allocate_child_and_increment(Args&&... args) { in allocate_child_and_increment() argument
151 F create_child_impl(Args&&... args) { in create_child_impl() argument
152 F obj{std::forward<Args>(args)...}; in create_child_impl()
159 F* allocate_child_impl(Args&&... args) { in allocate_child_impl() argument
160 F* obj = new F{std::forward<Args>(args)...}; in allocate_child_impl()
194 F create_root_task(tbb::task_group& tg, Args&&... args) { in create_root_task() argument
195 F obj{std::forward<Args>(args)...}; in create_root_task()
[all …]
/oneTBB/python/tbb/
H A D__init__.py104 def __exit__(self, *args): argument
147 def __exit__(self, *args): argument
283 args = parser.parse_args()
285 if args.verbose:
288 if args.allocator_huge_pages:
289 args.allocator = True
300 if args.allocator_huge_pages:
317 sys.argv = [args.name] + args.args
325 if '_' + args.name in globals():
326 return globals()['_' + args.name](*args.args)
[all …]
H A Dpool.py99 def apply(self, func, args=(), kwds=dict()): argument
102 return self.apply_async(func, args, kwds).get()
141 def apply_async(self, func, args=(), kwds=dict(), callback=None): argument
152 job = Job(func, args, kwds, apply_result)
269 def __init__(self, func, args, kwds, apply_result): argument
276 self._args = args
/oneTBB/src/tbb/
H A Dassert_impl.h82 va_list args; va_start(args, format); in runtime_warning() local
83 vsnprintf( str, 1024-1, format, args); in runtime_warning()
84 va_end(args); in runtime_warning()
H A Dmisc.cpp84 va_list args; va_start(args, format); in PrintExtraVersionInfo() local
86 std::vsnprintf( str, 1024-1, format, args); in PrintExtraVersionInfo()
87 va_end(args); in PrintExtraVersionInfo()
/oneTBB/test/tbb/
H A Dtest_collaborative_call_once.cpp60 void operator()(T first_op, Args&&... args) { in operator ()()
62 (*this)(std::forward<Args>(args)...); in operator ()()
76 void call_once_in_for_loop(std::size_t N, Fn&& body, Args&&... args) { in call_once_in_for_loop() argument
79 tbb::collaborative_call_once(flag, std::forward<Fn>(body), std::forward<Args>(args)...); in call_once_in_for_loop()
84 void call_once_in_parallel_for(std::size_t N, Fn&& body, Args&&... args) { in call_once_in_parallel_for() argument
87 auto stored_pack = tbb::detail::d0::save_pack(std::forward<Args>(args)...); in call_once_in_parallel_for()
96 tbb::collaborative_call_once(flag, std::forward<Fn>(body), std::forward<Args>(args)...); in call_once_in_parallel_for()
103 void call_once_threads(std::size_t N, Fn&& body, Args&&... args) { in call_once_threads() argument
108 auto stored_pack = tbb::detail::d0::save_pack(std::forward<Args>(args)...); in call_once_threads()
118 tbb::collaborative_call_once(flag, std::forward<Fn>(body), std::forward<Args>(args)...); in call_once_threads()
H A Dtest_parallel_for.cpp225 void run_parallel_for( Args&&... args ) const { in run_parallel_for()
227 tbb::parallel_for(std::forward<Args>(args)..., part, my_ctx); in run_parallel_for()
231 void run_overload( Args&&... args ) const { in run_overload()
235 tbb::parallel_for(std::forward<Args>(args)..., my_ctx); in run_overload()
239 run_parallel_for<tbb::simple_partitioner>(std::forward<Args>(args)...); in run_overload()
243 run_parallel_for<tbb::auto_partitioner>(std::forward<Args>(args)...); in run_overload()
247 run_parallel_for<tbb::static_partitioner>(std::forward<Args>(args)...); in run_overload()
251 run_parallel_for<tbb::affinity_partitioner>(std::forward<Args>(args)...); in run_overload()
308 concept can_call_parallel_for_basic = requires( Args&&... args ) {
309 tbb::parallel_for(std::forward<Args>(args)...);
H A Dtest_parallel_reduce.cpp131 void run_parallel_reduce( Args&&... args ) const { in run_parallel_reduce()
134 tbb::parallel_reduce(std::forward<Args>(args)..., my_ctx); in run_parallel_reduce()
138 … tbb::parallel_reduce(std::forward<Args>(args)..., tbb::simple_partitioner{}, my_ctx); in run_parallel_reduce()
142 tbb::parallel_reduce(std::forward<Args>(args)..., tbb::auto_partitioner{}, my_ctx); in run_parallel_reduce()
151 tbb::parallel_reduce(std::forward<Args>(args)..., aff, my_ctx); in run_parallel_reduce()
182 void run_parallel_deterministic_reduce( Args&&... args ) const { in run_parallel_deterministic_reduce()
185 tbb::parallel_deterministic_reduce(std::forward<Args>(args)..., my_ctx); in run_parallel_deterministic_reduce()
270 concept can_call_parallel_reduce_basic = requires( Args&&... args ) {
271 tbb::parallel_reduce(std::forward<Args>(args)...);
275 concept can_call_parallel_deterministic_reduce_basic = requires ( Args&&... args ) {
[all …]
H A Dtest_join_node_key_matching.cpp92 concept can_initialize_join_node = requires(tbb::flow::graph& g, Args... args) {
94 tbb::flow::key_matching<int>>(g, args...);
/oneTBB/include/oneapi/tbb/detail/
H A D_small_object_pool.h52 Type* new_object(execution_data& ed, Args&&... args) { in new_object() argument
55 auto constructed_object = new(allocated_object) Type(std::forward<Args>(args)...); in new_object()
60 Type* new_object(Args&&... args) { in new_object() argument
63 auto constructed_object = new(allocated_object) Type(std::forward<Args>(args)...); in new_object()
H A D_utils.h351 auto invoke(F&& f, Args&&... args) in atomic_do_once()
356 return std::invoke(std::forward<F>(f), std::forward<Args>(args)...); in atomic_do_once()
359 noexcept(noexcept(std::forward<F>(f)(std::forward<Args>(args)...))) in atomic_do_once()
360 -> decltype(std::forward<F>(f)(std::forward<Args>(args)...)) in atomic_do_once()
362 return std::forward<F>(f)(std::forward<Args>(args)...); in atomic_do_once()
/oneTBB/test/conformance/
H A Dconformance_parallel_scan.cpp64 void operator()(Args&&... args) { in operator ()()
65 oneapi::tbb::parallel_scan(std::forward<Args>(args)..., Partitioner()); in operator ()()
72 void operator()(Args&&... args) { in operator ()()
73 oneapi::tbb::parallel_scan(std::forward<Args>(args)...); in operator ()()
143 Args&&... args) { in test_pscan_invoke()
144 auto result = oneapi::tbb::parallel_scan(std::forward<Args>(args)...); in test_pscan_invoke()
/oneTBB/include/oneapi/tbb/
H A Dmemory_pool.h127 void construct(U *p, Args&&... args) in construct() argument
128 { ::new((void *)p) U(std::forward<Args>(args)...); } in construct()
204 rml::MemPoolPolicy args(allocate_request, deallocate_request, in memory_pool()
206 rml::MemPoolError res = rml::pool_create_v1(intptr_t(this), &args, &my_pool); in memory_pool()
248 rml::MemPoolPolicy args(allocate_request, nullptr, size, /*fixedPool=*/true); in fixed_pool()
249 rml::MemPoolError res = rml::pool_create_v1(intptr_t(this), &args, &my_pool); in fixed_pool()
H A Dconcurrent_queue.h196 void emplace( Args&&... args ) { in emplace() argument
197 internal_push(std::forward<Args>(args)...); in emplace()
244 void internal_push( Args&&... args ) { in internal_push() argument
246 …esentation->choose(k).push(k, *my_queue_representation, my_allocator, std::forward<Args>(args)...); in internal_push()
486 void emplace( Args&&... args ) { in emplace() argument
487 internal_push(std::forward<Args>(args)...); in emplace()
491 bool try_emplace( Args&&... args ) { in try_emplace() argument
492 return internal_push_if_not_full(std::forward<Args>(args)...); in try_emplace()
557 void internal_push( Args&&... args ) { in internal_push() argument
579 …->choose(ticket).push(ticket, *my_queue_representation, my_allocator, std::forward<Args>(args)...); in internal_push()
[all …]
H A Dcollaborative_call_once.h142 friend void collaborative_call_once(collaborative_once_flag& flag, Fn&& f, Args&&... args);
208 void collaborative_call_once(collaborative_once_flag& flag, Fn&& fn, Args&&... args) { in collaborative_call_once() argument
215 auto stored_pack = save_pack(std::forward<Args>(args)...); in collaborative_call_once()
218 auto func = [&] { fn(std::forward<Args>(args)...); }; in collaborative_call_once()
H A Dtbb_allocator.h89 void construct(U *p, Args&&... args) in construct() argument
90 { ::new (p) U(std::forward<Args>(args)...); } in construct()
H A Dconcurrent_vector.h416 iterator emplace_back( Args&&... args ) { in emplace_back() argument
417 return internal_emplace_back(std::forward<Args>(args)...); in emplace_back()
774 iterator internal_emplace_back( Args&&... args ) { in internal_emplace_back() argument
828 iterator internal_grow( size_type start_idx, size_type end_idx, const Args&... args ) { in internal_grow() argument
846 internal_loop_construct(table, start_idx, end_idx, args...); in internal_grow()
853 iterator internal_grow_by_delta( size_type delta, const Args&... args ) { in internal_grow_by_delta() argument
860 return internal_grow(start_idx, end_idx, args...); in internal_grow_by_delta()
864 iterator internal_grow_to_at_least( size_type new_size, const Args&... args ) { in internal_grow_to_at_least() argument
872 return internal_grow(old_size, new_size, args...); in internal_grow_to_at_least()
901 void internal_resize( size_type n, const Args&... args ) { in internal_resize() argument
[all …]
H A Dblocked_rangeNd.h72 blocked_rangeNd_impl(const dim_type_helper<Is>&... args) : my_dims{ {args...} } {} in __TBB_requires()
H A Dcache_aligned_allocator.h78 void construct(U *p, Args&&... args) in construct() argument
79 { ::new (p) U(std::forward<Args>(args)...); } in construct()
H A Dparallel_invoke.h206 void operator()(Fs&&... args, T&& t) {
207 parallel_invoke_impl(std::forward<T>(t), std::forward<Fs>(args)...);
H A Dscalable_allocator.h253 void construct(U *p, Args&&... args) in construct() argument
254 { ::new((void *)p) U(std::forward<Args>(args)...); } in construct()
/oneTBB/src/tbb/tools_api/
H A Dittnotify_static.c192 #define ITT_STUB(api,type,name,args,params,ptr,group,format) \ argument
193 static type api ITT_VERSIONIZE(ITT_JOIN(_N_(name),_init)) args;\
194 typedef type api ITT_JOIN(_N_(name),_t) args; \
196 static type api ITT_VERSIONIZE(ITT_JOIN(_N_(name),_init)) args \
206 #define ITT_STUBV(api,type,name,args,params,ptr,group,format) \ argument
207 static type api ITT_VERSIONIZE(ITT_JOIN(_N_(name),_init)) args;\
331 va_list args; in __itt_report_error() local
332 va_start(args, code); in __itt_report_error()
336 handler((__itt_error_code)code, args); in __itt_report_error()
339 _N_(error_handler)((__itt_error_code)code, args); in __itt_report_error()
[all …]
/oneTBB/doc/main/tbb_userguide/
H A Dappendix_B.rst59 void* OuterLoopIteration( void* args ) {
60 int i = (int)args;
/oneTBB/test/common/
H A Dtest_follows_and_precedes_api.h230 void test_follows(std::array<MessageType, 3>& messages, ConstructorArgs&&... args) {
242 NodeType node(follows(preds[0], preds[1], preds[2]), std::forward<ConstructorArgs>(args)...);
250 void test_precedes(std::vector<MessageType>& messages, ConstructorArgs&&... args) {
259 …ode(precedes(successors[0], successors[1], successors[2]), std::forward<ConstructorArgs>(args)...);
H A Dcustom_allocators.h178 void construct( U* ptr, Args&&... args ) { in construct() argument
179 base_traits::construct(*this, ptr, std::forward<Args>(args)...); in construct()
289 void construct( U* ptr, Args&&... args ) { in construct() argument
291 base_traits::construct(*this, ptr, std::forward<Args>(args)...); in construct()
425 void construct( U* ptr, Args&&... args ) { in construct() argument
426 base_traits::construct(*this, ptr, std::forward<Args>(args)...); in construct()

12