/frameworks/native/services/surfaceflinger/tests/ |
H A D | Stress_test.cpp | 23 #include <thread> 41 std::vector<std::thread> threads; 43 threads.push_back(std::thread(do_stress)); 45 for (auto& thread : threads) { 46 thread.join();
|
/frameworks/base/core/java/com/android/internal/view/ |
H A D | WindowManagerPolicyThread.java | 22 * Static storage of the thread running the window manager policy, to 29 public static void set(Thread thread, Looper looper) { argument 30 mThread = thread;
|
/frameworks/support/compat/tests/java/android/support/v4/provider/ |
H A D | SelfDestructiveThreadTest.java | 49 private void waitUntilDestruction(SelfDestructiveThread thread, long timeoutMs) { argument 50 if (!thread.isRunning()) { 62 if (!thread.isRunning()) { 66 throw new RuntimeException("Timeout for waiting thread destruction."); 87 final SelfDestructiveThread thread = new SelfDestructiveThread( 89 thread.postAndWait(new Callable<Object>() { 95 waitUntilDestruction(thread, DEFAULT_TIMEOUT); 96 assertFalse(thread.isRunning()); 102 final SelfDestructiveThread thread = new SelfDestructiveThread( 104 Integer generation = thread [all...] |
/frameworks/opt/bitmap/src/com/android/bitmap/ |
H A D | NamedThreadFactory.java | 35 final Thread thread = mDefaultThreadFactory.newThread(runnable); 36 thread.setName(mBaseName + "-" + mCount.getAndIncrement()); 37 return thread;
|
/frameworks/base/libs/hwui/pipeline/skia/ |
H A D | SkiaOpenGLReadback.h | 27 SkiaOpenGLReadback(renderthread::RenderThread& thread) : OpenGLReadback(thread) {} argument
|
H A D | SkiaOpenGLPipeline.cpp | 38 SkiaOpenGLPipeline::SkiaOpenGLPipeline(RenderThread& thread) argument 39 : SkiaPipeline(thread) 40 , mEglManager(thread.eglManager()) { 186 void SkiaOpenGLPipeline::invokeFunctor(const RenderThread& thread, Functor* functor) { argument 188 if (thread.eglManager().hasEglContext()) { 196 thread.getGrContext()->resetContext();
|
/frameworks/av/media/mtp/ |
H A D | AsyncIO.h | 27 #include <thread> 48 std::thread thread; member in struct:aiocb 61 // Suspend current thread until given IO is complete, at which point 76 // Suspend current thread until all queued work is complete, then ends the threadpool
|
H A D | AsyncIO.cpp | 95 std::thread pool[NUM_THREADS]; 100 CHECK(!thread.joinable()); 107 pool[i] = std::thread(f, i); 143 aiocbp->thread = std::thread(read_func, aiocbp); 148 aiocbp->thread = std::thread(write_func, aiocbp); 153 aiocbp->thread = std::thread(splice_read_func, aiocbp); 158 aiocbp->thread [all...] |
/frameworks/base/core/tests/coretests/src/android/content/ |
H A D | ContentQueryMapTest.java | 36 /** Helper class to run test code in a new thread with a Looper. */ 56 LooperThread thread = new LooperThread() { 101 thread.start(); 102 thread.join(); 103 if (thread.mError != null) throw thread.mError; 104 assertTrue(thread.mSuccess);
|
/frameworks/base/libs/hwui/ |
H A D | Readback.h | 49 explicit Readback(renderthread::RenderThread& thread) : mRenderThread(thread) {} argument
|
H A D | OpenGLReadback.h | 35 explicit OpenGLReadback(renderthread::RenderThread& thread) : Readback(thread) {} argument 47 OpenGLReadbackImpl(renderthread::RenderThread& thread) : OpenGLReadback(thread) {} argument
|
/frameworks/native/services/vr/performanced/ |
H A D | performance_service_tests.cpp | 6 #include <thread> 27 std::thread thread([&] { 50 thread.join(); 53 // the task id of the thread that we just joined. Technically the 97 std::thread thread([&]() { scheduler = sched_getscheduler(0); }); 98 thread.join();
|
/frameworks/native/services/sensorservice/ |
H A D | SensorRegistrationInfo.h | 46 IPCThreadState *thread = IPCThreadState::self(); local 47 mPid = (thread != nullptr) ? thread->getCallingPid() : -1; 48 mUid = (thread != nullptr) ? thread->getCallingUid() : -1;
|
/frameworks/base/libs/hwui/renderthread/ |
H A D | RenderProxy.cpp | 63 CREATE_BRIDGE4(createContext, RenderThread* thread, bool translucent, argument 65 return CanvasContext::create(*args->thread, args->translucent, 75 args->thread = &mRenderThread; 249 // the render thread. 253 CREATE_BRIDGE2(invokeFunctor, RenderThread* thread, Functor* functor) { argument 254 CanvasContext::invokeFunctor(*args->thread, args->functor); 260 RenderThread& thread = RenderThread::getInstance(); local 262 args->thread = &thread; 270 thread 342 CREATE_BRIDGE2(trimMemory, RenderThread* thread, int level) argument 350 RenderThread& thread = RenderThread::getInstance(); local 412 CREATE_BRIDGE4(dumpProfileInfo, CanvasContext* context, RenderThread* thread, int fd, int dumpFlags) argument 447 CREATE_BRIDGE2(frameTimePercentile, RenderThread* thread, int percentile) argument 460 CREATE_BRIDGE2(dumpGraphicsMemory, int fd, RenderThread* thread) argument 484 CREATE_BRIDGE2(setProcessStatsBuffer, RenderThread* thread, int fd) argument 498 CREATE_BRIDGE1(rotateProcessStatsBuffer, RenderThread* thread) argument 617 CREATE_BRIDGE4(copySurfaceInto, RenderThread* thread, Surface* surface, Rect srcRect, SkBitmap* bitmap) argument 634 CREATE_BRIDGE2(prepareToDraw, RenderThread* thread, Bitmap* bitmap) argument 667 CREATE_BRIDGE2(allocateHardwareBitmap, RenderThread* thread, SkBitmap* bitmap) argument 680 CREATE_BRIDGE3(copyGraphicBufferInto, RenderThread* thread, GraphicBuffer* buffer, SkBitmap* bitmap) argument 685 RenderThread& thread = RenderThread::getInstance(); local 698 CREATE_BRIDGE2(onBitmapDestroyed, RenderThread* thread, uint32_t pixelRefId) argument 706 RenderThread& thread = RenderThread::getInstance(); local 733 RenderThread& thread = RenderThread::getInstance(); local [all...] |
/frameworks/native/libs/vr/libvrflinger/ |
H A D | epoll_event_dispatcher.h | 9 #include <thread> 29 // |handler| is called on the internal dispatch thread when |fd| is signaled 39 std::thread thread_; 53 // by the event dispatch thread to avoid races.
|
/frameworks/minikin/tests/stresstest/ |
H A D | MultithreadTest.cpp | 22 #include <thread> 92 std::vector<std::thread> threads; 104 for (auto& thread : threads) { 105 thread.join();
|
/frameworks/base/core/java/android/app/ |
H A D | IntentService.java | 33 * thread, and stops itself when it runs out of work. 36 * from an application's main thread. The IntentService class exists to 39 * will receive the Intents, launch a worker thread, and stop the service as 42 * <p>All requests are handled on a single worker thread -- they may take as 76 * @param name Used to name the worker thread, important only for debugging. 110 HandlerThread thread = new HandlerThread("IntentService[" + mName + "]"); 111 thread.start(); 113 mServiceLooper = thread.getLooper(); 154 * This method is invoked on the worker thread with a request to process. 156 * worker thread tha [all...] |
/frameworks/support/emoji/bundled/src/android/support/text/emoji/bundled/ |
H A D | BundledEmojiCompatConfig.java | 58 final Thread thread = new Thread(runnable); 59 thread.setDaemon(false); 60 thread.start();
|
/frameworks/native/cmds/lshal/ |
H A D | Timeout.h | 21 #include <thread> 67 pthread_t thread; local 68 if (pthread_create(&thread, NULL, callAndNotify, &state)) { 69 std::cerr << "FATAL: could not create background thread." << std::endl; 74 pthread_kill(thread, SIGINT); 76 pthread_join(thread, NULL);
|
/frameworks/opt/telephony/src/java/com/google/android/mms/util/ |
H A D | PduCache.java | 104 HashSet<Uri> thread = mThreads.get(threadId); 105 if (thread == null) { 106 thread = new HashSet<Uri>(); 107 mThreads.put(threadId, thread); 114 thread.add(finalKey); 232 HashSet<Uri> thread = mThreads.get(entry.getThreadId()); 233 if (thread != null) { 234 thread.remove(key); 240 Log.v(TAG, "Purge cache in thread: " + threadId); 243 HashSet<Uri> thread [all...] |
/frameworks/av/services/audioflinger/ |
H A D | Tracks.cpp | 67 ThreadBase *thread, 81 mThread(thread), 100 mThreadIoHandle(thread->id()), 158 const sp<MemoryDealer> roHeap(thread->readOnlyHeap()); 173 mBufferMemory = thread->pipeMemory(); 297 // will be freed from the main thread once all pending buffers have 363 PlaybackThread *thread, 377 : TrackBase(thread, client, sampleRate, format, channelMask, frameCount, 387 mMainBuffer(thread->mixBuffer()), 434 mName = thread 66 TrackBase( ThreadBase *thread, const sp<Client>& client, uint32_t sampleRate, audio_format_t format, audio_channel_mask_t channelMask, size_t frameCount, void *buffer, audio_session_t sessionId, uid_t clientUid, bool isOut, alloc_type alloc, track_type type, audio_port_handle_t portId) argument 362 Track( PlaybackThread *thread, const sp<Client>& client, audio_stream_type_t streamType, uint32_t sampleRate, audio_format_t format, audio_channel_mask_t channelMask, size_t frameCount, void *buffer, const sp<IMemory>& sharedBuffer, audio_session_t sessionId, uid_t uid, audio_output_flags_t flags, track_type type, audio_port_handle_t portId) argument 492 sp<ThreadBase> thread = mThread.promote(); local 686 sp<ThreadBase> thread = mThread.promote(); local 763 sp<ThreadBase> thread = mThread.promote(); local 795 sp<ThreadBase> thread = mThread.promote(); local 826 sp<ThreadBase> thread = mThread.promote(); local 914 sp<ThreadBase> thread = mThread.promote(); local 950 sp<ThreadBase> thread = mThread.promote(); local 972 sp<ThreadBase> thread = mThread.promote(); local 985 sp<ThreadBase> thread = mThread.promote(); local 1156 sp<ThreadBase> thread = mThread.promote(); local 1365 sp<ThreadBase> thread = mThread.promote(); local 1562 RecordTrack( RecordThread *thread, const sp<Client>& client, uint32_t sampleRate, audio_format_t format, audio_channel_mask_t channelMask, size_t frameCount, void *buffer, audio_session_t sessionId, uid_t uid, audio_input_flags_t flags, track_type type, audio_port_handle_t portId) argument 1650 sp<ThreadBase> thread = mThread.promote(); local 1661 sp<ThreadBase> thread = mThread.promote(); local 1681 sp<ThreadBase> thread = mThread.promote(); local 1831 MmapTrack(ThreadBase *thread, uint32_t sampleRate, audio_format_t format, audio_channel_mask_t channelMask, audio_session_t sessionId, uid_t uid, audio_port_handle_t portId) argument [all...] |
H A D | PatchPanel.cpp | 264 sp<ThreadBase> thread = local 266 newPatch->mPlaybackThread = (MixerThread *)thread.get(); 267 if (thread == 0) { 268 ALOGW("createAudioPatch() cannot get playback thread"); 277 sp<ThreadBase> thread = audioflinger->openOutput_l( local 284 newPatch->mPlaybackThread = (PlaybackThread *)thread.get(); 314 sp<ThreadBase> thread = audioflinger->openInput_l(srcModule, local 321 newPatch->mRecordThread = (RecordThread *)thread.get(); 334 sp<ThreadBase> thread = audioflinger->checkRecordThread_l( local 336 if (thread 381 sp<ThreadBase> thread = local 614 sp<ThreadBase> thread = audioflinger->checkRecordThread_l( local 640 sp<ThreadBase> thread = local [all...] |
H A D | AudioFlinger.cpp | 325 sp<MmapThread> thread = mMmapThreads.valueFor(io); local 326 if (thread != 0) { 327 interface = new MmapThreadHandle(thread); 328 thread->configure(attr, streamType, sessionId, callback, portId); 678 // further sample rate checks are performed by createTrack_l() depending on the thread type 685 // further channel mask checks are performed by createTrack_l() depending on the thread type 692 // further format checks are performed by createTrack_l() depending on the thread type 707 PlaybackThread *thread = checkPlaybackThread_l(output); local 708 if (thread == NULL) { 709 ALOGE("no playback thread foun 802 ThreadBase *thread = checkThread_l(ioHandle); local 813 PlaybackThread *thread = checkPlaybackThread_l(output); local 824 ThreadBase *thread = checkThread_l(ioHandle); local 837 ThreadBase *thread = checkThread_l(ioHandle); local 848 PlaybackThread *thread = checkPlaybackThread_l(output); local 1197 sp<RecordThread> thread = mRecordThreads.valueAt(i); local 1228 sp<ThreadBase> thread; local 1278 ThreadBase *thread = (ThreadBase *)checkPlaybackThread_l(ioHandle); local 1476 sp<PlaybackThread> thread; local 1652 RecordThread *thread = checkRecordThread_l(input); local 1810 PlaybackThread *thread = fastPlaybackThread_l(); local 1817 PlaybackThread *thread = fastPlaybackThread_l(); local 1878 sp<PlaybackThread> thread = mPlaybackThreads.valueAt(i); local 1902 ThreadBase *thread = (ThreadBase *)mPlaybackThreads.valueAt(i).get(); local 1906 ThreadBase *thread = (ThreadBase *)mRecordThreads.valueAt(i).get(); local 1913 setAudioHwSyncForSession_l(PlaybackThread *thread, audio_session_t sessionId) argument 1986 sp<MmapPlaybackThread> thread = local 1994 sp<PlaybackThread> thread; local 2041 sp<ThreadBase> thread = openOutput_l(module, output, config, *devices, address, flags); local 2084 DuplicatingThread *thread = new DuplicatingThread(this, thread1, id, mSystemReady); local 2166 closeOutputFinish(const sp<PlaybackThread>& thread) argument 2174 closeOutputInternal_l(const sp<PlaybackThread>& thread) argument 2184 PlaybackThread *thread = checkPlaybackThread_l(output); local 2199 PlaybackThread *thread = checkPlaybackThread_l(output); local 2226 sp<ThreadBase> thread = openInput_l(module, input, config, *devices, address, source, flags); local 2298 sp<MmapCaptureThread> thread = local 2359 sp<RecordThread> thread = new RecordThread(this, local 2458 closeInputFinish(const sp<RecordThread>& thread) argument 2467 closeInputInternal_l(const sp<RecordThread>& thread) argument 2479 PlaybackThread *thread = mPlaybackThreads.valueAt(i).get(); local 2634 ThreadBase *thread = checkMmapThread_l(ioHandle); local 2659 PlaybackThread *thread = checkPlaybackThread_l(output); local 2733 PlaybackThread *thread = mPlaybackThreads.valueAt(i).get(); local 2747 PlaybackThread *thread = primaryPlaybackThread_l(); local 2761 PlaybackThread *thread = mPlaybackThreads.valueAt(i).get(); local 3024 ThreadBase *thread = checkRecordThread_l(io); local [all...] |
/frameworks/av/media/libstagefright/foundation/ |
H A D | ALooper.cpp | 133 sp<LooperThread> thread; local 139 thread = mThread; 145 if (thread == NULL && !runningLocally) { 149 if (thread != NULL) { 150 thread->requestExit(); 159 if (!runningLocally && !thread->isCurrentThread()) { 160 // If not running locally and this thread _is_ the looper thread, 162 thread->requestExitAndWait();
|
/frameworks/base/libs/hwui/tests/microbench/ |
H A D | FrameBuilderBench.cpp | 62 TestUtils::runOnRenderThread([&state](RenderThread& thread) { 75 TestUtils::runOnRenderThread([&state](RenderThread& thread) { 78 RenderState& renderState = thread.renderState(); 115 TestUtils::runOnRenderThread([&state](RenderThread& thread) { 131 TestUtils::runOnRenderThread([&state](RenderThread& thread) { 136 RenderState& renderState = thread.renderState();
|