/system/bt/osi/test/ |
H A D | thread_test.cc | 9 #include "osi/include/thread.h" 14 thread_t* thread = thread_new("test_thread"); local 15 ASSERT_TRUE(thread != NULL); 16 thread_free(thread); 20 thread_t* thread = thread_new("test_thread"); local 21 thread_free(thread); 25 thread_t* thread = thread_new("test_name"); local 26 ASSERT_STREQ(thread_name(thread), "test_name"); 27 thread_free(thread); 31 thread_t* thread local 37 thread_t* thread = thread_new("0123456789abcdefg"); local 43 thread_t* thread = (thread_t*)context; local 48 thread_t* thread = thread_new("test_thread"); local 54 thread_t* thread = thread_new("test_thread"); local [all...] |
/system/bt/osi/include/ |
H A D | thread.h | 31 // Creates and starts a new thread with the given name. Only THREAD_NAME_MAX 32 // bytes from |name| will be assigned to the newly-created thread. Returns a 33 // thread object if the thread was successfully started, NULL otherwise. The 34 // returned thread object must be freed with |thread_free|. |name| may not 41 // Frees the given |thread|. If the thread is still running, it is stopped 42 // and the calling thread will block until |thread| terminates. |thread| [all...] |
/system/extras/memory_replay/tests/ |
H A D | ThreadTest.cpp | 30 Thread thread; local 32 // A thread should be ready immediately. If not, this will hang forever. 33 thread.WaitForReady(); 38 Thread* thread = thread_data->first; local 41 thread->WaitForReady(); 48 Thread thread; local 50 thread_data_t thread_data = std::make_pair(&thread, &finish); 52 thread.SetPending(); 61 thread.ClearPending(); 68 Thread* thread local 78 Thread thread; local 96 Thread thread; local 104 Thread thread; local [all...] |
H A D | ThreadsTest.cpp | 28 Thread* thread = threads.CreateThread(900); local 29 ASSERT_TRUE(thread != nullptr); 33 ASSERT_EQ(thread, found_thread); 35 thread->CreateAction(0x1234, "thread_done", ""); 37 thread->SetPending(); 39 threads.Finish(thread); 90 Thread* thread = threads.CreateThread(900); local 91 ASSERT_TRUE(thread != nullptr); 97 thread->CreateAction(0x1234 + i, "malloc", "100"); 98 thread 117 Thread* thread = threads.CreateThread(900+i); local [all...] |
/system/bt/osi/src/ |
H A D | thread.cc | 21 #include "osi/include/thread.h" 52 thread_t* thread; member in struct:start_arg 85 start.thread = ret; 108 void thread_free(thread_t* thread) { argument 109 if (!thread) return; 111 thread_stop(thread); 112 thread_join(thread); 114 fixed_queue_free(thread->work_queue, osi_free); 115 reactor_free(thread->reactor); 116 osi_free(thread); 119 thread_join(thread_t* thread) argument 126 thread_post(thread_t* thread, thread_fn func, void* context) argument 143 thread_stop(thread_t* thread) argument 148 thread_set_priority(thread_t* thread, int priority) argument 162 thread_set_rt_priority(thread_t* thread, int priority) argument 179 thread_is_self(const thread_t* thread) argument 184 thread_get_reactor(const thread_t* thread) argument 189 thread_name(const thread_t* thread) argument 198 thread_t* thread = start->thread; local [all...] |
/system/chre/platform/linux/include/chre/target_platform/ |
H A D | platform_log_base.h | 22 #include <thread> 38 //! The thread that waits on incoming log messages and sends them out to 40 std::thread mLoggerThread;
|
/system/extras/memory_replay/ |
H A D | Threads.cpp | 34 Thread* thread = reinterpret_cast<Thread*>(data); local 36 thread->WaitForPending(); 37 Action* action = thread->GetAction(); 38 thread->AddTimeNsecs(action->Execute(thread->pointers())); 40 thread->ClearPending(); 80 Thread* thread = FindEmptyEntry(tid); local 81 if (thread == nullptr) { 85 thread->tid_ = tid; 86 thread 140 Finish(Thread* thread) argument [all...] |
H A D | main.cpp | 103 Thread* thread = threads.FindThread(tid); local 104 if (thread == nullptr) { 105 thread = threads.CreateThread(tid); 108 // Wait for the thread to complete any previous actions before handling 110 thread->WaitForReady(); 112 Action* action = thread->CreateAction(key_pointer, type, line + line_pos); 120 // before triggering the action. Otherwise, another thread could 125 // Tell the thread to execute the action. 126 thread->SetPending(); 129 // Wait for the thread t [all...] |
/system/extras/simpleperf/runtest/ |
H A D | function_pthread.cpp | 21 pthread_t thread; local 22 int ret = pthread_create(&thread, nullptr, ChildThreadFunction, nullptr); 28 ret = pthread_join(thread, nullptr);
|
/system/core/adb/ |
H A D | fdevent_test.h | 19 #include <thread> 64 void TerminateThread(std::thread& thread) { argument 67 thread.join();
|
H A D | socket_test.cpp | 25 #include <thread> 87 std::thread thread(fdevent_loop); 103 TerminateThread(thread); 150 std::thread thread(CloseWithPacketThreadFunc, &arg); 159 TerminateThread(thread); 173 std::thread thread(CloseWithPacketThreadFunc, &arg); 188 TerminateThread(thread); [all...] |
H A D | fdevent_test.cpp | 24 #include <thread> 83 std::thread thread(fdevent_loop); 84 TerminateThread(thread); 124 std::thread thread(FdEventThreadFunc, &thread_arg); 134 TerminateThread(thread); 173 std::thread thread(InvalidFdThreadFunc); 174 thread [all...] |
/system/vold/ |
H A D | MoveTask.h | 23 #include <thread> 38 std::thread mThread;
|
H A D | TrimTask.h | 22 #include <thread> 43 std::thread mThread;
|
/system/extras/simpleperf/ |
H A D | IOEventLoop_test.cpp | 23 #include <thread> 48 std::thread thread([&]() { 56 thread.join(); 82 std::thread thread([&]() { 93 // close fd[1] to make read thread stop. 95 thread.join(); 110 std::thread thread([ [all...] |
H A D | dwarf_unwind.h | 30 std::vector<uint64_t> UnwindCallChain(int abi, const ThreadEntry& thread, const RegSet& regs,
|
/system/libhidl/base/ |
H A D | TaskRunner.cpp | 18 #include <thread> 30 // Allow the thread to continue running in background; 31 // TaskRunner do not care about the std::thread object. 32 std::thread{[q = mQueue] {
|
/system/bt/btif/include/ |
H A D | btif_sock_sco.h | 25 bt_status_t btsock_sco_init(thread_t* thread);
|
/system/libhidl/base/include/hidl/ |
H A D | TaskRunner.h | 21 #include <thread> 39 * Notify the background thread to terminate and return immediately.
|
/system/bt/test/suite/core/ |
H A D | thread_performance_test.cc | 4 #include <base/threading/thread.h> 12 #include "osi/include/thread.h" 18 thread_t* thread; variable 56 thread = thread_new("performance test thread"); 57 thread_post(thread, run_message_loop, nullptr); 64 thread_free(thread); variable 65 thread = nullptr; 102 thread = thread_new("queue performance test thread"); [all...] |
/system/bt/btif/src/ |
H A D | btif_sock.cc | 37 #include "osi/include/thread.h" 49 static thread_t* thread; variable 60 CHECK(thread == NULL); 84 thread = thread_new("btif_sock"); 85 if (!thread) { 86 LOG_ERROR(LOG_TAG, "%s error creating new thread.", __func__); 91 status = btsock_sco_init(thread); 102 thread_free(thread); 103 thread = NULL; 118 thread_free(thread); [all...] |
/system/core/base/ |
H A D | properties_test.cpp | 24 #include <thread> 130 std::thread thread([&]() { 140 thread.join(); 156 std::thread thread([&]() { 167 thread.join(); 172 std::thread thread([&]() { 183 thread [all...] |
/system/bt/hci/src/ |
H A D | hci_inject.cc | 35 #include "osi/include/thread.h" 64 static thread_t* thread; variable 73 CHECK(thread == NULL); 79 thread = thread_new("hci_inject"); 80 if (!thread) goto error; 90 socket_register(listen_socket, thread_get_reactor(thread), NULL, accept_ready, 106 thread_free(thread); 109 thread = NULL; 144 socket_register(socket, thread_get_reactor(thread), client, read_ready, NULL);
|
/system/bt/vendor_libs/linux/interface/ |
H A D | async_fd_watcher.h | 21 #include <thread> 52 std::thread thread_;
|
/system/netd/server/ |
H A D | thread_util.h | 53 pthread_t thread; local 54 rval = pthread_create(&thread, &scoped_attr.attr, &runAndDelete<T>, obj);
|