| /aosp_15_r20/hardware/google/gfxstream/guest/android-emu/aemu/base/threads/ |
| D | AndroidWorkPool.cpp | 336 Impl(int numInitialThreads) : mThreads(numInitialThreads) { in Impl()
337 for (size_t i = 0; i < mThreads.size(); ++i) { in Impl()
338 mThreads[i].reset(new WorkPoolThread); in Impl()
351 for (size_t i = 0; i < mThreads.size(); ++i) { in schedule()
354 bool cleanup = mThreads[i]->shouldCleanupWaitGroup(&handle, &waitGroup); in schedule()
370 for (size_t i = 0; i < mThreads.size(); ++i) { in schedule()
371 if (!mThreads[i]->acquire()) continue; in schedule()
376 mThreads.resize(mThreads.size() + 1); in schedule()
377 mThreads[mThreads.size() - 1].reset(new WorkPoolThread); in schedule()
383 mThreads[threadIndices[i]]->run(resHandle, waitGroup, tasks[i]); in schedule()
[all …]
|
| /aosp_15_r20/external/apache-http/android/src/android/net/http/ |
| H A D | RequestQueue.java | 65 ConnectionThread[] mThreads; field in RequestQueue.ActivePool
76 mThreads = new ConnectionThread[mConnectionCount]; in ActivePool()
79 mThreads[i] = new ConnectionThread( in ActivePool()
86 mThreads[i].start(); in startup()
92 mThreads[i].requestStop(); in shutdown()
104 ConnectionThread rt = mThreads[i]; in startTiming()
115 ConnectionThread rt = mThreads[i]; in stopTiming()
129 dump.append(mThreads[i] + "\n"); in logState()
144 Connection connection = mThreads[i].mConnection; in disablePersistence()
155 for (int i = 0; i < mThreads.length; i++) { in getThread()
[all …]
|
| /aosp_15_r20/packages/apps/Messaging/src/com/android/messaging/mmslib/util/ |
| D | PduCache.java | 75 private final SimpleArrayMap<Long, HashSet<Uri>> mThreads; field in PduCache
80 mThreads = new SimpleArrayMap<Long, HashSet<Uri>>(); in PduCache()
104 HashSet<Uri> thread = mThreads.get(threadId); in put()
107 mThreads.put(threadId, thread); in put()
179 mThreads.clear(); in purgeAll()
233 HashSet<Uri> thread = mThreads.get(entry.getThreadId()); in removeFromThreads()
244 HashSet<Uri> thread = mThreads.remove(threadId); in purgeByThreadId()
257 HashSet<Uri> msgBox = mThreads.get(Long.valueOf(entry.getMessageBox())); in removeFromMessageBoxes()
|
| /aosp_15_r20/frameworks/base/telephony/common/com/google/android/mms/util/ |
| H A D | PduCache.java | 76 private final HashMap<Long, HashSet<Uri>> mThreads; field in PduCache
82 mThreads = new HashMap<Long, HashSet<Uri>>(); in PduCache()
107 HashSet<Uri> thread = mThreads.get(threadId); in put()
110 mThreads.put(threadId, thread); in put()
185 mThreads.clear(); in purgeAll()
238 HashSet<Uri> thread = mThreads.get(entry.getThreadId()); in removeFromThreads()
249 HashSet<Uri> thread = mThreads.remove(threadId); in purgeByThreadId()
262 HashSet<Uri> msgBox = mThreads.get(Long.valueOf(entry.getMessageBox())); in removeFromMessageBoxes()
|
| /aosp_15_r20/frameworks/base/media/jni/soundpool/ |
| H A D | StreamManager.h | 129 threads = std::move(mThreads); in quit()
130 mThreads.clear(); in quit()
148 for (auto it = mThreads.begin(); it != mThreads.end(); ) { in launch()
151 it = mThreads.erase(it); in launch()
157 const size_t threadCount = mThreads.size(); in launch()
162 mThreads.emplace_back(std::make_unique<JavaThread>( in launch()
193 std::list<std::unique_ptr<JavaThread>> mThreads GUARDED_BY(mThreadLock);
|
| /aosp_15_r20/hardware/interfaces/gnss/aidl/default/ |
| H A D | GnssNavigationMessageInterface.cpp | 33 mThreads.reserve(2); in GnssNavigationMessageInterface()
68 mThreads.emplace_back(std::thread([this]() { in start()
93 for (auto iter = mThreads.begin(); iter != mThreads.end();) { in stop()
104 iter = mThreads.erase(iter); in stop()
|
| H A D | GnssMeasurementInterface.cpp | 39 mThreads.reserve(2); in GnssMeasurementInterface()
109 mThreads.emplace_back(std::thread([this, enableCorrVecOutputs, enableFullTracking]() { in start()
149 for (auto iter = mThreads.begin(); iter != mThreads.end();) { in stop()
160 iter = mThreads.erase(iter); in stop()
|
| H A D | GnssNavigationMessageInterface.h | 43 std::vector<std::thread> mThreads; member
|
| H A D | GnssMeasurementInterface.h | 55 std::vector<std::thread> mThreads; member
|
| /aosp_15_r20/system/extras/simpleperf/app_api/java/com/android/simpleperf/ |
| H A D | RecordOptions.java | 92 mThreads.addAll(threads); in setSampleThreads()
146 if (mThreads.isEmpty()) { in toRecordArgs()
151 for (int i = 0; i < mThreads.size(); i++) { in toRecordArgs()
155 s += mThreads.get(i).toString(); in toRecordArgs()
189 private ArrayList<Integer> mThreads = new ArrayList<>(); field in RecordOptions
|
| /aosp_15_r20/external/angle/src/common/ |
| H A D | WorkerThread.cpp | 110 std::deque<std::thread> mThreads; member in angle::AsyncWorkerPool
128 for (auto &thread : mThreads) in ~AsyncWorkerPool()
137 if (mDesiredThreadCount == mThreads.size()) in createThreads()
141 ASSERT(mThreads.empty()); in createThreads()
145 mThreads.emplace_back(&AsyncWorkerPool::threadLoop, this); in createThreads()
|
| /aosp_15_r20/device/google/trout/hal/vehicle/2.0/ |
| D | GarageModeServerSideHandler.cpp | 47 mThreads.emplace_back(std::bind(&GarageModeServerSideHandlerImpl::PowerStateWatcher, this)); in GarageModeServerSideHandlerImpl()
48 mThreads.emplace_back( in GarageModeServerSideHandlerImpl()
55 for (auto& thread : mThreads) { in ~GarageModeServerSideHandlerImpl()
83 std::vector<std::thread> mThreads; member in android::hardware::automotive::vehicle::V2_0::impl::GarageModeServerSideHandlerImpl
|
| /aosp_15_r20/packages/modules/DnsResolver/tests/ |
| D | resolv_tls_unit_test.cpp | 478 for (auto& thread : mThreads) { in ~FakeSocketLimited()
483 mThreads.clear(); in ~FakeSocketLimited()
502 … mThreads.emplace_back(&IDnsTlsSocketObserver::onResponse, mObserver, make_echo(id, query)); in query()
518 for (auto& thread : mThreads) { in sendClose()
523 mThreads.clear(); in sendClose()
530 std::vector<std::thread> mThreads GUARDED_BY(mLock);
620 … mThreads.emplace_back(&IDnsTlsSocketObserver::onResponse, mObserver, make_query(ID + 1, SIZE)); in FakeSocketGarbage()
624 for (auto& thread : mThreads) { in ~FakeSocketGarbage()
632 mThreads.emplace_back(&IDnsTlsSocketObserver::onResponse, mObserver, echo); in query()
633 mThreads.emplace_back(&IDnsTlsSocketObserver::onResponse, mObserver, echo); in query()
[all …]
|
| /aosp_15_r20/frameworks/av/media/ndk/fuzzer/ |
| H A D | ndk_async_codec_fuzzer.cpp | 166 std::vector<std::thread> mThreads; member in NdkAsyncCodecFuzzer::ThreadPool
195 mThreads.resize(numThreads); in start()
197 mThreads.at(i) = std::thread(&ThreadPool::ThreadLoop, this); in start()
231 for (std::thread& active_thread : mThreads) { in stop()
234 mThreads.clear(); in stop()
|
| /aosp_15_r20/platform_testing/tests/health/scenarios/src/android/platform/test/scenario/generic/ |
| H A D | MathWork.java | 50 public final IntegerOption mThreads = new IntegerOption("math-work-threads").setDefault(20); field in MathWork
60 ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(mThreads.get()); in testDoMath()
61 for (int i = 0; i < mThreads.get(); i++) { in testDoMath()
|
| /aosp_15_r20/frameworks/base/services/usb/java/com/android/server/usb/ |
| H A D | UsbDirectMidiDevice.java | 104 private ArrayList<Thread> mThreads; field in UsbDirectMidiDevice
327 mThreads = new ArrayList<Thread>(); in openLocked()
518 mThreads.add(newThread); in openLocked()
660 mThreads.add(newThread); in openLocked()
738 for (Thread thread : mThreads) { in closeLocked()
745 for (Thread thread : mThreads) { in closeLocked()
755 mThreads = null; in closeLocked()
|
| /aosp_15_r20/frameworks/native/libs/binder/ |
| H A D | RpcSession.cpp | 252 LOG_ALWAYS_FATAL_IF(!mConnections.mThreads.empty(), "Shutdown failed"); in shutdownAndWait()
339 mConnections.mThreads[thread.get_id()] = std::move(thread); in preJoinThreadOwnership()
449 auto it = session->mConnections.mThreads.find(rpc_this_thread::get_id()); in join()
450 LOG_ALWAYS_FATAL_IF(it == session->mConnections.mThreads.end()); in join()
452 session->mConnections.mThreads.erase(it); in join()
|
| /aosp_15_r20/external/cronet/components/cronet/android/test/javatests/src/org/chromium/net/ |
| H A D | RequestFinishedInfoTest.java | 95 private List<Thread> mThreads = new ArrayList<Thread>(); field in RequestFinishedInfoTest.ThreadExecutor
100 mThreads.add(newThread); in execute()
105 for (Thread thread : mThreads) { in joinAll()
|
| /aosp_15_r20/prebuilts/vndk/v31/x86_64/include/frameworks/native/libs/binder/include/binder/ |
| D | RpcSession.h | 200 std::map<std::thread::id, std::thread> mThreads; variable
|
| /aosp_15_r20/prebuilts/vndk/v31/arm64/include/frameworks/native/libs/binder/include/binder/ |
| D | RpcSession.h | 200 std::map<std::thread::id, std::thread> mThreads; variable
|
| /aosp_15_r20/prebuilts/vndk/v31/arm/include/frameworks/native/libs/binder/include/binder/ |
| D | RpcSession.h | 200 std::map<std::thread::id, std::thread> mThreads; variable
|
| /aosp_15_r20/prebuilts/vndk/v32/arm64/include/frameworks/native/libs/binder/include/binder/ |
| D | RpcSession.h | 200 std::map<std::thread::id, std::thread> mThreads; variable
|
| /aosp_15_r20/prebuilts/vndk/v32/arm/include/frameworks/native/libs/binder/include/binder/ |
| D | RpcSession.h | 200 std::map<std::thread::id, std::thread> mThreads; variable
|
| /aosp_15_r20/prebuilts/vndk/v32/x86/include/frameworks/native/libs/binder/include/binder/ |
| D | RpcSession.h | 200 std::map<std::thread::id, std::thread> mThreads; variable
|
| /aosp_15_r20/prebuilts/vndk/v31/x86/include/frameworks/native/libs/binder/include/binder/ |
| D | RpcSession.h | 200 std::map<std::thread::id, std::thread> mThreads; variable
|