| /hardware/interfaces/broadcastradio/common/tests/ |
| D | WorkerThread_test.cpp | 42 WorkerThread thread; in TEST() local
45 thread.schedule( in TEST()
62 WorkerThread thread; in TEST() local
64 thread.schedule([&]() { executed2 = true; }, 100ms); in TEST()
65 thread.schedule([&]() { executed1 = true; }, 25ms); in TEST()
68 thread.cancelAll(); in TEST()
78 WorkerThread thread; in TEST() local
80 thread.schedule( in TEST()
87 thread.schedule( in TEST()
94 thread.schedule( in TEST()
[all …]
|
| /hardware/qcom/camera/msm8998/QCamera2/HAL3/test/ |
| D | QCameraHAL3Test.cpp | 38 buffer_thread_t thread; variable
158 pthread_mutex_init(&thread.mutex, NULL); in processThreadCreate()
159 pthread_cond_init(&thread.cond, NULL); in processThreadCreate()
161 thread.is_thread_started = 0; in processThreadCreate()
162 thread.readfd = pfd[0]; in processThreadCreate()
163 thread.writefd = pfd[1]; in processThreadCreate()
164 thread.data_obj = obj; in processThreadCreate()
165 thread.testcase = testcase; in processThreadCreate()
166 pthread_mutex_lock(&thread.mutex); in processThreadCreate()
167 ret = pthread_create(&thread.td, &attr, processBuffers, &thread ); in processThreadCreate()
[all …]
|
| D | QCameraHAL3SnapshotTest.cpp | 174 buffer_thread_t thread; in snapshotThreadCreate() local
181 pthread_mutex_init(&thread.mutex, NULL); in snapshotThreadCreate()
182 pthread_cond_init(&thread.cond, NULL); in snapshotThreadCreate()
183 thread.is_thread_started = 0; in snapshotThreadCreate()
184 thread.readfd = pfd[0]; in snapshotThreadCreate()
185 thread.writefd = pfd[1]; in snapshotThreadCreate()
186 thread.data_obj = this; in snapshotThreadCreate()
187 ret = pthread_create(&thread.td, &attr, hal3_thread_ops, &thread ); in snapshotThreadCreate()
188 pthread_setname_np(thread.td, "TestApp_Thread"); in snapshotThreadCreate()
193 pthread_mutex_lock(&thread.mutex); in snapshotThreadCreate()
[all …]
|
| D | QCameraHAL3RawSnapshotTest.cpp | 177 buffer_thread_t thread; in rawProcessThreadCreate() local
184 pthread_mutex_init(&thread.mutex, NULL); in rawProcessThreadCreate()
185 pthread_cond_init(&thread.cond, NULL); in rawProcessThreadCreate()
186 thread.is_thread_started = 0; in rawProcessThreadCreate()
187 thread.readfd = pfd[0]; in rawProcessThreadCreate()
188 thread.writefd = pfd[1]; in rawProcessThreadCreate()
189 thread.data_obj = this; in rawProcessThreadCreate()
190 ret = pthread_create(&thread.td, &attr, hal3_thread_ops, &thread ); in rawProcessThreadCreate()
191 pthread_setname_np(thread.td, "TestApp_Thread"); in rawProcessThreadCreate()
196 pthread_mutex_lock(&thread.mutex); in rawProcessThreadCreate()
[all …]
|
| /hardware/interfaces/wifi/1.4/default/ |
| D | THREADING.README | 4 1. HIDL thread: This is the main thread which processes all the incoming HIDL
6 2. Legacy HAL event loop thread: This is the thread forked off for processing
7 the legacy HAL event loop (wifi_event_loop()). This thread is used to process
9 callbacks passed to the legacy HAL API's are invoked on this thread.
17 thread when they are no longer used. For example: stopGscan() will reset the
19 was invoked. This is not thread safe since these callback variables are
20 accesed from the legacy hal event loop thread as well.
32 synchronous callbacks are invoked on the same invocation thread. If that is not
34 HIDL thread would have acquired the global lock which is needed by the
35 synchronous callback executed on the legacy hal event loop thread.
|
| /hardware/qcom/sm8150p/gps/utils/ |
| D | LocThread.cpp | 115 LocThreadDelegate* thread = NULL; in create() local
117 thread = new LocThreadDelegate(creator, threadName, runnable, joinable); in create()
118 if (thread && !thread->isRunning()) { in create()
119 thread->destroy(); in create()
120 thread = NULL; in create()
124 return thread; in create()
254 LocThread thread; in main() local
255 thread.start("LocThreadTest", test, atoi(argv[1])); in main()
259 thread.stop(); in main()
|
| D | MsgTask.cpp | 66 LocThread* thread = mThread; in destroy() local
68 if (thread) { in destroy()
70 delete thread; in destroy()
|
| /hardware/qcom/sm8150/gps/utils/ |
| D | LocThread.cpp | 115 LocThreadDelegate* thread = NULL; in create() local
117 thread = new LocThreadDelegate(creator, threadName, runnable, joinable); in create()
118 if (thread && !thread->isRunning()) { in create()
119 thread->destroy(); in create()
120 thread = NULL; in create()
124 return thread; in create()
254 LocThread thread; in main() local
255 thread.start("LocThreadTest", test, atoi(argv[1])); in main()
259 thread.stop(); in main()
|
| /hardware/qcom/gps/msm8998/utils/ |
| D | LocThread.cpp | 115 LocThreadDelegate* thread = NULL; in create() local
117 thread = new LocThreadDelegate(creator, threadName, runnable, joinable); in create()
118 if (thread && !thread->isRunning()) { in create()
119 thread->destroy(); in create()
120 thread = NULL; in create()
124 return thread; in create()
254 LocThread thread; in main() local
255 thread.start("LocThreadTest", test, atoi(argv[1])); in main()
259 thread.stop(); in main()
|
| D | MsgTask.cpp | 65 LocThread* thread = mThread; in destroy() local
67 if (thread) { in destroy()
69 delete thread; in destroy()
|
| /hardware/qcom/sdm845/gps/msm8996/utils/ |
| D | LocThread.cpp | 113 LocThreadDelegate* thread = NULL; in create() local
115 thread = new LocThreadDelegate(creator, threadName, runnable, joinable); in create()
116 if (thread && !thread->isRunning()) { in create()
117 thread->destroy(); in create()
118 thread = NULL; in create()
122 return thread; in create()
252 LocThread thread; in main() local
253 thread.start("LocThreadTest", test, atoi(argv[1])); in main()
257 thread.stop(); in main()
|
| D | MsgTask.cpp | 66 LocThread* thread = mThread; in destroy() local
68 if (thread) { in destroy()
70 delete thread; in destroy()
|
| /hardware/qcom/sdm845/gps/msm8998/utils/ |
| D | LocThread.cpp | 115 LocThreadDelegate* thread = NULL; in create() local
117 thread = new LocThreadDelegate(creator, threadName, runnable, joinable); in create()
118 if (thread && !thread->isRunning()) { in create()
119 thread->destroy(); in create()
120 thread = NULL; in create()
124 return thread; in create()
254 LocThread thread; in main() local
255 thread.start("LocThreadTest", test, atoi(argv[1])); in main()
259 thread.stop(); in main()
|
| D | MsgTask.cpp | 65 LocThread* thread = mThread; in destroy() local
67 if (thread) { in destroy()
69 delete thread; in destroy()
|
| /hardware/qcom/sdm845/gps/sdm845/utils/ |
| D | LocThread.cpp | 115 LocThreadDelegate* thread = NULL; in create() local
117 thread = new LocThreadDelegate(creator, threadName, runnable, joinable); in create()
118 if (thread && !thread->isRunning()) { in create()
119 thread->destroy(); in create()
120 thread = NULL; in create()
124 return thread; in create()
254 LocThread thread; in main() local
255 thread.start("LocThreadTest", test, atoi(argv[1])); in main()
259 thread.stop(); in main()
|
| D | MsgTask.cpp | 67 LocThread* thread = mThread; in destroy() local
69 if (thread) { in destroy()
71 delete thread; in destroy()
|
| /hardware/qcom/gps/msm8996/utils/ |
| D | LocThread.cpp | 113 LocThreadDelegate* thread = NULL; in create() local
115 thread = new LocThreadDelegate(creator, threadName, runnable, joinable); in create()
116 if (thread && !thread->isRunning()) { in create()
117 thread->destroy(); in create()
118 thread = NULL; in create()
122 return thread; in create()
252 LocThread thread; in main() local
253 thread.start("LocThreadTest", test, atoi(argv[1])); in main()
257 thread.stop(); in main()
|
| D | MsgTask.cpp | 66 LocThread* thread = mThread; in destroy() local
68 if (thread) { in destroy()
70 delete thread; in destroy()
|
| /hardware/qcom/gps/msm8909/utils/ |
| D | LocThread.cpp | 113 LocThreadDelegate* thread = NULL; in create() local
115 thread = new LocThreadDelegate(creator, threadName, runnable, joinable); in create()
116 if (thread && !thread->isRunning()) { in create()
117 thread->destroy(); in create()
118 thread = NULL; in create()
122 return thread; in create()
252 LocThread thread; in main() local
253 thread.start("LocThreadTest", test, atoi(argv[1])); in main()
257 thread.stop(); in main()
|
| D | MsgTask.cpp | 66 LocThread* thread = mThread; in destroy() local
68 if (thread) { in destroy()
70 delete thread; in destroy()
|
| /hardware/qcom/sm7150/gps/utils/ |
| D | LocThread.cpp | 115 LocThreadDelegate* thread = NULL; in create() local
117 thread = new LocThreadDelegate(creator, threadName, runnable, joinable); in create()
118 if (thread && !thread->isRunning()) { in create()
119 thread->destroy(); in create()
120 thread = NULL; in create()
124 return thread; in create()
254 LocThread thread; in main() local
255 thread.start("LocThreadTest", test, atoi(argv[1])); in main()
259 thread.stop(); in main()
|
| D | MsgTask.cpp | 66 LocThread* thread = mThread; in destroy() local
68 if (thread) { in destroy()
70 delete thread; in destroy()
|
| /hardware/qcom/gps/msm8909w_3100/utils/ |
| D | LocThread.cpp | 115 LocThreadDelegate* thread = NULL; in create() local
117 thread = new LocThreadDelegate(creator, threadName, runnable, joinable); in create()
118 if (thread && !thread->isRunning()) { in create()
119 thread->destroy(); in create()
120 thread = NULL; in create()
124 return thread; in create()
254 LocThread thread; in main() local
255 thread.start("LocThreadTest", test, atoi(argv[1])); in main()
259 thread.stop(); in main()
|
| D | MsgTask.cpp | 65 LocThread* thread = mThread; in destroy() local
67 if (thread) { in destroy()
69 delete thread; in destroy()
|
| /hardware/qcom/sdm845/gps/msm8909/utils/ |
| D | MsgTask.cpp | 66 LocThread* thread = mThread; in destroy() local
68 if (thread) { in destroy()
70 delete thread; in destroy()
|