Home
last modified time | relevance | path

Searched refs:fetch_add (Results 1 – 22 of 22) sorted by relevance

/oneTBB/test/common/
H A Dspin_barrier.h136 …int threadsLeft = static_cast<int>(myNumThreads - myNumThreadsFinished.fetch_add(1, std::memory_or… in customWait()
150 myLifeTimeGuard.fetch_add(myNumThreads - 1, std::memory_order_relaxed); in customWait()
151 epoch -= myEpoch.fetch_add(1, std::memory_order_release); in customWait()
H A Ddoctest.h3505 T operator++() DOCTEST_NOEXCEPT { return fetch_add(1) + 1; }
3507 T operator++(int) DOCTEST_NOEXCEPT { return fetch_add(1); }
3509 T fetch_add(T arg, std::memory_order order = std::memory_order_seq_cst) DOCTEST_NOEXCEPT {
3510 return myAtomic().fetch_add(arg, order);
/oneTBB/src/tbb/
H A Dthread_request_serializer.cpp33 int prev_pending_delta = my_pending_delta.fetch_add(counter_value + delta); in update()
85 int prev_value = my_num_mandatory_requests.fetch_add(mandatory_delta); in register_mandatory_request()
H A Dqueuing_rw_mutex.cpp42 … static T* fetch_add( std::atomic<word>& location, word addend, std::memory_order memory_order ) { in fetch_add() function in tbb::detail::r1::tricky_atomic_pointer
43 return reinterpret_cast<T*>(location.fetch_add(addend, memory_order)); in fetch_add()
342 …queuing_rw_mutex::scoped_lock *predecessor = tricky_pointer::fetch_add(s.my_prev, FLAG, std::memor… in release()
477 next = tricky_pointer::fetch_add(s.my_next, FLAG, std::memory_order_acquire); in upgrade_to_writer()
527 predecessor = tricky_pointer::fetch_add(s.my_prev, FLAG, std::memory_order_acquire); in upgrade_to_writer()
H A Dparallel_pipeline.cpp400 … std::size_t ntokens_avail = my_pipeline.input_tokens.fetch_add(1, std::memory_order_acquire); in execute_filter()
/oneTBB/include/oneapi/tbb/
H A Dspin_rw_mutex.h106 state_type prev_state = m_state.fetch_add(ONE_READER); in lock_shared()
123 state_type prev_state = m_state.fetch_add(ONE_READER); in try_lock_shared()
H A Drw_mutex.h117 if (m_state.fetch_add(ONE_READER) & has_writer) { in try_lock_shared()
H A Dparallel_invoke.h107 ref_count.fetch_add(3, std::memory_order_relaxed); in execute()
H A Dparallel_scan.h200 m_parent->ref_count.fetch_add(1); in sum_node()
H A Dconcurrent_vector.h857 size_type start_idx = this->my_size.fetch_add(delta); in internal_grow_by_delta()
H A Dconcurrent_hash_map.h1503 this->my_size.fetch_add(1, std::memory_order_relaxed); in __TBB_requires()
/oneTBB/test/tbb/
H A Dtest_mutex.h160 while( (step = Order.fetch_add(chunk, std::memory_order_acquire)) < TestSize ) { in operator()
H A Dtest_scheduler_mix.cpp331 if (obj->mReferences.fetch_add(REFERENCE_FLAG) & SHUTDOWN_FLAG) { in Guard()
362 mReferences.fetch_add(SHUTDOWN_FLAG); in signalShutdown()
H A Dtest_sequencer_node.cpp170 while ( (i_start = my_counter.fetch_add(C)) < N ) { in operator ()()
H A Dtest_task.cpp310 std::size_t start_idx = my_current_task.fetch_add(delta); in operator ()()
/oneTBB/include/oneapi/tbb/detail/
H A D_concurrent_queue_base.h157 tail_counter.fetch_add(queue_rep_type::n_queue); in push()
166 tail_counter.fetch_add(queue_rep_type::n_queue); in push()
173 tail_counter.fetch_add(queue_rep_type::n_queue); in abort_push()
H A D_task.h106 …std::uint64_t r = m_ref_count.fetch_add(static_cast<std::uint64_t>(delta)) + static_cast<std::uint… in add_reference()
H A D_pipeline_filters.h356 void add_ref() { ref_count.fetch_add(1, std::memory_order_relaxed); }
H A D_concurrent_unordered_base.h1012 auto sz = my_size.fetch_add(1); in internal_insert()
/oneTBB/src/tbbmalloc/
H A Dlarge_objects.cpp896 return (cacheCurrTime.fetch_add(range) + 1); in getCurrTimeRange()
984 memAllocKB.fetch_add(allocationSize/1024); in mallocLargeObject()
1005 memHitKB.fetch_add(allocationSize/1024); in mallocLargeObject()
H A Dbackend.cpp128 totalMemSize.fetch_add(size); in allocRawMem()
1029 totalMemSize.fetch_add(region->allocSz - oldRegionSize); in remap()
1416 backendCleanCnt.fetch_add(1, std::memory_order_acq_rel); in clean()
1427 backendCleanCnt.fetch_add(1, std::memory_order_acq_rel); in clean()
H A Dfrontend.cpp1983 if (flag.fetch_add(skipDtor) != 0) { in processExit()