mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-11-03 16:09:39 +00:00
f3dd7937a2
The qlock is released between popping a buffer from the queue and pushing it. When this buffer causes the sink to wait in preroll, this lets a query see that the queue is empty, and push the query then wait for it to be serviced. However, this will not be done till after peroll, and this will thus block. If upstream was waiting on buffering to reach 100% before switching to PLAYING, a deadlock would ensue. This had been fixed recently by failing queries when the queue2 was buffering, but this happens to break some other case (playbin on a local http server and matroska), while this patch works for both. See https://bugzilla.gnome.org/show_bug.cgi?id=728345
167 lines
4.8 KiB
C
167 lines
4.8 KiB
C
/* GStreamer
|
|
* Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
|
|
* 2003 Colin Walters <cwalters@gnome.org>
|
|
* 2000,2005,2007 Wim Taymans <wim.taymans@gmail.com>
|
|
* 2007 Thiago Sousa Santos <thiagoss@lcc.ufcg.edu.br>
|
|
*
|
|
* gstqueue2.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_QUEUE2_H__
|
|
#define __GST_QUEUE2_H__
|
|
|
|
#include <gst/gst.h>
|
|
#include <stdio.h>
|
|
|
|
G_BEGIN_DECLS
|
|
|
|
#define GST_TYPE_QUEUE2 \
|
|
(gst_queue2_get_type())
|
|
#define GST_QUEUE2(obj) \
|
|
(G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_QUEUE2,GstQueue2))
|
|
#define GST_QUEUE2_CLASS(klass) \
|
|
(G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_QUEUE2,GstQueue2Class))
|
|
#define GST_IS_QUEUE2(obj) \
|
|
(G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_QUEUE2))
|
|
#define GST_IS_QUEUE2_CLASS(klass) \
|
|
(G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_QUEUE2))
|
|
#define GST_QUEUE2_CAST(obj) \
|
|
((GstQueue2 *)(obj))
|
|
|
|
typedef struct _GstQueue2 GstQueue2;
|
|
typedef struct _GstQueue2Size GstQueue2Size;
|
|
typedef struct _GstQueue2Class GstQueue2Class;
|
|
typedef struct _GstQueue2Range GstQueue2Range;
|
|
|
|
/* used to keep track of sizes (current and max) */
|
|
struct _GstQueue2Size
|
|
{
|
|
guint buffers;
|
|
guint bytes;
|
|
guint64 time;
|
|
guint64 rate_time;
|
|
};
|
|
|
|
struct _GstQueue2Range
|
|
{
|
|
GstQueue2Range *next;
|
|
|
|
guint64 offset; /* offset of range start in source */
|
|
guint64 rb_offset; /* offset of range start in ring buffer */
|
|
guint64 writing_pos; /* writing position in source */
|
|
guint64 rb_writing_pos; /* writing position in ring buffer */
|
|
guint64 reading_pos; /* reading position in source */
|
|
guint64 max_reading_pos; /* latest requested offset in source */
|
|
};
|
|
|
|
struct _GstQueue2
|
|
{
|
|
GstElement element;
|
|
|
|
/*< private > */
|
|
GstPad *sinkpad;
|
|
GstPad *srcpad;
|
|
|
|
/* upstream size in bytes (if downstream is operating in pull mode) */
|
|
guint64 upstream_size;
|
|
|
|
/* segments to keep track of timestamps */
|
|
GstSegment sink_segment;
|
|
GstSegment src_segment;
|
|
|
|
/* Position of src/sink */
|
|
GstClockTime sinktime, srctime;
|
|
/* TRUE if either position needs to be recalculated */
|
|
gboolean sink_tainted, src_tainted;
|
|
|
|
/* flowreturn when srcpad is paused */
|
|
GstFlowReturn srcresult;
|
|
GstFlowReturn sinkresult;
|
|
gboolean is_eos;
|
|
gboolean unexpected;
|
|
|
|
/* the queue of data we're keeping our hands on */
|
|
GQueue queue;
|
|
|
|
GCond query_handled;
|
|
gboolean last_query; /* result of last serialized query */
|
|
|
|
GstQueue2Size cur_level; /* currently in the queue */
|
|
GstQueue2Size max_level; /* max. amount of data allowed in the queue */
|
|
gboolean use_buffering;
|
|
gboolean use_rate_estimate;
|
|
GstClockTime buffering_interval;
|
|
gint low_percent; /* low/high watermarks for buffering */
|
|
gint high_percent;
|
|
|
|
/* current buffering state */
|
|
gboolean is_buffering;
|
|
gint buffering_percent;
|
|
|
|
/* for measuring input/output rates */
|
|
GTimer *in_timer;
|
|
gboolean in_timer_started;
|
|
gdouble last_in_elapsed;
|
|
guint64 bytes_in;
|
|
gdouble byte_in_rate;
|
|
gdouble byte_in_period;
|
|
|
|
GTimer *out_timer;
|
|
gboolean out_timer_started;
|
|
gdouble last_out_elapsed;
|
|
guint64 bytes_out;
|
|
gdouble byte_out_rate;
|
|
|
|
GMutex qlock; /* lock for queue (vs object lock) */
|
|
gboolean waiting_add;
|
|
GCond item_add; /* signals buffers now available for reading */
|
|
gboolean waiting_del;
|
|
GCond item_del; /* signals space now available for writing */
|
|
|
|
/* temp location stuff */
|
|
gchar *temp_template;
|
|
gboolean temp_location_set;
|
|
gchar *temp_location;
|
|
gboolean temp_remove;
|
|
FILE *temp_file;
|
|
/* list of downloaded areas and the current area */
|
|
GstQueue2Range *ranges;
|
|
GstQueue2Range *current;
|
|
/* we need this to send the first new segment event of the stream
|
|
* because we can't save it on the file */
|
|
gboolean segment_event_received;
|
|
GstEvent *starting_segment;
|
|
gboolean seeking;
|
|
|
|
GstEvent *stream_start_event;
|
|
|
|
guint64 ring_buffer_max_size;
|
|
guint8 * ring_buffer;
|
|
|
|
volatile gint downstream_may_block;
|
|
};
|
|
|
|
struct _GstQueue2Class
|
|
{
|
|
GstElementClass parent_class;
|
|
};
|
|
|
|
G_GNUC_INTERNAL GType gst_queue2_get_type (void);
|
|
|
|
G_END_DECLS
|
|
|
|
#endif /* __GST_QUEUE2_H__ */
|