| /hardware/qcom/gps/msm8996/utils/ |
| D | MsgTask.cpp | 45 mQ(msg_q_init2()), mThread(new LocThread()) { in MsgTask()
46 if (!mThread->start(tCreator, threadName, this, joinable)) { in MsgTask()
47 delete mThread; in MsgTask()
48 mThread = NULL; in MsgTask()
53 mQ(msg_q_init2()), mThread(new LocThread()) { in MsgTask()
54 if (!mThread->start(threadName, this, joinable)) { in MsgTask()
55 delete mThread; in MsgTask()
56 mThread = NULL; in MsgTask()
66 LocThread* thread = mThread; in destroy()
69 mThread = NULL; in destroy()
|
| D | LocThread.cpp | 205 if (mThread) { in ~LocThread()
206 mThread->bye(); in ~LocThread()
207 mThread = NULL; in ~LocThread()
213 if (!mThread) { in start()
214 mThread = LocThreadDelegate::create(creator, threadName, runnable, joinable); in start()
216 success = (NULL != mThread); in start()
222 if (mThread) { in stop()
223 mThread->stop(); in stop()
224 mThread = NULL; in stop()
|
| D | LocThread.h | 63 LocThreadDelegate* mThread; variable
65 inline LocThread() : mThread(NULL) {} in LocThread()
89 inline bool isRunning() { return NULL != mThread; } in isRunning()
|
| /hardware/qcom/gps/msm8998/utils/ |
| D | MsgTask.cpp | 44 mQ(msg_q_init2()), mThread(new LocThread()) { in MsgTask()
45 if (!mThread->start(tCreator, threadName, this, joinable)) { in MsgTask()
46 delete mThread; in MsgTask()
47 mThread = NULL; in MsgTask()
52 mQ(msg_q_init2()), mThread(new LocThread()) { in MsgTask()
53 if (!mThread->start(threadName, this, joinable)) { in MsgTask()
54 delete mThread; in MsgTask()
55 mThread = NULL; in MsgTask()
65 LocThread* thread = mThread; in destroy()
68 mThread = NULL; in destroy()
|
| D | LocThread.cpp | 207 if (mThread) { in ~LocThread()
208 mThread->bye(); in ~LocThread()
209 mThread = NULL; in ~LocThread()
215 if (!mThread) { in start()
216 mThread = LocThreadDelegate::create(creator, threadName, runnable, joinable); in start()
218 success = (NULL != mThread); in start()
224 if (mThread) { in stop()
225 mThread->stop(); in stop()
226 mThread = NULL; in stop()
|
| /hardware/qcom/gps/msm8909w_3100/utils/ |
| D | MsgTask.cpp | 44 mQ(msg_q_init2()), mThread(new LocThread()) { in MsgTask()
45 if (!mThread->start(tCreator, threadName, this, joinable)) { in MsgTask()
46 delete mThread; in MsgTask()
47 mThread = NULL; in MsgTask()
52 mQ(msg_q_init2()), mThread(new LocThread()) { in MsgTask()
53 if (!mThread->start(threadName, this, joinable)) { in MsgTask()
54 delete mThread; in MsgTask()
55 mThread = NULL; in MsgTask()
65 LocThread* thread = mThread; in destroy()
68 mThread = NULL; in destroy()
|
| D | LocThread.cpp | 207 if (mThread) { in ~LocThread()
208 mThread->bye(); in ~LocThread()
209 mThread = NULL; in ~LocThread()
215 if (!mThread) { in start()
216 mThread = LocThreadDelegate::create(creator, threadName, runnable, joinable); in start()
218 success = (NULL != mThread); in start()
224 if (mThread) { in stop()
225 mThread->stop(); in stop()
226 mThread = NULL; in stop()
|
| /hardware/qcom/gps/msm8909/utils/ |
| D | MsgTask.cpp | 45 mQ(msg_q_init2()), mThread(new LocThread()) { in MsgTask()
46 if (!mThread->start(tCreator, threadName, this, joinable)) { in MsgTask()
47 delete mThread; in MsgTask()
48 mThread = NULL; in MsgTask()
53 mQ(msg_q_init2()), mThread(new LocThread()) { in MsgTask()
54 if (!mThread->start(threadName, this, joinable)) { in MsgTask()
55 delete mThread; in MsgTask()
56 mThread = NULL; in MsgTask()
66 LocThread* thread = mThread; in destroy()
69 mThread = NULL; in destroy()
|
| D | LocThread.cpp | 205 if (mThread) { in ~LocThread()
206 mThread->bye(); in ~LocThread()
207 mThread = NULL; in ~LocThread()
213 if (!mThread) { in start()
214 mThread = LocThreadDelegate::create(creator, threadName, runnable, joinable); in start()
216 success = (NULL != mThread); in start()
222 if (mThread) { in stop()
223 mThread->stop(); in stop()
224 mThread = NULL; in stop()
|
| D | LocThread.h | 63 LocThreadDelegate* mThread; variable
65 inline LocThread() : mThread(NULL) {} in LocThread()
89 inline bool isRunning() { return NULL != mThread; } in isRunning()
|
| /hardware/qcom/sm8150p/gps/utils/ |
| D | MsgTask.cpp | 45 mQ(msg_q_init2()), mThread(new LocThread()) { in MsgTask()
46 if (!mThread->start(tCreator, threadName, this, joinable)) { in MsgTask()
47 delete mThread; in MsgTask()
48 mThread = NULL; in MsgTask()
53 mQ(msg_q_init2()), mThread(new LocThread()) { in MsgTask()
54 if (!mThread->start(threadName, this, joinable)) { in MsgTask()
55 delete mThread; in MsgTask()
56 mThread = NULL; in MsgTask()
66 LocThread* thread = mThread; in destroy()
69 mThread = NULL; in destroy()
|
| D | LocThread.cpp | 207 if (mThread) { in ~LocThread()
208 mThread->bye(); in ~LocThread()
209 mThread = NULL; in ~LocThread()
215 if (!mThread) { in start()
216 mThread = LocThreadDelegate::create(creator, threadName, runnable, joinable); in start()
218 success = (NULL != mThread); in start()
224 if (mThread) { in stop()
225 mThread->stop(); in stop()
226 mThread = NULL; in stop()
|
| /hardware/qcom/sm7150/gps/utils/ |
| D | MsgTask.cpp | 45 mQ(msg_q_init2()), mThread(new LocThread()) { in MsgTask()
46 if (!mThread->start(tCreator, threadName, this, joinable)) { in MsgTask()
47 delete mThread; in MsgTask()
48 mThread = NULL; in MsgTask()
53 mQ(msg_q_init2()), mThread(new LocThread()) { in MsgTask()
54 if (!mThread->start(threadName, this, joinable)) { in MsgTask()
55 delete mThread; in MsgTask()
56 mThread = NULL; in MsgTask()
66 LocThread* thread = mThread; in destroy()
69 mThread = NULL; in destroy()
|
| D | LocThread.cpp | 207 if (mThread) { in ~LocThread()
208 mThread->bye(); in ~LocThread()
209 mThread = NULL; in ~LocThread()
215 if (!mThread) { in start()
216 mThread = LocThreadDelegate::create(creator, threadName, runnable, joinable); in start()
218 success = (NULL != mThread); in start()
224 if (mThread) { in stop()
225 mThread->stop(); in stop()
226 mThread = NULL; in stop()
|
| D | LocThread.h | 63 LocThreadDelegate* mThread; variable
65 inline LocThread() : mThread(NULL) {} in LocThread()
89 inline bool isRunning() { return NULL != mThread; } in isRunning()
|
| /hardware/google/aemu/base/include/aemu/base/testing/ |
| D | TestThread.h | 41 mThread = CreateThread(NULL,
51 pthread_create(&mThread, &attr, func, funcParam);
58 CloseHandle(mThread); in ~TestThread()
64 WaitForSingleObject(mThread, INFINITE); in join()
66 ::GetExitCodeThread(mThread, &ret); in join()
69 pthread_join(mThread, &ret); in join()
76 HANDLE mThread;
78 pthread_t mThread;
|
| /hardware/interfaces/audio/aidl/common/include/ |
| D | StreamWorker.h | 136 explicit StreamWorker(Args&&... args) : LogicImpl(std::forward<Args>(args)...), mThread(this) {} in StreamWorker()
147 return mThread.start(name, priority);
149 void pause() { mThread.pause(); } in pause()
150 void resume() { mThread.resume(); } in resume()
151 bool hasError() { return mThread.hasError(); } in hasError()
152 std::string getError() { return mThread.getError(); } in getError()
153 pid_t getTid() { return mThread.getTid(); } in getTid()
154 void stop() { mThread.stop(); } in stop()
155 void join() { mThread.join(); } in join()
156 bool waitForAtLeastOneCycle() { return mThread.waitForAtLeastOneCycle(); } in waitForAtLeastOneCycle()
[all …]
|
| /hardware/qcom/sm8150/gps/utils/ |
| D | LocThread.cpp | 46 thread mThread; member in loc_util::LocThreadDelegate
82 mThread([tName, runnable] { in LocThreadDelegate()
89 mThread.detach();
96 if (!mThread) { in start()
97 mThread = LocThreadDelegate::create(tName, runnable); in start()
99 success = (NULL != mThread); in start()
105 if (nullptr != mThread) { in stop()
106 delete mThread; in stop()
107 mThread = nullptr; in stop()
|
| D | LocThread.h | 71 LocThreadDelegate* mThread; variable
73 inline LocThread() : mThread(NULL) {} in LocThread()
91 inline bool isRunning() { return NULL != mThread; } in isRunning()
|
| /hardware/qcom/sm7250/gps/utils/ |
| D | LocThread.cpp | 46 thread mThread; member in loc_util::LocThreadDelegate
82 mThread([tName, runnable] { in LocThreadDelegate()
89 mThread.detach();
96 if (!mThread) { in start()
97 mThread = LocThreadDelegate::create(tName, runnable); in start()
99 success = (NULL != mThread); in start()
105 if (nullptr != mThread) { in stop()
106 delete mThread; in stop()
107 mThread = nullptr; in stop()
|
| D | LocThread.h | 71 LocThreadDelegate* mThread; variable
73 inline LocThread() : mThread(NULL) {} in LocThread()
91 inline bool isRunning() { return NULL != mThread; } in isRunning()
|
| /hardware/interfaces/camera/common/default/ |
| D | SimpleThread.cpp | 25 SimpleThread::SimpleThread() : mDone(true), mThread() {} in SimpleThread()
38 mThread = std::thread(&SimpleThread::runLoop, this); in run()
47 if (mThread.joinable()) { in requestExitAndWait()
48 mThread.join(); in requestExitAndWait()
50 mThread = std::thread(); in requestExitAndWait()
|
| /hardware/google/aemu/base/ |
| D | Thread_win32.cpp | 31 if (mThread) { in ~Thread()
33 CloseHandle(mThread); in ~Thread()
45 mThread = CreateThread(NULL, mStackSize, &Thread::thread_main, this, 0, in start()
47 if (!mThread) { in start()
60 HRESULT res = SetThreadDescription(mThread, name.c_str()); in start()
64 DWORD threadId = GetThreadId(mThread); in start()
90 if (WaitForSingleObject(mThread, INFINITE) == WAIT_FAILED) { in wait()
106 if (!mFinished || WaitForSingleObject(mThread, 0) != WAIT_OBJECT_0) { in tryWait()
|
| D | Thread_pthread.cpp | 30 … : mThread((pthread_t)NULL), mStackSize(stackSize), mFlags(flags), mNameOpt(std::move(nameOpt)) {} in Thread()
37 pthread_join(mThread, nullptr); in ~Thread()
57 if (pthread_create(&mThread, mStackSize ? &attr : nullptr, thread_main, in start()
73 pthread_setname_np(mThread, (*mNameOpt).c_str()); in start()
92 if (!mJoined && pthread_join(mThread, NULL)) { in wait()
116 if (pthread_join(mThread, NULL)) { in tryWait()
|
| /hardware/interfaces/biometrics/face/aidl/default/ |
| D | Session.cpp | 43 mThread = std::make_unique<WorkerThread>(MAX_WORKER_QUEUE_SIZE); in Session()
53 mThread->schedule(Callable::from([this] { mEngine->generateChallengeImpl(mCb.get()); })); in generateChallenge()
59 mThread->schedule(Callable::from( in revokeChallenge()
78 mThread->schedule(Callable::from( in enroll()
94 mThread->schedule( in authenticate()
109 mThread->schedule(Callable::from([this, cancFuture = std::move(cancFuture)] { in detectInteraction()
119 mThread->schedule(Callable::from([this] { mEngine->enumerateEnrollmentsImpl(mCb.get()); })); in enumerateEnrollments()
125 mThread->schedule(Callable::from( in removeEnrollments()
132 mThread->schedule(Callable::from([this] { mEngine->getFeaturesImpl(mCb.get()); })); in getFeatures()
139 mThread->schedule(Callable::from([this, hat, feature, enabled] { in setFeature()
[all …]
|