mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-04 13:30:12 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

stream: ref stream in _stop and _start

Browse source
This commit is contained in:
Wim Taymans 2016-04-06 21:01:29 +02:00
parent 00aed12909
commit f67ddb7c7e
1 changed files with 10 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

13
pinos/client/stream.c
View file

@ -1008,6 +1008,7 @@ on_stream_started (GObject *source_object,
handle_socket (stream, fd); handle_socket (stream, fd);
stream_set_state (stream, PINOS_STREAM_STATE_STREAMING, NULL); stream_set_state (stream, PINOS_STREAM_STATE_STREAMING, NULL);
g_object_unref (stream);
return; return;
@ -1026,6 +1027,7 @@ fd_failed:
exit_error: exit_error:
{ {
stream_set_state (stream, PINOS_STREAM_STATE_ERROR, error); stream_set_state (stream, PINOS_STREAM_STATE_ERROR, error);
g_object_unref (stream);
return; return;
} }
} }
@ -1081,7 +1083,9 @@ pinos_stream_start (PinosStream *stream,
stream_set_state (stream, PINOS_STREAM_STATE_STARTING, NULL); stream_set_state (stream, PINOS_STREAM_STATE_STARTING, NULL);
g_main_context_invoke (priv->context->priv->context, (GSourceFunc) do_start, stream); g_main_context_invoke (priv->context->priv->context,
(GSourceFunc) do_start,
g_object_ref (stream));
return TRUE; return TRUE;
} }
@ -1107,6 +1111,7 @@ on_stream_stopped (GObject *source_object,
g_object_notify (G_OBJECT (stream), "format"); g_object_notify (G_OBJECT (stream), "format");
stream_set_state (stream, PINOS_STREAM_STATE_READY, NULL); stream_set_state (stream, PINOS_STREAM_STATE_READY, NULL);
g_object_unref (stream);
return; return;
@ -1115,6 +1120,7 @@ call_failed:
{ {
g_warning ("failed to release: %s", error->message); g_warning ("failed to release: %s", error->message);
stream_set_state (stream, PINOS_STREAM_STATE_ERROR, error); stream_set_state (stream, PINOS_STREAM_STATE_ERROR, error);
g_object_unref (stream);
return; return;
} }
} }
@ -1133,7 +1139,6 @@ do_stop (PinosStream *stream)
on_stream_stopped, on_stream_stopped,
stream); stream);
return FALSE; return FALSE;
} }
/** /**
@ -1154,7 +1159,9 @@ pinos_stream_stop (PinosStream *stream)
priv = stream->priv; priv = stream->priv;
g_return_val_if_fail (priv->state == PINOS_STREAM_STATE_STREAMING, FALSE); g_return_val_if_fail (priv->state == PINOS_STREAM_STATE_STREAMING, FALSE);
g_main_context_invoke (priv->context->priv->context, (GSourceFunc) do_stop, stream); g_main_context_invoke (priv->context->priv->context,
(GSourceFunc) do_stop,
g_object_ref (stream));
return TRUE; return TRUE;
} }