+ /* g_print("Got %s message\n", GST_MESSAGE_TYPE_NAME(message)); */
+
+ switch(GST_MESSAGE_TYPE(message)) {
+ case GST_MESSAGE_ERROR: {
+ GError *err;
+ gchar *debug;
+
+ gst_message_parse_error(message, &err, &debug);
+ g_print("Error: %s\n", err->message);
+ g_error_free(err);
+ g_free(debug);
+ break;
+ }
+ case GST_MESSAGE_EOS:
+ /* end-of-stream */
+ break;
+ default:
+ /* unhandled message */
+ break;
+ }
+}
+
+static void
+on_ogg_demuxer_pad_added(GstElement *demux, GstPad *pad, schanid_t s)
+{
+ GstPad *sinkpad;
+
+ /* We can now link this pad with the vorbis-decoder sink pad */
+ sinkpad = gst_element_get_static_pad(s->decode, "sink");
+ gst_pad_link(pad, sinkpad);
+ gst_object_unref(sinkpad);
+}
+
+static void
+on_type_found(GstElement *typefind, guint probability, GstCaps *caps, schanid_t s)
+{
+ gchar *type = gst_caps_to_string(caps);
+ if(strcmp(type, "application/ogg") == 0)
+ {
+ s->demux = gst_element_factory_make("oggdemux", NULL);
+ s->decode = gst_element_factory_make("vorbisdec", NULL);
+ if(!s->demux || !s->decode)
+ {
+ WARNING(_("Could not create one or more GStreamer elements"));
+ goto finally;
+ }
+ gst_bin_add_many(GST_BIN(s->pipeline), s->demux, s->decode, NULL);
+ if(!gst_element_link(s->typefind, s->demux) || !gst_element_link(s->decode, s->convert))
+ {
+ WARNING(_("Could not link GStreamer elements"));
+ goto finally;
+ }
+ /* We link the demuxer and decoder together dynamically, since the
+ demuxer doesn't know what source pads it will have until it starts
+ demuxing the stream */
+ g_signal_connect(s->demux, "pad-added", G_CALLBACK(on_ogg_demuxer_pad_added), s);
+ }
+ else if(strcmp(type, "audio/x-aiff") == 0)
+ {
+ s->decode = gst_element_factory_make("aiffparse", NULL);
+ if(!s->decode)
+ {
+ WARNING(_("Could not create 'aiffparse' GStreamer element"));
+ goto finally;
+ }
+ gst_bin_add(GST_BIN(s->pipeline), s->decode);
+ if(!gst_element_link_many(s->typefind, s->decode, s->convert, NULL))
+ {
+ WARNING(_("Could not link GStreamer elements"));
+ goto finally;
+ }
+ }
+ else
+ {
+ WARNING("Can't play that type, you FOOL!");
+ }
+
+finally:
+ g_free(type);
+}
+#endif /* GSTREAMER_SOUND */