1010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten/* 2010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * Copyright (C) 2012 The Android Open Source Project 3010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * 4010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * Licensed under the Apache License, Version 2.0 (the "License"); 5010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * you may not use this file except in compliance with the License. 6010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * You may obtain a copy of the License at 7010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * 8010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * http://www.apache.org/licenses/LICENSE-2.0 9010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * 10010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * Unless required by applicable law or agreed to in writing, software 11010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * distributed under the License is distributed on an "AS IS" BASIS, 12010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * See the License for the specific language governing permissions and 14010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten * limitations under the License. 15010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten */ 16010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 17010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten#define LOG_TAG "AudioStreamOutSink" 18010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten//#define LOG_NDEBUG 0 19010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 20010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten#include <utils/Log.h> 21fc7992bd8220824f1404c0c54ac516d9e28b58c2Glenn Kasten#include <media/nbaio/AudioStreamOutSink.h> 22010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 23010662326b9c43c703725f933e95e0897f8a6bddGlenn Kastennamespace android { 24010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 25010662326b9c43c703725f933e95e0897f8a6bddGlenn KastenAudioStreamOutSink::AudioStreamOutSink(audio_stream_out *stream) : 26010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten NBAIO_Sink(), 27010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mStream(stream), 28010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mStreamBufferSizeBytes(0) 29010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten{ 30010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten ALOG_ASSERT(stream != NULL); 31010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} 32010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 33010662326b9c43c703725f933e95e0897f8a6bddGlenn KastenAudioStreamOutSink::~AudioStreamOutSink() 34010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten{ 35010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} 36010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 37010662326b9c43c703725f933e95e0897f8a6bddGlenn Kastenssize_t AudioStreamOutSink::negotiate(const NBAIO_Format offers[], size_t numOffers, 38010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten NBAIO_Format counterOffers[], size_t& numCounterOffers) 39010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten{ 40010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (mFormat == Format_Invalid) { 41010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mStreamBufferSizeBytes = mStream->common.get_buffer_size(&mStream->common); 42010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten audio_format_t streamFormat = mStream->common.get_format(&mStream->common); 43010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (streamFormat == AUDIO_FORMAT_PCM_16_BIT) { 44010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten uint32_t sampleRate = mStream->common.get_sample_rate(&mStream->common); 45010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten audio_channel_mask_t channelMask = 46010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten (audio_channel_mask_t) mStream->common.get_channels(&mStream->common); 47010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mFormat = Format_from_SR_C(sampleRate, popcount(channelMask)); 48010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mBitShift = Format_frameBitShift(mFormat); 49010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 50010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 51010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten return NBAIO_Sink::negotiate(offers, numOffers, counterOffers, numCounterOffers); 52010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} 53010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 54010662326b9c43c703725f933e95e0897f8a6bddGlenn Kastenssize_t AudioStreamOutSink::write(const void *buffer, size_t count) 55010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten{ 56010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (!mNegotiated) { 57010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten return NEGOTIATE; 58010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 59010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten ALOG_ASSERT(mFormat != Format_Invalid); 60010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten ssize_t ret = mStream->write(mStream, buffer, count << mBitShift); 61010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (ret > 0) { 62010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten ret >>= mBitShift; 63010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten mFramesWritten += ret; 64010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } else { 65010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten // FIXME verify HAL implementations are returning the correct error codes e.g. WOULD_BLOCK 66010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 67010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten return ret; 68010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} 69010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 702c3b2da3049627264b7c6b449a1622f002210f03John Grossmanstatus_t AudioStreamOutSink::getNextWriteTimestamp(int64_t *timestamp) { 712c3b2da3049627264b7c6b449a1622f002210f03John Grossman ALOG_ASSERT(timestamp != NULL); 722c3b2da3049627264b7c6b449a1622f002210f03John Grossman 732c3b2da3049627264b7c6b449a1622f002210f03John Grossman if (NULL == mStream) 742c3b2da3049627264b7c6b449a1622f002210f03John Grossman return INVALID_OPERATION; 752c3b2da3049627264b7c6b449a1622f002210f03John Grossman 762c3b2da3049627264b7c6b449a1622f002210f03John Grossman if (NULL == mStream->get_next_write_timestamp) 772c3b2da3049627264b7c6b449a1622f002210f03John Grossman return INVALID_OPERATION; 782c3b2da3049627264b7c6b449a1622f002210f03John Grossman 792c3b2da3049627264b7c6b449a1622f002210f03John Grossman return mStream->get_next_write_timestamp(mStream, timestamp); 802c3b2da3049627264b7c6b449a1622f002210f03John Grossman} 812c3b2da3049627264b7c6b449a1622f002210f03John Grossman 82010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} // namespace android 83