• Home
  • Raw
  • Download

Lines Matching refs:transfer_cond

247   sink->transfer_cond = g_malloc (sizeof (TransferCondition));  in gst_curl_base_sink_init()
248 g_cond_init (&sink->transfer_cond->cond); in gst_curl_base_sink_init()
249 sink->transfer_cond->data_sent = FALSE; in gst_curl_base_sink_init()
250 sink->transfer_cond->data_available = FALSE; in gst_curl_base_sink_init()
251 sink->transfer_cond->wait_for_response = FALSE; in gst_curl_base_sink_init()
272 g_cond_clear (&this->transfer_cond->cond); in gst_curl_base_sink_finalize()
273 g_free (this->transfer_cond); in gst_curl_base_sink_finalize()
292 sink->transfer_cond->data_available = TRUE; in gst_curl_base_sink_transfer_thread_notify_unlocked()
293 sink->transfer_cond->data_sent = FALSE; in gst_curl_base_sink_transfer_thread_notify_unlocked()
294 sink->transfer_cond->wait_for_response = TRUE; in gst_curl_base_sink_transfer_thread_notify_unlocked()
295 g_cond_signal (&sink->transfer_cond->cond); in gst_curl_base_sink_transfer_thread_notify_unlocked()
304 g_cond_signal (&sink->transfer_cond->cond); in gst_curl_base_sink_transfer_thread_close()
369 g_assert (sink->transfer_cond->data_available == FALSE); in gst_curl_base_sink_render()
444 sink->transfer_cond->data_sent = FALSE; in gst_curl_base_sink_start()
445 sink->transfer_cond->data_available = FALSE; in gst_curl_base_sink_start()
446 sink->transfer_cond->wait_for_response = FALSE; in gst_curl_base_sink_start()
1356 while (!sink->transfer_cond->data_available && in gst_curl_base_sink_wait_for_data_unlocked()
1358 g_cond_wait (&sink->transfer_cond->cond, GST_OBJECT_GET_LOCK (sink)); in gst_curl_base_sink_wait_for_data_unlocked()
1378 g_cond_signal (&sink->transfer_cond->cond); in gst_curl_base_sink_new_file_notify_unlocked()
1391 while (!sink->transfer_cond->data_sent) { in gst_curl_base_sink_wait_for_transfer_thread_to_send_unlocked()
1392 g_cond_wait (&sink->transfer_cond->cond, GST_OBJECT_GET_LOCK (sink)); in gst_curl_base_sink_wait_for_transfer_thread_to_send_unlocked()
1402 sink->transfer_cond->data_available = FALSE; in gst_curl_base_sink_data_sent_notify()
1403 sink->transfer_cond->data_sent = TRUE; in gst_curl_base_sink_data_sent_notify()
1404 g_cond_signal (&sink->transfer_cond->cond); in gst_curl_base_sink_data_sent_notify()
1414 while (sink->transfer_cond->wait_for_response) { in gst_curl_base_sink_wait_for_response()
1415 g_cond_wait (&sink->transfer_cond->cond, GST_OBJECT_GET_LOCK (sink)); in gst_curl_base_sink_wait_for_response()
1428 sink->transfer_cond->wait_for_response = FALSE; in gst_curl_base_sink_got_response_notify()
1429 g_cond_signal (&sink->transfer_cond->cond); in gst_curl_base_sink_got_response_notify()