audio_workgroup_client.hpp

Go to the documentation of this file.

#pragma once
 
#include <pulp/audio/device.hpp>
 
namespace pulp::format {

class AudioWorkgroupClient {
public:
    virtual void set_audio_workgroup(void* workgroup) noexcept = 0;

    virtual void set_audio_workgroup_from_render_context(
        void* workgroup) noexcept {
        set_audio_workgroup(workgroup);
    }

    virtual bool prepare_audio_workgroup_for_render() noexcept { return true; }

    virtual void wait_for_audio_workgroup_update() noexcept = 0;
 
protected:
    ~AudioWorkgroupClient() = default;
};

inline void bind_audio_device_workgroup(AudioWorkgroupClient& client,
                                        audio::AudioDevice* device) {
    if (device) {
        device->set_workgroup_change_callback(
            [&client](void* workgroup) {
                client.set_audio_workgroup(workgroup);
                if (!workgroup) client.wait_for_audio_workgroup_update();
            });
    } else {
        client.set_audio_workgroup(nullptr);
    }
}

inline void close_audio_device_after_workgroup_release(
    AudioWorkgroupClient* client, audio::AudioDevice& device) noexcept {
    // A live device can still be finishing a retarget after an earlier null
    // publication. Disable future changes and drain that in-flight publication
    // before the final explicit removal and close.
    device.quiesce_workgroup_changes();
    if (client) {
        client->set_audio_workgroup(nullptr);
        client->wait_for_audio_workgroup_update();
    }
    device.close();
}

inline void clear_audio_workgroup_after_render_resources(
    AudioWorkgroupClient* client) noexcept {
    if (!client) return;
    client->set_audio_workgroup_from_render_context(nullptr);
    client->wait_for_audio_workgroup_update();
}
 
} // namespace pulp::format