| /packages/modules/Bluetooth/system/test/mock/ |
| D | mock_osi_thread.h | 42 std::function<void(thread_t* thread)> body{[](thread_t* /* thread */) {}};
43 void operator()(thread_t* thread) { body(thread); }; in operator()
52 std::function<reactor_t*(const thread_t* thread)> body{
53 [this](const thread_t* /* thread */) { return return_value; }};
54 reactor_t* operator()(const thread_t* thread) { return body(thread); }; in operator()
63 std::function<bool(const thread_t* thread)> body{
64 [this](const thread_t* /* thread */) { return return_value; }};
65 bool operator()(const thread_t* thread) { return body(thread); }; in operator()
73 std::function<void(thread_t* thread)> body{[](thread_t* /* thread */) {}};
74 void operator()(thread_t* thread) { body(thread); }; in operator()
[all …]
|
| D | mock_osi_thread.cc | 52 void thread_free(thread_t* thread) { in thread_free()
56 reactor_t* thread_get_reactor(const thread_t* thread) { in thread_get_reactor()
60 bool thread_is_self(const thread_t* thread) { in thread_is_self()
64 void thread_join(thread_t* thread) { in thread_join()
68 const char* thread_name(const thread_t* thread) { in thread_name()
72 thread_t* thread_new(const char* name) { in thread_new()
76 thread_t* thread_new_sized(const char* name, size_t work_queue_capacity) { in thread_new_sized()
80 bool thread_post(thread_t* thread, thread_fn func, void* context) { in thread_post()
84 bool thread_set_priority(thread_t* thread, int priority) { in thread_set_priority()
88 bool thread_set_rt_priority(thread_t* thread, int priority) { in thread_set_rt_priority()
[all …]
|
| /packages/modules/Bluetooth/system/osi/include/ |
| D | thread.h | 27 typedef struct thread_t thread_t; typedef
36 thread_t* thread_new(const char* name);
39 thread_t* thread_new_sized(const char* name, size_t size);
44 void thread_free(thread_t* thread);
49 void thread_join(thread_t* thread);
56 bool thread_post(thread_t* thread, thread_fn func, void* context);
61 void thread_stop(thread_t* thread);
66 bool thread_set_priority(thread_t* thread, int priority);
73 bool thread_set_rt_priority(thread_t* thread, int priority);
78 bool thread_is_self(const thread_t* thread);
[all …]
|
| D | alarm.h | 26 typedef struct thread_t thread_t; typedef
|
| /packages/modules/Bluetooth/system/osi/src/ |
| D | thread.cc | 44 struct thread_t { struct
54 thread_t* thread; argument
69 thread_t* thread_new_sized(const char* name, size_t work_queue_capacity) { in thread_new_sized()
74 thread_t* ret = static_cast<thread_t*>(osi_calloc(sizeof(thread_t))); in thread_new_sized()
107 thread_t* thread_new(const char* name) { in thread_new()
111 void thread_free(thread_t* thread) { in thread_free()
122 void thread_join(thread_t* thread) { in thread_join()
129 bool thread_post(thread_t* thread, thread_fn func, void* context) { in thread_post()
146 void thread_stop(thread_t* thread) { in thread_stop()
151 bool thread_set_priority(thread_t* thread, int priority) { in thread_set_priority()
[all …]
|
| D | alarm.cc | 120 static thread_t* dispatcher_thread;
125 static thread_t* default_callback_thread;
147 thread_t* thread);
540 thread_t* thread) { in alarm_register_processing_queue()
|
| /packages/modules/Bluetooth/system/osi/test/ |
| D | thread_test.cc | 12 thread_t* thread = thread_new("test_thread"); in TEST_F()
18 thread_t* thread = thread_new("test_thread"); in TEST_F()
23 thread_t* thread = thread_new("test_name"); in TEST_F()
29 thread_t* thread = thread_new("0123456789abcdef"); in TEST_F()
35 thread_t* thread = thread_new("0123456789abcdefg"); in TEST_F()
41 thread_t* thread = (thread_t*)context; in thread_is_self_fn()
46 thread_t* thread = thread_new("test_thread"); in TEST_F()
52 thread_t* thread = thread_new("test_thread"); in TEST_F()
|
| D | fixed_queue_test.cc | 334 thread_t* worker_thread = thread_new("test_fixed_queue_worker_thread"); in TEST_F()
|
| /packages/modules/Bluetooth/system/test/fake/ |
| D | fake_thread.cc | 26 thread_t* thread;
29 bool thread_t::is_running() const { in is_running()
34 void thread_t::set_state(State state) { in set_state()
39 void thread_t::quiesce() { in quiesce()
48 quiesce->thread->set_state(thread_t::State::QUIESCE); in quiesce()
57 void thread_t::notify_finished() { thread_finish_semaphore.notify(); } in notify_finished()
|
| D | fake_looper.cc | 50 thread_t* thread = nullptr; in run_message_loop()
55 thread->set_state(thread_t::State::RUNNING); in run_message_loop()
104 thread->set_state(thread_t::State::STOPPED); in run_message_loop()
|
| D | fake_thread.h | 65 thread_t* thread;
70 struct thread_t { struct
|
| /packages/modules/Bluetooth/system/btif/include/ |
| D | btif_sock_sco.h | 25 typedef struct thread_t thread_t; typedef
27 bt_status_t btsock_sco_init(thread_t* thread);
|
| /packages/modules/Bluetooth/system/stack/test/btm/ |
| D | stack_btm_dm_inq_db_test.cc | 62 [](const char* name) -> thread_t* { in SetUp()
63 thread_t* thread = new thread_t; in SetUp()
73 [](thread_t* thread, thread_func func, void* context) -> bool { in SetUp()
82 test::mock::osi_thread::thread_free.body = [](thread_t* thread) { in SetUp()
132 thread_t* threads[kNumberOfThreads];
|
| /packages/modules/Bluetooth/system/test/stub/ |
| D | osi.cc | 222 bool thread_is_self(const thread_t* thread) { in thread_is_self()
226 bool thread_post(thread_t* thread, thread_fn func, void* context) { in thread_post()
230 bool thread_set_priority(thread_t* thread, int priority) { in thread_set_priority()
234 bool thread_set_rt_priority(thread_t* thread, int priority) { in thread_set_rt_priority()
238 const char* thread_name(const thread_t* thread) { in thread_name()
242 reactor_t* thread_get_reactor(const thread_t* thread) { in thread_get_reactor()
246 thread_t* thread_new(const char* name) { in thread_new()
250 thread_t* thread_new_sized(const char* name, size_t work_queue_capacity) { in thread_new_sized()
254 void thread_free(thread_t* thread) { inc_func_call_count(__func__); } in thread_free()
255 void thread_join(thread_t* thread) { inc_func_call_count(__func__); } in thread_join()
[all …]
|
| /packages/modules/Bluetooth/system/osi/test/fuzzers/fixed_queue/ |
| D | fuzz_fixed_queue.cc | 75 std::vector<thread_t*>* live_thread_vector, in callArbitraryFunction()
214 std::vector<thread_t*> live_thread_vector; in LLVMFuzzerTestOneInput()
|
| /packages/modules/Bluetooth/system/btif/src/ |
| D | btif_sock_sco.cc | 82 static thread_t* thread; // Not owned, do not free.
84 bt_status_t btsock_sco_init(thread_t* thread_) { in btsock_sco_init()
|
| D | btif_sock.cc | 67 static thread_t* thread;
|
| /packages/modules/Bluetooth/system/common/test/ |
| D | thread_performance_test.cc | 116 thread_t* thread_ = nullptr;
247 thread_t* thread_ = nullptr;
|
| /packages/modules/Bluetooth/system/common/benchmark/ |
| D | thread_performance_benchmark.cc | 137 thread_t* thread_ = nullptr;
271 thread_t* thread_ = nullptr;
|