Don Turner | 3bf32ae | 2017-11-27 13:25:05 +0000 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (C) 2016 The Android Open Source Project |
| 3 | * |
| 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
| 5 | * you may not use this file except in compliance with the License. |
| 6 | * You may obtain a copy of the License at |
| 7 | * |
| 8 | * http://www.apache.org/licenses/LICENSE-2.0 |
| 9 | * |
| 10 | * Unless required by applicable law or agreed to in writing, software |
| 11 | * distributed under the License is distributed on an "AS IS" BASIS, |
| 12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 13 | * See the License for the specific language governing permissions and |
| 14 | * limitations under the License. |
| 15 | */ |
| 16 | |
| 17 | #ifndef OBOE_STREAM_BUFFERED_H |
| 18 | #define OBOE_STREAM_BUFFERED_H |
| 19 | |
Phil Burk | 373e646 | 2018-02-07 20:37:17 -0800 | [diff] [blame^] | 20 | #include <cstring> |
| 21 | #include <assert.h> |
Don Turner | 3bf32ae | 2017-11-27 13:25:05 +0000 | [diff] [blame] | 22 | #include "common/OboeDebug.h" |
Don Turner | 379e8e5 | 2017-11-29 15:49:29 +0000 | [diff] [blame] | 23 | #include "oboe/AudioStream.h" |
| 24 | #include "oboe/AudioStreamCallback.h" |
Don Turner | 3bf32ae | 2017-11-27 13:25:05 +0000 | [diff] [blame] | 25 | #include "fifo/FifoBuffer.h" |
| 26 | |
| 27 | namespace oboe { |
| 28 | |
| 29 | // A stream that contains a FIFO buffer. |
Phil Burk | 373e646 | 2018-02-07 20:37:17 -0800 | [diff] [blame^] | 30 | // This is used to implement blocking reads and writes. |
Don Turner | 379e8e5 | 2017-11-29 15:49:29 +0000 | [diff] [blame] | 31 | class AudioStreamBuffered : public AudioStream { |
Don Turner | 3bf32ae | 2017-11-27 13:25:05 +0000 | [diff] [blame] | 32 | public: |
| 33 | |
Don Turner | 379e8e5 | 2017-11-29 15:49:29 +0000 | [diff] [blame] | 34 | AudioStreamBuffered(); |
| 35 | explicit AudioStreamBuffered(const AudioStreamBuilder &builder); |
Phil Burk | 373e646 | 2018-02-07 20:37:17 -0800 | [diff] [blame^] | 36 | ~AudioStreamBuffered(); |
Don Turner | 3bf32ae | 2017-11-27 13:25:05 +0000 | [diff] [blame] | 37 | |
Phil Burk | 373e646 | 2018-02-07 20:37:17 -0800 | [diff] [blame^] | 38 | Result finishOpen(); |
Don Turner | 3bf32ae | 2017-11-27 13:25:05 +0000 | [diff] [blame] | 39 | |
| 40 | int32_t write(const void *buffer, |
| 41 | int32_t numFrames, |
| 42 | int64_t timeoutNanoseconds) override; |
| 43 | |
Phil Burk | 373e646 | 2018-02-07 20:37:17 -0800 | [diff] [blame^] | 44 | int32_t read(void *buffer, |
| 45 | int32_t numFrames, |
| 46 | int64_t timeoutNanoseconds) override; |
| 47 | |
Don Turner | 3bf32ae | 2017-11-27 13:25:05 +0000 | [diff] [blame] | 48 | Result setBufferSizeInFrames(int32_t requestedFrames) override; |
| 49 | |
| 50 | int32_t getBufferSizeInFrames() const override; |
| 51 | |
| 52 | int32_t getBufferCapacityInFrames() const override; |
| 53 | |
| 54 | protected: |
| 55 | |
Don Turner | 379e8e5 | 2017-11-29 15:49:29 +0000 | [diff] [blame] | 56 | class AudioStreamBufferedCallback : public AudioStreamCallback { |
Don Turner | 3bf32ae | 2017-11-27 13:25:05 +0000 | [diff] [blame] | 57 | public: |
Don Turner | 379e8e5 | 2017-11-29 15:49:29 +0000 | [diff] [blame] | 58 | AudioStreamBufferedCallback(AudioStreamBuffered *bufferedStream) |
Don Turner | 3bf32ae | 2017-11-27 13:25:05 +0000 | [diff] [blame] | 59 | : mBufferedStream(bufferedStream) { |
| 60 | } |
| 61 | |
| 62 | virtual ~AudioStreamBufferedCallback() {} |
| 63 | |
| 64 | virtual DataCallbackResult onAudioReady( |
Don Turner | 379e8e5 | 2017-11-29 15:49:29 +0000 | [diff] [blame] | 65 | AudioStream *audioStream, |
Don Turner | 3bf32ae | 2017-11-27 13:25:05 +0000 | [diff] [blame] | 66 | void *audioData, |
| 67 | int numFrames) { |
Phil Burk | 373e646 | 2018-02-07 20:37:17 -0800 | [diff] [blame^] | 68 | int32_t framesTransferred = 0; |
| 69 | static int transferCount = 0; |
| 70 | |
| 71 | if (mBufferedStream->getDirection() == oboe::Direction::Output) { |
| 72 | // This OUTPUT callback will read from the FIFO and write to audioData |
| 73 | framesTransferred = mBufferedStream->mFifoBuffer->readNow(audioData, numFrames); |
| 74 | LOGV("AudioStreamBufferedCallback::onAudioReady() read %d / %d frames from FIFO, #%d", |
| 75 | framesTransferred, numFrames, transferCount); |
| 76 | } else { |
| 77 | // This INPUT callback will read from audioData and write to the FIFO |
| 78 | framesTransferred = mBufferedStream->mFifoBuffer->write(audioData, numFrames); |
| 79 | LOGD("AudioStreamBufferedCallback::onAudioReady() wrote %d / %d frames to FIFO, #%d", |
| 80 | framesTransferred, numFrames, transferCount); |
| 81 | } |
| 82 | transferCount++; |
| 83 | // return (framesTransferred >= 0) ? DataCallbackResult::Continue : DataCallbackResult::Stop; |
| 84 | return DataCallbackResult::Continue; |
Don Turner | 3bf32ae | 2017-11-27 13:25:05 +0000 | [diff] [blame] | 85 | } |
| 86 | |
| 87 | virtual void onExit(Result reason) {} |
| 88 | private: |
Don Turner | 379e8e5 | 2017-11-29 15:49:29 +0000 | [diff] [blame] | 89 | AudioStreamBuffered *mBufferedStream; |
Don Turner | 3bf32ae | 2017-11-27 13:25:05 +0000 | [diff] [blame] | 90 | }; |
| 91 | |
| 92 | private: |
| 93 | |
Phil Burk | 373e646 | 2018-02-07 20:37:17 -0800 | [diff] [blame^] | 94 | FifoBuffer *mFifoBuffer = nullptr; |
Don Turner | d4b7f08 | 2017-12-01 13:51:54 +0000 | [diff] [blame] | 95 | std::unique_ptr<AudioStreamBufferedCallback> mInternalCallback; |
Don Turner | 3bf32ae | 2017-11-27 13:25:05 +0000 | [diff] [blame] | 96 | }; |
| 97 | |
| 98 | } // namespace oboe |
| 99 | |
| 100 | #endif //OBOE_STREAM_BUFFERED_H |