Home
last modified time | relevance | path

Searched refs:m_mutex (Results 1 – 10 of 10) sorted by relevance

/oneTBB/include/oneapi/tbb/detail/
H A D_scoped_lock.h28 Mutex* m_mutex{};
46 m_mutex = &m; in acquire()
56 m_mutex = &m; in try_acquire()
64 m_mutex->unlock(); in release()
65 m_mutex = nullptr; in release()
70 if (m_mutex) { in ~unique_scoped_lock()
91 if (m_mutex) { in ~rw_scoped_lock()
104 m_mutex = &m;
116 m_mutex = &m;
125 Mutex* m = m_mutex; in release()
[all …]
H A D_rtm_rw_mutex.h69 … constexpr scoped_lock() : m_mutex(nullptr), m_transaction_state(rtm_type::rtm_not_in_mutex) {} in alignas()
72 …scoped_lock(rtm_rw_mutex& m, bool write = true) : m_mutex(nullptr), m_transaction_state(rtm_type::… in alignas()
105 rtm_rw_mutex* m_mutex; in alignas()
146 __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()
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()
H A D_rtm_mutex.h66 constexpr scoped_lock() : m_mutex(nullptr), m_transaction_state(rtm_state::rtm_none) {} in alignas()
69 scoped_lock(rtm_mutex& m) : m_mutex(nullptr), m_transaction_state(rtm_state::rtm_none) { in alignas()
94 rtm_mutex* m_mutex; in alignas()
121 __TBB_ASSERT(!m_mutex, "lock is already acquired"); in acquire()
127 __TBB_ASSERT(!m_mutex, "lock is already acquired"); in try_acquire()
133 __TBB_ASSERT(m_mutex, "lock is not acquired"); in release()
/oneTBB/src/tbb/
H A Drtm_rw_mutex.cpp43 s.m_mutex = nullptr; in release()
48 s.m_mutex = nullptr; in release()
53 s.m_mutex->unlock(); in release()
54 s.m_mutex = nullptr; in release()
87 s.m_mutex = &m; in acquire_writer()
127 s.m_mutex = &m; in acquire_reader()
144 s.m_mutex = &m; in acquire_reader()
145 s.m_mutex->lock_shared(); in acquire_reader()
186 s.m_mutex->downgrade(); in downgrade()
210 s.m_mutex = &m; in try_acquire_writer()
[all …]
H A Drtm_mutex.cpp42 s.m_mutex = nullptr; in release()
45 s.m_mutex->unlock(); in release()
46 s.m_mutex = nullptr; in release()
78 s.m_mutex = &m; in acquire()
86 s.m_mutex = &m; in acquire()
87 s.m_mutex->lock(); in acquire()
100 s.m_mutex = &m; in try_acquire()
H A Dthread_data.h59 d1::mutex m_mutex{};
67 mutex::scoped_lock lock(m_mutex); in remove()
78 mutex::scoped_lock lock(m_mutex); in push_front()
84 mutex::scoped_lock lock(m_mutex); in orphan()
117 ITT_SYNC_CREATE(&my_context_list->m_mutex, SyncType_Scheduler, SyncObj_ContextsList);
240 mutex::scoped_lock lock(my_context_list->m_mutex); in propagate_task_group_state()
/oneTBB/include/oneapi/tbb/
H A Dqueuing_mutex.h51 m_mutex = nullptr; in reset()
66 if (m_mutex) release(); in ~scoped_lock()
75 __TBB_ASSERT(!m_mutex, "scoped_lock is already holding a mutex"); in acquire()
79 m_mutex = &m; in acquire()
99 __TBB_ASSERT(!m_mutex, "scoped_lock is already holding a mutex"); in try_acquire()
113 m_mutex = &m; in try_acquire()
122 __TBB_ASSERT(this->m_mutex, "no lock acquired"); in release()
124 call_itt_notify(releasing, this->m_mutex); in release()
128 if (m_mutex->q_tail.compare_exchange_strong(expected, nullptr)) { in release()
143 queuing_mutex* m_mutex{nullptr};
/oneTBB/src/tbbmalloc/
H A DSynchronize.h49 MallocMutex& m_mutex; variable
53 scoped_lock(MallocMutex& m) : m_mutex(m), m_taken(true) { in scoped_lock()
56 scoped_lock(MallocMutex& m, bool block, bool *locked) : m_mutex(m), m_taken(false) { in scoped_lock()
71 m_mutex.unlock(); in ~scoped_lock()
/oneTBB/test/tbb/
H A Dtest_resumable_tasks.cpp50 std::lock_guard<std::mutex> lock(m_mutex); in ~AsyncActivity()
63 std::lock_guard<std::mutex> lock(m_mutex); in submit()
73 std::unique_lock<std::mutex> lock(async->m_mutex); in asyncLoop()
86 std::mutex m_mutex; member in AsyncActivity
198 std::lock_guard<std::mutex> lock(m_mutex); in ~EpochAsyncActivity()
211 std::lock_guard<std::mutex> lock(m_mutex); in submit()
221 std::unique_lock<std::mutex> lock(async->m_mutex); in asyncLoop()
237 std::mutex m_mutex; member in EpochAsyncActivity
H A Dtest_async_node.cpp287 std::lock_guard<mutex_t> lock( m_mutex ); in push()
292 std::lock_guard<mutex_t> lock( m_mutex ); in try_pop()
301 std::lock_guard<mutex_t> lock( m_mutex ); in empty()
307 mutex_t m_mutex; member in async_activity_queue