| /frameworks/support/compat/tests/java/android/support/v4/provider/ |
| D | SelfDestructiveThreadTest.java | 50 private void waitUntilDestruction(SelfDestructiveThread thread, long timeoutMs) { in waitUntilDestruction() argument
51 if (!thread.isRunning()) { in waitUntilDestruction()
63 if (!thread.isRunning()) { in waitUntilDestruction()
88 final SelfDestructiveThread thread = new SelfDestructiveThread( in testDestruction() local
90 thread.postAndWait(new Callable<Object>() { in testDestruction()
96 waitUntilDestruction(thread, DEFAULT_TIMEOUT); in testDestruction()
97 assertFalse(thread.isRunning()); in testDestruction()
103 final SelfDestructiveThread thread = new SelfDestructiveThread( in testReconstruction() local
105 Integer generation = thread.postAndWait(new Callable<Integer>() { in testReconstruction()
108 return thread.getGeneration(); in testReconstruction()
[all …]
|
| /frameworks/base/libs/hwui/renderthread/ |
| D | RenderProxy.cpp | 64 CREATE_BRIDGE4(createContext, RenderThread* thread, bool translucent, in CREATE_BRIDGE4() argument
66 return CanvasContext::create(*args->thread, args->translucent, in CREATE_BRIDGE4()
76 args->thread = &mRenderThread; in RenderProxy()
266 CREATE_BRIDGE2(invokeFunctor, RenderThread* thread, Functor* functor) { in CREATE_BRIDGE2() argument
267 CanvasContext::invokeFunctor(*args->thread, args->functor); in CREATE_BRIDGE2()
273 RenderThread& thread = RenderThread::getInstance(); in invokeFunctor() local
275 args->thread = &thread; in invokeFunctor()
283 thread.queue(task); in invokeFunctor()
355 CREATE_BRIDGE2(trimMemory, RenderThread* thread, int level) { in CREATE_BRIDGE2() argument
356 CanvasContext::trimMemory(*args->thread, args->level); in CREATE_BRIDGE2()
[all …]
|
| D | CanvasContext.cpp | 66 CanvasContext* CanvasContext::create(RenderThread& thread, in create() argument
73 return new CanvasContext(thread, translucent, rootRenderNode, contextFactory, in create()
74 std::make_unique<OpenGLPipeline>(thread)); in create()
76 return new CanvasContext(thread, translucent, rootRenderNode, contextFactory, in create()
77 std::make_unique<skiapipeline::SkiaOpenGLPipeline>(thread)); in create()
79 return new CanvasContext(thread, translucent, rootRenderNode, contextFactory, in create()
80 std::make_unique<skiapipeline::SkiaVulkanPipeline>(thread)); in create()
104 void CanvasContext::invokeFunctor(const RenderThread& thread, Functor* functor) { in invokeFunctor() argument
109 OpenGLPipeline::invokeFunctor(thread, functor); in invokeFunctor()
112 skiapipeline::SkiaOpenGLPipeline::invokeFunctor(thread, functor); in invokeFunctor()
[all …]
|
| D | OpenGLPipeline.h | 31 OpenGLPipeline(RenderThread& thread);
62 static void prepareToDraw(const RenderThread& thread, Bitmap* bitmap);
63 static void invokeFunctor(const RenderThread& thread, Functor* functor);
64 static sk_sp<Bitmap> allocateHardwareBitmap(RenderThread& thread,
|
| /frameworks/av/services/audioflinger/ |
| D | Tracks.cpp | 63 ThreadBase *thread, in TrackBase() argument
78 mThread(thread), in TrackBase()
97 mThreadIoHandle(thread->id()), in TrackBase()
162 const sp<MemoryDealer> roHeap(thread->readOnlyHeap()); in TrackBase()
177 mBufferMemory = thread->pipeMemory(); in TrackBase()
371 PlaybackThread *thread, in Track() argument
386 : TrackBase(thread, client, sampleRate, format, channelMask, frameCount, in Track()
397 mMainBuffer(thread->mixBuffer()), in Track()
429 mName = thread->getTrackName_l(channelMask, format, sessionId, uid); in Track()
440 ALOG_ASSERT(thread->mFastTrackAvailMask != 0); in Track()
[all …]
|
| D | AudioFlinger.cpp | 326 sp<MmapThread> thread = mMmapThreads.valueFor(io); in openMmapStream() local
327 if (thread != 0) { in openMmapStream()
328 interface = new MmapThreadHandle(thread); in openMmapStream()
329 thread->configure(attr, streamType, sessionId, callback, *deviceId, portId); in openMmapStream()
713 PlaybackThread *thread = checkPlaybackThread_l(output); in createTrack() local
714 if (thread == NULL) { in createTrack()
751 track = thread->createTrack_l(client, streamType, sampleRate, format, in createTrack()
761 Mutex::Autolock _dl(thread->mLock); in createTrack()
763 moveEffectChain_l(lSessionId, effectThread, thread, true); in createTrack()
769 if (thread->isValidSyncEvent(mPendingSyncEvents[i])) { in createTrack()
[all …]
|
| D | Effects.cpp | 61 AudioFlinger::EffectModule::EffectModule(ThreadBase *thread, in EffectModule() argument
68 mThread(thread), mChain(chain), mId(id), mSessionId(sessionId), in EffectModule()
75 mAudioFlinger(thread->mAudioFlinger) in EffectModule()
87 &desc->uuid, sessionId, thread->id(), &mEffectInterface); in EffectModule()
100 setOffloaded(thread->type() == ThreadBase::OFFLOAD, thread->id()); in EffectModule()
353 sp<ThreadBase> thread; in configure() local
362 thread = mThread.promote(); in configure()
363 if (thread == 0) { in configure()
369 channelMask = thread->channelMask(); in configure()
389 mConfig.inputCfg.samplingRate = thread->sampleRate(); in configure()
[all …]
|
| D | PatchPanel.cpp | 264 sp<ThreadBase> thread = in createAudioPatch() local
266 newPatch->mPlaybackThread = (MixerThread *)thread.get(); in createAudioPatch()
267 if (thread == 0) { in createAudioPatch()
277 sp<ThreadBase> thread = audioflinger->openOutput_l( in createAudioPatch() local
284 newPatch->mPlaybackThread = (PlaybackThread *)thread.get(); in createAudioPatch()
314 sp<ThreadBase> thread = audioflinger->openInput_l(srcModule, in createAudioPatch() local
321 newPatch->mRecordThread = (RecordThread *)thread.get(); in createAudioPatch()
334 sp<ThreadBase> thread = audioflinger->checkRecordThread_l( in createAudioPatch() local
336 if (thread == 0) { in createAudioPatch()
337 thread = audioflinger->checkMmapThread_l(patch->sinks[0].ext.mix.handle); in createAudioPatch()
[all …]
|
| D | Effects.h | 45 EffectModule(ThreadBase *thread,
98 void setThread(const wp<ThreadBase>& thread) { mThread = thread; } in setThread() argument
99 const wp<ThreadBase>& thread() { return mThread; } in thread() function
265 EffectChain(ThreadBase *thread, audio_session_t sessionId);
286 ThreadBase *thread,
364 bool isCompatibleWithThread_l(const sp<ThreadBase>& thread) const;
394 void clearInputBuffer_l(const sp<ThreadBase>& thread);
396 void setThread(const sp<ThreadBase>& thread);
|
| /frameworks/av/media/mtp/ |
| D | AsyncIO.cpp | 95 std::thread pool[NUM_THREADS];
100 CHECK(!thread.joinable()); in ~aiocb()
107 pool[i] = std::thread(f, i); in aio_pool_init()
143 aiocbp->thread = std::thread(read_func, aiocbp); in aio_read()
148 aiocbp->thread = std::thread(write_func, aiocbp); in aio_write()
153 aiocbp->thread = std::thread(splice_read_func, aiocbp); in aio_splice_read()
158 aiocbp->thread = std::thread(splice_write_func, aiocbp); in aio_splice_write()
173 aiocbp[i]->thread.join(); in aio_suspend()
|
| /frameworks/base/core/tests/coretests/src/android/content/ |
| D | ContentQueryMapTest.java | 56 LooperThread thread = new LooperThread() { in testContentQueryMap() local
101 thread.start(); in testContentQueryMap()
102 thread.join(); in testContentQueryMap()
103 if (thread.mError != null) throw thread.mError; in testContentQueryMap()
104 assertTrue(thread.mSuccess); in testContentQueryMap()
|
| /frameworks/opt/telephony/src/java/com/google/android/mms/util/ |
| D | PduCache.java | 104 HashSet<Uri> thread = mThreads.get(threadId); in put() local
105 if (thread == null) { in put()
106 thread = new HashSet<Uri>(); in put()
107 mThreads.put(threadId, thread); in put()
114 thread.add(finalKey); in put()
232 HashSet<Uri> thread = mThreads.get(entry.getThreadId()); in removeFromThreads() local
233 if (thread != null) { in removeFromThreads()
234 thread.remove(key); in removeFromThreads()
243 HashSet<Uri> thread = mThreads.remove(threadId); in purgeByThreadId() local
244 if (thread != null) { in purgeByThreadId()
[all …]
|
| /frameworks/native/services/surfaceflinger/tests/ |
| D | Stress_test.cpp | 41 std::vector<std::thread> threads; in TEST()
43 threads.push_back(std::thread(do_stress)); in TEST()
45 for (auto& thread : threads) { in TEST() local
46 thread.join(); in TEST()
|
| /frameworks/av/media/libstagefright/foundation/ |
| D | ALooper.cpp | 133 sp<LooperThread> thread; in stop() local
139 thread = mThread; in stop()
145 if (thread == NULL && !runningLocally) { in stop()
149 if (thread != NULL) { in stop()
150 thread->requestExit(); in stop()
159 if (!runningLocally && !thread->isCurrentThread()) { in stop()
162 thread->requestExitAndWait(); in stop()
|
| /frameworks/base/core/tests/coretests/src/android/database/sqlite/ |
| D | SQLiteConnectionPoolTest.java | 72 HandlerThread thread = new HandlerThread("test-close-idle-connections-thread"); in testCloseIdleConnections() local
73 Log.i(TAG, "Starting " + thread.getName()); in testCloseIdleConnections()
74 thread.start(); in testCloseIdleConnections()
76 pool.setupIdleConnectionHandler(thread.getLooper(), 100); in testCloseIdleConnections()
89 thread.quit(); in testCloseIdleConnections()
|
| /frameworks/native/services/sensorservice/ |
| D | SensorRegistrationInfo.h | 46 IPCThreadState *thread = IPCThreadState::self(); in SensorRegistrationInfo() local
47 mPid = (thread != nullptr) ? thread->getCallingPid() : -1; in SensorRegistrationInfo()
48 mUid = (thread != nullptr) ? thread->getCallingUid() : -1; in SensorRegistrationInfo()
|
| /frameworks/base/libs/hwui/ |
| D | OpenGLReadback.h | 38 explicit OpenGLReadback(renderthread::RenderThread& thread) : Readback(thread) {} in OpenGLReadback() argument
50 OpenGLReadbackImpl(renderthread::RenderThread& thread) : OpenGLReadback(thread) {} in OpenGLReadbackImpl() argument
|
| /frameworks/base/libs/hwui/tests/microbench/ |
| D | FrameBuilderBench.cpp | 62 TestUtils::runOnRenderThread([&state](RenderThread& thread) { in BM_FrameBuilder_defer() argument
75 TestUtils::runOnRenderThread([&state](RenderThread& thread) { in BM_FrameBuilder_deferAndRender() argument
78 RenderState& renderState = thread.renderState(); in BM_FrameBuilder_deferAndRender()
115 TestUtils::runOnRenderThread([&state](RenderThread& thread) { in BM_FrameBuilder_defer_scene() argument
131 TestUtils::runOnRenderThread([&state](RenderThread& thread) { in BM_FrameBuilder_deferAndRender_scene() argument
136 RenderState& renderState = thread.renderState(); in BM_FrameBuilder_deferAndRender_scene()
|
| /frameworks/opt/bitmap/src/com/android/bitmap/ |
| D | NamedThreadFactory.java | 35 final Thread thread = mDefaultThreadFactory.newThread(runnable); in newThread() local
36 thread.setName(mBaseName + "-" + mCount.getAndIncrement()); in newThread()
37 return thread; in newThread()
|
| /frameworks/native/cmds/surfacereplayer/replayer/ |
| D | README.md | 190 the main thread, queued up in a thread pool and completed when the main thread deems they are
195 (e.g. locking and pushing a buffer), it waits for the main thread to complete it using an Event
196 object. The main thread holds a queue of these Event objects and completes the
197 corresponding Event base on its time stamp. After completing an increment, the main thread will
200 The main thread's execution flow is outlined below
213 A worker thread's flow looks like so
231 - **Waiting** - The worker is waiting on the main thread to signal it.
232 - **Signaled** - The worker has just been signaled by the main thread
235 When the main thread wants to finish the execution of a worker, the worker can either still be
236 **SettingUp**, in which the main thread will wait, or the worker will be **Waiting**, in which the
[all …]
|
| /frameworks/support/emoji/core/tests/java/android/support/text/emoji/ |
| D | FontRequestEmojiCompatConfigTest.java | 279 HandlerThread thread = new HandlerThread("testThread"); in testLoad_keepRetryingAndFail() local
280 thread.start(); in testLoad_keepRetryingAndFail()
282 Handler handler = new Handler(thread.getLooper()); in testLoad_keepRetryingAndFail()
317 thread.quit(); in testLoad_keepRetryingAndFail()
337 HandlerThread thread = new HandlerThread("testThread"); in testLoad_keepRetryingAndSuccess() local
338 thread.start(); in testLoad_keepRetryingAndSuccess()
340 Handler handler = new Handler(thread.getLooper()); in testLoad_keepRetryingAndSuccess()
375 thread.quit(); in testLoad_keepRetryingAndSuccess()
394 HandlerThread thread = new HandlerThread("testThread"); in testLoad_ObserverNotifyAndSuccess() local
395 thread.start(); in testLoad_ObserverNotifyAndSuccess()
[all …]
|
| /frameworks/base/core/tests/coretests/src/android/database/ |
| D | DatabaseLockTest.java | 93 Thread thread = new DatabaseFairnessThread(); in startDatabaseFairnessThread() local
94 thread.start(); in startDatabaseFairnessThread()
150 Thread thread = new DatabaseLatencyThread(); in startDatabaseLatencyThread() local
151 thread.start(); in startDatabaseLatencyThread()
|
| /frameworks/base/core/tests/coretests/src/android/os/storage/ |
| D | StorageManagerIntegrationTest.java | 268 assertNotSame(Thread.State.TERMINATED, factory.thread.getState()); in testOpenProxyFileDescriptor()
274 factory.thread.join(3000); in testOpenProxyFileDescriptor()
275 assertEquals(Thread.State.TERMINATED, factory.thread.getState()); in testOpenProxyFileDescriptor()
280 assertNotSame(Thread.State.TERMINATED, factory.thread.getState()); in testOpenProxyFileDescriptor()
286 Thread thread = null; field in StorageManagerIntegrationTest.MyThreadFactory
290 thread = new Thread(r); in newThread()
291 return thread; in newThread()
|
| /frameworks/native/libs/vr/libpdx_uds/ |
| D | client_channel_tests.cpp | 87 dispatch_thread_ = std::thread( in TestServiceRunner()
100 std::thread dispatch_thread_;
151 std::vector<std::thread> threads; in TEST_F()
159 for (auto& thread : threads) in TEST_F() local
160 thread.join(); in TEST_F()
|
| /frameworks/base/libs/hwui/pipeline/skia/ |
| D | SkiaOpenGLPipeline.h | 30 SkiaOpenGLPipeline(renderthread::RenderThread& thread);
52 static void invokeFunctor(const renderthread::RenderThread& thread, Functor* functor);
53 static sk_sp<Bitmap> allocateHardwareBitmap(renderthread::RenderThread& thread,
|