Home
last modified time | relevance | path

Searched refs:nullptr (Results 1 – 25 of 253) sorted by relevance

1234567891011

/oneTBB/src/tbb/
H A Dtcm_adaptor.cpp58 tcm_result_t(*tcm_unregister_thread)(){nullptr};
127 __TBB_ASSERT(tcm_get_permit_data, nullptr); in actualize_permit()
151 __TBB_ASSERT(tcm_request_permit, nullptr); in request_permit()
174 __TBB_ASSERT(tcm_request_permit, nullptr); in init()
196 __TBB_ASSERT(tcm_register_thread, nullptr); in register_thread()
233 __TBB_ASSERT(client_ptr, nullptr); in renegotiation_callback()
248 __TBB_ASSERT(tcm_get_version_info, nullptr); in print_version()
256 __TBB_ASSERT(tcm_connect, nullptr); in tcm_adaptor()
266 __TBB_ASSERT(tcm_disconnect, nullptr); in ~tcm_adaptor()
269 my_impl = nullptr; in ~tcm_adaptor()
[all …]
H A Dco_context.h117 __TBB_ASSERT(arg != nullptr, nullptr); in co_context()
178 __TBB_ASSERT(c.my_thread_data == nullptr, nullptr); in coroutine_thread_func()
182 data.second = nullptr; in coroutine_thread_func()
187 __TBB_ASSERT(c.my_thread_data != nullptr, nullptr); in coroutine_thread_func()
202 return nullptr; in coroutine_thread_func()
259 __TBB_ASSERT(governor::get_thread_data() != nullptr, nullptr); in swap_coroutine()
280 __TBB_ASSERT(arg, nullptr); in create_coroutine()
282 __TBB_ASSERT(c, nullptr); in create_coroutine()
288 __TBB_ASSERT(c, nullptr); in current_coroutine()
302 __TBB_ASSERT(c, nullptr); in destroy_coroutine()
[all …]
H A Dobserver_proxy.cpp36 : my_ref_count(1), my_list(nullptr), my_next(nullptr), my_prev(nullptr), my_observer(&tso) in observer_proxy()
87 …_head.load(std::memory_order_relaxed) == nullptr && my_tail.load(std::memory_order_relaxed) == nul… in clear()
105 __TBB_ASSERT(!p->my_next, nullptr); in remove()
108 __TBB_ASSERT(p->my_next, nullptr); in remove()
112 __TBB_ASSERT(!p->my_prev, nullptr); in remove()
115 __TBB_ASSERT(p->my_prev, nullptr); in remove()
124 __TBB_ASSERT(is_alive(r), nullptr); in remove_ref()
130 __TBB_ASSERT(r == 1, nullptr); in remove_ref()
209 observer_proxy* p = nullptr, * prev = nullptr; in do_notify_exit_observers()
283 __TBB_ASSERT(a != nullptr, nullptr); in observe()
[all …]
H A Dtask.cpp96 __TBB_ASSERT(m_thread_data != nullptr, nullptr); in internal_suspend()
99 __TBB_ASSERT(slot != nullptr, nullptr); in internal_suspend()
114 __TBB_ASSERT(suspend_callback != nullptr, nullptr); in suspend()
115 __TBB_ASSERT(user_callback != nullptr, nullptr); in suspend()
118 __TBB_ASSERT(m_thread_data != nullptr, nullptr); in suspend()
120 __TBB_ASSERT(m_thread_data->my_post_resume_arg == nullptr, nullptr); in suspend()
136 __TBB_ASSERT(m_suspend_point != nullptr, "Suspend point must be created"); in resume()
137 __TBB_ASSERT(target.m_suspend_point != nullptr, "Suspend point must be created"); in resume()
150 __TBB_ASSERT(slot != nullptr, nullptr); in resume()
152 __TBB_ASSERT(m_suspend_point != nullptr, nullptr); in resume()
[all …]
H A Darena_slot.cpp36 return nullptr; in get_task_impl()
43 return nullptr; in get_task_impl()
56 task_pool_ptr[T] = nullptr; in get_task_impl()
58 return nullptr; in get_task_impl()
67 d1::task* result = nullptr; in get_task()
135 task_pool_ptr[T] = nullptr; in get_task()
151 return nullptr; in steal_task()
153 d1::task* result = nullptr; in steal_task()
183 result = nullptr; in steal_task()
192 __TBB_ASSERT( result, nullptr ); in steal_task()
[all …]
H A Dtask_dispatcher.h46 d1::task* t = nullptr; in get_self_recall_task()
91 return nullptr; in execute()
129 return nullptr; in get_inbox_or_critical_task()
151 return nullptr; in get_stream_or_critical_task()
167 return nullptr; in steal_or_get_critical()
196 __TBB_ASSERT(t == nullptr, nullptr); in receive_or_steal_task()
200 __TBB_ASSERT(t == nullptr, nullptr); in receive_or_steal_task()
367 __TBB_ASSERT(t == nullptr, nullptr); in local_wait_for_all()
376 return nullptr; in local_wait_for_all()
382 __TBB_ASSERT(m_suspend_point != nullptr, nullptr); in recall_point()
[all …]
H A Dmailbox.h82 return nullptr; in extract_task()
86 __TBB_ASSERT_RELEASE(false, nullptr); in execute()
87 return nullptr; in execute()
90 __TBB_ASSERT_RELEASE(false, nullptr); in cancel()
91 return nullptr; in cancel()
118 return nullptr; in internal_pop()
126 return nullptr; in internal_pop()
137 prev_ptr->store(nullptr, std::memory_order_relaxed); in internal_pop()
180 __TBB_ASSERT( sizeof(*this)==max_nfs_size, nullptr ); in construct()
209 mail_inbox() : my_putter(nullptr) {} in mail_inbox()
[all …]
H A Dsemaphore.h101 int r = ::syscall(SYS_futex, futex, __TBB_FUTEX_WAIT, comparand, nullptr, nullptr, 0); in futex_wait()
110 int r = ::syscall(SYS_futex, futex, __TBB_FUTEX_WAKE, 1, nullptr, nullptr, 0); in futex_wakeup_one()
138 void V() {ReleaseSemaphore( sem, 1, nullptr);} in V()
142 …sem = CreateSemaphoreEx( nullptr, LONG(start_cnt_), max_semaphore_cnt, nullptr, 0, SEMAPHORE_ALL_A… in init_semaphore()
174 __TBB_ASSERT_EX( !ret, nullptr); in ~semaphore()
179 __TBB_ASSERT( errno==EINTR, nullptr); in P()
187 __TBB_ASSERT_EX( !ret, nullptr); in init_semaphore()
200 binary_semaphore() { my_sem = CreateEventEx( nullptr, nullptr, 0, EVENT_ALL_ACCESS ); } in binary_semaphore()
275 __TBB_ASSERT_EX( !ret, nullptr); in binary_semaphore()
280 __TBB_ASSERT_EX( !ret, nullptr); in ~binary_semaphore()
[all …]
H A Dtask_group_context.cpp55 __TBB_ASSERT(!is_poisoned(ctx.my_context_list), nullptr); in destroy()
57 if (ctx.my_context_list != nullptr) { in destroy()
85 ITT_TASK_GROUP(&ctx, ctx.my_name, nullptr); in initialize()
94 ctx.my_parent = nullptr; in initialize()
95 ctx.my_context_list = nullptr; in initialize()
97 ctx.my_itt_caller = nullptr; in initialize()
106 __TBB_ASSERT(!is_poisoned(ctx.my_context_list), nullptr); in register_with()
107 __TBB_ASSERT(td, nullptr); in register_with()
114 __TBB_ASSERT(!is_poisoned(ctx.my_context_list), nullptr); in bind_to_impl()
119 __TBB_ASSERT(ctx.my_parent, nullptr); in bind_to_impl()
[all …]
H A Dthread_data.h104 , my_task_dispatcher{ nullptr }
105 , my_arena{ nullptr }
106 , my_last_client{ nullptr }
109 , my_last_observer{ nullptr }
114 , my_post_resume_arg{nullptr}
189 my_post_resume_arg = nullptr; in clear_post_resume_action()
216 __TBB_ASSERT(my_task_dispatcher == nullptr, nullptr); in attach_task_dispatcher()
217 __TBB_ASSERT(task_disp.m_thread_data == nullptr, nullptr); in attach_task_dispatcher()
223 __TBB_ASSERT(my_task_dispatcher != nullptr, nullptr); in detach_task_dispatcher()
225 my_task_dispatcher->m_thread_data = nullptr; in detach_task_dispatcher()
[all …]
H A Darena.cpp191 __TBB_ASSERT( my_num_slots >= 1, nullptr); in process()
228 tls.my_last_observer = nullptr; in process()
235 tls.my_arena_slot = nullptr; in process()
238 __TBB_ASSERT(is_alive(my_guard), nullptr); in process()
309 my_numa_binding_observer = nullptr; in free_arena()
637 td.my_last_observer = nullptr; in nested_arena_context()
716 return nullptr; in execute()
720 return nullptr; in cancel()
742 __TBB_ASSERT(a != nullptr, nullptr); in execute()
808 __TBB_ASSERT(a != nullptr, nullptr); in wait()
[all …]
H A Dtask_stream.h57 __TBB_ASSERT( pos>=0, nullptr); in set_one_bit()
63 __TBB_ASSERT( pos>=0, nullptr); in clear_one_bit()
69 __TBB_ASSERT( pos>=0, nullptr); in is_bit_set()
135 d1::task* result = nullptr; in get_item()
136 __TBB_ASSERT(!queue.empty(), nullptr); in get_item()
151 lane_t* lanes{nullptr};
194 d1::task* popped = nullptr; in pop()
206 d1::task* result = nullptr; in pop_specific()
247 return nullptr; in try_pop()
248 d1::task* result = nullptr; in try_pop()
[all …]
H A Dobserver_proxy.h38 std::atomic<observer_proxy*> my_head{nullptr};
41 std::atomic<observer_proxy*> my_tail{nullptr};
125 __TBB_ASSERT_EX( r, nullptr); in remove_ref_fast()
126 p = nullptr; in remove_ref_fast()
139 if (last == nullptr) { in notify_exit_observers()
142 __TBB_ASSERT(!is_poisoned(last), nullptr); in notify_exit_observers()
144 __TBB_ASSERT(last != nullptr, nullptr); in notify_exit_observers()
H A Dthread_dispatcher.cpp63 __TBB_ASSERT(client, nullptr); in try_unregister_client()
65 __TBB_ASSERT(!is_poisoned(my_server), nullptr); in try_unregister_client()
100 __TBB_ASSERT(client.priority_level() < num_priority_levels, nullptr); in insert_client()
103 … __TBB_ASSERT(!my_next_client || my_next_client->priority_level() < num_priority_levels, nullptr); in insert_client()
109 __TBB_ASSERT(client.priority_level() < num_priority_levels, nullptr); in remove_client()
113 my_next_client = nullptr; in remove_client()
138 return nullptr; in client_in_need()
143 __TBB_ASSERT(it != clients[curr_priority_level].end(), nullptr); in client_in_need()
156 return nullptr; in client_in_need()
208 __TBB_ASSERT(index > 0, nullptr); in create_one_job()
[all …]
H A Dparallel_pipeline.cpp43 first_filter(nullptr), in pipeline()
44 last_filter(nullptr), in pipeline()
92 void* my_object = nullptr;
101 my_object = nullptr; in reset()
157 array(nullptr), in input_buffer()
165 __TBB_ASSERT( array, nullptr ); in input_buffer()
170 __TBB_ASSERT( array, nullptr ); in ~input_buffer()
325 return nullptr; in execute()
331 return nullptr; in cancel()
337 my_object = nullptr; in ~stage_task()
[all …]
/oneTBB/examples/graph/fgbzip2/
H A Dbzlib.cpp198 if (s == nullptr) in BZ_API()
202 s->arr1 = nullptr; in BZ_API()
211 if (s->arr1 == nullptr || s->arr2 == nullptr || s->ftab == nullptr) { in BZ_API()
558 s->tt = nullptr; in BZ_API()
1088 if (bzf == nullptr || buf == nullptr || len < 0) { in BZ_API()
1305 if (bzf == nullptr || buf == nullptr || len < 0) { in BZ_API()
1377 if (unused == nullptr || nUnused == nullptr) { in BZ_API()
1403 if (dest == nullptr || destLen == nullptr || source == nullptr || blockSize100k < 1 || in BZ_API()
1451 if (dest == nullptr || destLen == nullptr || source == nullptr || (small != 0 && small != 1) || in BZ_API()
1652 BZ2_bzWriteClose(&bzerr, b, 0, nullptr, nullptr); in BZ_API()
[all …]
/oneTBB/python/rml/
H A Dipc_utils.cpp49 return nullptr; in get_stat_item()
52 return nullptr; in get_stat_item()
65 if( stat_file==nullptr ) { in get_start_time()
71 if( line==nullptr ) { in get_start_time()
76 if( starttime_str==nullptr ) { in get_start_time()
80 unsigned long long starttime = strtoull( starttime_str, nullptr, 10 ); in get_start_time()
107 if( env_var==nullptr ) { in get_num_threads()
112 if( value==nullptr ) { in get_num_threads()
116 int num_threads = (int)strtol( value, nullptr, 10 ); in get_num_threads()
121 if( env_var==nullptr ) { in get_enable_flag()
[all …]
H A Dipc_server.cpp125 __TBB_ASSERT(name != nullptr, nullptr); in get_sem_name()
126 __TBB_ASSERT(prefix != nullptr, nullptr); in get_sem_name()
132 __TBB_ASSERT(sem_name != nullptr, nullptr); in get_sem_name()
160 __TBB_ASSERT(name != nullptr, nullptr); in set_sem_name()
161 __TBB_ASSERT(prefix != nullptr, nullptr); in set_sem_name()
166 __TBB_ASSERT(templ != nullptr, nullptr); in set_sem_name()
828 my_waker(nullptr), in ipc_server()
829 my_stopper(nullptr) in ipc_server()
1104 if( my_global_server!=nullptr && my_global_client!=nullptr ) { in rml_atfork_child()
1109 pthread_atfork( nullptr, nullptr, rml_atfork_child ); in rml_atfork_child()
[all …]
/oneTBB/test/tbbmalloc/
H A Dtest_malloc_compliance.cpp63 if (nullptr == hJob) { in limitMem()
64 if (nullptr == (hJob = CreateJobObject(nullptr, nullptr))) { in limitMem()
359 char *ptr = nullptr, in InvariantDataRealloc()
452 if (nullptr != ret) in Tmalloc()
462 if (nullptr != ret) in Tcalloc()
472 if (nullptr != ret) in Trealloc()
488 if (nullptr != ret) in Taligned_malloc()
496 if (nullptr != ret) in Taligned_realloc()
531 if (nullptr!=arr[i].ptr && nullptr!=arr[i+1].ptr) in AddrArifm()
553 if (nullptr!=arr[i].ptr && nullptr!=arr[i+1].ptr) in AddrArifm()
[all …]
/oneTBB/include/oneapi/tbb/detail/
H A D_scoped_lock.h32 constexpr unique_scoped_lock() noexcept : m_mutex(nullptr) {} in unique_scoped_lock()
45 __TBB_ASSERT(m_mutex == nullptr, "The mutex is already acquired"); in acquire()
53 __TBB_ASSERT(m_mutex == nullptr, "The mutex is already acquired"); in try_acquire()
65 m_mutex = nullptr; in release()
102 __TBB_ASSERT(m_mutex == nullptr, "The mutex is already acquired");
124 __TBB_ASSERT(m_mutex != nullptr, "The mutex is not acquired"); in release()
126 m_mutex = nullptr; in release()
138 __TBB_ASSERT(m_mutex != nullptr, "The mutex is not acquired"); in upgrade_to_writer()
148 __TBB_ASSERT(m_mutex != nullptr, "The mutex is not acquired"); in downgrade_to_reader()
157 __TBB_ASSERT(m_mutex != nullptr, "The mutex is not acquired"); in is_writer()
[all …]
/oneTBB/examples/parallel_for/tachyon/src/
H A Dpthread.cpp61 if (thread == nullptr) in pthread_create()
63 *thread = nullptr; in pthread_create()
65 if (start_routine == nullptr) in pthread_create()
72 CreateThread(nullptr, 0, (LPTHREAD_START_ROUTINE)start_routine, arg, 0, &th->winthread_id); in pthread_create()
73 if (th->winthread_handle == nullptr) in pthread_create()
85 *thread_return = nullptr; in pthread_join()
87 if ((th == nullptr) || (th->winthread_handle == nullptr)) in pthread_join()
108 th = nullptr; in pthread_join()
H A Dui.cpp56 static void (*rt_static_ui_message)(int, const char *) = nullptr;
57 static void (*rt_static_ui_progress)(int) = nullptr;
58 static int (*rt_static_ui_checkaction)(void) = nullptr;
71 if (rt_static_ui_message == nullptr) { in rt_ui_message()
83 if (rt_static_ui_progress != nullptr) in rt_ui_progress()
94 if (rt_static_ui_checkaction != nullptr) in rt_ui_checkaction()
/oneTBB/include/oneapi/tbb/
H A Dparallel_scan.h113 __TBB_ASSERT( m_parent == nullptr, nullptr ); in finish_construction()
130 return nullptr; in release_parent()
190 m_left_sum(nullptr), in sum_node()
191 m_left(nullptr), in sum_node()
192 m_right(nullptr), in sum_node()
222 return nullptr; in release_parent()
253 ref_count = (left_child != nullptr) + (right_child != nullptr); in execute()
339 return nullptr; in release_parent()
380 return nullptr; in release_parent()
418 m_parent(nullptr), in start_scan()
[all …]
H A Dqueuing_mutex.h51 m_mutex = nullptr; in reset()
80 m_next.store(nullptr, std::memory_order_relaxed); in acquire()
88 …__TBB_ASSERT(pred->m_next.load(std::memory_order_relaxed) == nullptr, "the predecessor has another… in acquire()
103 m_next.store(nullptr, std::memory_order_relaxed); in try_acquire()
106 scoped_lock* expected = nullptr; in try_acquire()
126 if (m_next.load(std::memory_order_relaxed) == nullptr) { in release()
128 if (m_mutex->q_tail.compare_exchange_strong(expected, nullptr)) { in release()
134 spin_wait_while_eq(m_next, nullptr); in release()
143 queuing_mutex* m_mutex{nullptr};
146 std::atomic<scoped_lock*> m_next{nullptr};
[all …]
/oneTBB/test/tbb/
H A Dtest_tbb_fork.cpp118 ASSERT(ok, nullptr); in operator ()()
156 ASSERT(ok, nullptr); in TestTasksInThread()
187 ASSERT(ok, nullptr); in TestSchedulerMemLeaks()
218 ASSERT(ok, nullptr); in TestNestingTSI()
224 ASSERT(ok, nullptr); in TestNestingTSI()
255 if (sigaction(SIGCHLD, &sa, nullptr)) in main()
257 if (sigaction(SIGALRM, &sa, nullptr)) in main()
263 if (pthread_sigmask(SIG_BLOCK, &sig_set, nullptr)) in main()
273 ASSERT(ok, nullptr); in main()
278 ASSERT(ok, nullptr); in main()
[all …]

1234567891011