mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-11-27 12:11:13 +00:00
examples/seeking/: Added app for playback speed testing.
Original commit message from CVS: * examples/seeking/Makefile.am: * examples/seeking/scrubby.c: (gst_element_factory_make_or_warn), (dynamic_link), (setup_dynamic_link), (make_wav_pipeline), (make_playerbin_pipeline), (format_value), (update_scale), (speed_cb), (seek_cb), (do_seek), (start_seek), (stop_seek), (play_cb), (pause_cb), (stop_cb), (print_message), (bus_message), (print_usage), (main): Added app for playback speed testing. * examples/seeking/seek.c: (dynamic_link), (make_avi_msmpeg4v3_mp3_pipeline), (make_avi_pipeline), (make_mpeg_pipeline), (do_seek), (set_update_scale), (message_received), (main): Updated seek example.
This commit is contained in:
parent
5194aac11a
commit
09e894fec5
8 changed files with 1212 additions and 65 deletions
17
ChangeLog
17
ChangeLog
|
@ -1,3 +1,20 @@
|
||||||
|
2005-11-04 Wim Taymans <wim@fluendo.com>
|
||||||
|
|
||||||
|
* examples/seeking/Makefile.am:
|
||||||
|
* examples/seeking/scrubby.c: (gst_element_factory_make_or_warn),
|
||||||
|
(dynamic_link), (setup_dynamic_link), (make_wav_pipeline),
|
||||||
|
(make_playerbin_pipeline), (format_value), (update_scale),
|
||||||
|
(speed_cb), (seek_cb), (do_seek), (start_seek), (stop_seek),
|
||||||
|
(play_cb), (pause_cb), (stop_cb), (print_message), (bus_message),
|
||||||
|
(print_usage), (main):
|
||||||
|
Added app for playback speed testing.
|
||||||
|
|
||||||
|
* examples/seeking/seek.c: (dynamic_link),
|
||||||
|
(make_avi_msmpeg4v3_mp3_pipeline), (make_avi_pipeline),
|
||||||
|
(make_mpeg_pipeline), (do_seek), (set_update_scale),
|
||||||
|
(message_received), (main):
|
||||||
|
Updated seek example.
|
||||||
|
|
||||||
2005-11-04 Zeeshan Ali <zeenix@gmail.com>
|
2005-11-04 Zeeshan Ali <zeenix@gmail.com>
|
||||||
|
|
||||||
* gst-libs/gst/rtp/gstbasertpdepayload.c:
|
* gst-libs/gst/rtp/gstbasertpdepayload.c:
|
||||||
|
|
|
@ -1,4 +1,4 @@
|
||||||
examples = seek #scrubby cdplayer cdparanoia
|
examples = seek scrubby #cdplayer cdparanoia
|
||||||
|
|
||||||
noinst_PROGRAMS = $(examples)
|
noinst_PROGRAMS = $(examples)
|
||||||
|
|
||||||
|
|
558
examples/seeking/scrubby.c
Normal file
558
examples/seeking/scrubby.c
Normal file
|
@ -0,0 +1,558 @@
|
||||||
|
#include <stdlib.h>
|
||||||
|
#include <glib.h>
|
||||||
|
#include <gtk/gtk.h>
|
||||||
|
#include <gst/gst.h>
|
||||||
|
#include <string.h>
|
||||||
|
|
||||||
|
GST_DEBUG_CATEGORY (scrubby_debug);
|
||||||
|
#define GST_CAT_DEFAULT (scrubby_debug)
|
||||||
|
|
||||||
|
static GstElement *pipeline;
|
||||||
|
static gint64 position;
|
||||||
|
static gint64 duration;
|
||||||
|
static GtkAdjustment *adjustment;
|
||||||
|
static GtkWidget *hscale;
|
||||||
|
static GtkAdjustment *sadjustment;
|
||||||
|
static GtkWidget *shscale;
|
||||||
|
static gboolean verbose = FALSE;
|
||||||
|
|
||||||
|
static guint bus_watch = 0;
|
||||||
|
static guint update_id = 0;
|
||||||
|
static guint changed_id = 0;
|
||||||
|
static guint schanged_id = 0;
|
||||||
|
|
||||||
|
//#define SOURCE "filesrc"
|
||||||
|
#define SOURCE "gnomevfssrc"
|
||||||
|
#define ASINK "alsasink"
|
||||||
|
//#define ASINK "osssink"
|
||||||
|
#define VSINK "xvimagesink"
|
||||||
|
//#define VSINK "ximagesink"
|
||||||
|
//#define VSINK "aasink"
|
||||||
|
//#define VSINK "cacasink"
|
||||||
|
|
||||||
|
#define RANGE_PREC 10000
|
||||||
|
#define SEGMENT_LEN 100
|
||||||
|
#define UPDATE_INTERVAL 500
|
||||||
|
|
||||||
|
gdouble prev_range = -1.0;
|
||||||
|
GstClockTime prev_time = -1;
|
||||||
|
gdouble cur_range;
|
||||||
|
GstClockTime cur_time;
|
||||||
|
GstClockTimeDiff diff;
|
||||||
|
gdouble cur_speed = 1.0;
|
||||||
|
|
||||||
|
typedef struct
|
||||||
|
{
|
||||||
|
const gchar *padname;
|
||||||
|
GstPad *target;
|
||||||
|
GstElement *bin;
|
||||||
|
}
|
||||||
|
dyn_link;
|
||||||
|
|
||||||
|
static GstElement *
|
||||||
|
gst_element_factory_make_or_warn (gchar * type, gchar * name)
|
||||||
|
{
|
||||||
|
GstElement *element = gst_element_factory_make (type, name);
|
||||||
|
|
||||||
|
if (!element) {
|
||||||
|
g_warning ("Failed to create element %s of type %s", name, type);
|
||||||
|
}
|
||||||
|
|
||||||
|
return element;
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
dynamic_link (GstPadTemplate * templ, GstPad * newpad, gpointer data)
|
||||||
|
{
|
||||||
|
dyn_link *connect = (dyn_link *) data;
|
||||||
|
|
||||||
|
if (connect->padname == NULL ||
|
||||||
|
!strcmp (gst_pad_get_name (newpad), connect->padname)) {
|
||||||
|
if (connect->bin)
|
||||||
|
gst_bin_add (GST_BIN (pipeline), connect->bin);
|
||||||
|
gst_pad_link (newpad, connect->target);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
setup_dynamic_link (GstElement * element, const gchar * padname,
|
||||||
|
GstPad * target, GstElement * bin)
|
||||||
|
{
|
||||||
|
dyn_link *connect;
|
||||||
|
|
||||||
|
connect = g_new0 (dyn_link, 1);
|
||||||
|
connect->padname = g_strdup (padname);
|
||||||
|
connect->target = target;
|
||||||
|
connect->bin = bin;
|
||||||
|
|
||||||
|
g_signal_connect (G_OBJECT (element), "pad-added", G_CALLBACK (dynamic_link),
|
||||||
|
connect);
|
||||||
|
}
|
||||||
|
|
||||||
|
static GstElement *
|
||||||
|
make_wav_pipeline (const gchar * location)
|
||||||
|
{
|
||||||
|
GstElement *pipeline;
|
||||||
|
GstElement *src, *decoder, *audiosink;
|
||||||
|
|
||||||
|
pipeline = gst_pipeline_new ("app");
|
||||||
|
|
||||||
|
src = gst_element_factory_make_or_warn (SOURCE, "src");
|
||||||
|
decoder = gst_element_factory_make_or_warn ("wavparse", "decoder");
|
||||||
|
audiosink = gst_element_factory_make_or_warn (ASINK, "sink");
|
||||||
|
|
||||||
|
g_object_set (G_OBJECT (src), "location", location, NULL);
|
||||||
|
|
||||||
|
gst_bin_add (GST_BIN (pipeline), src);
|
||||||
|
gst_bin_add (GST_BIN (pipeline), decoder);
|
||||||
|
gst_bin_add (GST_BIN (pipeline), audiosink);
|
||||||
|
|
||||||
|
gst_element_link (src, decoder);
|
||||||
|
|
||||||
|
setup_dynamic_link (decoder, "src", gst_element_get_pad (audiosink, "sink"),
|
||||||
|
NULL);
|
||||||
|
|
||||||
|
return pipeline;
|
||||||
|
}
|
||||||
|
|
||||||
|
static GstElement *
|
||||||
|
make_playerbin_pipeline (const gchar * location)
|
||||||
|
{
|
||||||
|
GstElement *player;
|
||||||
|
|
||||||
|
player = gst_element_factory_make ("playbin", "player");
|
||||||
|
g_assert (player);
|
||||||
|
|
||||||
|
g_object_set (G_OBJECT (player), "uri", location, NULL);
|
||||||
|
|
||||||
|
return player;
|
||||||
|
}
|
||||||
|
|
||||||
|
static gchar *
|
||||||
|
format_value (GtkScale * scale, gdouble value)
|
||||||
|
{
|
||||||
|
gint64 real;
|
||||||
|
gint64 seconds;
|
||||||
|
gint64 subseconds;
|
||||||
|
|
||||||
|
real = value * duration / RANGE_PREC;
|
||||||
|
seconds = (gint64) real / GST_SECOND;
|
||||||
|
subseconds = (gint64) real / (GST_SECOND / RANGE_PREC);
|
||||||
|
|
||||||
|
return g_strdup_printf ("%02" G_GINT64_FORMAT ":%02" G_GINT64_FORMAT ":%02"
|
||||||
|
G_GINT64_FORMAT, seconds / 60, seconds % 60, subseconds % 100);
|
||||||
|
}
|
||||||
|
|
||||||
|
static gboolean
|
||||||
|
update_scale (gpointer data)
|
||||||
|
{
|
||||||
|
GstFormat format;
|
||||||
|
|
||||||
|
position = 0;
|
||||||
|
duration = 0;
|
||||||
|
|
||||||
|
format = GST_FORMAT_TIME;
|
||||||
|
|
||||||
|
gst_element_query_position (pipeline, &format, &position);
|
||||||
|
gst_element_query_duration (pipeline, &format, &duration);
|
||||||
|
|
||||||
|
if (position >= duration)
|
||||||
|
duration = position;
|
||||||
|
|
||||||
|
if (duration > 0) {
|
||||||
|
gtk_adjustment_set_value (adjustment,
|
||||||
|
position * (gdouble) RANGE_PREC / duration);
|
||||||
|
gtk_widget_queue_draw (hscale);
|
||||||
|
}
|
||||||
|
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
speed_cb (GtkWidget * widget)
|
||||||
|
{
|
||||||
|
GstEvent *s_event;
|
||||||
|
gboolean res;
|
||||||
|
|
||||||
|
GST_DEBUG ("speed change");
|
||||||
|
cur_speed = gtk_range_get_value (GTK_RANGE (widget));
|
||||||
|
|
||||||
|
s_event = gst_event_new_seek (cur_speed,
|
||||||
|
GST_FORMAT_TIME, 0, GST_SEEK_TYPE_NONE, -1, GST_SEEK_TYPE_NONE, -1);
|
||||||
|
|
||||||
|
res = gst_element_send_event (pipeline, s_event);
|
||||||
|
if (!res)
|
||||||
|
g_print ("speed change failed\n");
|
||||||
|
}
|
||||||
|
|
||||||
|
static gboolean do_seek (GtkWidget * widget, gboolean flush, gboolean segment);
|
||||||
|
|
||||||
|
static void
|
||||||
|
seek_cb (GtkWidget * widget)
|
||||||
|
{
|
||||||
|
if (changed_id) {
|
||||||
|
GST_DEBUG ("seek because of slider move");
|
||||||
|
|
||||||
|
if (do_seek (widget, TRUE, TRUE)) {
|
||||||
|
g_source_remove (changed_id);
|
||||||
|
changed_id = 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static gboolean
|
||||||
|
do_seek (GtkWidget * widget, gboolean flush, gboolean segment)
|
||||||
|
{
|
||||||
|
gint64 start, stop;
|
||||||
|
gboolean res = FALSE;
|
||||||
|
GstEvent *s_event;
|
||||||
|
gdouble rate;
|
||||||
|
GTimeVal tv;
|
||||||
|
gboolean valid;
|
||||||
|
gdouble new_range;
|
||||||
|
|
||||||
|
if (segment)
|
||||||
|
new_range = gtk_range_get_value (GTK_RANGE (widget));
|
||||||
|
else {
|
||||||
|
new_range = (gdouble) RANGE_PREC;
|
||||||
|
cur_time = -1;
|
||||||
|
}
|
||||||
|
|
||||||
|
valid = prev_time != -1;
|
||||||
|
|
||||||
|
GST_DEBUG ("flush %d, segment %d, valid %d", flush, segment, valid);
|
||||||
|
|
||||||
|
if (new_range == cur_range)
|
||||||
|
return FALSE;
|
||||||
|
|
||||||
|
prev_time = cur_time;
|
||||||
|
prev_range = cur_range;
|
||||||
|
|
||||||
|
cur_range = new_range;
|
||||||
|
|
||||||
|
g_get_current_time (&tv);
|
||||||
|
cur_time = GST_TIMEVAL_TO_TIME (tv);
|
||||||
|
|
||||||
|
if (!valid)
|
||||||
|
return FALSE;
|
||||||
|
|
||||||
|
GST_DEBUG ("cur: %lf, %" GST_TIME_FORMAT, cur_range,
|
||||||
|
GST_TIME_ARGS (cur_time));
|
||||||
|
GST_DEBUG ("prev: %lf, %" GST_TIME_FORMAT, prev_range,
|
||||||
|
GST_TIME_ARGS (prev_time));
|
||||||
|
|
||||||
|
diff = cur_time - prev_time;
|
||||||
|
|
||||||
|
GST_DEBUG ("diff: %" GST_TIME_FORMAT, GST_TIME_ARGS (diff));
|
||||||
|
|
||||||
|
start = prev_range * duration / RANGE_PREC;
|
||||||
|
/* play 50 milliseconds */
|
||||||
|
stop = segment ? cur_range * duration / RANGE_PREC : duration;
|
||||||
|
|
||||||
|
if (start == stop)
|
||||||
|
return FALSE;
|
||||||
|
|
||||||
|
if (segment)
|
||||||
|
rate = (stop - start) / (gdouble) diff;
|
||||||
|
else
|
||||||
|
rate = cur_speed;
|
||||||
|
|
||||||
|
if (start > stop) {
|
||||||
|
gint64 tmp;
|
||||||
|
|
||||||
|
tmp = start;
|
||||||
|
start = stop;
|
||||||
|
stop = tmp;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
GST_DEBUG ("seek to %" GST_TIME_FORMAT " -- %" GST_TIME_FORMAT ", rate %lf"
|
||||||
|
" on element %s",
|
||||||
|
GST_TIME_ARGS (start), GST_TIME_ARGS (stop), rate,
|
||||||
|
GST_ELEMENT_NAME (pipeline));
|
||||||
|
|
||||||
|
s_event = gst_event_new_seek (rate,
|
||||||
|
GST_FORMAT_TIME,
|
||||||
|
(flush ? GST_SEEK_FLAG_FLUSH : 0) |
|
||||||
|
(segment ? GST_SEEK_FLAG_SEGMENT : 0),
|
||||||
|
GST_SEEK_TYPE_SET, start, GST_SEEK_TYPE_SET, stop);
|
||||||
|
|
||||||
|
res = gst_element_send_event (pipeline, s_event);
|
||||||
|
if (!res)
|
||||||
|
g_print ("seek failed\n");
|
||||||
|
|
||||||
|
gst_element_get_state (pipeline, NULL, NULL, GST_CLOCK_TIME_NONE);
|
||||||
|
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
static gboolean
|
||||||
|
start_seek (GtkWidget * widget, GdkEventButton * event, gpointer user_data)
|
||||||
|
{
|
||||||
|
if (update_id) {
|
||||||
|
g_source_remove (update_id);
|
||||||
|
update_id = 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (changed_id == 0) {
|
||||||
|
changed_id = gtk_signal_connect (GTK_OBJECT (hscale),
|
||||||
|
"value_changed", G_CALLBACK (seek_cb), pipeline);
|
||||||
|
}
|
||||||
|
|
||||||
|
GST_DEBUG ("start seek");
|
||||||
|
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
|
||||||
|
static gboolean
|
||||||
|
stop_seek (GtkWidget * widget, gpointer user_data)
|
||||||
|
{
|
||||||
|
update_id =
|
||||||
|
g_timeout_add (UPDATE_INTERVAL, (GtkFunction) update_scale, pipeline);
|
||||||
|
|
||||||
|
GST_DEBUG ("stop seek");
|
||||||
|
|
||||||
|
if (changed_id) {
|
||||||
|
g_source_remove (changed_id);
|
||||||
|
changed_id = 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
do_seek (hscale, FALSE, FALSE);
|
||||||
|
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
play_cb (GtkButton * button, gpointer data)
|
||||||
|
{
|
||||||
|
GstState state;
|
||||||
|
|
||||||
|
gst_element_get_state (pipeline, &state, NULL, GST_CLOCK_TIME_NONE);
|
||||||
|
if (state != GST_STATE_PLAYING) {
|
||||||
|
g_print ("PLAY pipeline\n");
|
||||||
|
gst_element_set_state (pipeline, GST_STATE_PAUSED);
|
||||||
|
gst_element_get_state (pipeline, NULL, NULL, GST_CLOCK_TIME_NONE);
|
||||||
|
gst_element_set_state (pipeline, GST_STATE_PLAYING);
|
||||||
|
update_id =
|
||||||
|
g_timeout_add (UPDATE_INTERVAL, (GtkFunction) update_scale, pipeline);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
pause_cb (GtkButton * button, gpointer data)
|
||||||
|
{
|
||||||
|
GstState state;
|
||||||
|
|
||||||
|
gst_element_get_state (pipeline, &state, NULL, GST_CLOCK_TIME_NONE);
|
||||||
|
if (state != GST_STATE_PAUSED) {
|
||||||
|
g_print ("PAUSE pipeline\n");
|
||||||
|
gst_element_set_state (pipeline, GST_STATE_PAUSED);
|
||||||
|
g_source_remove (update_id);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
stop_cb (GtkButton * button, gpointer data)
|
||||||
|
{
|
||||||
|
GstState state;
|
||||||
|
|
||||||
|
gst_element_get_state (pipeline, &state, NULL, GST_CLOCK_TIME_NONE);
|
||||||
|
if (state != GST_STATE_READY) {
|
||||||
|
g_print ("READY pipeline\n");
|
||||||
|
gst_element_set_state (pipeline, GST_STATE_PAUSED);
|
||||||
|
gst_element_set_state (pipeline, GST_STATE_READY);
|
||||||
|
gtk_adjustment_set_value (adjustment, 0.0);
|
||||||
|
g_source_remove (update_id);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
print_message (GstMessage * message)
|
||||||
|
{
|
||||||
|
const GstStructure *s;
|
||||||
|
|
||||||
|
s = gst_message_get_structure (message);
|
||||||
|
g_print ("Got Message from element \"%s\"\n",
|
||||||
|
GST_STR_NULL (GST_ELEMENT_NAME (GST_MESSAGE_SRC (message))));
|
||||||
|
|
||||||
|
if (s) {
|
||||||
|
gchar *sstr;
|
||||||
|
|
||||||
|
sstr = gst_structure_to_string (s);
|
||||||
|
g_print ("%s\n", sstr);
|
||||||
|
g_free (sstr);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static gboolean
|
||||||
|
bus_message (GstBus * bus, GstMessage * message, gpointer data)
|
||||||
|
{
|
||||||
|
switch (GST_MESSAGE_TYPE (message)) {
|
||||||
|
case GST_MESSAGE_EOS:
|
||||||
|
g_print ("EOS\n");
|
||||||
|
break;
|
||||||
|
case GST_MESSAGE_ERROR:
|
||||||
|
case GST_MESSAGE_WARNING:
|
||||||
|
print_message (message);
|
||||||
|
break;
|
||||||
|
case GST_MESSAGE_SEGMENT_START:
|
||||||
|
break;
|
||||||
|
case GST_MESSAGE_SEGMENT_DONE:
|
||||||
|
GST_DEBUG ("segment_done, doing next seek");
|
||||||
|
if (!do_seek (hscale, FALSE, update_id == 0)) {
|
||||||
|
if (changed_id == 0) {
|
||||||
|
changed_id = gtk_signal_connect (GTK_OBJECT (hscale),
|
||||||
|
"value_changed", G_CALLBACK (seek_cb), pipeline);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
typedef struct
|
||||||
|
{
|
||||||
|
gchar *name;
|
||||||
|
GstElement *(*func) (const gchar * location);
|
||||||
|
}
|
||||||
|
Pipeline;
|
||||||
|
|
||||||
|
static Pipeline pipelines[] = {
|
||||||
|
{"wav", make_wav_pipeline},
|
||||||
|
{"playerbin", make_playerbin_pipeline},
|
||||||
|
{NULL, NULL},
|
||||||
|
};
|
||||||
|
|
||||||
|
#define NUM_TYPES ((sizeof (pipelines) / sizeof (Pipeline)) - 1)
|
||||||
|
|
||||||
|
static void
|
||||||
|
print_usage (int argc, char **argv)
|
||||||
|
{
|
||||||
|
gint i;
|
||||||
|
|
||||||
|
g_print ("usage: %s <type> <filename>\n", argv[0]);
|
||||||
|
g_print (" possible types:\n");
|
||||||
|
|
||||||
|
for (i = 0; i < NUM_TYPES; i++) {
|
||||||
|
g_print (" %d = %s\n", i, pipelines[i].name);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
int
|
||||||
|
main (int argc, char **argv)
|
||||||
|
{
|
||||||
|
GtkWidget *window, *hbox, *vbox, *play_button, *pause_button, *stop_button;
|
||||||
|
GstBus *bus;
|
||||||
|
GOptionEntry options[] = {
|
||||||
|
{"verbose", 'v', 0, G_OPTION_ARG_NONE, &verbose,
|
||||||
|
"Verbose properties", NULL},
|
||||||
|
{NULL}
|
||||||
|
};
|
||||||
|
gint type;
|
||||||
|
GOptionContext *ctx;
|
||||||
|
GError *err = NULL;
|
||||||
|
|
||||||
|
ctx = g_option_context_new ("seek");
|
||||||
|
g_option_context_add_main_entries (ctx, options, NULL);
|
||||||
|
g_option_context_add_group (ctx, gst_init_get_option_group ());
|
||||||
|
|
||||||
|
if (!g_option_context_parse (ctx, &argc, &argv, &err)) {
|
||||||
|
g_print ("Error initializing: %s\n", err->message);
|
||||||
|
exit (1);
|
||||||
|
}
|
||||||
|
|
||||||
|
GST_DEBUG_CATEGORY_INIT (scrubby_debug, "scrubby", 0, "scrubby example");
|
||||||
|
|
||||||
|
gtk_init (&argc, &argv);
|
||||||
|
|
||||||
|
if (argc != 3) {
|
||||||
|
print_usage (argc, argv);
|
||||||
|
exit (-1);
|
||||||
|
}
|
||||||
|
|
||||||
|
type = atoi (argv[1]);
|
||||||
|
|
||||||
|
if (type < 0 || type >= NUM_TYPES) {
|
||||||
|
print_usage (argc, argv);
|
||||||
|
exit (-1);
|
||||||
|
}
|
||||||
|
|
||||||
|
pipeline = pipelines[type].func (argv[2]);
|
||||||
|
g_assert (pipeline);
|
||||||
|
|
||||||
|
/* initialize gui elements ... */
|
||||||
|
window = gtk_window_new (GTK_WINDOW_TOPLEVEL);
|
||||||
|
hbox = gtk_hbox_new (FALSE, 0);
|
||||||
|
vbox = gtk_vbox_new (FALSE, 0);
|
||||||
|
play_button = gtk_button_new_with_label ("play");
|
||||||
|
pause_button = gtk_button_new_with_label ("pause");
|
||||||
|
stop_button = gtk_button_new_with_label ("stop");
|
||||||
|
|
||||||
|
adjustment =
|
||||||
|
GTK_ADJUSTMENT (gtk_adjustment_new (0.0, 0.0, (gdouble) RANGE_PREC, 0.1,
|
||||||
|
1.0, 1.0));
|
||||||
|
hscale = gtk_hscale_new (adjustment);
|
||||||
|
gtk_scale_set_digits (GTK_SCALE (hscale), 2);
|
||||||
|
gtk_range_set_update_policy (GTK_RANGE (hscale), GTK_UPDATE_CONTINUOUS);
|
||||||
|
|
||||||
|
sadjustment =
|
||||||
|
GTK_ADJUSTMENT (gtk_adjustment_new (1.0, 0.0, 5.0, 0.1, 1.0, 1.0));
|
||||||
|
shscale = gtk_hscale_new (sadjustment);
|
||||||
|
gtk_scale_set_digits (GTK_SCALE (shscale), 2);
|
||||||
|
gtk_range_set_update_policy (GTK_RANGE (shscale), GTK_UPDATE_CONTINUOUS);
|
||||||
|
|
||||||
|
schanged_id = gtk_signal_connect (GTK_OBJECT (shscale),
|
||||||
|
"value_changed", G_CALLBACK (speed_cb), pipeline);
|
||||||
|
|
||||||
|
gtk_signal_connect (GTK_OBJECT (hscale),
|
||||||
|
"button_press_event", G_CALLBACK (start_seek), pipeline);
|
||||||
|
gtk_signal_connect (GTK_OBJECT (hscale),
|
||||||
|
"button_release_event", G_CALLBACK (stop_seek), pipeline);
|
||||||
|
gtk_signal_connect (GTK_OBJECT (hscale),
|
||||||
|
"format_value", G_CALLBACK (format_value), pipeline);
|
||||||
|
|
||||||
|
/* do the packing stuff ... */
|
||||||
|
gtk_window_set_default_size (GTK_WINDOW (window), 96, 96);
|
||||||
|
gtk_container_add (GTK_CONTAINER (window), vbox);
|
||||||
|
gtk_container_add (GTK_CONTAINER (vbox), hbox);
|
||||||
|
gtk_box_pack_start (GTK_BOX (hbox), play_button, FALSE, FALSE, 2);
|
||||||
|
gtk_box_pack_start (GTK_BOX (hbox), pause_button, FALSE, FALSE, 2);
|
||||||
|
gtk_box_pack_start (GTK_BOX (hbox), stop_button, FALSE, FALSE, 2);
|
||||||
|
gtk_box_pack_start (GTK_BOX (vbox), hscale, TRUE, TRUE, 2);
|
||||||
|
gtk_box_pack_start (GTK_BOX (vbox), shscale, TRUE, TRUE, 2);
|
||||||
|
|
||||||
|
/* connect things ... */
|
||||||
|
g_signal_connect (G_OBJECT (play_button), "clicked", G_CALLBACK (play_cb),
|
||||||
|
pipeline);
|
||||||
|
g_signal_connect (G_OBJECT (pause_button), "clicked", G_CALLBACK (pause_cb),
|
||||||
|
pipeline);
|
||||||
|
g_signal_connect (G_OBJECT (stop_button), "clicked", G_CALLBACK (stop_cb),
|
||||||
|
pipeline);
|
||||||
|
g_signal_connect (G_OBJECT (window), "delete_event", gtk_main_quit, NULL);
|
||||||
|
|
||||||
|
/* show the gui. */
|
||||||
|
gtk_widget_show_all (window);
|
||||||
|
|
||||||
|
if (verbose) {
|
||||||
|
g_signal_connect (pipeline, "deep_notify",
|
||||||
|
G_CALLBACK (gst_object_default_deep_notify), NULL);
|
||||||
|
}
|
||||||
|
bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
|
||||||
|
g_assert (bus);
|
||||||
|
|
||||||
|
bus_watch = gst_bus_add_watch_full (bus,
|
||||||
|
G_PRIORITY_LOW, bus_message, pipeline, NULL);
|
||||||
|
|
||||||
|
gtk_main ();
|
||||||
|
|
||||||
|
g_print ("NULL pipeline\n");
|
||||||
|
gst_element_set_state (pipeline, GST_STATE_NULL);
|
||||||
|
|
||||||
|
g_print ("free pipeline\n");
|
||||||
|
gst_object_unref (pipeline);
|
||||||
|
|
||||||
|
return 0;
|
||||||
|
}
|
|
@ -30,11 +30,13 @@ static gulong changed_id;
|
||||||
#define ASINK "alsasink"
|
#define ASINK "alsasink"
|
||||||
//#define ASINK "osssink"
|
//#define ASINK "osssink"
|
||||||
#define VSINK "xvimagesink"
|
#define VSINK "xvimagesink"
|
||||||
|
//#define VSINK "sdlvideosink"
|
||||||
//#define VSINK "ximagesink"
|
//#define VSINK "ximagesink"
|
||||||
//#define VSINK "aasink"
|
//#define VSINK "aasink"
|
||||||
//#define VSINK "cacasink"
|
//#define VSINK "cacasink"
|
||||||
|
|
||||||
#define UPDATE_INTERVAL 500
|
//#define UPDATE_INTERVAL 500
|
||||||
|
#define UPDATE_INTERVAL 100
|
||||||
|
|
||||||
/* number of milliseconds to play for after a seek */
|
/* number of milliseconds to play for after a seek */
|
||||||
//#define SCRUB_TIME 250
|
//#define SCRUB_TIME 250
|
||||||
|
@ -66,10 +68,12 @@ gst_element_factory_make_or_warn (gchar * type, gchar * name)
|
||||||
static void
|
static void
|
||||||
dynamic_link (GstPadTemplate * templ, GstPad * newpad, gpointer data)
|
dynamic_link (GstPadTemplate * templ, GstPad * newpad, gpointer data)
|
||||||
{
|
{
|
||||||
|
gchar *padname;
|
||||||
dyn_link *connect = (dyn_link *) data;
|
dyn_link *connect = (dyn_link *) data;
|
||||||
|
|
||||||
if (connect->padname == NULL ||
|
padname = gst_pad_get_name (newpad);
|
||||||
!strcmp (gst_pad_get_name (newpad), connect->padname)) {
|
|
||||||
|
if (connect->padname == NULL || !strcmp (padname, connect->padname)) {
|
||||||
if (connect->bin)
|
if (connect->bin)
|
||||||
gst_bin_add (GST_BIN (pipeline), connect->bin);
|
gst_bin_add (GST_BIN (pipeline), connect->bin);
|
||||||
gst_pad_link (newpad, connect->target);
|
gst_pad_link (newpad, connect->target);
|
||||||
|
@ -77,6 +81,7 @@ dynamic_link (GstPadTemplate * templ, GstPad * newpad, gpointer data)
|
||||||
//seekable_pads = g_list_prepend (seekable_pads, newpad);
|
//seekable_pads = g_list_prepend (seekable_pads, newpad);
|
||||||
rate_pads = g_list_prepend (rate_pads, newpad);
|
rate_pads = g_list_prepend (rate_pads, newpad);
|
||||||
}
|
}
|
||||||
|
g_free (padname);
|
||||||
}
|
}
|
||||||
|
|
||||||
static void
|
static void
|
||||||
|
@ -598,7 +603,6 @@ make_avi_pipeline (const gchar * location)
|
||||||
audio_bin = gst_bin_new ("a_decoder_bin");
|
audio_bin = gst_bin_new ("a_decoder_bin");
|
||||||
a_decoder = gst_element_factory_make_or_warn ("mad", "a_dec");
|
a_decoder = gst_element_factory_make_or_warn ("mad", "a_dec");
|
||||||
audiosink = gst_element_factory_make_or_warn (ASINK, "a_sink");
|
audiosink = gst_element_factory_make_or_warn (ASINK, "a_sink");
|
||||||
//g_object_set (G_OBJECT (audiosink), "fragment", 0x00180008, NULL);
|
|
||||||
a_queue = gst_element_factory_make_or_warn ("queue", "a_queue");
|
a_queue = gst_element_factory_make_or_warn ("queue", "a_queue");
|
||||||
gst_element_link (a_decoder, a_queue);
|
gst_element_link (a_decoder, a_queue);
|
||||||
gst_element_link (a_queue, audiosink);
|
gst_element_link (a_queue, audiosink);
|
||||||
|
@ -617,14 +621,9 @@ make_avi_pipeline (const gchar * location)
|
||||||
g_list_prepend (rate_pads, gst_element_get_pad (a_decoder, "sink"));
|
g_list_prepend (rate_pads, gst_element_get_pad (a_decoder, "sink"));
|
||||||
|
|
||||||
video_bin = gst_bin_new ("v_decoder_bin");
|
video_bin = gst_bin_new ("v_decoder_bin");
|
||||||
//v_decoder = gst_element_factory_make_or_warn ("identity", "v_dec");
|
|
||||||
//v_decoder = gst_element_factory_make_or_warn ("windec", "v_dec");
|
|
||||||
v_decoder = gst_element_factory_make_or_warn ("ffmpegdecall", "v_dec");
|
v_decoder = gst_element_factory_make_or_warn ("ffmpegdecall", "v_dec");
|
||||||
videosink = gst_element_factory_make_or_warn ("ximagesink", "v_sink");
|
videosink = gst_element_factory_make_or_warn ("ximagesink", "v_sink");
|
||||||
//videosink = gst_element_factory_make_or_warn ("fakesink", "v_sink");
|
|
||||||
//g_object_set (G_OBJECT (videosink), "sync", TRUE, NULL);
|
|
||||||
v_queue = gst_element_factory_make_or_warn ("queue", "v_queue");
|
v_queue = gst_element_factory_make_or_warn ("queue", "v_queue");
|
||||||
//g_object_set (G_OBJECT (v_queue), "max_level", 10, NULL);
|
|
||||||
gst_element_link (v_decoder, v_queue);
|
gst_element_link (v_decoder, v_queue);
|
||||||
gst_element_link (v_queue, videosink);
|
gst_element_link (v_queue, videosink);
|
||||||
gst_bin_add (GST_BIN (video_bin), v_decoder);
|
gst_bin_add (GST_BIN (video_bin), v_decoder);
|
||||||
|
@ -653,16 +652,15 @@ make_mpeg_pipeline (const gchar * location)
|
||||||
GstElement *audiosink, *videosink;
|
GstElement *audiosink, *videosink;
|
||||||
GstElement *a_queue, *v_queue;
|
GstElement *a_queue, *v_queue;
|
||||||
GstPad *seekable;
|
GstPad *seekable;
|
||||||
|
GstPad *pad;
|
||||||
|
|
||||||
pipeline = gst_pipeline_new ("app");
|
pipeline = gst_pipeline_new ("app");
|
||||||
|
|
||||||
src = gst_element_factory_make_or_warn (SOURCE, "src");
|
src = gst_element_factory_make_or_warn (SOURCE, "src");
|
||||||
g_object_set (G_OBJECT (src), "location", location, NULL);
|
g_object_set (G_OBJECT (src), "location", location, NULL);
|
||||||
|
|
||||||
demux = gst_element_factory_make_or_warn ("mpegdemux", "demux");
|
//demux = gst_element_factory_make_or_warn ("mpegdemux", "demux");
|
||||||
g_object_set (G_OBJECT (demux), "sync", FALSE, NULL);
|
demux = gst_element_factory_make_or_warn ("flupsdemux", "demux");
|
||||||
|
|
||||||
seekable_elements = g_list_prepend (seekable_elements, demux);
|
|
||||||
|
|
||||||
gst_bin_add (GST_BIN (pipeline), src);
|
gst_bin_add (GST_BIN (pipeline), src);
|
||||||
gst_bin_add (GST_BIN (pipeline), demux);
|
gst_bin_add (GST_BIN (pipeline), demux);
|
||||||
|
@ -672,38 +670,47 @@ make_mpeg_pipeline (const gchar * location)
|
||||||
a_decoder = gst_element_factory_make_or_warn ("mad", "a_dec");
|
a_decoder = gst_element_factory_make_or_warn ("mad", "a_dec");
|
||||||
a_queue = gst_element_factory_make_or_warn ("queue", "a_queue");
|
a_queue = gst_element_factory_make_or_warn ("queue", "a_queue");
|
||||||
audiosink = gst_element_factory_make_or_warn (ASINK, "a_sink");
|
audiosink = gst_element_factory_make_or_warn (ASINK, "a_sink");
|
||||||
//g_object_set (G_OBJECT (audiosink), "fragment", 0x00180008, NULL);
|
|
||||||
gst_element_link (a_decoder, a_queue);
|
|
||||||
gst_element_link (a_queue, audiosink);
|
|
||||||
gst_bin_add (GST_BIN (audio_bin), a_decoder);
|
gst_bin_add (GST_BIN (audio_bin), a_decoder);
|
||||||
gst_bin_add (GST_BIN (audio_bin), a_queue);
|
gst_bin_add (GST_BIN (audio_bin), a_queue);
|
||||||
gst_bin_add (GST_BIN (audio_bin), audiosink);
|
gst_bin_add (GST_BIN (audio_bin), audiosink);
|
||||||
|
|
||||||
setup_dynamic_link (demux, "audio_00", gst_element_get_pad (a_decoder,
|
gst_element_link (a_decoder, a_queue);
|
||||||
"sink"), audio_bin);
|
gst_element_link (a_queue, audiosink);
|
||||||
|
|
||||||
seekable = gst_element_get_pad (a_queue, "src");
|
gst_bin_add (GST_BIN (pipeline), audio_bin);
|
||||||
seekable_pads = g_list_prepend (seekable_pads, seekable);
|
|
||||||
rate_pads = g_list_prepend (rate_pads, seekable);
|
pad = gst_element_get_pad (a_decoder, "sink");
|
||||||
rate_pads =
|
gst_element_add_pad (audio_bin, gst_ghost_pad_new ("sink", pad));
|
||||||
g_list_prepend (rate_pads, gst_element_get_pad (a_decoder, "sink"));
|
gst_object_unref (pad);
|
||||||
|
|
||||||
|
setup_dynamic_link (demux, "audio_c0", gst_element_get_pad (audio_bin,
|
||||||
|
"sink"), NULL);
|
||||||
|
|
||||||
video_bin = gst_bin_new ("v_decoder_bin");
|
video_bin = gst_bin_new ("v_decoder_bin");
|
||||||
v_decoder = gst_element_factory_make_or_warn ("mpeg2dec", "v_dec");
|
v_decoder = gst_element_factory_make_or_warn ("mpeg2dec", "v_dec");
|
||||||
//g_object_set (G_OBJECT (video_thread), "priority", 2, NULL);
|
|
||||||
v_queue = gst_element_factory_make_or_warn ("queue", "v_queue");
|
v_queue = gst_element_factory_make_or_warn ("queue", "v_queue");
|
||||||
v_filter = gst_element_factory_make_or_warn ("ffmpegcolorspace", "v_filter");
|
v_filter = gst_element_factory_make_or_warn ("ffmpegcolorspace", "v_filter");
|
||||||
videosink = gst_element_factory_make_or_warn ("ximagesink", "v_sink");
|
videosink = gst_element_factory_make_or_warn (VSINK, "v_sink");
|
||||||
gst_element_link_many (v_decoder, v_queue, v_filter, NULL);
|
|
||||||
|
|
||||||
|
gst_bin_add (GST_BIN (video_bin), v_decoder);
|
||||||
|
gst_bin_add (GST_BIN (video_bin), v_queue);
|
||||||
|
gst_bin_add (GST_BIN (video_bin), v_filter);
|
||||||
|
gst_bin_add (GST_BIN (video_bin), videosink);
|
||||||
|
|
||||||
|
gst_element_link (v_decoder, v_queue);
|
||||||
|
gst_element_link (v_queue, v_filter);
|
||||||
gst_element_link (v_filter, videosink);
|
gst_element_link (v_filter, videosink);
|
||||||
gst_bin_add_many (GST_BIN (video_bin), v_decoder, NULL);
|
|
||||||
gst_bin_add_many (GST_BIN (video_bin), v_queue, v_filter, videosink, NULL);
|
|
||||||
|
|
||||||
setup_dynamic_link (demux, "video_00", gst_element_get_pad (v_decoder,
|
gst_bin_add (GST_BIN (pipeline), video_bin);
|
||||||
"sink"), video_bin);
|
|
||||||
|
|
||||||
seekable = gst_element_get_pad (v_queue, "src");
|
pad = gst_element_get_pad (v_decoder, "sink");
|
||||||
|
gst_element_add_pad (video_bin, gst_ghost_pad_new ("sink", pad));
|
||||||
|
gst_object_unref (pad);
|
||||||
|
|
||||||
|
setup_dynamic_link (demux, "video_e0", gst_element_get_pad (video_bin,
|
||||||
|
"sink"), NULL);
|
||||||
|
|
||||||
|
seekable = gst_element_get_pad (v_filter, "src");
|
||||||
seekable_pads = g_list_prepend (seekable_pads, seekable);
|
seekable_pads = g_list_prepend (seekable_pads, seekable);
|
||||||
rate_pads = g_list_prepend (rate_pads, seekable);
|
rate_pads = g_list_prepend (rate_pads, seekable);
|
||||||
rate_pads =
|
rate_pads =
|
||||||
|
|
|
@ -1,4 +1,4 @@
|
||||||
examples = seek #scrubby cdplayer cdparanoia
|
examples = seek scrubby #cdplayer cdparanoia
|
||||||
|
|
||||||
noinst_PROGRAMS = $(examples)
|
noinst_PROGRAMS = $(examples)
|
||||||
|
|
||||||
|
|
558
tests/examples/seek/scrubby.c
Normal file
558
tests/examples/seek/scrubby.c
Normal file
|
@ -0,0 +1,558 @@
|
||||||
|
#include <stdlib.h>
|
||||||
|
#include <glib.h>
|
||||||
|
#include <gtk/gtk.h>
|
||||||
|
#include <gst/gst.h>
|
||||||
|
#include <string.h>
|
||||||
|
|
||||||
|
GST_DEBUG_CATEGORY (scrubby_debug);
|
||||||
|
#define GST_CAT_DEFAULT (scrubby_debug)
|
||||||
|
|
||||||
|
static GstElement *pipeline;
|
||||||
|
static gint64 position;
|
||||||
|
static gint64 duration;
|
||||||
|
static GtkAdjustment *adjustment;
|
||||||
|
static GtkWidget *hscale;
|
||||||
|
static GtkAdjustment *sadjustment;
|
||||||
|
static GtkWidget *shscale;
|
||||||
|
static gboolean verbose = FALSE;
|
||||||
|
|
||||||
|
static guint bus_watch = 0;
|
||||||
|
static guint update_id = 0;
|
||||||
|
static guint changed_id = 0;
|
||||||
|
static guint schanged_id = 0;
|
||||||
|
|
||||||
|
//#define SOURCE "filesrc"
|
||||||
|
#define SOURCE "gnomevfssrc"
|
||||||
|
#define ASINK "alsasink"
|
||||||
|
//#define ASINK "osssink"
|
||||||
|
#define VSINK "xvimagesink"
|
||||||
|
//#define VSINK "ximagesink"
|
||||||
|
//#define VSINK "aasink"
|
||||||
|
//#define VSINK "cacasink"
|
||||||
|
|
||||||
|
#define RANGE_PREC 10000
|
||||||
|
#define SEGMENT_LEN 100
|
||||||
|
#define UPDATE_INTERVAL 500
|
||||||
|
|
||||||
|
gdouble prev_range = -1.0;
|
||||||
|
GstClockTime prev_time = -1;
|
||||||
|
gdouble cur_range;
|
||||||
|
GstClockTime cur_time;
|
||||||
|
GstClockTimeDiff diff;
|
||||||
|
gdouble cur_speed = 1.0;
|
||||||
|
|
||||||
|
typedef struct
|
||||||
|
{
|
||||||
|
const gchar *padname;
|
||||||
|
GstPad *target;
|
||||||
|
GstElement *bin;
|
||||||
|
}
|
||||||
|
dyn_link;
|
||||||
|
|
||||||
|
static GstElement *
|
||||||
|
gst_element_factory_make_or_warn (gchar * type, gchar * name)
|
||||||
|
{
|
||||||
|
GstElement *element = gst_element_factory_make (type, name);
|
||||||
|
|
||||||
|
if (!element) {
|
||||||
|
g_warning ("Failed to create element %s of type %s", name, type);
|
||||||
|
}
|
||||||
|
|
||||||
|
return element;
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
dynamic_link (GstPadTemplate * templ, GstPad * newpad, gpointer data)
|
||||||
|
{
|
||||||
|
dyn_link *connect = (dyn_link *) data;
|
||||||
|
|
||||||
|
if (connect->padname == NULL ||
|
||||||
|
!strcmp (gst_pad_get_name (newpad), connect->padname)) {
|
||||||
|
if (connect->bin)
|
||||||
|
gst_bin_add (GST_BIN (pipeline), connect->bin);
|
||||||
|
gst_pad_link (newpad, connect->target);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
setup_dynamic_link (GstElement * element, const gchar * padname,
|
||||||
|
GstPad * target, GstElement * bin)
|
||||||
|
{
|
||||||
|
dyn_link *connect;
|
||||||
|
|
||||||
|
connect = g_new0 (dyn_link, 1);
|
||||||
|
connect->padname = g_strdup (padname);
|
||||||
|
connect->target = target;
|
||||||
|
connect->bin = bin;
|
||||||
|
|
||||||
|
g_signal_connect (G_OBJECT (element), "pad-added", G_CALLBACK (dynamic_link),
|
||||||
|
connect);
|
||||||
|
}
|
||||||
|
|
||||||
|
static GstElement *
|
||||||
|
make_wav_pipeline (const gchar * location)
|
||||||
|
{
|
||||||
|
GstElement *pipeline;
|
||||||
|
GstElement *src, *decoder, *audiosink;
|
||||||
|
|
||||||
|
pipeline = gst_pipeline_new ("app");
|
||||||
|
|
||||||
|
src = gst_element_factory_make_or_warn (SOURCE, "src");
|
||||||
|
decoder = gst_element_factory_make_or_warn ("wavparse", "decoder");
|
||||||
|
audiosink = gst_element_factory_make_or_warn (ASINK, "sink");
|
||||||
|
|
||||||
|
g_object_set (G_OBJECT (src), "location", location, NULL);
|
||||||
|
|
||||||
|
gst_bin_add (GST_BIN (pipeline), src);
|
||||||
|
gst_bin_add (GST_BIN (pipeline), decoder);
|
||||||
|
gst_bin_add (GST_BIN (pipeline), audiosink);
|
||||||
|
|
||||||
|
gst_element_link (src, decoder);
|
||||||
|
|
||||||
|
setup_dynamic_link (decoder, "src", gst_element_get_pad (audiosink, "sink"),
|
||||||
|
NULL);
|
||||||
|
|
||||||
|
return pipeline;
|
||||||
|
}
|
||||||
|
|
||||||
|
static GstElement *
|
||||||
|
make_playerbin_pipeline (const gchar * location)
|
||||||
|
{
|
||||||
|
GstElement *player;
|
||||||
|
|
||||||
|
player = gst_element_factory_make ("playbin", "player");
|
||||||
|
g_assert (player);
|
||||||
|
|
||||||
|
g_object_set (G_OBJECT (player), "uri", location, NULL);
|
||||||
|
|
||||||
|
return player;
|
||||||
|
}
|
||||||
|
|
||||||
|
static gchar *
|
||||||
|
format_value (GtkScale * scale, gdouble value)
|
||||||
|
{
|
||||||
|
gint64 real;
|
||||||
|
gint64 seconds;
|
||||||
|
gint64 subseconds;
|
||||||
|
|
||||||
|
real = value * duration / RANGE_PREC;
|
||||||
|
seconds = (gint64) real / GST_SECOND;
|
||||||
|
subseconds = (gint64) real / (GST_SECOND / RANGE_PREC);
|
||||||
|
|
||||||
|
return g_strdup_printf ("%02" G_GINT64_FORMAT ":%02" G_GINT64_FORMAT ":%02"
|
||||||
|
G_GINT64_FORMAT, seconds / 60, seconds % 60, subseconds % 100);
|
||||||
|
}
|
||||||
|
|
||||||
|
static gboolean
|
||||||
|
update_scale (gpointer data)
|
||||||
|
{
|
||||||
|
GstFormat format;
|
||||||
|
|
||||||
|
position = 0;
|
||||||
|
duration = 0;
|
||||||
|
|
||||||
|
format = GST_FORMAT_TIME;
|
||||||
|
|
||||||
|
gst_element_query_position (pipeline, &format, &position);
|
||||||
|
gst_element_query_duration (pipeline, &format, &duration);
|
||||||
|
|
||||||
|
if (position >= duration)
|
||||||
|
duration = position;
|
||||||
|
|
||||||
|
if (duration > 0) {
|
||||||
|
gtk_adjustment_set_value (adjustment,
|
||||||
|
position * (gdouble) RANGE_PREC / duration);
|
||||||
|
gtk_widget_queue_draw (hscale);
|
||||||
|
}
|
||||||
|
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
speed_cb (GtkWidget * widget)
|
||||||
|
{
|
||||||
|
GstEvent *s_event;
|
||||||
|
gboolean res;
|
||||||
|
|
||||||
|
GST_DEBUG ("speed change");
|
||||||
|
cur_speed = gtk_range_get_value (GTK_RANGE (widget));
|
||||||
|
|
||||||
|
s_event = gst_event_new_seek (cur_speed,
|
||||||
|
GST_FORMAT_TIME, 0, GST_SEEK_TYPE_NONE, -1, GST_SEEK_TYPE_NONE, -1);
|
||||||
|
|
||||||
|
res = gst_element_send_event (pipeline, s_event);
|
||||||
|
if (!res)
|
||||||
|
g_print ("speed change failed\n");
|
||||||
|
}
|
||||||
|
|
||||||
|
static gboolean do_seek (GtkWidget * widget, gboolean flush, gboolean segment);
|
||||||
|
|
||||||
|
static void
|
||||||
|
seek_cb (GtkWidget * widget)
|
||||||
|
{
|
||||||
|
if (changed_id) {
|
||||||
|
GST_DEBUG ("seek because of slider move");
|
||||||
|
|
||||||
|
if (do_seek (widget, TRUE, TRUE)) {
|
||||||
|
g_source_remove (changed_id);
|
||||||
|
changed_id = 0;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static gboolean
|
||||||
|
do_seek (GtkWidget * widget, gboolean flush, gboolean segment)
|
||||||
|
{
|
||||||
|
gint64 start, stop;
|
||||||
|
gboolean res = FALSE;
|
||||||
|
GstEvent *s_event;
|
||||||
|
gdouble rate;
|
||||||
|
GTimeVal tv;
|
||||||
|
gboolean valid;
|
||||||
|
gdouble new_range;
|
||||||
|
|
||||||
|
if (segment)
|
||||||
|
new_range = gtk_range_get_value (GTK_RANGE (widget));
|
||||||
|
else {
|
||||||
|
new_range = (gdouble) RANGE_PREC;
|
||||||
|
cur_time = -1;
|
||||||
|
}
|
||||||
|
|
||||||
|
valid = prev_time != -1;
|
||||||
|
|
||||||
|
GST_DEBUG ("flush %d, segment %d, valid %d", flush, segment, valid);
|
||||||
|
|
||||||
|
if (new_range == cur_range)
|
||||||
|
return FALSE;
|
||||||
|
|
||||||
|
prev_time = cur_time;
|
||||||
|
prev_range = cur_range;
|
||||||
|
|
||||||
|
cur_range = new_range;
|
||||||
|
|
||||||
|
g_get_current_time (&tv);
|
||||||
|
cur_time = GST_TIMEVAL_TO_TIME (tv);
|
||||||
|
|
||||||
|
if (!valid)
|
||||||
|
return FALSE;
|
||||||
|
|
||||||
|
GST_DEBUG ("cur: %lf, %" GST_TIME_FORMAT, cur_range,
|
||||||
|
GST_TIME_ARGS (cur_time));
|
||||||
|
GST_DEBUG ("prev: %lf, %" GST_TIME_FORMAT, prev_range,
|
||||||
|
GST_TIME_ARGS (prev_time));
|
||||||
|
|
||||||
|
diff = cur_time - prev_time;
|
||||||
|
|
||||||
|
GST_DEBUG ("diff: %" GST_TIME_FORMAT, GST_TIME_ARGS (diff));
|
||||||
|
|
||||||
|
start = prev_range * duration / RANGE_PREC;
|
||||||
|
/* play 50 milliseconds */
|
||||||
|
stop = segment ? cur_range * duration / RANGE_PREC : duration;
|
||||||
|
|
||||||
|
if (start == stop)
|
||||||
|
return FALSE;
|
||||||
|
|
||||||
|
if (segment)
|
||||||
|
rate = (stop - start) / (gdouble) diff;
|
||||||
|
else
|
||||||
|
rate = cur_speed;
|
||||||
|
|
||||||
|
if (start > stop) {
|
||||||
|
gint64 tmp;
|
||||||
|
|
||||||
|
tmp = start;
|
||||||
|
start = stop;
|
||||||
|
stop = tmp;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
GST_DEBUG ("seek to %" GST_TIME_FORMAT " -- %" GST_TIME_FORMAT ", rate %lf"
|
||||||
|
" on element %s",
|
||||||
|
GST_TIME_ARGS (start), GST_TIME_ARGS (stop), rate,
|
||||||
|
GST_ELEMENT_NAME (pipeline));
|
||||||
|
|
||||||
|
s_event = gst_event_new_seek (rate,
|
||||||
|
GST_FORMAT_TIME,
|
||||||
|
(flush ? GST_SEEK_FLAG_FLUSH : 0) |
|
||||||
|
(segment ? GST_SEEK_FLAG_SEGMENT : 0),
|
||||||
|
GST_SEEK_TYPE_SET, start, GST_SEEK_TYPE_SET, stop);
|
||||||
|
|
||||||
|
res = gst_element_send_event (pipeline, s_event);
|
||||||
|
if (!res)
|
||||||
|
g_print ("seek failed\n");
|
||||||
|
|
||||||
|
gst_element_get_state (pipeline, NULL, NULL, GST_CLOCK_TIME_NONE);
|
||||||
|
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
static gboolean
|
||||||
|
start_seek (GtkWidget * widget, GdkEventButton * event, gpointer user_data)
|
||||||
|
{
|
||||||
|
if (update_id) {
|
||||||
|
g_source_remove (update_id);
|
||||||
|
update_id = 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (changed_id == 0) {
|
||||||
|
changed_id = gtk_signal_connect (GTK_OBJECT (hscale),
|
||||||
|
"value_changed", G_CALLBACK (seek_cb), pipeline);
|
||||||
|
}
|
||||||
|
|
||||||
|
GST_DEBUG ("start seek");
|
||||||
|
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
|
||||||
|
static gboolean
|
||||||
|
stop_seek (GtkWidget * widget, gpointer user_data)
|
||||||
|
{
|
||||||
|
update_id =
|
||||||
|
g_timeout_add (UPDATE_INTERVAL, (GtkFunction) update_scale, pipeline);
|
||||||
|
|
||||||
|
GST_DEBUG ("stop seek");
|
||||||
|
|
||||||
|
if (changed_id) {
|
||||||
|
g_source_remove (changed_id);
|
||||||
|
changed_id = 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
do_seek (hscale, FALSE, FALSE);
|
||||||
|
|
||||||
|
return FALSE;
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
play_cb (GtkButton * button, gpointer data)
|
||||||
|
{
|
||||||
|
GstState state;
|
||||||
|
|
||||||
|
gst_element_get_state (pipeline, &state, NULL, GST_CLOCK_TIME_NONE);
|
||||||
|
if (state != GST_STATE_PLAYING) {
|
||||||
|
g_print ("PLAY pipeline\n");
|
||||||
|
gst_element_set_state (pipeline, GST_STATE_PAUSED);
|
||||||
|
gst_element_get_state (pipeline, NULL, NULL, GST_CLOCK_TIME_NONE);
|
||||||
|
gst_element_set_state (pipeline, GST_STATE_PLAYING);
|
||||||
|
update_id =
|
||||||
|
g_timeout_add (UPDATE_INTERVAL, (GtkFunction) update_scale, pipeline);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
pause_cb (GtkButton * button, gpointer data)
|
||||||
|
{
|
||||||
|
GstState state;
|
||||||
|
|
||||||
|
gst_element_get_state (pipeline, &state, NULL, GST_CLOCK_TIME_NONE);
|
||||||
|
if (state != GST_STATE_PAUSED) {
|
||||||
|
g_print ("PAUSE pipeline\n");
|
||||||
|
gst_element_set_state (pipeline, GST_STATE_PAUSED);
|
||||||
|
g_source_remove (update_id);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
stop_cb (GtkButton * button, gpointer data)
|
||||||
|
{
|
||||||
|
GstState state;
|
||||||
|
|
||||||
|
gst_element_get_state (pipeline, &state, NULL, GST_CLOCK_TIME_NONE);
|
||||||
|
if (state != GST_STATE_READY) {
|
||||||
|
g_print ("READY pipeline\n");
|
||||||
|
gst_element_set_state (pipeline, GST_STATE_PAUSED);
|
||||||
|
gst_element_set_state (pipeline, GST_STATE_READY);
|
||||||
|
gtk_adjustment_set_value (adjustment, 0.0);
|
||||||
|
g_source_remove (update_id);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
print_message (GstMessage * message)
|
||||||
|
{
|
||||||
|
const GstStructure *s;
|
||||||
|
|
||||||
|
s = gst_message_get_structure (message);
|
||||||
|
g_print ("Got Message from element \"%s\"\n",
|
||||||
|
GST_STR_NULL (GST_ELEMENT_NAME (GST_MESSAGE_SRC (message))));
|
||||||
|
|
||||||
|
if (s) {
|
||||||
|
gchar *sstr;
|
||||||
|
|
||||||
|
sstr = gst_structure_to_string (s);
|
||||||
|
g_print ("%s\n", sstr);
|
||||||
|
g_free (sstr);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static gboolean
|
||||||
|
bus_message (GstBus * bus, GstMessage * message, gpointer data)
|
||||||
|
{
|
||||||
|
switch (GST_MESSAGE_TYPE (message)) {
|
||||||
|
case GST_MESSAGE_EOS:
|
||||||
|
g_print ("EOS\n");
|
||||||
|
break;
|
||||||
|
case GST_MESSAGE_ERROR:
|
||||||
|
case GST_MESSAGE_WARNING:
|
||||||
|
print_message (message);
|
||||||
|
break;
|
||||||
|
case GST_MESSAGE_SEGMENT_START:
|
||||||
|
break;
|
||||||
|
case GST_MESSAGE_SEGMENT_DONE:
|
||||||
|
GST_DEBUG ("segment_done, doing next seek");
|
||||||
|
if (!do_seek (hscale, FALSE, update_id == 0)) {
|
||||||
|
if (changed_id == 0) {
|
||||||
|
changed_id = gtk_signal_connect (GTK_OBJECT (hscale),
|
||||||
|
"value_changed", G_CALLBACK (seek_cb), pipeline);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
return TRUE;
|
||||||
|
}
|
||||||
|
|
||||||
|
typedef struct
|
||||||
|
{
|
||||||
|
gchar *name;
|
||||||
|
GstElement *(*func) (const gchar * location);
|
||||||
|
}
|
||||||
|
Pipeline;
|
||||||
|
|
||||||
|
static Pipeline pipelines[] = {
|
||||||
|
{"wav", make_wav_pipeline},
|
||||||
|
{"playerbin", make_playerbin_pipeline},
|
||||||
|
{NULL, NULL},
|
||||||
|
};
|
||||||
|
|
||||||
|
#define NUM_TYPES ((sizeof (pipelines) / sizeof (Pipeline)) - 1)
|
||||||
|
|
||||||
|
static void
|
||||||
|
print_usage (int argc, char **argv)
|
||||||
|
{
|
||||||
|
gint i;
|
||||||
|
|
||||||
|
g_print ("usage: %s <type> <filename>\n", argv[0]);
|
||||||
|
g_print (" possible types:\n");
|
||||||
|
|
||||||
|
for (i = 0; i < NUM_TYPES; i++) {
|
||||||
|
g_print (" %d = %s\n", i, pipelines[i].name);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
int
|
||||||
|
main (int argc, char **argv)
|
||||||
|
{
|
||||||
|
GtkWidget *window, *hbox, *vbox, *play_button, *pause_button, *stop_button;
|
||||||
|
GstBus *bus;
|
||||||
|
GOptionEntry options[] = {
|
||||||
|
{"verbose", 'v', 0, G_OPTION_ARG_NONE, &verbose,
|
||||||
|
"Verbose properties", NULL},
|
||||||
|
{NULL}
|
||||||
|
};
|
||||||
|
gint type;
|
||||||
|
GOptionContext *ctx;
|
||||||
|
GError *err = NULL;
|
||||||
|
|
||||||
|
ctx = g_option_context_new ("seek");
|
||||||
|
g_option_context_add_main_entries (ctx, options, NULL);
|
||||||
|
g_option_context_add_group (ctx, gst_init_get_option_group ());
|
||||||
|
|
||||||
|
if (!g_option_context_parse (ctx, &argc, &argv, &err)) {
|
||||||
|
g_print ("Error initializing: %s\n", err->message);
|
||||||
|
exit (1);
|
||||||
|
}
|
||||||
|
|
||||||
|
GST_DEBUG_CATEGORY_INIT (scrubby_debug, "scrubby", 0, "scrubby example");
|
||||||
|
|
||||||
|
gtk_init (&argc, &argv);
|
||||||
|
|
||||||
|
if (argc != 3) {
|
||||||
|
print_usage (argc, argv);
|
||||||
|
exit (-1);
|
||||||
|
}
|
||||||
|
|
||||||
|
type = atoi (argv[1]);
|
||||||
|
|
||||||
|
if (type < 0 || type >= NUM_TYPES) {
|
||||||
|
print_usage (argc, argv);
|
||||||
|
exit (-1);
|
||||||
|
}
|
||||||
|
|
||||||
|
pipeline = pipelines[type].func (argv[2]);
|
||||||
|
g_assert (pipeline);
|
||||||
|
|
||||||
|
/* initialize gui elements ... */
|
||||||
|
window = gtk_window_new (GTK_WINDOW_TOPLEVEL);
|
||||||
|
hbox = gtk_hbox_new (FALSE, 0);
|
||||||
|
vbox = gtk_vbox_new (FALSE, 0);
|
||||||
|
play_button = gtk_button_new_with_label ("play");
|
||||||
|
pause_button = gtk_button_new_with_label ("pause");
|
||||||
|
stop_button = gtk_button_new_with_label ("stop");
|
||||||
|
|
||||||
|
adjustment =
|
||||||
|
GTK_ADJUSTMENT (gtk_adjustment_new (0.0, 0.0, (gdouble) RANGE_PREC, 0.1,
|
||||||
|
1.0, 1.0));
|
||||||
|
hscale = gtk_hscale_new (adjustment);
|
||||||
|
gtk_scale_set_digits (GTK_SCALE (hscale), 2);
|
||||||
|
gtk_range_set_update_policy (GTK_RANGE (hscale), GTK_UPDATE_CONTINUOUS);
|
||||||
|
|
||||||
|
sadjustment =
|
||||||
|
GTK_ADJUSTMENT (gtk_adjustment_new (1.0, 0.0, 5.0, 0.1, 1.0, 1.0));
|
||||||
|
shscale = gtk_hscale_new (sadjustment);
|
||||||
|
gtk_scale_set_digits (GTK_SCALE (shscale), 2);
|
||||||
|
gtk_range_set_update_policy (GTK_RANGE (shscale), GTK_UPDATE_CONTINUOUS);
|
||||||
|
|
||||||
|
schanged_id = gtk_signal_connect (GTK_OBJECT (shscale),
|
||||||
|
"value_changed", G_CALLBACK (speed_cb), pipeline);
|
||||||
|
|
||||||
|
gtk_signal_connect (GTK_OBJECT (hscale),
|
||||||
|
"button_press_event", G_CALLBACK (start_seek), pipeline);
|
||||||
|
gtk_signal_connect (GTK_OBJECT (hscale),
|
||||||
|
"button_release_event", G_CALLBACK (stop_seek), pipeline);
|
||||||
|
gtk_signal_connect (GTK_OBJECT (hscale),
|
||||||
|
"format_value", G_CALLBACK (format_value), pipeline);
|
||||||
|
|
||||||
|
/* do the packing stuff ... */
|
||||||
|
gtk_window_set_default_size (GTK_WINDOW (window), 96, 96);
|
||||||
|
gtk_container_add (GTK_CONTAINER (window), vbox);
|
||||||
|
gtk_container_add (GTK_CONTAINER (vbox), hbox);
|
||||||
|
gtk_box_pack_start (GTK_BOX (hbox), play_button, FALSE, FALSE, 2);
|
||||||
|
gtk_box_pack_start (GTK_BOX (hbox), pause_button, FALSE, FALSE, 2);
|
||||||
|
gtk_box_pack_start (GTK_BOX (hbox), stop_button, FALSE, FALSE, 2);
|
||||||
|
gtk_box_pack_start (GTK_BOX (vbox), hscale, TRUE, TRUE, 2);
|
||||||
|
gtk_box_pack_start (GTK_BOX (vbox), shscale, TRUE, TRUE, 2);
|
||||||
|
|
||||||
|
/* connect things ... */
|
||||||
|
g_signal_connect (G_OBJECT (play_button), "clicked", G_CALLBACK (play_cb),
|
||||||
|
pipeline);
|
||||||
|
g_signal_connect (G_OBJECT (pause_button), "clicked", G_CALLBACK (pause_cb),
|
||||||
|
pipeline);
|
||||||
|
g_signal_connect (G_OBJECT (stop_button), "clicked", G_CALLBACK (stop_cb),
|
||||||
|
pipeline);
|
||||||
|
g_signal_connect (G_OBJECT (window), "delete_event", gtk_main_quit, NULL);
|
||||||
|
|
||||||
|
/* show the gui. */
|
||||||
|
gtk_widget_show_all (window);
|
||||||
|
|
||||||
|
if (verbose) {
|
||||||
|
g_signal_connect (pipeline, "deep_notify",
|
||||||
|
G_CALLBACK (gst_object_default_deep_notify), NULL);
|
||||||
|
}
|
||||||
|
bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
|
||||||
|
g_assert (bus);
|
||||||
|
|
||||||
|
bus_watch = gst_bus_add_watch_full (bus,
|
||||||
|
G_PRIORITY_LOW, bus_message, pipeline, NULL);
|
||||||
|
|
||||||
|
gtk_main ();
|
||||||
|
|
||||||
|
g_print ("NULL pipeline\n");
|
||||||
|
gst_element_set_state (pipeline, GST_STATE_NULL);
|
||||||
|
|
||||||
|
g_print ("free pipeline\n");
|
||||||
|
gst_object_unref (pipeline);
|
||||||
|
|
||||||
|
return 0;
|
||||||
|
}
|
|
@ -30,11 +30,13 @@ static gulong changed_id;
|
||||||
#define ASINK "alsasink"
|
#define ASINK "alsasink"
|
||||||
//#define ASINK "osssink"
|
//#define ASINK "osssink"
|
||||||
#define VSINK "xvimagesink"
|
#define VSINK "xvimagesink"
|
||||||
|
//#define VSINK "sdlvideosink"
|
||||||
//#define VSINK "ximagesink"
|
//#define VSINK "ximagesink"
|
||||||
//#define VSINK "aasink"
|
//#define VSINK "aasink"
|
||||||
//#define VSINK "cacasink"
|
//#define VSINK "cacasink"
|
||||||
|
|
||||||
#define UPDATE_INTERVAL 500
|
//#define UPDATE_INTERVAL 500
|
||||||
|
#define UPDATE_INTERVAL 100
|
||||||
|
|
||||||
/* number of milliseconds to play for after a seek */
|
/* number of milliseconds to play for after a seek */
|
||||||
//#define SCRUB_TIME 250
|
//#define SCRUB_TIME 250
|
||||||
|
@ -66,10 +68,12 @@ gst_element_factory_make_or_warn (gchar * type, gchar * name)
|
||||||
static void
|
static void
|
||||||
dynamic_link (GstPadTemplate * templ, GstPad * newpad, gpointer data)
|
dynamic_link (GstPadTemplate * templ, GstPad * newpad, gpointer data)
|
||||||
{
|
{
|
||||||
|
gchar *padname;
|
||||||
dyn_link *connect = (dyn_link *) data;
|
dyn_link *connect = (dyn_link *) data;
|
||||||
|
|
||||||
if (connect->padname == NULL ||
|
padname = gst_pad_get_name (newpad);
|
||||||
!strcmp (gst_pad_get_name (newpad), connect->padname)) {
|
|
||||||
|
if (connect->padname == NULL || !strcmp (padname, connect->padname)) {
|
||||||
if (connect->bin)
|
if (connect->bin)
|
||||||
gst_bin_add (GST_BIN (pipeline), connect->bin);
|
gst_bin_add (GST_BIN (pipeline), connect->bin);
|
||||||
gst_pad_link (newpad, connect->target);
|
gst_pad_link (newpad, connect->target);
|
||||||
|
@ -77,6 +81,7 @@ dynamic_link (GstPadTemplate * templ, GstPad * newpad, gpointer data)
|
||||||
//seekable_pads = g_list_prepend (seekable_pads, newpad);
|
//seekable_pads = g_list_prepend (seekable_pads, newpad);
|
||||||
rate_pads = g_list_prepend (rate_pads, newpad);
|
rate_pads = g_list_prepend (rate_pads, newpad);
|
||||||
}
|
}
|
||||||
|
g_free (padname);
|
||||||
}
|
}
|
||||||
|
|
||||||
static void
|
static void
|
||||||
|
@ -598,7 +603,6 @@ make_avi_pipeline (const gchar * location)
|
||||||
audio_bin = gst_bin_new ("a_decoder_bin");
|
audio_bin = gst_bin_new ("a_decoder_bin");
|
||||||
a_decoder = gst_element_factory_make_or_warn ("mad", "a_dec");
|
a_decoder = gst_element_factory_make_or_warn ("mad", "a_dec");
|
||||||
audiosink = gst_element_factory_make_or_warn (ASINK, "a_sink");
|
audiosink = gst_element_factory_make_or_warn (ASINK, "a_sink");
|
||||||
//g_object_set (G_OBJECT (audiosink), "fragment", 0x00180008, NULL);
|
|
||||||
a_queue = gst_element_factory_make_or_warn ("queue", "a_queue");
|
a_queue = gst_element_factory_make_or_warn ("queue", "a_queue");
|
||||||
gst_element_link (a_decoder, a_queue);
|
gst_element_link (a_decoder, a_queue);
|
||||||
gst_element_link (a_queue, audiosink);
|
gst_element_link (a_queue, audiosink);
|
||||||
|
@ -617,14 +621,9 @@ make_avi_pipeline (const gchar * location)
|
||||||
g_list_prepend (rate_pads, gst_element_get_pad (a_decoder, "sink"));
|
g_list_prepend (rate_pads, gst_element_get_pad (a_decoder, "sink"));
|
||||||
|
|
||||||
video_bin = gst_bin_new ("v_decoder_bin");
|
video_bin = gst_bin_new ("v_decoder_bin");
|
||||||
//v_decoder = gst_element_factory_make_or_warn ("identity", "v_dec");
|
|
||||||
//v_decoder = gst_element_factory_make_or_warn ("windec", "v_dec");
|
|
||||||
v_decoder = gst_element_factory_make_or_warn ("ffmpegdecall", "v_dec");
|
v_decoder = gst_element_factory_make_or_warn ("ffmpegdecall", "v_dec");
|
||||||
videosink = gst_element_factory_make_or_warn ("ximagesink", "v_sink");
|
videosink = gst_element_factory_make_or_warn ("ximagesink", "v_sink");
|
||||||
//videosink = gst_element_factory_make_or_warn ("fakesink", "v_sink");
|
|
||||||
//g_object_set (G_OBJECT (videosink), "sync", TRUE, NULL);
|
|
||||||
v_queue = gst_element_factory_make_or_warn ("queue", "v_queue");
|
v_queue = gst_element_factory_make_or_warn ("queue", "v_queue");
|
||||||
//g_object_set (G_OBJECT (v_queue), "max_level", 10, NULL);
|
|
||||||
gst_element_link (v_decoder, v_queue);
|
gst_element_link (v_decoder, v_queue);
|
||||||
gst_element_link (v_queue, videosink);
|
gst_element_link (v_queue, videosink);
|
||||||
gst_bin_add (GST_BIN (video_bin), v_decoder);
|
gst_bin_add (GST_BIN (video_bin), v_decoder);
|
||||||
|
@ -653,16 +652,15 @@ make_mpeg_pipeline (const gchar * location)
|
||||||
GstElement *audiosink, *videosink;
|
GstElement *audiosink, *videosink;
|
||||||
GstElement *a_queue, *v_queue;
|
GstElement *a_queue, *v_queue;
|
||||||
GstPad *seekable;
|
GstPad *seekable;
|
||||||
|
GstPad *pad;
|
||||||
|
|
||||||
pipeline = gst_pipeline_new ("app");
|
pipeline = gst_pipeline_new ("app");
|
||||||
|
|
||||||
src = gst_element_factory_make_or_warn (SOURCE, "src");
|
src = gst_element_factory_make_or_warn (SOURCE, "src");
|
||||||
g_object_set (G_OBJECT (src), "location", location, NULL);
|
g_object_set (G_OBJECT (src), "location", location, NULL);
|
||||||
|
|
||||||
demux = gst_element_factory_make_or_warn ("mpegdemux", "demux");
|
//demux = gst_element_factory_make_or_warn ("mpegdemux", "demux");
|
||||||
g_object_set (G_OBJECT (demux), "sync", FALSE, NULL);
|
demux = gst_element_factory_make_or_warn ("flupsdemux", "demux");
|
||||||
|
|
||||||
seekable_elements = g_list_prepend (seekable_elements, demux);
|
|
||||||
|
|
||||||
gst_bin_add (GST_BIN (pipeline), src);
|
gst_bin_add (GST_BIN (pipeline), src);
|
||||||
gst_bin_add (GST_BIN (pipeline), demux);
|
gst_bin_add (GST_BIN (pipeline), demux);
|
||||||
|
@ -672,38 +670,47 @@ make_mpeg_pipeline (const gchar * location)
|
||||||
a_decoder = gst_element_factory_make_or_warn ("mad", "a_dec");
|
a_decoder = gst_element_factory_make_or_warn ("mad", "a_dec");
|
||||||
a_queue = gst_element_factory_make_or_warn ("queue", "a_queue");
|
a_queue = gst_element_factory_make_or_warn ("queue", "a_queue");
|
||||||
audiosink = gst_element_factory_make_or_warn (ASINK, "a_sink");
|
audiosink = gst_element_factory_make_or_warn (ASINK, "a_sink");
|
||||||
//g_object_set (G_OBJECT (audiosink), "fragment", 0x00180008, NULL);
|
|
||||||
gst_element_link (a_decoder, a_queue);
|
|
||||||
gst_element_link (a_queue, audiosink);
|
|
||||||
gst_bin_add (GST_BIN (audio_bin), a_decoder);
|
gst_bin_add (GST_BIN (audio_bin), a_decoder);
|
||||||
gst_bin_add (GST_BIN (audio_bin), a_queue);
|
gst_bin_add (GST_BIN (audio_bin), a_queue);
|
||||||
gst_bin_add (GST_BIN (audio_bin), audiosink);
|
gst_bin_add (GST_BIN (audio_bin), audiosink);
|
||||||
|
|
||||||
setup_dynamic_link (demux, "audio_00", gst_element_get_pad (a_decoder,
|
gst_element_link (a_decoder, a_queue);
|
||||||
"sink"), audio_bin);
|
gst_element_link (a_queue, audiosink);
|
||||||
|
|
||||||
seekable = gst_element_get_pad (a_queue, "src");
|
gst_bin_add (GST_BIN (pipeline), audio_bin);
|
||||||
seekable_pads = g_list_prepend (seekable_pads, seekable);
|
|
||||||
rate_pads = g_list_prepend (rate_pads, seekable);
|
pad = gst_element_get_pad (a_decoder, "sink");
|
||||||
rate_pads =
|
gst_element_add_pad (audio_bin, gst_ghost_pad_new ("sink", pad));
|
||||||
g_list_prepend (rate_pads, gst_element_get_pad (a_decoder, "sink"));
|
gst_object_unref (pad);
|
||||||
|
|
||||||
|
setup_dynamic_link (demux, "audio_c0", gst_element_get_pad (audio_bin,
|
||||||
|
"sink"), NULL);
|
||||||
|
|
||||||
video_bin = gst_bin_new ("v_decoder_bin");
|
video_bin = gst_bin_new ("v_decoder_bin");
|
||||||
v_decoder = gst_element_factory_make_or_warn ("mpeg2dec", "v_dec");
|
v_decoder = gst_element_factory_make_or_warn ("mpeg2dec", "v_dec");
|
||||||
//g_object_set (G_OBJECT (video_thread), "priority", 2, NULL);
|
|
||||||
v_queue = gst_element_factory_make_or_warn ("queue", "v_queue");
|
v_queue = gst_element_factory_make_or_warn ("queue", "v_queue");
|
||||||
v_filter = gst_element_factory_make_or_warn ("ffmpegcolorspace", "v_filter");
|
v_filter = gst_element_factory_make_or_warn ("ffmpegcolorspace", "v_filter");
|
||||||
videosink = gst_element_factory_make_or_warn ("ximagesink", "v_sink");
|
videosink = gst_element_factory_make_or_warn (VSINK, "v_sink");
|
||||||
gst_element_link_many (v_decoder, v_queue, v_filter, NULL);
|
|
||||||
|
|
||||||
|
gst_bin_add (GST_BIN (video_bin), v_decoder);
|
||||||
|
gst_bin_add (GST_BIN (video_bin), v_queue);
|
||||||
|
gst_bin_add (GST_BIN (video_bin), v_filter);
|
||||||
|
gst_bin_add (GST_BIN (video_bin), videosink);
|
||||||
|
|
||||||
|
gst_element_link (v_decoder, v_queue);
|
||||||
|
gst_element_link (v_queue, v_filter);
|
||||||
gst_element_link (v_filter, videosink);
|
gst_element_link (v_filter, videosink);
|
||||||
gst_bin_add_many (GST_BIN (video_bin), v_decoder, NULL);
|
|
||||||
gst_bin_add_many (GST_BIN (video_bin), v_queue, v_filter, videosink, NULL);
|
|
||||||
|
|
||||||
setup_dynamic_link (demux, "video_00", gst_element_get_pad (v_decoder,
|
gst_bin_add (GST_BIN (pipeline), video_bin);
|
||||||
"sink"), video_bin);
|
|
||||||
|
|
||||||
seekable = gst_element_get_pad (v_queue, "src");
|
pad = gst_element_get_pad (v_decoder, "sink");
|
||||||
|
gst_element_add_pad (video_bin, gst_ghost_pad_new ("sink", pad));
|
||||||
|
gst_object_unref (pad);
|
||||||
|
|
||||||
|
setup_dynamic_link (demux, "video_e0", gst_element_get_pad (video_bin,
|
||||||
|
"sink"), NULL);
|
||||||
|
|
||||||
|
seekable = gst_element_get_pad (v_filter, "src");
|
||||||
seekable_pads = g_list_prepend (seekable_pads, seekable);
|
seekable_pads = g_list_prepend (seekable_pads, seekable);
|
||||||
rate_pads = g_list_prepend (rate_pads, seekable);
|
rate_pads = g_list_prepend (rate_pads, seekable);
|
||||||
rate_pads =
|
rate_pads =
|
||||||
|
|
|
@ -1,4 +1,4 @@
|
||||||
examples = seek #scrubby cdplayer cdparanoia
|
examples = seek scrubby #cdplayer cdparanoia
|
||||||
|
|
||||||
noinst_PROGRAMS = $(examples)
|
noinst_PROGRAMS = $(examples)
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue