| /system/extras/memory_replay/ |
| D | Thread.cpp | 22 Thread::Thread() { in Thread() function in Thread
26 Thread::~Thread() { in ~Thread()
30 void Thread::WaitForReady() { in WaitForReady()
38 void Thread::WaitForPending() { in WaitForPending()
46 void Thread::SetPending() { in SetPending()
53 void Thread::ClearPending() { in ClearPending()
60 Action* Thread::CreateAction(uintptr_t key_pointer, const char* type, const char* line) { in CreateAction()
|
| D | Threads.h | 24 class Thread; variable
31 Thread* CreateThread(pid_t tid);
32 Thread* FindThread(pid_t tid);
34 void Finish(Thread* thread);
43 Thread* threads_ = nullptr;
49 Thread* FindEmptyEntry(pid_t tid);
54 friend Thread; variable
|
| D | Threads.cpp | 34 Thread* thread = reinterpret_cast<Thread*>(data); in ThreadRunner()
51 data_size_ = (max_threads_ * sizeof(Thread) + pagesize - 1) & ~(pagesize - 1); in Threads()
52 max_threads_ = data_size_ / sizeof(Thread); in Threads()
60 if (Thread::ACTION_SIZE < Action::MaxActionSize()) { in Threads()
62 Thread::ACTION_SIZE, Action::MaxActionSize()); in Threads()
65 threads_ = new (memory) Thread[max_threads_]; in Threads()
76 Thread* Threads::CreateThread(pid_t tid) { in CreateThread()
80 Thread* thread = FindEmptyEntry(tid); in CreateThread()
96 Thread* Threads::FindThread(pid_t tid) { in FindThread()
127 Thread* Threads::FindEmptyEntry(pid_t tid) { in FindEmptyEntry()
[all …]
|
| D | Thread.h | 29 class Thread {
31 Thread();
32 virtual ~Thread();
|
| D | Android.mk | 8 Thread.cpp \
|
| D | main.cpp | 103 Thread* thread = threads.FindThread(tid); in ProcessDump()
|
| /system/extras/memory_replay/tests/ |
| D | ThreadsTest.cpp | 28 Thread* thread = threads.CreateThread(900); in TEST()
32 Thread* found_thread = threads.FindThread(900); in TEST()
48 Thread* thread1 = threads.CreateThread(900); in TEST()
52 Thread* thread2 = threads.CreateThread(901); in TEST()
56 Thread* thread3 = threads.CreateThread(902); in TEST()
60 Thread* found_thread1 = threads.FindThread(900); in TEST()
63 Thread* found_thread2 = threads.FindThread(901); in TEST()
66 Thread* found_thread3 = threads.FindThread(902); in TEST()
90 Thread* thread = threads.CreateThread(900); in TEST()
117 Thread* thread = threads.CreateThread(900+i); in TestTooManyThreads()
|
| D | ThreadTest.cpp | 27 typedef std::pair<Thread*, volatile bool*> thread_data_t;
30 Thread thread; in TEST()
38 Thread* thread = thread_data->first; in ThreadWaitForReady()
48 Thread thread; in TEST()
68 Thread* thread = thread_data->first; in ThreadWaitForPending()
78 Thread thread; in TEST()
96 Thread thread; in TEST()
104 Thread thread; in TEST()
|
| /system/core/include/utils/ |
| D | Thread.h | 39 class Thread : virtual public RefBase
44 Thread(bool canCallJava = true);
45 virtual ~Thread();
92 Thread& operator=(const Thread&);
103 sp<Thread> mHoldSelf;
|
| /system/core/libutils/ |
| D | Threads.cpp | 648 Thread::Thread(bool canCallJava) in Thread() function in android::Thread
660 Thread::~Thread() in ~Thread()
664 status_t Thread::readyToRun() in readyToRun()
669 status_t Thread::run(const char* name, int32_t priority, size_t stack) in run()
718 int Thread::_threadLoop(void* user) in _threadLoop()
720 Thread* const self = static_cast<Thread*>(user); in _threadLoop()
722 sp<Thread> strong(self->mHoldSelf); in _threadLoop()
723 wp<Thread> weak(strong); in _threadLoop()
783 void Thread::requestExit() in requestExit()
789 status_t Thread::requestExitAndWait() in requestExitAndWait()
[all …]
|
| /system/bt/vendor_libs/test_vendor_lib/test/ |
| D | hci_transport_unittest.cc | 85 base::Thread thread_;
98 base::Thread::Options(base::MessageLoop::TYPE_IO, 0))); in StartThread()
|
| /system/bt/service/ipc/ |
| D | ipc_handler_linux.h | 75 base::Thread thread_;
|
| D | ipc_handler_linux.cpp | 107 base::Thread::Options options(base::MessageLoop::TYPE_IO, 0); in Run()
|
| /system/bt/vendor_libs/test_vendor_lib/include/ |
| D | vendor_manager.h | 101 base::Thread thread_;
|
| /system/core/libutils/tests/ |
| D | TestHelpers.h | 59 class DelayedTask : public Thread {
|
| /system/core/adb/ |
| D | test_adb.py | 108 stdout_thread = threading.Thread(
115 stderr_thread = threading.Thread(
|
| /system/extras/tests/net_test/ |
| D | tcp_nuke_addr_test.py | 91 with RunInBackground(threading.Thread(target=TcpAcceptAndReceive,
124 class ExceptionalReadThread(threading.Thread):
|
| D | anycast_test.py | 41 class CloseFileDescriptorThread(threading.Thread):
|
| /system/tpm/trunks/ |
| D | background_command_transceiver_test.cc | 76 base::Thread test_thread_;
|
| D | trunksd.cc | 111 base::Thread background_thread(kBackgroundThreadName); in main()
|
| /system/bt/vendor_libs/test_vendor_lib/src/ |
| D | vendor_manager.cc | 88 base::Thread::Options(base::MessageLoop::TYPE_IO, 0))) { in Run()
|
| /system/tpm/tpm_manager/server/ |
| D | tpm_manager_service.cc | 39 worker_thread_.reset(new base::Thread("TpmManager Service Worker")); in Initialize()
41 base::Thread::Options(base::MessageLoop::TYPE_IO, 0)); in Initialize()
|
| D | tpm_manager_service.h | 188 std::unique_ptr<base::Thread> worker_thread_;
|
| /system/extras/pagecache/ |
| D | pagecache.py | 113 class FileReaderThread(threading.Thread):
133 threading.Thread.__init__(self)
|
| /system/tpm/attestation/server/ |
| D | attestation_service.h | 303 std::unique_ptr<base::Thread> worker_thread_;
|