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 "MonoPipeReader" 18010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten//#define LOG_NDEBUG 0 19010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 20010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten#include <cutils/compiler.h> 21010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten#include <utils/Log.h> 222dd4bdd715f586d4d30cf90cc6fc2bbfbce60fe0Glenn Kasten#include <media/nbaio/MonoPipeReader.h> 23010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 24010662326b9c43c703725f933e95e0897f8a6bddGlenn Kastennamespace android { 25010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 26010662326b9c43c703725f933e95e0897f8a6bddGlenn KastenMonoPipeReader::MonoPipeReader(MonoPipe* pipe) : 27010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten NBAIO_Source(pipe->mFormat), 28ed99c2b5a99a8bfc163a6ffa0b767c82032b09b5Glenn Kasten mPipe(pipe), mFifoReader(mPipe->mFifo, true /*throttlesWriter*/) 29010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten{ 30010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} 31010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 32010662326b9c43c703725f933e95e0897f8a6bddGlenn KastenMonoPipeReader::~MonoPipeReader() 33010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten{ 34010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} 35010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 36010662326b9c43c703725f933e95e0897f8a6bddGlenn Kastenssize_t MonoPipeReader::availableToRead() 37010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten{ 38010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten if (CC_UNLIKELY(!mNegotiated)) { 39010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten return NEGOTIATE; 40010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 41ed99c2b5a99a8bfc163a6ffa0b767c82032b09b5Glenn Kasten ssize_t ret = mFifoReader.available(); 42ed99c2b5a99a8bfc163a6ffa0b767c82032b09b5Glenn Kasten ALOG_ASSERT(ret <= mPipe->mMaxFrames); 43010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten return ret; 44010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} 45010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 46d79072e9dff59f767cce2cda1caab80ce5a0815bGlenn Kastenssize_t MonoPipeReader::read(void *buffer, size_t count) 47010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten{ 48010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten // count == 0 is unlikely and not worth checking for explicitly; will be handled automatically 49ed99c2b5a99a8bfc163a6ffa0b767c82032b09b5Glenn Kasten ssize_t actual = mFifoReader.read(buffer, count); 50ed99c2b5a99a8bfc163a6ffa0b767c82032b09b5Glenn Kasten ALOG_ASSERT(actual <= count); 51ed99c2b5a99a8bfc163a6ffa0b767c82032b09b5Glenn Kasten if (CC_UNLIKELY(actual <= 0)) { 52ed99c2b5a99a8bfc163a6ffa0b767c82032b09b5Glenn Kasten return actual; 53010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten } 54ed99c2b5a99a8bfc163a6ffa0b767c82032b09b5Glenn Kasten mFramesRead += (size_t) actual; 55ed99c2b5a99a8bfc163a6ffa0b767c82032b09b5Glenn Kasten return actual; 56010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} 57010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten 58818e7a32ce3633980138aff2c2bfcc5158b3cfccAndy Hungvoid MonoPipeReader::onTimestamp(const ExtendedTimestamp ×tamp) 59894d6be4f9b4721c77a01919ecf03b27cec90cc9Glenn Kasten{ 60894d6be4f9b4721c77a01919ecf03b27cec90cc9Glenn Kasten mPipe->mTimestampMutator.push(timestamp); 61894d6be4f9b4721c77a01919ecf03b27cec90cc9Glenn Kasten} 62894d6be4f9b4721c77a01919ecf03b27cec90cc9Glenn Kasten 63010662326b9c43c703725f933e95e0897f8a6bddGlenn Kasten} // namespace android 64