| /arkcompiler/ets_frontend/es2panda/util/ |
| H A D | workerQueue.cpp | 29 std::lock_guard<std::mutex> lock(m_); in Signal() 49 std::unique_lock<std::mutex> lock(m_); in ~WorkerQueue() 51 lock.unlock(); in ~WorkerQueue() 62 std::unique_lock<std::mutex> lock(queue->m_); in Worker() 63 queue->jobsAvailable_.wait(lock, [queue]() { return queue->terminate_ || queue->jobsCount_ != 0; }); in Worker() 69 lock.unlock(); in Worker() 78 std::unique_lock<std::mutex> lock(m_); in Consume() 85 lock.unlock(); in Consume() 90 lock.lock(); in Consume() [all...] |
| /arkcompiler/ets_frontend/ets2panda/compiler/core/ |
| H A D | compileQueue.cpp | 39 std::unique_lock<std::mutex> lock(m_); in ~CompileQueue() 41 lock.unlock(); in ~CompileQueue() 52 std::unique_lock<std::mutex> lock(m_); in Schedule() 62 lock.unlock(); in Schedule() 69 std::unique_lock<std::mutex> lock(queue->m_); in Worker() 70 queue->jobsAvailable_.wait(lock, [queue]() { return queue->terminate_ || queue->jobsCount_ != 0; }); in Worker() 76 lock.unlock(); in Worker() 85 std::unique_lock<std::mutex> lock(m_); in Consume() 92 lock.unlock(); in Consume() 97 lock in Consume() [all...] |
| H A D | compileJob.cpp | 23 std::unique_lock<std::mutex> lock(m_); in Run() 24 cond_.wait(lock, [this] { return dependencies_ == 0; }); in Run() 42 std::lock_guard<std::mutex> lock(m_); in Signal()
|
| /arkcompiler/runtime_core/static_core/libpandabase/os/ |
| H A D | mutex.h | 35 // Dummy lock which locks nothing 97 // those threads ignoring failures on lock structures destructors. 170 explicit LockHolder(T &lock) ACQUIRE(lock) : lock_(lock) in ACQUIRE() 194 explicit ReadLockHolder(T &lock) ACQUIRE_SHARED(lock) : lock_(lock) in ACQUIRE_SHARED() 218 explicit WriteLockHolder(T &lock) ACQUIRE(lock) 261 TryLock(L &lock) TryLock() argument 298 Lock(L0 &lock) Lock() argument [all...] |
| /arkcompiler/runtime_core/static_core/runtime/tooling/inspector/ |
| H A D | debuggable_thread.cpp | 27 os::memory::LockHolder lock(mutex_); in Reset() 33 os::memory::LockHolder lock(mutex_); in BreakOnStart() 39 os::memory::LockHolder lock(mutex_); in Continue() 46 os::memory::LockHolder lock(mutex_); in ContinueTo() 53 os::memory::LockHolder lock(mutex_); in StepInto() 60 os::memory::LockHolder lock(mutex_); in StepOver() 67 os::memory::LockHolder lock(mutex_); in StepOut() 74 os::memory::LockHolder lock(mutex_); in IsPaused() 80 os::memory::LockHolder lock(mutex_); in Touch() 86 os::memory::LockHolder lock(mutex in Pause() [all...] |
| H A D | session_manager.cpp | 23 os::memory::LockHolder lock(mutex_); in AddSession() 29 os::memory::LockHolder lock(mutex_); in RemoveSession() 37 os::memory::LockHolder lock(mutex_); in GetSessionIdByThread() 49 os::memory::LockHolder lock(mutex_); in GetThreadBySessionId() 61 os::memory::LockHolder lock(mutex_); in EnumerateSessions()
|
| H A D | inspector.cpp | 48 // acquire lock to later release it either in `OnOpen` or `OnFail` callbacks in Inspector() 109 os::memory::ReadLockHolder lock(debuggerEventsLock_); in ConsoleCall() 121 os::memory::ReadLockHolder lock(debuggerEventsLock_); in Exception() 130 os::memory::ReadLockHolder lock(debuggerEventsLock_); in FramePop() 139 os::memory::ReadLockHolder lock(debuggerEventsLock_); in MethodEntry() 150 os::memory::ReadLockHolder lock(debuggerEventsLock_); in LoadModule() 165 os::memory::ReadLockHolder lock(debuggerEventsLock_); in SingleStep() 174 os::memory::ReadLockHolder lock(debuggerEventsLock_); in ThreadStart() 201 os::memory::ReadLockHolder lock(debuggerEventsLock_); in ThreadEnd() 212 os::memory::WriteLockHolder lock(vmDeathLock in VmDeath() [all...] |
| /arkcompiler/runtime_core/libpandabase/tests/ |
| H A D | mutex_test.cpp | 36 os::memory::Mutex *lock; member 83 bool res = arg->lock->TryLockWithSpinning(); in TestThread4() 86 arg->lock->Unlock(); in TestThread4() 158 auto *lock = new os::memory::Mutex(); in HWTEST_F() local 159 bool res = lock->TryLockWithSpinning(); in HWTEST_F() 163 ThreadMutexArgs arg = {lock, &index}; in HWTEST_F() 170 lock->Unlock(); in HWTEST_F() 172 delete lock; in HWTEST_F() 180 auto *lock = new os::memory::Mutex(); in HWTEST_F() local 183 lock in HWTEST_F() [all...] |
| /arkcompiler/runtime_core/libpandabase/os/ |
| H A D | mutex.h | 33 // Dummy lock which locks nothing 83 // those threads ignoring failures on lock structures destructors. 156 explicit LockHolder(T &lock) ACQUIRE(lock) : lock_(lock) in ACQUIRE() 180 explicit ReadLockHolder(T &lock) ACQUIRE_SHARED(lock) : lock_(lock) in ACQUIRE_SHARED() 204 explicit WriteLockHolder(T &lock) ACQUIRE(lock) [all...] |
| /arkcompiler/runtime_core/tests/fuzztest/readwritelockholder_fuzzer/ |
| H A D | readwritelockholder_fuzzer.cpp | 22 panda::os::memory::DummyLock lock; in ReadWriteLockHolderFuzzTest() local 25 panda::os::memory::LockHolder<panda::os::memory::DummyLock> lock_holder(lock); in ReadWriteLockHolderFuzzTest() 29 panda::os::memory::ReadLockHolder<panda::os::memory::DummyLock> read_lock_holder(lock); in ReadWriteLockHolderFuzzTest() 33 panda::os::memory::WriteLockHolder<panda::os::memory::DummyLock> write_lock_holder(lock); in ReadWriteLockHolderFuzzTest()
|
| /arkcompiler/runtime_core/static_core/runtime/mem/ |
| H A D | heap_space.cpp | 95 os::memory::WriteLockHolder lock(heapLock_); in ComputeNewSize() 146 os::memory::WriteLockHolder lock(heapLock_); in ClampCurrentMaxHeapSize() 174 os::memory::WriteLockHolder lock(heapLock_); in TryAllocPool() 195 os::memory::WriteLockHolder lock(heapLock_); in TryAllocArena() 201 os::memory::ReadLockHolder lock(heapLock_); in FreePool() 213 os::memory::ReadLockHolder lock(heapLock_); in FreeArena() 245 os::memory::ReadLockHolder lock(heapLock_); in GetCurrentFreeYoungSize() 251 os::memory::ReadLockHolder lock(heapLock_); in GetCurrentFreeTenuredSize() 271 os::memory::WriteLockHolder lock(heapLock_); in ComputeNewSize() 296 os::memory::WriteLockHolder lock(heapLock in UpdateSize() [all...] |
| /arkcompiler/runtime_core/static_core/runtime/ |
| H A D | class_linker_context.h | 38 os::memory::LockHolder lock(classesLock_); in FindClass() 65 os::memory::LockHolder lock(classesLock_); in InsertClass() 78 os::memory::LockHolder lock(classesLock_); in RemoveClass() 85 os::memory::LockHolder lock(classesLock_); in EnumerateClasses() 98 os::memory::LockHolder lock(classesLock_); in NumLoadedClasses() 104 os::memory::LockHolder lock(classesLock_); in VisitLoadedClasses() 120 os::memory::LockHolder lock(classesLock_); in AddGCRoot()
|
| H A D | thread_pool.h | 113 os::memory::LockHolder lock(scaleLock_); in ~ThreadPool() 177 os::memory::LockHolder lock(queueLock_); in Help() 199 os::memory::LockHolder lock(queueLock_); in TryPutTask() 215 os::memory::LockHolder lock(queueLock_); in PutTask() 230 os::memory::LockHolder lock(queueLock_); in IsActive() 236 os::memory::LockHolder lock(scaleLock_); in Shutdown() 262 os::memory::LockHolder lock(threadPool->queueLock_); in WorkerEntry() 289 os::memory::LockHolder lock(scaleLock_); in EnumerateProcs() 308 os::memory::LockHolder lock(queueLock_); in DeactivateWorkers() 329 os::memory::LockHolder lock(queueLock in REQUIRES() [all...] |
| H A D | monitor_pool.cpp | 27 os::memory::LockHolder lock(poolLock_); in CreateMonitor() 46 os::memory::LockHolder lock(poolLock_); in LookupMonitor() 56 os::memory::LockHolder lock(poolLock_); in FreeMonitor() 67 os::memory::LockHolder lock(poolLock_); in DeflateMonitors() 81 os::memory::LockHolder lock(poolLock_); in ReleaseMonitors() 84 // Recursive lock is possible in ReleaseMonitors() 94 os::memory::LockHolder lock(poolLock_); in GetEnteredMonitorsIds()
|
| H A D | mt_thread_manager.cpp | 42 os::memory::LockHolder lock(idsLock_); in GetInternalThreadId() 57 os::memory::LockHolder lock(idsLock_); in RemoveInternalThreadId() 151 os::memory::LockHolder lock(threadLock_); in WaitForDeregistration() 216 os::memory::LockHolder lock(threadLock_); in SuspendAllThreads() 229 os::memory::LockHolder lock(threadLock_); in IsRunningThreadExist() 247 os::memory::LockHolder lock(threadLock_); in ResumeAllThreads() 261 os::memory::LockHolder lock(threadLock_); in RegisterThread() 279 os::memory::LockHolder lock(threadLock_); in UnregisterExitedThread() 326 os::memory::LockHolder lock(threadLock_); in DumpUnattachedThreads() 348 os::memory::LockHolder lock(threadLock in SuspendAndWaitThreadByInternalThreadId() [all...] |
| /arkcompiler/ets_runtime/ecmascript/pgo_profiler/ |
| H A D | pgo_profiler_encoder.cpp | 39 LockHolder lock(mutex_); in Destroy() 56 LockHolder lock(mutex_); in ResetOutPathByModuleName() 84 LockHolder lock(mutex_); in InitializeData() 98 WriteLockHolder lock(rwLock_); in SamplePandaFileInfo() 106 ReadLockHolder lock(rwLock_); in GetPandaFileId() 115 ReadLockHolder lock(rwLock_); in GetPandaFileDesc() 129 LockHolder lock(mutex_); in Merge() 135 WriteLockHolder lock(rwLock_); in Merge() 156 LockHolder lock(mutex_); in Save() 173 WriteLockHolder lock(rwLock in MergeWithExistProfile() [all...] |
| /arkcompiler/ets_runtime/ecmascript/compiler/aot_file/ |
| H A D | an_file_data_manager.cpp | 41 WriteLockHolder lock(lock_); in SafeDestroyAllData() 58 WriteLockHolder lock(lock_); in SafeDestroyAnData() 71 WriteLockHolder lock(lock_); in SafeLoad() 169 ReadLockHolder lock(lock_); in SafeGetFileInfoIndex() 175 ReadLockHolder lock(lock_); in SafeGetAnFileInfo() 181 ReadLockHolder lock(lock_); in SafeGetStubFileInfo() 188 // Try to acquire the lock when the signal callback starts to execute. At this time, the vm thread is interrupted, in SafeTryReadLock() 189 // so the status of whether the lock is held by vm thread will not change until the signal callback ends. If the in SafeTryReadLock() 190 // attempt is successful, it means that the current vm thread does not hold the lock,the reentrancy problem will in SafeTryReadLock() 201 ReadLockHolder lock(lock in SafeInsideStub() [all...] |
| /arkcompiler/runtime_core/static_core/plugins/ets/runtime/ |
| H A D | ets_native_library_provider.cpp | 49 os::memory::ReadLockHolder lock(lock_); in LoadLibrary() 65 os::memory::WriteLockHolder lock(lock_); in LoadLibrary() 90 os::memory::ReadLockHolder lock(lock_); in ResolveSymbol() 103 os::memory::ReadLockHolder lock(lock_); in GetLibraryPath() 109 os::memory::WriteLockHolder lock(lock_); in SetLibraryPath() 115 os::memory::WriteLockHolder lock(lock_); in AddLibraryPath()
|
| /arkcompiler/ets_runtime/compiler_service/src/ |
| H A D | aot_compiler_client.cpp | 127 std::unique_lock<std::mutex> lock(loadSaMutex_); in LoadAotCompilerService() 146 std::unique_lock<std::mutex> lock(loadSaMutex_); in LoadAotCompilerService() 147 auto waitStatus = loadSaCondition_.wait_for(lock, std::chrono::milliseconds(LOAD_SA_TIMEOUT_MS), in LoadAotCompilerService() 161 std::lock_guard<std::mutex> lock(mutex_); in SetAotCompiler() 167 std::lock_guard<std::mutex> lock(mutex_); in GetAotCompiler() 182 std::unique_lock<std::mutex> lock(loadSaMutex_); in OnLoadSystemAbilitySuccess() 190 std::unique_lock<std::mutex> lock(loadSaMutex_); in OnLoadSystemAbilityFail()
|
| /arkcompiler/ets_runtime/ecmascript/mem/ |
| H A D | mem_map_allocator.h | 40 LockHolder lock(lock_); in Finalize() 58 LockHolder lock(lock_); in GetMemFromCache() 70 LockHolder lock(lock_); in GetRegularMemFromCommitted() 81 LockHolder lock(lock_); in IsRegularCommittedFull() 88 LockHolder lock(lock_); in ShouldFreeMore() 96 LockHolder lock(lock_); in AddMemToCommittedCache() 103 LockHolder lock(lock_); in AddMemToCache() 109 LockHolder lock(lock_); in SplitMemFromCache() 133 LockHolder lock(lock_); in InsertMemMap() 201 LockHolder lock(lock in GetMemFromList() [all...] |
| /arkcompiler/ets_frontend/es2panda/compiler/core/ |
| H A D | compileQueue.cpp | 41 std::unique_lock<std::mutex> lock(m_); in Run() 42 cond_.wait(lock, [this] { return dependencies_ == 0; }); in Run() 61 std::unique_lock<std::mutex> lock(m_); in Run() 62 cond_.wait(lock, [this] { return dependencies_ == 0; }); in Run() 95 std::unique_lock<std::mutex> lock(globalMutex_); in RetrieveProgramFromCacheFiles() 172 std::unique_lock<std::mutex> lock(globalMutex_); in OptimizeAndCacheProgram() 207 std::unique_lock<std::mutex> lock(CompileFileJob::globalMutex_); in Run() 274 std::unique_lock<std::mutex> lock(m_); in Schedule() 290 lock.unlock(); in Schedule() 297 std::unique_lock<std::mutex> lock(m in Schedule() [all...] |
| /arkcompiler/ets_runtime/ecmascript/platform/ |
| H A D | mutex.h | 127 explicit ReadLockHolder(RWLock &lock) : lock_(lock) in ReadLockHolder() argument 146 explicit WriteLockHolder(RWLock &lock) : lock_(lock) in WriteLockHolder() argument
|
| /arkcompiler/ets_runtime/ecmascript/shared_mm/ |
| H A D | shared_mm.cpp | 25 LockHolder lock(jsSharedMemoryLock_); in ~JSSharedMemoryManager() 49 LockHolder lock(jsSharedMemoryLock_); in InsertSharedMemory() 57 LockHolder lock(jsSharedMemoryLock_); in IncreaseRefSharedMemory() 65 LockHolder lock(jsSharedMemoryLock_); in DecreaseRefSharedMemory()
|
| /arkcompiler/ets_runtime/ecmascript/debugger/ |
| H A D | js_debugger_manager.cpp | 25 std::unique_lock<std::shared_mutex> lock(mutex_); in AddJsDebuggerManager() 33 std::shared_lock<std::shared_mutex> lock(mutex_); in GetJsDebuggerManager() 42 std::unique_lock<std::shared_mutex> lock(mutex_); in DeleteJsDebuggerManager()
|
| /arkcompiler/ets_runtime/ecmascript/dfx/ |
| H A D | vm_thread_control.cpp | 28 LockHolder lock(vmThreadSuspensionMutex_); in NotifyVMThreadSuspension() 72 LockHolder lock(vmThreadSuspensionMutex_); in SuspendVM() 83 LockHolder lock(vmThreadSuspensionMutex_); in ResumeVM()
|