187c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk/* 287c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk * Copyright (C) 2017 The Android Open Source Project 387c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk * 487c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk * Licensed under the Apache License, Version 2.0 (the "License"); 587c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk * you may not use this file except in compliance with the License. 687c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk * You may obtain a copy of the License at 787c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk * 887c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk * http://www.apache.org/licenses/LICENSE-2.0 987c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk * 1087c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk * Unless required by applicable law or agreed to in writing, software 1187c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk * distributed under the License is distributed on an "AS IS" BASIS, 1287c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 1387c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk * See the License for the specific language governing permissions and 1487c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk * limitations under the License. 1587c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk */ 1687c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk 1787c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk#define LOG_TAG "AAudioService" 1887c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk//#define LOG_NDEBUG 0 1987c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk#include <utils/Log.h> 2087c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk 2187c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk#include <assert.h> 2287c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk#include <map> 2387c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk#include <mutex> 2487c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk#include <utils/Singleton.h> 2587c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk 2687c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk#include "AAudioEndpointManager.h" 2787c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk#include "AAudioServiceEndpoint.h" 2887c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk 2987c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk#include "core/AudioStreamBuilder.h" 3087c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk#include "AAudioServiceEndpoint.h" 3187c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk#include "AAudioServiceStreamShared.h" 3287c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk#include "AAudioServiceEndpointCapture.h" 3387c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk 3487c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burkusing namespace android; // TODO just import names needed 3587c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burkusing namespace aaudio; // TODO just import names needed 3687c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk 3787c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil BurkAAudioServiceEndpointCapture::AAudioServiceEndpointCapture(AAudioService &audioService) 3887c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk : mStreamInternalCapture(audioService, true) { 3987c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk} 4087c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk 4187c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil BurkAAudioServiceEndpointCapture::~AAudioServiceEndpointCapture() { 4287c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk delete mDistributionBuffer; 4387c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk} 4487c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk 4587c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burkaaudio_result_t AAudioServiceEndpointCapture::open(int32_t deviceId) { 4687c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk aaudio_result_t result = AAudioServiceEndpoint::open(deviceId); 4787c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk if (result == AAUDIO_OK) { 4887c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk delete mDistributionBuffer; 4987c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk int distributionBufferSizeBytes = getStreamInternal()->getFramesPerBurst() 5087c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk * getStreamInternal()->getBytesPerFrame(); 5187c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk mDistributionBuffer = new uint8_t[distributionBufferSizeBytes]; 5287c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk } 5387c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk return result; 5487c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk} 5587c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk 5687c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk// Read data from the shared MMAP stream and then distribute it to the client streams. 5787c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burkvoid *AAudioServiceEndpointCapture::callbackLoop() { 5887c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk ALOGD("AAudioServiceEndpointCapture(): callbackLoop() entering"); 5987c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk int32_t underflowCount = 0; 6087c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk 6187c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk aaudio_result_t result = getStreamInternal()->requestStart(); 6287c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk 6387c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk int64_t timeoutNanos = getStreamInternal()->calculateReasonableTimeout(); 6487c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk 6587c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk // result might be a frame count 6687c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk while (mCallbackEnabled.load() && getStreamInternal()->isActive() && (result >= 0)) { 6787c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk // Read audio data from stream using a blocking read. 6887c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk result = getStreamInternal()->read(mDistributionBuffer, getFramesPerBurst(), timeoutNanos); 6987c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk if (result == AAUDIO_ERROR_DISCONNECTED) { 7087c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk disconnectRegisteredStreams(); 7187c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk break; 7287c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk } else if (result != getFramesPerBurst()) { 7387c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk ALOGW("AAudioServiceEndpointCapture(): callbackLoop() read %d / %d", 7487c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk result, getFramesPerBurst()); 7587c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk break; 7687c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk } 7787c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk 7887c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk // Distribute data to each active stream. 7987c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk { // use lock guard 8087c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk std::lock_guard <std::mutex> lock(mLockStreams); 8187c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk for (AAudioServiceStreamShared *sharedStream : mRunningStreams) { 8287c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk FifoBuffer *fifo = sharedStream->getDataFifoBuffer(); 8387c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk if (fifo->getFifoControllerBase()->getEmptyFramesAvailable() < 8487c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk getFramesPerBurst()) { 8587c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk underflowCount++; 8687c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk } else { 8787c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk fifo->write(mDistributionBuffer, getFramesPerBurst()); 8887c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk } 8987c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk sharedStream->markTransferTime(AudioClock::getNanoseconds()); 9087c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk } 9187c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk } 9287c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk } 9387c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk 9487c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk result = getStreamInternal()->requestStop(); 9587c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk 9687c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk ALOGD("AAudioServiceEndpointCapture(): callbackLoop() exiting, %d underflows", underflowCount); 9787c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk return NULL; // TODO review 9887c9f646a94259d7c321c3b3d5947fa1778f5ac2Phil Burk} 99