gstplay/mpeg2.c

   1
   2 #define BUFFER 20
   3 #define VIDEO_DECODER "mpeg2play"
   4
   5 #ifdef HAVE_CONFIG_H
   6 #  include <config.h>
   7 #endif
   8
   9 #include <gnome.h>
  10 #include <gst/gst.h>
  11
  12 #include "codecs.h"
  13
  14
  15 extern gboolean _gst_plugin_spew;
  16 extern GstElement *video_render_queue, *audio_render_queue;
  17
  18 void mpeg2_new_pad_created(GstElement *parse,GstPad *pad,GstElement *pipeline)
  19 {
  20   GstElement *parse_audio, *decode;
  21   GstElement *audio_queue;
  22   GstElement *audio_thread;
  23
  24   g_print("***** a new pad %s was created\n", gst_pad_get_name(pad));
  25
  26   // connect to audio pad
  27   if (strncmp(gst_pad_get_name(pad), "video_", 6) == 0) {
  28     mpeg2_setup_video_thread(pad, video_render_queue, pipeline);
  29     return;
  30   }
  31   else if (strncmp(gst_pad_get_name(pad), "private_stream_1.0", 18) == 0) {
  32     gst_plugin_load("ac3parse");
  33     gst_plugin_load("ac3dec");
  34     // construct internal pipeline elements
  35     parse_audio = gst_elementfactory_make("ac3parse","parse_audio");
  36     g_return_if_fail(parse_audio != NULL);
  37     decode = gst_elementfactory_make("ac3dec","decode_audio");
  38     g_return_if_fail(decode != NULL);
  39   }
  40   else if (strncmp(gst_pad_get_name(pad), "audio_", 6) == 0) {
  41     gst_plugin_load("mp3parse");
  42     gst_plugin_load("mpg123");
  43     // construct internal pipeline elements
  44     parse_audio = gst_elementfactory_make("mp3parse","parse_audio");
  45     g_return_if_fail(parse_audio != NULL);
  46     decode = gst_elementfactory_make("mpg123","decode_audio");
  47     g_return_if_fail(decode != NULL);
  48   }
  49   else return;
  50
  51   // create the thread and pack stuff into it
  52   audio_thread = gst_thread_new("audio_thread");
  53   g_return_if_fail(audio_thread != NULL);
  54   gst_bin_add(GST_BIN(audio_thread),GST_ELEMENT(parse_audio));
  55   gst_bin_add(GST_BIN(audio_thread),GST_ELEMENT(decode));
  56
  57   // set up pad connections
  58   gst_element_add_ghost_pad(GST_ELEMENT(audio_thread),
  59                             gst_element_get_pad(parse_audio,"sink"));
  60   gst_pad_connect(gst_element_get_pad(parse_audio,"src"),
  61                   gst_element_get_pad(decode,"sink"));
  62   gst_pad_connect(gst_element_get_pad(decode,"src"),
  63                   gst_element_get_pad(audio_render_queue,"sink"));
  64
  65   // construct queue and connect everything in the main pipelie
  66   audio_queue = gst_elementfactory_make("queue","audio_queue");
  67   gtk_object_set(GTK_OBJECT(audio_queue),"max_level",30,NULL);
  68   gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(audio_queue));
  69   gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(audio_thread));
  70   gst_pad_connect(pad,
  71                   gst_element_get_pad(audio_queue,"sink"));
  72   gst_pad_connect(gst_element_get_pad(audio_queue,"src"),
  73                   gst_element_get_pad(audio_thread,"sink"));
  74
  75   // set up thread state and kick things off
  76   gtk_object_set(GTK_OBJECT(audio_thread),"create_thread",TRUE,NULL);
  77   g_print("setting to RUNNING state\n");
  78   gst_element_set_state(GST_ELEMENT(audio_thread),GST_STATE_RUNNING);
  79   g_print("setting to PLAYING state\n");
  80   gst_element_set_state(GST_ELEMENT(audio_thread),GST_STATE_PLAYING);
  81
  82   gst_element_set_state(GST_ELEMENT(pipeline),GST_STATE_PLAYING);
  83 }
  84
  85 void mpeg2_setup_video_thread(GstPad *pad, GstElement *show, GstElement *pipeline)
  86 {
  87   GstElement *parse_video, *decode_video;
  88   GstElement *video_queue;
  89   GstElement *video_thread;
  90
  91   gst_plugin_load("mp1videoparse");
  92   gst_plugin_load(VIDEO_DECODER);
  93   // construct internal pipeline elements
  94   parse_video = gst_elementfactory_make("mp1videoparse","parse_video");
  95   g_return_if_fail(parse_video != NULL);
  96   decode_video = gst_elementfactory_make(VIDEO_DECODER,"decode_video");
  97   g_return_if_fail(decode_video != NULL);
  98
  99   // create the thread and pack stuff into it
 100   video_thread = gst_thread_new("video_thread");
 101   g_return_if_fail(video_thread != NULL);
 102   gst_bin_add(GST_BIN(video_thread),GST_ELEMENT(parse_video));
 103   gst_bin_add(GST_BIN(video_thread),GST_ELEMENT(decode_video));
 104
 105   // set up pad connections
 106   gst_element_add_ghost_pad(GST_ELEMENT(video_thread),
 107                             gst_element_get_pad(parse_video,"sink"));
 108   gst_pad_connect(gst_element_get_pad(parse_video,"src"),
 109                   gst_element_get_pad(decode_video,"sink"));
 110   gst_pad_connect(gst_element_get_pad(decode_video,"src"),
 111                   gst_element_get_pad(video_render_queue,"sink"));
 112
 113   // construct queue and connect everything in the main pipeline
 114   video_queue = gst_elementfactory_make("queue","video_queue");
 115   gtk_object_set(GTK_OBJECT(video_queue),"max_level",BUFFER,NULL);
 116   gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(video_queue));
 117   gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(video_thread));
 118   gst_pad_connect(pad,
 119                   gst_element_get_pad(video_queue,"sink"));
 120   gst_pad_connect(gst_element_get_pad(video_queue,"src"),
 121                   gst_element_get_pad(video_thread,"sink"));
 122
 123   // set up thread state and kick things off
 124   gtk_object_set(GTK_OBJECT(video_thread),"create_thread",TRUE,NULL);
 125   g_print("setting to RUNNING state\n");
 126   gst_element_set_state(GST_ELEMENT(video_thread),GST_STATE_RUNNING);
 127   gst_element_set_state(GST_ELEMENT(video_thread),GST_STATE_PLAYING);
 128
 129   g_print("\n");
 130 }
 131