59   GTask *task;  in gst_rtmp_input_stream_read_all_bytes_async()  local
64   task = g_task_new (stream, cancellable, callback, user_data);  in gst_rtmp_input_stream_read_all_bytes_async()
68   g_task_set_task_data (task, ba, (GDestroyNotify) g_byte_array_unref);  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()
79   GTask *task = user_data;  in read_all_bytes_done()  local
80   GByteArray *ba = g_task_get_task_data (task);  in read_all_bytes_done()
88     g_task_return_error (task, error);  in read_all_bytes_done()
89     g_object_unref (task);  in read_all_bytes_done()
96   g_task_return_pointer (task, bytes, (GDestroyNotify) g_bytes_unref);  in read_all_bytes_done()
97   g_object_unref (task);  in read_all_bytes_done()
113   GTask *task;  in gst_rtmp_output_stream_write_all_bytes_async()  local
123   task = g_task_new (stream, cancellable, callback, user_data);  in gst_rtmp_output_stream_write_all_bytes_async()
124   g_task_set_task_data (task, g_bytes_ref (bytes),  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()
136   GTask *task = user_data;  in write_all_bytes_done()  local
142     g_task_return_error (task, error);  in write_all_bytes_done()
143     g_object_unref (task);  in write_all_bytes_done()
147   g_task_return_boolean (task, TRUE);  in write_all_bytes_done()
148   g_object_unref (task);  in write_all_bytes_done()
191   GTask *task;  in gst_rtmp_output_stream_write_all_buffer_async()  local
197   task = g_task_new (stream, cancellable, callback, user_data);  in gst_rtmp_output_stream_write_all_buffer_async()
200   g_task_set_task_data (task, data, write_all_buffer_data_free);  in gst_rtmp_output_stream_write_all_buffer_async()
203     g_task_return_new_error (task, GST_RESOURCE_ERROR, GST_RESOURCE_ERROR_READ,  in gst_rtmp_output_stream_write_all_buffer_async()
205     g_object_unref (task);  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()
220   GTask *task = user_data;  in write_all_buffer_done()  local
221   WriteAllBufferData *data = g_task_get_task_data (task);  in write_all_buffer_done()
232     g_task_return_error (task, error);  in write_all_buffer_done()
233     g_object_unref (task);  in write_all_buffer_done()
237   g_task_return_boolean (task, TRUE);  in write_all_buffer_done()
238   g_object_unref (task);  in write_all_buffer_done()
247   GTask *task;  in gst_rtmp_output_stream_write_all_buffer_finish()  local
250   task = G_TASK (result);  in gst_rtmp_output_stream_write_all_buffer_finish()
252   data = g_task_get_task_data (task);  in gst_rtmp_output_stream_write_all_buffer_finish()
257   return g_task_propagate_boolean (task, error);  in gst_rtmp_output_stream_write_all_buffer_finish()