| /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/camera/common/default/ |
| D | SimpleThread.cpp | 25 SimpleThread::SimpleThread() : mDone(true), mThread() {} in SimpleThread()
42 mThread = std::thread(&SimpleThread::runLoop, this); in run()
53 if (mThread.joinable()) { in requestExitAndWait()
54 if (mThread.get_id() != std::this_thread::get_id()) { in requestExitAndWait()
55 mThread.join(); in requestExitAndWait()
57 mThread.detach(); in requestExitAndWait()
60 mThread = std::thread(); in requestExitAndWait()
|
| /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/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 …]
|
| /hardware/google/gfxstream/guest/android-emu/aemu/base/threads/ |
| D | AndroidThread_pthread.cpp | 40 : mThread((pthread_t)NULL), mStackSize(stackSize), mFlags(flags) {} in Thread()
47 pthread_join(mThread, nullptr); in ~Thread()
67 if (pthread_create(&mThread, mStackSize ? &attr : nullptr, thread_main, in start()
95 if (!mJoined && pthread_join(mThread, NULL)) { in wait()
119 if (pthread_join(mThread, NULL)) { in tryWait()
|
| D | AndroidThread.h | 113 HANDLE mThread = nullptr; variable
117 pthread_t mThread;
|
| /hardware/google/gfxstream/host/ |
| D | VsyncThread.cpp | 22 mThread([this] { threadFunc(); }) { in VsyncThread()
23 mThread.start();
40 mThread.wait(); in exit()
|
| D | RenderWindow.h | 156 bool useThread() const { return mThread != nullptr; } in useThread()
160 android::base::Thread* mThread = nullptr; variable
|
| /hardware/interfaces/audio/aidl/default/ |
| D | EffectThread.cpp | 35 if (mThread.joinable()) { in createThread()
48 mThread = std::thread(&EffectThread::threadLoop, this); in createThread()
60 if (mThread.joinable()) { in destroyThread()
61 mThread.join(); in destroyThread()
|
| /hardware/interfaces/gnss/common/utils/default/v2_1/ |
| D | GnssAntennaInfo.cpp | 64 mThread = std::thread([this]() { in start()
81 if (mThread.joinable()) { in stop()
82 mThread.join(); in stop()
|
| D | GnssMeasurement.cpp | 94 mThread = std::thread([this]() { in start()
112 if (mThread.joinable()) { in stop()
113 mThread.join(); in stop()
|
| /hardware/google/aemu/base/include/aemu/base/threads/ |
| D | WorkerThread.h | 76 : mProcessor(std::move(processor)), mThread([this]() { worker(); }) { in WorkerThread()
87 if (!mThread.start()) { in start()
101 void join() { mThread.wait(); } in join()
177 base::FunctorThread mThread; variable
|
| D | Thread.h | 119 HANDLE mThread = nullptr; variable
123 pthread_t mThread;
|
| /hardware/interfaces/gnss/2.0/default/ |
| D | GnssMeasurement.cpp | 84 mThread = std::thread([this]() { in start()
97 if (mThread.joinable()) { in stop()
98 mThread.join(); in stop()
|
| /hardware/interfaces/automotive/vehicle/2.0/default/impl/vhal_v2_0/ |
| D | GeneratorHub.cpp | 32 mThread = std::thread(&GeneratorHub::run, this); in GeneratorHub()
44 if (mThread.joinable()) { in ~GeneratorHub()
45 mThread.join(); in ~GeneratorHub()
|
| /hardware/interfaces/biometrics/common/thread/ |
| D | WorkerThread.cpp | 29 mThread(&WorkerThread::threadFunc, this) {} in WorkerThread()
39 mThread.join(); in ~WorkerThread()
|
| /hardware/interfaces/broadcastradio/2.0/default/ |
| D | TunerSession.cpp | 115 mThread.schedule(task, delay::tune); in tune()
137 mThread.schedule(task, delay::seek); in scan()
169 mThread.schedule(task, delay::seek); in scan()
209 mThread.schedule(task, delay::step); in step()
217 mThread.cancelAll(); in cancelLocked()
254 mThread.schedule(task, delay::list); in startProgramListUpdates()
295 mThread.cancelAll(); in close()
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/3/fake_impl/GeneratorHub/src/ |
| D | GeneratorHub.cpp | 33 mThread = std::thread(&GeneratorHub::run, this); in GeneratorHub()
45 if (mThread.joinable()) { in ~GeneratorHub()
46 mThread.join(); in ~GeneratorHub()
|
| /hardware/interfaces/gnss/aidl/default/ |
| D | GnssAntennaInfo.cpp | 65 mThread = std::thread([this]() { in start()
129 if (mThread.joinable()) { in stop()
130 mThread.join(); in stop()
|
| D | GnssBatching.cpp | 70 mThread = std::thread([this]() { in start()
100 if (mThread.joinable()) { in stop()
101 mThread.join(); in stop()
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/current/fake_impl/GeneratorHub/src/ |
| D | GeneratorHub.cpp | 33 mThread = std::thread(&GeneratorHub::run, this); in GeneratorHub()
45 if (mThread.joinable()) { in ~GeneratorHub()
46 mThread.join(); in ~GeneratorHub()
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/3/utils/common/src/ |
| D | RecurrentTimer.cpp | 42 mThread = std::thread([this] { in RecurrentTimer()
55 if (mThread.joinable()) { in ~RecurrentTimer()
56 mThread.join(); in ~RecurrentTimer()
|
| /hardware/interfaces/automotive/vehicle/aidl/impl/current/utils/common/src/ |
| D | RecurrentTimer.cpp | 42 mThread = std::thread([this] { in RecurrentTimer()
55 if (mThread.joinable()) { in ~RecurrentTimer()
56 mThread.join(); in ~RecurrentTimer()
|