pipewire_common.hpp

Go to the documentation of this file.

#ifndef PIPEWIRE_COMMON_HPP_b6f55dc83d84
#define PIPEWIRE_COMMON_HPP_b6f55dc83d84
 
#include <memory>
#include <string>
#include <string_view>
#include <vector>
#include <mutex>
#include <spa/param/audio/format-utils.h>
#include <spa/debug/types.h> //For pw format to string
#include <pipewire/pipewire.h>
#include "types.h"
 
template<typename T, auto delete_func>
struct raii_deleter_helper { void operator()(T *p) { delete_func(p); } };
template<typename T, auto delete_func>
using raii_uniq_handle = std::unique_ptr<T, raii_deleter_helper<T, delete_func>>;
 
template<typename T>
struct raii_proxy_deleter_helper { void operator()(T *p) { pw_proxy_destroy(reinterpret_cast<pw_proxy *>(p)); } };
template<typename T>
using raii_uniq_proxy_handle = std::unique_ptr<T, raii_proxy_deleter_helper<T>>;
 
using pw_thread_loop_uniq = raii_uniq_handle<pw_thread_loop, pw_thread_loop_destroy>;
using pw_main_loop_uniq = raii_uniq_handle<pw_main_loop, pw_main_loop_destroy>;
using pw_stream_uniq = raii_uniq_handle<pw_stream, pw_stream_destroy>;
using pw_context_uniq = raii_uniq_handle<pw_context, pw_context_destroy>;
using pw_core_uniq = raii_uniq_handle<pw_core, pw_core_disconnect>;
using pw_registry_uniq = raii_uniq_proxy_handle<pw_registry>;
 
struct spa_hook_uniq{
        spa_hook_uniq(){
                spa_zero(hook);
        }
        ~spa_hook_uniq(){
                /*Check if hook is initialized.
                 * Needed only for old pw versions before commit 2394413e */
                if(!!hook.link.prev)
                        spa_hook_remove(&hook);
        }
        spa_hook_uniq(spa_hook_uniq&) = delete;
        spa_hook_uniq& operator=(spa_hook_uniq&) = delete;
 
        spa_hook& get() { return hook; }
 
        spa_hook hook;
};
 
class pipewire_thread_loop_lock_guard{
public:
        pipewire_thread_loop_lock_guard(pw_thread_loop *loop) : l(loop) {
                pw_thread_loop_lock(l);
        }
        ~pipewire_thread_loop_lock_guard(){
                pw_thread_loop_unlock(l);
        }
        pipewire_thread_loop_lock_guard(pipewire_thread_loop_lock_guard&) = delete;
        pipewire_thread_loop_lock_guard& operator=(pipewire_thread_loop_lock_guard&) = delete;
 
private:
        pw_thread_loop *l;
};
 
class pipewire_init_guard{
public:
        pipewire_init_guard() = default;
        pipewire_init_guard(pipewire_init_guard&) = delete;
        pipewire_init_guard& operator=(pipewire_init_guard&) = delete;
        pipewire_init_guard(pipewire_init_guard&& o) { std::swap(initialized, o.initialized);}
        pipewire_init_guard& operator=(pipewire_init_guard&& o) {
                std::swap(initialized, o.initialized);
                return *this;
        }
 
        ~pipewire_init_guard(){
#if !PW_CHECK_VERSION(0, 3, 49)
                std::lock_guard<std::mutex> l(mut);
                if(initialized){
                        init_count--;
                        if(init_count > 0)
                                return;
                }
#endif
                if(initialized)
                        pw_deinit();
        }
 
        void init(){
#if !PW_CHECK_VERSION(0, 3, 49)
                std::lock_guard<std::mutex> l(mut);
                init_count++;
#endif
                pw_init(nullptr, nullptr);
                initialized = true;
        }
 
private:
        bool initialized = false;
#if !PW_CHECK_VERSION(0, 3, 49)
        /* After 0.3.49 deinit needs to be called as many times as init was called,
         * but on previous versions it can be called only once.
         */
        inline static int init_count = 0;
        std::mutex mut;
#endif
};
 
struct pipewire_state_common{
        ~pipewire_state_common();
 
        pipewire_init_guard init_guard;
 
        pw_thread_loop_uniq pipewire_loop;
        pw_context_uniq pipewire_context;
        pw_core_uniq pipewire_core;
        spa_hook_uniq core_listener;
 
        int pw_pending_seq = 0;
        int pw_last_seq = 0;
};
 
struct Pipewire_device{
        std::string name; //Internal name
        std::string nick; //Display name
        std::string description; //Longer display name
        std::string serial;
 
        std::string media_class; //"Audio/Sink", "Audio/Source"...
};
 
bool initialize_pw_common(pipewire_state_common& s, int fd = -1);
 
std::vector<Pipewire_device> get_pw_device_list();
void print_devices(std::string_view media_class);
 
inline spa_audio_format get_pw_format_from_bps(unsigned bps){
        spa_audio_format format_map[] = {
                SPA_AUDIO_FORMAT_UNKNOWN,
                SPA_AUDIO_FORMAT_S8,
                SPA_AUDIO_FORMAT_S16,
                SPA_AUDIO_FORMAT_S24,
                SPA_AUDIO_FORMAT_S32,
        };
 
        return bps < std::size(format_map) ? format_map[bps] : SPA_AUDIO_FORMAT_UNKNOWN;
}
 
inline unsigned get_bps_from_pw_format(spa_audio_format fmt){
        switch(fmt){
        case SPA_AUDIO_FORMAT_S8: return 1;
        case SPA_AUDIO_FORMAT_S16: return 2;
        case SPA_AUDIO_FORMAT_S24: return 3;
        case SPA_AUDIO_FORMAT_S32: return 4;
        default: return 0;
        }
}
 
inline codec_t uv_codec_from_pw_fmt(spa_video_format fmt){
        switch(fmt){
        case SPA_VIDEO_FORMAT_RGBA:
        case SPA_VIDEO_FORMAT_RGBx:
        case SPA_VIDEO_FORMAT_BGRA:
        case SPA_VIDEO_FORMAT_BGRx:
                return RGBA;
        case SPA_VIDEO_FORMAT_RGB:
                return RGB;
        case SPA_VIDEO_FORMAT_BGR:
                return BGR;
        case SPA_VIDEO_FORMAT_UYVY:
                return UYVY;
        case SPA_VIDEO_FORMAT_YUY2:
                return YUYV;
        default:
                return VIDEO_CODEC_NONE;
        }
}
 
inline spa_video_format pw_fmt_from_uv_codec(codec_t codec){
        switch(codec){
        case RGBA:
                return SPA_VIDEO_FORMAT_RGBA;
        case RGB:
                return SPA_VIDEO_FORMAT_RGB;
        case BGR:
                return SPA_VIDEO_FORMAT_BGR;
        case UYVY:
                return SPA_VIDEO_FORMAT_UYVY;
        default:
                return SPA_VIDEO_FORMAT_UNKNOWN;
        }
}
 
#if !PW_CHECK_VERSION(0, 3, 64)
#    define STREAM_TARGET_PROPERTY_KEY PW_KEY_NODE_TARGET
#else
#    define STREAM_TARGET_PROPERTY_KEY PW_KEY_TARGET_OBJECT
#endif
 
#ifndef PW_KEY_NODE_RATE
#    define PW_KEY_NODE_RATE "node.rate"
#endif
 
#endif