Lines Matching defs:cblk

59 Proxy::Proxy(audio_track_cblk_t* cblk, void *buffers, size_t frameCount, size_t frameSize,
61 : mCblk(cblk), mBuffers(buffers), mFrameCount(frameCount), mFrameSize(frameSize),
69 ClientProxy::ClientProxy(audio_track_cblk_t* cblk, void *buffers, size_t frameCount,
71 : Proxy(cblk, buffers, frameCount, frameSize, isOut, clientInServer)
73 , mTimestampObserver(&cblk->mExtendedTimestampQueue)
141 audio_track_cblk_t* cblk = mCblk;
149 int32_t flags = android_atomic_and(~CBLK_INTERRUPT, &cblk->mFlags);
179 front = android_atomic_acquire_load(&cblk->u.mStreaming.mFront);
180 rear = cblk->u.mStreaming.mRear;
183 rear = android_atomic_acquire_load(&cblk->u.mStreaming.mRear);
184 front = cblk->u.mStreaming.mFront;
199 cblk->u.mStreaming.mFront = rear;
200 (void) android_atomic_or(CBLK_OVERRUN, &cblk->mFlags);
273 int32_t old = android_atomic_and(~CBLK_FUTEX_WAKE, &cblk->mFutex);
280 (void) syscall(__NR_futex, &cblk->mFutex,
350 audio_track_cblk_t* cblk = mCblk;
353 int32_t rear = cblk->u.mStreaming.mRear;
354 android_atomic_release_store(stepCount + rear, &cblk->u.mStreaming.mRear);
356 int32_t front = cblk->u.mStreaming.mFront;
357 android_atomic_release_store(stepCount + front, &cblk->u.mStreaming.mFront);
363 audio_track_cblk_t* cblk = mCblk;
364 if (!(android_atomic_or(CBLK_INVALID, &cblk->mFlags) & CBLK_INVALID)) {
365 android_atomic_or(CBLK_FUTEX_WAKE, &cblk->mFutex);
367 (void) syscall(__NR_futex, &cblk->mFutex, mClientInServer ? FUTEX_WAKE_PRIVATE : FUTEX_WAKE,
374 audio_track_cblk_t* cblk = mCblk;
375 if (!(android_atomic_or(CBLK_INTERRUPT, &cblk->mFlags) & CBLK_INTERRUPT)) {
376 android_atomic_or(CBLK_FUTEX_WAKE, &cblk->mFutex);
377 (void) syscall(__NR_futex, &cblk->mFutex, mClientInServer ? FUTEX_WAKE_PRIVATE : FUTEX_WAKE,
385 audio_track_cblk_t* cblk = mCblk;
386 return (mFrameCountP2 - (mIsOut ? cblk->u.mStreaming.mRear : cblk->u.mStreaming.mFront)) &
397 audio_track_cblk_t* cblk = mCblk;
399 // Should newFlush = cblk->u.mStreaming.mRear? Only problem is
401 int32_t newFlush = (cblk->u.mStreaming.mRear & mask) |
402 ((cblk->u.mStreaming.mFlush & ~mask) + increment);
403 android_atomic_release_store(newFlush, &cblk->u.mStreaming.mFlush);
419 audio_track_cblk_t* cblk = mCblk;
437 int32_t flags = android_atomic_and(~(CBLK_INTERRUPT|CBLK_STREAM_END_DONE), &cblk->mFlags);
495 int32_t old = android_atomic_and(~CBLK_FUTEX_WAKE, &cblk->mFutex);
498 (void) syscall(__NR_futex, &cblk->mFutex,
523 StaticAudioTrackClientProxy::StaticAudioTrackClientProxy(audio_track_cblk_t* cblk, void *buffers,
525 : AudioTrackClientProxy(cblk, buffers, frameCount, frameSize),
526 mMutator(&cblk->u.mStatic.mSingleStateQueue),
527 mPosLoopObserver(&cblk->u.mStatic.mPosLoopQueue)
615 ServerProxy::ServerProxy(audio_track_cblk_t* cblk, void *buffers, size_t frameCount,
617 : Proxy(cblk, buffers, frameCount, frameSize, isOut, clientInServer),
619 , mTimestampMutator(&cblk->mExtendedTimestampQueue)
621 cblk->mBufferSizeInFrames = frameCount;
627 audio_track_cblk_t* cblk = mCblk;
632 int32_t flush = android_atomic_acquire_load(&cblk->u.mStreaming.mFlush);
636 int32_t rear = android_atomic_acquire_load(&cblk->u.mStreaming.mRear);
637 int32_t front = cblk->u.mStreaming.mFront;
661 android_atomic_release_store(newFront, &cblk->u.mStreaming.mFront);
664 int32_t old = android_atomic_or(CBLK_FUTEX_WAKE, &cblk->mFutex);
666 (void) syscall(__NR_futex, &cblk->mFutex,
682 audio_track_cblk_t* cblk = mCblk;
690 rear = android_atomic_acquire_load(&cblk->u.mStreaming.mRear);
691 front = cblk->u.mStreaming.mFront;
693 front = android_atomic_acquire_load(&cblk->u.mStreaming.mFront);
694 rear = cblk->u.mStreaming.mRear;
765 audio_track_cblk_t* cblk = mCblk;
767 int32_t front = cblk->u.mStreaming.mFront;
768 android_atomic_release_store(stepCount + front, &cblk->u.mStreaming.mFront);
770 int32_t rear = cblk->u.mStreaming.mRear;
771 android_atomic_release_store(stepCount + rear, &cblk->u.mStreaming.mRear);
774 cblk->mServer += stepCount;
781 size_t minimum = (size_t) cblk->mMinimum;
790 int32_t old = android_atomic_or(CBLK_FUTEX_WAKE, &cblk->mFutex);
792 (void) syscall(__NR_futex, &cblk->mFutex,
812 audio_track_cblk_t* cblk = mCblk;
814 int32_t flush = cblk->u.mStreaming.mFlush;
820 int32_t rear = android_atomic_acquire_load(&cblk->u.mStreaming.mRear);
821 ssize_t filled = rear - cblk->u.mStreaming.mFront;
836 audio_track_cblk_t* cblk = mCblk;
838 (android_atomic_or(CBLK_STREAM_END_DONE, &cblk->mFlags) & CBLK_STREAM_END_DONE) != 0;
840 (void) syscall(__NR_futex, &cblk->mFutex, mClientInServer ? FUTEX_WAKE_PRIVATE : FUTEX_WAKE,
848 audio_track_cblk_t* cblk = mCblk;
850 cblk->u.mStreaming.mUnderrunFrames += frameCount;
854 cblk->u.mStreaming.mUnderrunCount = mUnderrunCount;
857 frameCount, cblk->u.mStreaming.mUnderrunFrames, mUnderrunCount);
861 (void) android_atomic_or(CBLK_UNDERRUN, &cblk->mFlags);
865 frameCount, cblk->u.mStreaming.mUnderrunFrames);
878 StaticAudioTrackServerProxy::StaticAudioTrackServerProxy(audio_track_cblk_t* cblk, void *buffers,
880 : AudioTrackServerProxy(cblk, buffers, frameCount, frameSize),
881 mObserver(&cblk->u.mStatic.mSingleStateQueue),
882 mPosLoopMutator(&cblk->u.mStatic.mPosLoopQueue),
1052 audio_track_cblk_t* cblk = mCblk;
1077 cblk->mServer += stepCount;
1086 (void) android_atomic_or(setFlags, &cblk->mFlags);