mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-07-03 05:05:52 +00:00
5755e24379
Set the seeking flag right before we send a seek event upstream and discard all data untill we see a flush-stop again. We need to do this because we activate the range that we seek to immediately after sending the seek event and it is possible that we receive data in our chain function from before the seek which would then be added to the wrong range resulting in data corruption.
162 lines
4.6 KiB
C
162 lines
4.6 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., 59 Temple Place - Suite 330,
|
|
* Boston, MA 02111-1307, 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;
|
|
|
|
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;
|
|
guint buffering_iteration;
|
|
|
|
/* 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;
|
|
|
|
guint64 ring_buffer_max_size;
|
|
guint8 * ring_buffer;
|
|
};
|
|
|
|
struct _GstQueue2Class
|
|
{
|
|
GstElementClass parent_class;
|
|
};
|
|
|
|
GType gst_queue2_get_type (void);
|
|
|
|
G_END_DECLS
|
|
|
|
#endif /* __GST_QUEUE2_H__ */
|