1 ////////////////////////////////////////////////////////////////////////////// 2 // 3 // Copyright (c) 2004-2021 musikcube team 4 // 5 // All rights reserved. 6 // 7 // Redistribution and use in source and binary forms, with or without 8 // modification, are permitted provided that the following conditions are met: 9 // 10 // * Redistributions of source code must retain the above copyright notice, 11 // this list of conditions and the following disclaimer. 12 // 13 // * Redistributions in binary form must reproduce the above copyright 14 // notice, this list of conditions and the following disclaimer in the 15 // documentation and/or other materials provided with the distribution. 16 // 17 // * Neither the name of the author nor the names of other contributors may 18 // be used to endorse or promote products derived from this software 19 // without specific prior written permission. 20 // 21 // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" 22 // AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 23 // IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 24 // ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE 25 // LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 26 // CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF 27 // SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 28 // INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN 29 // CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) 30 // ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE 31 // POSSIBILITY OF SUCH DAMAGE. 32 // 33 ////////////////////////////////////////////////////////////////////////////// 34 35 #pragma once 36 37 #include <musikcore/config.h> 38 #include <musikcore/io/DataStreamFactory.h> 39 #include <musikcore/audio/Buffer.h> 40 #include <musikcore/audio/IStream.h> 41 #include <musikcore/sdk/IDecoder.h> 42 #include <musikcore/sdk/IDSP.h> 43 #include <musikcore/sdk/constants.h> 44 45 #include <deque> 46 #include <list> 47 48 namespace musik { namespace core { namespace audio { 49 50 class Stream : public IStream { 51 using IDSP = musik::core::sdk::IDSP; 52 using IDecoder = musik::core::sdk::IDecoder; 53 using IBuffer = musik::core::sdk::IBuffer; 54 using StreamFlags = musik::core::sdk::StreamFlags; 55 56 public: 57 static IStreamPtr Create( 58 int samplesPerChannel = 2048, 59 double bufferLengthSeconds = 5, 60 StreamFlags options = StreamFlags::None); 61 62 static IStream* CreateUnmanaged( 63 int samplesPerChannel = 2048, 64 double bufferLengthSeconds = 5, 65 StreamFlags options = StreamFlags::None); 66 67 private: 68 Stream( 69 int samplesPerChannel, 70 double bufferLengthSeconds, 71 StreamFlags options); 72 73 public: 74 virtual ~Stream(); 75 76 virtual IBuffer* GetNextProcessedOutputBuffer() override; 77 virtual void OnBufferProcessedByPlayer(IBuffer* buffer) override; 78 virtual double SetPosition(double seconds) override; 79 virtual double GetDuration() override; 80 virtual bool OpenStream(std::string uri) override; 81 virtual void Interrupt() override; 82 virtual int GetCapabilities() override; Eof()83 virtual bool Eof() override { return this->done; } Release()84 virtual void Release() override { delete this; } 85 86 private: 87 bool GetNextBufferFromDecoder(); 88 Buffer* GetEmptyBuffer(); 89 void RefillInternalBuffers(); 90 91 typedef std::deque<Buffer*> BufferList; 92 typedef std::shared_ptr<IDecoder> DecoderPtr; 93 typedef std::shared_ptr<IDSP> DspPtr; 94 typedef std::vector<DspPtr> Dsps; 95 96 long decoderSampleRate; 97 long decoderChannels; 98 std::string uri; 99 musik::core::io::DataStreamFactory::DataStreamPtr dataStream; 100 101 BufferList recycledBuffers; 102 BufferList filledBuffers; 103 104 Buffer* decoderBuffer; 105 long decoderSampleOffset; 106 long decoderSamplesRemain; 107 uint64_t decoderPosition; 108 109 musik::core::sdk::StreamFlags options; 110 int samplesPerChannel; 111 long samplesPerBuffer; 112 int bufferCount; 113 bool done; 114 double bufferLengthSeconds; 115 int capabilities; 116 117 float* rawBuffer; 118 119 DecoderPtr decoder; 120 Dsps dsps; 121 }; 122 123 } } } 124