Lines Matching refs:cancellable
207 guint port, GCancellable * cancellable, GError ** err_out) in gst_srt_object_resolve() argument
220 results = g_resolver_lookup_by_name (resolver, address, cancellable, &err); in gst_srt_object_resolve()
1061 GCancellable * cancellable, gpointer sa, size_t sa_len, GError ** error) in gst_srt_object_wait_connect() argument
1084 gst_srt_object_resolve (srtobject, local_address, local_port, cancellable, in gst_srt_object_wait_connect()
1171 gst_srt_object_connect (GstSRTObject * srtobject, GCancellable * cancellable, in gst_srt_object_connect() argument
1234 local_port, cancellable, error); in gst_srt_object_connect()
1295 GCancellable * cancellable, GstSRTConnectionMode connection_mode, in gst_srt_object_open_connection() argument
1302 gst_srt_object_wait_connect (srtobject, cancellable, sa, sa_len, error); in gst_srt_object_open_connection()
1305 gst_srt_object_connect (srtobject, cancellable, connection_mode, sa, in gst_srt_object_open_connection()
1314 GCancellable * cancellable, GError ** error) in gst_srt_object_open_internal() argument
1354 gst_srt_object_resolve (srtobject, addr_str, port, cancellable, error); in gst_srt_object_open_internal()
1370 (srtobject, cancellable, connection_mode, sa, sa_len, error); in gst_srt_object_open_internal()
1383 gst_srt_object_open (GstSRTObject * srtobject, GCancellable * cancellable, in gst_srt_object_open() argument
1388 return gst_srt_object_open_internal (srtobject, cancellable, error); in gst_srt_object_open()
1455 GCancellable * cancellable, GError ** error) in gst_srt_object_wait_caller() argument
1464 while (!g_cancellable_is_cancelled (cancellable)) { in gst_srt_object_wait_caller()
1489 guint8 * data, gsize size, GCancellable * cancellable, GError ** error, in gst_srt_object_read() argument
1514 if (!gst_srt_object_wait_caller (srtobject, cancellable, error)) in gst_srt_object_read()
1530 while (!g_cancellable_is_cancelled (cancellable)) { in gst_srt_object_read()
1566 if (!gst_srt_object_open_internal (srtobject, cancellable, error)) { in gst_srt_object_read()
1594 gst_srt_object_wakeup (GstSRTObject * srtobject, GCancellable * cancellable) in gst_srt_object_wakeup() argument
1610 g_cancellable_cancel (cancellable); in gst_srt_object_wakeup()
1618 GCancellable * cancellable) in gst_srt_object_send_headers() argument
1636 if (g_cancellable_is_cancelled (cancellable)) { in gst_srt_object_send_headers()
1671 const GstMapInfo * mapinfo, GCancellable * cancellable, GError ** error) in gst_srt_object_write_to_callers() argument
1686 if (g_cancellable_is_cancelled (cancellable)) { in gst_srt_object_write_to_callers()
1692 -1, headers, cancellable)) { in gst_srt_object_write_to_callers()
1734 const GstMapInfo * mapinfo, GCancellable * cancellable, GError ** error) in gst_srt_object_write_one() argument
1752 srtobject->poll_id, poll_timeout, headers, cancellable)) { in gst_srt_object_write_one()
1767 if (g_cancellable_is_cancelled (cancellable)) { in gst_srt_object_write_one()
1794 if (!gst_srt_object_open_internal (srtobject, cancellable, error)) { in gst_srt_object_write_one()
1823 const GstMapInfo * mapinfo, GCancellable * cancellable, GError ** error) in gst_srt_object_write() argument
1841 if (!gst_srt_object_wait_caller (srtobject, cancellable, error)) in gst_srt_object_write()
1846 cancellable, error); in gst_srt_object_write()
1849 gst_srt_object_write_one (srtobject, headers, mapinfo, cancellable, in gst_srt_object_write()