| /oneTBB/src/tbbmalloc/ |
| H A D | shared_utils.h | 38 static inline T alignDown(T arg, uintptr_t alignment) { in alignDown() argument
39 return T( (uintptr_t)arg & ~(alignment-1)); in alignDown()
42 static inline T alignUp (T arg, uintptr_t alignment) { in alignUp() argument
43 return T(((uintptr_t)arg+(alignment-1)) & ~(alignment-1)); in alignUp()
47 static inline T alignUpGeneric(T arg, uintptr_t alignment) { in alignUpGeneric() argument
48 if (size_t rem = arg % alignment) { in alignUpGeneric()
49 arg += alignment - rem; in alignUpGeneric()
51 return arg; in alignUpGeneric()
|
| H A D | Customize.h | 55 static inline bool isAligned(T* arg, uintptr_t alignment) { in isAligned() argument
56 return tbb::detail::is_aligned(arg,alignment); in isAligned()
59 static inline bool isPowerOfTwo(uintptr_t arg) { in isPowerOfTwo() argument
60 return tbb::detail::is_power_of_two(arg); in isPowerOfTwo()
62 static inline bool isPowerOfTwoAtLeast(uintptr_t arg, uintptr_t power2) { in isPowerOfTwoAtLeast() argument
63 return arg && tbb::detail::is_power_of_two_at_least(arg,power2); in isPowerOfTwoAtLeast()
|
| /oneTBB/src/tbb/ |
| H A D | co_context.h | 113 co_context(std::size_t stack_size, void* arg) in co_context() argument
117 __TBB_ASSERT(arg != nullptr, nullptr); in co_context()
118 create_coroutine(my_coroutine, stack_size, arg); in co_context()
175 void* arg = data.second; in coroutine_thread_func() local
191 co_local_wait_for_all(arg); in coroutine_thread_func()
195 std::uintptr_t addr = std::uintptr_t(arg); in coroutine_thread_func()
207 thread_data_t data{ c, arg }; in create_coroutine()
226 c.my_condvar.wait(lock, [&arg] { return arg == nullptr; }); in create_coroutine()
280 __TBB_ASSERT(arg, nullptr); in create_coroutine()
281 c = CreateFiber(stack_size, co_local_wait_for_all, arg); in create_coroutine()
[all …]
|
| H A D | rml_thread_monitor.h | 101 …static handle_type launch( thread_routine_type thread_routine, void* arg, std::size_t stack_size, …
110 …static handle_type launch( thread_routine_type thread_routine, void* arg, std::size_t stack_size );
135 …le_type thread_monitor::launch( thread_routine_type thread_function, void* arg, std::size_t, const… in launch() argument
137 std::thread* thread_tmp=new std::thread(thread_function, arg); in launch()
141 …dle_type thread_monitor::launch( thread_routine_type thread_routine, void* arg, std::size_t stack_… in launch() argument
145 …HANDLE h = (HANDLE)_beginthreadex( nullptr, unsigned(stack_size), thread_routine, arg, STACK_SIZE_… in launch()
187 …:handle_type thread_monitor::launch( void* (*thread_routine)(void*), void* arg, std::size_t stack_… in launch() argument
208 error = pthread_create(&handle, &s, thread_routine, arg); in launch()
|
| H A D | private_server.cpp | 92 static __RML_DECL_THREAD_ROUTINE thread_routine( void* arg );
218 __RML_DECL_THREAD_ROUTINE private_worker::thread_routine( void* arg ) { in thread_routine() argument
219 private_worker* self = static_cast<private_worker*>(arg); in thread_routine()
|
| H A D | thread_data.h | 180 void set_post_resume_action(task_dispatcher::post_resume_action pra, void* arg) { in set_post_resume_action() argument
184 my_post_resume_arg = arg; in set_post_resume_action()
|
| H A D | rml_tbb.h | 68 void (*my_call_with_server_info_routine)( ::rml::server_info_callback_t cb, void* arg );
|
| /oneTBB/include/oneapi/tbb/detail/ |
| H A D | _utils.h | 160 constexpr bool is_power_of_two( IntegerType arg ) { in is_power_of_two() argument
163 return arg && (0 == (arg & (arg - 1))); in is_power_of_two()
170 constexpr bool is_power_of_two_at_least(ArgIntegerType arg, DivisorIntegerType divisor) { in is_power_of_two_at_least() argument
174 return 0 == (arg & (arg - divisor)); in is_power_of_two_at_least()
179 inline ArgIntegerType modulo_power_of_two(ArgIntegerType arg, DivisorIntegerType divisor) { in modulo_power_of_two() argument
181 return arg & (divisor - 1); in modulo_power_of_two()
|
| /oneTBB/examples/task_arena/fractal/ |
| H A D | main.cpp | 57 .arg(schedule_auto, "use-auto-partitioner", "use oneapi::tbb::auto_partitioner") in main()
58 .arg(silent, "silent", "no output except elapsed time") in main()
59 .arg(single, "single", "process only one fractal")); in main()
|
| /oneTBB/integration/linux/env/ |
| H A D | vars.sh | 150 for arg do
151 case "$arg" in
153 TBB_TARGET_ARCH="${arg}"
|
| /oneTBB/examples/graph/binpack/ |
| H A D | binpack.cpp | 273 .arg(verbose, "verbose", " print diagnostic output to screen") in main()
274 .arg(silent, "silent", " limits output to timing info; overrides verbose") in main()
275 .arg(elements_num, "elements_num", " number of values to pack") in main()
276 .arg(desired_bin_capacity, "bin_capacity", " capacity of each bin") in main()
277 .arg(num_bin_packers, in main()
281 .arg(optimality, in main()
|
| /oneTBB/python/rml/ |
| H A D | ipc_server.cpp | 71 static handle_type launch(thread_routine_type thread_routine, void* arg, size_t stack_size);
84 if( pthread_create( &handle, &s, thread_routine, arg ) ) return 0; in launch()
298 static __RML_DECL_THREAD_ROUTINE thread_routine(void* arg);
332 static __RML_DECL_THREAD_ROUTINE thread_routine(void* arg);
345 static __RML_DECL_THREAD_ROUTINE thread_routine(void* arg);
504 __RML_DECL_THREAD_ROUTINE ipc_worker::thread_routine(void* arg) { in thread_routine() argument
505 ipc_worker* self = static_cast<ipc_worker*>(arg); in thread_routine()
646 __RML_DECL_THREAD_ROUTINE ipc_waker::thread_routine(void* arg) { in thread_routine() argument
647 ipc_waker* self = static_cast<ipc_waker*>(arg); in thread_routine()
745 __RML_DECL_THREAD_ROUTINE ipc_stopper::thread_routine(void* arg) { in thread_routine() argument
[all …]
|
| /oneTBB/examples/parallel_for/tachyon/src/ |
| H A D | pthread.cpp | 58 void *arg) { in pthread_create() argument
72 CreateThread(nullptr, 0, (LPTHREAD_START_ROUTINE)start_routine, arg, 0, &th->winthread_id); in pthread_create()
|
| H A D | trace.threads.cpp | 186 static void parallel_thread(void *arg) { in parallel_thread() argument
206 pthread_exit(arg); in parallel_thread()
209 pthread_exit(arg); in parallel_thread()
|
| H A D | main.cpp | 290 .arg(nodisp, "no-display-updating", "disable run-time display updating") in ParseCommandLine()
291 .arg(nobounding, "no-bounding", "disable bounding technique") in ParseCommandLine()
292 .arg(silent_mode, "silent", "no output except elapsed time")); in ParseCommandLine()
|
| H A D | trace.threads2d.cpp | 236 static void parallel_thread(void *arg) { in parallel_thread() argument
259 pthread_exit(arg); in parallel_thread()
261 pthread_exit(arg); in parallel_thread()
|
| H A D | pthread_w.hpp | 97 void *arg);
|
| /oneTBB/examples/concurrent_priority_queue/shortpath/ |
| H A D | shortpath.cpp | 283 .arg(verbose, "verbose", " print diagnostic output to screen") in main()
284 .arg(silent, "silent", " limits output to timing info; overrides verbose") in main()
285 .arg(N, "N", " number of vertices") in main()
286 .arg(src, "start", " start of path") in main()
287 .arg(dst, "end", " end of path")); in main()
|
| /oneTBB/examples/parallel_for/seismic/ |
| H A D | main.cpp | 68 .arg(silent, "silent", "no output except elapsed time") in ParseCommandLine()
69 .arg(serial, "serial", "in GUI mode start with serial version of algorithm")); in ParseCommandLine()
|
| /oneTBB/examples/graph/fgbzip2/ |
| H A D | fgbzip2.cpp | 301 .arg(blockSizeIn100KB, "-b", "\t block size in 100KB chunks, [1 .. 9]") in main()
302 .arg(verbose, "-v", "verbose mode") in main()
303 .arg(memoryLimitIn1MB, in main()
306 .arg(asyncType, "-async", "use graph async_node-based implementation") in main()
|
| /oneTBB/examples/concurrent_hash_map/count_strings/ |
| H A D | count_strings.cpp | 256 .arg(verbose, "verbose", "verbose mode") in main()
257 .arg(silent, "silent", "no output except elapsed time") in main()
258 .arg(count_collisions, "count_collisions", "print the count of collisions")); in main()
|
| /oneTBB/python/tbb/ |
| H A D | test.py | 53 def test(arg=None): argument
54 if arg == "-v":
|
| /oneTBB/examples/parallel_reduce/convex_hull/ |
| H A D | convex_hull.hpp | 64 .arg(silent, "silent", "no output except elapsed time") in ParseInputArgs()
65 .arg(verbose, "verbose", "turns verbose ON")); in ParseInputArgs()
|
| /oneTBB/test/tbbmalloc/ |
| H A D | test_malloc_regression.cpp | 39 void RunThread(const Body& body, const Arg& arg) { in RunThread() argument
40 std::thread job(body, arg); in RunThread()
|
| /oneTBB/examples/task_group/sudoku/ |
| H A D | sudoku.cpp | 291 .arg(verbose, "verbose", "prints the first solution") in main()
292 .arg(silent, "silent", "no output except elapsed time") in main()
293 .arg(find_one, "find-one", "stops after finding first solution\n")); in main()
|