| #include <stdlib.h> |
| #include <gst/gst.h> |
| |
| gboolean playing; |
| |
| /* eos will be called when the src element has an end of stream */ |
| void eos(GstElement *element, gpointer data) |
| { |
| g_print("have eos, quitting\n"); |
| |
| playing = FALSE; |
| } |
| |
| int main(int argc,char *argv[]) |
| { |
| GstElement *disksrc, *osssink, *queue, *queue2, *parse, *decode; |
| GstElement *bin; |
| GstElement *thread, *thread2; |
| |
| gst_init(&argc,&argv); |
| |
| if (argc != 2) { |
| g_print("usage: %s <filename>\n", argv[0]); |
| exit(-1); |
| } |
| |
| /* create a new thread to hold the elements */ |
| thread = gst_thread_new("thread"); |
| g_assert(thread != NULL); |
| thread2 = gst_thread_new("thread2"); |
| g_assert(thread2 != NULL); |
| |
| /* create a new bin to hold the elements */ |
| bin = gst_bin_new("bin"); |
| g_assert(bin != NULL); |
| |
| /* create a disk reader */ |
| disksrc = gst_elementfactory_make("disksrc", "disk_source"); |
| g_assert(disksrc != NULL); |
| gtk_object_set(GTK_OBJECT(disksrc),"location", argv[1],NULL); |
| gtk_signal_connect(GTK_OBJECT(disksrc),"eos", |
| GTK_SIGNAL_FUNC(eos), thread); |
| |
| queue = gst_elementfactory_make("queue", "queue"); |
| queue2 = gst_elementfactory_make("queue", "queue2"); |
| |
| /* and an audio sink */ |
| osssink = gst_elementfactory_make("osssink", "play_audio"); |
| g_assert(osssink != NULL); |
| |
| parse = gst_elementfactory_make("mp3parse", "parse"); |
| decode = gst_elementfactory_make("mpg123", "decode"); |
| |
| /* add objects to the main bin */ |
| gst_bin_add(GST_BIN(bin), disksrc); |
| gst_bin_add(GST_BIN(bin), queue); |
| |
| gst_bin_add(GST_BIN(thread), parse); |
| gst_bin_add(GST_BIN(thread), decode); |
| gst_bin_add(GST_BIN(thread), queue2); |
| |
| gst_bin_add(GST_BIN(thread2), osssink); |
| |
| gst_pad_connect(gst_element_get_pad(disksrc,"src"), |
| gst_element_get_pad(queue,"sink")); |
| |
| gst_pad_connect(gst_element_get_pad(queue,"src"), |
| gst_element_get_pad(parse,"sink")); |
| gst_pad_connect(gst_element_get_pad(parse,"src"), |
| gst_element_get_pad(decode,"sink")); |
| gst_pad_connect(gst_element_get_pad(decode,"src"), |
| gst_element_get_pad(queue2,"sink")); |
| |
| gst_pad_connect(gst_element_get_pad(queue2,"src"), |
| gst_element_get_pad(osssink,"sink")); |
| |
| gst_bin_add(GST_BIN(bin), thread); |
| gst_bin_add(GST_BIN(bin), thread2); |
| |
| /* make it ready */ |
| gst_element_set_state(GST_ELEMENT(bin), GST_STATE_READY); |
| /* start playing */ |
| gst_element_set_state(GST_ELEMENT(bin), GST_STATE_PLAYING); |
| |
| playing = TRUE; |
| |
| while (playing) { |
| gst_bin_iterate(GST_BIN(bin)); |
| } |
| |
| gst_element_set_state(GST_ELEMENT(bin), GST_STATE_NULL); |
| |
| exit(0); |
| } |
| |