AudioPlaybackThread.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_AUDIO_PLAYBACK_THREAD_H
#define OPENSHOT_AUDIO_PLAYBACK_THREAD_H
 
#include "ReaderBase.h"
#include "RendererBase.h"
#include "AudioReaderSource.h"
#include "AudioDevices.h"
#include "AudioReaderSource.h"
#include "Qt/VideoCacheThread.h"
 
#include <OpenShotAudio.h>
#include <AppConfig.h>
#include <juce_audio_basics/juce_audio_basics.h>
#include <juce_audio_devices/juce_audio_devices.h>
 
namespace openshot
{
 
// Forward decls
class ReaderBase;
class Frame;
class PlayerPrivate;
class QtPlayer;
 

class AudioDeviceManagerSingleton {
private:
        AudioDeviceManagerSingleton(){ initialise_error=""; };

        static AudioDeviceManagerSingleton* m_pInstance;
 
public:
        std::string initialise_error;

        double defaultSampleRate;

        AudioDeviceInfo currentAudioDevice;

        static AudioDeviceManagerSingleton* Instance();

        static AudioDeviceManagerSingleton* Instance(int rate, int channels);

        juce::AudioDeviceManager audioDeviceManager;

        void CloseAudioDevice();
    };

    class AudioPlaybackThread : juce::Thread
    {
        juce::AudioSourcePlayer player;
        juce::AudioTransportSource transport;
        juce::MixerAudioSource mixer;
        AudioReaderSource *source;
        double sampleRate;
        int numChannels;
        juce::WaitableEvent play;
        bool is_playing;
        juce::TimeSliceThread time_thread;
        openshot::VideoCacheThread *videoCache; 
        std::mutex transportMutex;
        std::condition_variable transportCondition;

        AudioPlaybackThread(openshot::VideoCacheThread* cache);
        ~AudioPlaybackThread();

        void NotifyTransportStateChanged();

        void Reader(openshot::ReaderBase *reader);

        std::shared_ptr<openshot::Frame> getFrame();

        void Play();

        void Seek(int64_t new_position);

        void Stop();

        void run();

        void setSpeed(int new_speed) { if (source) source->setSpeed(new_speed); }

        int getSpeed() const { if (source) return source->getSpeed(); else return 1; }

        std::string getError()
        {
            return AudioDeviceManagerSingleton::Instance()->initialise_error;
        }

        double getDefaultSampleRate()
        {
            return AudioDeviceManagerSingleton::Instance()->defaultSampleRate;
        }

        AudioDeviceInfo getCurrentAudioDevice()
        {
            return AudioDeviceManagerSingleton::Instance()->currentAudioDevice;
        }

        AudioDeviceList getAudioDeviceNames()
        {
            AudioDevices devs;
            return devs.getNames();
        };
 
        friend class PlayerPrivate;
        friend class QtPlayer;
};
 
}  // namespace openshot
 
#endif // OPENSHOT_AUDIO_PLAYBACK_THREAD_H