/arkcompiler/runtime_core/static_core/runtime/include/ |
H A D | mtmanaged_thread.h | 46 ThreadStatus GetWaitingMonitorOldStatus() in GetWaitingMonitorOldStatus() 51 void SetWaitingMonitorOldStatus(ThreadStatus status) in SetWaitingMonitorOldStatus() 178 void WaitWithLockHeld(ThreadStatus waitStatus) REQUIRES(condLock_) in REQUIRES() 180 ASSERT(waitStatus == ThreadStatus::IS_WAITING); in REQUIRES() 194 while (thread->GetStatus() == ThreadStatus::RUNNING) { in WaitForSuspension() 212 bool TimedWaitWithLockHeld(ThreadStatus waitStatus, uint64_t timeout, uint64_t nanos, bool isAbsolute = false) 215 ASSERT(waitStatus == ThreadStatus::IS_TIMED_WAITING || waitStatus == ThreadStatus::IS_SLEEPING || in REQUIRES() 216 waitStatus == ThreadStatus::IS_BLOCKED || waitStatus == ThreadStatus in REQUIRES() [all...] |
H A D | managed_thread.h | 170 return GetStatus() != ThreadStatus::FINISHED; in IsThreadAlive() 173 void UpdateStatus(enum ThreadStatus status) in UpdateStatus() 177 ThreadStatus oldStatus = GetStatus(); in UpdateStatus() 178 if (oldStatus == ThreadStatus::RUNNING && status != ThreadStatus::RUNNING) { in UpdateStatus() 180 } else if (oldStatus != ThreadStatus::RUNNING && status == ThreadStatus::RUNNING) { in UpdateStatus() 185 StoreStatus<CHECK_SAFEPOINT, READLOCK>(ThreadStatus::RUNNING); in UpdateStatus() 186 } else if (oldStatus == ThreadStatus::NATIVE && status != ThreadStatus in UpdateStatus() [all...] |
H A D | thread_scopes.h | 111 explicit ScopedChangeThreadStatus(ManagedThread *thread, ThreadStatus newStatus) : thread_(thread) in ScopedChangeThreadStatus() 124 ThreadStatus oldStatus_;
|
H A D | thread_status.h | 21 enum class ThreadStatus : uint16_t { class
|
/arkcompiler/runtime_core/static_core/runtime/ |
H A D | global_object_lock.cpp | 26 ScopedChangeThreadStatus s(ManagedThread::GetCurrent(), ThreadStatus::IS_BLOCKED); in GlobalObjectLock() 32 ScopedChangeThreadStatus s(ManagedThread::GetCurrent(), ThreadStatus::IS_WAITING); in Wait() 39 ScopedChangeThreadStatus s(ManagedThread::GetCurrent(), ThreadStatus::IS_TIMED_WAITING); in TimedWait()
|
H A D | thread.cpp | 486 UpdateStatus(ThreadStatus::NATIVE); in NativeCodeBegin() 495 UpdateStatus(ThreadStatus::RUNNING); in NativeCodeEnd() 511 UpdateStatus(ThreadStatus::RUNNING); in ManagedCodeBegin() 524 UpdateStatus(ThreadStatus::NATIVE); in ManagedCodeEnd() 552 PandaString ManagedThread::ThreadStatusAsString(enum ThreadStatus status) in ThreadStatusAsString() 555 case ThreadStatus::CREATED: in ThreadStatusAsString() 557 case ThreadStatus::RUNNING: in ThreadStatusAsString() 559 case ThreadStatus::IS_BLOCKED: in ThreadStatusAsString() 561 case ThreadStatus::IS_WAITING: in ThreadStatusAsString() 563 case ThreadStatus in ThreadStatusAsString() [all...] |
H A D | mt_thread_manager.cpp | 94 if (status == ThreadStatus::NATIVE || status == ThreadStatus::IS_BLOCKED) { in DeregisterSuspendedThreads() 233 if (thread->GetStatus() == ThreadStatus::RUNNING) { in IsRunningThreadExist() 293 thread->UpdateStatus(ThreadStatus::FINISHED); in UnregisterExitedThread() 339 ASSERT(current->GetStatus() != ThreadStatus::RUNNING); in SuspendAndWaitThreadByInternalThreadId() 367 if (suspended->GetStatus() != ThreadStatus::RUNNING) { in SuspendAndWaitThreadByInternalThreadId()
|
H A D | monitor.cpp | 109 ScopedChangeThreadStatus sts(thread, ThreadStatus::IS_WAITING_INFLATION); in InflateThinLock() 113 thread->SetWaitingMonitorOldStatus(ThreadStatus::FINISHED); in InflateThinLock() 130 thread->TimedWait(ThreadStatus::IS_WAITING_INFLATION, SLEEP_MS, 0); in InflateThinLock() 133 thread->SetWaitingMonitorOldStatus(ThreadStatus::FINISHED); in InflateThinLock() 178 thread->SetWaitingMonitorOldStatus(ThreadStatus::IS_WAITING_INFLATION); in HandleLightLockedState() 361 static inline bool DoWaitInternal(MTManagedThread *thread, ThreadStatus status, uint64_t timeout, uint64_t nanos) 376 Monitor::State Monitor::Wait(ObjectHeader *obj, ThreadStatus status, uint64_t timeout, uint64_t nanos, in Wait() 458 thread->SetWaitingMonitorOldStatus(ThreadStatus::FINISHED); in Wait() 610 thread->SetWaitingMonitorOldStatus(ThreadStatus::IS_BLOCKED); in Acquire() 612 ScopedChangeThreadStatus sts(thread, ThreadStatus in Acquire() [all...] |
H A D | monitor_object_lock.cpp | 33 Monitor::State state = Monitor::Wait(objHandler_.GetPtr(), ThreadStatus::IS_WAITING, 0, 0, ignoreInterruption); in Wait() 40 Monitor::State state = Monitor::Wait(objHandler_.GetPtr(), ThreadStatus::IS_TIMED_WAITING, timeout, 0); in TimedWait()
|
H A D | lock_order_graph.cpp | 50 if (status == ThreadStatus::NATIVE) { in CheckForTerminationLoops() 53 if (status != ThreadStatus::IS_BLOCKED) { in CheckForTerminationLoops()
|
H A D | single_thread_manager.h | 52 if (mainThread->GetStatus() == ThreadStatus::RUNNING) {
|
H A D | thread_manager.h | 288 bool CanDeregister(enum ThreadStatus status) in CanDeregister() 298 return status == ThreadStatus::IS_TERMINATED_LOOP; in CanDeregister()
|
H A D | intrinsics.cpp | 377 Monitor::State state = Monitor::Wait(header, ThreadStatus::IS_WAITING, 0, 0); in ObjectWait() 383 Monitor::State state = Monitor::Wait(header, ThreadStatus::IS_TIMED_WAITING, timeout, 0); in ObjectTimedWait() 389 Monitor::State state = Monitor::Wait(header, ThreadStatus::IS_TIMED_WAITING, timeout, nanos); in ObjectTimedWaitNanos()
|
H A D | monitor.h | 115 PANDA_PUBLIC_API static State Wait(ObjectHeader *obj, ThreadStatus status, uint64_t timeout, uint64_t nanos,
|
/arkcompiler/runtime_core/static_core/tools/sampler/ |
H A D | trace_dumper.cpp | 61 void TraceDumper::WriteThreadStatus(std::ofstream &stream, SampleInfo::ThreadStatus threadStatus) in WriteThreadStatus() 66 case SampleInfo::ThreadStatus::RUNNING: { in WriteThreadStatus() 70 case SampleInfo::ThreadStatus::SUSPENDED: { in WriteThreadStatus()
|
H A D | trace_dumper.h | 57 static void WriteThreadStatus(std::ofstream &stream, SampleInfo::ThreadStatus threadStatus);
|
/arkcompiler/runtime_core/static_core/runtime/tooling/sampler/ |
H A D | sampling_profiler.cpp | 286 static SampleInfo::ThreadStatus GetThreadStatus(ManagedThread *mthread) in GetThreadStatus() 291 if (threadStatus == ThreadStatus::RUNNING) { in GetThreadStatus() 292 return SampleInfo::ThreadStatus::RUNNING; in GetThreadStatus() 299 if (threadStatus == ThreadStatus::NATIVE && isCoroutineRunning) { in GetThreadStatus() 300 return SampleInfo::ThreadStatus::RUNNING; in GetThreadStatus() 303 return SampleInfo::ThreadStatus::SUSPENDED; in GetThreadStatus()
|
H A D | sample_info.h | 31 enum class ThreadStatus : uint32_t { UNDECLARED = 0, RUNNING = 1, SUSPENDED = 2 }; class 48 ThreadStatus threadStatus {ThreadStatus::UNDECLARED};
|
H A D | sample_reader-inl.h | 117 static_cast<SampleInfo::ThreadStatus>(ReadUint32TBitMisaligned(¤tSamplePtr[SAMPLE_THREAD_STATUS_OFFSET])); in GetNextSample()
|
/arkcompiler/ets_runtime/ecmascript/compiler/codegen/maple/maple_util/include/ |
H A D | mpl_scheduler.h | 141 enum ThreadStatus { kThreadStop, kThreadRun, kThreadPause }; enum in maple::MplScheduler 143 ThreadStatus statusFinish;
|
/arkcompiler/runtime_core/static_core/runtime/coroutines/ |
H A D | stackful_coroutine.cpp | 73 ASSERT(co->GetStatus() != ThreadStatus::FINISHED); in Destroy() 75 co->UpdateStatus(ThreadStatus::TERMINATING); in Destroy()
|
H A D | threaded_coroutine.cpp | 72 ASSERT(co->GetStatus() != ThreadStatus::FINISHED); in Destroy() 74 co->UpdateStatus(ThreadStatus::TERMINATING); in Destroy()
|
H A D | threaded_coroutine_manager.cpp | 110 co->UpdateStatus(ThreadStatus::TERMINATING); in TerminateCoroutine() 139 co->UpdateStatus(ThreadStatus::FINISHED); in TerminateCoroutine()
|
/arkcompiler/runtime_core/static_core/verification/type/ |
H A D | type_system.cpp | 44 ScopedChangeThreadStatus st(ManagedThread::GetCurrent(), ThreadStatus::RUNNING); 121 ScopedChangeThreadStatus st(ManagedThread::GetCurrent(), ThreadStatus::RUNNING); in GetMethodSignature()
|
/arkcompiler/runtime_core/static_core/verification/jobs/ |
H A D | job.cpp | 43 ScopedChangeThreadStatus st(ManagedThread::GetCurrent(), ThreadStatus::RUNNING); in UpdateTypes()
|