Lines Matching refs:elt
2074 GstCurlHttpSrc *elt; in gst_curl_http_src_curl_multi_loop() local
2099 elt = qelement->p; in gst_curl_http_src_curl_multi_loop()
2102 g_mutex_lock (&elt->buffer_mutex); in gst_curl_http_src_curl_multi_loop()
2103 if (elt->connection_status == GSTCURL_WANT_REMOVAL) { in gst_curl_http_src_curl_multi_loop()
2104 curl_multi_remove_handle (context->multi_handle, elt->curl_handle); in gst_curl_http_src_curl_multi_loop()
2105 if (elt->state == GSTCURL_UNLOCK) { in gst_curl_http_src_curl_multi_loop()
2106 elt->pending_state = GSTCURL_REMOVED; in gst_curl_http_src_curl_multi_loop()
2108 elt->state = GSTCURL_REMOVED; in gst_curl_http_src_curl_multi_loop()
2110 elt->connection_status = GSTCURL_NOT_CONNECTED; in gst_curl_http_src_curl_multi_loop()
2112 g_cond_signal (&elt->buffer_cond); in gst_curl_http_src_curl_multi_loop()
2113 } else if (elt->connection_status == GSTCURL_CONNECTED) { in gst_curl_http_src_curl_multi_loop()
2120 g_mutex_unlock (&elt->buffer_mutex); in gst_curl_http_src_curl_multi_loop()
2547 GstCurlHttpSrc *elt = NULL; local
2550 elt = qelement->p;
2551 g_mutex_lock (&elt->buffer_mutex);
2552 elt->curl_result = CURLE_COULDNT_CONNECT;
2553 curl_multi_remove_handle (context->multi_handle, elt->curl_handle);
2554 elt->connection_status = GSTCURL_NOT_CONNECTED;
2555 elt->data_received = FALSE;
2557 g_cond_signal (&elt->buffer_cond);
2558 g_mutex_unlock (&elt->buffer_mutex);