Searched refs:thread (Results 1 - 25 of 181) sorted by relevance

12345678

/system/bt/osi/test/
H A Dthread_test.cc9 #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 Dsemaphore_test.cc12 #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 Dthread.h31 // 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 DThreadTest.cpp30 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 DThreadsTest.cpp28 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 Dthread.cc21 #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 Dplatform_log_base.h22 #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 DThreads.cpp34 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 Dmain.cpp103 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 Dfunction_pthread.cpp21 pthread_t thread; local
22 int ret = pthread_create(&thread, nullptr, ChildThreadFunction, nullptr);
28 ret = pthread_join(thread, nullptr);
/system/core/adb/
H A Dfdevent_test.h19 #include <thread>
59 void TerminateThread(std::thread& thread) { argument
62 thread.join();
H A Dfdevent_test.cpp24 #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 Dsocket_test.cpp25 #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 DIOEventLoop_test.cpp23 #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 Dinit.cc26 #include <thread>
56 std::thread socketServerThread([&]() {
/system/bt/btif/include/
H A Dbtif_sock_sco.h25 bt_status_t btsock_sco_init(thread_t* thread);
/system/bt/test/suite/core/
H A Dthread_performance_test.cc4 #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 DMapInfoGetLoadBiasTest.cpp28 #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 Dproperties_test.cpp24 #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 Dhci_inject.cc35 #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 Dasync_fd_watcher.h21 #include <thread>
52 std::thread thread_;
/system/libhidl/base/
H A DTaskRunner.cpp22 #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 Dthread_util.h53 pthread_t thread; local
54 rval = pthread_create(&thread, &scoped_attr.attr, &runAndDelete<T>, obj);
/system/bt/service/ipc/dbus/
H A Dipc_handler_dbus.h18 #include <base/threading/thread.h>
/system/core/debuggerd/
H A Ddebuggerd.cpp23 #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));

Completed in 1374 milliseconds

12345678