GstAutoplug *autoplug;
GtkWidget *socket;
GstElement *autobin;
- GstElement *disksrc;
+ GstElement *filesrc;
GstElement *cache;
GST_DEBUG (0,"GstPipeline: play have type\n");
gst_element_set_state (pipeline, GST_STATE_PAUSED);
- disksrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
+ filesrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
autobin = gst_bin_get_by_name (GST_BIN (pipeline), "autobin");
cache = gst_bin_get_by_name (GST_BIN (autobin), "cache");
gst_play_cache_empty (GstElement *element, GstElement *pipeline)
{
GstElement *autobin;
- GstElement *disksrc;
+ GstElement *filesrc;
GstElement *cache;
GstElement *new_element;
gst_element_set_state (pipeline, GST_STATE_PAUSED);
- disksrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
+ filesrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
autobin = gst_bin_get_by_name (GST_BIN (pipeline), "autobin");
cache = gst_bin_get_by_name (GST_BIN (autobin), "cache");
new_element = gst_bin_get_by_name (GST_BIN (autobin), "new_element");
- gst_element_disconnect (disksrc, "src", cache, "sink");
+ gst_element_disconnect (filesrc, "src", cache, "sink");
gst_element_disconnect (cache, "src", new_element, "sink");
gst_bin_remove (GST_BIN (autobin), cache);
- gst_element_connect (disksrc, "src", new_element, "sink");
+ gst_element_connect (filesrc, "src", new_element, "sink");
gst_element_set_state (pipeline, GST_STATE_PLAYING);
int main(int argc,char *argv[])
{
- GstElement *disksrc;
+ GstElement *filesrc;
GstElement *pipeline;
GstElement *autobin;
GstElement *typefind;
g_assert(pipeline != 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);
- gst_bin_add (GST_BIN (pipeline), disksrc);
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_assert(filesrc != NULL);
+ gtk_object_set(GTK_OBJECT(filesrc),"location", argv[1],NULL);
+ gst_bin_add (GST_BIN (pipeline), filesrc);
autobin = gst_bin_new ("autobin");
cache = gst_elementfactory_make ("autoplugcache", "cache");
gst_element_add_ghost_pad (autobin, gst_element_get_pad (cache, "sink"), "sink");
gst_bin_add (GST_BIN( pipeline), autobin);
- gst_element_connect (disksrc, "src", autobin, "sink");
+ gst_element_connect (filesrc, "src", autobin, "sink");
/* start playing */
gst_element_set_state( GST_ELEMENT (pipeline), GST_STATE_PLAYING);
int main(int argc,char *argv[])
{
- GstElement *bin, *disksrc, *parse, *decoder, *downmix, *mulaw, *mulawdec, *osssink;
+ GstElement *bin, *filesrc, *parse, *decoder, *downmix, *mulaw, *mulawdec, *osssink;
gst_init(&argc,&argv);
bin = gst_pipeline_new("pipeline");
/* create a disk reader */
- disksrc = gst_elementfactory_make("disksrc", "disk_source");
- g_object_set(G_OBJECT(disksrc),"location", argv[1],NULL);
- g_signal_connect(G_OBJECT(disksrc),"eos",
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_object_set(G_OBJECT(filesrc),"location", argv[1],NULL);
+ g_signal_connect(G_OBJECT(filesrc),"eos",
G_CALLBACK(eos),NULL);
/* now it's time to get the parser */
osssink = gst_elementfactory_make("osssink", "play_audio");
/* add objects to the main pipeline */
- gst_bin_add(GST_BIN(bin), disksrc);
+ gst_bin_add(GST_BIN(bin), filesrc);
gst_bin_add(GST_BIN(bin), parse);
gst_bin_add(GST_BIN(bin), decoder);
gst_bin_add(GST_BIN(bin), downmix);
gst_bin_add(GST_BIN(bin), osssink);
/* connect src to sink */
- gst_pad_connect(gst_element_get_pad(disksrc,"src"),
+ gst_pad_connect(gst_element_get_pad(filesrc,"src"),
gst_element_get_pad(parse,"sink"));
gst_pad_connect(gst_element_get_pad(parse,"src"),
gst_element_get_pad(decoder,"sink"));
gst_object_destroy(GST_OBJECT(downmix));
gst_object_destroy(GST_OBJECT(mulaw));
gst_object_destroy(GST_OBJECT(mulawdec));
- gst_object_destroy(GST_OBJECT(disksrc));
+ gst_object_destroy(GST_OBJECT(filesrc));
gst_object_destroy(GST_OBJECT(bin));
exit(0);
GstElement *new_element;
GstAutoplug *autoplug;
GstElement *autobin;
- GstElement *disksrc;
+ GstElement *filesrc;
GstElement *cache;
GST_DEBUG (0,"GstPipeline: play have type\n");
gst_element_set_state (pipeline, GST_STATE_PAUSED);
- disksrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
+ filesrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
autobin = gst_bin_get_by_name (GST_BIN (pipeline), "autobin");
cache = gst_bin_get_by_name (GST_BIN (autobin), "cache");
gst_play_cache_empty (GstElement *element, GstElement *pipeline)
{
GstElement *autobin;
- GstElement *disksrc;
+ GstElement *filesrc;
GstElement *cache;
GstElement *new_element;
gst_element_set_state (pipeline, GST_STATE_PAUSED);
- disksrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
+ filesrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
autobin = gst_bin_get_by_name (GST_BIN (pipeline), "autobin");
cache = gst_bin_get_by_name (GST_BIN (autobin), "cache");
new_element = gst_bin_get_by_name (GST_BIN (autobin), "new_element");
- gst_element_disconnect (disksrc, "src", cache, "sink");
+ gst_element_disconnect (filesrc, "src", cache, "sink");
gst_element_disconnect (cache, "src", new_element, "sink");
gst_bin_remove (GST_BIN (autobin), cache);
- gst_element_connect (disksrc, "src", new_element, "sink");
+ gst_element_connect (filesrc, "src", new_element, "sink");
gst_element_set_state (pipeline, GST_STATE_PLAYING);
int
main (int argc, char *argv[])
{
- GstElement *disksrc;
+ GstElement *filesrc;
GstElement *pipeline;
GstElement *autobin;
GstElement *typefind;
g_assert (pipeline != NULL);
/* create a disk reader */
- disksrc = gst_elementfactory_make ("disksrc", "disk_source");
- g_assert (disksrc != NULL);
- g_object_set (G_OBJECT (disksrc), "location", argv[1], NULL);
- gst_bin_add (GST_BIN (pipeline), disksrc);
+ filesrc = gst_elementfactory_make ("filesrc", "disk_source");
+ g_assert (filesrc != NULL);
+ g_object_set (G_OBJECT (filesrc), "location", argv[1], NULL);
+ gst_bin_add (GST_BIN (pipeline), filesrc);
autobin = gst_bin_new ("autobin");
cache = gst_elementfactory_make ("autoplugcache", "cache");
gst_element_add_ghost_pad (autobin, gst_element_get_pad (cache, "sink"), "sink");
gst_bin_add (GST_BIN( pipeline), autobin);
- gst_element_connect (disksrc, "src", autobin, "sink");
+ gst_element_connect (filesrc, "src", autobin, "sink");
/* start playing */
gst_element_set_state( GST_ELEMENT (pipeline), GST_STATE_PLAYING);
main (int argc, char *argv[])
{
GstElement *pipeline;
- GstElement *disksrc;
+ GstElement *filesrc;
gst_init (&argc, &argv);
}
pipeline = gst_pipeline_new ("my_pipeline");
- gst_parse_launch ("disksrc[my_disksrc] ! mp3parse ! mpg123 ! osssink", GST_BIN (pipeline));
+ gst_parse_launch ("filesrc[my_filesrc] ! mp3parse ! mpg123 ! osssink", GST_BIN (pipeline));
- disksrc = gst_bin_get_by_name (GST_BIN (pipeline), "my_disksrc");
- g_object_set (G_OBJECT (disksrc), "location", argv[1], NULL);
+ filesrc = gst_bin_get_by_name (GST_BIN (pipeline), "my_filesrc");
+ g_object_set (G_OBJECT (filesrc), "location", argv[1], NULL);
gst_element_set_state (pipeline, GST_STATE_PLAYING);
/* create elements */
- GST_DEBUG(0, "c_i_p : creating disksrc\n");
+ GST_DEBUG(0, "c_i_p : creating filesrc\n");
- sprintf (buffer, "disksrc%d", id);
- channel->disksrc = gst_elementfactory_make ("disksrc", buffer);
- g_assert(channel->disksrc != NULL);
+ sprintf (buffer, "filesrc%d", id);
+ channel->filesrc = gst_elementfactory_make ("filesrc", buffer);
+ g_assert(channel->filesrc != NULL);
GST_DEBUG(0, "c_i_p : setting location\n");
- g_object_set(G_OBJECT(channel->disksrc),"location", location, NULL);
+ g_object_set(G_OBJECT(channel->filesrc),"location", location, NULL);
- /* add disksrc to the bin before autoplug */
- gst_bin_add(GST_BIN(channel->pipe), channel->disksrc);
+ /* add filesrc to the bin before autoplug */
+ gst_bin_add(GST_BIN(channel->pipe), channel->filesrc);
- /* connect signal to eos of disksrc */
- g_signal_connect (G_OBJECT(channel->disksrc),"eos",
+ /* connect signal to eos of filesrc */
+ g_signal_connect (G_OBJECT(channel->filesrc),"eos",
G_CALLBACK(eos),NULL);
#endif
#ifdef WITH_BUG
- srccaps = gst_play_typefind (GST_BIN (channel->pipe), channel->disksrc);
+ srccaps = gst_play_typefind (GST_BIN (channel->pipe), channel->filesrc);
#endif
#ifdef WITH_BUG2
{
gst_bin_add (GST_BIN(channel->pipe), channel->volenv);
gst_bin_add (GST_BIN (channel->pipe), new_element);
- gst_element_connect (channel->disksrc, "src", new_element, "sink");
+ gst_element_connect (channel->filesrc, "src", new_element, "sink");
gst_element_connect (new_element, "src_00", channel->volenv, "sink");
/* add a ghost pad */
typedef struct
{
- GstElement *pipe, *disksrc, *volenv;
+ GstElement *pipe, *filesrc, *volenv;
char *location;
int channel_id;
int main(int argc,char *argv[])
{
- GstElement *disksrc, *osssink, *parse, *decode, *queue;
+ GstElement *filesrc, *osssink, *parse, *decode, *queue;
GstElement *bin;
GstElement *thread;
g_assert(bin != NULL);
/* create a disk reader */
- disksrc = gst_elementfactory_make("disksrc", "disk_source");
- g_assert(disksrc != NULL);
- g_object_set(G_OBJECT(disksrc),"location", argv[1],NULL);
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_assert(filesrc != NULL);
+ g_object_set(G_OBJECT(filesrc),"location", argv[1],NULL);
parse = gst_elementfactory_make("mp3parse", "parse");
decode = gst_elementfactory_make("mpg123", "decode");
g_assert(osssink != NULL);
/* add objects to the main pipeline */
- gst_bin_add(GST_BIN(bin), disksrc);
+ gst_bin_add(GST_BIN(bin), filesrc);
gst_bin_add(GST_BIN(bin), parse);
gst_bin_add(GST_BIN(bin), decode);
gst_bin_add(GST_BIN(bin), queue);
gst_bin_add(GST_BIN(bin), thread);
- gst_pad_connect(gst_element_get_pad(disksrc,"src"),
+ gst_pad_connect(gst_element_get_pad(filesrc,"src"),
gst_element_get_pad(parse,"sink"));
gst_pad_connect(gst_element_get_pad(parse,"src"),
gst_element_get_pad(decode,"sink"));
int main(int argc,char *argv[])
{
- GstElement *disksrc, *osssink, *queue;
+ GstElement *filesrc, *osssink, *queue;
GstElement *pipeline;
GstElement *thread;
g_assert(pipeline != NULL);
/* create a disk reader */
- disksrc = gst_elementfactory_make("disksrc", "disk_source");
- g_assert(disksrc != NULL);
- g_object_set(G_OBJECT(disksrc),"location", argv[1],NULL);
- g_signal_connect (G_OBJECT(disksrc),"eos",
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_assert(filesrc != NULL);
+ g_object_set(G_OBJECT(filesrc),"location", argv[1],NULL);
+ g_signal_connect (G_OBJECT(filesrc),"eos",
G_CALLBACK(eos), thread);
queue = gst_elementfactory_make("queue", "queue");
/* add objects to the main pipeline */
/*
- gst_pipeline_add_src(GST_PIPELINE(pipeline), disksrc);
+ gst_pipeline_add_src(GST_PIPELINE(pipeline), filesrc);
gst_pipeline_add_sink(GST_PIPELINE(pipeline), queue);
gst_bin_add(GST_BIN(thread), osssink);
int main(int argc,char *argv[])
{
- GstElement *disksrc, *osssink, *queue, *parse, *decode;
+ GstElement *filesrc, *osssink, *queue, *parse, *decode;
GstElement *bin;
GstElement *thread;
g_assert(bin != NULL);
/* create a disk reader */
- disksrc = gst_elementfactory_make("disksrc", "disk_source");
- g_assert(disksrc != NULL);
- g_object_set(G_OBJECT(disksrc),"location", argv[1],NULL);
- g_signal_connect(G_OBJECT(disksrc),"eos",
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_assert(filesrc != NULL);
+ g_object_set(G_OBJECT(filesrc),"location", argv[1],NULL);
+ g_signal_connect(G_OBJECT(filesrc),"eos",
G_CALLBACK(eos), thread);
queue = gst_elementfactory_make("queue", "queue");
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), filesrc);
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), osssink);
- gst_pad_connect(gst_element_get_pad(disksrc,"src"),
+ gst_pad_connect(gst_element_get_pad(filesrc,"src"),
gst_element_get_pad(queue,"sink"));
gst_pad_connect(gst_element_get_pad(queue,"src"),
int main(int argc,char *argv[])
{
- GstElement *disksrc, *osssink, *queue, *queue2, *parse, *decode;
+ GstElement *filesrc, *osssink, *queue, *queue2, *parse, *decode;
GstElement *bin;
GstElement *thread, *thread2;
g_assert(bin != NULL);
/* create a disk reader */
- disksrc = gst_elementfactory_make("disksrc", "disk_source");
- g_assert(disksrc != NULL);
- g_object_set(G_OBJECT(disksrc),"location", argv[1],NULL);
- g_signal_connect(G_OBJECT(disksrc),"eos",
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_assert(filesrc != NULL);
+ g_object_set(G_OBJECT(filesrc),"location", argv[1],NULL);
+ g_signal_connect(G_OBJECT(filesrc),"eos",
G_CALLBACK(eos), thread);
queue = gst_elementfactory_make("queue", "queue");
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), filesrc);
gst_bin_add(GST_BIN(bin), queue);
gst_bin_add(GST_BIN(thread), parse);
gst_bin_add(GST_BIN(thread2), osssink);
- gst_pad_connect(gst_element_get_pad(disksrc,"src"),
+ gst_pad_connect(gst_element_get_pad(filesrc,"src"),
gst_element_get_pad(queue,"sink"));
gst_pad_connect(gst_element_get_pad(queue,"src"),
int main(int argc,char *argv[])
{
- GstElement *disksrc, *osssink;
+ GstElement *filesrc, *osssink;
GstElement *pipeline;
GstElement *thread;
g_assert(pipeline != NULL);
/* create a disk reader */
- disksrc = gst_elementfactory_make("disksrc", "disk_source");
- g_assert(disksrc != NULL);
- g_object_set(G_OBJECT(disksrc),"location", argv[1],NULL);
- g_signal_connect(G_OBJECT(disksrc),"eos",
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_assert(filesrc != NULL);
+ g_object_set(G_OBJECT(filesrc),"location", argv[1],NULL);
+ g_signal_connect(G_OBJECT(filesrc),"eos",
G_CALLBACK(eos), thread);
/* and an audio sink */
/* add objects to the main pipeline */
/*
- gst_pipeline_add_src(GST_PIPELINE(pipeline), disksrc);
+ gst_pipeline_add_src(GST_PIPELINE(pipeline), filesrc);
gst_pipeline_add_sink(GST_PIPELINE(pipeline), osssink);
if (!gst_pipeline_autoplug(GST_PIPELINE(pipeline))) {
}
*/
- //gst_bin_remove(GST_BIN(pipeline), disksrc);
+ //gst_bin_remove(GST_BIN(pipeline), filesrc);
- //gst_bin_add(GST_BIN(thread), disksrc);
+ //gst_bin_add(GST_BIN(thread), filesrc);
gst_bin_add(GST_BIN(thread), GST_ELEMENT(pipeline));
/* make it ready */
int main(int argc,char *argv[])
{
- GstElement *disksrc, *osssink, *queue, *queue2, *parse, *decode;
+ GstElement *filesrc, *osssink, *queue, *queue2, *parse, *decode;
GstElement *bin;
GstElement *thread, *thread2;
g_assert(bin != NULL);
/* create a disk reader */
- disksrc = gst_elementfactory_make("disksrc", "disk_source");
- g_assert(disksrc != NULL);
- g_object_set(G_OBJECT(disksrc),"location", argv[1],NULL);
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_assert(filesrc != NULL);
+ g_object_set(G_OBJECT(filesrc),"location", argv[1],NULL);
queue = gst_elementfactory_make("queue", "queue");
queue2 = gst_elementfactory_make("queue", "queue2");
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), filesrc);
gst_bin_add(GST_BIN(bin), queue);
gst_bin_add(GST_BIN(thread), parse);
gst_bin_add(GST_BIN(thread2), osssink);
- gst_pad_connect(gst_element_get_pad(disksrc,"src"),
+ gst_pad_connect(gst_element_get_pad(filesrc,"src"),
gst_element_get_pad(queue,"sink"));
gst_pad_connect(gst_element_get_pad(queue,"src"),
GstAutoplug *autoplug;
GtkWidget *socket;
GstElement *autobin;
- GstElement *disksrc;
+ GstElement *filesrc;
GstElement *cache;
GST_DEBUG (0,"GstPipeline: play have type\n");
gst_element_set_state (pipeline, GST_STATE_PAUSED);
- disksrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
+ filesrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
autobin = gst_bin_get_by_name (GST_BIN (pipeline), "autobin");
cache = gst_bin_get_by_name (GST_BIN (autobin), "cache");
gst_play_cache_empty (GstElement *element, GstElement *pipeline)
{
GstElement *autobin;
- GstElement *disksrc;
+ GstElement *filesrc;
GstElement *cache;
GstElement *new_element;
gst_element_set_state (pipeline, GST_STATE_PAUSED);
- disksrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
+ filesrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
autobin = gst_bin_get_by_name (GST_BIN (pipeline), "autobin");
cache = gst_bin_get_by_name (GST_BIN (autobin), "cache");
new_element = gst_bin_get_by_name (GST_BIN (autobin), "new_element");
- gst_element_disconnect (disksrc, "src", cache, "sink");
+ gst_element_disconnect (filesrc, "src", cache, "sink");
gst_element_disconnect (cache, "src", new_element, "sink");
gst_bin_remove (GST_BIN (autobin), cache);
- gst_element_connect (disksrc, "src", new_element, "sink");
+ gst_element_connect (filesrc, "src", new_element, "sink");
gst_element_set_state (pipeline, GST_STATE_PLAYING);
int main(int argc,char *argv[])
{
- GstElement *disksrc;
+ GstElement *filesrc;
GstElement *pipeline;
GstElement *autobin;
GstElement *typefind;
g_assert(pipeline != 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);
- gst_bin_add (GST_BIN (pipeline), disksrc);
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_assert(filesrc != NULL);
+ gtk_object_set(GTK_OBJECT(filesrc),"location", argv[1],NULL);
+ gst_bin_add (GST_BIN (pipeline), filesrc);
autobin = gst_bin_new ("autobin");
cache = gst_elementfactory_make ("autoplugcache", "cache");
gst_element_add_ghost_pad (autobin, gst_element_get_pad (cache, "sink"), "sink");
gst_bin_add (GST_BIN( pipeline), autobin);
- gst_element_connect (disksrc, "src", autobin, "sink");
+ gst_element_connect (filesrc, "src", autobin, "sink");
/* start playing */
gst_element_set_state( GST_ELEMENT (pipeline), GST_STATE_PLAYING);
int main(int argc,char *argv[])
{
- GstElement *bin, *disksrc, *parse, *decoder, *downmix, *mulaw, *mulawdec, *osssink;
+ GstElement *bin, *filesrc, *parse, *decoder, *downmix, *mulaw, *mulawdec, *osssink;
gst_init(&argc,&argv);
bin = gst_pipeline_new("pipeline");
/* create a disk reader */
- disksrc = gst_elementfactory_make("disksrc", "disk_source");
- g_object_set(G_OBJECT(disksrc),"location", argv[1],NULL);
- g_signal_connect(G_OBJECT(disksrc),"eos",
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_object_set(G_OBJECT(filesrc),"location", argv[1],NULL);
+ g_signal_connect(G_OBJECT(filesrc),"eos",
G_CALLBACK(eos),NULL);
/* now it's time to get the parser */
osssink = gst_elementfactory_make("osssink", "play_audio");
/* add objects to the main pipeline */
- gst_bin_add(GST_BIN(bin), disksrc);
+ gst_bin_add(GST_BIN(bin), filesrc);
gst_bin_add(GST_BIN(bin), parse);
gst_bin_add(GST_BIN(bin), decoder);
gst_bin_add(GST_BIN(bin), downmix);
gst_bin_add(GST_BIN(bin), osssink);
/* connect src to sink */
- gst_pad_connect(gst_element_get_pad(disksrc,"src"),
+ gst_pad_connect(gst_element_get_pad(filesrc,"src"),
gst_element_get_pad(parse,"sink"));
gst_pad_connect(gst_element_get_pad(parse,"src"),
gst_element_get_pad(decoder,"sink"));
gst_object_destroy(GST_OBJECT(downmix));
gst_object_destroy(GST_OBJECT(mulaw));
gst_object_destroy(GST_OBJECT(mulawdec));
- gst_object_destroy(GST_OBJECT(disksrc));
+ gst_object_destroy(GST_OBJECT(filesrc));
gst_object_destroy(GST_OBJECT(bin));
exit(0);
GstElement *new_element;
GstAutoplug *autoplug;
GstElement *autobin;
- GstElement *disksrc;
+ GstElement *filesrc;
GstElement *cache;
GST_DEBUG (0,"GstPipeline: play have type\n");
gst_element_set_state (pipeline, GST_STATE_PAUSED);
- disksrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
+ filesrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
autobin = gst_bin_get_by_name (GST_BIN (pipeline), "autobin");
cache = gst_bin_get_by_name (GST_BIN (autobin), "cache");
gst_play_cache_empty (GstElement *element, GstElement *pipeline)
{
GstElement *autobin;
- GstElement *disksrc;
+ GstElement *filesrc;
GstElement *cache;
GstElement *new_element;
gst_element_set_state (pipeline, GST_STATE_PAUSED);
- disksrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
+ filesrc = gst_bin_get_by_name (GST_BIN (pipeline), "disk_source");
autobin = gst_bin_get_by_name (GST_BIN (pipeline), "autobin");
cache = gst_bin_get_by_name (GST_BIN (autobin), "cache");
new_element = gst_bin_get_by_name (GST_BIN (autobin), "new_element");
- gst_element_disconnect (disksrc, "src", cache, "sink");
+ gst_element_disconnect (filesrc, "src", cache, "sink");
gst_element_disconnect (cache, "src", new_element, "sink");
gst_bin_remove (GST_BIN (autobin), cache);
- gst_element_connect (disksrc, "src", new_element, "sink");
+ gst_element_connect (filesrc, "src", new_element, "sink");
gst_element_set_state (pipeline, GST_STATE_PLAYING);
int
main (int argc, char *argv[])
{
- GstElement *disksrc;
+ GstElement *filesrc;
GstElement *pipeline;
GstElement *autobin;
GstElement *typefind;
g_assert (pipeline != NULL);
/* create a disk reader */
- disksrc = gst_elementfactory_make ("disksrc", "disk_source");
- g_assert (disksrc != NULL);
- g_object_set (G_OBJECT (disksrc), "location", argv[1], NULL);
- gst_bin_add (GST_BIN (pipeline), disksrc);
+ filesrc = gst_elementfactory_make ("filesrc", "disk_source");
+ g_assert (filesrc != NULL);
+ g_object_set (G_OBJECT (filesrc), "location", argv[1], NULL);
+ gst_bin_add (GST_BIN (pipeline), filesrc);
autobin = gst_bin_new ("autobin");
cache = gst_elementfactory_make ("autoplugcache", "cache");
gst_element_add_ghost_pad (autobin, gst_element_get_pad (cache, "sink"), "sink");
gst_bin_add (GST_BIN( pipeline), autobin);
- gst_element_connect (disksrc, "src", autobin, "sink");
+ gst_element_connect (filesrc, "src", autobin, "sink");
/* start playing */
gst_element_set_state( GST_ELEMENT (pipeline), GST_STATE_PLAYING);
main (int argc, char *argv[])
{
GstElement *pipeline;
- GstElement *disksrc;
+ GstElement *filesrc;
gst_init (&argc, &argv);
}
pipeline = gst_pipeline_new ("my_pipeline");
- gst_parse_launch ("disksrc[my_disksrc] ! mp3parse ! mpg123 ! osssink", GST_BIN (pipeline));
+ gst_parse_launch ("filesrc[my_filesrc] ! mp3parse ! mpg123 ! osssink", GST_BIN (pipeline));
- disksrc = gst_bin_get_by_name (GST_BIN (pipeline), "my_disksrc");
- g_object_set (G_OBJECT (disksrc), "location", argv[1], NULL);
+ filesrc = gst_bin_get_by_name (GST_BIN (pipeline), "my_filesrc");
+ g_object_set (G_OBJECT (filesrc), "location", argv[1], NULL);
gst_element_set_state (pipeline, GST_STATE_PLAYING);
/* create elements */
- GST_DEBUG(0, "c_i_p : creating disksrc\n");
+ GST_DEBUG(0, "c_i_p : creating filesrc\n");
- sprintf (buffer, "disksrc%d", id);
- channel->disksrc = gst_elementfactory_make ("disksrc", buffer);
- g_assert(channel->disksrc != NULL);
+ sprintf (buffer, "filesrc%d", id);
+ channel->filesrc = gst_elementfactory_make ("filesrc", buffer);
+ g_assert(channel->filesrc != NULL);
GST_DEBUG(0, "c_i_p : setting location\n");
- g_object_set(G_OBJECT(channel->disksrc),"location", location, NULL);
+ g_object_set(G_OBJECT(channel->filesrc),"location", location, NULL);
- /* add disksrc to the bin before autoplug */
- gst_bin_add(GST_BIN(channel->pipe), channel->disksrc);
+ /* add filesrc to the bin before autoplug */
+ gst_bin_add(GST_BIN(channel->pipe), channel->filesrc);
- /* connect signal to eos of disksrc */
- g_signal_connect (G_OBJECT(channel->disksrc),"eos",
+ /* connect signal to eos of filesrc */
+ g_signal_connect (G_OBJECT(channel->filesrc),"eos",
G_CALLBACK(eos),NULL);
#endif
#ifdef WITH_BUG
- srccaps = gst_play_typefind (GST_BIN (channel->pipe), channel->disksrc);
+ srccaps = gst_play_typefind (GST_BIN (channel->pipe), channel->filesrc);
#endif
#ifdef WITH_BUG2
{
gst_bin_add (GST_BIN(channel->pipe), channel->volenv);
gst_bin_add (GST_BIN (channel->pipe), new_element);
- gst_element_connect (channel->disksrc, "src", new_element, "sink");
+ gst_element_connect (channel->filesrc, "src", new_element, "sink");
gst_element_connect (new_element, "src_00", channel->volenv, "sink");
/* add a ghost pad */
typedef struct
{
- GstElement *pipe, *disksrc, *volenv;
+ GstElement *pipe, *filesrc, *volenv;
char *location;
int channel_id;
int main(int argc,char *argv[])
{
- GstElement *disksrc, *osssink, *parse, *decode, *queue;
+ GstElement *filesrc, *osssink, *parse, *decode, *queue;
GstElement *bin;
GstElement *thread;
g_assert(bin != NULL);
/* create a disk reader */
- disksrc = gst_elementfactory_make("disksrc", "disk_source");
- g_assert(disksrc != NULL);
- g_object_set(G_OBJECT(disksrc),"location", argv[1],NULL);
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_assert(filesrc != NULL);
+ g_object_set(G_OBJECT(filesrc),"location", argv[1],NULL);
parse = gst_elementfactory_make("mp3parse", "parse");
decode = gst_elementfactory_make("mpg123", "decode");
g_assert(osssink != NULL);
/* add objects to the main pipeline */
- gst_bin_add(GST_BIN(bin), disksrc);
+ gst_bin_add(GST_BIN(bin), filesrc);
gst_bin_add(GST_BIN(bin), parse);
gst_bin_add(GST_BIN(bin), decode);
gst_bin_add(GST_BIN(bin), queue);
gst_bin_add(GST_BIN(bin), thread);
- gst_pad_connect(gst_element_get_pad(disksrc,"src"),
+ gst_pad_connect(gst_element_get_pad(filesrc,"src"),
gst_element_get_pad(parse,"sink"));
gst_pad_connect(gst_element_get_pad(parse,"src"),
gst_element_get_pad(decode,"sink"));
int main(int argc,char *argv[])
{
- GstElement *disksrc, *osssink, *queue;
+ GstElement *filesrc, *osssink, *queue;
GstElement *pipeline;
GstElement *thread;
g_assert(pipeline != NULL);
/* create a disk reader */
- disksrc = gst_elementfactory_make("disksrc", "disk_source");
- g_assert(disksrc != NULL);
- g_object_set(G_OBJECT(disksrc),"location", argv[1],NULL);
- g_signal_connect (G_OBJECT(disksrc),"eos",
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_assert(filesrc != NULL);
+ g_object_set(G_OBJECT(filesrc),"location", argv[1],NULL);
+ g_signal_connect (G_OBJECT(filesrc),"eos",
G_CALLBACK(eos), thread);
queue = gst_elementfactory_make("queue", "queue");
/* add objects to the main pipeline */
/*
- gst_pipeline_add_src(GST_PIPELINE(pipeline), disksrc);
+ gst_pipeline_add_src(GST_PIPELINE(pipeline), filesrc);
gst_pipeline_add_sink(GST_PIPELINE(pipeline), queue);
gst_bin_add(GST_BIN(thread), osssink);
int main(int argc,char *argv[])
{
- GstElement *disksrc, *osssink, *queue, *parse, *decode;
+ GstElement *filesrc, *osssink, *queue, *parse, *decode;
GstElement *bin;
GstElement *thread;
g_assert(bin != NULL);
/* create a disk reader */
- disksrc = gst_elementfactory_make("disksrc", "disk_source");
- g_assert(disksrc != NULL);
- g_object_set(G_OBJECT(disksrc),"location", argv[1],NULL);
- g_signal_connect(G_OBJECT(disksrc),"eos",
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_assert(filesrc != NULL);
+ g_object_set(G_OBJECT(filesrc),"location", argv[1],NULL);
+ g_signal_connect(G_OBJECT(filesrc),"eos",
G_CALLBACK(eos), thread);
queue = gst_elementfactory_make("queue", "queue");
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), filesrc);
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), osssink);
- gst_pad_connect(gst_element_get_pad(disksrc,"src"),
+ gst_pad_connect(gst_element_get_pad(filesrc,"src"),
gst_element_get_pad(queue,"sink"));
gst_pad_connect(gst_element_get_pad(queue,"src"),
int main(int argc,char *argv[])
{
- GstElement *disksrc, *osssink, *queue, *queue2, *parse, *decode;
+ GstElement *filesrc, *osssink, *queue, *queue2, *parse, *decode;
GstElement *bin;
GstElement *thread, *thread2;
g_assert(bin != NULL);
/* create a disk reader */
- disksrc = gst_elementfactory_make("disksrc", "disk_source");
- g_assert(disksrc != NULL);
- g_object_set(G_OBJECT(disksrc),"location", argv[1],NULL);
- g_signal_connect(G_OBJECT(disksrc),"eos",
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_assert(filesrc != NULL);
+ g_object_set(G_OBJECT(filesrc),"location", argv[1],NULL);
+ g_signal_connect(G_OBJECT(filesrc),"eos",
G_CALLBACK(eos), thread);
queue = gst_elementfactory_make("queue", "queue");
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), filesrc);
gst_bin_add(GST_BIN(bin), queue);
gst_bin_add(GST_BIN(thread), parse);
gst_bin_add(GST_BIN(thread2), osssink);
- gst_pad_connect(gst_element_get_pad(disksrc,"src"),
+ gst_pad_connect(gst_element_get_pad(filesrc,"src"),
gst_element_get_pad(queue,"sink"));
gst_pad_connect(gst_element_get_pad(queue,"src"),
int main(int argc,char *argv[])
{
- GstElement *disksrc, *osssink;
+ GstElement *filesrc, *osssink;
GstElement *pipeline;
GstElement *thread;
g_assert(pipeline != NULL);
/* create a disk reader */
- disksrc = gst_elementfactory_make("disksrc", "disk_source");
- g_assert(disksrc != NULL);
- g_object_set(G_OBJECT(disksrc),"location", argv[1],NULL);
- g_signal_connect(G_OBJECT(disksrc),"eos",
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_assert(filesrc != NULL);
+ g_object_set(G_OBJECT(filesrc),"location", argv[1],NULL);
+ g_signal_connect(G_OBJECT(filesrc),"eos",
G_CALLBACK(eos), thread);
/* and an audio sink */
/* add objects to the main pipeline */
/*
- gst_pipeline_add_src(GST_PIPELINE(pipeline), disksrc);
+ gst_pipeline_add_src(GST_PIPELINE(pipeline), filesrc);
gst_pipeline_add_sink(GST_PIPELINE(pipeline), osssink);
if (!gst_pipeline_autoplug(GST_PIPELINE(pipeline))) {
}
*/
- //gst_bin_remove(GST_BIN(pipeline), disksrc);
+ //gst_bin_remove(GST_BIN(pipeline), filesrc);
- //gst_bin_add(GST_BIN(thread), disksrc);
+ //gst_bin_add(GST_BIN(thread), filesrc);
gst_bin_add(GST_BIN(thread), GST_ELEMENT(pipeline));
/* make it ready */
int main(int argc,char *argv[])
{
- GstElement *disksrc, *osssink, *queue, *queue2, *parse, *decode;
+ GstElement *filesrc, *osssink, *queue, *queue2, *parse, *decode;
GstElement *bin;
GstElement *thread, *thread2;
g_assert(bin != NULL);
/* create a disk reader */
- disksrc = gst_elementfactory_make("disksrc", "disk_source");
- g_assert(disksrc != NULL);
- g_object_set(G_OBJECT(disksrc),"location", argv[1],NULL);
+ filesrc = gst_elementfactory_make("filesrc", "disk_source");
+ g_assert(filesrc != NULL);
+ g_object_set(G_OBJECT(filesrc),"location", argv[1],NULL);
queue = gst_elementfactory_make("queue", "queue");
queue2 = gst_elementfactory_make("queue", "queue2");
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), filesrc);
gst_bin_add(GST_BIN(bin), queue);
gst_bin_add(GST_BIN(thread), parse);
gst_bin_add(GST_BIN(thread2), osssink);
- gst_pad_connect(gst_element_get_pad(disksrc,"src"),
+ gst_pad_connect(gst_element_get_pad(filesrc,"src"),
gst_element_get_pad(queue,"sink"));
gst_pad_connect(gst_element_get_pad(queue,"src"),