Searched refs:thread (Results 1 - 25 of 159) sorted by relevance

1234567

/frameworks/native/services/surfaceflinger/tests/
H A DStress_test.cpp23 #include <thread>
41 std::vector<std::thread> threads;
43 threads.push_back(std::thread(do_stress));
45 for (auto& thread : threads) {
46 thread.join();
/frameworks/base/core/java/com/android/internal/view/
H A DWindowManagerPolicyThread.java22 * Static storage of the thread running the window manager policy, to
29 public static void set(Thread thread, Looper looper) { argument
30 mThread = thread;
/frameworks/support/compat/tests/java/android/support/v4/provider/
H A DSelfDestructiveThreadTest.java49 private void waitUntilDestruction(SelfDestructiveThread thread, long timeoutMs) { argument
50 if (!thread.isRunning()) {
62 if (!thread.isRunning()) {
66 throw new RuntimeException("Timeout for waiting thread destruction.");
87 final SelfDestructiveThread thread = new SelfDestructiveThread(
89 thread.postAndWait(new Callable<Object>() {
95 waitUntilDestruction(thread, DEFAULT_TIMEOUT);
96 assertFalse(thread.isRunning());
102 final SelfDestructiveThread thread = new SelfDestructiveThread(
104 Integer generation = thread
[all...]
/frameworks/opt/bitmap/src/com/android/bitmap/
H A DNamedThreadFactory.java35 final Thread thread = mDefaultThreadFactory.newThread(runnable);
36 thread.setName(mBaseName + "-" + mCount.getAndIncrement());
37 return thread;
/frameworks/base/libs/hwui/pipeline/skia/
H A DSkiaOpenGLReadback.h27 SkiaOpenGLReadback(renderthread::RenderThread& thread) : OpenGLReadback(thread) {} argument
H A DSkiaOpenGLPipeline.cpp38 SkiaOpenGLPipeline::SkiaOpenGLPipeline(RenderThread& thread) argument
39 : SkiaPipeline(thread)
40 , mEglManager(thread.eglManager()) {
186 void SkiaOpenGLPipeline::invokeFunctor(const RenderThread& thread, Functor* functor) { argument
188 if (thread.eglManager().hasEglContext()) {
196 thread.getGrContext()->resetContext();
/frameworks/av/media/mtp/
H A DAsyncIO.h27 #include <thread>
48 std::thread thread; member in struct:aiocb
61 // Suspend current thread until given IO is complete, at which point
76 // Suspend current thread until all queued work is complete, then ends the threadpool
H A DAsyncIO.cpp95 std::thread pool[NUM_THREADS];
100 CHECK(!thread.joinable());
107 pool[i] = std::thread(f, i);
143 aiocbp->thread = std::thread(read_func, aiocbp);
148 aiocbp->thread = std::thread(write_func, aiocbp);
153 aiocbp->thread = std::thread(splice_read_func, aiocbp);
158 aiocbp->thread
[all...]
/frameworks/base/core/tests/coretests/src/android/content/
H A DContentQueryMapTest.java36 /** Helper class to run test code in a new thread with a Looper. */
56 LooperThread thread = new LooperThread() {
101 thread.start();
102 thread.join();
103 if (thread.mError != null) throw thread.mError;
104 assertTrue(thread.mSuccess);
/frameworks/base/libs/hwui/
H A DReadback.h49 explicit Readback(renderthread::RenderThread& thread) : mRenderThread(thread) {} argument
H A DOpenGLReadback.h35 explicit OpenGLReadback(renderthread::RenderThread& thread) : Readback(thread) {} argument
47 OpenGLReadbackImpl(renderthread::RenderThread& thread) : OpenGLReadback(thread) {} argument
/frameworks/native/services/vr/performanced/
H A Dperformance_service_tests.cpp6 #include <thread>
27 std::thread thread([&] {
50 thread.join();
53 // the task id of the thread that we just joined. Technically the
97 std::thread thread([&]() { scheduler = sched_getscheduler(0); });
98 thread.join();
/frameworks/native/services/sensorservice/
H A DSensorRegistrationInfo.h46 IPCThreadState *thread = IPCThreadState::self(); local
47 mPid = (thread != nullptr) ? thread->getCallingPid() : -1;
48 mUid = (thread != nullptr) ? thread->getCallingUid() : -1;
/frameworks/base/libs/hwui/renderthread/
H A DRenderProxy.cpp63 CREATE_BRIDGE4(createContext, RenderThread* thread, bool translucent, argument
65 return CanvasContext::create(*args->thread, args->translucent,
75 args->thread = &mRenderThread;
249 // the render thread.
253 CREATE_BRIDGE2(invokeFunctor, RenderThread* thread, Functor* functor) { argument
254 CanvasContext::invokeFunctor(*args->thread, args->functor);
260 RenderThread& thread = RenderThread::getInstance(); local
262 args->thread = &thread;
270 thread
342 CREATE_BRIDGE2(trimMemory, RenderThread* thread, int level) argument
350 RenderThread& thread = RenderThread::getInstance(); local
412 CREATE_BRIDGE4(dumpProfileInfo, CanvasContext* context, RenderThread* thread, int fd, int dumpFlags) argument
447 CREATE_BRIDGE2(frameTimePercentile, RenderThread* thread, int percentile) argument
460 CREATE_BRIDGE2(dumpGraphicsMemory, int fd, RenderThread* thread) argument
484 CREATE_BRIDGE2(setProcessStatsBuffer, RenderThread* thread, int fd) argument
498 CREATE_BRIDGE1(rotateProcessStatsBuffer, RenderThread* thread) argument
617 CREATE_BRIDGE4(copySurfaceInto, RenderThread* thread, Surface* surface, Rect srcRect, SkBitmap* bitmap) argument
634 CREATE_BRIDGE2(prepareToDraw, RenderThread* thread, Bitmap* bitmap) argument
667 CREATE_BRIDGE2(allocateHardwareBitmap, RenderThread* thread, SkBitmap* bitmap) argument
680 CREATE_BRIDGE3(copyGraphicBufferInto, RenderThread* thread, GraphicBuffer* buffer, SkBitmap* bitmap) argument
685 RenderThread& thread = RenderThread::getInstance(); local
698 CREATE_BRIDGE2(onBitmapDestroyed, RenderThread* thread, uint32_t pixelRefId) argument
706 RenderThread& thread = RenderThread::getInstance(); local
733 RenderThread& thread = RenderThread::getInstance(); local
[all...]
/frameworks/native/libs/vr/libvrflinger/
H A Depoll_event_dispatcher.h9 #include <thread>
29 // |handler| is called on the internal dispatch thread when |fd| is signaled
39 std::thread thread_;
53 // by the event dispatch thread to avoid races.
/frameworks/minikin/tests/stresstest/
H A DMultithreadTest.cpp22 #include <thread>
92 std::vector<std::thread> threads;
104 for (auto& thread : threads) {
105 thread.join();
/frameworks/base/core/java/android/app/
H A DIntentService.java33 * thread, and stops itself when it runs out of work.
36 * from an application's main thread. The IntentService class exists to
39 * will receive the Intents, launch a worker thread, and stop the service as
42 * <p>All requests are handled on a single worker thread -- they may take as
76 * @param name Used to name the worker thread, important only for debugging.
110 HandlerThread thread = new HandlerThread("IntentService[" + mName + "]");
111 thread.start();
113 mServiceLooper = thread.getLooper();
154 * This method is invoked on the worker thread with a request to process.
156 * worker thread tha
[all...]
/frameworks/support/emoji/bundled/src/android/support/text/emoji/bundled/
H A DBundledEmojiCompatConfig.java58 final Thread thread = new Thread(runnable);
59 thread.setDaemon(false);
60 thread.start();
/frameworks/native/cmds/lshal/
H A DTimeout.h21 #include <thread>
67 pthread_t thread; local
68 if (pthread_create(&thread, NULL, callAndNotify, &state)) {
69 std::cerr << "FATAL: could not create background thread." << std::endl;
74 pthread_kill(thread, SIGINT);
76 pthread_join(thread, NULL);
/frameworks/opt/telephony/src/java/com/google/android/mms/util/
H A DPduCache.java104 HashSet<Uri> thread = mThreads.get(threadId);
105 if (thread == null) {
106 thread = new HashSet<Uri>();
107 mThreads.put(threadId, thread);
114 thread.add(finalKey);
232 HashSet<Uri> thread = mThreads.get(entry.getThreadId());
233 if (thread != null) {
234 thread.remove(key);
240 Log.v(TAG, "Purge cache in thread: " + threadId);
243 HashSet<Uri> thread
[all...]
/frameworks/av/services/audioflinger/
H A DTracks.cpp67 ThreadBase *thread,
81 mThread(thread),
100 mThreadIoHandle(thread->id()),
158 const sp<MemoryDealer> roHeap(thread->readOnlyHeap());
173 mBufferMemory = thread->pipeMemory();
297 // will be freed from the main thread once all pending buffers have
363 PlaybackThread *thread,
377 : TrackBase(thread, client, sampleRate, format, channelMask, frameCount,
387 mMainBuffer(thread->mixBuffer()),
434 mName = thread
66 TrackBase( ThreadBase *thread, const sp<Client>& client, uint32_t sampleRate, audio_format_t format, audio_channel_mask_t channelMask, size_t frameCount, void *buffer, audio_session_t sessionId, uid_t clientUid, bool isOut, alloc_type alloc, track_type type, audio_port_handle_t portId) argument
362 Track( PlaybackThread *thread, const sp<Client>& client, audio_stream_type_t streamType, uint32_t sampleRate, audio_format_t format, audio_channel_mask_t channelMask, size_t frameCount, void *buffer, const sp<IMemory>& sharedBuffer, audio_session_t sessionId, uid_t uid, audio_output_flags_t flags, track_type type, audio_port_handle_t portId) argument
492 sp<ThreadBase> thread = mThread.promote(); local
686 sp<ThreadBase> thread = mThread.promote(); local
763 sp<ThreadBase> thread = mThread.promote(); local
795 sp<ThreadBase> thread = mThread.promote(); local
826 sp<ThreadBase> thread = mThread.promote(); local
914 sp<ThreadBase> thread = mThread.promote(); local
950 sp<ThreadBase> thread = mThread.promote(); local
972 sp<ThreadBase> thread = mThread.promote(); local
985 sp<ThreadBase> thread = mThread.promote(); local
1156 sp<ThreadBase> thread = mThread.promote(); local
1365 sp<ThreadBase> thread = mThread.promote(); local
1562 RecordTrack( RecordThread *thread, const sp<Client>& client, uint32_t sampleRate, audio_format_t format, audio_channel_mask_t channelMask, size_t frameCount, void *buffer, audio_session_t sessionId, uid_t uid, audio_input_flags_t flags, track_type type, audio_port_handle_t portId) argument
1650 sp<ThreadBase> thread = mThread.promote(); local
1661 sp<ThreadBase> thread = mThread.promote(); local
1681 sp<ThreadBase> thread = mThread.promote(); local
1831 MmapTrack(ThreadBase *thread, uint32_t sampleRate, audio_format_t format, audio_channel_mask_t channelMask, audio_session_t sessionId, uid_t uid, audio_port_handle_t portId) argument
[all...]
H A DPatchPanel.cpp264 sp<ThreadBase> thread = local
266 newPatch->mPlaybackThread = (MixerThread *)thread.get();
267 if (thread == 0) {
268 ALOGW("createAudioPatch() cannot get playback thread");
277 sp<ThreadBase> thread = audioflinger->openOutput_l( local
284 newPatch->mPlaybackThread = (PlaybackThread *)thread.get();
314 sp<ThreadBase> thread = audioflinger->openInput_l(srcModule, local
321 newPatch->mRecordThread = (RecordThread *)thread.get();
334 sp<ThreadBase> thread = audioflinger->checkRecordThread_l( local
336 if (thread
381 sp<ThreadBase> thread = local
614 sp<ThreadBase> thread = audioflinger->checkRecordThread_l( local
640 sp<ThreadBase> thread = local
[all...]
H A DAudioFlinger.cpp325 sp<MmapThread> thread = mMmapThreads.valueFor(io); local
326 if (thread != 0) {
327 interface = new MmapThreadHandle(thread);
328 thread->configure(attr, streamType, sessionId, callback, portId);
678 // further sample rate checks are performed by createTrack_l() depending on the thread type
685 // further channel mask checks are performed by createTrack_l() depending on the thread type
692 // further format checks are performed by createTrack_l() depending on the thread type
707 PlaybackThread *thread = checkPlaybackThread_l(output); local
708 if (thread == NULL) {
709 ALOGE("no playback thread foun
802 ThreadBase *thread = checkThread_l(ioHandle); local
813 PlaybackThread *thread = checkPlaybackThread_l(output); local
824 ThreadBase *thread = checkThread_l(ioHandle); local
837 ThreadBase *thread = checkThread_l(ioHandle); local
848 PlaybackThread *thread = checkPlaybackThread_l(output); local
1197 sp<RecordThread> thread = mRecordThreads.valueAt(i); local
1228 sp<ThreadBase> thread; local
1278 ThreadBase *thread = (ThreadBase *)checkPlaybackThread_l(ioHandle); local
1476 sp<PlaybackThread> thread; local
1652 RecordThread *thread = checkRecordThread_l(input); local
1810 PlaybackThread *thread = fastPlaybackThread_l(); local
1817 PlaybackThread *thread = fastPlaybackThread_l(); local
1878 sp<PlaybackThread> thread = mPlaybackThreads.valueAt(i); local
1902 ThreadBase *thread = (ThreadBase *)mPlaybackThreads.valueAt(i).get(); local
1906 ThreadBase *thread = (ThreadBase *)mRecordThreads.valueAt(i).get(); local
1913 setAudioHwSyncForSession_l(PlaybackThread *thread, audio_session_t sessionId) argument
1986 sp<MmapPlaybackThread> thread = local
1994 sp<PlaybackThread> thread; local
2041 sp<ThreadBase> thread = openOutput_l(module, output, config, *devices, address, flags); local
2084 DuplicatingThread *thread = new DuplicatingThread(this, thread1, id, mSystemReady); local
2166 closeOutputFinish(const sp<PlaybackThread>& thread) argument
2174 closeOutputInternal_l(const sp<PlaybackThread>& thread) argument
2184 PlaybackThread *thread = checkPlaybackThread_l(output); local
2199 PlaybackThread *thread = checkPlaybackThread_l(output); local
2226 sp<ThreadBase> thread = openInput_l(module, input, config, *devices, address, source, flags); local
2298 sp<MmapCaptureThread> thread = local
2359 sp<RecordThread> thread = new RecordThread(this, local
2458 closeInputFinish(const sp<RecordThread>& thread) argument
2467 closeInputInternal_l(const sp<RecordThread>& thread) argument
2479 PlaybackThread *thread = mPlaybackThreads.valueAt(i).get(); local
2634 ThreadBase *thread = checkMmapThread_l(ioHandle); local
2659 PlaybackThread *thread = checkPlaybackThread_l(output); local
2733 PlaybackThread *thread = mPlaybackThreads.valueAt(i).get(); local
2747 PlaybackThread *thread = primaryPlaybackThread_l(); local
2761 PlaybackThread *thread = mPlaybackThreads.valueAt(i).get(); local
3024 ThreadBase *thread = checkRecordThread_l(io); local
[all...]
/frameworks/av/media/libstagefright/foundation/
H A DALooper.cpp133 sp<LooperThread> thread; local
139 thread = mThread;
145 if (thread == NULL && !runningLocally) {
149 if (thread != NULL) {
150 thread->requestExit();
159 if (!runningLocally && !thread->isCurrentThread()) {
160 // If not running locally and this thread _is_ the looper thread,
162 thread->requestExitAndWait();
/frameworks/base/libs/hwui/tests/microbench/
H A DFrameBuilderBench.cpp62 TestUtils::runOnRenderThread([&state](RenderThread& thread) {
75 TestUtils::runOnRenderThread([&state](RenderThread& thread) {
78 RenderState& renderState = thread.renderState();
115 TestUtils::runOnRenderThread([&state](RenderThread& thread) {
131 TestUtils::runOnRenderThread([&state](RenderThread& thread) {
136 RenderState& renderState = thread.renderState();

Completed in 925 milliseconds

1234567