[maemo-commits] [maemo-commits] r17833 - projects/haf/trunk/hildon-welcome/src
From: subversion at stage.maemo.org subversion at stage.maemo.orgDate: Fri Mar 27 14:00:03 EET 2009
- Previous message: [maemo-commits] r17832 - in projects/haf/trunk/clutter0.8: clutter/cogl/common clutter/eglx debian
- Next message: [maemo-commits] r17834 - in projects/haf/trunk/gtk+: . gtk
- Messages sorted by: [ date ] [ thread ] [ subject ] [ author ]
Author: schulhof
Date: 2009-03-27 14:00:02 +0200 (Fri, 27 Mar 2009)
New Revision: 17833
Modified:
projects/haf/trunk/hildon-welcome/src/tmp.c
Log:
Modified: projects/haf/trunk/hildon-welcome/src/tmp.c
===================================================================
--- projects/haf/trunk/hildon-welcome/src/tmp.c 2009-03-27 11:21:58 UTC (rev 17832)
+++ projects/haf/trunk/hildon-welcome/src/tmp.c 2009-03-27 12:00:02 UTC (rev 17833)
@@ -12,52 +12,135 @@
? "GST_STATE_PAUSED" \
: "GST_STATE_PLAYING")
+
static void
-play_pipeline(GstElement *pipeline)
+no_more_pads(GstElement *src, GstElement *dst)
{
+ g_print("no_more_pads: Linking src to dst\n");
+ gst_element_link(src, dst);
+}
+
+static GstElement *
+create_bin(char *fname, GstElement *sink)
+{
+ static int counter = 0;
+ char *name = NULL;
+ GstElement *bin, *filesrc, *decodebin2;
+
+ name = g_strdup_printf("audio-bin%d", counter++);
+ bin = gst_bin_new(name);
+ g_free(name);
+
+ filesrc = gst_element_factory_make("filesrc", "the-filesrc");
+ g_object_set(G_OBJECT(filesrc), "location", fname, NULL);
+ decodebin2 = gst_element_factory_make("decodebin2", "the-decodebin2");
+ g_signal_connect(G_OBJECT(decodebin2), "no-more-pads", (GCallback)no_more_pads, sink);
+ gst_bin_add_many(GST_BIN(bin), filesrc, decodebin2, NULL);
+ gst_element_link(filesrc, decodebin2);
+
+ return bin;
+}
+
+static void
+do_everything(GstElement *pipeline, int argc, char **argv, GstElement *audiosink)
+{
GstBus *bus = gst_pipeline_get_bus(GST_PIPELINE(pipeline));
- gst_element_set_state(pipeline, GST_STATE_PLAYING);
-
if (bus) {
+ gboolean keep_looping = TRUE;
+ static int current_logo = 1;
GstMessage *msg = NULL;
- gboolean keep_looping = TRUE;
+ GstElement *new_bin = NULL;
+ new_bin = create_bin(argv[current_logo++], audiosink);
+ gst_bin_add(GST_BIN(pipeline), new_bin);
+ gst_element_set_state(pipeline, GST_STATE_PAUSED);
+ gst_element_send_event(pipeline,
+ gst_event_new_seek(1.0, GST_FORMAT_TIME, GST_SEEK_FLAG_FLUSH|GST_SEEK_FLAG_SEGMENT, GST_SEEK_TYPE_SET, G_GUINT64_CONSTANT(0), GST_SEEK_TYPE_NONE, GST_CLOCK_TIME_NONE));
+ gst_element_set_state(pipeline, GST_STATE_PLAYING);
+
+ g_print("do_everything: Entering loop\n");
+
while (keep_looping) {
msg = gst_bus_poll(bus, GST_MESSAGE_ANY, -1);
- g_print("play_pipeline: Got message %s\n", GST_MESSAGE_TYPE_NAME(msg));
if (!msg) break;
- switch(GST_MESSAGE_TYPE(msg)) {
+ switch (GST_MESSAGE_TYPE(msg)) {
+ case GST_MESSAGE_ERROR:
+ {
+ GError *err = NULL;
+ gchar *debug = NULL;
+
+ gst_message_parse_error(msg, &err, &debug);
+
+ if (err) {
+ g_print("do_everything: error: %s, debug: %s\n", err->message ? err->message : "?", debug ? debug : "?");
+ g_error_free(err);
+ err = NULL;
+ }
+ g_free(debug);
+ debug = NULL;;
+ }
+ break;
+
+ case GST_MESSAGE_EOS:
+ g_print("do_everything: EOS\n");
+ break;
+
+ case GST_MESSAGE_SEGMENT_START:
+ g_print("do_everything: SEGMENT_START\n");
+ break;
+
+ case GST_MESSAGE_SEGMENT_DONE:
+ g_print("do_everything: SEGMENT_DONE\n");
+ gst_element_set_locked_state(new_bin, TRUE);
+ gst_element_set_state(new_bin, GST_STATE_NULL);
+ gst_bin_remove(GST_BIN(pipeline), new_bin);
+
+ if (current_logo == argc)
+ keep_looping = FALSE;
+ else {
+ new_bin = create_bin(argv[current_logo++], audiosink);
+ gst_bin_add(GST_BIN(pipeline), new_bin);
+ gst_element_set_state(pipeline, GST_STATE_PAUSED);
+ gst_element_send_event(pipeline,
+ gst_event_new_seek(1.0, GST_FORMAT_TIME, GST_SEEK_FLAG_FLUSH|GST_SEEK_FLAG_SEGMENT, GST_SEEK_TYPE_SET, G_GUINT64_CONSTANT(0), GST_SEEK_TYPE_NONE, GST_CLOCK_TIME_NONE));
+ gst_element_set_state(pipeline, GST_STATE_PLAYING);
+ }
+ break;
+
case GST_MESSAGE_STATE_CHANGED:
- if (pipeline == GST_ELEMENT(GST_MESSAGE_SRC(msg)))
- {
+ if (GST_MESSAGE_SRC(msg) == GST_OBJECT(pipeline)) {
GstState oldstate, newstate, pending;
-
gst_message_parse_state_changed(msg, &oldstate, &newstate, &pending);
- g_print("play_pipeline: state-changed: old = %s, new = %s, pending = %s\n",
+ g_print("do_everything: STATE_CHANGED for %s: old = %s, new = %s, pending = %s\n",
+ gst_element_get_name(GST_MESSAGE_SRC(msg)),
GST_STATE_NAME(oldstate),
GST_STATE_NAME(newstate),
GST_STATE_NAME(pending));
}
break;
+#if (0)
+ if (GST_MESSAGE_SRC(msg) == GST_OBJECT(pipeline)) {
+ GstState oldstate, newstate, pending;
+ gst_message_parse_state_changed(msg, &oldstate, &newstate, &pending);
+ if (GST_STATE_PLAYING == oldstate && GST_STATE_PAUSED == newstate) {
+ gst_element_set_locked_state(new_bin, TRUE);
+ gst_element_set_state(new_bin, GST_STATE_NULL);
+ gst_bin_remove(GST_BIN(pipeline), new_bin);
- case GST_MESSAGE_ERROR:
- {
- GError *err = NULL;
- char *debug = NULL;
- gst_message_parse_error(msg, &err, &debug);
- g_print("play_pipeline: %s: %s %s\n", GST_MESSAGE_TYPE_NAME(msg), err ? err->message : "", debug ? debug : "");
- if (err)
- g_error_free(err);
- g_free(debug);
+ if (current_logo == argc)
+ keep_looping = FALSE;
+ else {
+ new_bin = create_bin(argv[current_logo++], audiosink);
+ gst_bin_add(GST_BIN(pipeline), new_bin);
+ gst_element_send_event(pipeline,
+ gst_event_new_seek(1.0, GST_FORMAT_TIME, GST_SEEK_FLAG_FLUSH|GST_SEEK_FLAG_SEGMENT, GST_SEEK_TYPE_SET, G_GUINT64_CONSTANT(0), GST_SEEK_TYPE_NONE, GST_CLOCK_TIME_NONE));
+ gst_element_set_state(pipeline, GST_STATE_PLAYING);
+ }
+ }
}
- /* fall through */
- case GST_MESSAGE_EOS:
- case GST_MESSAGE_SEGMENT_DONE:
- g_print("play_pipeline: SEGMENT_DONE received\n");
- gst_element_set_state(pipeline, GST_STATE_PAUSED);
- keep_looping = FALSE;
+#endif /* (0) */
break;
default:
@@ -69,68 +152,21 @@
}
}
-static void
-no_more_pads(GstElement *decodebin2, GstElement *output)
-{
- g_print("no_more_pads: Linking input to output\n");
- gst_element_link(decodebin2, output);
-}
-
-static GstElement *
-create_bin(const char *fname, GstElement *output)
-{
- GstElement *filesrc, *decodebin2, *bin;
- static int counter = 0;
- char *name = g_strdup_printf("audio_bin%d", counter++);
-
- bin = gst_bin_new(name);
- g_free(name);
- filesrc = gst_element_factory_make("filesrc", "audio_filesrc");
- g_object_set(G_OBJECT(filesrc), "location", fname, NULL);
- decodebin2 = gst_element_factory_make("decodebin2", "audio_decodebin");
- gst_bin_add_many(GST_BIN(bin), filesrc, decodebin2, NULL);
- gst_element_link(filesrc, decodebin2);
-
- g_signal_connect(G_OBJECT(decodebin2), "no-more-pads", (GCallback)no_more_pads, output);
-
- return bin;
-}
-
int
main(int argc, char **argv)
{
- GstEvent *seek;
- int Nix;
- GstElement *pipeline, *autoaudiosink, *old_bin = NULL, *new_bin = NULL;
-
+ GstElement *pipeline = NULL, *audiosink;
gst_init(&argc, &argv);
- pipeline = gst_pipeline_new("myname");
- autoaudiosink = gst_element_factory_make("autoaudiosink", "audio_autoaudiosink");
- seek = gst_event_new_seek(1.0, GST_FORMAT_TIME, GST_SEEK_FLAG_FLUSH | GST_SEEK_FLAG_SEGMENT, GST_SEEK_TYPE_SET, G_GUINT64_CONSTANT(0), GST_SEEK_TYPE_NONE, GST_CLOCK_TIME_NONE);
-
- gst_bin_add(GST_BIN(pipeline), autoaudiosink);
-
- for (Nix = 1 ; Nix < argc ; Nix++) {
- g_print("main: playing argv[%d] = %s\n", Nix, argv[Nix]);
- new_bin = create_bin(argv[Nix], autoaudiosink);
- if (old_bin) {
- gst_element_set_locked_state(old_bin, TRUE);
- gst_element_set_state(old_bin, GST_STATE_NULL);
- gst_bin_remove(GST_BIN(pipeline), old_bin);
+ if (argc > 1)
+ if ((pipeline = gst_pipeline_new("sequence-player"))) {
+ audiosink = gst_element_factory_make("autoaudiosink", "the-audio-sink");
+ gst_bin_add(GST_BIN(pipeline), audiosink);
+ do_everything(pipeline, argc, argv, audiosink);
+ gst_element_set_state(pipeline, GST_STATE_NULL);
+ gst_object_unref(pipeline);
}
- gst_bin_add(GST_BIN(pipeline), new_bin);
- gst_element_set_state(pipeline, GST_STATE_PAUSED);
- gst_element_send_event(pipeline, seek);
- play_pipeline(pipeline);
- old_bin = new_bin;
- g_print("main: played argv[%d] = %s\n", Nix, argv[Nix]);
- }
- gst_element_set_state(pipeline, GST_STATE_NULL);
- gst_object_unref(pipeline);
-
gst_deinit();
-
return 0;
}
- Previous message: [maemo-commits] r17832 - in projects/haf/trunk/clutter0.8: clutter/cogl/common clutter/eglx debian
- Next message: [maemo-commits] r17834 - in projects/haf/trunk/gtk+: . gtk
- Messages sorted by: [ date ] [ thread ] [ subject ] [ author ]