Lines Matching defs:thread
65 ThreadBase *thread,
79 mThread(thread),
100 mThreadIoHandle(thread->id())
141 const sp<MemoryDealer> roHeap(thread->readOnlyHeap());
156 mBufferMemory = thread->pipeMemory();
281 // will be freed from the main thread once all pending buffers have
374 PlaybackThread *thread,
387 : TrackBase(thread, client, sampleRate, format, channelMask, frameCount,
397 mMainBuffer(thread->mixBuffer()),
430 mName = thread->getTrackName_l(channelMask, format, sessionId);
438 ALOG_ASSERT(thread->mFastTrackAvailMask != 0);
439 int i = __builtin_ctz(thread->mFastTrackAvailMask);
447 mObservedUnderruns = thread->getFastTrackUnderruns(i);
448 thread->mFastTrackAvailMask &= ~(1 << i);
487 sp<ThreadBase> thread = mThread.promote();
488 if (thread != 0) {
489 Mutex::Autolock _l(thread->mLock);
490 PlaybackThread *playbackThread = (PlaybackThread *)thread.get();
616 // as the normal mixer thread runs at lower
617 // priority than the client's callback thread: there is a short window within framesReady()
660 sp<ThreadBase> thread = mThread.promote();
661 if (thread != 0) {
663 Mutex::Autolock _laf(thread->mAudioFlinger->mLock);
664 Mutex::Autolock _lth(thread->mLock);
665 sp<EffectChain> ec = thread->getEffectChain_l(mSessionId);
666 if (thread->mAudioFlinger->isNonOffloadableGlobalEffectEnabled_l() ||
672 Mutex::Autolock _lth(thread->mLock);
684 ALOGV("PAUSED => STOPPING_1 (%d) on thread %p", mName, this);
687 ALOGV("PAUSED => RESUMING (%d) on thread %p", mName, this);
691 ALOGV("? => ACTIVE (%d) on thread %p", mName, this);
694 PlaybackThread *playbackThread = (PlaybackThread *)thread.get();
708 // It is usually unsafe to access the server proxy from a binder thread.
709 // But in this case we know the mixer thread (whether normal mixer or fast mixer)
710 // isn't looking at this track yet: we still hold the normal mixer thread lock,
711 // and for fast tracks the track is not yet in the fast mixer thread's active set.
725 sp<ThreadBase> thread = mThread.promote();
726 if (thread != 0) {
727 Mutex::Autolock _l(thread->mLock);
731 PlaybackThread *playbackThread = (PlaybackThread *)thread.get();
744 ALOGV("not stopping/stopped => stopping/stopped (%d) on thread %p", mName,
753 sp<ThreadBase> thread = mThread.promote();
754 if (thread != 0) {
755 Mutex::Autolock _l(thread->mLock);
756 PlaybackThread *playbackThread = (PlaybackThread *)thread.get();
771 ALOGV("ACTIVE/RESUMING => PAUSING (%d) on thread %p", mName, thread.get());
784 sp<ThreadBase> thread = mThread.promote();
785 if (thread != 0) {
786 Mutex::Autolock _l(thread->mLock);
787 PlaybackThread *playbackThread = (PlaybackThread *)thread.get();
827 if (thread->type() == ThreadBase::DIRECT) {
834 // before mixer thread can run. This is important when offloading
840 // must be called with thread lock held
852 // the audioflinger thread detects the track is stopped.
867 sp<ThreadBase> thread = mThread.promote();
868 if (thread == 0) {
869 ALOGE("thread is dead");
871 } else if ((thread->type() == ThreadBase::DIRECT) ||
872 (thread->type() == ThreadBase::OFFLOAD)) {
873 return thread->setParameters(keyValuePairs);
886 sp<ThreadBase> thread = mThread.promote();
887 if (thread == 0) {
891 Mutex::Autolock _l(thread->mLock);
892 PlaybackThread *playbackThread = (PlaybackThread *)thread.get();
946 sp<ThreadBase> thread = mThread.promote();
947 if (thread != 0) {
948 PlaybackThread *playbackThread = (PlaybackThread *)thread.get();
1094 sp<ThreadBase> thread = mThread.promote();
1095 if (thread != 0) {
1096 PlaybackThread *t = (PlaybackThread *)thread.get();
1102 //To be called with thread lock held
1115 //To be called with thread lock held
1133 PlaybackThread *thread,
1148 thread, client, streamType, sampleRate, format, channelMask, frameCount,
1153 PlaybackThread *thread,
1163 : Track(thread, client, streamType, sampleRate, format, channelMask,
1679 ALOGW("Error creating output track on thread %p", playbackThread);
1724 sp<ThreadBase> thread = mThread.promote();
1725 if (thread != 0) {
1726 MixerThread *mixerThread = (MixerThread *)thread.get();
1760 ALOGV("OutputTrack::write() %p thread %p no more output buffers; status %d", this,
1790 ALOGV("OutputTrack::write() %p thread %p released overflow buffer %d", this,
1800 sp<ThreadBase> thread = mThread.promote();
1801 if (thread != 0 && !thread->standby()) {
1810 ALOGV("OutputTrack::write() %p thread %p adding overflow buffer %d", this,
1813 ALOGW("OutputTrack::write() %p thread %p no more overflow buffers",
1978 RecordThread *thread,
1989 : TrackBase(thread, client, sampleRate, format,
2009 if (thread->mSampleRate != sampleRate && thread->mChannelCount <= FCC_2 &&
2013 thread->mChannelCount, sampleRate);
2015 mResampler->setSampleRate(thread->mSampleRate);
2021 ALOG_ASSERT(thread->mFastTrackAvail);
2022 thread->mFastTrackAvail = false;
2053 sp<ThreadBase> thread = mThread.promote();
2054 if (thread != 0) {
2055 RecordThread *recordThread = (RecordThread *)thread.get();
2064 sp<ThreadBase> thread = mThread.promote();
2065 if (thread != 0) {
2066 RecordThread *recordThread = (RecordThread *)thread.get();
2084 sp<ThreadBase> thread = mThread.promote();
2085 if (thread != 0) {
2086 Mutex::Autolock _l(thread->mLock);
2087 RecordThread *recordThread = (RecordThread *) thread.get();
