| /arkcompiler/runtime_core/platforms/unix/libpandabase/futex/ |
| D | mutex.cpp | 296 void ConditionVariable::Wait(Mutex *mutex) in Wait() argument
301 if (!mutex->IsHeld(current_tid)) { in Wait()
308 while (!mutex_ptr_.compare_exchange_weak(old_mutex, mutex, std::memory_order_relaxed)) { in Wait()
310 if (old_mutex != mutex && old_mutex != nullptr) { in Wait()
317 mutex->IncrementWaiters(); in Wait()
318 auto old_count = mutex->GetRecursiveCount(); in Wait()
319 mutex->SetRecursiveCount(1); in Wait()
322 mutex->Unlock(); in Wait()
329 mutex->Lock(); in Wait()
330 mutex->SetRecursiveCount(old_count); in Wait()
[all …]
|
| /arkcompiler/ets_runtime/ecmascript/compiler/codegen/maple/maple_util/include/ |
| D | thread_env.h | 37 static std::mutex mtx; in GetThreadIndex()
38 std::lock_guard<std::mutex> guard(mtx); in GetThreadIndex()
48 static std::mutex mtx; in InitThreadIndex()
49 std::lock_guard<std::mutex> guard(mtx); in InitThreadIndex()
63 explicit ParallelGuard(std::mutex &mtxInput, bool cond = true) : mtx(mtxInput), condition(cond) in mtx()
81 std::mutex &mtx;
|
| /arkcompiler/ets_frontend/es2panda/compiler/core/ |
| D | compileQueue.cpp | 33 std::mutex CompileFileJob::global_m_;
37 std::unique_lock<std::mutex> lock(m_); in Run()
57 std::unique_lock<std::mutex> lock(m_); in Run()
90 std::unique_lock<std::mutex> lock(global_m_); in Run()
109 std::unique_lock<std::mutex> lock(global_m_); in Run()
118 std::unique_lock<std::mutex> lock(m_); in Schedule()
141 std::unique_lock<std::mutex> lock(m_); in Schedule()
|
| D | compilerContext.h | 76 std::mutex &Mutex() in Mutex()
147 std::mutex m_;
|
| /arkcompiler/ets_frontend/ets2panda/compiler/core/ |
| D | compileQueue.cpp | 39 std::unique_lock<std::mutex> lock(m_); in ~CompileQueue()
52 std::unique_lock<std::mutex> lock(m_); in Schedule()
69 std::unique_lock<std::mutex> lock(queue->m_); in Worker()
85 std::unique_lock<std::mutex> lock(m_); in Consume()
110 std::unique_lock<std::mutex> lock(m_); in Wait()
|
| D | compileJob.cpp | 24 std::unique_lock<std::mutex> lock(m_); in Run()
43 std::lock_guard<std::mutex> lock(m_); in Signal()
|
| /arkcompiler/ets_frontend/es2panda/util/ |
| D | workerQueue.cpp | 29 std::lock_guard<std::mutex> lock(m_); in Signal()
49 std::unique_lock<std::mutex> lock(m_); in ~WorkerQueue()
62 std::unique_lock<std::mutex> lock(queue->m_); in Worker()
78 std::unique_lock<std::mutex> lock(m_); in Consume()
103 std::unique_lock<std::mutex> lock(m_); in Wait()
|
| D | workerQueue.h | 40 std::mutex m_;
62 std::mutex m_;
|
| /arkcompiler/runtime_core/static_core/runtime/tests/ |
| D | multithreaded_intern_string_table_test.cpp | 87 std::unique_lock<std::mutex> lk(preLock_); in PreCheck()
112 std::unique_lock<std::mutex> lk(postLock_); in PostFree()
136 std::mutex mutex; member in panda::mem::test::MultithreadedInternStringTableTest
141 std::mutex preLock_;
144 std::mutex postLock_;
184 std::lock_guard<std::mutex> lockGuard(test->mutex); in TestConcurrentInsertion()
|
| /arkcompiler/toolchain/inspector/ |
| D | connect_inspector.cpp | 20 std::mutex g_connectMutex;
47 std::lock_guard<std::mutex> lock(g_connectMutex); in OnMessage()
99 std::lock_guard<std::mutex> lock(g_connectMutex); in SetSwitchCallBack()
115 std::lock_guard<std::mutex> lock(g_connectMutex); in SetDebugModeCallBack()
171 std::lock_guard<std::mutex> lock(g_connectMutex); in StoreMessage()
184 std::lock_guard<std::mutex> lock(g_connectMutex); in StoreInspectorInfo()
191 std::lock_guard<std::mutex> lock(g_connectMutex); in RemoveMessage()
|
| D | ws_server.cpp | 32 std::lock_guard<std::mutex> lock(wsMutex_); in RunServer()
101 std::lock_guard<std::mutex> lock(wsMutex_); in StopServer()
|
| /arkcompiler/ets_runtime/ecmascript/ |
| D | waiter_list.h | 90 explicit MutexGuard(Mutex *mutex) : mutex_(mutex), lockHolder_(*mutex) {} in MutexGuard() argument
|
| /arkcompiler/runtime_core/static_core/runtime/templates/ |
| D | init_icu_gen.cpp.erb | 18 #include <mutex>
27 static std::mutex dataMutex;
30 std::lock_guard<std::mutex> lock(dataMutex);
|
| /arkcompiler/ets_runtime/ecmascript/platform/common/ |
| D | mutex.cpp | 160 void ConditionVariable::Wait(Mutex *mutex) in Wait() argument
162 int rc = pthread_cond_wait(&cond_, &mutex->mutex_); in Wait()
186 bool ConditionVariable::TimedWait(Mutex *mutex, uint64_t ms, uint64_t ns, bool is_absolute) in TimedWait() argument
189 int rc = pthread_cond_timedwait(&cond_, &mutex->mutex_, &abs_time); in TimedWait()
|
| /arkcompiler/runtime_core/libpandabase/os/ |
| D | mutex.cpp | 172 void ConditionVariable::Wait(Mutex *mutex) in Wait() argument
174 int rc = pthread_cond_wait(&cond_, &mutex->mutex_); in Wait()
198 bool ConditionVariable::TimedWait(Mutex *mutex, uint64_t ms, uint64_t ns, bool is_absolute /* = fal… in TimedWait() argument
201 int rc = pthread_cond_timedwait(&cond_, &mutex->mutex_, &abs_time); in TimedWait()
|
| /arkcompiler/runtime_core/static_core/libpandabase/os/ |
| D | mutex.cpp | 172 void ConditionVariable::Wait(Mutex *mutex) in Wait() argument
174 int rc = pthread_cond_wait(&cond_, &mutex->mutex_); in Wait()
198 bool ConditionVariable::TimedWait(Mutex *mutex, uint64_t ms, uint64_t ns, bool is_absolute /* = fal… in TimedWait() argument
201 int rc = pthread_cond_timedwait(&cond_, &mutex->mutex_, &abs_time); in TimedWait()
|
| /arkcompiler/runtime_core/static_core/runtime/ |
| D | default_debugger_agent.cpp | 19 DefaultDebuggerAgent::DefaultDebuggerAgent(os::memory::Mutex &mutex) in DefaultDebuggerAgent() argument
20 …: LibraryAgent(mutex, PandaString(Runtime::GetOptions().GetDebuggerLibraryPath()), "StartDebugger"… in DefaultDebuggerAgent()
|
| D | loadable_agent.cpp | 21 LibraryAgent::LibraryAgent(os::memory::Mutex &mutex, PandaString libraryPath, PandaString loadCallb… in LibraryAgent() argument
23 : lock_(mutex), in LibraryAgent()
|
| /arkcompiler/toolchain/tooling/ |
| D | protocol_handler.cpp | 35 std::unique_lock<std::mutex> queueLock(requestLock_); in DispatchCommand()
46 std::unique_lock<std::mutex> queueLock(requestLock_); in GetDispatchStatus()
58 std::unique_lock<std::mutex> queueLock(requestLock_); in ProcessCommand()
|
| /arkcompiler/runtime_core/libpandabase/utils/ |
| D | logger.cpp | 131 os::memory::Mutex Logger::mutex; // NOLINT(fuchsia-statically-constructed-objects) member in panda::Logger
160 os::memory::LockHolder<os::memory::Mutex> lock(mutex); in Log()
200 os::memory::LockHolder<os::memory::Mutex> lock(mutex); in InitializeFileLogging()
231 os::memory::LockHolder<os::memory::Mutex> lock(mutex); in InitializeHiLogging()
250 os::memory::LockHolder<os::memory::Mutex> lock(mutex); in InitializeStdLogging()
268 os::memory::LockHolder<os::memory::Mutex> lock(mutex); in InitializeDummyLogging()
288 os::memory::LockHolder<os::memory::Mutex> lock(mutex); in Destroy()
|
| /arkcompiler/runtime_core/static_core/platforms/unix/libpandabase/futex/ |
| D | mutex.h | 285 PANDA_PUBLIC_API void Wait(Mutex *mutex) in Wait() argument
287 futex::Wait(&cond_, &mutex->mutex_); in Wait()
290 …PANDA_PUBLIC_API bool TimedWait(Mutex *mutex, uint64_t ms, uint64_t ns = 0, bool isAbsolute = fals…
292 return futex::TimedWait(&cond_, &mutex->mutex_, ms, ns, isAbsolute);
|
| /arkcompiler/ets_runtime/ecmascript/extractortool/src/ |
| D | extractor.cpp | 222 std::mutex ExtractorUtil::mapMutex_;
242 std::lock_guard<std::mutex> mapMutex(mapMutex_); in GetExtractor()
254 std::lock_guard<std::mutex> mapMutex(mapMutex_); in GetExtractor()
267 std::lock_guard<std::mutex> mapMutex(mapMutex_); in DeleteExtractor()
|
| /arkcompiler/runtime_core/static_core/platforms/unix/libpandabase/ |
| D | signal.h | 131 std::unique_lock<std::mutex> cvUniqueLock(cvLock_); in StartThread()
169 std::lock_guard<std::mutex> lockGuard(self->cvLock_); in Run()
198 std::mutex cvLock_;
|
| /arkcompiler/runtime_core/platforms/unix/libpandabase/ |
| D | signal.h | 132 std::unique_lock<std::mutex> cv_unique_lock(cv_lock_); in StartThread()
170 std::lock_guard<std::mutex> lock_guard(self->cv_lock_); in Run()
199 std::mutex cv_lock_;
|
| /arkcompiler/ets_runtime/ecmascript/platform/ |
| D | mutex.h | 92 void Wait(Mutex *mutex);
94 bool TimedWait(Mutex *mutex, uint64_t ms, uint64_t ns = 0, bool is_absolute = false);
|