mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-25 03:01:03 +00:00
Code Issues 1 Projects Releases Wiki Activity
gstreamer/ext/smoothstreaming/gstmssdemux.h

131 lines
3.1 KiB
C
Raw Normal View History

smoothstreaming: stubs for mssdemux Just the stubs for mssdemux element. Also add some useful code from hlsdemux that we intend to reuse
2012-11-08 19:06:44 +00:00
/* GStreamer
* Copyright (C) 2012 Smart TV Alliance
* Author: Thiago Sousa Santos <thiago.sousa.santos@collabora.com>, Collabora Ltd.
*
* gstmssdemux.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_MSSDEMUX_H__
#define __GST_MSSDEMUX_H__
#include <gst/gst.h>
#include <gst/base/gstadapter.h>
mssdemux: rewriting pad tasks so that buffers are pushed by ts order Use pad tasks to download data and an extra task that gets the earlier buffer (with the smallest timestamp) and pushes on the corresponding pad. This prevents that the audio stream rushes ahead on buffers as its fragments should be smaller
2013-01-14 16:21:10 +00:00
#include <gst/base/gstdataqueue.h>
smoothstreaming: stubs for mssdemux Just the stubs for mssdemux element. Also add some useful code from hlsdemux that we intend to reuse
2012-11-08 19:06:44 +00:00
#include "gstmssmanifest.h"
mssdemux: use the shared uridownloader lib instead of an internal copy
2013-02-05 00:58:09 +00:00
#include <gst/uridownloader/gsturidownloader.h>
smoothstreaming: stubs for mssdemux Just the stubs for mssdemux element. Also add some useful code from hlsdemux that we intend to reuse
2012-11-08 19:06:44 +00:00
G_BEGIN_DECLS
GST_DEBUG_CATEGORY_EXTERN (mssdemux_debug);
#define GST_CAT_DEFAULT mssdemux_debug
#define GST_TYPE_MSS_DEMUX \
(gst_mss_demux_get_type())
#define GST_MSS_DEMUX(obj) \
(G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_MSS_DEMUX,GstMssDemux))
#define GST_MSS_DEMUX_CLASS(klass) \
(G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_MSS_DEMUX,GstMssDemuxClass))
#define GST_IS_MSS_DEMUX(obj) \
(G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_MSS_DEMUX))
#define GST_IS_MSS_DEMUX_CLASS(klass) \
(G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_MSS_DEMUX))
#define GST_MSS_DEMUX_CAST(obj) ((GstMssDemux *)(obj))
mssdemux: pad exposing initial implementation Does some basic parsing of the stream caps and adds a pad for each stream detected in the manifest
2012-11-14 20:19:35 +00:00
typedef struct _GstMssDemuxStream GstMssDemuxStream;
smoothstreaming: stubs for mssdemux Just the stubs for mssdemux element. Also add some useful code from hlsdemux that we intend to reuse
2012-11-08 19:06:44 +00:00
typedef struct _GstMssDemux GstMssDemux;
typedef struct _GstMssDemuxClass GstMssDemuxClass;
mssdemux: pad exposing initial implementation Does some basic parsing of the stream caps and adds a pad for each stream detected in the manifest
2012-11-14 20:19:35 +00:00
struct _GstMssDemuxStream {
GstPad *pad;
mssdemux: switch bitrates without switching pads
2013-02-08 03:51:30 +00:00
GstCaps *caps;
mssdemux: initial implementation of the pad loop The loop will fetch a new fragment and push on its srcpad. Each stream has its own loop
2012-11-16 20:30:12 +00:00
GstMssDemux *parent;
smoothstreaming: refactor structure names and implement url fetching Use shorter names for the MSS manifest helper structure and functions. Also continues the implementation of the stream fetching and pushing loop. Now it uses the base url correctly and already fetches and pushes the fragments downstream
2012-11-19 20:53:16 +00:00
GstMssStream *manifest_stream;
mssdemux: initial implementation of the pad loop The loop will fetch a new fragment and push on its srcpad. Each stream has its own loop
2012-11-16 20:30:12 +00:00
mssdemux: remove uridownloader in favor of internal source Refactor mssdemux to remove uridownloader to use an internal source element which reduces startup latency and provides smaller buffers for better buffering management downstream
2014-05-12 16:40:19 +00:00
#if 0
mssdemux: initial implementation of the pad loop The loop will fetch a new fragment and push on its srcpad. Each stream has its own loop
2012-11-16 20:30:12 +00:00
GstUriDownloader *downloader;
mssdemux: remove uridownloader in favor of internal source Refactor mssdemux to remove uridownloader to use an internal source element which reduces startup latency and provides smaller buffers for better buffering management downstream
2014-05-12 16:40:19 +00:00
#endif
mssdemux: initial implementation of the pad loop The loop will fetch a new fragment and push on its srcpad. Each stream has its own loop
2012-11-16 20:30:12 +00:00
mssdemux: remove uridownloader in favor of internal source Refactor mssdemux to remove uridownloader to use an internal source element which reduces startup latency and provides smaller buffers for better buffering management downstream
2014-05-12 16:40:19 +00:00
GstEvent *pending_segment;
mssdemux: initial implementation of seek event handling Adds basic handling for seek in time events. Needs to cooperate with the downstream qtdemux so that it forwards the seeks and the corresponding newsegments
2012-12-28 03:48:33 +00:00
mssdemux: track segments per stream As streams now flow independently, the GstSegment needs to be put on each stream so they can track the position of each one correctly instead of being mixed in a single segment
2013-12-17 16:16:58 +00:00
GstSegment segment;
mssdemux: implement live streams handling Live streams force the demuxer to keep reloading the Manifest from time to time, as the new fragments are being added as they are recorded. The demuxer should also try to keep up and detect when it had to skip fragments, marking the discont flag when that happens. Curiously, the spec doesn't seem to mention when/how a live stream is supposed to end, so keep trying downloads until the demuxer errors out.
2013-01-17 19:20:10 +00:00
mssdemux: rewriting pad tasks so that buffers are pushed by ts order Use pad tasks to download data and an extra task that gets the earlier buffer (with the smallest timestamp) and pushes on the corresponding pad. This prevents that the audio stream rushes ahead on buffers as its fragments should be smaller
2013-01-14 16:21:10 +00:00
/* Downloading task */
GstTask *download_task;
smoothstreaming: port to 1.0
2013-04-16 22:35:03 +00:00
GRecMutex download_lock;
mssdemux: implement bitrate switching When connection-speed changes, signal that we might need a bitrate switch. During the switch, a new pad group is added and the old one is drained and removed. New pads also need to push newsegments before starting to stream
2013-01-10 18:16:36 +00:00
mssdemux: avoid downloading not-linked streams When a stream gets a not-linked return, it will be marked as so and won't download any more new fragments until a reconfigure event is received. This will make mssdemux expose all pads, but only download fragments for the streams that are actually being used. Relying on the pads being linked/unlinked isn't enough in this scenario as there might be an input-selector downstream that is actually discarding buffers for a given linked pad. When streams are switching, the old active stream can be blocked because input-selector will block not-linked streams. In case the mssdemux's stream loop is blocked pushing a buffer to a full queue downstream it will never unblock as the queue will not drain (input-selector is blocking). In this scenario, stream switching will deadlock as input-selector is waiting for the newly active stream data and the stream_loop that would push this data is blocked waiting for input-selector. To solve this issue, whenever an stream is reactivated on a reconfigure it will enter into the 'catch up mode', in this mode it can push buffers from its download thread until it reaches the currrent GstSegment's position. This works because this timestamp will always be behind or equal to the maximum timestamp pushed for all streams, after pushing data for this timestamp, the stream will go back to default and be pushed sequentially from the main streaming thread. By this time, the input-selector should have already released the thread. https://bugzilla.gnome.org/show_bug.cgi?id=711849
2013-11-12 12:58:31 +00:00
GstFlowReturn last_ret;
mssdemux: rewriting pad tasks so that buffers are pushed by ts order Use pad tasks to download data and an extra task that gets the earlier buffer (with the smallest timestamp) and pushes on the corresponding pad. This prevents that the audio stream rushes ahead on buffers as its fragments should be smaller
2013-01-14 16:21:10 +00:00
gboolean eos;
mssdemux: add bitrate-limit property It allows the plugin to use its own downloading bitrate measures as a feedback to select the best streams bitrate for the current network scenario
2013-02-05 03:28:19 +00:00
gboolean have_data;
mssdemux: avoid streaming to fail when download is cancelled When download was failing repeatedly, it was causing streaming to fail even though it was cancelled on purpose (stopping tasks).
2013-02-19 18:17:53 +00:00
gboolean cancelled;
mssdemux: avoid downloading not-linked streams When a stream gets a not-linked return, it will be marked as so and won't download any more new fragments until a reconfigure event is received. This will make mssdemux expose all pads, but only download fragments for the streams that are actually being used. Relying on the pads being linked/unlinked isn't enough in this scenario as there might be an input-selector downstream that is actually discarding buffers for a given linked pad. When streams are switching, the old active stream can be blocked because input-selector will block not-linked streams. In case the mssdemux's stream loop is blocked pushing a buffer to a full queue downstream it will never unblock as the queue will not drain (input-selector is blocking). In this scenario, stream switching will deadlock as input-selector is waiting for the newly active stream data and the stream_loop that would push this data is blocked waiting for input-selector. To solve this issue, whenever an stream is reactivated on a reconfigure it will enter into the 'catch up mode', in this mode it can push buffers from its download thread until it reaches the currrent GstSegment's position. This works because this timestamp will always be behind or equal to the maximum timestamp pushed for all streams, after pushing data for this timestamp, the stream will go back to default and be pushed sequentially from the main streaming thread. By this time, the input-selector should have already released the thread. https://bugzilla.gnome.org/show_bug.cgi?id=711849
2013-11-12 12:58:31 +00:00
gboolean restart_download;
mssdemux: add bitrate-limit property It allows the plugin to use its own downloading bitrate measures as a feedback to select the best streams bitrate for the current network scenario
2013-02-05 03:28:19 +00:00
mssdemux: add a maximum error count for downloads mssdemux will tolerate a few download errors before emitting an error message to the bus
2013-02-07 06:10:46 +00:00
guint download_error_count;
mssdemux: remove uridownloader in favor of internal source Refactor mssdemux to remove uridownloader to use an internal source element which reduces startup latency and provides smaller buffers for better buffering management downstream
2014-05-12 16:40:19 +00:00
/* download tooling */
GstElement *src;
GstPad *src_srcpad;
GMutex fragment_download_lock;
GCond fragment_download_cond;
gboolean starting_fragment;
gint64 download_start_time;
gint64 download_total_time;
gint64 download_total_bytes;
gint current_download_rate;
mssdemux: pad exposing initial implementation Does some basic parsing of the stream caps and adds a pad for each stream detected in the manifest
2012-11-14 20:19:35 +00:00
};
smoothstreaming: stubs for mssdemux Just the stubs for mssdemux element. Also add some useful code from hlsdemux that we intend to reuse
2012-11-08 19:06:44 +00:00
struct _GstMssDemux {
mssdemux: remove uridownloader in favor of internal source Refactor mssdemux to remove uridownloader to use an internal source element which reduces startup latency and provides smaller buffers for better buffering management downstream
2014-05-12 16:40:19 +00:00
GstBin bin;
smoothstreaming: stubs for mssdemux Just the stubs for mssdemux element. Also add some useful code from hlsdemux that we intend to reuse
2012-11-08 19:06:44 +00:00
/* pads */
GstPad *sinkpad;
mssdemux: Add support for group-id in the stream-start event
2013-07-23 08:11:49 +00:00
gboolean have_group_id;
guint group_id;
smoothstreaming: stubs for mssdemux Just the stubs for mssdemux element. Also add some useful code from hlsdemux that we intend to reuse
2012-11-08 19:06:44 +00:00
GstBuffer *manifest_buffer;
GstMssManifest *manifest;
smoothstreaming: refactor structure names and implement url fetching Use shorter names for the MSS manifest helper structure and functions. Also continues the implementation of the stream fetching and pushing loop. Now it uses the base url correctly and already fetches and pushes the fragments downstream
2012-11-19 20:53:16 +00:00
gchar *base_url;
mssdemux: implement live streams handling Live streams force the demuxer to keep reloading the Manifest from time to time, as the new fragments are being added as they are recorded. The demuxer should also try to keep up and detect when it had to skip fragments, marking the discont flag when that happens. Curiously, the spec doesn't seem to mention when/how a live stream is supposed to end, so keep trying downloads until the demuxer errors out.
2013-01-17 19:20:10 +00:00
gchar *manifest_uri;
mssdemux: pad exposing initial implementation Does some basic parsing of the stream caps and adds a pad for each stream detected in the manifest
2012-11-14 20:19:35 +00:00
GSList *streams;
guint n_videos;
guint n_audios;
mssdemux: initial implementation of seek event handling Adds basic handling for seek in time events. Needs to cooperate with the downstream qtdemux so that it forwards the seeks and the corresponding newsegments
2012-12-28 03:48:33 +00:00
mssdemux: implement bitrate switching When connection-speed changes, signal that we might need a bitrate switch. During the switch, a new pad group is added and the old one is drained and removed. New pads also need to push newsegments before starting to stream
2013-01-10 18:16:36 +00:00
gboolean update_bitrates;
mssdemux: add connection-speed property This speed limits the maximum bitrate of streams. Currently it is only read when starting the pipeline, but it should be used for switching bitrates during playback to adapt to network changes.
2013-01-08 21:01:17 +00:00
/* properties */
guint64 connection_speed; /* in bps */
mssdemux: rewriting pad tasks so that buffers are pushed by ts order Use pad tasks to download data and an extra task that gets the earlier buffer (with the smallest timestamp) and pushes on the corresponding pad. This prevents that the audio stream rushes ahead on buffers as its fragments should be smaller
2013-01-14 16:21:10 +00:00
guint data_queue_max_size;
mssdemux: add bitrate-limit property It allows the plugin to use its own downloading bitrate measures as a feedback to select the best streams bitrate for the current network scenario
2013-02-05 03:28:19 +00:00
gfloat bitrate_limit;
smoothstreaming: stubs for mssdemux Just the stubs for mssdemux element. Also add some useful code from hlsdemux that we intend to reuse
2012-11-08 19:06:44 +00:00
};
struct _GstMssDemuxClass {
mssdemux: remove uridownloader in favor of internal source Refactor mssdemux to remove uridownloader to use an internal source element which reduces startup latency and provides smaller buffers for better buffering management downstream
2014-05-12 16:40:19 +00:00
GstBinClass parent_class;
smoothstreaming: stubs for mssdemux Just the stubs for mssdemux element. Also add some useful code from hlsdemux that we intend to reuse
2012-11-08 19:06:44 +00:00
};
GType gst_mss_demux_get_type (void);
G_END_DECLS
#endif /* __GST_MSSDEMUX_H__ */
Reference in a new issue Copy permalink