pipewire_common.cpp File Reference

#include "debug.h"
#include "utils/color_out.h"
#include "pipewire_common.hpp"

Include dependency graph for pipewire_common.cpp:

Go to the source code of this file.

Functions
std::vector< Pipewire_device >	get_pw_device_list ()
bool	initialize_pw_common (pipewire_state_common &s, int fd)
static void	on_core_done (void *data, uint32_t, int seq)
static void	on_core_error (void *, uint32_t id, int seq, int res, const char *message)
static void	on_registry_event_global (void *data, uint32_t, uint32_t, const char *type, uint32_t, const struct spa_dict *props)
void	print_devices (std::string_view media_class)

Variables
static const struct pw_core_events	core_events

Function Documentation

get_pw_device_list()

std::vector< Pipewire_device > get_pw_device_list

(

)

Definition at line 85 of file pipewire_common.cpp.

                                               {
        pipewire_state_common s;
        initialize_pw_common(s);
 
        std::vector<Pipewire_device> result;
 
        pipewire_thread_loop_lock_guard lock(s.pipewire_loop.get());
 
        pw_registry_uniq registry(pw_core_get_registry(s.pipewire_core.get(), PW_VERSION_REGISTRY, 0));
 
        const static pw_registry_events registry_events = {
                PW_VERSION_REGISTRY_EVENTS,
                .global = on_registry_event_global,
                .global_remove = nullptr
        };
 
        spa_hook_uniq registry_listener;
        pw_registry_add_listener(registry.get(), &registry_listener.get(), &registry_events, &result);
 
        s.pw_pending_seq = pw_core_sync(s.pipewire_core.get(), PW_ID_CORE, s.pw_pending_seq);
        int wait_seq = s.pw_pending_seq;
 
        do{
                pw_thread_loop_wait(s.pipewire_loop.get());
        } while(s.pw_last_seq < wait_seq);
 
        return result;
}

References spa_hook_uniq::get(), initialize_pw_common(), on_registry_event_global(), pipewire_state_common::pipewire_core, pipewire_state_common::pipewire_loop, pipewire_state_common::pw_last_seq, and pipewire_state_common::pw_pending_seq.

Referenced by print_devices().

Here is the call graph for this function:

initialize_pw_common()

bool initialize_pw_common	(	pipewire_state_common &	s,
		int	fd )

Definition at line 39 of file pipewire_common.cpp.

                                                           {
        s.init_guard.init();
        s.pipewire_loop.reset(pw_thread_loop_new("Playback", nullptr));
        s.pipewire_context.reset(pw_context_new(pw_thread_loop_get_loop(s.pipewire_loop.get()), nullptr, 0)); //TODO check return
                                                                                                
        if(fd != -1)
                s.pipewire_core.reset(pw_context_connect_fd(s.pipewire_context.get(), fd, nullptr, 0));
        else
                s.pipewire_core.reset(pw_context_connect(s.pipewire_context.get(), nullptr, 0));
 
        pw_core_add_listener(s.pipewire_core.get(), &s.core_listener.get(), &core_events, &s);
 
        pw_thread_loop_start(s.pipewire_loop.get());
 
        return true;
}

References core_events, pipewire_state_common::core_listener, spa_hook_uniq::get(), pipewire_init_guard::init(), pipewire_state_common::init_guard, pipewire_state_common::pipewire_context, pipewire_state_common::pipewire_core, and pipewire_state_common::pipewire_loop.

Referenced by audio_cap_pipewire_init(), audio_play_pw_init(), display_pw_init(), get_pw_device_list(), and start_pipewire().

Here is the call graph for this function:

on_core_done()

static void on_core_done ( void * data, uint32_t , int seq )

static

Definition at line 11 of file pipewire_common.cpp.

{
        auto s = static_cast<pipewire_state_common *>(data);
 
        s->pw_last_seq = seq;
        pw_thread_loop_signal(s->pipewire_loop.get(), false);
}

References pipewire_state_common::pw_last_seq, and seq.

on_core_error()

static void on_core_error ( void * , uint32_t id, int seq, int res, const char * message )

static

Definition at line 19 of file pipewire_common.cpp.

{
        log_msg(LOG_LEVEL_ERROR, "Pipewire error: id:%d seq:%x res:%d msg: %s\n", id, seq, res, message);
}

References LOG_LEVEL_ERROR, log_msg(), and seq.

Here is the call graph for this function:

on_registry_event_global()

static void on_registry_event_global ( void * data, uint32_t , uint32_t , const char * type, uint32_t , const struct spa_dict * props )

static

Definition at line 56 of file pipewire_common.cpp.

{
        auto result = static_cast<std::vector<Pipewire_device> *>(data);
        std::string_view type_sv(type);
        if(type_sv != "PipeWire:Interface:Node")
                return;
 
        Pipewire_device dev;
        for(unsigned i = 0; i < props->n_items; i++){
                std::string_view key(props->items[i].key);
                std::string_view val(props->items[i].value);
 
                if(key == "node.description")
                        dev.description = val;
                else if(key == "node.nick")
                        dev.nick = val;
                else if(key == "media.class")
                        dev.media_class = val;
                else if(key == "node.name")
                        dev.name = val;
                else if(key == "object.serial")
                        dev.serial = val;
        }
 
        result->push_back(std::move(dev));
}

References Pipewire_device::description, key, Pipewire_device::media_class, Pipewire_device::name, Pipewire_device::nick, Pipewire_device::serial, type, and val.

Referenced by get_pw_device_list().

print_devices()

void print_devices

(

std::string_view

media_class

)

Definition at line 120 of file pipewire_common.cpp.

                                              {
        auto devices = get_pw_device_list();
 
        for(const auto& dev : devices){
                if(dev.media_class == media_class){
                        color_printf("\t%s: %s (%s)\n", dev.serial.c_str(), dev.description.c_str(), dev.name.c_str());
                }
        }
}

References color_printf(), and get_pw_device_list().

Referenced by audio_cap_pw_help(), audio_play_pw_help(), display_pw_help(), and show_generic_help().

Here is the call graph for this function:

Variable Documentation

core_events

const struct pw_core_events core_events

static

Initial value:

= {
        PW_VERSION_CORE_EVENTS,
        .info = nullptr,
        .done = on_core_done,
        .ping = nullptr,
        .error = on_core_error,
        .remove_id = nullptr,
        .bound_id = nullptr,
        .add_mem = nullptr,
        .remove_mem = nullptr,
 
 
 
}

Definition at line 24 of file pipewire_common.cpp.

                                                 {
        PW_VERSION_CORE_EVENTS,
        .info = nullptr,
        .done = on_core_done,
        .ping = nullptr,
        .error = on_core_error,
        .remove_id = nullptr,
        .bound_id = nullptr,
        .add_mem = nullptr,
        .remove_mem = nullptr,
#if PW_MAJOR > 0 || PW_MINOR > 3 || (PW_MINOR == 3 && PW_MICRO > 67)
        .bound_props = nullptr,
#endif
};

Referenced by initialize_pw_common().