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

link: refactor a little

Browse source
This commit is contained in:
Wim Taymans 2020-08-10 10:20:16 +02:00
parent 374210c890
commit 2c2bb381b3
1 changed files with 9 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

16
src/pipewire/impl-link.c
View file

@ -856,16 +856,21 @@ static void output_node_result(void *data, int seq, int res, uint32_t type, cons
node_result(impl, port, seq, res, type, result);
}
static void node_active_changed(void *data, bool active)
static void check_prepare(struct pw_impl_link *this)
{
struct impl *impl = data;
struct pw_impl_link *this = &impl->this;
struct impl *impl = SPA_CONTAINER_OF(this, struct impl, this);
pw_log_debug(NAME" %p: input active:%d output active:%d", impl,
impl->inode->active, impl->onode->active);
if (impl->inode->active && impl->onode->active)
pw_impl_link_prepare(this);
}
static void node_active_changed(void *data, bool active)
{
struct impl *impl = data;
check_prepare(&impl->this);
}
static const struct pw_impl_node_events input_node_events = {
PW_VERSION_IMPL_NODE_EVENTS,
.result = input_node_result,
@ -1218,10 +1223,7 @@ int pw_impl_link_register(struct pw_impl_link *link,
pw_global_add_listener(link->global, &link->global_listener, &global_events, link);
pw_global_register(link->global);
pw_log_debug(NAME" %p: output_active:%d input_active:%d", link,
input_node->active, output_node->active);
if (input_node->active && output_node->active)
pw_impl_link_prepare(link);
check_prepare(link);
return 0;