mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-09-08 21:28:45 +00:00
72c31876aa
Multiqueue should only be used to cope with: * decoupling upstream and dowstream threading (i.e. having separate threads for elementary streams). * Ensuring individual queues have enough space to cope with upstream interleave (distance in stream time between co-located samples). This is to guarantee that we have enough room in each individual queues to provide new data in each, without being blocked. * Limit the queue sizes to that interleave distance (and an extra minimal buffering size). This is to ensure we don't consume too much memory. Based on that, multiqueue now continuously calculates the input interleave (per incoming streaming thread). Based on that, it calculates a target interleave (currently 1.5 x real_interleave + 250ms padding). If the target interleave is greater than the current max_size.time, it will update it accordingly (to allow enough margin to not block). If the target interleave goes down by more than 50%, we re-adjust it once we know we have gone past a safe distance (2 x current max_size.time). This mode can only be used for incoming streams that are guaranteed to be properly timestamped. Furthermore, we ignore sparse streams when calculating interleave and maximum size of queues. For the simplest of use-cases (single stream), multiqueue acts as a single queue with a time limit of 250ms. If there are multiple inputs, but each come from a different streaming thread, the maximum time limit will also end up being 250ms. On regular files (more than one input stream from the same upstream streaming thread), it can reduce the total memory used as much as 10x, ending up with max_size.time around 500ms. Due to the adaptive nature, it can also cope with changing interleave (which can happen commonly on some files at startup/pre-roll time)
99 lines
2.9 KiB
C
99 lines
2.9 KiB
C
/* GStreamer
|
|
* Copyright (C) 2006 Edward Hervey <edward@fluendo.com>
|
|
*
|
|
* gstmultiqueue.h:
|
|
*
|
|
* This library is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Library General Public
|
|
* License as published by the Free Software Foundation; either
|
|
* version 2 of the License, or (at your option) any later version.
|
|
*
|
|
* This library is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* Library General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Library General Public
|
|
* License along with this library; if not, write to the
|
|
* Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
|
|
* Boston, MA 02110-1301, USA.
|
|
*/
|
|
|
|
|
|
#ifndef __GST_MULTI_QUEUE_H__
|
|
#define __GST_MULTI_QUEUE_H__
|
|
|
|
#include <gst/gst.h>
|
|
#include <gst/base/gstdataqueue.h>
|
|
|
|
G_BEGIN_DECLS
|
|
|
|
#define GST_TYPE_MULTI_QUEUE \
|
|
(gst_multi_queue_get_type())
|
|
#define GST_MULTI_QUEUE(obj) \
|
|
(G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_MULTI_QUEUE,GstMultiQueue))
|
|
#define GST_MULTI_QUEUE_CLASS(klass) \
|
|
(G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_MULTI_QUEUE,GstMultiQueueClass))
|
|
#define GST_IS_MULTI_QUEUE(obj) \
|
|
(G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_MULTI_QUEUE))
|
|
#define GST_IS_MULTI_QUEUE_CLASS(obj) \
|
|
(G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_MULTI_QUEUE))
|
|
|
|
typedef struct _GstMultiQueue GstMultiQueue;
|
|
typedef struct _GstMultiQueueClass GstMultiQueueClass;
|
|
|
|
/**
|
|
* GstMultiQueue:
|
|
*
|
|
* Opaque #GstMultiQueue structure.
|
|
*/
|
|
struct _GstMultiQueue {
|
|
GstElement element;
|
|
|
|
gboolean sync_by_running_time;
|
|
gboolean use_interleave;
|
|
|
|
/* number of queues */
|
|
guint nbqueues;
|
|
|
|
/* The list of individual queues */
|
|
GList *queues;
|
|
guint32 queues_cookie;
|
|
|
|
GstDataQueueSize max_size, extra_size;
|
|
gboolean use_buffering;
|
|
gint low_percent, high_percent;
|
|
gboolean buffering;
|
|
gint percent;
|
|
|
|
guint counter; /* incoming object counter, use atomic accesses */
|
|
guint32 highid; /* contains highest id of last outputted object */
|
|
GstClockTime high_time; /* highest start running time */
|
|
|
|
GMutex qlock; /* Global queue lock (vs object lock or individual */
|
|
/* queues lock). Protects nbqueues, queues, global */
|
|
/* GstMultiQueueSize, counter and highid */
|
|
|
|
gint numwaiting; /* number of not-linked pads waiting */
|
|
|
|
gboolean percent_changed;
|
|
GMutex buffering_post_lock; /* assures only one posted at a time */
|
|
|
|
GstClockTime interleave; /* Input interleave */
|
|
GstClockTime last_interleave_update;
|
|
};
|
|
|
|
struct _GstMultiQueueClass {
|
|
GstElementClass parent_class;
|
|
|
|
/* signals emitted when ALL queues are either full or empty */
|
|
void (*underrun) (GstMultiQueue *queue);
|
|
void (*overrun) (GstMultiQueue *queue);
|
|
};
|
|
|
|
G_GNUC_INTERNAL GType gst_multi_queue_get_type (void);
|
|
|
|
G_END_DECLS
|
|
|
|
|
|
#endif /* __GST_MULTI_QUEUE_H__ */
|