Home
last modified time | relevance | path

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

1234567891011

/frameworks/base/libs/hwui/renderthread/
DRenderProxy.cpp133 RenderThread& thread = RenderThread::getInstance(); in invokeFunctor() local
134 auto invoke = [&thread, functor]() { CanvasContext::invokeFunctor(thread, functor); }; in invokeFunctor()
139 thread.queue().runSync(std::move(invoke)); in invokeFunctor()
141 thread.queue().post(std::move(invoke)); in invokeFunctor()
147 RenderThread& thread = RenderThread::getInstance(); in destroyFunctor() local
148 thread.queue().post([=]() { WebViewFunctorManager::instance().destroyFunctor(functor); }); in destroyFunctor()
163 auto& thread = RenderThread::getInstance(); in copyLayerInto() local
164 return thread.queue().runSync([&]() -> bool { in copyLayerInto()
165 return thread.readback().copyLayerInto(layer, &bitmap) == CopyResult::Success; in copyLayerInto()
188 RenderThread& thread = RenderThread::getInstance(); in trimMemory() local
[all …]
DCanvasContext.cpp59 CanvasContext* CanvasContext::create(RenderThread& thread, bool translucent, in create() argument
65 return new CanvasContext(thread, translucent, rootRenderNode, contextFactory, in create()
66 std::make_unique<skiapipeline::SkiaOpenGLPipeline>(thread)); in create()
68 return new CanvasContext(thread, translucent, rootRenderNode, contextFactory, in create()
69 std::make_unique<skiapipeline::SkiaVulkanPipeline>(thread)); in create()
77 void CanvasContext::invokeFunctor(const RenderThread& thread, Functor* functor) { in invokeFunctor() argument
82 skiapipeline::SkiaOpenGLPipeline::invokeFunctor(thread, functor); in invokeFunctor()
85 skiapipeline::SkiaVulkanPipeline::invokeFunctor(thread, functor); in invokeFunctor()
93 void CanvasContext::prepareToDraw(const RenderThread& thread, Bitmap* bitmap) { in prepareToDraw() argument
94 skiapipeline::SkiaPipeline::prepareToDraw(thread, bitmap); in prepareToDraw()
[all …]
/frameworks/av/services/audioflinger/
DPatchPanel.cpp226 sp<ThreadBase> thread = in createAudioPatch() local
228 if (thread == 0) { in createAudioPatch()
235 reinterpret_cast<PlaybackThread*>(thread.get()), false /*closeThread*/); in createAudioPatch()
252 sp<ThreadBase> thread = mAudioFlinger.openOutput_l( in createAudioPatch() local
259 ALOGV("mAudioFlinger.openOutput_l() returned %p", thread.get()); in createAudioPatch()
260 if (thread == 0) { in createAudioPatch()
264 newPatch.mPlayback.setThread(reinterpret_cast<PlaybackThread*>(thread.get())); in createAudioPatch()
274 config.sample_rate = newPatch.mPlayback.thread()->sampleRate(); in createAudioPatch()
280 newPatch.mPlayback.thread()->channelCount()); in createAudioPatch()
285 config.format = newPatch.mPlayback.thread()->format(); in createAudioPatch()
[all …]
DAudioFlinger.cpp154 std::thread notifier([]() { in onNewDevicesAvailable()
368 sp<MmapThread> thread = mMmapThreads.valueFor(io); in openMmapStream() local
369 if (thread != 0) { in openMmapStream()
370 interface = new MmapThreadHandle(thread); in openMmapStream()
371 thread->configure(&localAttr, streamType, actualSessionId, callback, *deviceId, portId); in openMmapStream()
374 config->sample_rate = thread->sampleRate(); in openMmapStream()
375 config->channel_mask = thread->channelMask(); in openMmapStream()
376 config->format = thread->format(); in openMmapStream()
820 PlaybackThread *thread = checkPlaybackThread_l(output.outputId); in createTrack() local
821 if (thread == NULL) { in createTrack()
[all …]
DTracks.cpp68 ThreadBase *thread, in TrackBase() argument
86 mThread(thread), in TrackBase()
106 mThreadIoHandle(thread ? thread->id() : AUDIO_IO_HANDLE_NONE), in TrackBase()
174 const sp<MemoryDealer> roHeap(thread->readOnlyHeap()); in TrackBase()
190 mBufferMemory = thread->pipeMemory(); in TrackBase()
282 const ThreadBase& thread, in PatchTrackBase() argument
290 uint64_t mixBufferNs = ((uint64_t)2 * thread.frameCount() * 1000000000) / in PatchTrackBase()
291 thread.sampleRate(); in PatchTrackBase()
497 PlaybackThread *thread, in Track() argument
515 : TrackBase(thread, client, attr, sampleRate, format, channelMask, frameCount, in Track()
[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/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/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/base/libs/hwui/pipeline/skia/
DSkiaOpenGLPipeline.cpp47 SkiaOpenGLPipeline::SkiaOpenGLPipeline(RenderThread& thread) in SkiaOpenGLPipeline() argument
48 : SkiaPipeline(thread), mEglManager(thread.eglManager()) { in SkiaOpenGLPipeline()
49 thread.renderState().registerContextCallback(this); in SkiaOpenGLPipeline()
192 void SkiaOpenGLPipeline::invokeFunctor(const RenderThread& thread, Functor* functor) { in invokeFunctor() argument
194 if (thread.eglManager().hasEglContext()) { in invokeFunctor()
202 thread.getGrContext()->resetContext(); in invokeFunctor()
DSkiaVulkanPipeline.cpp45 SkiaVulkanPipeline::SkiaVulkanPipeline(renderthread::RenderThread& thread) in SkiaVulkanPipeline() argument
46 : SkiaPipeline(thread), mVkManager(thread.vulkanManager()) { in SkiaVulkanPipeline()
47 thread.renderState().registerContextCallback(this); in SkiaVulkanPipeline()
143 void SkiaVulkanPipeline::invokeFunctor(const RenderThread& thread, Functor* functor) { in invokeFunctor() argument
DSkiaVulkanPipeline.h31 explicit SkiaVulkanPipeline(renderthread::RenderThread& thread);
50 static void invokeFunctor(const renderthread::RenderThread& thread, Functor* functor);
51 static sk_sp<Bitmap> allocateHardwareBitmap(renderthread::RenderThread& thread,
/frameworks/base/packages/SystemUI/src/com/android/systemui/util/concurrency/
DConcurrencyModule.java48 HandlerThread thread = new HandlerThread("SysUiBg", in provideBgLooper() local
50 thread.start(); in provideBgLooper()
51 return thread.getLooper(); in provideBgLooper()
59 HandlerThread thread = new HandlerThread("SysUiLng", in provideLongRunningLooper() local
61 thread.start(); in provideLongRunningLooper()
62 return thread.getLooper(); in provideLongRunningLooper()
/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/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/native/services/sensorservice/
DSensorRegistrationInfo.h50 IPCThreadState *thread = IPCThreadState::self(); in SensorRegistrationInfo() local
51 mPid = (thread != nullptr) ? thread->getCallingPid() : -1; in SensorRegistrationInfo()
52 mUid = (thread != nullptr) ? thread->getCallingUid() : -1; in SensorRegistrationInfo()
/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/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.cpp53 std::thread writer([&queue, timeBaseNs] { in TEST()
62 std::thread reader([&queue, timeBaseNs] { in TEST()
78 std::thread writer([&queue, timeBaseNs] { in TEST()
95 std::thread reader([&queue, timeBaseNs] { 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/native/services/surfaceflinger/tests/
DStress_test.cpp45 std::vector<std::thread> threads; in TEST()
47 threads.push_back(std::thread(do_stress)); in TEST()
49 for (auto& thread : threads) { in TEST() local
50 thread.join(); in TEST()
/frameworks/native/services/surfaceflinger/tests/unittests/
DPromiseTest.cpp59 std::thread fetchThread(std::move(fetchString)); in TEST()
61 std::thread appendThread, decrementThread; in TEST()
68 appendThread = std::thread(std::move(appendString), std::move(str)); in TEST()
73 decrementThread = std::thread(std::move(decrementBytes), 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/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/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/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()

1234567891011