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

123456

/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...]
/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>
64 void TerminateThread(std::thread& thread) { argument
67 thread.join();
H A Dsocket_test.cpp25 #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 Dfdevent_test.cpp24 #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 DMoveTask.h23 #include <thread>
38 std::thread mThread;
H A DTrimTask.h22 #include <thread>
43 std::thread mThread;
/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...]
H A Ddwarf_unwind.h30 std::vector<uint64_t> UnwindCallChain(int abi, const ThreadEntry& thread, const RegSet& regs,
/system/libhidl/base/
H A DTaskRunner.cpp18 #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 Dbtif_sock_sco.h25 bt_status_t btsock_sco_init(thread_t* thread);
/system/libhidl/base/include/hidl/
H A DTaskRunner.h21 #include <thread>
39 * Notify the background thread to terminate and return immediately.
/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/bt/btif/src/
H A Dbtif_sock.cc37 #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 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/netd/server/
H A Dthread_util.h53 pthread_t thread; local
54 rval = pthread_create(&thread, &scoped_attr.attr, &runAndDelete<T>, obj);

Completed in 437 milliseconds

123456