/frameworks/av/media/libstagefright/foundation/ |
H A D | ALooper.cpp | 133 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 D | AsyncIO.h | 27 #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 D | AudioFlinger.cpp | 325 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 D | Effects.cpp | 59 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 D | Effects.h | 45 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 D | PatchPanel.cpp | 264 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 D | PlaybackTracks.h | 25 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 D | Threads.cpp | 113 // 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 D | Threads.h | 33 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 D | Tracks.cpp | 67 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 D | Section.cpp | 103 // 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 D | Instrumentation.java | 132 * {@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 D | Service.java | 49 * 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 D | AbstractThreadedSyncAdapter.java | 30 * 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 D | SQLiteConnectionPool.java | 50 * 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 D | RemoteViewsAdapter.java | 791 // 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 D | PackageMonitor.java | 72 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 D | WindowManagerPolicyThread.java | 22 * 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 D | StorageManagerIntegrationTest.java | 268 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 D | OpenGLReadback.h | 35 explicit OpenGLReadback(renderthread::RenderThread& thread) : Readback(thread) {} argument 47 OpenGLReadbackImpl(renderthread::RenderThread& thread) : OpenGLReadback(thread) {} argument
|
H A D | Readback.h | 49 explicit Readback(renderthread::RenderThread& thread) : mRenderThread(thread) {} argument
|
/frameworks/base/libs/hwui/pipeline/skia/ |
H A D | SkiaOpenGLPipeline.cpp | 38 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 D | SkiaOpenGLReadback.h | 27 SkiaOpenGLReadback(renderthread::RenderThread& thread) : OpenGLReadback(thread) {} argument
|
H A D | SkiaPipeline.cpp | 43 SkiaPipeline::SkiaPipeline(RenderThread& thread) : mRenderThread(thread) { } argument 154 void SkiaPipeline::prepareToDraw(const RenderThread& thread, Bitmap* bitmap) { argument 155 GrContext* context = thread.getGrContext();
|
H A D | SkiaVulkanPipeline.cpp | 43 SkiaVulkanPipeline::SkiaVulkanPipeline(renderthread::RenderThread& thread) argument 44 : SkiaPipeline(thread) 45 , mVkManager(thread.vulkanManager()) {} 155 void SkiaVulkanPipeline::invokeFunctor(const RenderThread& thread, Functor* functor) { argument
|