Searched defs:thread (Results 1 - 25 of 50) sorted by path

12

/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/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
/frameworks/av/services/audioflinger/
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...]
H A DEffects.cpp59 AudioFlinger::EffectModule::EffectModule(ThreadBase *thread, argument
66 mThread(thread), mChain(chain), mId(id), mSessionId(sessionId),
73 mAudioFlinger(thread->mAudioFlinger)
85 &desc->uuid, sessionId, thread->id(), &mEffectInterface);
98 setOffloaded(thread->type() == ThreadBase::OFFLOAD, thread->id());
211 // unsafe method called when the effect parent thread has been destroyed
348 sp<ThreadBase> thread; local
357 thread = mThread.promote();
358 if (thread
487 sp<ThreadBase> thread = mThread.promote(); local
585 sp<ThreadBase> thread = mThread.promote(); local
1210 sp<ThreadBase> thread = effect->thread().promote(); local
1269 sp<ThreadBase> thread = effect->thread().promote(); local
1298 sp<ThreadBase> thread; local
1508 EffectChain(ThreadBase *thread, audio_session_t sessionId) argument
1571 sp<ThreadBase> thread = mThread.promote(); local
1580 clearInputBuffer_l(const sp<ThreadBase>& thread) argument
1598 sp<ThreadBase> thread = mThread.promote(); local
1656 createEffect_l(sp<EffectModule>& effect, ThreadBase *thread, effect_descriptor_t *desc, int id, audio_session_t sessionId, bool pinned) argument
1688 sp<ThreadBase> thread = mThread.promote(); local
2193 setThread(const sp<ThreadBase>& thread) argument
[all...]
H A DEffects.h45 EffectModule(ThreadBase *thread,
98 void setThread(const wp<ThreadBase>& thread) { mThread = thread; } argument
99 const wp<ThreadBase>& thread() { return mThread; } function in class:EffectModule
153 wp<ThreadBase> mThread; // parent thread
256 // There can be any number of EffectChain objects per output mixer thread (PlaybackThread).
267 EffectChain(ThreadBase *thread, audio_session_t sessionId);
288 ThreadBase *thread,
364 // isCompatibleWithThread_l() must be called with thread->mLock held
365 bool isCompatibleWithThread_l(const sp<ThreadBase>& thread) cons
[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 DPlaybackTracks.h25 Track( PlaybackThread *thread,
126 // FIXME parameters not needed, could get them from the thread
161 // access these three variables only when holding thread lock.
183 bool mFlushHwPending; // track requests for thread flush
197 OutputTrack(PlaybackThread *thread,
213 const wp<ThreadBase>& thread() const { return mThread; } function in class:OutputTrack
H A DThreads.cpp113 // allow less retry attempts on direct output thread.
129 // minimum sleep time for the mixer thread loop when tracks are active but in underrun
131 // maximum divider applied to the active sleep time in the mixer thread loop
140 // minimum capture buffer size in milliseconds to _not_ need a fast capture thread
144 // Offloaded output thread standby delay: allows track transition without going to standby
147 // Direct output thread minimum sleep time in idle or active(underrun) state
336 ThreadCpuUsage mCpuUsage; // instantaneous thread CPU usage in wall clock ns
337 CentralTendencyStatistics mWcStats; // statistics on thread CPU usage in wall clock ns
339 CentralTendencyStatistics mHzStats; // statistics on thread CPU usage in cycles
341 int mCpuNum; // thread'
991 sp<ThreadBase> thread = mThread.promote(); local
1587 updatePowerState( sp<ThreadBase> thread, bool force) argument
5821 addOutputTrack(MixerThread *thread) argument
5851 removeOutputTrack(MixerThread *thread) argument
5888 sp<ThreadBase> thread = outputTracks[i]->thread().promote(); local
7481 MmapThreadHandle(const sp<MmapThread>& thread) argument
7488 MmapThread *thread = mThread.get(); local
[all...]
H A DThreads.h33 MMAP // control thread for MMAP stream
69 // Config event sequence by client if status needed (e.g binder thread calling setParameters()):
225 explicit PMDeathRecipient(const wp<ThreadBase>& thread) : mThread(thread) {} argument
384 // Return a reference to a per-thread heap which can be used to allocate IMemory
386 // and shared by all client processes of the thread.
387 // The heap is per-thread rather than common across all threads, because
389 // If a thread does not have such a heap, this method returns 0.
464 // These fields are written and read by thread itself without lock or barrier,
467 // Because of the absence of a lock or barrier, any other thread tha
[all...]
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...]
/frameworks/base/cmds/incidentd/src/
H A DSection.cpp103 // data might be gone now. don't use it after this point in this thread.
111 pthread_t thread; local
116 // Data shared between this thread and the worker thread.
125 // The worker thread needs a reference and we can't let the count go to zero
126 // if that thread is slow to start.
129 // Create the thread
134 // TODO: Do we need to tweak thread priority?
140 err = pthread_create(&thread, &attr, worker_thread_func, (void*)data.get());
155 // Done with the read fd. The worker thread close
[all...]
/frameworks/base/core/java/android/app/
H A DInstrumentation.java132 * {@link #start} to begin the instrumentation thread, which will then
135 * <p>If you do not need your own thread -- that is you are writing your
148 * Create and start a new thread in which to run instrumentation. This new
149 * thread will call to {@link #onStart} where you can implement the
161 * Method where the instrumentation thread enters execution. This allows
162 * you to run your instrumentation code in a separate thread than the
372 * Schedule a callback for when the application's main thread goes idle
375 * @param recipient Called the next time the thread's message queue is
385 * from the main application thread -- use {@link #start} to execute
386 * instrumentation in its own thread
1910 init(ActivityThread thread, Context instrContext, Context appContext, ComponentName component, IInstrumentationWatcher watcher, IUiAutomationConnection uiAutomationConnection) argument
[all...]
H A DService.java49 * thread of their hosting process. This means that, if your service is going
51 * networking) operations, it should spawn its own thread in which to do that
55 * as a standard implementation of Service that has its own thread where it
84 * <li> A Service is <b>not</b> a thread. It is not a means itself to do work off
85 * of the main thread (to avoid Application Not Responding errors).
107 * main thread. It is up to the Service to implement these with the appropriate
108 * behavior, such as creating a secondary thread in which it does its work.</p>
235 * to schedule work to be done asynchronously or in another thread, then you
403 * and spawns a thread to do its networking. If its process is killed
483 * service's main thread
757 attach( Context context, ActivityThread thread, String className, IBinder token, Application application, Object activityManager) argument
[all...]
/frameworks/base/core/java/android/content/
H A DAbstractThreadedSyncAdapter.java30 * An abstract implementation of a SyncAdapter that spawns a thread to invoke a sync operation.
33 * However if there is no sync in progress then a thread will be spawned and {@link #onPerformSync}
34 * will be invoked on that thread.
44 * A sync is cancelled by issuing a {@link Thread#interrupt()} on the syncing thread. <strong>Either
138 * at the same time, each in their own thread. This must be consistent with the setting
234 * The thread that invokes {@link AbstractThreadedSyncAdapter#onPerformSync}. It also acquires
236 * this thread in order to cancel the sync.
341 * thread than the sync thread and so you must consider the multi-threaded implications
359 * thread tha
366 onSyncCanceled(Thread thread) argument
[all...]
/frameworks/base/core/java/android/database/sqlite/
H A DSQLiteConnectionPool.java50 * The connection pool is thread-safe (but the connections themselves are not).
141 * This flag indicates that the connection is needed by the UI thread.
657 // Park the thread until a connection is assigned or the pool is closed.
738 final Thread thread = Thread.currentThread();
741 msg.append("' has been unable to grant a connection to thread ");
742 msg.append(thread.getId()).append(" (").append(thread.getName()).append(") ");
967 private ConnectionWaiter obtainConnectionWaiterLocked(Thread thread, long startTime, argument
976 waiter.mThread = thread;
1045 + " ms - thread
[all...]
/frameworks/base/core/java/android/widget/
H A DRemoteViewsAdapter.java791 // Initialize the worker thread
1187 // Because temporary meta data is only ever modified from this thread (ie.
1303 HandlerThreadExecutor(HandlerThread thread) { argument
1304 mThread = thread;
1330 // Inflate the first view on the worker thread
/frameworks/base/core/java/com/android/internal/content/
H A DPackageMonitor.java72 public void register(Context context, Looper thread, boolean externalStorage) { argument
73 register(context, thread, null, externalStorage);
76 public void register(Context context, Looper thread, UserHandle user, argument
79 (thread == null) ? BackgroundThread.getHandler() : new Handler(thread));
/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/base/core/tests/coretests/src/android/os/storage/
H A DStorageManagerIntegrationTest.java268 assertNotSame(Thread.State.TERMINATED, factory.thread.getState());
274 factory.thread.join(3000);
275 assertEquals(Thread.State.TERMINATED, factory.thread.getState());
280 assertNotSame(Thread.State.TERMINATED, factory.thread.getState());
286 Thread thread = null; field in class:StorageManagerIntegrationTest.MyThreadFactory
290 thread = new Thread(r);
291 return thread;
/frameworks/base/libs/hwui/
H A DOpenGLReadback.h35 explicit OpenGLReadback(renderthread::RenderThread& thread) : Readback(thread) {} argument
47 OpenGLReadbackImpl(renderthread::RenderThread& thread) : OpenGLReadback(thread) {} argument
H A DReadback.h49 explicit Readback(renderthread::RenderThread& thread) : mRenderThread(thread) {} argument
/frameworks/base/libs/hwui/pipeline/skia/
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();
H A DSkiaOpenGLReadback.h27 SkiaOpenGLReadback(renderthread::RenderThread& thread) : OpenGLReadback(thread) {} argument
H A DSkiaPipeline.cpp43 SkiaPipeline::SkiaPipeline(RenderThread& thread) : mRenderThread(thread) { } argument
154 void SkiaPipeline::prepareToDraw(const RenderThread& thread, Bitmap* bitmap) { argument
155 GrContext* context = thread.getGrContext();
H A DSkiaVulkanPipeline.cpp43 SkiaVulkanPipeline::SkiaVulkanPipeline(renderthread::RenderThread& thread) argument
44 : SkiaPipeline(thread)
45 , mVkManager(thread.vulkanManager()) {}
155 void SkiaVulkanPipeline::invokeFunctor(const RenderThread& thread, Functor* functor) { argument

Completed in 1799 milliseconds

12