mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-10-29 05:40:27 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

pulse-tunnel: use format, channels and rate props

Browse source
This commit is contained in:
Nicolai Syvertsen 2021-10-06 22:04:50 +02:00
parent 466715672e
commit 28c2e8ca56
3 changed files with 38 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

3
src/modules/meson.build
View file

@ -278,7 +278,8 @@ pipewire_module_protocol_pulse = shared_library('pipewire-module-protocol-pulse'
build_module_pulse_tunnel = pulseaudio_dep.found()
if build_module_pulse_tunnel
pipewire_module_pulse_tunnel = shared_library('pipewire-module-pulse-tunnel',
[ 'module-pulse-tunnel.c' ],
[ 'module-pulse-tunnel.c',
'module-protocol-pulse/format.c' ],
include_directories : [configinc, spa_inc],
install : true,
install_dir : modules_install_dir,

9
src/modules/module-protocol-pulse/modules/module-tunnel-sink.c
View file

@ -204,6 +204,15 @@ struct module *create_module_tunnel_sink(struct impl *impl, const char *argument
}
audio_info_to_props(&info, stream_props);
if ((str = pw_properties_get(props, "format")) != NULL) {
uint32_t id = format_paname2id(str, strlen(str));
if (id == SPA_AUDIO_FORMAT_UNKNOWN) {
res = -EINVAL;
goto out;
}
pw_properties_set(stream_props, PW_KEY_AUDIO_FORMAT, format_id2name(id));
}
module = module_new(impl, &module_tunnel_sink_methods, sizeof(*d));
if (module == NULL) {

36
src/modules/module-pulse-tunnel.c
View file

@ -50,6 +50,7 @@
#include <pipewire/i18n.h>
#include <pulse/pulseaudio.h>
#include "module-protocol-pulse/format.h"
/** \page page_module_pulse_tunnel PipeWire Module: Pulse Tunnel
*/
@ -314,11 +315,6 @@ static int create_stream(struct impl *impl)
&playback_stream_events, impl);
}
impl->info = SPA_AUDIO_INFO_RAW_INIT(
.format = SPA_AUDIO_FORMAT_S16,
.rate = 48000,
.channels = 2,
.position = { SPA_AUDIO_CHANNEL_FL, SPA_AUDIO_CHANNEL_FR });
impl->frame_size = 2 * 2;
n_params = 0;
@ -533,9 +529,9 @@ static int create_pulse_stream(struct impl *impl)
pa_threaded_mainloop_wait(impl->pa_mainloop);
}
ss.format = PA_SAMPLE_S16NE;
ss.channels = 2;
ss.rate = 48000;
ss.format = (pa_sample_format_t) format_id2pa(impl->info.format);
ss.channels = impl->info.channels;
ss.rate = impl->info.rate;
snprintf(stream_name, sizeof(stream_name), _("Tunnel for %s@%s"),
pw_get_user_name(), pw_get_host_name());
@ -704,12 +700,33 @@ static void parse_position(struct spa_audio_info_raw *info, const char *val, siz
}
}
static inline uint32_t format_from_name(const char *name, size_t len)
{
int i;
for (i = 0; spa_type_audio_format[i].name; i++) {
if (strncmp(name, spa_debug_type_short_name(spa_type_audio_format[i].name), len) == 0)
return spa_type_audio_format[i].type;
}
return SPA_AUDIO_FORMAT_UNKNOWN;
}
static void parse_audio_info(struct pw_properties *props, struct spa_audio_info_raw *info)
{
const char *str;
*info = SPA_AUDIO_INFO_RAW_INIT(
.format = SPA_AUDIO_FORMAT_F32P);
.rate = 48000,
.channels = 2,
.format = SPA_AUDIO_FORMAT_F32_LE);
if ((str = pw_properties_get(props, PW_KEY_AUDIO_FORMAT)) != NULL) {
uint32_t id;
id = format_from_name(str, strlen(str));
if (id != SPA_AUDIO_FORMAT_UNKNOWN)
info->format = id;
}
if ((str = pw_properties_get(props, PW_KEY_AUDIO_RATE)) != NULL)
info->rate = atoi(str);
if ((str = pw_properties_get(props, PW_KEY_AUDIO_CHANNELS)) != NULL)
@ -803,6 +820,7 @@ int pipewire__module_init(struct pw_impl_module *module, const char *args)
if ((str = pw_properties_get(props, "stream.props")) != NULL)
pw_properties_update_string(impl->stream_props, str, strlen(str));
copy_props(impl, props, PW_KEY_AUDIO_FORMAT);
copy_props(impl, props, PW_KEY_AUDIO_RATE);
copy_props(impl, props, PW_KEY_AUDIO_CHANNELS);
copy_props(impl, props, SPA_KEY_AUDIO_POSITION);