197b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten/* 297b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten * Copyright (C) 2012 The Android Open Source Project 397b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten * 497b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten * Licensed under the Apache License, Version 2.0 (the "License"); 597b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten * you may not use this file except in compliance with the License. 697b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten * You may obtain a copy of the License at 797b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten * 897b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten * http://www.apache.org/licenses/LICENSE-2.0 997b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten * 1097b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten * Unless required by applicable law or agreed to in writing, software 1197b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten * distributed under the License is distributed on an "AS IS" BASIS, 1297b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 1397b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten * See the License for the specific language governing permissions and 1497b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten * limitations under the License. 1597b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten */ 1697b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 17a3d2628a22f2b3d682495044897a40ea1399a662Glenn Kasten// <IMPORTANT_WARNING> 18a3d2628a22f2b3d682495044897a40ea1399a662Glenn Kasten// Design rules for threadLoop() are given in the comments at section "Fast mixer thread" of 19a3d2628a22f2b3d682495044897a40ea1399a662Glenn Kasten// StateQueue.h. In particular, avoid library and system calls except at well-known points. 20a3d2628a22f2b3d682495044897a40ea1399a662Glenn Kasten// The design rules are only for threadLoop(), and don't apply to FastMixerDumpState methods. 21a3d2628a22f2b3d682495044897a40ea1399a662Glenn Kasten// </IMPORTANT_WARNING> 22a3d2628a22f2b3d682495044897a40ea1399a662Glenn Kasten 2397b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten#define LOG_TAG "FastMixer" 247f5d335f7b4caecd0dfb8f1085f352f1d2da5d2eGlenn Kasten//#define LOG_NDEBUG 0 2597b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 26b3a8364eeea621ef63b983e4c1b0771f62069fe0Alex Ray#define ATRACE_TAG ATRACE_TAG_AUDIO 27371eb9756c32109ea572b91216b19bb623f6d3fdAlex Ray 28153b9fe667e6e78e0218ff0159353097428c7657Glenn Kasten#include "Configuration.h" 2997b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten#include <time.h> 30ad8510a339ffab330c2c46e5c247dd1cf9e15c22Glenn Kasten#include <utils/Debug.h> 3197b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten#include <utils/Log.h> 32d8e6fd35ec2b59ee7d873daf1f1d9d348221c7bcGlenn Kasten#include <utils/Trace.h> 3397b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten#include <system/audio.h> 34214b406c813e5baca3e4b5cdc1d986de35f09bbbGlenn Kasten#ifdef FAST_THREAD_STATISTICS 3597b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten#include <cpustats/CentralTendencyStatistics.h> 360a14c4ce1a41bc09eb7855fa531a3af629a69139Glenn Kasten#ifdef CPU_FREQUENCY_STATISTICS 3742d45cfd0c3d62357a6549c62f535e4d4fe08d91Glenn Kasten#include <cpustats/ThreadCpuUsage.h> 3897b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten#endif 390a14c4ce1a41bc09eb7855fa531a3af629a69139Glenn Kasten#endif 406bf707f4c0752643757a7389384817da41d34fabGlenn Kasten#include <audio_utils/mono_blend.h> 411258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung#include <audio_utils/format.h> 42068561c8e84569d51df2adbbb53b56fdfd09c06bAndy Hung#include <media/AudioMixer.h> 4397b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten#include "FastMixer.h" 44eef598c5539aa2be5a106f2483b19e368e4b8c0eGlenn Kasten#include "TypedLogger.h" 4597b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 4697b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kastennamespace android { 4797b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 48e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten/*static*/ const FastMixerState FastMixer::sInitial; 492234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 50f9715e43ea73361321663514c44129c939c5db2fGlenn KastenFastMixer::FastMixer() : FastThread("cycle_ms", "load_us"), 51e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten // mFastTrackNames 52e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten // mGenerations 53e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOutputSink(NULL), 54e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOutputSinkGen(0), 55e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer(NULL), 561258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung mSinkBuffer(NULL), 571258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung mSinkBufferSize(0), 589a59276fb465e492138e0576523b54079671e8f4Andy Hung mSinkChannelCount(FCC_2), 5945d68d366d07b10733c1e8af6a6984befbc08ce1Andy Hung mMixerBuffer(NULL), 601258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung mMixerBufferSize(0), 611258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung mMixerBufferFormat(AUDIO_FORMAT_PCM_16_BIT), 6245d68d366d07b10733c1e8af6a6984befbc08ce1Andy Hung mMixerBufferState(UNDEFINED), 63e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mFormat(Format_Invalid), 64e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mSampleRate(0), 65e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mFastTracksGen(0), 66e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mTotalNativeFramesWritten(0), 672234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // timestamp 682ddee19245641e86bca436dda23a0f5089bf2ab5Andy Hung mNativeFramesWrittenButNotPresented(0), // the = 0 is to silence the compiler 692ddee19245641e86bca436dda23a0f5089bf2ab5Andy Hung mMasterMono(false) 7097b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten{ 71e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten // FIXME pass sInitial as parameter to base class constructor, and make it static local 72e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mPrevious = &sInitial; 73e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mCurrent = &sInitial; 742234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 75e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mDummyDumpState = &mDummyFastMixerDumpState; 769a59276fb465e492138e0576523b54079671e8f4Andy Hung // TODO: Add channel mask to NBAIO_Format. 779a59276fb465e492138e0576523b54079671e8f4Andy Hung // We assume that the channel mask must be a valid positional channel mask. 789a59276fb465e492138e0576523b54079671e8f4Andy Hung mSinkChannelMask = audio_channel_out_mask_from_count(mSinkChannelCount); 792234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 8097b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten unsigned i; 81dc2c50bad491d2c0c8a2efc0e24491076701c63cGlenn Kasten for (i = 0; i < FastMixerState::sMaxFastTracks; ++i) { 82e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mFastTrackNames[i] = -1; 83e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mGenerations[i] = 0; 8497b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten } 85214b406c813e5baca3e4b5cdc1d986de35f09bbbGlenn Kasten#ifdef FAST_THREAD_STATISTICS 86e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOldLoad.tv_sec = 0; 87e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOldLoad.tv_nsec = 0; 880a14c4ce1a41bc09eb7855fa531a3af629a69139Glenn Kasten#endif 892234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} 9097b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 912234002b0710c8db73f82d397cb945cd541c6bbbGlenn KastenFastMixer::~FastMixer() 922234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten{ 932234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} 9497b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 952234002b0710c8db73f82d397cb945cd541c6bbbGlenn KastenFastMixerStateQueue* FastMixer::sq() 962234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten{ 972234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten return &mSQ; 982234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} 9997b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 1002234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kastenconst FastThreadState *FastMixer::poll() 1012234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten{ 1022234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten return mSQ.poll(); 1032234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} 10497b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 1053ab8d66ad1c47a5ee1f87ad9f5ee2666cf89b32dGlenn Kastenvoid FastMixer::setNBLogWriter(NBLog::Writer *logWriter) 1062234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten{ 1073ab8d66ad1c47a5ee1f87ad9f5ee2666cf89b32dGlenn Kasten // FIXME If mMixer is set or changed prior to this, we don't inform correctly. 1083ab8d66ad1c47a5ee1f87ad9f5ee2666cf89b32dGlenn Kasten // Should cache logWriter and re-apply it at the assignment to mMixer. 109e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mMixer != NULL) { 1103ab8d66ad1c47a5ee1f87ad9f5ee2666cf89b32dGlenn Kasten mMixer->setNBLogWriter(logWriter); 1112234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1122234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} 11397b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 1142234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kastenvoid FastMixer::onIdle() 1152234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten{ 116e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mPreIdle = *(const FastMixerState *)mCurrent; 117e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mCurrent = &mPreIdle; 1182234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} 11997b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 1202234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kastenvoid FastMixer::onExit() 1212234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten{ 122e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten delete mMixer; 1231258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung free(mMixerBuffer); 1241258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung free(mSinkBuffer); 1252234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} 1262234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 1272234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kastenbool FastMixer::isSubClassCommand(FastThreadState::Command command) 1282234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten{ 1292234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten switch ((FastMixerState::Command) command) { 1302234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten case FastMixerState::MIX: 1312234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten case FastMixerState::WRITE: 1322234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten case FastMixerState::MIX_WRITE: 1332234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten return true; 1342234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten default: 1352234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten return false; 1362234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1372234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} 1382234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 1392234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kastenvoid FastMixer::onStateChange() 1402234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten{ 141a8a8a47da86e181d835eab7f858d6b1d2c3a8357Sanna Catherine de Treville Wager // log that audio was turned on/off 142a8a8a47da86e181d835eab7f858d6b1d2c3a8357Sanna Catherine de Treville Wager LOG_AUDIO_STATE(); 1434dd03b5b68dcd8eb5f5ffe2cfe93d26b8f08b848Glenn Kasten const FastMixerState * const current = (const FastMixerState *) mCurrent; 1444dd03b5b68dcd8eb5f5ffe2cfe93d26b8f08b848Glenn Kasten const FastMixerState * const previous = (const FastMixerState *) mPrevious; 1454dd03b5b68dcd8eb5f5ffe2cfe93d26b8f08b848Glenn Kasten FastMixerDumpState * const dumpState = (FastMixerDumpState *) mDumpState; 1462234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten const size_t frameCount = current->mFrameCount; 1472234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 148818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung // update boottime offset, in case it has changed 149818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung mTimestamp.mTimebaseOffset[ExtendedTimestamp::TIMEBASE_BOOTTIME] = 150818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung mBoottimeOffset.load(); 151818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung 1522234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // handle state change here, but since we want to diff the state, 153e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten // we're prepared for previous == &sInitial the first time through 1542234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten unsigned previousTrackMask; 1552234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 1562234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // check for change in output HAL configuration 157e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten NBAIO_Format previousFormat = mFormat; 158e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (current->mOutputSinkGen != mOutputSinkGen) { 159e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOutputSink = current->mOutputSink; 160e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOutputSinkGen = current->mOutputSinkGen; 161e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mOutputSink == NULL) { 162e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mFormat = Format_Invalid; 163e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mSampleRate = 0; 1649a59276fb465e492138e0576523b54079671e8f4Andy Hung mSinkChannelCount = 0; 1659a59276fb465e492138e0576523b54079671e8f4Andy Hung mSinkChannelMask = AUDIO_CHANNEL_NONE; 1662234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 167e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mFormat = mOutputSink->format(); 168e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mSampleRate = Format_sampleRate(mFormat); 169e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mSinkChannelCount = Format_channelCount(mFormat); 1709a59276fb465e492138e0576523b54079671e8f4Andy Hung LOG_ALWAYS_FATAL_IF(mSinkChannelCount > AudioMixer::MAX_NUM_CHANNELS); 1719a59276fb465e492138e0576523b54079671e8f4Andy Hung 1729a59276fb465e492138e0576523b54079671e8f4Andy Hung // TODO: Add channel mask to NBAIO_Format 1739a59276fb465e492138e0576523b54079671e8f4Andy Hung // We assume that the channel mask must be a valid positional channel mask. 1749a59276fb465e492138e0576523b54079671e8f4Andy Hung mSinkChannelMask = audio_channel_out_mask_from_count(mSinkChannelCount); 1752234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 176e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten dumpState->mSampleRate = mSampleRate; 1772234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 1782234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 179e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if ((!Format_isEqual(mFormat, previousFormat)) || (frameCount != previous->mFrameCount)) { 1802234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // FIXME to avoid priority inversion, don't delete here 181e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten delete mMixer; 182e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer = NULL; 1831258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung free(mMixerBuffer); 18445d68d366d07b10733c1e8af6a6984befbc08ce1Andy Hung mMixerBuffer = NULL; 1851258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung free(mSinkBuffer); 1861258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung mSinkBuffer = NULL; 187e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (frameCount > 0 && mSampleRate > 0) { 18860c545dfc4160a6d46febb9aa6684f6d300ec74dAndy Hung // The mixer produces either 16 bit PCM or float output, select 18960c545dfc4160a6d46febb9aa6684f6d300ec74dAndy Hung // float output if the HAL supports higher than 16 bit precision. 19060c545dfc4160a6d46febb9aa6684f6d300ec74dAndy Hung mMixerBufferFormat = mFormat.mFormat == AUDIO_FORMAT_PCM_16_BIT ? 19160c545dfc4160a6d46febb9aa6684f6d300ec74dAndy Hung AUDIO_FORMAT_PCM_16_BIT : AUDIO_FORMAT_PCM_FLOAT; 1922234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // FIXME new may block for unbounded time at internal mutex of the heap 1932234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // implementation; it would be better to have normal mixer allocate for us 1942234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // to avoid blocking here and to prevent possible priority inversion 195dc2c50bad491d2c0c8a2efc0e24491076701c63cGlenn Kasten mMixer = new AudioMixer(frameCount, mSampleRate, FastMixerState::sMaxFastTracks); 1963ab8d66ad1c47a5ee1f87ad9f5ee2666cf89b32dGlenn Kasten // FIXME See the other FIXME at FastMixer::setNBLogWriter() 1979a59276fb465e492138e0576523b54079671e8f4Andy Hung const size_t mixerFrameSize = mSinkChannelCount 1989a59276fb465e492138e0576523b54079671e8f4Andy Hung * audio_bytes_per_sample(mMixerBufferFormat); 1991258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung mMixerBufferSize = mixerFrameSize * frameCount; 2001258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung (void)posix_memalign(&mMixerBuffer, 32, mMixerBufferSize); 2019a59276fb465e492138e0576523b54079671e8f4Andy Hung const size_t sinkFrameSize = mSinkChannelCount 202e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten * audio_bytes_per_sample(mFormat.mFormat); 2031258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung if (sinkFrameSize > mixerFrameSize) { // need a sink buffer 2041258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung mSinkBufferSize = sinkFrameSize * frameCount; 2051258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung (void)posix_memalign(&mSinkBuffer, 32, mSinkBufferSize); 2061258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung } 207e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mPeriodNs = (frameCount * 1000000000LL) / mSampleRate; // 1.00 208e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mUnderrunNs = (frameCount * 1750000000LL) / mSampleRate; // 1.75 209e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOverrunNs = (frameCount * 500000000LL) / mSampleRate; // 0.50 210e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mForceNs = (frameCount * 950000000LL) / mSampleRate; // 0.95 211e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mWarmupNsMin = (frameCount * 750000000LL) / mSampleRate; // 0.75 212e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mWarmupNsMax = (frameCount * 1250000000LL) / mSampleRate; // 1.25 2132234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 214e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mPeriodNs = 0; 215e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mUnderrunNs = 0; 216e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mOverrunNs = 0; 217e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mForceNs = 0; 218e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mWarmupNsMin = 0; 219e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mWarmupNsMax = LONG_MAX; 2202234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 22145d68d366d07b10733c1e8af6a6984befbc08ce1Andy Hung mMixerBufferState = UNDEFINED; 22297b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten#if !LOG_NDEBUG 223dc2c50bad491d2c0c8a2efc0e24491076701c63cGlenn Kasten for (unsigned i = 0; i < FastMixerState::sMaxFastTracks; ++i) { 224e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mFastTrackNames[i] = -1; 2252234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 22697b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten#endif 2272234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // we need to reconfigure all active tracks 2282234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten previousTrackMask = 0; 229e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mFastTracksGen = current->mFastTracksGen - 1; 2302234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState->mFrameCount = frameCount; 2312234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 2322234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten previousTrackMask = previous->mTrackMask; 2332234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 23497b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 2352234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // check for change in active track set 2362234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten const unsigned currentTrackMask = current->mTrackMask; 2372234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState->mTrackMask = currentTrackMask; 238e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (current->mFastTracksGen != mFastTracksGen) { 23945d68d366d07b10733c1e8af6a6984befbc08ce1Andy Hung ALOG_ASSERT(mMixerBuffer != NULL); 2402234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten int name; 2412234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 2422234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // process removed tracks first to avoid running out of track names 2432234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten unsigned removedTracks = previousTrackMask & ~currentTrackMask; 2442234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten while (removedTracks != 0) { 2452234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten int i = __builtin_ctz(removedTracks); 2462234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten removedTracks &= ~(1 << i); 2472234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten const FastTrack* fastTrack = ¤t->mFastTracks[i]; 2482234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOG_ASSERT(fastTrack->mBufferProvider == NULL); 249e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mMixer != NULL) { 250e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten name = mFastTrackNames[i]; 2512234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOG_ASSERT(name >= 0); 252e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->deleteTrackName(name); 2532234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 25497b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten#if !LOG_NDEBUG 255e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mFastTrackNames[i] = -1; 25697b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten#endif 2572234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // don't reset track dump state, since other side is ignoring it 258e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mGenerations[i] = fastTrack->mGeneration; 2592234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 26097b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 2612234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // now process added tracks 2622234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten unsigned addedTracks = currentTrackMask & ~previousTrackMask; 2632234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten while (addedTracks != 0) { 2642234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten int i = __builtin_ctz(addedTracks); 2652234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten addedTracks &= ~(1 << i); 2662234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten const FastTrack* fastTrack = ¤t->mFastTracks[i]; 2672234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten AudioBufferProvider *bufferProvider = fastTrack->mBufferProvider; 268e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten ALOG_ASSERT(bufferProvider != NULL && mFastTrackNames[i] == -1); 269e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mMixer != NULL) { 270e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten name = mMixer->getTrackName(fastTrack->mChannelMask, 271e8a1ced4da17dc6c07803dc2af8060f62a8389c1Andy Hung fastTrack->mFormat, AUDIO_SESSION_OUTPUT_MIX); 2722234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOG_ASSERT(name >= 0); 273e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mFastTrackNames[i] = name; 274e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setBufferProvider(name, bufferProvider); 275e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setParameter(name, AudioMixer::TRACK, AudioMixer::MAIN_BUFFER, 2769a59276fb465e492138e0576523b54079671e8f4Andy Hung (void *)mMixerBuffer); 2772234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // newly allocated track names default to full scale volume 278e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setParameter( 2791258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung name, 2801258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung AudioMixer::TRACK, 2811258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung AudioMixer::MIXER_FORMAT, (void *)mMixerBufferFormat); 282e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setParameter(name, AudioMixer::TRACK, AudioMixer::FORMAT, 283ef7c7fbd0e3fb36af14cd7d39f64c949031516a5Andy Hung (void *)(uintptr_t)fastTrack->mFormat); 284e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setParameter(name, AudioMixer::TRACK, AudioMixer::CHANNEL_MASK, 2859a59276fb465e492138e0576523b54079671e8f4Andy Hung (void *)(uintptr_t)fastTrack->mChannelMask); 286e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setParameter(name, AudioMixer::TRACK, AudioMixer::MIXER_CHANNEL_MASK, 2879a59276fb465e492138e0576523b54079671e8f4Andy Hung (void *)(uintptr_t)mSinkChannelMask); 288e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->enable(name); 2892234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 290e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mGenerations[i] = fastTrack->mGeneration; 2912234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 29297b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 2932234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // finally process (potentially) modified tracks; these use the same slot 2942234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // but may have a different buffer provider or volume provider 2952234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten unsigned modifiedTracks = currentTrackMask & previousTrackMask; 2962234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten while (modifiedTracks != 0) { 2972234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten int i = __builtin_ctz(modifiedTracks); 2982234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten modifiedTracks &= ~(1 << i); 2992234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten const FastTrack* fastTrack = ¤t->mFastTracks[i]; 300e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (fastTrack->mGeneration != mGenerations[i]) { 3012234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // this track was actually modified 3022234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten AudioBufferProvider *bufferProvider = fastTrack->mBufferProvider; 3032234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOG_ASSERT(bufferProvider != NULL); 304e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mMixer != NULL) { 305e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten name = mFastTrackNames[i]; 3062234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOG_ASSERT(name >= 0); 307e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setBufferProvider(name, bufferProvider); 3082234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (fastTrack->mVolumeProvider == NULL) { 3096be494077f8d7970f3a88129c5d139c5a0c88f6dAndy Hung float f = AudioMixer::UNITY_GAIN_FLOAT; 310e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setParameter(name, AudioMixer::VOLUME, AudioMixer::VOLUME0, &f); 311e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setParameter(name, AudioMixer::VOLUME, AudioMixer::VOLUME1, &f); 31297b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten } 313e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setParameter(name, AudioMixer::RESAMPLE, 3142234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten AudioMixer::REMOVE, NULL); 315e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setParameter( 3161258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung name, 3171258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung AudioMixer::TRACK, 3181258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung AudioMixer::MIXER_FORMAT, (void *)mMixerBufferFormat); 319e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setParameter(name, AudioMixer::TRACK, AudioMixer::FORMAT, 320ef7c7fbd0e3fb36af14cd7d39f64c949031516a5Andy Hung (void *)(uintptr_t)fastTrack->mFormat); 321e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setParameter(name, AudioMixer::TRACK, AudioMixer::CHANNEL_MASK, 3229a59276fb465e492138e0576523b54079671e8f4Andy Hung (void *)(uintptr_t)fastTrack->mChannelMask); 323e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setParameter(name, AudioMixer::TRACK, AudioMixer::MIXER_CHANNEL_MASK, 3249a59276fb465e492138e0576523b54079671e8f4Andy Hung (void *)(uintptr_t)mSinkChannelMask); 3252234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // already enabled 32697b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten } 327e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mGenerations[i] = fastTrack->mGeneration; 32897b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten } 32997b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten } 33097b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 331e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mFastTracksGen = current->mFastTracksGen; 332732845c7e8d294bb1aaa4cd9687da62b51f1f6e6Glenn Kasten 3332234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState->mNumTracks = popcount(currentTrackMask); 3342234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 3352234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten} 3362c3b2da3049627264b7c6b449a1622f002210f03John Grossman 3372234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kastenvoid FastMixer::onWork() 3382234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten{ 339eef598c5539aa2be5a106f2483b19e368e4b8c0eGlenn Kasten LOG_HIST_TS(); 3404dd03b5b68dcd8eb5f5ffe2cfe93d26b8f08b848Glenn Kasten const FastMixerState * const current = (const FastMixerState *) mCurrent; 3414dd03b5b68dcd8eb5f5ffe2cfe93d26b8f08b848Glenn Kasten FastMixerDumpState * const dumpState = (FastMixerDumpState *) mDumpState; 3424dd03b5b68dcd8eb5f5ffe2cfe93d26b8f08b848Glenn Kasten const FastMixerState::Command command = mCommand; 3432234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten const size_t frameCount = current->mFrameCount; 3442234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 345e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if ((command & FastMixerState::MIX) && (mMixer != NULL) && mIsWarm) { 346ef7c7fbd0e3fb36af14cd7d39f64c949031516a5Andy Hung ALOG_ASSERT(mMixerBuffer != NULL); 347947ffa37beced7cca943477b4d748b0f6b279b0bMohan Kumar 348947ffa37beced7cca943477b4d748b0f6b279b0bMohan Kumar // AudioMixer::mState.enabledTracks is undefined if mState.hook == process__validate, 349947ffa37beced7cca943477b4d748b0f6b279b0bMohan Kumar // so we keep a side copy of enabledTracks 350947ffa37beced7cca943477b4d748b0f6b279b0bMohan Kumar bool anyEnabledTracks = false; 351947ffa37beced7cca943477b4d748b0f6b279b0bMohan Kumar 3522234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // for each track, update volume and check for underrun 3532234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten unsigned currentTrackMask = current->mTrackMask; 3542234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten while (currentTrackMask != 0) { 3552234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten int i = __builtin_ctz(currentTrackMask); 3562234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten currentTrackMask &= ~(1 << i); 3572234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten const FastTrack* fastTrack = ¤t->mFastTracks[i]; 3582234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 359818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung const int64_t trackFramesWrittenButNotPresented = 360818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung mNativeFramesWrittenButNotPresented; 361818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung const int64_t trackFramesWritten = fastTrack->mBufferProvider->framesReleased(); 362818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung ExtendedTimestamp perTrackTimestamp(mTimestamp); 363818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung 364818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung // Can't provide an ExtendedTimestamp before first frame presented. 365818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung // Also, timestamp may not go to very last frame on stop(). 366818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung if (trackFramesWritten >= trackFramesWrittenButNotPresented && 367818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung perTrackTimestamp.mTimeNs[ExtendedTimestamp::LOCATION_KERNEL] > 0) { 368818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung perTrackTimestamp.mPosition[ExtendedTimestamp::LOCATION_KERNEL] = 369818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung trackFramesWritten - trackFramesWrittenButNotPresented; 370818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung } else { 371818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung perTrackTimestamp.mPosition[ExtendedTimestamp::LOCATION_KERNEL] = 0; 372818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung perTrackTimestamp.mTimeNs[ExtendedTimestamp::LOCATION_KERNEL] = -1; 3736e2ebe97f2ad0a21907f20f9ee644c4eacbb7a40Glenn Kasten } 374818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung perTrackTimestamp.mPosition[ExtendedTimestamp::LOCATION_SERVER] = trackFramesWritten; 375818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung fastTrack->mBufferProvider->onTimestamp(perTrackTimestamp); 3762c3b2da3049627264b7c6b449a1622f002210f03John Grossman 377e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten int name = mFastTrackNames[i]; 3782234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOG_ASSERT(name >= 0); 3792234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (fastTrack->mVolumeProvider != NULL) { 380c56f3426099a3cf2d07ccff8886050c7fbce140fGlenn Kasten gain_minifloat_packed_t vlr = fastTrack->mVolumeProvider->getVolumeLR(); 3816be494077f8d7970f3a88129c5d139c5a0c88f6dAndy Hung float vlf = float_from_gain(gain_minifloat_unpack_left(vlr)); 3826be494077f8d7970f3a88129c5d139c5a0c88f6dAndy Hung float vrf = float_from_gain(gain_minifloat_unpack_right(vlr)); 3836be494077f8d7970f3a88129c5d139c5a0c88f6dAndy Hung 384e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setParameter(name, AudioMixer::VOLUME, AudioMixer::VOLUME0, &vlf); 385e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->setParameter(name, AudioMixer::VOLUME, AudioMixer::VOLUME1, &vrf); 386fbae5dae5187aca9d974cbe15ec818e9c6f56705Glenn Kasten } 3872234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // FIXME The current implementation of framesReady() for fast tracks 3882234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // takes a tryLock, which can block 3892234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // up to 1 ms. If enough active tracks all blocked in sequence, this would result 3902234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // in the overall fast mix cycle being delayed. Should use a non-blocking FIFO. 3912234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten size_t framesReady = fastTrack->mBufferProvider->framesReady(); 3922234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (ATRACE_ENABLED()) { 3932234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // I wish we had formatted trace names 3942234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten char traceName[16]; 3952234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten strcpy(traceName, "fRdy"); 3962234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten traceName[4] = i + (i < 10 ? '0' : 'A' - 10); 3972234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten traceName[5] = '\0'; 3982234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ATRACE_INT(traceName, framesReady); 39997b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten } 4002234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten FastTrackDump *ftDump = &dumpState->mTracks[i]; 4012234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten FastTrackUnderruns underruns = ftDump->mUnderruns; 4022234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (framesReady < frameCount) { 4032234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (framesReady == 0) { 4042234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten underruns.mBitFields.mEmpty++; 4052234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten underruns.mBitFields.mMostRecent = UNDERRUN_EMPTY; 406e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->disable(name); 407732845c7e8d294bb1aaa4cd9687da62b51f1f6e6Glenn Kasten } else { 4082234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // allow mixing partial buffer 4092234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten underruns.mBitFields.mPartial++; 4102234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten underruns.mBitFields.mMostRecent = UNDERRUN_PARTIAL; 411e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->enable(name); 412947ffa37beced7cca943477b4d748b0f6b279b0bMohan Kumar anyEnabledTracks = true; 413732845c7e8d294bb1aaa4cd9687da62b51f1f6e6Glenn Kasten } 4142234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 4152234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten underruns.mBitFields.mFull++; 4162234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten underruns.mBitFields.mMostRecent = UNDERRUN_FULL; 417e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mMixer->enable(name); 418947ffa37beced7cca943477b4d748b0f6b279b0bMohan Kumar anyEnabledTracks = true; 419732845c7e8d294bb1aaa4cd9687da62b51f1f6e6Glenn Kasten } 4202234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ftDump->mUnderruns = underruns; 4212234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ftDump->mFramesReady = framesReady; 422b54c854d1ef1bb66e093c94099f915178eac570eAndy Hung ftDump->mFramesWritten = trackFramesWritten; 42397b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten } 42497b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 425947ffa37beced7cca943477b4d748b0f6b279b0bMohan Kumar if (anyEnabledTracks) { 426947ffa37beced7cca943477b4d748b0f6b279b0bMohan Kumar // process() is CPU-bound 427947ffa37beced7cca943477b4d748b0f6b279b0bMohan Kumar mMixer->process(); 428947ffa37beced7cca943477b4d748b0f6b279b0bMohan Kumar mMixerBufferState = MIXED; 429947ffa37beced7cca943477b4d748b0f6b279b0bMohan Kumar } else if (mMixerBufferState != ZEROED) { 430947ffa37beced7cca943477b4d748b0f6b279b0bMohan Kumar mMixerBufferState = UNDEFINED; 431947ffa37beced7cca943477b4d748b0f6b279b0bMohan Kumar } 432947ffa37beced7cca943477b4d748b0f6b279b0bMohan Kumar 43345d68d366d07b10733c1e8af6a6984befbc08ce1Andy Hung } else if (mMixerBufferState == MIXED) { 43445d68d366d07b10733c1e8af6a6984befbc08ce1Andy Hung mMixerBufferState = UNDEFINED; 4352234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 4362234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten //bool didFullWrite = false; // dumpsys could display a count of partial writes 437e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if ((command & FastMixerState::WRITE) && (mOutputSink != NULL) && (mMixerBuffer != NULL)) { 43845d68d366d07b10733c1e8af6a6984befbc08ce1Andy Hung if (mMixerBufferState == UNDEFINED) { 4391258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung memset(mMixerBuffer, 0, mMixerBufferSize); 44045d68d366d07b10733c1e8af6a6984befbc08ce1Andy Hung mMixerBufferState = ZEROED; 4412234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 4422ddee19245641e86bca436dda23a0f5089bf2ab5Andy Hung 4432ddee19245641e86bca436dda23a0f5089bf2ab5Andy Hung if (mMasterMono.load()) { // memory_order_seq_cst 444c42e9b462661673dff480ee71757a58b0f806370Glenn Kasten mono_blend(mMixerBuffer, mMixerBufferFormat, Format_channelCount(mFormat), frameCount, 445c42e9b462661673dff480ee71757a58b0f806370Glenn Kasten true /*limit*/); 4462ddee19245641e86bca436dda23a0f5089bf2ab5Andy Hung } 447f59497bd3c190e087202043de5450ef06e92b27dGlenn Kasten // prepare the buffer used to write to sink 4481258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung void *buffer = mSinkBuffer != NULL ? mSinkBuffer : mMixerBuffer; 449e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (mFormat.mFormat != mMixerBufferFormat) { // sink format not the same as mixer format 450e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten memcpy_by_audio_format(buffer, mFormat.mFormat, mMixerBuffer, mMixerBufferFormat, 451e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten frameCount * Format_channelCount(mFormat)); 4521258c1ab592a899fabb1e31eb5db2ef413b6f38aAndy Hung } 4532234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // if non-NULL, then duplicate write() to this non-blocking sink 4542234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten NBAIO_Sink* teeSink; 4552234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if ((teeSink = current->mTeeSink) != NULL) { 456329f6511ee4e03a4605c70bbda8d3a96d2544884Glenn Kasten (void) teeSink->write(buffer, frameCount); 4572234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 4582234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // FIXME write() is non-blocking and lock-free for a properly implemented NBAIO sink, 4592234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // but this code should be modified to handle both non-blocking and blocking sinks 4602234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState->mWriteSequence++; 4612234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ATRACE_BEGIN("write"); 462e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten ssize_t framesWritten = mOutputSink->write(buffer, frameCount); 4632234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ATRACE_END(); 4642234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState->mWriteSequence++; 4652234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten if (framesWritten >= 0) { 4662234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten ALOG_ASSERT((size_t) framesWritten <= frameCount); 467e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mTotalNativeFramesWritten += framesWritten; 468e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten dumpState->mFramesWritten = mTotalNativeFramesWritten; 4692234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten //if ((size_t) framesWritten == frameCount) { 4702234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // didFullWrite = true; 4712234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten //} 4722234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } else { 4732234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten dumpState->mWriteErrors++; 4742234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 475e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mAttemptedWrite = true; 4762234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // FIXME count # of writes blocked excessively, CPU usage, etc. for dump 4772234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten 478818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung ExtendedTimestamp timestamp; // local 479818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung status_t status = mOutputSink->getTimestamp(timestamp); 480818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung if (status == NO_ERROR) { 481818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung const int64_t totalNativeFramesPresented = 482818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung timestamp.mPosition[ExtendedTimestamp::LOCATION_KERNEL]; 483e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten if (totalNativeFramesPresented <= mTotalNativeFramesWritten) { 484e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mNativeFramesWrittenButNotPresented = 485e4a7ce250cb94a00aa2f76e5edca1c4479dc5401Glenn Kasten mTotalNativeFramesWritten - totalNativeFramesPresented; 486818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung mTimestamp.mPosition[ExtendedTimestamp::LOCATION_KERNEL] = 487818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung timestamp.mPosition[ExtendedTimestamp::LOCATION_KERNEL]; 488818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung mTimestamp.mTimeNs[ExtendedTimestamp::LOCATION_KERNEL] = 489818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung timestamp.mTimeNs[ExtendedTimestamp::LOCATION_KERNEL]; 49097b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten } else { 4912234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten // HAL reported that more frames were presented than were written 492818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung mNativeFramesWrittenButNotPresented = 0; 493818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung status = INVALID_OPERATION; 49497b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten } 49597b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten } 496818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung if (status == NO_ERROR) { 497818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung mTimestamp.mTimeNs[ExtendedTimestamp::LOCATION_SERVER] = 498818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung mTimestamp.mTimeNs[ExtendedTimestamp::LOCATION_KERNEL]; 499818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung } else { 500818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung // fetch server time if we can't get timestamp 501818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung mTimestamp.mTimeNs[ExtendedTimestamp::LOCATION_SERVER] = 502818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung systemTime(SYSTEM_TIME_MONOTONIC); 50307eee80b3422c0304491f24bbc415deb0badbefcAndy Hung // clear out kernel cached position as this may get rapidly stale 50407eee80b3422c0304491f24bbc415deb0badbefcAndy Hung // if we never get a new valid timestamp 50507eee80b3422c0304491f24bbc415deb0badbefcAndy Hung mTimestamp.mPosition[ExtendedTimestamp::LOCATION_KERNEL] = 0; 50607eee80b3422c0304491f24bbc415deb0badbefcAndy Hung mTimestamp.mTimeNs[ExtendedTimestamp::LOCATION_KERNEL] = -1; 507818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hung } 5082234002b0710c8db73f82d397cb945cd541c6bbbGlenn Kasten } 50997b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten} 51097b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten 51197b5d0d5b5ef766eb5dd680d05a5d199662d4ae0Glenn Kasten} // namespace android 512