Commit ab83d906 authored by Wim Taymans's avatar Wim Taymans
Browse files

tests/examples/seek/seek.c: Add basic download reports to seek using the new buffering API.

Original commit message from CVS:
* tests/examples/seek/seek.c: (update_fill), (set_update_fill),
(play_cb), (pause_cb), (stop_cb), (msg_state_changed),
(msg_buffering), (main):
Add basic download reports to seek using the new buffering API.
parent e5bdd950
2008-04-09 Wim Taymans <wim.taymans@collabora.co.uk>
* tests/examples/seek/seek.c: (update_fill), (set_update_fill),
(play_cb), (pause_cb), (stop_cb), (msg_state_changed),
(msg_buffering), (main):
Add basic download reports to seek using the new buffering API.
2008-04-09 Wim Taymans <wim.taymans@collabora.co.uk>
 
* gst/playback/gstqueue2.c: (update_buffering),
......@@ -46,6 +46,7 @@ GST_DEBUG_CATEGORY_STATIC (seek_debug);
//#define VSINK "aasink"
//#define VSINK "cacasink"
#define FILL_INTERVAL 100
//#define UPDATE_INTERVAL 500
//#define UPDATE_INTERVAL 100
#define UPDATE_INTERVAL 10
......@@ -87,6 +88,7 @@ static GstState state = GST_STATE_NULL;
static guint update_id = 0;
static guint seek_timeout_id = 0;
static gulong changed_id;
static guint fill_id = 0;
static gint n_video = 0, n_audio = 0, n_text = 0;
static gboolean need_streams = TRUE;
......@@ -1085,6 +1087,38 @@ set_scale (gdouble value)
gtk_widget_queue_draw (hscale);
}
static gboolean
update_fill (gpointer data)
{
if (elem_seek) {
if (seekable_elements) {
GstElement *element = GST_ELEMENT (seekable_elements->data);
GstQuery *query;
query = gst_query_new_buffering (GST_FORMAT_PERCENT);
if (gst_element_query (element, query)) {
gint64 start, stop;
GstFormat format;
gdouble fill;
gst_query_parse_buffering_range (query, &format, &start, &stop, NULL);
GST_DEBUG ("start %" G_GINT64_FORMAT ", stop %" G_GINT64_FORMAT,
start, stop);
if (stop != -1)
fill = 100.0 * stop / GST_FORMAT_PERCENT_MAX;
else
fill = 100.0;
gtk_range_set_fill_level (GTK_RANGE (hscale), fill);
}
gst_query_unref (query);
}
}
return TRUE;
}
static gboolean
update_scale (gpointer data)
{
......@@ -1130,6 +1164,7 @@ update_scale (gpointer data)
static void do_seek (GtkWidget * widget);
static void connect_bus_signals (GstElement * pipeline);
static void set_update_scale (gboolean active);
static void set_update_fill (gboolean active);
static gboolean
end_scrub (GtkWidget * widget)
......@@ -1247,6 +1282,24 @@ seek_cb (GtkWidget * widget)
}
}
static void
set_update_fill (gboolean active)
{
GST_DEBUG ("fill scale is %d", active);
if (active) {
if (fill_id == 0) {
fill_id =
g_timeout_add (FILL_INTERVAL, (GtkFunction) update_fill, pipeline);
}
} else {
if (fill_id) {
g_source_remove (fill_id);
fill_id = 0;
}
}
}
static void
set_update_scale (gboolean active)
{
......@@ -1401,6 +1454,7 @@ stop_cb (GtkButton * button, gpointer data)
buffering = FALSE;
set_update_scale (FALSE);
set_scale (0.0);
set_update_fill (FALSE);
if (pipeline_type == 16)
clear_streams (pipeline);
......@@ -1861,6 +1915,7 @@ msg_state_changed (GstBus * bus, GstMessage * message, GstPipeline * pipeline)
/* When state of the pipeline changes to paused or playing we start updating scale */
if (new == GST_STATE_PLAYING) {
set_update_scale (TRUE);
set_update_fill (TRUE);
} else {
set_update_scale (FALSE);
}
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment