AudioMixerWasapiDeviceThread.h

Go to the documentation of this file.

// Copyright Epic Games, Inc. All Rights Reserved.
 
#pragma once
 
#include <atomic>
 
#include "HAL/Runnable.h"
#include "HAL/RunnableThread.h"
#include "IAudioMixerWasapiDeviceManager.h"
#include "Templates/Function.h"
#include "Templates/UniquePtr.h"
 
#include "Windows/AllowWindowsPlatformTypes.h"
#include "Windows/AllowWindowsPlatformAtomics.h"
 
#include "Microsoft/COMPointer.h"
 
THIRD_PARTY_INCLUDES_START
#include <winnt.h>
THIRD_PARTY_INCLUDES_END
 
#include "Windows/HideWindowsPlatformAtomics.h"
#include "Windows/HideWindowsPlatformTypes.h"
 
namespace Audio
{
    class FAudioMixerWasapiRunnable : public FRunnable
    {
    public:
        FAudioMixerWasapiRunnable() = delete;
 
        FAudioMixerWasapiRunnable(const TFunction<void()>& InDeviceRenderCallback, HANDLE& OutEventHandle);
 
        FAudioMixerWasapiRunnable(const TFunction<void()>& InDeviceRenderCallback, TArray<HANDLE>& OutEventHandles, const int32 InNumRequestedHandles);
 
        virtual ~FAudioMixerWasapiRunnable() = default;
 
        // Begin FRunnable overrides
        virtual uint32 Run() override;
        virtual void Stop() override;
        // End FRunnable overrides
 
    private:
        std::atomic<bool> bIsRunning;
        
        TArray<HANDLE> EventHandles;
 
        uint32 OutputStreamTimeoutsDetected = 0;
        
        TFunction<void()> DeviceRenderCallback;
 
        bool CreateEventHandles(const uint32 InNumRequestedHandles = 1);
    };
 
    class FAudioMixerWasapiDeviceThread
    {
    public:
        FAudioMixerWasapiDeviceThread() = delete;
 
        FAudioMixerWasapiDeviceThread(const TFunction<void()>& InDeviceRenderCallback, HANDLE& OutEventHandle);
 
        FAudioMixerWasapiDeviceThread(const TFunction<void()>& InDeviceRenderCallback, TArray<HANDLE>& OutEventHandles, const int32 InNumRequestedHandles);
 
        bool Start();
 
        void Stop();
        
        void Abort();
 
    private:
        static std::atomic<uint32> AudioDeviceThreadCounter;
 
        TUniquePtr<FRunnableThread> DeviceRenderThread;
 
        TUniquePtr<FAudioMixerWasapiRunnable> DeviceRenderRunnable;
    };
}