Lines Matching refs:task
313 static void socket_connect (GTask * task);
318 static void send_connect (GTask * task);
321 static void send_secure_token_response (GTask * task,
364 GTask *task; in gst_rtmp_client_connect_async() local
375 task = g_task_new (NULL, cancellable, callback, user_data); in gst_rtmp_client_connect_async()
377 g_task_set_task_data (task, connect_task_data_new (location), in gst_rtmp_client_connect_async()
380 socket_connect (task); in gst_rtmp_client_connect_async()
384 socket_connect (GTask * task) in socket_connect() argument
386 ConnectTaskData *data = g_task_get_task_data (task); in socket_connect()
405 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_NOT_INITIALIZED, in socket_connect()
407 g_object_unref (task); in socket_connect()
412 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_NOT_INITIALIZED, in socket_connect()
414 g_object_unref (task); in socket_connect()
434 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_NOT_SUPPORTED, in socket_connect()
437 g_object_unref (task); in socket_connect()
446 g_task_get_cancellable (task), socket_connect_done, task); in socket_connect()
457 GTask *task = user_data; in socket_connect_done() local
463 if (g_task_return_error_if_cancelled (task)) { in socket_connect_done()
465 g_object_unref (task); in socket_connect_done()
471 g_task_return_error (task, error); in socket_connect_done()
472 g_object_unref (task); in socket_connect_done()
479 g_task_get_cancellable (task), handshake_done, task); in socket_connect_done()
489 GTask *task = user_data; in handshake_done() local
490 ConnectTaskData *data = g_task_get_task_data (task); in handshake_done()
497 g_task_return_error (task, error); in handshake_done()
498 g_object_unref (task); in handshake_done()
503 g_task_get_cancellable (task)); in handshake_done()
505 "error", G_CALLBACK (connection_error), task); in handshake_done()
507 send_connect (task); in handshake_done()
513 GTask *task = user_data; in connection_error() local
514 if (!g_task_had_error (task)) in connection_error()
515 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_FAILED, in connection_error()
581 send_connect (GTask * task) in send_connect() argument
583 ConnectTaskData *data = g_task_get_task_data (task); in send_connect()
596 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_NOT_INITIALIZED, in send_connect()
598 g_object_unref (task); in send_connect()
603 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_NOT_INITIALIZED, in send_connect()
605 g_object_unref (task); in send_connect()
618 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED, in send_connect()
620 g_object_unref (task); in send_connect()
625 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED, in send_connect()
627 g_object_unref (task); in send_connect()
685 task, 0, "connect", node, NULL); in send_connect()
696 GTask *task = G_TASK (user_data); in send_connect_done() local
697 ConnectTaskData *data = g_task_get_task_data (task); in send_connect_done()
701 if (g_task_return_error_if_cancelled (task)) { in send_connect_done()
702 g_object_unref (task); in send_connect_done()
707 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_FAILED, in send_connect_done()
709 g_object_unref (task); in send_connect_done()
714 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_FAILED, in send_connect_done()
716 g_object_unref (task); in send_connect_done()
724 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_FAILED, in send_connect_done()
726 g_object_unref (task); in send_connect_done()
735 send_secure_token_response (task, data->connection, in send_connect_done()
748 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED, in send_connect_done()
750 g_object_unref (task); in send_connect_done()
761 socket_connect (task); in send_connect_done()
765 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED, in send_connect_done()
767 g_object_unref (task); in send_connect_done()
772 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED, in send_connect_done()
774 g_object_unref (task); in send_connect_done()
798 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED, in send_connect_done()
801 g_object_unref (task); in send_connect_done()
810 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED, in send_connect_done()
813 g_object_unref (task); in send_connect_done()
824 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED, in send_connect_done()
826 g_object_unref (task); in send_connect_done()
832 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED, in send_connect_done()
834 g_object_unref (task); in send_connect_done()
849 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_FAILED, in send_connect_done()
851 g_object_unref (task); in send_connect_done()
855 socket_connect (task); in send_connect_done()
859 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_FAILED, in send_connect_done()
861 g_object_unref (task); in send_connect_done()
990 send_secure_token_response (GTask * task, GstRtmpConnection * connection, in send_secure_token_response() argument
993 ConnectTaskData *data = g_task_get_task_data (task); in send_secure_token_response()
1000 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED, in send_secure_token_response()
1002 g_object_unref (task); in send_secure_token_response()
1021 g_task_return_pointer (task, g_object_ref (connection), in send_secure_token_response()
1023 g_object_unref (task); in send_secure_token_response()
1029 GTask *task = G_TASK (result); in gst_rtmp_client_connect_finish() local
1030 return g_task_propagate_pointer (task, error); in gst_rtmp_client_connect_finish()
1033 static void send_create_stream (GTask * task);
1034 static void send_publish_or_play (GTask * task);
1073 GTask *task; in start_stream() local
1078 task = g_task_new (connection, cancellable, callback, user_data); in start_stream()
1081 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_NOT_INITIALIZED, in start_stream()
1083 g_object_unref (task); in start_stream()
1088 g_task_set_task_data (task, data, stream_task_data_free); in start_stream()
1091 "error", G_CALLBACK (connection_error), task); in start_stream()
1093 send_create_stream (task); in start_stream()
1127 send_create_stream (GTask * task) in send_create_stream() argument
1129 GstRtmpConnection *connection = g_task_get_source_object (task); in send_create_stream()
1130 StreamTaskData *data = g_task_get_task_data (task); in send_create_stream()
1151 gst_rtmp_connection_send_command (connection, create_stream_done, task, 0, in send_create_stream()
1162 GTask *task = G_TASK (user_data); in create_stream_done() local
1163 StreamTaskData *data = g_task_get_task_data (task); in create_stream_done()
1166 if (g_task_return_error_if_cancelled (task)) { in create_stream_done()
1167 g_object_unref (task); in create_stream_done()
1172 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_FAILED, in create_stream_done()
1174 g_object_unref (task); in create_stream_done()
1179 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_FAILED, in create_stream_done()
1181 g_object_unref (task); in create_stream_done()
1191 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_FAILED, in create_stream_done()
1193 g_object_unref (task); in create_stream_done()
1203 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_INVALID_DATA, in create_stream_done()
1205 g_object_unref (task); in create_stream_done()
1209 send_publish_or_play (task); in create_stream_done()
1213 send_publish_or_play (GTask * task) in send_publish_or_play() argument
1215 GstRtmpConnection *connection = g_task_get_source_object (task); in send_publish_or_play()
1216 StreamTaskData *data = g_task_get_task_data (task); in send_publish_or_play()
1235 task, data->id, "onStatus"); in send_publish_or_play()
1253 GTask *task = G_TASK (user_data); in on_publish_or_play_status() local
1254 GstRtmpConnection *connection = g_task_get_source_object (task); in on_publish_or_play_status()
1255 StreamTaskData *data = g_task_get_task_data (task); in on_publish_or_play_status()
1259 if (g_task_return_error_if_cancelled (task)) { in on_publish_or_play_status()
1260 g_object_unref (task); in on_publish_or_play_status()
1265 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_FAILED, in on_publish_or_play_status()
1267 g_object_unref (task); in on_publish_or_play_status()
1272 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_FAILED, in on_publish_or_play_status()
1274 g_object_unref (task); in on_publish_or_play_status()
1294 g_task_return_boolean (task, TRUE); in on_publish_or_play_status()
1299 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_EXISTS, in on_publish_or_play_status()
1305 g_task_return_new_error (task, G_IO_ERROR, in on_publish_or_play_status()
1314 g_task_return_boolean (task, TRUE); in on_publish_or_play_status()
1319 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_NOT_FOUND, in on_publish_or_play_status()
1325 g_task_return_new_error (task, G_IO_ERROR, G_IO_ERROR_FAILED, in on_publish_or_play_status()
1334 g_object_unref (task); in on_publish_or_play_status()
1341 GTask *task; in start_stream_finish() local
1346 task = G_TASK (result); in start_stream_finish()
1352 data = g_task_get_task_data (task); in start_stream_finish()