Home
last modified time | relevance | path

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

12345678910

/frameworks/base/libs/hwui/renderthread/
DRenderProxy.cpp137 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 …]
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.cpp153 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 …]
DTracks.cpp68 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/
DPduCache.java107 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/
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/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
DSkiaVulkanPipeline.h31 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/
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/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/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/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/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/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/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) { t.join(); }); in TEST_F()
/frameworks/base/services/tests/servicestests/src/com/android/server/
DThreadPriorityBoosterTest.java81 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/
Dclient_channel_tests.cpp87 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()

12345678910