Home
last modified time | relevance | path

Searched refs:__TBB_ASSERT (Results 1 – 25 of 102) sorted by relevance

12345

/oneTBB/src/tbb/
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()
128 __TBB_ASSERT(&target != this, "We cannot resume to ourself"); in resume()
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()
[all …]
H A Dobserver_proxy.cpp105 __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()
140 __TBB_ASSERT(r || !p->my_ref_count, nullptr); in remove_ref()
191 __TBB_ASSERT(!prev || p != prev, nullptr); in do_notify_entry_observers()
247 __TBB_ASSERT(!prev || p != prev, nullptr); in do_notify_exit_observers()
274 __TBB_ASSERT(td && td->my_arena, nullptr); in observe()
[all …]
H A Darena_slot.h124 __TBB_ASSERT( my_task_pool_size, nullptr); in free_task_pool()
142 __TBB_ASSERT(!my_is_occupied.load(std::memory_order_relaxed), nullptr); in occupy()
153 __TBB_ASSERT(my_is_occupied.load(std::memory_order_relaxed), nullptr); in release()
160 __TBB_ASSERT(is_poisoned(task_pool_ptr[T]), nullptr); in spawn()
182 __TBB_ASSERT(my_default_task_dispatcher != nullptr, nullptr); in default_task_dispatcher()
222 __TBB_ASSERT( !task_pool_ptr, nullptr); in prepare_task_pool()
230 __TBB_ASSERT( my_task_pool_size >= min_task_pool_size, nullptr); in prepare_task_pool()
345 __TBB_ASSERT(victim_task_pool == EmptyTaskPool || in lock_task_pool()
355 __TBB_ASSERT(victim_task_pool != LockedTaskPool, nullptr); in unlock_task_pool()
366 __TBB_ASSERT(is_local_task_pool_quiescent(), "Task pool is not quiescent"); in is_quiescent_local_task_pool_empty()
[all …]
H A Darena_slot.cpp62 __TBB_ASSERT(is_task_pool_published(), nullptr); in get_task()
71 __TBB_ASSERT( !result, nullptr ); in get_task()
105 __TBB_ASSERT( T0 == T+1, nullptr ); in get_task()
118 __TBB_ASSERT( H0 == T, nullptr ); in get_task()
121 __TBB_ASSERT( H0 <= T0, nullptr ); in get_task()
133 __TBB_ASSERT( is_task_pool_published(), nullptr ); in get_task()
134 __TBB_ASSERT( result, nullptr ); in get_task()
165 __TBB_ASSERT( !result, nullptr ); in steal_task()
169 __TBB_ASSERT( !is_poisoned( result ), nullptr ); in steal_task()
187 __TBB_ASSERT( H0 == H-1, nullptr ); in steal_task()
[all …]
H A Darena.cpp190 __TBB_ASSERT( is_alive(my_guard), nullptr); in process()
191 __TBB_ASSERT( my_num_slots >= 1, nullptr); in process()
211 __TBB_ASSERT(task_disp.can_steal(), nullptr); in process()
238 __TBB_ASSERT(is_alive(my_guard), nullptr); in process()
302 __TBB_ASSERT( is_alive(my_guard), nullptr); in free_arena()
452 __TBB_ASSERT(num_slots > 0, NULL); in create()
479 __TBB_ASSERT( is_arena_priority_correct, in assert_arena_priority_valid()
584 __TBB_ASSERT(a->my_references > 0, nullptr); in attach()
654 __TBB_ASSERT(td.my_arena_slot, nullptr); in nested_arena_context()
742 __TBB_ASSERT(a != nullptr, nullptr); in execute()
[all …]
H A Dco_context.h117 __TBB_ASSERT(arg != nullptr, nullptr); in co_context()
137 __TBB_ASSERT(my_state == co_executing, nullptr); in resume()
146 __TBB_ASSERT(my_state == co_executing, nullptr); in resume()
187 __TBB_ASSERT(c.my_thread_data != nullptr, nullptr); in coroutine_thread_func()
198 __TBB_ASSERT(sizeof(addr) == 8 || hi == 0, nullptr); in coroutine_thread_func()
280 __TBB_ASSERT(arg, nullptr); in create_coroutine()
282 __TBB_ASSERT(c, nullptr); in create_coroutine()
288 __TBB_ASSERT(c, nullptr); in current_coroutine()
295 __TBB_ASSERT(new_coroutine, nullptr); in swap_coroutine()
297 __TBB_ASSERT(prev_coroutine, nullptr); in swap_coroutine()
[all …]
H A Dtask_stream.h57 __TBB_ASSERT( pos>=0, nullptr); in set_one_bit()
58 __TBB_ASSERT( pos<int(sizeof(population_t)*CHAR_BIT), nullptr); in set_one_bit()
63 __TBB_ASSERT( pos>=0, nullptr); in clear_one_bit()
64 __TBB_ASSERT( pos<int(sizeof(population_t)*CHAR_BIT), nullptr); in clear_one_bit()
69 __TBB_ASSERT( pos>=0, nullptr); in is_bit_set()
70 __TBB_ASSERT( pos<int(sizeof(population_t)*CHAR_BIT), nullptr); in is_bit_set()
136 __TBB_ASSERT(!queue.empty(), nullptr); in get_item()
162 __TBB_ASSERT( N <= sizeof(population_t) * CHAR_BIT, nullptr); in initialize()
186 __TBB_ASSERT( lane < N, "Incorrect lane index." ); in push()
198 __TBB_ASSERT(lane < N, "Incorrect lane index."); in pop()
[all …]
H A Dallocator.cpp135 __TBB_ASSERT(allocate_handler == &initialize_allocate_handler, nullptr); in initialize_handler_pointers()
162 __TBB_ASSERT(allocate_handler != &initialize_allocate_handler, nullptr); in initialize_allocate_handler()
169 …__TBB_ASSERT(cache_aligned_allocate_handler != &initialize_cache_aligned_allocate_handler, nullptr… in initialize_cache_aligned_allocate_handler()
183 __TBB_ASSERT(is_power_of_two(cache_line_size), "must be power of two"); in cache_aligned_allocate()
196 __TBB_ASSERT(is_aligned(result, cache_line_size), "The returned address isn't aligned"); in cache_aligned_allocate()
201 __TBB_ASSERT(cache_aligned_deallocate_handler, "Initialization has not been yet."); in cache_aligned_deallocate()
225 …__TBB_ASSERT((result - base) >= sizeof(std::uintptr_t), "Cannot store a base pointer to the header… in std_cache_aligned_allocate()
226 __TBB_ASSERT(space - (result - base) >= bytes, "Not enough space for the storage"); in std_cache_aligned_allocate()
241 …__TBB_ASSERT(reinterpret_cast<std::uintptr_t>(p) >= 0x4096, "attempt to free block not obtained fr… in std_cache_aligned_deallocate()
260 __TBB_ASSERT(deallocate_handler, "Initialization has not been yet."); in deallocate_memory()
[all …]
H A Drtm_rw_mutex.cpp41 __TBB_ASSERT(is_in_transaction(), "m_transaction_state && not speculating"); in release()
46 …__TBB_ASSERT(!s.m_mutex->write_flag.load(std::memory_order_relaxed), "write_flag set but read lock… in release()
51 …__TBB_ASSERT(s.m_mutex->write_flag.load(std::memory_order_relaxed), "write_flag unset but write lo… in release()
57 __TBB_ASSERT(false, "rtm_not_in_mutex, but in release"); in release()
60 __TBB_ASSERT(false, "invalid m_transaction_state"); in release()
97 …__TBB_ASSERT(!m.write_flag.load(std::memory_order_relaxed), "After acquire for write, write_flag a… in acquire_writer()
174 __TBB_ASSERT(false, "Invalid state for upgrade"); in upgrade()
184 …__TBB_ASSERT(s.m_mutex->write_flag.load(std::memory_order_relaxed), "Before downgrade write_flag n… in downgrade()
192 __TBB_ASSERT(false, "Invalid state for downgrade"); in downgrade()
207 … __TBB_ASSERT(s.m_transaction_state == d1::rtm_rw_mutex::rtm_type::rtm_not_in_mutex, nullptr); in try_acquire_writer()
[all …]
H A Dtask_group_context.cpp55 __TBB_ASSERT(!is_poisoned(ctx.my_context_list), nullptr); in destroy()
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()
116 __TBB_ASSERT(!ctx.my_parent, "Parent is set before initial binding"); in bind_to_impl()
119 __TBB_ASSERT(ctx.my_parent, nullptr); in bind_to_impl()
201 __TBB_ASSERT(!is_poisoned(ctx.my_context_list), nullptr); in propagate_task_group_state()
227 __TBB_ASSERT(!is_poisoned(ctx.my_context_list), nullptr); in cancel_group_execution()
245 __TBB_ASSERT(!is_poisoned(ctx.my_context_list), nullptr); in reset()
260 __TBB_ASSERT(!is_poisoned(ctx.my_context_list), nullptr); in capture_fp_settings()
[all …]
H A Dtask_dispatcher.h51 __TBB_ASSERT(sp->m_resume_task.m_target.m_thread_data == nullptr, nullptr); in get_self_recall_task()
120 __TBB_ASSERT(m_stealing_threshold != 0, nullptr); in can_steal()
175 __TBB_ASSERT(governor::is_thread_data_set(&tls), nullptr); in receive_or_steal_task()
196 __TBB_ASSERT(t == nullptr, nullptr); in receive_or_steal_task()
200 __TBB_ASSERT(t == nullptr, nullptr); in receive_or_steal_task()
235 __TBB_ASSERT(is_alive(a.my_guard), nullptr); in receive_or_steal_task()
245 __TBB_ASSERT(m_thread_data->my_task_dispatcher == this, nullptr); in local_wait_for_all()
338 __TBB_ASSERT(m_thread_data->my_arena_slot != nullptr, nullptr); in local_wait_for_all()
367 __TBB_ASSERT(t == nullptr, nullptr); in local_wait_for_all()
382 __TBB_ASSERT(m_suspend_point != nullptr, nullptr); in recall_point()
[all …]
H A Dtcm_adaptor.cpp104 __TBB_ASSERT(tcm_release_permit, nullptr); in ~tcm_client()
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()
175 __TBB_ASSERT(tcm_deactivate_permit, nullptr); in init()
196 __TBB_ASSERT(tcm_register_thread, nullptr); in register_thread()
202 __TBB_ASSERT(tcm_unregister_thread, nullptr); in unregister_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()
[all …]
H A Dmailbox.h67 __TBB_ASSERT( tat == from_bit || (is_shared(tat) && task_ptr(tat)), in extract_task()
81 …__TBB_ASSERT( task_and_tag.load(std::memory_order_relaxed) == from_bit, "Empty proxy cannot contai… in extract_task()
141 __TBB_ASSERT( !curr->next_in_mailbox.load(std::memory_order_relaxed), nullptr); in internal_pop()
180 __TBB_ASSERT( sizeof(*this)==max_nfs_size, nullptr ); in construct()
181 __TBB_ASSERT( !my_first.load(std::memory_order_relaxed), nullptr ); in construct()
182 __TBB_ASSERT( !my_last.load(std::memory_order_relaxed), nullptr ); in construct()
183 __TBB_ASSERT( !my_is_idle.load(std::memory_order_relaxed), nullptr ); in construct()
217 __TBB_ASSERT(my_putter,"not attached"); in detach()
232 …__TBB_ASSERT( my_putter->my_is_idle.load(std::memory_order_relaxed) || value, "attempt to redundan… in set_is_idle()
H A Dthread_dispatcher.cpp30 __TBB_ASSERT( my_server, "Failed to create RML server" ); in thread_dispatcher()
63 __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()
143 __TBB_ASSERT(it != clients[curr_priority_level].end(), nullptr); in client_in_need()
208 __TBB_ASSERT(index > 0, nullptr); in create_one_job()
212 __TBB_ASSERT(index <= my_num_workers_hard_limit, nullptr); in create_one_job()
H A Dqueuing_rw_mutex.cpp160 __TBB_ASSERT( !s.my_mutex, "scoped_lock is already holding a mutex"); in acquire()
182 __TBB_ASSERT( !predecessor->my_next, "the predecessor has another successor!"); in acquire()
214 … __TBB_ASSERT( !( tricky_pointer(predecessor) & FLAG ), "use of corrupted pointer!" ); in acquire()
256 __TBB_ASSERT( !s.my_mutex, "scoped_lock is already holding a mutex"); in try_acquire()
282 __TBB_ASSERT(s.my_mutex!=nullptr, "no lock acquired"); in release()
437 __TBB_ASSERT( next, "still no successor at this point!" ); in downgrade_to_reader()
471 … __TBB_ASSERT( !(s.my_next.load(std::memory_order_relaxed) & FLAG), "use of corrupted pointer!" ); in upgrade_to_writer()
501 __TBB_ASSERT( n_state & (STATE_WRITER | STATE_UPGRADE_WAITING), "unexpected state"); in upgrade_to_writer()
519 … __TBB_ASSERT( s.my_state & STATE_COMBINED_UPGRADING, "wrong state at upgrade waiting_retry" ); in upgrade_to_writer()
520 __TBB_ASSERT( me==&s, nullptr ); in upgrade_to_writer()
[all …]
H A Dgovernor.cpp100 __TBB_ASSERT( UsePrivateRML, nullptr); in create_rml_server()
103 __TBB_ASSERT( server, "Failed to create RML server" ); in create_rml_server()
157 __TBB_ASSERT( &stack_limit > stack_limit, "stack size must be positive" ); in get_stack_base()
199 __TBB_ASSERT(td.my_inbox.is_idle_state(false), nullptr); in init_external_thread()
217 __TBB_ASSERT(get_thread_data_if_initialized() == nullptr || in auto_terminate()
258 __TBB_ASSERT(get_thread_data_if_initialized() == nullptr, nullptr); in auto_terminate()
287 __TBB_ASSERT(task_disp, nullptr); in finalize_impl()
505 __TBB_ASSERT(slot_index >= 0, "Negative thread index"); in apply_affinity_mask()
506 __TBB_ASSERT(apply_affinity_ptr, "tbbbind loading was not performed"); in apply_affinity_mask()
511 __TBB_ASSERT(slot_index >= 0, "Negative thread index"); in restore_affinity_mask()
[all …]
H A Dmarket.cpp62 __TBB_ASSERT(it != clients.end(), "Destroying of an unregistered client"); in unregister_and_destroy_client()
74 __TBB_ASSERT(max_workers >= 0, nullptr); in update_allotment()
97 __TBB_ASSERT(max_workers == 0 || max_workers == 1, nullptr); in update_allotment()
103 __TBB_ASSERT(allotted <= client.max_workers(), nullptr); in update_allotment()
110 __TBB_ASSERT(assigned == max_workers, nullptr); in update_allotment()
122 __TBB_ASSERT(-1 <= mandatory_delta && mandatory_delta <= 1, nullptr); in adjust_demand()
H A Drtm_mutex.cpp40 __TBB_ASSERT(is_in_transaction(), "m_transaction_state && not speculating"); in release()
49 __TBB_ASSERT(false, "mutex is not locked, but in release"); in release()
52 __TBB_ASSERT(false, "invalid m_transaction_state"); in release()
59 …__TBB_ASSERT(s.m_transaction_state == d1::rtm_mutex::rtm_state::rtm_none, "scoped_lock already in … in acquire()
97 __TBB_ASSERT(s.m_transaction_state == d1::rtm_mutex::rtm_state::rtm_none, nullptr); in try_acquire()
/oneTBB/include/oneapi/tbb/detail/
H A D_flow_graph_item_buffer_impl.h71 __TBB_ASSERT(my_item_valid(i),"attempt to get invalid item"); in get_my_item()
87 __TBB_ASSERT(my_item_valid(i), "Trying to fetch an empty slot"); in fetch_item()
96 __TBB_ASSERT(!my_item_valid(to), "Trying to move to a non-empty slot"); in move_item()
97 __TBB_ASSERT(my_item_valid(from), "Trying to move from an empty slot"); in move_item()
114 __TBB_ASSERT(my_item_valid(i) && my_item_valid(j), "attempt to swap invalid item(s)"); in swap_items()
121 __TBB_ASSERT(my_item_valid(i), "destruction of invalid item"); in destroy_item()
129 __TBB_ASSERT(my_item_valid(my_head), "attempt to fetch head non-item"); in front()
136 __TBB_ASSERT(my_item_valid(my_tail - 1), "attempt to fetch head non-item"); in back()
158 __TBB_ASSERT(capacity() >= my_tail - my_head, "total items exceed capacity"); in grow_my_array()
265 __TBB_ASSERT(my_reserved, "Attempt to consume a non-reserved item"); in consume_front()
[all …]
H A D_scoped_lock.h45 __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()
63 __TBB_ASSERT(m_mutex, "release on Mutex::unique_scoped_lock that is not holding a lock"); 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()
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()
H A D_rtm_rw_mutex.h146 __TBB_ASSERT(!m_mutex, "lock is already acquired"); in acquire()
156 __TBB_ASSERT(!m_mutex, "lock is already acquired"); in try_acquire()
166 __TBB_ASSERT(m_mutex, "lock is not acquired"); in release()
167 __TBB_ASSERT(m_transaction_state != rtm_type::rtm_not_in_mutex, "lock is not acquired"); in release()
174 __TBB_ASSERT(m_mutex, "lock is not acquired"); in upgrade_to_writer()
183 __TBB_ASSERT(m_mutex, "lock is not acquired"); in downgrade_to_reader()
191 __TBB_ASSERT(m_mutex, "lock is not acquired"); in is_writer()
/oneTBB/src/tbbbind/
H A Dtbb_bind.cpp164 __TBB_ASSERT(max_numa_index >= 0, "Maximal NUMA index must not be negative"); in numa_topology_parsing()
274 __TBB_ASSERT(instance_ptr != nullptr, "Getting instance of non-constructed topology"); in instance()
279 __TBB_ASSERT(instance_ptr != nullptr, "Destroying non-constructed topology"); in destroy()
393 __TBB_ASSERT(!hwloc_bitmap_iszero(current_mask), in store_current_affinity_mask()
453 __TBB_ASSERT(slot_num < affinity_backup.size(), in apply_affinity()
455 __TBB_ASSERT(topology.is_topology_parsed(), in apply_affinity()
483 __TBB_ASSERT(topology.is_topology_parsed(), in restore_previous_affinity_mask()
505 __TBB_ASSERT(number_of_slots > 0, "Trying to create numa handler for 0 threads."); in __TBB_internal_allocate_binding_handler()
510 __TBB_ASSERT(handler_ptr != nullptr, "Trying to deallocate nullptr pointer."); in __TBB_internal_deallocate_binding_handler()
515 __TBB_ASSERT(handler_ptr != nullptr, "Trying to get access to uninitialized metadata."); in __TBB_internal_apply_affinity()
[all …]
/oneTBB/include/oneapi/tbb/
H A Dblocked_range.h58 __TBB_ASSERT( my_grainsize>0, "grainsize must be positive" ); in __TBB_requires()
70 __TBB_ASSERT( !(end()<begin()), "size() unspecified if end()<begin()" ); in __TBB_requires()
97 …__TBB_ASSERT( !(my_begin < r.my_end) && !(r.my_end < my_begin), "blocked_range has been split inco… in __TBB_requires()
109 …__TBB_ASSERT( !(my_begin < r.my_end) && !(r.my_end < my_begin), "blocked_range has been split inco… in __TBB_requires()
121 __TBB_ASSERT( r.is_divisible(), "cannot split blocked_range that is not divisible" ); in __TBB_requires()
129 __TBB_ASSERT( r.is_divisible(), "cannot split blocked_range that is not divisible" ); in __TBB_requires()
H A Drw_mutex.h40 __TBB_ASSERT(!m_state.load(std::memory_order_relaxed), "destruction of an acquired mutex"); in ~rw_mutex()
107 …__TBB_ASSERT(m_state.load(std::memory_order_relaxed) & READERS, "invalid state of a read lock: no … in lock_shared()
130 …__TBB_ASSERT(m_state.load(std::memory_order_relaxed) & READERS, "invalid state of a read lock: no … in unlock_shared()
152 __TBB_ASSERT(s & READERS, "invalid state before upgrade: no readers "); in upgrade()
163 …__TBB_ASSERT((m_state.load(std::memory_order_relaxed) & (WRITER_PENDING|WRITER)) == (WRITER_PENDIN… in upgrade()
178 __TBB_ASSERT(m_state.load(std::memory_order_relaxed) & WRITER, nullptr), in downgrade()
186 …__TBB_ASSERT(m_state.load(std::memory_order_relaxed) & READERS, "invalid state after downgrade: no… in downgrade()
/oneTBB/python/rml/
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()
134 __TBB_ASSERT(sem_name[len] == 0, 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()
168 __TBB_ASSERT(templ[plen] == 0, nullptr); in set_sem_name()
525 __TBB_ASSERT( s!=st_quit, nullptr ); in start_shutdown()
623 __TBB_ASSERT( s==st_quit, nullptr ); in wake_or_launch()
[all …]

12345