| /third_party/gstreamer/gstplugins_bad/ext/wpe/wpe-extension/ |
| D | gstwpeaudiosink.c | 37 GCancellable *cancellable;; member
122 gst_wpe_extension_send_message (msg, self->cancellable, NULL, NULL); in render()
143 gst_wpe_extension_send_message (msg, self->cancellable, in render()
177 self->cancellable, NULL, NULL); in set_caps()
188 g_cancellable_cancel (self->cancellable); in unlock()
197 GCancellable *cancellable = self->cancellable; in unlock_stop() local
199 self->cancellable = g_cancellable_new (); in unlock_stop()
200 g_object_unref (cancellable); in unlock_stop()
225 g_cancellable_cancel (self->cancellable); in stop()
229 g_variant_new_uint32 (self->id)), self->cancellable, NULL, NULL); in stop()
[all …]
|
| D | gstwpebusmsgforwarder.c | 27 GCancellable *cancellable; member
39 g_clear_object (&self->cancellable); in dispose()
156 gst_wpe_extension_send_message (msg, self->cancellable, NULL, NULL); in gst_message_post_cb()
171 self->cancellable = g_cancellable_new (); in gst_wpe_bus_msg_forwarder_init()
|
| D | gstwpeextension.c | 56 GCancellable * cancellable, GAsyncReadyCallback cb, gpointer udata) in gst_wpe_extension_send_message() argument
59 cancellable, cb, udata); in gst_wpe_extension_send_message()
|
| /third_party/gstreamer/gstplugins_bad/sys/d3d11/ |
| D | gstd3d11window_swapchainpanel.cpp | 55 HANDLE cancellable; member
136 run_async (const ComPtr<Core::ICoreDispatcher> &dispatcher, HANDLE cancellable, in run_async() argument
175 event_handle[1] = cancellable; in run_async()
186 HANDLE cancellable, in get_panel_size() argument
195 hr = run_async (dispatcher, cancellable, DEFAULT_ASYNC_TIMEOUT, in get_panel_size()
237 self->storage->cancellable = CreateEvent (NULL, TRUE, FALSE, NULL); in gst_d3d11_window_swap_chain_panel_init()
275 storage->cancellable, storage->panel, &size); in gst_d3d11_window_swap_chain_panel_constructed()
292 storage->cancellable, DEFAULT_ASYNC_TIMEOUT, in gst_d3d11_window_swap_chain_panel_constructed()
334 storage->cancellable, DEFAULT_ASYNC_TIMEOUT, in gst_d3d11_window_swap_chain_panel_unprepare()
340 CloseHandle (storage->cancellable); in gst_d3d11_window_swap_chain_panel_unprepare()
[all …]
|
| D | gstd3d11window_corewindow.cpp | 60 HANDLE cancellable; member
171 run_async (const ComPtr<Core::ICoreDispatcher> &dispatcher, HANDLE cancellable, in run_async() argument
210 event_handle[1] = cancellable; in run_async()
221 HANDLE cancellable, in get_window_size() argument
224 return run_async (dispatcher, cancellable, INFINITE, in get_window_size()
271 self->storage->cancellable = CreateEvent (NULL, TRUE, FALSE, NULL); in gst_d3d11_window_core_window_init()
302 hr = get_window_size (storage->dispatcher, storage->cancellable, in gst_d3d11_window_core_window_constructed()
321 storage->cancellable, DEFAULT_ASYNC_TIMEOUT, in gst_d3d11_window_core_window_constructed()
361 storage->cancellable, DEFAULT_ASYNC_TIMEOUT, in gst_d3d11_window_core_window_unprepare()
368 CloseHandle (storage->cancellable); in gst_d3d11_window_core_window_unprepare()
[all …]
|
| /third_party/gstreamer/gstplugins_bad/ext/srt/ |
| D | gstsrtobject.c | 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
[all …]
|
| D | gstsrtobject.h | 83 GCancellable *cancellable,
102 GCancellable *cancellable,
109 GCancellable *cancellable,
113 GCancellable *cancellable);
|
| D | gstsrtsrc.c | 118 ret = gst_srt_object_open (self->srtobject, self->cancellable, &error); in gst_srt_src_start()
158 if (g_cancellable_is_cancelled (self->cancellable)) { in gst_srt_src_fill()
179 gst_buffer_get_size (outbuf), self->cancellable, &err, &mctrl); in gst_srt_src_fill()
198 if (g_cancellable_is_cancelled (self->cancellable)) { in gst_srt_src_fill()
268 self->cancellable = g_cancellable_new (); in gst_srt_src_init()
284 g_clear_object (&self->cancellable); in gst_srt_src_finalize()
295 gst_srt_object_wakeup (self->srtobject, self->cancellable); in gst_srt_src_unlock()
305 g_cancellable_reset (self->cancellable); in gst_srt_src_unlock_stop()
|
| D | gstsrtsink.c | 133 g_clear_object (&self->cancellable); in gst_srt_sink_finalize()
143 self->cancellable = g_cancellable_new (); in gst_srt_sink_init()
156 ret = gst_srt_object_open (self->srtobject, self->cancellable, &error); in gst_srt_sink_start()
187 if (g_cancellable_is_cancelled (self->cancellable)) { in gst_srt_sink_render()
204 self->cancellable, &error) < 0) { in gst_srt_sink_render()
232 gst_srt_object_wakeup (self->srtobject, self->cancellable); in gst_srt_sink_unlock()
242 g_cancellable_reset (self->cancellable); in gst_srt_sink_unlock_stop()
|
| /third_party/gstreamer/gstplugins_base/gst/tcp/ |
| D | gsttcpclientsink.c | 145 this->cancellable = g_cancellable_new (); in gst_tcp_client_sink_init()
155 if (this->cancellable) in gst_tcp_client_sink_finalize()
156 g_object_unref (this->cancellable); in gst_tcp_client_sink_finalize()
157 this->cancellable = NULL; in gst_tcp_client_sink_finalize()
197 map.size - written, sink->cancellable, &err); in gst_tcp_client_sink_render()
294 tcp_get_addresses (GST_ELEMENT (this), this->host, this->cancellable, in gst_tcp_client_sink_start()
318 if (g_socket_connect (this->socket, saddr, this->cancellable, &err)) in gst_tcp_client_sink_start()
410 g_cancellable_cancel (sink->cancellable); in gst_tcp_client_sink_unlock()
422 g_object_unref (sink->cancellable); in gst_tcp_client_sink_unlock_stop()
423 sink->cancellable = g_cancellable_new (); in gst_tcp_client_sink_unlock_stop()
|
| D | gsttcpclientsrc.c | 185 this->cancellable = g_cancellable_new (); in gst_tcp_client_src_init()
195 if (this->cancellable) in gst_tcp_client_src_finalize()
196 g_object_unref (this->cancellable); in gst_tcp_client_src_finalize()
197 this->cancellable = NULL; in gst_tcp_client_src_finalize()
248 G_IO_IN | G_IO_PRI | G_IO_ERR | G_IO_HUP, src->cancellable, &err)) in gst_tcp_client_src_create()
278 src->cancellable, &err); in gst_tcp_client_src_create()
419 tcp_get_addresses (GST_ELEMENT (src), src->host, src->cancellable, &err); in gst_tcp_client_src_start()
445 if (g_socket_connect (src->socket, saddr, src->cancellable, &err)) in gst_tcp_client_src_start()
539 g_cancellable_cancel (src->cancellable); in gst_tcp_client_src_unlock()
551 g_object_unref (src->cancellable); in gst_tcp_client_src_unlock_stop()
[all …]
|
| D | gsttcpserversrc.c | 180 src->cancellable = g_cancellable_new (); in gst_tcp_server_src_init()
190 if (src->cancellable) in gst_tcp_server_src_finalize()
191 g_object_unref (src->cancellable); in gst_tcp_server_src_finalize()
192 src->cancellable = NULL; in gst_tcp_server_src_finalize()
226 g_socket_accept (src->server_socket, src->cancellable, &err); in gst_tcp_server_src_create()
249 G_IO_IN | G_IO_PRI | G_IO_ERR | G_IO_HUP, src->cancellable, &err)) in gst_tcp_server_src_create()
279 src->cancellable, &err); in gst_tcp_server_src_create()
431 tcp_get_addresses (GST_ELEMENT (src), src->host, src->cancellable, &err); in gst_tcp_server_src_start()
570 g_cancellable_cancel (src->cancellable); in gst_tcp_server_src_unlock()
580 g_object_unref (src->cancellable); in gst_tcp_server_src_unlock_stop()
[all …]
|
| D | gstsocketsrc.c | 180 this->cancellable = g_cancellable_new (); in gst_socket_src_init()
191 g_clear_object (&this->cancellable); in gst_socket_src_finalize()
228 map.size, FALSE, src->cancellable, &err); in gst_socketsrc_event()
311 &num_messages, &flags, src->cancellable, &err); in gst_socket_src_fill()
464 g_cancellable_cancel (src->cancellable); in gst_socket_src_unlock()
475 g_cancellable_reset (src->cancellable); in gst_socket_src_unlock_stop()
|
| D | gstmultisocketsink.c | 451 this->cancellable = g_cancellable_new (); in gst_multi_socket_sink_init()
461 if (this->cancellable) { in gst_multi_socket_sink_finalize()
462 g_object_unref (this->cancellable); in gst_multi_socket_sink_finalize()
463 this->cancellable = NULL; in gst_multi_socket_sink_finalize()
641 maxmem), sink->cancellable, &err); in gst_multi_socket_sink_handle_client_read()
780 GCancellable * cancellable, GError ** err) in gst_multi_socket_sink_write() argument
795 cancellable, err); in gst_multi_socket_sink_write()
916 mhclient->bufoffset, sink->cancellable, &err); in gst_multi_socket_sink_handle_client_write()
1004 condition, sink->cancellable); in ensure_condition()
1274 g_cancellable_cancel (sink->cancellable); in gst_multi_socket_sink_unlock()
[all …]
|
| /third_party/gstreamer/gstplugins_bad/gst/rtmp2/rtmp/ |
| D | rtmputils.c | 56 int io_priority, GCancellable * cancellable, GAsyncReadyCallback callback, in gst_rtmp_input_stream_read_all_bytes_async() argument
64 task = g_task_new (stream, cancellable, callback, user_data); in gst_rtmp_input_stream_read_all_bytes_async()
71 cancellable, read_all_bytes_done, task); in gst_rtmp_input_stream_read_all_bytes_async()
110 GBytes * bytes, int io_priority, GCancellable * cancellable, in gst_rtmp_output_stream_write_all_bytes_async() argument
123 task = g_task_new (stream, cancellable, callback, user_data); in gst_rtmp_output_stream_write_all_bytes_async()
128 cancellable, write_all_bytes_done, task); in gst_rtmp_output_stream_write_all_bytes_async()
188 GstBuffer * buffer, int io_priority, GCancellable * cancellable, in gst_rtmp_output_stream_write_all_buffer_async() argument
197 task = g_task_new (stream, cancellable, callback, user_data); in gst_rtmp_output_stream_write_all_buffer_async()
212 io_priority, cancellable, write_all_buffer_done, task); in gst_rtmp_output_stream_write_all_buffer_async()
|
| D | rtmputils.h | 32 gsize count, int io_priority, GCancellable * cancellable,
38 GBytes * bytes, int io_priority, GCancellable * cancellable,
44 GstBuffer * buffer, int io_priority, GCancellable * cancellable,
|
| D | rtmpconnection.c | 53 GCancellable *cancellable; member
108 GCancellable * cancellable);
259 rtmpconnection->cancellable = g_cancellable_new (); in gst_rtmp_connection_init()
283 g_cancellable_cancel (rtmpconnection->cancellable); in gst_rtmp_connection_dispose()
300 g_clear_object (&rtmpconnection->cancellable); in gst_rtmp_connection_finalize()
335 sc->cancellable); in gst_rtmp_connection_set_socket_connection()
344 GCancellable * cancellable) in gst_rtmp_connection_set_cancellable() argument
350 if (cancellable == NULL) in gst_rtmp_connection_set_cancellable()
353 self->outer_cancellable = g_object_ref (cancellable); in gst_rtmp_connection_set_cancellable()
355 g_cancellable_connect (cancellable, G_CALLBACK (g_cancellable_cancel), in gst_rtmp_connection_set_cancellable()
[all …]
|
| D | rtmpclient.h | 110 GCancellable * cancellable, GAsyncReadyCallback callback,
115 const gchar * stream, GCancellable * cancellable,
121 const gchar * stream, GCancellable * cancellable,
|
| /third_party/gstreamer/gstplugins_good/ext/soup/ |
| D | gstsouploader.c | 124 GCancellable * cancellable, GAsyncReadyCallback callback, gpointer user_data);
126 int io_priority, GCancellable * cancellable, GAsyncReadyCallback callback, gpointer user_data);
130 GCancellable * cancellable, GError ** error);
831 GCancellable * cancellable, GAsyncReadyCallback callback, in _soup_session_send_async() argument
836 soup_session_send_async (session, msg, cancellable, callback, user_data); in _soup_session_send_async()
838 soup_session_send_async (session, msg, G_PRIORITY_DEFAULT, cancellable, in _soup_session_send_async()
845 G_PRIORITY_DEFAULT, cancellable, callback, user_data); in _soup_session_send_async()
849 cancellable, callback, user_data); in _soup_session_send_async()
868 GCancellable * cancellable, GError ** error) in _soup_session_send() argument
871 return soup_session_send (session, msg, cancellable, error); in _soup_session_send()
[all …]
|
| D | gstsouploader.h | 106 GCancellable *cancellable,
114 GCancellable *cancellable,
117 …st_soup_session_cancel_message (SoupSession *session, SoupMessage *msg, GCancellable *cancellable);
|
| /third_party/gstreamer/gstplugins_good/gst/udp/ |
| D | gstdynudpsink.c | 251 sink->cancellable, &err); in gst_dynudpsink_render()
376 sink->cancellable = g_cancellable_new (); in gst_dynudpsink_create_cancellable()
377 sink->made_cancel_fd = g_cancellable_make_pollfd (sink->cancellable, &pollfd); in gst_dynudpsink_create_cancellable()
384 g_cancellable_release_fd (sink->cancellable); in gst_dynudpsink_free_cancellable()
387 g_object_unref (sink->cancellable); in gst_dynudpsink_free_cancellable()
388 sink->cancellable = NULL; in gst_dynudpsink_free_cancellable()
444 udpsink->cancellable, &err); in gst_dynudpsink_start()
585 g_cancellable_cancel (udpsink->cancellable); in gst_dynudpsink_unlock()
|
| /third_party/gstreamer/gstplugins_bad/gst/rtmp2/ |
| D | gstrtmp2src.c | 81 GCancellable *cancellable; member
438 g_clear_object (&self->cancellable); in gst_rtmp2_src_finalize()
465 g_clear_object (&self->cancellable); in gst_rtmp2_src_start()
468 self->cancellable = g_cancellable_new (); in gst_rtmp2_src_start()
495 if (self->cancellable) { in stop_task()
497 g_cancellable_cancel (self->cancellable); in stop_task()
769 connector = g_task_new (self, self->cancellable, connect_task_done, NULL); in gst_rtmp2_src_task_func()
774 gst_rtmp_client_connect_async (&self->location, self->cancellable, in gst_rtmp2_src_task_func()
923 if (self->cancellable) { in error_callback()
924 g_cancellable_cancel (self->cancellable); in error_callback()
[all …]
|
| D | gstrtmp2sink.c | 87 GCancellable *cancellable; member
504 g_clear_object (&self->cancellable); in gst_rtmp2_sink_finalize()
531 g_clear_object (&self->cancellable); in gst_rtmp2_sink_start()
534 self->cancellable = g_cancellable_new (); in gst_rtmp2_sink_start()
559 if (self->cancellable) { in stop_task()
561 g_cancellable_cancel (self->cancellable); in stop_task()
847 if (G_UNLIKELY (is_running (self) && self->cancellable && in gst_rtmp2_sink_render()
975 connector = g_task_new (self, self->cancellable, connect_task_done, NULL); in gst_rtmp2_sink_task_func()
980 gst_rtmp_client_connect_async (&self->location, self->cancellable, in gst_rtmp2_sink_task_func()
1081 if (self->cancellable) { in error_callback()
[all …]
|
| /third_party/gstreamer/gstplugins_bad/sys/wasapi/ |
| D | gstwasapisink.c | 180 self->cancellable = CreateEvent (NULL, TRUE, FALSE, NULL); in gst_wasapi_sink_init()
196 if (self->cancellable != NULL) { in gst_wasapi_sink_dispose()
197 CloseHandle (self->cancellable); in gst_wasapi_sink_dispose()
198 self->cancellable = NULL; in gst_wasapi_sink_dispose()
583 ResetEvent (self->cancellable); in gst_wasapi_sink_prepare()
623 event_handle[1] = self->cancellable; in gst_wasapi_sink_write()
631 ResetEvent (self->cancellable); in gst_wasapi_sink_write()
751 SetEvent (self->cancellable); in gst_wasapi_sink_reset()
|
| /third_party/gstreamer/gstplugins_base/gst-libs/gst/rtsp/ |
| D | gstrtspconnection.c | 175 GCancellable *cancellable; member
379 newconn->cancellable = g_cancellable_new (); in gst_rtsp_connection_create()
528 GCancellable * cancellable) in gst_rtsp_connection_accept() argument
539 client_sock = g_socket_accept (socket, cancellable, &err); in gst_rtsp_connection_accept()
902 conn->proxy_host, conn->proxy_port, conn->cancellable, &error); in setup_tunneling()
906 connection_uri, 0, conn->cancellable, &error); in setup_tunneling()
1057 conn->proxy_host, conn->proxy_port, conn->cancellable, &error); in gst_rtsp_connection_connect_with_response_usec()
1061 connection_uri, url_port, conn->cancellable, &error); in gst_rtsp_connection_connect_with_response_usec()
1262 guint size, gboolean block, GCancellable * cancellable) in write_bytes() argument
1277 cancellable, &err); in write_bytes()
[all …]
|