Searched refs:available_queue (Results 1 – 4 of 4) sorted by relevance
720 nvenc->available_queue = g_async_queue_new (); in gst_nv_base_enc_start()760 if (nvenc->available_queue) { in gst_nv_base_enc_stop()761 g_async_queue_unref (nvenc->available_queue); in gst_nv_base_enc_stop()762 nvenc->available_queue = NULL; in gst_nv_base_enc_stop()1231 g_async_queue_push (nvenc->available_queue, state_in_queue); in gst_nv_base_enc_bitstream_thread()1289 g_async_queue_push (nvenc->available_queue, SHUTDOWN_COOKIE); in gst_nv_base_enc_bitstream_thread()1303 g_async_queue_push (nvenc->available_queue, SHUTDOWN_COOKIE); in gst_nv_base_enc_bitstream_thread()1356 g_async_queue_lock (nvenc->available_queue); in gst_nv_base_enc_stop_bitstream_thread()1361 g_async_queue_push_unlocked (nvenc->available_queue, state); in gst_nv_base_enc_stop_bitstream_thread()1364 g_async_queue_unlock (nvenc->available_queue); in gst_nv_base_enc_stop_bitstream_thread()[all …]
131 GAsyncQueue *available_queue; member
95 GstVulkanQueue * available_queue,
309 GstVulkanQueue * available_queue, GError ** error) in gst_vulkan_swapper_choose_queue() argument317 if (available_queue) { in gst_vulkan_swapper_choose_queue()320 queue_family_props[available_queue->family].queueFlags; in gst_vulkan_swapper_choose_queue()325 swapper->device, available_queue->index); in gst_vulkan_swapper_choose_queue()327 swapper->queue = gst_object_ref (available_queue); in gst_vulkan_swapper_choose_queue()