/system/bt/osi/test/ |
H A D | thread_test.cpp | 10 #include "thread.h" 17 thread_t *thread = thread_new("test_thread"); local 18 ASSERT_TRUE(thread != NULL); 19 thread_free(thread); 23 thread_t *thread = thread_new("test_thread"); local 24 thread_free(thread); 28 thread_t *thread = thread_new("test_name"); local 29 ASSERT_STREQ(thread_name(thread), "test_name"); 30 thread_free(thread); 34 thread_t *thread local 40 thread_t *thread = thread_new("0123456789abcdefg"); local 46 thread_t *thread = (thread_t *)context; local 51 thread_t *thread = thread_new("test_thread"); local 57 thread_t *thread = thread_new("test_thread"); local [all...] |
H A D | reactor_test.cpp | 15 static pthread_t thread; variable 29 int ret = pthread_create(&thread, NULL, reactor_thread, reactor); 34 pthread_join(thread, NULL);
|
/system/bt/osi/include/ |
H A D | thread.h | 30 // Creates and starts a new thread with the given name. Only THREAD_NAME_MAX 31 // bytes from |name| will be assigned to the newly-created thread. Returns a 32 // thread object if the thread was successfully started, NULL otherwise. The 33 // returned thread object must be freed with |thread_free|. |name| may not 40 // Frees the given |thread|. If the thread is still running, it is stopped 41 // and the calling thread will block until |thread| terminates. |thread| [all...] |
/system/bt/osi/src/ |
H A D | thread.c | 36 #include "osi/include/thread.h" 48 thread_t *thread; member in struct:start_arg 86 start.thread = ret; 110 void thread_free(thread_t *thread) { argument 111 if (!thread) 114 thread_stop(thread); 115 thread_join(thread); 117 fixed_queue_free(thread->work_queue, osi_free); 118 reactor_free(thread->reactor); 119 osi_free(thread); 122 thread_join(thread_t *thread) argument 132 thread_post(thread_t *thread, thread_fn func, void *context) argument 153 thread_stop(thread_t *thread) argument 158 thread_set_priority(thread_t *thread, int priority) argument 172 thread_is_self(const thread_t *thread) argument 177 thread_get_reactor(const thread_t *thread) argument 182 thread_name(const thread_t *thread) argument 191 thread_t *thread = start->thread; local [all...] |
/system/vold/ |
H A D | MoveTask.h | 23 #include <thread> 38 std::thread mThread;
|
H A D | TrimTask.h | 22 #include <thread> 43 std::thread mThread;
|
/system/bt/hci/test/ |
H A D | low_power_manager_test.cpp | 30 #include "thread.h" 41 static thread_t *thread; variable 67 thread_post(thread, flush_work_queue_item, NULL); 74 thread_post(thread, flush_work_queue_item, NULL); 109 thread = thread_new("test_thread"); 113 manager->init(thread); 124 thread_free(thread);
|
H A D | hci_hal_h4_test.cpp | 152 thread = thread_new("hal_test"); 155 EXPECT_TRUE(hal->init(&callbacks, thread)); 168 thread_free(thread); 174 thread_t *thread;
|
H A D | hci_hal_mct_test.cpp | 152 thread = thread_new("hal_test"); 155 EXPECT_TRUE(hal->init(&callbacks, thread)); 168 thread_free(thread); 177 thread_t *thread;
|
/system/bt/btif/src/ |
H A D | btif_sock.c | 33 #include "osi/include/thread.h" 41 static thread_t *thread; variable 56 assert(thread == NULL); 77 thread = thread_new("btif_sock"); 78 if (!thread) { 79 LOG_ERROR("%s error creating new thread.", __func__); 84 status = btsock_sco_init(thread); 94 thread_free(thread); 95 thread = NULL; 106 thread_stop(thread); [all...] |
H A D | btif_sock_sco.c | 35 #include "osi/include/thread.h" 87 static thread_t *thread; // Not owned, do not free. variable 98 thread = thread_; 170 socket_register(socket, thread_get_reactor(thread), sco_socket, socket_read_ready_cb, NULL); 190 // Must be called with |lock| held except during teardown when we know the socket thread
|
/system/bt/btif/include/ |
H A D | btif_sock_sco.h | 25 bt_status_t btsock_sco_init(thread_t *thread);
|
/system/bt/hci/src/ |
H A D | hci_inject.c | 34 #include "osi/include/thread.h" 55 static thread_t *thread; variable 69 assert(thread == NULL); 75 thread = thread_new("hci_inject"); 76 if (!thread) 90 socket_register(listen_socket, thread_get_reactor(thread), NULL, accept_ready, NULL); 105 thread_free(thread); 108 thread = NULL; 149 socket_register(socket, thread_get_reactor(thread), client, read_ready, NULL);
|
H A D | hci_layer.c | 122 static thread_t *thread; // We own this variable 218 thread = thread_new("hci_thread"); 219 if (!thread) { 220 LOG_ERROR("%s unable to create thread.", __func__); 234 fixed_queue_register_dequeue(command_queue, thread_get_reactor(thread), event_command_ready, NULL); 235 fixed_queue_register_dequeue(packet_queue, thread_get_reactor(thread), event_packet_ready, NULL); 238 hal->init(&hal_callbacks, thread); 239 low_power_manager->init(thread); 267 thread_post(thread, event_finish_startup, NULL); 279 if (thread) { [all...] |
H A D | hci_hal_h4.c | 30 #include "osi/include/thread.h" 36 // Increased HCI thread priority to keep up with the audio sub-system 45 static thread_t *thread; // Not owned by us variable 63 thread = upper_thread; 94 eager_reader_register(uart_stream, thread_get_reactor(thread), event_uart_has_bytes, NULL); 96 // Raise thread priorities to keep up with audio 97 thread_set_priority(thread, HCI_THREAD_PRIORITY);
|
H A D | hci_hal_mct.c | 40 static thread_t *thread; // Not owned by us variable 57 thread = upper_thread; 107 eager_reader_register(event_stream, thread_get_reactor(thread), event_event_stream_has_bytes, NULL); 108 eager_reader_register(acl_stream, thread_get_reactor(thread), event_acl_stream_has_bytes, NULL);
|
H A D | low_power_manager.c | 28 #include "osi/include/thread.h" 68 static thread_t *thread; variable 79 thread = post_thread; 103 thread_post(thread, event_functions[command], NULL); 183 thread_post(thread, event_idle_timeout, NULL);
|
/system/extras/simpleperf/ |
H A D | environment.cpp | 291 ThreadComm thread; local 292 thread.tid = tid; 293 thread.tgid = tgid; 294 thread.comm = comm; 295 thread.is_process = (tid == pid); 296 thread_comms->push_back(thread); 340 ThreadMmap thread; local 341 thread.start_addr = start_addr; 342 thread.len = end_addr - start_addr; 343 thread [all...] |
H A D | cmd_record.cpp | 286 for (auto& thread : thread_comms) { 287 CommRecord record = CreateCommRecord(attr, thread.tgid, thread.tid, thread.comm); 291 if (thread.is_process) { 293 if (!GetThreadMmapsInProcess(thread.tgid, &thread_mmaps)) { 294 // The thread may exit before we get its info. 302 CreateMmapRecord(attr, false, thread.tgid, thread.tid, thread_mmap.start_addr,
|
/system/vold/bench/ |
H A D | benchgen.py | 35 def __init__(self, thread, time, call, args, ret): 36 self.thread = thread 69 handle = "t%sf%s" % (e.thread, fd) 114 thread = int(fn.split(".")[-1]) variable 125 events.append(Event(thread, time, call, args, ret))
|
/system/netd/server/ |
H A D | DnsProxyListener.cpp | 68 pthread_t thread; local 69 pthread_create(&thread, NULL, 71 pthread_detach(thread); 329 pthread_t thread; local 330 pthread_create(&thread, NULL, 332 pthread_detach(thread); 446 pthread_t thread; local 447 pthread_create(&thread, NULL, 449 pthread_detach(thread);
|
/system/core/libbacktrace/ |
H A D | backtrace_test.cpp | 75 thread_t thread; member in struct:dump_thread_t 191 thread_t* thread = reinterpret_cast<thread_t*>(data); local 192 android_atomic_acquire_store(1, &thread->state); 194 while (thread->state) { 428 pthread_t thread; local 429 ASSERT_TRUE(pthread_create(&thread, &attr, PtraceThreadLevelRun, nullptr) == 0); 487 thread_t* thread = reinterpret_cast<thread_t*>(data); local 489 thread->tid = gettid(); 500 pthread_t thread; local 501 ASSERT_TRUE(pthread_create(&thread, 549 pthread_t thread; local 574 thread_t* thread = reinterpret_cast<thread_t*>(data); local 587 pthread_t thread; local 994 pthread_t thread; local 1414 pthread_t thread; local [all...] |
/system/core/libsync/tests/ |
H A D | sync_test.cpp | 10 #include <thread> 358 // Spawn a thread to wait on a fence when the timeline is killed. 359 thread waitThread{ 368 // Wait for the thread to spool up. 374 // wait for the thread to clean up. 385 // Spawn a thread to wait on a fence when the timeline is killed. 386 thread waitThread{ 399 // Wait for the thread to spool up. 405 // wait for the thread to clean up. 454 // Wait on the prior thread t [all...] |
/system/bt/doc/ |
H A D | power_management.md | 8 PM code via the BTA workqueue thread. 30 through the BTA workqueue thread and the `bta_dm_pm_btm_status` function. Since 32 controller, timers are used to post messages to the BTA workqueue thread as 147 made through the BTA workqueue thread to `bta_dm_pm_btm_cback`, which then 149 responses are also fired as messages through the BTA workqueue thread, which are 159 `tBTA_DM_PM_BTM_STATUS` struct and posts it to the BTA workqueue thread via 163 **Determine if this is running on the workqueue thread or not** 200 sends off an event to the BTA workqueue thread.
|
/system/bt/osi/ |
H A D | Android.mk | 49 ./src/thread.c
|