/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...] |
H A D | semaphore_test.cc | 12 #include "osi/include/thread.h" 74 thread_t* thread = thread_new("semaphore_test_thread"); local 75 ASSERT_TRUE(thread != NULL); 79 thread_post(thread, sleep_then_increment_counter, &sequence_helper); 85 thread_free(thread);
|
/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> 59 void TerminateThread(std::thread& thread) { argument 62 thread.join();
|
H A D | fdevent_test.cpp | 24 #include <thread> 84 std::thread thread(fdevent_loop); 85 TerminateThread(thread); 125 std::thread thread(FdEventThreadFunc, &thread_arg); 135 TerminateThread(thread); 174 std::thread thread(InvalidFdThreadFunc); 175 thread [all...] |
H A D | socket_test.cpp | 25 #include <thread> 87 std::thread thread(fdevent_loop); 103 TerminateThread(thread); 146 std::thread thread(CloseWithPacketThreadFunc, &arg); 155 TerminateThread(thread); 169 std::thread thread(CloseWithPacketThreadFunc, &arg); 184 TerminateThread(thread); [all...] |
/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...] |
/system/chre/platform/android/ |
H A D | init.cc | 26 #include <thread> 56 std::thread socketServerThread([&]() {
|
/system/bt/btif/include/ |
H A D | btif_sock_sco.h | 25 bt_status_t btsock_sco_init(thread_t* thread);
|
/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/core/libunwindstack/tests/ |
H A D | MapInfoGetLoadBiasTest.cpp | 28 #include <thread> 96 std::vector<std::thread*> threads; 103 std::thread* thread = new std::thread([i, this, &wait, &load_bias_values]() { local 108 threads.push_back(thread); 113 for (auto thread : threads) { 114 thread->join(); 115 delete thread;
|
/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/libhidl/base/ |
H A D | TaskRunner.cpp | 22 #include <thread> 50 // Allow the thread to continue running in background; 51 // TaskRunner do not care about the std::thread object. 52 std::thread{[q = mQueue] {
|
/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);
|
/system/bt/service/ipc/dbus/ |
H A D | ipc_handler_dbus.h | 18 #include <base/threading/thread.h>
|
/system/core/debuggerd/ |
H A D | debuggerd.cpp | 23 #include <thread> 42 static std::thread spawn_redirect_thread(unique_fd fd) { 43 return std::thread([fd{ std::move(fd) }]() { 92 std::thread redirect_thread = spawn_redirect_thread(std::move(piperead));
|