Home
last modified time | relevance | path

Searched refs:compare_exchange_strong (Results 1 – 25 of 35) sorted by relevance

12

/oneTBB/src/tbb/
H A Dqueuing_rw_mutex.cpp50 …static T* compare_exchange_strong( std::atomic<word>& obj, const T* expected, const T* desired, st… in compare_exchange_strong() function in tbb::detail::r1::tricky_atomic_pointer
52 obj.compare_exchange_strong(expd, reinterpret_cast<word>(desired), memory_order); in compare_exchange_strong()
111 return s.my_internal_lock.compare_exchange_strong(expected, ACQUIRED); in try_acquire_internal_lock()
205 …predecessor->my_state.compare_exchange_strong(pred_state, STATE_READER_UNBLOCKNEXT, std::memory_or… in acquire()
233 …s.my_state.compare_exchange_strong(old_state, STATE_ACTIVEREADER, std::memory_order_release, std::… in acquire()
273 if (!m.q_tail.compare_exchange_strong(expected, &s, std::memory_order_acq_rel)) in try_acquire()
296 if( s.my_mutex->q_tail.compare_exchange_strong(expected, nullptr, in release()
390 if( !s.my_mutex->q_tail.compare_exchange_strong(expected, nullptr, in release()
474 …if( !s.my_mutex->q_tail.compare_exchange_strong(expected, tricky_pointer(me)|FLAG, std::memory_ord… in upgrade_to_writer()
524 s.my_mutex->q_tail.compare_exchange_strong(expected, &s, std::memory_order_release); in upgrade_to_writer()
[all …]
H A Darena.h150 if (my_state.compare_exchange_strong(state, SET)) { in test_and_set()
161 return my_state.compare_exchange_strong(state, SET); in test_and_set()
168 if (state == SET && my_state.compare_exchange_strong(state, busy)) { in try_clear_if()
170 return my_state.compare_exchange_strong(busy, UNSET); in try_clear_if()
173 my_state.compare_exchange_strong(busy, SET); in try_clear_if()
H A Dprivate_server.cpp295 if (my_state.compare_exchange_strong(state, st_starting)) { in wake_or_launch()
310 if (!my_state.compare_exchange_strong(state, st_normal)) { in wake_or_launch()
363 if (my_slack.compare_exchange_strong(expected, expected + 1)) { in try_insert_in_asleep_list()
389 } while (!my_slack.compare_exchange_strong(old, old - 1)); in wake_some()
H A Dmailbox.h75 if ( task_and_tag.compare_exchange_strong(tat, cleaner_bit) ) { in extract_task()
139 if ( my_last.compare_exchange_strong( expected, prev_ptr ) ) { in internal_pop()
H A Darena_slot.h301 task_pool.compare_exchange_strong(expected, LockedTaskPool ) ) { in acquire_task_pool()
338 …if (victim_task_pool != LockedTaskPool && task_pool.compare_exchange_strong(expected, LockedTaskPo… in lock_task_pool()
H A Dtask_group_context.cpp170 … std::underlying_type<d1::task_group_context::state>::type>&)ctx.my_state).compare_exchange_strong( in bind_to()
174 ctx.my_state.compare_exchange_strong(state, d1::task_group_context::state::locked) in bind_to()
H A Dsmall_object_pool.cpp109 if (m_public_list.compare_exchange_strong(old_public_list, obj)) { in deallocate_impl()
H A Dmisc.h179 if ( dst.compare_exchange_strong(oldValue, newValue) ) in atomic_update()
H A Dsemaphore.h249 if( !my_sem.compare_exchange_strong( s, 1 ) ) { in P()
H A Dobserver_proxy.cpp126 if (p->my_ref_count.compare_exchange_strong(r, r - 1)) { in remove_ref()
/oneTBB/python/rml/
H A Dipc_server.cpp49 if( one_time_flag.compare_exchange_strong(expected, true) ) { in __RML_open_factory()
153 } while( !my_global_thread_count.compare_exchange_strong(old, old-1) ); in release_thread_sem()
526 } while( !my_state.compare_exchange_strong( s, st_quit ) ); in start_shutdown()
543 while( !my_state.compare_exchange_strong( s, st_quit ) ) {}; in start_stopping()
602 my_state.compare_exchange_strong( s, st_init ); in wake_or_launch()
618 my_state.compare_exchange_strong( s, st_normal ); in wake_or_launch()
701 my_state.compare_exchange_strong(s, st_init); in wake_or_launch()
717 my_state.compare_exchange_strong(s, st_normal); in wake_or_launch()
788 my_state.compare_exchange_strong(s, st_init); in wake_or_launch()
804 my_state.compare_exchange_strong(s, st_normal); in wake_or_launch()
[all …]
/oneTBB/test/common/
H A Dexception_handling.h70 g_ActualMaxThreads.compare_exchange_strong(q, p); in on_scheduler_entry()
150 if ( g_ExceptionsThrown.compare_exchange_strong(expected, 1) ) { in ThrowTestException()
158 if ( g_ExceptionsThrown.compare_exchange_strong(expected, 1) ) { in ThrowTestException()
177 g_ExecutedAtFirstCatch.compare_exchange_strong(expected , g_CurExecuted); \
180 …while (expected < curExecuted) g_ExecutedAtLastCatch.compare_exchange_strong(expected, curExecuted…
H A Dconcurrency_tracker.h40 ctPeakParallelism.compare_exchange_strong(q, p); in Started()
/oneTBB/include/oneapi/tbb/
H A Dspin_rw_mutex.h70 if (m_state.compare_exchange_strong(s, WRITER)) in lock()
86 if (m_state.compare_exchange_strong(s, WRITER)) { in try_lock()
154 if (m_state.compare_exchange_strong(s, s | WRITER | WRITER_PENDING)) { in upgrade()
H A Dcollaborative_call_once.h152 } while (!m_state.compare_exchange_strong(expected, desired)); in set_completion_state()
161 …if (expected == state::uninitialized && m_state.compare_exchange_strong(expected, runner.to_bits()… in do_collaborative_call_once()
182 … } while (expected > state::done && !m_state.compare_exchange_strong(expected, expected + 1)); in do_collaborative_call_once()
H A Dqueuing_mutex.h110 if (!m.q_tail.compare_exchange_strong(expected, this, std::memory_order_acq_rel)) in try_acquire()
128 if (m_mutex->q_tail.compare_exchange_strong(expected, nullptr)) { in release()
H A Drw_mutex.h77 if (m_state.compare_exchange_strong(s, WRITER)) { in try_lock()
157 if (m_state.compare_exchange_strong(s, s | WRITER | WRITER_PENDING)) { in upgrade()
H A Dconcurrent_queue.h44 } while (!queue.head_counter.compare_exchange_strong(ticket, ticket + 1)); in internal_try_pop_impl()
593 … } while (!my_queue_representation->tail_counter.compare_exchange_strong(ticket, ticket + 1)); in internal_push_if_not_full()
/oneTBB/test/tbb/
H A Dtest_scheduler_mix.cpp184 if (mState.compare_exchange_strong(expected, p)) { in trySet()
203 if (mState.compare_exchange_strong(v, v | LOCKED)) { in tryLock()
217 if (mState.compare_exchange_strong(v, v + 1)) { in tryLockShared()
226 mState.compare_exchange_strong(v, v | LOCK_PENDING); in lock()
/oneTBB/include/oneapi/tbb/detail/
H A D_aggregator.h81 } while (!pending_operations.compare_exchange_strong(res, op));
H A D_utils.h280 …if( ((std::atomic<enum_type>&)state).compare_exchange_strong( (enum_type&)expected_state, (enum_ty… in atomic_do_once()
282 if( state.compare_exchange_strong( expected_state, do_once_state::pending ) ) { in atomic_do_once()
H A D_segment_table.h180 …if (!table[seg_index].compare_exchange_strong(disabled_segment, new_segment - segment_base(seg_ind… in enable_segment()
533 this->my_first_block.compare_exchange_strong(zero, index); in assign_first_block_if_necessary()
H A D_concurrent_unordered_base.h155 return my_next.compare_exchange_strong(expected_next, new_next); in try_set_next()
672 …my_bucket_count.compare_exchange_strong(current_bucket_count, round_up_to_power_of_two(bucket_coun… in rehash()
687 … while (!my_bucket_count.compare_exchange_strong(current_bucket_count, necessary_bucket_count)) { in reserve()
1043 my_bucket_count.compare_exchange_strong(current_size, 2u * current_size); in adjust_table_size()
1097 my_segments[0].compare_exchange_strong(disabled, &my_head); in init_bucket()
H A D_concurrent_skip_list.h974 if (!prev->atomic_next(0).compare_exchange_strong(next, new_node)) { in internal_insert_node()
984 … if (new_height <= max_height || my_max_height.compare_exchange_strong(max_height, new_height)) { in internal_insert_node()
999 if (prev->atomic_next(level).compare_exchange_strong(next, new_node)) { in internal_insert_node()
1148 if (my_head_ptr.compare_exchange_strong(current_head, new_head)) { in create_head_if_necessary()
/oneTBB/src/tbbmalloc/
H A Dbackend.h76 if (active.compare_exchange_strong(prevCnt, prevCnt + 1)) { in wait()

12