| /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 | 43 struct thread_t { struct
53 thread_t* thread; argument
68 thread_t* thread_new_sized(const char* name, size_t work_queue_capacity) { in thread_new_sized()
72 thread_t* ret = static_cast<thread_t*>(osi_calloc(sizeof(thread_t))); in thread_new_sized()
113 thread_t* thread_new(const char* name) { in thread_new()
117 void thread_free(thread_t* thread) { in thread_free()
130 void thread_join(thread_t* thread) { in thread_join()
138 bool thread_post(thread_t* thread, thread_fn func, void* context) { in thread_post()
155 void thread_stop(thread_t* thread) { in thread_stop()
160 bool thread_set_priority(thread_t* thread, int priority) { in thread_set_priority()
[all …]
|
| D | alarm.cc | 122 static thread_t* dispatcher_thread;
127 static thread_t* default_callback_thread;
145 static void alarm_register_processing_queue(fixed_queue_t* queue, thread_t* thread);
553 static void alarm_register_processing_queue(fixed_queue_t* queue, 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 | 330 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()
47 quiesce->thread->set_state(thread_t::State::QUIESCE); in quiesce()
56 void thread_t::notify_finished() { thread_finish_semaphore.notify(); } in notify_finished()
|
| D | fake_looper.cc | 49 thread_t* thread = nullptr; in run_message_loop()
54 thread->set_state(thread_t::State::RUNNING); in run_message_loop()
103 thread->set_state(thread_t::State::STOPPED); in run_message_loop()
|
| D | fake_thread.h | 66 thread_t* thread;
71 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/test/stub/ |
| D | osi.cc | 212 bool thread_is_self(const thread_t* thread) { in thread_is_self()
216 bool thread_post(thread_t* thread, thread_fn func, void* context) { in thread_post()
220 bool thread_set_priority(thread_t* thread, int priority) { in thread_set_priority()
224 bool thread_set_rt_priority(thread_t* thread, int priority) { in thread_set_rt_priority()
228 const char* thread_name(const thread_t* thread) { in thread_name()
232 reactor_t* thread_get_reactor(const thread_t* thread) { in thread_get_reactor()
236 thread_t* thread_new(const char* name) { in thread_new()
240 thread_t* thread_new_sized(const char* name, size_t work_queue_capacity) { in thread_new_sized()
244 void thread_free(thread_t* thread) { inc_func_call_count(__func__); } in thread_free()
245 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() argument
212 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 | 66 static thread_t* thread;
|
| /packages/modules/Bluetooth/system/common/test/ |
| D | thread_performance_test.cc | 115 thread_t* thread_ = nullptr;
233 thread_t* thread_ = nullptr;
|
| /packages/modules/Bluetooth/system/common/benchmark/ |
| D | thread_performance_benchmark.cc | 133 thread_t* thread_ = nullptr;
265 thread_t* thread_ = nullptr;
|
| /packages/modules/Bluetooth/system/btif/test/ |
| D | btif_core_test.cc | 995 thread_t* kThreadPtr = reinterpret_cast<thread_t*>(0xbadbadbad); in SetUp()
996 test::mock::osi_thread::thread_new.body = [kThreadPtr](const char* name) -> thread_t* { in SetUp()
1000 test::mock::osi_thread::thread_free.body = [kThreadPtr](thread_t* ptr_to_free) { in SetUp()
|