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

stream: update port_io before sending need_input

Browse source 
Update the port_io area to NEED_BUFFER right before starting
This commit is contained in:
Wim Taymans 2017-10-27 17:45:29 +02:00
parent 0662f3a3ea
commit ff242550c8
1 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

14
src/pipewire/stream.c
View file

@ -639,14 +639,19 @@ handle_node_command(struct pw_stream *stream, uint32_t seq, const struct spa_com
add_async_complete(stream, seq, SPA_RESULT_OK); add_async_complete(stream, seq, SPA_RESULT_OK);
if (stream->state == PW_STREAM_STATE_PAUSED) { if (stream->state == PW_STREAM_STATE_PAUSED) {
int i;
pw_log_debug("stream %p: start %d %d", stream, seq, impl->direction); pw_log_debug("stream %p: start %d %d", stream, seq, impl->direction);
pw_loop_update_io(stream->remote->core->data_loop, pw_loop_update_io(stream->remote->core->data_loop,
impl->rtsocket_source, impl->rtsocket_source,
SPA_IO_IN | SPA_IO_ERR | SPA_IO_HUP); SPA_IO_IN | SPA_IO_ERR | SPA_IO_HUP);
if (impl->direction == SPA_DIRECTION_INPUT) if (impl->direction == SPA_DIRECTION_INPUT) {
for (i = 0; i < impl->trans->area->max_input_ports; i++)
impl->trans->inputs[i].status = SPA_RESULT_NEED_BUFFER;
send_need_input(stream); send_need_input(stream);
}
else { else {
impl->in_need_buffer = true; impl->in_need_buffer = true;
spa_hook_list_call(&stream->listener_list, struct pw_stream_events, spa_hook_list_call(&stream->listener_list, struct pw_stream_events,
@ -897,17 +902,12 @@ static void client_node_transport(void *data, uint32_t node_id,
{ {
struct stream *impl = data; struct stream *impl = data;
struct pw_stream *stream = &impl->this; struct pw_stream *stream = &impl->this;
int i;
stream->node_id = node_id; stream->node_id = node_id;
if (impl->trans) { if (impl->trans)
pw_client_node_transport_destroy(impl->trans); pw_client_node_transport_destroy(impl->trans);
}
impl->trans = transport; impl->trans = transport;
for (i = 0; i < impl->trans->area->max_input_ports; i++) {
impl->trans->inputs[i].status = SPA_RESULT_NEED_BUFFER;
}
pw_log_info("stream %p: create client transport %p with fds %d %d for node %u", pw_log_info("stream %p: create client transport %p with fds %d %d for node %u",
stream, impl->trans, readfd, writefd, node_id); stream, impl->trans, readfd, writefd, node_id);