libgstsmoothstreaming_la_LDFLAGS = ${GST_PLUGIN_LDFLAGS}
libgstsmoothstreaming_la_SOURCES = gstsmoothstreaming-plugin.c \
gstmssdemux.c \
- gstmssmanifest.c
+ gstmssmanifest.c \
+ gstdownloadrate.c
libgstsmoothstreaming_la_LIBTOOLFLAGS = --tag=disable-static
noinst_HEADERS = gstmssdemux.h \
- gstmssmanifest.h
+ gstmssmanifest.h \
+ gstdownloadrate.h
Android.mk: Makefile.am $(BUILT_SOURCES)
androgenizer \
--- /dev/null
+/* GStreamer
+ * Copyright (C) 2011 Andoni Morales Alastruey <ylatuya@gmail.com>
+ * Copyright (C) 2012 Smart TV Alliance
+ * Author: Louis-Francis Ratté-Boulianne <lfrb@collabora.com>, Collabora Ltd.
+ *
+ * gstfragment.c:
+ *
+ * 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.
+ */
+
+#include <glib.h>
+#include "gstdownloadrate.h"
+
+static void
+_gst_download_rate_check_remove_rates (GstDownloadRate * rate)
+{
+ if (rate->max_length == 0)
+ return;
+
+ while (g_queue_get_length (&rate->queue) > rate->max_length) {
+ guint bitrate = GPOINTER_TO_UINT (g_queue_pop_head (&rate->queue));
+
+ rate->total -= bitrate;
+ }
+}
+
+void
+gst_download_rate_init (GstDownloadRate * rate)
+{
+ g_queue_init (&rate->queue);
+ g_static_mutex_init (&rate->mutex);
+ rate->total = 0;
+ rate->max_length = 0;
+}
+
+void
+gst_download_rate_deinit (GstDownloadRate * rate)
+{
+ gst_download_rate_clear (rate);
+}
+
+void
+gst_download_rate_set_max_length (GstDownloadRate * rate, gint max_length)
+{
+ g_static_mutex_lock (&rate->mutex);
+ rate->max_length = max_length;
+ _gst_download_rate_check_remove_rates (rate);
+ g_static_mutex_unlock (&rate->mutex);
+}
+
+gint
+gst_download_rate_get_max_length (GstDownloadRate * rate)
+{
+ guint ret;
+ g_static_mutex_lock (&rate->mutex);
+ ret = rate->max_length;
+ g_static_mutex_unlock (&rate->mutex);
+
+ return ret;
+}
+
+void
+gst_download_rate_clear (GstDownloadRate * rate)
+{
+ g_static_mutex_lock (&rate->mutex);
+ g_queue_clear (&rate->queue);
+ rate->total = 0;
+ g_static_mutex_unlock (&rate->mutex);
+}
+
+void
+gst_download_rate_add_rate (GstDownloadRate * rate, guint bytes, guint64 time)
+{
+ guint64 bitrate;
+ g_static_mutex_lock (&rate->mutex);
+
+ /* convert from bytes / nanoseconds to bits per second */
+ bitrate = G_GUINT64_CONSTANT (8000000000) * bytes / time;
+
+ g_queue_push_tail (&rate->queue, GUINT_TO_POINTER ((guint) bitrate));
+ rate->total += bitrate;
+
+ _gst_download_rate_check_remove_rates (rate);
+ g_static_mutex_unlock (&rate->mutex);
+}
+
+guint
+gst_download_rate_get_current_rate (GstDownloadRate * rate)
+{
+ guint ret;
+ g_static_mutex_lock (&rate->mutex);
+ ret = rate->total / g_queue_get_length (&rate->queue);
+ g_static_mutex_unlock (&rate->mutex);
+
+ return ret;
+}
--- /dev/null
+/* GStreamer
+ * Copyright (C) 2012 Smart TV Alliance
+ * Author: Thiago Sousa Santos <thiago.sousa.santos@collabora.com>, Collabora Ltd.
+ *
+ * gstdownloadrate.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_DOWNLOAD_RATE_H__
+#define __GST_DOWNLOAD_RATE_H__
+
+#include <glib-object.h>
+#include <gst/gst.h>
+
+G_BEGIN_DECLS
+
+typedef struct _GstDownloadRate GstDownloadRate;
+
+struct _GstDownloadRate
+{
+ GQueue queue;
+ GStaticMutex mutex;
+
+ gint max_length;
+
+ guint64 total;
+};
+
+void gst_download_rate_init (GstDownloadRate * rate);
+void gst_download_rate_deinit (GstDownloadRate * rate);
+
+void gst_download_rate_set_max_length (GstDownloadRate * rate, gint max_length);
+gint gst_download_rate_get_max_length (GstDownloadRate * rate);
+
+void gst_download_rate_clear (GstDownloadRate * rate);
+void gst_download_rate_add_rate (GstDownloadRate * rate, guint bytes, guint64 time);
+
+guint gst_download_rate_get_current_rate (GstDownloadRate * rate);
+
+G_END_DECLS
+#endif /* __GST_DOWNLOAD_RATE_H__ */
#define DEFAULT_MAX_QUEUE_SIZE_BUFFERS 0
#define DEFAULT_BITRATE_LIMIT 0.8
+#define DOWNLOAD_RATE_MAX_HISTORY_LENGTH 5
+
enum
{
PROP_0,
stream->pad = srcpad;
stream->manifest_stream = manifeststream;
stream->parent = mssdemux;
+ gst_download_rate_init (&stream->download_rate);
+ gst_download_rate_set_max_length (&stream->download_rate,
+ DOWNLOAD_RATE_MAX_HISTORY_LENGTH);
return stream;
}
static void
gst_mss_demux_stream_free (GstMssDemuxStream * stream)
{
+ gst_download_rate_deinit (&stream->download_rate);
if (stream->download_task) {
if (GST_TASK_STATE (stream->download_task) != GST_TASK_STOPPED) {
GST_DEBUG_OBJECT (stream->parent, "Leaving streaming task %s:%s",
for (iter = mssdemux->streams; iter; iter = g_slist_next (iter)) {
GstMssDemuxStream *stream = iter->data;
- total += stream->download_bitrate;
+ total += gst_download_rate_get_current_rate (&stream->download_rate);
count++;
}
GST_DEBUG_OBJECT (mssdemux, "Measured download bitrate: %s %llu bps",
GST_PAD_NAME (stream->pad), bitrate);
- stream->download_bitrate = bitrate;
+ gst_download_rate_add_rate (&stream->download_rate,
+ GST_BUFFER_SIZE (_buffer), 1000 * (after_download - before_download));
GST_DEBUG_OBJECT (mssdemux,
"Storing buffer for stream %p - %s. Timestamp: %" GST_TIME_FORMAT
#include <gst/base/gstdataqueue.h>
#include "gstmssmanifest.h"
#include <gst/uridownloader/gsturidownloader.h>
+#include "gstdownloadrate.h"
G_BEGIN_DECLS
gboolean eos;
gboolean have_data;
- guint64 download_bitrate;
+ GstDownloadRate download_rate;
};
struct _GstMssDemux {