Home
last modified time | relevance | path

Searched refs:thread (Results 1 – 25 of 258) sorted by relevance

1234567891011

/frameworks/base/libs/hwui/renderthread/
DRenderProxy.cpp136 RenderThread& thread = RenderThread::getInstance(); in invokeFunctor() local
137 auto invoke = [&thread, functor]() { CanvasContext::invokeFunctor(thread, functor); }; in invokeFunctor()
142 thread.queue().runSync(std::move(invoke)); in invokeFunctor()
144 thread.queue().post(std::move(invoke)); in invokeFunctor()
150 RenderThread& thread = RenderThread::getInstance(); in destroyFunctor() local
151 thread.queue().post([=]() { WebViewFunctorManager::instance().destroyFunctor(functor); }); in destroyFunctor()
166 auto& thread = RenderThread::getInstance(); in copyLayerInto() local
167 return thread.queue().runSync([&]() -> bool { in copyLayerInto()
168 return thread.readback().copyLayerInto(layer, &bitmap) == CopyResult::Success; in copyLayerInto()
191 RenderThread& thread = RenderThread::getInstance(); in trimMemory() local
[all …]
DCanvasContext.cpp63 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/
DPatchPanel.cpp225 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 …]
DAudioFlinger.cpp332 sp<MmapThread> thread = mMmapThreads.valueFor(io); in openMmapStream() local
333 if (thread != 0) { in openMmapStream()
334 interface = new MmapThreadHandle(thread); in openMmapStream()
335 thread->configure(&localAttr, streamType, actualSessionId, callback, *deviceId, portId); in openMmapStream()
757 PlaybackThread *thread = checkPlaybackThread_l(output.outputId); in createTrack() local
758 if (thread == NULL) { in createTrack()
786 track = thread->createTrack_l(client, streamType, localAttr, &output.sampleRate, in createTrack()
796 output.afFrameCount = thread->frameCount(); in createTrack()
797 output.afSampleRate = thread->sampleRate(); in createTrack()
798 output.afLatencyMs = thread->latency(); in createTrack()
[all …]
DTracks.cpp66 ThreadBase *thread, in TrackBase() argument
83 mThread(thread), in TrackBase()
103 mThreadIoHandle(thread ? thread->id() : AUDIO_IO_HANDLE_NONE), in TrackBase()
170 const sp<MemoryDealer> roHeap(thread->readOnlyHeap()); in TrackBase()
186 mBufferMemory = thread->pipeMemory(); in TrackBase()
283 const ThreadBase& thread, in PatchTrackBase() argument
291 uint64_t mixBufferNs = ((uint64_t)2 * thread.frameCount() * 1000000000) / in PatchTrackBase()
292 thread.sampleRate(); in PatchTrackBase()
498 PlaybackThread *thread, in Track() argument
515 : TrackBase(thread, client, attr, sampleRate, format, channelMask, frameCount, in Track()
[all …]
DEffects.cpp64 AudioFlinger::EffectModule::EffectModule(ThreadBase *thread, in EffectModule() argument
71 mThread(thread), mChain(chain), mId(id), mSessionId(sessionId), in EffectModule()
82 mAudioFlinger(thread->mAudioFlinger)
97 &desc->uuid, sessionId, thread->id(), &mEffectInterface);
110 setOffloaded(thread->type() == ThreadBase::OFFLOAD, thread->id());
189 sp <ThreadBase> thread = mThread.promote(); in updatePolicyState() local
191 if (thread == nullptr || chain == nullptr) { in updatePolicyState()
194 io = thread->id(); in updatePolicyState()
566 sp<ThreadBase> thread; in configure() local
575 thread = mThread.promote(); in configure()
[all …]
DEffects.h45 EffectModule(ThreadBase *thread,
100 void setThread(const wp<ThreadBase>& thread) in setThread() argument
101 { mThread = thread; mThreadType = thread.promote()->type(); } in setThread()
102 const wp<ThreadBase>& thread() { return mThread; } in thread() function
313 EffectChain(ThreadBase *thread, audio_session_t sessionId);
334 ThreadBase *thread,
414 bool isCompatibleWithThread_l(const sp<ThreadBase>& thread) const;
444 void clearInputBuffer_l(const sp<ThreadBase>& thread);
446 void setThread(const sp<ThreadBase>& thread);
/frameworks/opt/gamesdk/src/swappy/
DChoreographerFilter.cpp135 for (int32_t thread = 0; thread < numThreads; ++thread) { in launchThreadsLocked() local
136 mThreadPool.push_back(std::thread([this, thread]() { threadMain(mUseAffinity, thread); })); in launchThreadsLocked()
147 for (auto &thread : mThreadPool) { in terminateThreadsLocked() local
148 thread.join(); in terminateThreadsLocked()
165 void ChoreographerFilter::threadMain(bool useAffinity, int32_t thread) { in threadMain() argument
169 int cpu = getNumCpus() - 1 - thread; in threadMain()
176 threadName += swappy::to_string(thread); in threadMain()
/frameworks/base/core/tests/coretests/src/android/content/
DContentQueryMapTest.java54 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/opt/telephony/src/java/com/google/android/mms/util/
DPduCache.java104 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/av/media/libaaudio/tests/
Dtest_bad_disconnect.cpp39 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/
DSensorRegistrationInfo.h46 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/
DSQLiteConnectionPoolTest.java73 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/
DSkiaOpenGLPipeline.cpp46 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()
DSkiaVulkanPipeline.cpp44 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
/frameworks/av/media/libstagefright/foundation/
DALooper.cpp133 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/opt/bitmap/src/com/android/bitmap/
DNamedThreadFactory.java35 final Thread thread = mDefaultThreadFactory.newThread(runnable); in newThread() local
36 thread.setName(mBaseName + "-" + mCount.getAndIncrement()); in newThread()
37 return thread; in newThread()
/frameworks/base/cmds/statsd/tests/log_event/
DLogEventQueue_test.cpp36 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/base/core/tests/coretests/src/android/os/storage/
DStorageManagerIntegrationTest.java193 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/native/services/surfaceflinger/tests/
DStress_test.cpp41 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/native/cmds/surfacereplayer/replayer/
DREADME.md190 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/base/core/tests/coretests/src/android/view/
DViewRootSurfaceCallbackTest.java62 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/
DDependencyProvider.java73 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/
DDatabaseLockTest.java95 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/
DTestOpenmpSettings.cpp67 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) { in TEST_F()

1234567891011