mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-28 12:41:05 +00:00
Code Issues 1 Projects Releases Wiki Activity

multiqueue: split gst_multi_queue_item_new

Browse source 
Split gst_multi_queue_item_new into buffer and event variant to make save an if
and make code more readable.
This commit is contained in:
Stefan Kost 2009-10-08 10:51:49 +03:00
parent 4cfe11d42c
commit 963932b1f1
1 changed files with 23 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

37
plugins/elements/gstmultiqueue.c
View file

@ -828,8 +828,7 @@ gst_multi_queue_item_destroy (GstMultiQueueItem * item)
/* takes ownership of passed mini object! */ /* takes ownership of passed mini object! */
static GstMultiQueueItem * static GstMultiQueueItem *
gst_multi_queue_item_new (GstMiniObject * object, guint32 curid, gst_multi_queue_buffer_item_new (GstMiniObject * object, guint32 curid)
gboolean isbuffer)
{ {
GstMultiQueueItem *item; GstMultiQueueItem *item;
@ -838,17 +837,27 @@ gst_multi_queue_item_new (GstMiniObject * object, guint32 curid,
item->destroy = (GDestroyNotify) gst_multi_queue_item_destroy; item->destroy = (GDestroyNotify) gst_multi_queue_item_destroy;
item->posid = curid; item->posid = curid;
if (isbuffer) { item->size = GST_BUFFER_SIZE (object);
item->size = GST_BUFFER_SIZE (object); item->duration = GST_BUFFER_DURATION (object);
item->duration = GST_BUFFER_DURATION (object); if (item->duration == GST_CLOCK_TIME_NONE)
if (item->duration == GST_CLOCK_TIME_NONE)
item->duration = 0;
item->visible = TRUE;
} else {
item->size = 0;
item->duration = 0; item->duration = 0;
item->visible = FALSE; item->visible = TRUE;
} return item;
}
static GstMultiQueueItem *
gst_multi_queue_event_item_new (GstMiniObject * object, guint32 curid)
{
GstMultiQueueItem *item;
item = g_slice_new (GstMultiQueueItem);
item->object = object;
item->destroy = (GDestroyNotify) gst_multi_queue_item_destroy;
item->posid = curid;
item->size = 0;
item->duration = 0;
item->visible = FALSE;
return item; return item;
} }
@ -1012,7 +1021,7 @@ gst_multi_queue_chain (GstPad * pad, GstBuffer * buffer)
GST_LOG_OBJECT (mq, "SingleQueue %d : about to enqueue buffer %p with id %d", GST_LOG_OBJECT (mq, "SingleQueue %d : about to enqueue buffer %p with id %d",
sq->id, buffer, curid); sq->id, buffer, curid);
item = gst_multi_queue_item_new (GST_MINI_OBJECT_CAST (buffer), curid, TRUE); item = gst_multi_queue_buffer_item_new (GST_MINI_OBJECT_CAST (buffer), curid);
timestamp = GST_BUFFER_TIMESTAMP (buffer); timestamp = GST_BUFFER_TIMESTAMP (buffer);
duration = GST_BUFFER_DURATION (buffer); duration = GST_BUFFER_DURATION (buffer);
@ -1108,7 +1117,7 @@ gst_multi_queue_sink_event (GstPad * pad, GstEvent * event)
curid = mq->counter++; curid = mq->counter++;
GST_MULTI_QUEUE_MUTEX_UNLOCK (mq); GST_MULTI_QUEUE_MUTEX_UNLOCK (mq);
item = gst_multi_queue_item_new ((GstMiniObject *) event, curid, FALSE); item = gst_multi_queue_event_item_new ((GstMiniObject *) event, curid);
GST_DEBUG_OBJECT (mq, GST_DEBUG_OBJECT (mq,
"SingleQueue %d : Enqueuing event %p of type %s with id %d", "SingleQueue %d : Enqueuing event %p of type %s with id %d",