Lines Matching refs:queue
61 #define GET_PRIV(queue) gst_vulkan_queue_get_instance_private (queue) argument
66 gst_vulkan_queue_init (GstVulkanQueue * queue) in gst_vulkan_queue_init() argument
68 GstVulkanQueuePrivate *priv = GET_PRIV (queue); in gst_vulkan_queue_init()
84 GstVulkanQueue *queue = GST_VULKAN_QUEUE (object); in gst_vulkan_queue_dispose() local
85 GstVulkanQueuePrivate *priv = GET_PRIV (queue); in gst_vulkan_queue_dispose()
87 if (queue->device) in gst_vulkan_queue_dispose()
88 gst_object_unref (queue->device); in gst_vulkan_queue_dispose()
89 queue->device = NULL; in gst_vulkan_queue_dispose()
105 gst_vulkan_queue_get_device (GstVulkanQueue * queue) in gst_vulkan_queue_get_device() argument
107 g_return_val_if_fail (GST_IS_VULKAN_QUEUE (queue), NULL); in gst_vulkan_queue_get_device()
109 return queue->device ? gst_object_ref (queue->device) : NULL; in gst_vulkan_queue_get_device()
122 gst_vulkan_queue_create_command_pool (GstVulkanQueue * queue, GError ** error) in gst_vulkan_queue_create_command_pool() argument
129 g_return_val_if_fail (GST_IS_VULKAN_QUEUE (queue), NULL); in gst_vulkan_queue_create_command_pool()
133 cmd_pool_info.queueFamilyIndex = queue->family; in gst_vulkan_queue_create_command_pool()
136 GST_OBJECT_LOCK (queue->device); in gst_vulkan_queue_create_command_pool()
138 vkCreateCommandPool (queue->device->device, &cmd_pool_info, NULL, in gst_vulkan_queue_create_command_pool()
141 GST_OBJECT_LOCK (queue->device); in gst_vulkan_queue_create_command_pool()
144 GST_OBJECT_UNLOCK (queue->device); in gst_vulkan_queue_create_command_pool()
148 pool->queue = gst_object_ref (queue); in gst_vulkan_queue_create_command_pool()
167 gst_context_set_vulkan_queue (GstContext * context, GstVulkanQueue * queue) in gst_context_set_vulkan_queue() argument
174 if (queue) in gst_context_set_vulkan_queue()
177 GST_PTR_FORMAT ")", queue, context); in gst_context_set_vulkan_queue()
181 GST_TYPE_VULKAN_QUEUE, queue, NULL); in gst_context_set_vulkan_queue()
194 gst_context_get_vulkan_queue (GstContext * context, GstVulkanQueue ** queue) in gst_context_get_vulkan_queue() argument
199 g_return_val_if_fail (queue != NULL, FALSE); in gst_context_get_vulkan_queue()
204 GST_TYPE_VULKAN_QUEUE, queue, NULL); in gst_context_get_vulkan_queue()
207 ") from context(%" GST_PTR_FORMAT ")", *queue, context); in gst_context_get_vulkan_queue()
229 GstVulkanQueue * queue) in gst_vulkan_queue_handle_context_query() argument
239 if (!queue) in gst_vulkan_queue_handle_context_query()
252 gst_context_set_vulkan_queue (context, queue); in gst_vulkan_queue_handle_context_query()
256 res = queue != NULL; in gst_vulkan_queue_handle_context_query()
276 GstVulkanQueue ** queue) in gst_vulkan_queue_run_context_query() argument
281 g_return_val_if_fail (queue != NULL, FALSE); in gst_vulkan_queue_run_context_query()
285 if (*queue && GST_IS_VULKAN_QUEUE (*queue)) in gst_vulkan_queue_run_context_query()
295 gst_context_get_vulkan_queue (context, queue); in gst_vulkan_queue_run_context_query()
300 GST_DEBUG_OBJECT (element, "found queue %p", *queue); in gst_vulkan_queue_run_context_query()
302 if (*queue) in gst_vulkan_queue_run_context_query()
318 gst_vulkan_queue_submit_lock (GstVulkanQueue * queue) in gst_vulkan_queue_submit_lock() argument
320 GstVulkanQueuePrivate *priv = GET_PRIV (queue); in gst_vulkan_queue_submit_lock()
336 gst_vulkan_queue_submit_unlock (GstVulkanQueue * queue) in gst_vulkan_queue_submit_unlock() argument
338 GstVulkanQueuePrivate *priv = GET_PRIV (queue); in gst_vulkan_queue_submit_unlock()