mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-27 04:01:08 +00:00
Code Issues 1 Projects Releases Wiki Activity

basetransform: improve propose_allocation

Browse source 
Improve the propose allocation vmethod by passing the downstream allocation
query to it. This way the vmethod implementation can use properties of the
downstream allocation to generate the upstream query result. If there is no
downstream quety, it means that the element is working in passthrough mode.
Implement a default decide_allocation.
This commit is contained in:
Wim Taymans 2012-03-01 14:30:58 +01:00
parent 4f6faa3405
commit d6a28a6e3a
2 changed files with 48 additions and 24 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

54
libs/gst/base/gstbasetransform.c
View file

@ -257,6 +257,7 @@ struct _GstBaseTransformPrivate
GstAllocator *allocator;
guint prefix;
guint alignment;
GstQuery *query;
};
@ -330,8 +331,10 @@ static gboolean gst_base_transform_acceptcaps_default (GstBaseTransform * trans,
GstPadDirection direction, GstCaps * caps);
static gboolean gst_base_transform_setcaps (GstBaseTransform * trans,
GstPad * pad, GstCaps * caps);
static gboolean gst_base_transform_default_decide_allocation (GstBaseTransform
* trans, GstQuery * query);
static gboolean gst_base_transform_default_propose_allocation (GstBaseTransform
* trans, gboolean passthrough, GstQuery * query);
* trans, GstQuery * decide_query, GstQuery * query);
static gboolean gst_base_transform_query (GstPad * pad, GstObject * parent,
GstQuery * query);
static gboolean gst_base_transform_default_query (GstBaseTransform * trans,
@ -388,6 +391,8 @@ gst_base_transform_class_init (GstBaseTransformClass * klass)
klass->accept_caps =
GST_DEBUG_FUNCPTR (gst_base_transform_acceptcaps_default);
klass->query = GST_DEBUG_FUNCPTR (gst_base_transform_default_query);
klass->decide_allocation =
GST_DEBUG_FUNCPTR (gst_base_transform_default_decide_allocation);
klass->propose_allocation =
GST_DEBUG_FUNCPTR (gst_base_transform_default_propose_allocation);
klass->transform_size =
@ -743,14 +748,15 @@ done:
return caps;
}
/* takes ownership of the pool and allocator */
/* takes ownership of the pool, allocator and query */
static gboolean
gst_base_transform_set_allocation (GstBaseTransform * trans,
GstBufferPool * pool, GstAllocator * allocator, guint prefix,
guint alignment)
guint alignment, GstQuery * query)
{
GstAllocator *oldalloc;
GstBufferPool *oldpool;
GstQuery *oldquery;
GstBaseTransformPrivate *priv = trans->priv;
/* activate */
@ -765,6 +771,8 @@ gst_base_transform_set_allocation (GstBaseTransform * trans,
priv->pool = pool;
oldalloc = priv->allocator;
priv->allocator = allocator;
oldquery = priv->query;
priv->query = query;
priv->prefix = prefix;
priv->alignment = alignment;
GST_OBJECT_UNLOCK (trans);
@ -777,6 +785,9 @@ gst_base_transform_set_allocation (GstBaseTransform * trans,
if (oldalloc) {
gst_allocator_unref (oldalloc);
}
if (oldquery) {
gst_query_unref (oldquery);
}
return TRUE;
/* ERRORS */
@ -787,6 +798,13 @@ activate_failed:
}
}
static gboolean
gst_base_transform_default_decide_allocation (GstBaseTransform * trans,
GstQuery * query)
{
return TRUE;
}
static gboolean
gst_base_transform_do_bufferpool (GstBaseTransform * trans, GstCaps * outcaps)
{
@ -806,14 +824,13 @@ gst_base_transform_do_bufferpool (GstBaseTransform * trans, GstCaps * outcaps)
* propose_allocation vmethod will be called and we will configure the
* upstream allocator with our proposed values then.
*/
if (trans->passthrough || trans->always_in_place) {
/* we are in passthrough, the input buffer is never copied and always passed
* along. We never allocate an output buffer on the srcpad. What we do is
* let the upstream element decide if it wants to use a bufferpool and
* then we will proxy the downstream pool */
GST_DEBUG_OBJECT (trans, "we're passthough, delay bufferpool");
gst_base_transform_set_allocation (trans, NULL, NULL, 0, 0);
gst_base_transform_set_allocation (trans, NULL, NULL, 0, 0, NULL);
return TRUE;
}
@ -857,12 +874,10 @@ gst_base_transform_do_bufferpool (GstBaseTransform * trans, GstCaps * outcaps)
gst_buffer_pool_set_config (pool, config);
}
gst_query_unref (query);
/* and store */
result =
gst_base_transform_set_allocation (trans, pool, allocator, prefix,
alignment);
alignment, query);
return result;
@ -1267,11 +1282,11 @@ failed_configure:
static gboolean
gst_base_transform_default_propose_allocation (GstBaseTransform * trans,
gboolean passthrough, GstQuery * query)
GstQuery * decide_query, GstQuery * query)
{
gboolean ret;
if (passthrough) {
if (decide_query == NULL) {
GST_DEBUG_OBJECT (trans, "doing passthrough query");
ret = gst_pad_peer_query (trans->srcpad, query);
} else {
@ -1301,23 +1316,30 @@ gst_base_transform_default_query (GstBaseTransform * trans,
switch (GST_QUERY_TYPE (query)) {
case GST_QUERY_ALLOCATION:
{
gboolean passthrough;
GstQuery *decide_query;
/* can only be done on the sinkpad */
if (direction != GST_PAD_SINK)
goto done;
passthrough = gst_base_transform_is_passthrough (trans);
GST_OBJECT_LOCK (trans);
if ((decide_query = trans->priv->query))
gst_query_ref (decide_query);
GST_OBJECT_UNLOCK (trans);
GST_DEBUG_OBJECT (trans, "propose %spassthrough allocation values",
(passthrough ? "" : "non-"));
GST_DEBUG_OBJECT (trans,
"calling propose allocation with query %" GST_PTR_FORMAT,
decide_query);
/* pass the query to the propose_allocation vmethod if any */
if (G_LIKELY (klass->propose_allocation))
ret = klass->propose_allocation (trans, passthrough, query);
ret = klass->propose_allocation (trans, decide_query, query);
else
ret = FALSE;
if (decide_query)
gst_query_unref (decide_query);
GST_DEBUG_OBJECT (trans, "ALLOCATION ret %d, %" GST_PTR_FORMAT, ret,
query);
break;
@ -2111,7 +2133,7 @@ gst_base_transform_activate (GstBaseTransform * trans, gboolean active)
if (trans->priv->pad_mode != GST_PAD_MODE_NONE && bclass->stop)
result &= bclass->stop (trans);
gst_base_transform_set_allocation (trans, NULL, NULL, 0, 0);
gst_base_transform_set_allocation (trans, NULL, NULL, 0, 0, NULL);
}
return result;

18
libs/gst/base/gstbasetransform.h
View file

@ -138,16 +138,18 @@ struct _GstBaseTransform {
* Handle a requested query. Subclasses that implement this
* should must chain up to the parent if they didn't handle the
* query
* @propose_allocation: Propose buffer allocation parameters for upstream elements.
* This function must be implemented if the element reads or
* writes the buffer content. In passthrough mode, the
* default implementation will forward the ALLOCATION query
* downstream.
* @decide_allocation: Setup the allocation parameters for allocating output
* buffers. The passed in query contains the result of the
* downstream allocation query. This function is only called
* when not operating in passthrough mode. The default
* implementation is NULL.
* @propose_allocation: Propose buffer allocation parameters for upstream elements.
* This function must be implemented if the element reads or
* writes the buffer content. The query that was passed to
* the decide_allocation is passed in this method (or NULL
* when the element is in passthrough mode). The default
* implementation will pass the query downstream when in
* passthrough mode.
* @transform_size: Optional. Given the size of a buffer in the given direction
* with the given caps, calculate the size in bytes of a buffer
* on the other pad with the given other caps.
@ -216,11 +218,11 @@ struct _GstBaseTransformClass {
gboolean (*query) (GstBaseTransform *trans, GstPadDirection direction,
GstQuery *query);
/* propose allocation query parameters for input buffers */
gboolean (*propose_allocation) (GstBaseTransform *trans, gboolean passthrough,
GstQuery *query);
/* decide allocation query for output buffers */
gboolean (*decide_allocation) (GstBaseTransform *trans, GstQuery *query);
/* propose allocation query parameters for input buffers */
gboolean (*propose_allocation) (GstBaseTransform *trans, GstQuery *decide_query,
GstQuery *query);
/* transform size */
gboolean (*transform_size) (GstBaseTransform *trans,