mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-03 09:01:54 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

client-stream: fix format and buffers for capture

Browse source
This commit is contained in:
Wim Taymans 2018-06-22 17:36:26 +02:00
parent 1eae3f1a2c
commit ce2e605255
1 changed files with 16 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

32
src/modules/module-client-node/client-stream.c
View file

@ -393,20 +393,20 @@ static int negotiate_format(struct impl *impl)
state = 0;
if ((res = spa_node_port_enum_params(impl->adapter,
SPA_DIRECTION_INPUT, 0,
SPA_DIRECTION_REVERSE(impl->direction), 0,
t->param.idEnumFormat, &state,
NULL, &format, &b)) <= 0) {
debug_params(impl, impl->adapter, SPA_DIRECTION_INPUT, 0,
debug_params(impl, impl->adapter, SPA_DIRECTION_REVERSE(impl->direction), 0,
t->param.idEnumFormat, NULL);
return -ENOTSUP;
}
state = 0;
if ((res = spa_node_port_enum_params(impl->cnode,
SPA_DIRECTION_OUTPUT, 0,
impl->direction, 0,
t->param.idEnumFormat, &state,
format, &format, &b)) <= 0) {
debug_params(impl, impl->cnode, SPA_DIRECTION_OUTPUT, 0,
debug_params(impl, impl->cnode, impl->direction, 0,
t->param.idEnumFormat, format);
return -ENOTSUP;
}
@ -415,13 +415,13 @@ static int negotiate_format(struct impl *impl)
spa_debug_pod(format, SPA_DEBUG_FLAG_FORMAT);
if ((res = spa_node_port_set_param(impl->adapter,
SPA_DIRECTION_INPUT, 0,
SPA_DIRECTION_REVERSE(impl->direction), 0,
t->param.idFormat, 0,
format)) < 0)
return res;
if ((res = spa_node_port_set_param(impl->cnode,
SPA_DIRECTION_OUTPUT, 0,
impl->direction, 0,
t->param.idFormat, 0,
format)) < 0)
return res;
@ -453,10 +453,10 @@ static int negotiate_buffers(struct impl *impl)
state = 0;
if ((res = spa_node_port_enum_params(impl->cnode,
SPA_DIRECTION_OUTPUT, 0,
impl->direction, 0,
t->param.idBuffers, &state,
param, &param, &b)) < 0) {
debug_params(impl, impl->cnode, SPA_DIRECTION_OUTPUT, 0,
debug_params(impl, impl->cnode, impl->direction, 0,
t->param.idBuffers, param);
return res;
}
@ -466,10 +466,10 @@ static int negotiate_buffers(struct impl *impl)
state = 0;
if ((res = spa_node_port_enum_params(impl->adapter,
SPA_DIRECTION_INPUT, 0,
SPA_DIRECTION_REVERSE(impl->direction), 0,
t->param.idBuffers, &state,
param, &param, &b)) <= 0) {
debug_params(impl, impl->adapter, SPA_DIRECTION_INPUT, 0,
debug_params(impl, impl->adapter, SPA_DIRECTION_REVERSE(impl->direction), 0,
t->param.idBuffers, param);
return -ENOTSUP;
}
@ -477,11 +477,11 @@ static int negotiate_buffers(struct impl *impl)
spa_pod_fixate(param);
if ((res = spa_node_port_get_info(impl->cnode,
SPA_DIRECTION_OUTPUT, 0,
impl->direction, 0,
&out_info)) < 0)
return res;
if ((res = spa_node_port_get_info(impl->adapter,
SPA_DIRECTION_INPUT, 0,
SPA_DIRECTION_REVERSE(impl->direction), 0,
&in_info)) < 0)
return res;
@ -545,27 +545,27 @@ static int negotiate_buffers(struct impl *impl)
if (in_alloc) {
if ((res = spa_node_port_alloc_buffers(impl->adapter,
SPA_DIRECTION_INPUT, 0,
SPA_DIRECTION_REVERSE(impl->direction), 0,
NULL, 0,
impl->buffers, &impl->n_buffers)) < 0)
return res;
}
else {
if ((res = spa_node_port_use_buffers(impl->adapter,
SPA_DIRECTION_INPUT, 0,
SPA_DIRECTION_REVERSE(impl->direction), 0,
impl->buffers, impl->n_buffers)) < 0)
return res;
}
if (out_alloc) {
if ((res = spa_node_port_alloc_buffers(impl->cnode,
SPA_DIRECTION_OUTPUT, 0,
impl->direction, 0,
NULL, 0,
impl->buffers, &impl->n_buffers)) < 0)
return res;
}
else {
if ((res = spa_node_port_use_buffers(impl->cnode,
SPA_DIRECTION_OUTPUT, 0,
impl->direction, 0,
impl->buffers, impl->n_buffers)) < 0)
return res;
}