mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-07-04 21:55:55 +00:00
fa94322349
There's no expectation that any other element or applications might want to use this helper API any time soon, so keep it private for the time being. There were open questions regarding portability and binding-friendliness too. This also removes the gio dependency of -base again. https://bugzilla.gnome.org/show_bug.cgi?id=729951 https://bugzilla.gnome.org/show_bug.cgi?id=729949
129 lines
3.5 KiB
C
129 lines
3.5 KiB
C
/* GStreamer
|
|
* Copyright (C) 2014 Wim Taymans <wim.taymans@gmail.com>
|
|
*
|
|
* gstdownloadbuffer.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_DOWNLOAD_BUFFER_H__
|
|
#define __GST_DOWNLOAD_BUFFER_H__
|
|
|
|
#include <gst/gst.h>
|
|
#include <stdio.h>
|
|
|
|
#include "gstsparsefile.h"
|
|
|
|
G_BEGIN_DECLS
|
|
|
|
#define GST_TYPE_DOWNLOAD_BUFFER \
|
|
(gst_download_buffer_get_type())
|
|
#define GST_DOWNLOAD_BUFFER(obj) \
|
|
(G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_DOWNLOAD_BUFFER,GstDownloadBuffer))
|
|
#define GST_DOWNLOAD_BUFFER_CLASS(klass) \
|
|
(G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_DOWNLOAD_BUFFER,GstDownloadBufferClass))
|
|
#define GST_IS_DOWNLOAD_BUFFER(obj) \
|
|
(G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_DOWNLOAD_BUFFER))
|
|
#define GST_IS_DOWNLOAD_BUFFER_CLASS(klass) \
|
|
(G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_DOWNLOAD_BUFFER))
|
|
#define GST_DOWNLOAD_BUFFER_CAST(obj) \
|
|
((GstDownloadBuffer *)(obj))
|
|
|
|
typedef struct _GstDownloadBuffer GstDownloadBuffer;
|
|
typedef struct _GstDownloadBufferClass GstDownloadBufferClass;
|
|
typedef struct _GstDownloadBufferSize GstDownloadBufferSize;
|
|
|
|
/* used to keep track of sizes (current and max) */
|
|
struct _GstDownloadBufferSize
|
|
{
|
|
guint bytes;
|
|
guint64 time;
|
|
};
|
|
|
|
struct _GstDownloadBuffer
|
|
{
|
|
GstElement element;
|
|
|
|
/*< private > */
|
|
GstPad *sinkpad;
|
|
GstPad *srcpad;
|
|
|
|
/* upstream size in bytes (if downstream is operating in pull mode) */
|
|
guint64 upstream_size;
|
|
|
|
/* flowreturn when srcpad is paused */
|
|
GstFlowReturn srcresult;
|
|
GstFlowReturn sinkresult;
|
|
gboolean unexpected;
|
|
|
|
/* the queue of data we're keeping our hands on */
|
|
GstSparseFile *file;
|
|
guint64 write_pos;
|
|
guint64 read_pos;
|
|
gboolean filling;
|
|
|
|
GstDownloadBufferSize cur_level;
|
|
GstDownloadBufferSize max_level;
|
|
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 */
|
|
guint64 waiting_offset;
|
|
|
|
/* temp location stuff */
|
|
gchar *temp_template;
|
|
gboolean temp_location_set;
|
|
gchar *temp_location;
|
|
gboolean temp_remove;
|
|
gint temp_fd;
|
|
gboolean seeking;
|
|
|
|
GstEvent *stream_start_event;
|
|
GstEvent *segment_event;
|
|
|
|
volatile gint downstream_may_block;
|
|
};
|
|
|
|
struct _GstDownloadBufferClass
|
|
{
|
|
GstElementClass parent_class;
|
|
};
|
|
|
|
G_GNUC_INTERNAL GType gst_download_buffer_get_type (void);
|
|
|
|
G_END_DECLS
|
|
|
|
#endif /* __GST_DOWNLOAD_BUFFER_H__ */
|