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

remote: send start command before adding the source

Browse source
This commit is contained in:
Wim Taymans 2018-11-29 17:48:26 +01:00
parent 67e6a66429
commit c982f73779
1 changed files with 5 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

11
src/pipewire/remote.c
View file

@ -529,7 +529,7 @@ on_rtsocket_condition(void *user_data, int fd, enum spa_io mask)
if (read(fd, &cmd, sizeof(uint64_t)) != sizeof(uint64_t) || cmd != 1) if (read(fd, &cmd, sizeof(uint64_t)) != sizeof(uint64_t) || cmd != 1)
pw_log_warn("proxy %p: read %"PRIu64" failed %m", proxy, cmd); pw_log_warn("proxy %p: read %"PRIu64" failed %m", proxy, cmd);
pw_log_trace("remote %p: process", data->remote); pw_log_trace("remote %p: process %p", data->remote, proxy);
spa_graph_run(node->graph); spa_graph_run(node->graph);
} }
} }
@ -912,7 +912,6 @@ static void client_node_command(void *object, uint32_t seq, const struct spa_com
pw_loop_invoke(data->core->data_loop, pw_loop_invoke(data->core->data_loop,
do_pause_source, 1, NULL, 0, true, data); do_pause_source, 1, NULL, 0, true, data);
} }
if ((res = spa_node_send_command(data->node->node, command)) < 0) if ((res = spa_node_send_command(data->node->node, command)) < 0)
pw_log_warn("node %p: pause failed", proxy); pw_log_warn("node %p: pause failed", proxy);
@ -921,15 +920,15 @@ static void client_node_command(void *object, uint32_t seq, const struct spa_com
case SPA_NODE_COMMAND_Start: case SPA_NODE_COMMAND_Start:
pw_log_debug("node %p: start %d", proxy, seq); pw_log_debug("node %p: start %d", proxy, seq);
if (data->rtsocket_source) { if ((res = spa_node_send_command(data->node->node, command)) < 0) {
pw_log_warn("node %p: start failed", proxy);
}
else if (data->rtsocket_source) {
pw_loop_update_io(remote->core->data_loop, pw_loop_update_io(remote->core->data_loop,
data->rtsocket_source, data->rtsocket_source,
SPA_IO_IN | SPA_IO_ERR | SPA_IO_HUP); SPA_IO_IN | SPA_IO_ERR | SPA_IO_HUP);
} }
if ((res = spa_node_send_command(data->node->node, command)) < 0)
pw_log_warn("node %p: start failed", proxy);
pw_client_node_proxy_done(data->node_proxy, seq, res); pw_client_node_proxy_done(data->node_proxy, seq, res);
break; break;
default: default: