| /art/runtime/base/ |
| D | mutex_test.cc | 31 mu.AssertNotHeld(Thread::Current()); in AssertDepth()
33 mu.AssertHeld(Thread::Current()); in AssertDepth()
41 mu.Lock(Thread::Current()); in TEST_F()
43 mu.Unlock(Thread::Current()); in TEST_F()
51 ASSERT_TRUE(mu.TryLock(Thread::Current())); in TryLockUnlockTest()
53 mu.Unlock(Thread::Current()); in TryLockUnlockTest()
65 mu.Lock(Thread::Current()); in RecursiveLockUnlockTest()
67 mu.Lock(Thread::Current()); in RecursiveLockUnlockTest()
69 mu.Unlock(Thread::Current()); in RecursiveLockUnlockTest()
71 mu.Unlock(Thread::Current()); in RecursiveLockUnlockTest()
[all …]
|
| D | mutex.h | 48 class Thread; variable
84 void RegisterAsLocked(Thread* self);
85 void RegisterAsUnlocked(Thread* self);
86 void CheckSafeToWait(Thread* self);
147 void ExclusiveLock(Thread* self) EXCLUSIVE_LOCK_FUNCTION();
148 void Lock(Thread* self) EXCLUSIVE_LOCK_FUNCTION() { ExclusiveLock(self); } in Lock()
151 bool ExclusiveTryLock(Thread* self) EXCLUSIVE_TRYLOCK_FUNCTION(true);
152 bool TryLock(Thread* self) EXCLUSIVE_TRYLOCK_FUNCTION(true) { return ExclusiveTryLock(self); } in TryLock()
155 void ExclusiveUnlock(Thread* self) UNLOCK_FUNCTION();
156 void Unlock(Thread* self) UNLOCK_FUNCTION() { ExclusiveUnlock(self); } in Unlock()
[all …]
|
| /art/runtime/ |
| D | monitor.h | 62 class Thread; variable
75 static void MonitorEnter(Thread* thread, mirror::Object* obj)
78 static bool MonitorExit(Thread* thread, mirror::Object* obj)
82 static void Notify(Thread* self, mirror::Object* obj)
84 static void NotifyAll(Thread* self, mirror::Object* obj)
86 static void Wait(Thread* self, mirror::Object* obj, int64_t ms, int32_t ns,
90 static void DescribeWait(std::ostream& os, const Thread* thread)
95 static mirror::Object* GetContendedMonitor(Thread* thread);
108 explicit Monitor(Thread* owner, mirror::Object* obj)
111 void AppendToWaitSet(Thread* thread) EXCLUSIVE_LOCKS_REQUIRED(monitor_lock_);
[all …]
|
| D | thread_list.cc | 41 if (Contains(Thread::Current())) { in ~ThreadList()
51 bool ThreadList::Contains(Thread* thread) { in Contains()
70 MutexLock mu(Thread::Current(), *Locks::thread_list_lock_); in DumpForSigQuit()
79 Thread::DumpState(os, NULL, tid); in DumpUnattachedThread()
95 Thread* self = Thread::Current(); in DumpUnattachedThreads()
122 void ThreadList::AssertThreadsAreSuspended(Thread* self, Thread* ignore1, Thread* ignore2) { in AssertThreadsAreSuspended()
129 << "self: <<" << *Thread::Current(); in AssertThreadsAreSuspended()
136 static void UnsafeLogFatalForThreadSuspendAllTimeout(Thread* self) NO_THREAD_SAFETY_ANALYSIS { in UnsafeLogFatalForThreadSuspendAllTimeout()
148 Thread* self = Thread::Current(); in RunCheckpoint()
156 std::vector<Thread*> suspended_count_modified_threads; in RunCheckpoint()
[all …]
|
| D | thread_list.h | 28 class Thread; variable
53 void Resume(Thread* thread, bool for_debugger = false)
82 void ForEach(void (*callback)(Thread*, void*), void* context)
86 void Register(Thread* self)
89 void Unregister(Thread* self) LOCKS_EXCLUDED(Locks::mutator_lock_, Locks::thread_list_lock_);
98 std::list<Thread*> GetList() EXCLUSIVE_LOCKS_REQUIRED(Locks::thread_list_lock_) { in GetList()
102 Thread* FindThreadByThinLockId(uint32_t thin_lock_id);
105 uint32_t AllocThreadId(Thread* self);
106 void ReleaseThreadId(Thread* self, uint32_t id) LOCKS_EXCLUDED(allocated_ids_lock_);
108 bool Contains(Thread* thread) EXCLUSIVE_LOCKS_REQUIRED(Locks::thread_list_lock_);
[all …]
|
| D | thread.cc | 74 bool Thread::is_started_ = false;
75 pthread_key_t Thread::pthread_key_self_;
76 ConditionVariable* Thread::resume_cond_ = NULL;
80 void Thread::InitCardTable() { in InitCardTable()
93 void Thread::InitTlsEntryPoints() { in InitTlsEntryPoints()
111 void Thread::SetDeoptimizationShadowFrame(ShadowFrame* sf) { in SetDeoptimizationShadowFrame()
115 void Thread::SetDeoptimizationReturnValue(const JValue& ret_val) { in SetDeoptimizationReturnValue()
119 ShadowFrame* Thread::GetAndClearDeoptimizationShadowFrame(JValue* ret_val) { in GetAndClearDeoptimizationShadowFrame()
126 void Thread::InitTid() { in InitTid()
130 void Thread::InitAfterFork() { in InitAfterFork()
[all …]
|
| D | barrier.h | 32 void Pass(Thread* self);
35 void Wait(Thread* self);
39 void Init(Thread* self, int count);
42 void Increment(Thread* self, int delta);
45 void SetCountLocked(Thread* self, int count) EXCLUSIVE_LOCKS_REQUIRED(lock_);
|
| D | thread_pool.cc | 46 Thread* self = Thread::Current(); in Run()
65 void ThreadPool::AddTask(Thread* self, Task* task) { in AddTask()
86 Thread* self = Thread::Current(); in ThreadPool()
96 MutexLock mu(Thread::Current(), task_queue_lock_); in SetMaxActiveWorkers()
103 Thread* self = Thread::Current(); in ~ThreadPool()
115 void ThreadPool::StartWorkers(Thread* self) { in StartWorkers()
123 void ThreadPool::StopWorkers(Thread* self) { in StopWorkers()
128 Task* ThreadPool::GetTask(Thread* self) { in GetTask()
160 Task* ThreadPool::TryGetTask(Thread* self) { in TryGetTask()
165 Task* ThreadPool::TryGetTaskLocked(Thread* self) { in TryGetTaskLocked()
[all …]
|
| D | instrumentation.h | 34 class Thread; variable
49 virtual void MethodEntered(Thread* thread, mirror::Object* this_object,
56 virtual void MethodExited(Thread* thread, mirror::Object* this_object,
63 virtual void MethodUnwind(Thread* thread, const mirror::ArtMethod* method,
67 virtual void DexPcMoved(Thread* thread, mirror::Object* this_object,
72 virtual void ExceptionCaught(Thread* thread, const ThrowLocation& throw_location,
154 void MethodEnterEvent(Thread* thread, mirror::Object* this_object, in MethodEnterEvent()
163 void MethodExitEvent(Thread* thread, mirror::Object* this_object, in MethodExitEvent()
173 void MethodUnwindEvent(Thread* thread, mirror::Object* this_object,
178 void DexPcMovedEvent(Thread* thread, mirror::Object* this_object, in DexPcMovedEvent()
[all …]
|
| D | thread_pool_test.cc | 30 void Run(Thread* self) { in Run()
42 LOG(INFO) << "Finalizing: " << *Thread::Current(); in Finalize()
61 Thread* self = Thread::Current(); in TEST_F()
76 Thread* self = Thread::Current(); in TEST_F()
110 void Run(Thread* self) { in Run()
131 Thread* self = Thread::Current(); in TEST_F()
|
| D | monitor.cc | 118 Monitor::Monitor(Thread* owner, mirror::Object* obj) in Monitor()
149 void Monitor::AppendToWaitSet(Thread* thread) { in AppendToWaitSet()
150 DCHECK(owner_ == Thread::Current()); in AppendToWaitSet()
159 Thread* t = wait_set_; in AppendToWaitSet()
170 void Monitor::RemoveFromWaitSet(Thread *thread) { in RemoveFromWaitSet()
171 DCHECK(owner_ == Thread::Current()); in RemoveFromWaitSet()
182 Thread* t = wait_set_; in RemoveFromWaitSet()
197 void Monitor::Lock(Thread* self) { in Lock()
257 Thread* self = Thread::Current(); in ThrowIllegalMonitorStateExceptionF()
269 static std::string ThreadToString(Thread* thread) { in ThreadToString()
[all …]
|
| D | intern_table.cc | 36 MutexLock mu(Thread::Current(), intern_table_lock_); in Size()
41 MutexLock mu(Thread::Current(), intern_table_lock_); in DumpForSigQuit()
48 MutexLock mu(Thread::Current(), intern_table_lock_); in VisitRoots()
63 intern_table_lock_.AssertHeld(Thread::Current()); in Lookup()
75 intern_table_lock_.AssertHeld(Thread::Current()); in Insert()
82 intern_table_lock_.AssertHeld(Thread::Current()); in Remove()
117 Thread* self = Thread::Current(); in AllowNewInterns()
124 Thread* self = Thread::Current(); in DisallowNewInterns()
130 Thread* self = Thread::Current(); in Insert()
191 Thread::Current(), utf16_length, utf8_data)); in InternStrong()
[all …]
|
| D | thread_pool.h | 71 void StartWorkers(Thread* self);
74 void StopWorkers(Thread* self);
78 void AddTask(Thread* self, Task* task);
84 void Wait(Thread* self, bool do_work, bool may_hold_locks);
86 size_t GetTaskCount(Thread* self);
99 virtual Task* GetTask(Thread* self);
102 Task* TryGetTask(Thread* self);
103 Task* TryGetTaskLocked(Thread* self) EXCLUSIVE_LOCKS_REQUIRED(task_queue_lock_);
140 virtual void StealFrom(Thread* self, WorkStealingTask* source) = 0;
179 WorkStealingTask* FindTaskToStealFrom(Thread* self) EXCLUSIVE_LOCKS_REQUIRED(work_steal_lock_);
|
| D | thread.h | 73 class Thread; variable
90 class PACKED(4) Thread {
101 static Thread* Attach(const char* thread_name, bool as_daemon, jobject thread_group,
107 static Thread* Current() { in Current()
113 void* thread = pthread_getspecific(Thread::pthread_key_self_); in Current()
114 return reinterpret_cast<Thread*>(thread); in Current()
118 static Thread* FromManagedThread(const ScopedObjectAccessUnchecked& ts,
123 static Thread* FromManagedThread(const ScopedObjectAccessUnchecked& ts, jobject thread)
141 static void DumpState(std::ostream& os, const Thread* thread, pid_t tid)
165 void ModifySuspendCount(Thread* self, int delta, bool for_debugger)
[all …]
|
| /art/runtime/native/ |
| D | java_lang_Thread.cc | 41 Thread* thread = Thread::FromManagedThread(soa, java_thread); in Thread_isInterrupted()
47 Thread::CreateNativeThread(env, java_thread, stack_size, daemon == JNI_TRUE); in Thread_nativeCreate()
62 Thread* thread = Thread::FromManagedThread(soa, java_thread); in Thread_nativeGetStatus()
99 Thread* thread = Thread::FromManagedThread(soa, java_thread); in Thread_nativeHoldsLock()
106 Thread* thread = Thread::FromManagedThread(soa, java_thread); in Thread_nativeInterrupt()
125 Thread* thread = Thread::SuspendForDebugger(peer, true, &timed_out); in Thread_nativeSetName()
146 Thread* thread = Thread::FromManagedThread(soa, java_thread); in Thread_nativeSetPriority()
155 Monitor::Wait(Thread::Current(), lock, ms, ns, true, kSleeping); in Thread_sleep()
169 NATIVE_METHOD(Thread, currentThread, "()Ljava/lang/Thread;"),
170 NATIVE_METHOD(Thread, interrupted, "()Z"),
[all …]
|
| /art/runtime/jdwp/ |
| D | object_registry.cc | 50 ScopedObjectAccessUnchecked soa(Thread::Current()); in InternalAdd()
83 Thread* self = Thread::Current(); in Contains()
89 Thread* self = Thread::Current(); in Clear()
110 Thread* self = Thread::Current(); in InternalGet()
121 Thread* self = Thread::Current(); in GetJObject()
130 Thread* self = Thread::Current(); in DisableCollection()
140 Thread* self = Thread::Current(); in EnableCollection()
151 Thread* self = Thread::Current(); in Demote()
162 Thread* self = Thread::Current(); in Promote()
172 Thread* self = Thread::Current(); in IsCollected()
[all …]
|
| /art/runtime/entrypoints/quick/ |
| D | quick_entrypoints.h | 26 ThreadOffset(static_cast<uintptr_t>(OFFSETOF_MEMBER(Thread, quick_entrypoints_)) + \
37 class Thread; variable
78 uint32_t (*pJniMethodStart)(Thread*);
79 uint32_t (*pJniMethodStartSynchronized)(jobject to_lock, Thread* self);
80 void (*pJniMethodEnd)(uint32_t cookie, Thread* self);
81 void (*pJniMethodEndSynchronized)(uint32_t cookie, jobject locked, Thread* self);
82 mirror::Object* (*pJniMethodEndWithReference)(jobject result, uint32_t cookie, Thread* self);
84 jobject locked, Thread* self);
129 void (*pCheckSuspend)(Thread*); // Stub that is called when the suspend count is non-zero
143 extern uint32_t JniMethodStart(Thread* self) UNLOCK_FUNCTION(Locks::mutator_lock_) HOT_ATTR;
[all …]
|
| /art/test/039-join-main/src/ |
| D | Main.java | 22 Thread t; in main()
24 t = new Thread(new JoinMainSub(Thread.currentThread()), "Joiner"); in main()
28 try { Thread.sleep(1000); } in main()
36 private Thread mJoinMe;
38 public JoinMainSub(Thread joinMe) { in JoinMainSub()
|
| /art/test/033-class-init-deadlock/src/ |
| D | Main.java | 27 Thread thread1, thread2; in main()
30 thread1 = new Thread() { public void run() { new A(); } }; in main()
31 thread2 = new Thread() { public void run() { new B(); } }; in main()
34 try { Thread.sleep(1000); } catch (InterruptedException ie) { } in main()
37 try { Thread.sleep(6000); } catch (InterruptedException ie) { } in main()
52 try { Thread.sleep(3000); } catch (InterruptedException ie) { }
62 try { Thread.sleep(3000); } catch (InterruptedException ie) { }
|
| /art/test/054-uncaught/src/ |
| D | Main.java | 30 Thread t = new Helper(which); in testThread()
47 Thread.setDefaultUncaughtExceptionHandler(defHandler); in catchTheUncaught()
51 Thread.currentThread().setUncaughtExceptionHandler( in catchTheUncaught()
56 Thread.setDefaultUncaughtExceptionHandler(defHandler); in catchTheUncaught()
57 Thread.currentThread().setUncaughtExceptionHandler( in catchTheUncaught()
66 private static class Helper extends Thread {
|
| /art/runtime/arch/mips/ |
| D | quick_entrypoints_mips.S | 156 move $a0, rSELF # pass Thread::Current
158 jr $t9 # artDeliverPendingExceptionFromCode(Thread*, $sp)
163 lw $t0, THREAD_EXCEPTION_OFFSET(rSELF) # load Thread::Current()->exception_
274 move $a1, rSELF # pass Thread::Current
276 jr $t9 # artDeliverExceptionFromCode(Throwable*, Thread*, $sp)
287 move $a0, rSELF # pass Thread::Current
289 jr $t9 # artThrowNullPointerExceptionFromCode(Thread*, $sp)
300 move $a0, rSELF # pass Thread::Current
302 jr $t9 # artThrowDivZeroFromCode(Thread*, $sp)
313 move $a2, rSELF # pass Thread::Current
[all …]
|
| /art/test/063-process-manager/src/ |
| D | Main.java | 9 Thread.sleep(2000); in main()
19 Thread.sleep(1000); in child()
26 Map<Thread, StackTraceElement[]> traces = Thread.getAllStackTraces(); in checkManager()
29 for (Map.Entry<Thread, StackTraceElement[]> entry : in checkManager()
31 Thread t = entry.getKey(); in checkManager()
|
| /art/runtime/interpreter/ |
| D | interpreter.h | 32 class Thread; variable
37 extern void EnterInterpreterFromInvoke(Thread* self, mirror::ArtMethod* method,
41 extern void EnterInterpreterFromDeoptimize(Thread* self, ShadowFrame* shadow_frame,
45 extern JValue EnterInterpreterFromStub(Thread* self, MethodHelper& mh,
50 extern "C" void artInterpreterToInterpreterBridge(Thread* self, MethodHelper& mh,
57 extern "C" void artInterpreterToCompiledCodeBridge(Thread* self, MethodHelper& mh,
|
| /art/test/030-bad-finalizer/ |
| D | info.txt | 7 at java.lang.Thread.sleep(Thread.java:1031)
8 at java.lang.Thread.sleep(Thread.java:1013)
13 at java.lang.Thread.run(Thread.java:856)
|
| /art/test/ParallelGC/ |
| D | ParallelGC.java | 22 Thread[] threads = new Thread[16]; in main()
24 threads[i] = new Thread(new ParallelGC(i)); in main()
26 for (Thread thread : threads) { in main()
29 for (Thread thread : threads) { in main()
|