#include #include #include void eof(GstSrc *src) { g_print("have eof, quitting\n"); exit(0); } int main(int argc,char *argv[]) { guint16 mp3type; GList *factories; GstElementFactory *parsefactory; GstElement *bin, *src, *parse, *osssink; GList *padlist; ghttp_request *pls; guchar *plsbuf; gint plsbuflen,parsedlen = 0; guchar *url,*local; GSList *urls = NULL; pls = ghttp_request_new(); if (argc >= 2) ghttp_set_uri(pls,argv[1]); else ghttp_set_uri(pls,"http://209.127.18.4:9000"); ghttp_prepare(pls); ghttp_process(pls); plsbuf = ghttp_get_body(pls); plsbuflen = ghttp_get_body_len(pls); while (parsedlen < plsbuflen) { local = plsbuf + parsedlen; if ((*local != '[') && (*local != '\n')) { /* t/v pair */ if (!strncmp(local,"File1=",4)) { /* if file */ url = strchr(local,'=') + 1; /* url after = */ local = strchr(url,'\n'); /* ffwd after = */ *(local)++ = 0; /* nullz url */ g_print("prepending '%s' to list\n",url); urls = g_slist_prepend(urls,g_strdup(url)); /* local should point to next line now */ } else { local = strchr(local,'\n') + 1; /* skip line */ } } else { local = strchr(local,'\n') + 1; /* skip line */ } /* we can consider that line parsed... */ parsedlen = local - plsbuf; } if (urls == NULL) { g_print("couldn't find any streams\n"); exit(1); } ghttp_request_destroy(pls); gst_init(&argc,&argv); gst_plugin_load_all(); bin = gst_bin_new("bin"); src = gst_httpsrc_new("src"); if (argc == 3) { int i; for (i=1;idata); gtk_object_set(GTK_OBJECT(src),"location",urls->data,NULL); g_print("created src\n"); /* now it's time to get the parser */ mp3type = gst_type_find_by_mime("audio/mpeg"); factories = gst_type_get_sinks(mp3type); if (factories != NULL) parsefactory = GST_ELEMENTFACTORY(factories->data); else { g_print("sorry, can't find anyone registered to sink 'mp3'\n"); return 1; } parse = gst_elementfactory_create(parsefactory,"parser"); if (parse == NULL) { g_print("sorry, couldn't create parser\n"); return 1; } osssink = gst_osssink_new("osssink"); gtk_signal_connect(GTK_OBJECT(src),"eof", GTK_SIGNAL_FUNC(eof),NULL); /* add objects to the main pipeline */ gst_bin_add(GST_BIN(bin),GST_OBJECT(src)); gst_bin_add(GST_BIN(bin),GST_OBJECT(parse)); gst_bin_add(GST_BIN(bin),GST_OBJECT(osssink)); /* connect src to sink */ gst_pad_connect(gst_element_get_pad(src,"src"), gst_element_get_pad(parse,"sink")); gst_pad_connect(gst_element_get_pad(parse,"src"), gst_element_get_pad(osssink,"sink")); sleep(5); /* to let the network buffer fill a bit */ while(1) { g_print("calling gst_httpsrc_push\n"); gst_httpsrc_push(GST_SRC(src)); } gst_object_destroy(GST_OBJECT(osssink)); gst_object_destroy(GST_OBJECT(parse)); gst_object_destroy(GST_OBJECT(src)); gst_object_destroy(GST_OBJECT(bin)); }