| /frameworks/base/libs/hwui/renderthread/ |
| D | RenderProxy.cpp | 137 RenderThread& thread = RenderThread::getInstance(); in invokeFunctor() local
138 auto invoke = [&thread, functor]() { CanvasContext::invokeFunctor(thread, functor); }; in invokeFunctor()
143 thread.queue().runSync(std::move(invoke)); in invokeFunctor()
145 thread.queue().post(std::move(invoke)); in invokeFunctor()
151 RenderThread& thread = RenderThread::getInstance(); in destroyFunctor() local
152 thread.queue().post([=]() { WebViewFunctorManager::instance().destroyFunctor(functor); }); in destroyFunctor()
167 auto& thread = RenderThread::getInstance(); in copyLayerInto() local
168 return thread.queue().runSync([&]() -> bool { in copyLayerInto()
169 return thread.readback().copyLayerInto(layer, &bitmap) == CopyResult::Success; in copyLayerInto()
192 RenderThread& thread = RenderThread::getInstance(); in trimMemory() local
[all …]
|
| D | CanvasContext.cpp | 63 CanvasContext* CanvasContext::create(RenderThread& thread, bool translucent, in create() argument
69 return new CanvasContext(thread, translucent, rootRenderNode, contextFactory, in create()
70 std::make_unique<skiapipeline::SkiaOpenGLPipeline>(thread)); in create()
72 return new CanvasContext(thread, translucent, rootRenderNode, contextFactory, in create()
73 std::make_unique<skiapipeline::SkiaVulkanPipeline>(thread)); in create()
81 void CanvasContext::invokeFunctor(const RenderThread& thread, Functor* functor) { in invokeFunctor() argument
86 skiapipeline::SkiaOpenGLPipeline::invokeFunctor(thread, functor); in invokeFunctor()
89 skiapipeline::SkiaVulkanPipeline::invokeFunctor(thread, functor); in invokeFunctor()
97 void CanvasContext::prepareToDraw(const RenderThread& thread, Bitmap* bitmap) { in prepareToDraw() argument
98 skiapipeline::SkiaPipeline::prepareToDraw(thread, bitmap); in prepareToDraw()
[all …]
|
| /frameworks/av/services/audioflinger/ |
| D | PatchPanel.cpp | 225 sp<ThreadBase> thread = in createAudioPatch() local
227 if (thread == 0) { in createAudioPatch()
234 reinterpret_cast<PlaybackThread*>(thread.get()), false /*closeThread*/); in createAudioPatch()
251 sp<ThreadBase> thread = mAudioFlinger.openOutput_l( in createAudioPatch() local
258 ALOGV("mAudioFlinger.openOutput_l() returned %p", thread.get()); in createAudioPatch()
259 if (thread == 0) { in createAudioPatch()
263 newPatch.mPlayback.setThread(reinterpret_cast<PlaybackThread*>(thread.get())); in createAudioPatch()
273 config.sample_rate = newPatch.mPlayback.thread()->sampleRate(); in createAudioPatch()
279 newPatch.mPlayback.thread()->channelCount()); in createAudioPatch()
284 config.format = newPatch.mPlayback.thread()->format(); in createAudioPatch()
[all …]
|
| D | AudioFlinger.cpp | 153 std::thread notifier([]() { in onNewDevicesAvailable()
362 sp<MmapThread> thread = mMmapThreads.valueFor(io); in openMmapStream() local
363 if (thread != 0) { in openMmapStream()
364 interface = new MmapThreadHandle(thread); in openMmapStream()
365 thread->configure(&localAttr, streamType, actualSessionId, callback, *deviceId, portId); in openMmapStream()
810 PlaybackThread *thread = checkPlaybackThread_l(output.outputId); in createTrack() local
811 if (thread == NULL) { in createTrack()
839 track = thread->createTrack_l(client, streamType, localAttr, &output.sampleRate, in createTrack()
849 output.afFrameCount = thread->frameCount(); in createTrack()
850 output.afSampleRate = thread->sampleRate(); in createTrack()
[all …]
|
| D | Tracks.cpp | 68 ThreadBase *thread, in TrackBase() argument
85 mThread(thread), in TrackBase()
105 mThreadIoHandle(thread ? thread->id() : AUDIO_IO_HANDLE_NONE), in TrackBase()
172 const sp<MemoryDealer> roHeap(thread->readOnlyHeap()); in TrackBase()
188 mBufferMemory = thread->pipeMemory(); in TrackBase()
285 const ThreadBase& thread, in PatchTrackBase() argument
293 uint64_t mixBufferNs = ((uint64_t)2 * thread.frameCount() * 1000000000) / in PatchTrackBase()
294 thread.sampleRate(); in PatchTrackBase()
500 PlaybackThread *thread, in Track() argument
518 : TrackBase(thread, client, attr, sampleRate, format, channelMask, frameCount, in Track()
[all …]
|
| /frameworks/base/telephony/common/com/google/android/mms/util/ |
| D | PduCache.java | 107 HashSet<Uri> thread = mThreads.get(threadId); in put() local
108 if (thread == null) { in put()
109 thread = new HashSet<Uri>(); in put()
110 mThreads.put(threadId, thread); in put()
117 thread.add(finalKey); in put()
238 HashSet<Uri> thread = mThreads.get(entry.getThreadId()); in removeFromThreads() local
239 if (thread != null) { in removeFromThreads()
240 thread.remove(key); in removeFromThreads()
249 HashSet<Uri> thread = mThreads.remove(threadId); in purgeByThreadId() local
250 if (thread != null) { in purgeByThreadId()
[all …]
|
| /frameworks/base/core/tests/coretests/src/android/content/ |
| D | ContentQueryMapTest.java | 54 LooperThread thread = new LooperThread() { in testContentQueryMap() local
99 thread.start(); in testContentQueryMap()
100 thread.join(); in testContentQueryMap()
101 if (thread.mError != null) throw thread.mError; in testContentQueryMap()
102 assertTrue(thread.mSuccess); in testContentQueryMap()
|
| /frameworks/av/media/libaaudio/tests/ |
| D | test_bad_disconnect.cpp | 39 std::thread *thread = nullptr; member
123 s_AudioEngine.thread = nullptr; in s_StartThreadProc()
132 if (s_AudioEngine.thread == nullptr) { in s_myErrorCallbackProc()
133 s_AudioEngine.thread = new std::thread(s_StartThreadProc); in s_myErrorCallbackProc()
|
| /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/core/tests/coretests/src/android/database/sqlite/ |
| D | SQLiteConnectionPoolTest.java | 73 HandlerThread thread = new HandlerThread("test-close-idle-connections-thread"); in testCloseIdleConnections() local
74 Log.i(TAG, "Starting " + thread.getName()); in testCloseIdleConnections()
75 thread.start(); in testCloseIdleConnections()
77 pool.setupIdleConnectionHandler(thread.getLooper(), 100); in testCloseIdleConnections()
90 thread.quit(); in testCloseIdleConnections()
|
| /frameworks/base/libs/hwui/pipeline/skia/ |
| D | SkiaOpenGLPipeline.cpp | 46 SkiaOpenGLPipeline::SkiaOpenGLPipeline(RenderThread& thread) in SkiaOpenGLPipeline() argument
47 : SkiaPipeline(thread), mEglManager(thread.eglManager()) { in SkiaOpenGLPipeline()
48 thread.renderState().registerContextCallback(this); in SkiaOpenGLPipeline()
208 void SkiaOpenGLPipeline::invokeFunctor(const RenderThread& thread, Functor* functor) { in invokeFunctor() argument
210 if (thread.eglManager().hasEglContext()) { in invokeFunctor()
218 thread.getGrContext()->resetContext(); in invokeFunctor()
|
| D | SkiaVulkanPipeline.cpp | 44 SkiaVulkanPipeline::SkiaVulkanPipeline(renderthread::RenderThread& thread) in SkiaVulkanPipeline() argument
45 : SkiaPipeline(thread), mVkManager(thread.vulkanManager()) { in SkiaVulkanPipeline()
46 thread.renderState().registerContextCallback(this); in SkiaVulkanPipeline()
144 void SkiaVulkanPipeline::invokeFunctor(const RenderThread& thread, Functor* functor) { in invokeFunctor() argument
|
| D | SkiaVulkanPipeline.h | 31 explicit SkiaVulkanPipeline(renderthread::RenderThread& thread);
51 static void invokeFunctor(const renderthread::RenderThread& thread, Functor* functor);
52 static sk_sp<Bitmap> allocateHardwareBitmap(renderthread::RenderThread& thread,
|
| /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/os/storage/ |
| D | StorageManagerIntegrationTest.java | 193 assertNotSame(Thread.State.TERMINATED, factory.thread.getState()); in testOpenProxyFileDescriptor()
199 factory.thread.join(3000); in testOpenProxyFileDescriptor()
200 assertEquals(Thread.State.TERMINATED, factory.thread.getState()); in testOpenProxyFileDescriptor()
205 assertNotSame(Thread.State.TERMINATED, factory.thread.getState()); in testOpenProxyFileDescriptor()
211 Thread thread = null; field in StorageManagerIntegrationTest.MyThreadFactory
215 thread = new Thread(r); in newThread()
216 return thread; in newThread()
|
| /frameworks/base/cmds/statsd/tests/log_event/ |
| D | LogEventQueue_test.cpp | 36 std::thread writer([&queue, timeBaseNs] { in TEST()
46 std::thread reader([&queue, timeBaseNs] { in TEST()
62 std::thread writer([&queue, timeBaseNs] { in TEST()
80 std::thread reader([&queue, timeBaseNs] { in TEST()
|
| /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/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/base/core/tests/coretests/src/android/view/ |
| D | ViewRootSurfaceCallbackTest.java | 62 final HandlerThread thread = new HandlerThread(TAG); in testCallingTidOfSurfaceCallback() local
63 thread.start(); in testCallingTidOfSurfaceCallback()
64 thread.getThreadHandler().runWithScissors(() -> { in testCallingTidOfSurfaceCallback()
70 final int attachedTid = thread.getThreadId(); in testCallingTidOfSurfaceCallback()
|
| /frameworks/base/packages/SystemUI/src/com/android/systemui/ |
| D | DependencyProvider.java | 73 HandlerThread thread = new HandlerThread("TimeTick"); in provideHandler() local
74 thread.start(); in provideHandler()
75 return new Handler(thread.getLooper()); in provideHandler()
82 HandlerThread thread = new HandlerThread("SysUiBg", in provideBgLooper() local
84 thread.start(); in provideBgLooper()
85 return thread.getLooper(); in provideBgLooper()
|
| /frameworks/base/core/tests/coretests/src/android/database/ |
| D | DatabaseLockTest.java | 95 Thread thread = new DatabaseFairnessThread(); in startDatabaseFairnessThread() local
96 thread.start(); in startDatabaseFairnessThread()
152 Thread thread = new DatabaseLatencyThread(); in startDatabaseLatencyThread() local
153 thread.start(); in startDatabaseLatencyThread()
|
| /frameworks/ml/nn/runtime/test/ |
| D | TestOpenmpSettings.cpp | 67 std::vector<std::thread> threads; in TEST_F()
72 threads.push_back(std::thread([sleepFor]() { in TEST_F()
89 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in TEST_F()
|
| /frameworks/base/services/tests/servicestests/src/com/android/server/ |
| D | ThreadPriorityBoosterTest.java | 81 final Thread thread = new Thread(action); in joinNewThread() local
82 thread.start(); in joinNewThread()
84 thread.join(); in joinNewThread()
|
| /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()
|