AudioReaderSource.h

Go to the documentation of this file.

 
// Copyright (c) 2008-2019 OpenShot Studios, LLC
//
// SPDX-License-Identifier: LGPL-3.0-or-later
 
#ifndef OPENSHOT_AUDIOREADERSOURCE_H
#define OPENSHOT_AUDIOREADERSOURCE_H
 
#include <atomic>
#include <mutex>
 
#include "ReaderBase.h"
#include "Qt/VideoCacheThread.h"
 
#include <AppConfig.h>
#include <juce_audio_basics/juce_audio_basics.h>
 
namespace openshot
{
    class Frame;
    class AudioReaderSource : public juce::PositionableAudioSource
    {
    private:
        std::atomic<int64_t> stream_position; 
        int64_t frame_position; 
        std::atomic<int> speed;          
 
        ReaderBase *reader; 
        std::shared_ptr<Frame> frame; 
        std::mutex seek_mutex; 
        std::atomic<uint64_t> seek_generation{0}; 
        std::atomic<int64_t> requested_frame;
        uint64_t applied_generation = 0; 
        std::atomic<uint64_t> published_generation{0};
        std::atomic<uint64_t> speed_generation{0};
        int64_t sample_position; 
        openshot::VideoCacheThread *videoCache; 
 
    public:
 
        AudioReaderSource(ReaderBase *audio_reader, int64_t starting_frame_number);
 
        ~AudioReaderSource();
 
        void getNextAudioBlock (const juce::AudioSourceChannelInfo& info);
 
        void prepareToPlay(int, double);
 
        void releaseResources();
 
        void setNextReadPosition (juce::int64 newPosition) { stream_position = newPosition; };
 
        juce::int64 getNextReadPosition() const { return stream_position; };
 
        juce::int64 getTotalLength() const;
 
        bool isLooping() const { return false; };
 
        void setLooping (bool shouldLoop) {  };
 
        std::shared_ptr<Frame> getFrame() const;
 
        void setSpeed(int new_speed) { if (speed.exchange(new_speed) != new_speed) ++speed_generation; }
        int getSpeed() const { return speed; }
 
        void setVideoCache(openshot::VideoCacheThread *newCache) { videoCache = newCache; }
 
        void Reader(ReaderBase *audio_reader) { reader = audio_reader; }
        ReaderBase* Reader() const { return reader; }
 
        void Seek(int64_t new_position);
 
    };
 
}
 
#endif