Commit b80c112d authored by Olivier Crête's avatar Olivier Crête

outputstream: Trigger the pollable source on error or removal

parent 11ff575f
...@@ -992,7 +992,7 @@ static void priv_pseudo_tcp_error (NiceAgent *agent, Stream *stream, ...@@ -992,7 +992,7 @@ static void priv_pseudo_tcp_error (NiceAgent *agent, Stream *stream,
Component *component) Component *component)
{ {
if (component->tcp_writable_cancellable) { if (component->tcp_writable_cancellable) {
g_cancellable_reset (component->tcp_writable_cancellable); g_cancellable_cancel (component->tcp_writable_cancellable);
g_clear_object (&component->tcp_writable_cancellable); g_clear_object (&component->tcp_writable_cancellable);
} }
......
...@@ -188,7 +188,10 @@ component_free (Component *cmp) ...@@ -188,7 +188,10 @@ component_free (Component *cmp)
g_source_unref (cmp->tcp_clock); g_source_unref (cmp->tcp_clock);
cmp->tcp_clock = NULL; cmp->tcp_clock = NULL;
} }
if (cmp->tcp_writable_cancellable) {
g_cancellable_cancel (cmp->tcp_writable_cancellable);
g_clear_object (&cmp->tcp_writable_cancellable); g_clear_object (&cmp->tcp_writable_cancellable);
}
if (cmp->tcp) { if (cmp->tcp) {
pseudo_tcp_socket_close (cmp->tcp, TRUE); pseudo_tcp_socket_close (cmp->tcp, TRUE);
g_clear_object(&cmp->tcp); g_clear_object(&cmp->tcp);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment