mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-02-03 13:02:29 +00:00
Code Issues 1 Projects Releases Wiki Activity

vkqueue: add context helpers

Browse source
This commit is contained in:
Matthew Waters 2016-02-16 11:22:37 +11:00
parent 5617b0904b
commit eb4419b49b
2 changed files with 136 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

124
ext/vulkan/vkqueue.c
View file

@ -26,10 +26,12 @@
#define GST_CAT_DEFAULT gst_vulkan_queue_debug
GST_DEBUG_CATEGORY (GST_CAT_DEFAULT);
GST_DEBUG_CATEGORY_STATIC (GST_CAT_CONTEXT);
G_DEFINE_TYPE_WITH_CODE (GstVulkanQueue, gst_vulkan_queue, GST_TYPE_OBJECT,
GST_DEBUG_CATEGORY_INIT (GST_CAT_DEFAULT, "vulkanqueue", 0,
"Vulkan Queue"));
"Vulkan Queue");
GST_DEBUG_CATEGORY_GET (GST_CAT_CONTEXT, "GST_CONTEXT"));
static void gst_vulkan_queue_dispose (GObject * object);
@ -63,3 +65,123 @@ gst_vulkan_queue_get_device (GstVulkanQueue * queue)
return queue->device ? gst_object_ref (queue->device) : NULL;
}
/**
* gst_context_set_vulkan_queue:
* @context: a #GstContext
* @queue: a #GstVulkanQueue
*
* Sets @queue on @context
*
* Since: 1.10
*/
void
gst_context_set_vulkan_queue (GstContext * context, GstVulkanQueue * queue)
{
GstStructure *s;
g_return_if_fail (context != NULL);
g_return_if_fail (gst_context_is_writable (context));
if (queue)
GST_CAT_LOG (GST_CAT_CONTEXT,
"setting GstVulkanQueue(%" GST_PTR_FORMAT ") on context(%"
GST_PTR_FORMAT ")", queue, context);
s = gst_context_writable_structure (context);
gst_structure_set (s, GST_VULKAN_QUEUE_CONTEXT_TYPE_STR,
GST_TYPE_VULKAN_QUEUE, queue, NULL);
}
/**
* gst_context_get_vulkan_queue:
* @context: a #GstContext
* @queue: resulting #GstVulkanQueue
*
* Returns: Whether @queue was in @context
*
* Since: 1.10
*/
gboolean
gst_context_get_vulkan_queue (GstContext * context, GstVulkanQueue ** queue)
{
const GstStructure *s;
gboolean ret;
g_return_val_if_fail (queue != NULL, FALSE);
g_return_val_if_fail (context != NULL, FALSE);
s = gst_context_get_structure (context);
ret = gst_structure_get (s, GST_VULKAN_QUEUE_CONTEXT_TYPE_STR,
GST_TYPE_VULKAN_QUEUE, queue, NULL);
GST_CAT_LOG (GST_CAT_CONTEXT, "got GstVulkanQueue(%" GST_PTR_FORMAT
") from context(%" GST_PTR_FORMAT ")", *queue, context);
return ret;
}
gboolean
gst_vulkan_queue_handle_context_query (GstElement * element, GstQuery * query,
GstVulkanQueue ** queue)
{
gboolean res = FALSE;
const gchar *context_type;
GstContext *context, *old_context;
g_return_val_if_fail (element != NULL, FALSE);
g_return_val_if_fail (query != NULL, FALSE);
g_return_val_if_fail (GST_QUERY_TYPE (query) == GST_QUERY_CONTEXT, FALSE);
g_return_val_if_fail (queue != NULL, FALSE);
gst_query_parse_context_type (query, &context_type);
if (g_strcmp0 (context_type, GST_VULKAN_QUEUE_CONTEXT_TYPE_STR) == 0) {
gst_query_parse_context (query, &old_context);
if (old_context)
context = gst_context_copy (old_context);
else
context = gst_context_new (GST_VULKAN_QUEUE_CONTEXT_TYPE_STR, TRUE);
gst_context_set_vulkan_queue (context, *queue);
gst_query_set_context (query, context);
gst_context_unref (context);
res = *queue != NULL;
}
return res;
}
gboolean
gst_vulkan_queue_run_context_query (GstElement * element,
GstVulkanQueue ** queue)
{
GstQuery *query;
g_return_val_if_fail (GST_IS_ELEMENT (element), FALSE);
g_return_val_if_fail (queue != NULL, FALSE);
if (*queue && GST_IS_VULKAN_QUEUE (*queue))
return TRUE;
if ((query =
gst_vulkan_local_context_query (element,
GST_VULKAN_QUEUE_CONTEXT_TYPE_STR, FALSE))) {
GstContext *context;
gst_query_parse_context (query, &context);
if (context)
gst_context_get_vulkan_queue (context, queue);
}
GST_DEBUG_OBJECT (element, "found queue %p", *queue);
gst_query_unref (query);
if (*queue)
return TRUE;
return FALSE;
}

14
ext/vulkan/vkqueue.h
View file

@ -31,6 +31,8 @@
#define GST_VULKAN_QUEUE_GET_CLASS(o) (G_TYPE_INSTANCE_GET_CLASS((o), GST_TYPE_VULKAN_QUEUE, GstVulkanQueueClass))
GType gst_vulkan_queue_get_type (void);
#define GST_VULKAN_QUEUE_CONTEXT_TYPE_STR "gst.vulkan.queue"
struct _GstVulkanQueue
{
GstObject parent;
@ -47,6 +49,16 @@ struct _GstVulkanQueueClass
GstObjectClass parent_class;
};
GstVulkanDevice * gst_vulkan_queue_get_device (GstVulkanQueue * queue);
GstVulkanDevice * gst_vulkan_queue_get_device (GstVulkanQueue * queue);
void gst_context_set_vulkan_queue (GstContext * context,
GstVulkanQueue * queue);
gboolean gst_context_get_vulkan_queue (GstContext * context,
GstVulkanQueue ** queue);
gboolean gst_vulkan_queue_handle_context_query (GstElement * element,
GstQuery * query,
GstVulkanQueue ** queue);
gboolean gst_vulkan_queue_run_context_query (GstElement * element,
GstVulkanQueue ** queue);
#endif /* _VK_QUEUE_H_ */