| /arkcompiler/runtime_core/static_core/runtime/ |
| D | lock_order_graph.h | 33 using ThreadId = ManagedThread::ThreadId;
46 LockOrderGraph(PandaMap<ThreadId, bool> nodes, PandaMap<ThreadId, ThreadId> edges) in LockOrderGraph() argument
58 PandaMap<ThreadId, bool> nodes_;
59 PandaMap<ThreadId, ThreadId> edges_;
|
| D | lock_order_graph.cpp | 21 void UpdateMonitorsForThread(PandaMap<ManagedThread::ThreadId, Monitor::MonitorId> &enteringMonitor… in UpdateMonitorsForThread() argument
22 … PandaMap<Monitor::MonitorId, PandaSet<ManagedThread::ThreadId>> &enteredMonitors, in UpdateMonitorsForThread()
39 PandaMap<ThreadId, bool> nodes; in CheckForTerminationLoops()
40 PandaMap<ThreadId, ThreadId> edges; in CheckForTerminationLoops()
41 PandaMap<ThreadId, MonitorId> enteringMonitors; in CheckForTerminationLoops()
42 PandaMap<MonitorId, PandaSet<ThreadId>> enteredMonitors; in CheckForTerminationLoops()
91 PandaSet<ThreadId> nodesInDeadlocks = {}; in CheckForTerminationLoops()
105 PandaSet<ThreadId> exploredNodes = {node}; in CheckForTerminationLoops()
107 PandaList<ThreadId> front = {node}; in CheckForTerminationLoops()
114 ThreadId currentNode = *i; in CheckForTerminationLoops()
|
| D | mark_word.h | 219 MarkWord DecodeFromLightLock(os::thread::ThreadId threadId, uint32_t count) in DecodeFromLightLock()
293 os::thread::ThreadId GetThreadId() const in GetThreadId()
296 …return static_cast<os::thread::ThreadId>((Value() >> LIGHT_LOCK_THREADID_SHIFT) & LIGHT_LOCK_THREA… in GetThreadId()
|
| D | thread.cpp | 50 MTManagedThread::ThreadId MTManagedThread::GetInternalId() in GetInternalId()
207 ManagedThread::ManagedThread(ThreadId id, mem::InternalAllocatorPtr allocator, PandaVM *pandaVm, in ManagedThread()
598 MTManagedThread::MTManagedThread(ThreadId id, mem::InternalAllocatorPtr allocator, PandaVM *pandaVm, in MTManagedThread()
734 ThreadId tid = GetId(); in SetThreadPriority()
745 ThreadId tid = GetId(); in GetThreadPriority()
|
| /arkcompiler/runtime_core/platforms/unix/libpandabase/ |
| D | thread.cpp | 39 ThreadId GetCurrentThreadId() in GetCurrentThreadId()
42 static_assert(sizeof(decltype(gettid())) == sizeof(ThreadId), "Incorrect alias for ThreadID"); in GetCurrentThreadId()
43 return static_cast<ThreadId>(gettid()); in GetCurrentThreadId()
47 return static_cast<ThreadId>(tid64); in GetCurrentThreadId()
50 return static_cast<ThreadId>(syscall(SYS_gettid)); in GetCurrentThreadId()
|
| /arkcompiler/runtime_core/static_core/platforms/unix/libpandabase/ |
| D | thread.cpp | 40 ThreadId GetCurrentThreadId() in GetCurrentThreadId()
43 static_assert(sizeof(decltype(gettid())) == sizeof(ThreadId), "Incorrect alias for ThreadID"); in GetCurrentThreadId()
44 return static_cast<ThreadId>(gettid()); in GetCurrentThreadId()
48 return static_cast<ThreadId>(tid64); in GetCurrentThreadId()
51 return static_cast<ThreadId>(syscall(SYS_gettid)); in GetCurrentThreadId()
|
| /arkcompiler/runtime_core/platforms/unix/libpandabase/futex/ |
| D | mutex.h | 56 void LockForOther(thread::ThreadId thread);
60 void UnlockForOther(thread::ThreadId thread);
97 bool IsHeld(thread::ThreadId thread) in IsHeld()
112 static_assert(std::atomic<thread::ThreadId>::is_always_lock_free);
223 alignas(alignof(uint32_t)) std::atomic<thread::ThreadId> exclusive_owner_ {0};
224 static_assert(std::atomic<thread::ThreadId>::is_always_lock_free);
231 bool IsExclusiveHeld(thread::ThreadId thread) in IsExclusiveHeld()
|
| D | mutex.cpp | 30 thread_local thread::ThreadId current_tid {0};
101 void Mutex::LockForOther(thread::ThreadId thread) in LockForOther()
106 void Mutex::UnlockForOther(thread::ThreadId thread) in UnlockForOther()
|
| /arkcompiler/runtime_core/static_core/platforms/unix/libpandabase/futex/ |
| D | mutex.h | 55 PANDA_PUBLIC_API void LockForOther(panda::os::thread::ThreadId thread);
59 PANDA_PUBLIC_API void UnlockForOther(panda::os::thread::ThreadId thread);
96 bool IsHeld(panda::os::thread::ThreadId thread) in IsHeld()
111 static_assert(std::atomic<panda::os::thread::ThreadId>::is_always_lock_free);
222 alignas(alignof(uint32_t)) std::atomic<panda::os::thread::ThreadId> exclusiveOwner_ {0};
223 static_assert(std::atomic<panda::os::thread::ThreadId>::is_always_lock_free);
230 bool IsExclusiveHeld(panda::os::thread::ThreadId thread) in IsExclusiveHeld()
|
| D | mutex.cpp | 29 thread_local panda::os::thread::ThreadId current_tid {0};
100 void Mutex::LockForOther(panda::os::thread::ThreadId thread) in LockForOther()
105 void Mutex::UnlockForOther(panda::os::thread::ThreadId thread) in UnlockForOther()
|
| /arkcompiler/runtime_core/libpandabase/os/ |
| D | thread.h | 36 using ThreadId = uint32_t; variable
41 ThreadId GetCurrentThreadId();
|
| /arkcompiler/runtime_core/static_core/runtime/include/ |
| D | managed_thread.h | 47 static constexpr ThreadId NON_INITIALIZED_THREAD_ID = 0;
48 static constexpr ThreadId MAX_INTERNAL_THREAD_ID = MarkWord::LIGHT_LOCK_THREADID_MAX_COUNT;
253 …explicit ManagedThread(ThreadId id, mem::InternalAllocatorPtr allocator, PandaVM *vm, Thread::Thre…
588 ThreadId GetId() const in GetId()
784 void UpdateId(ThreadId id) in UpdateId()
881 std::atomic<ThreadId> id_;
|
| D | runtime_notification.h | 94 virtual void ThreadStart([[maybe_unused]] ManagedThread::ThreadId threadId) {} in ThreadStart()
95 virtual void ThreadEnd([[maybe_unused]] ManagedThread::ThreadId threadId) {} in ThreadEnd()
96 virtual void VmInitialization([[maybe_unused]] ManagedThread::ThreadId threadId) {} in VmInitialization()
333 void VmInitializationEvent(ManagedThread::ThreadId threadId) in VmInitializationEvent()
|
| D | thread.h | 252 using ThreadId = uint32_t;
358 ThreadId internalId_ {0};
|
| D | mtmanaged_thread.h | 23 ThreadId GetInternalId();
29 explicit MTManagedThread(ThreadId id, mem::InternalAllocatorPtr allocator, PandaVM *vm,
|
| /arkcompiler/runtime_core/static_core/libpandabase/os/ |
| D | thread.h | 36 using ThreadId = uint32_t; variable
41 PANDA_PUBLIC_API ThreadId GetCurrentThreadId();
|
| /arkcompiler/runtime_core/static_core/runtime/tests/ |
| D | mark_word_test.cpp | 70 ManagedThread::ThreadId GetThreadId() in GetThreadId()
112 ManagedThread::ThreadId GetThreadId() const in GetThreadId()
164 …void CheckLightweightLock(const ManagedThread::ThreadId tId, const uint32_t lockCount, bool isMark… in CheckLightweightLock()
200 void DecodeLightLock(ManagedThread::ThreadId tId, uint32_t lCount) in DecodeLightLock()
|
| D | signal_handler_test.cpp | 119 os::thread::ThreadId managedThread_ = 0;
|
| /arkcompiler/runtime_core/static_core/platforms/windows/libpandabase/ |
| D | thread.cpp | 26 ThreadId GetCurrentThreadId() in GetCurrentThreadId()
|
| /arkcompiler/runtime_core/platforms/windows/libpandabase/ |
| D | thread.cpp | 26 ThreadId GetCurrentThreadId() in GetCurrentThreadId()
|
| /arkcompiler/runtime_core/static_core/runtime/coroutines/ |
| D | coroutine.h | 60 static constexpr ThreadId MAX_COROUTINE_ID = MarkWord::LIGHT_LOCK_THREADID_MAX_COUNT;
249 explicit Coroutine(ThreadId id, mem::InternalAllocatorPtr allocator, PandaVM *vm,
|
| D | stackful_coroutine_worker.h | 177 os::thread::ThreadId id_;
|
| /arkcompiler/runtime_core/static_core/plugins/ets/runtime/ |
| D | ets_coroutine.h | 106 …explicit EtsCoroutine(ThreadId id, mem::InternalAllocatorPtr allocator, PandaVM *vm, PandaString n…
|
| /arkcompiler/runtime_core/static_core/runtime/tooling/sampler/ |
| D | sampling_profiler.h | 134 PandaSet<os::thread::ThreadId> managedThreads_ GUARDED_BY(managedThreadsLock_);
|
| /arkcompiler/runtime_core/static_core/runtime/tests/tooling/sampler/ |
| D | sampling_profiler_test.cpp | 94 static PandaSet<os::thread::ThreadId> ExtractManagedThreads(Sampler *sPtr) in ExtractManagedThreads()
98 PandaSet<os::thread::ThreadId> managedThreadsCopy = sPtr->managedThreads_; in ExtractManagedThreads()
181 void RunManagedThreadAndSaveThreadId(std::atomic<bool> *syncFlag, os::thread::ThreadId *id) in RunManagedThreadAndSaveThreadId()
266 os::thread::ThreadId mtId = 0; in TEST_F()
|