src/modules/gstreamer/emotion_gstreamer_pipeline_dvd.c

   1 /*
   2  * vim:ts=8:sw=3:sts=8:noexpandtab:cino=>5n-3f0^-2{2
   3  */
   4 #include "emotion_gstreamer.h"
   5 #include "emotion_gstreamer_pipeline.h"
   6
   7
   8 static void dvd_pad_added_cb    (GstElement *dvddemuxer,
   9                                  GObject    *new_pad,
  10                                  gpointer    user_data);
  11
  12 static void dvd_no_more_pads_cb (GstElement *dvddemuxer,
  13                                  gpointer    user_data);
  14
  15 static int no_more_pads = 0;
  16
  17
  18 int
  19 emotion_pipeline_dvd_build(void *video, const char *device)
  20 {
  21    GstElement              *dvdreadsrc;
  22    GstElement              *dvddemux;
  23    Emotion_Gstreamer_Video *ev;
  24    Eina_List               *alist;
  25    Eina_List               *vlist;
  26
  27    ev = (Emotion_Gstreamer_Video *)video;
  28    if (!ev) return 0;
  29
  30    dvdreadsrc = gst_element_factory_make("dvdreadsrc", "src");
  31    if (!dvdreadsrc)
  32      goto failure_dvdreadsrc;
  33    if (device)
  34      g_object_set(G_OBJECT(dvdreadsrc), "device", device, NULL);
  35
  36    dvddemux = gst_element_factory_make("dvddemux", "dvddemux");
  37    if (!dvddemux)
  38      goto failure_dvddemux;
  39    g_signal_connect(dvddemux, "pad-added",
  40                     G_CALLBACK(dvd_pad_added_cb), ev);
  41    g_signal_connect(dvddemux, "no-more-pads",
  42                     G_CALLBACK(dvd_no_more_pads_cb), ev);
  43
  44    gst_bin_add_many(GST_BIN(ev->pipeline), dvdreadsrc, dvddemux, NULL);
  45    if (!gst_element_link(dvdreadsrc, dvddemux))
  46      goto failure_link;
  47
  48    if (!emotion_pipeline_pause(ev->pipeline))
  49      goto failure_gstreamer_pause;
  50
  51    while (no_more_pads == 0)
  52      {
  53         g_print("toto\n");
  54      }
  55    no_more_pads = 0;
  56
  57    /* We get the informations of streams */
  58    alist = ev->audio_sinks;
  59    vlist = ev->video_sinks;
  60
  61      {
  62         GstIterator *it;
  63         gpointer     data;
  64
  65         it = gst_element_iterate_src_pads(dvddemux);
  66         while (gst_iterator_next(it, &data) == GST_ITERATOR_OK)
  67           {
  68              GstPad  *pad;
  69              GstCaps *caps;
  70              gchar   *str;
  71
  72              pad = GST_PAD(data);
  73
  74              caps = gst_pad_get_caps(pad);
  75              str = gst_caps_to_string(caps);
  76              g_print("caps !! %s\n", str);
  77              /* video stream */
  78              if (g_str_has_prefix(str, "video/mpeg"))
  79                {
  80                   Emotion_Video_Sink *vsink;
  81                   GstPad             *sink_pad;
  82                   GstCaps            *sink_caps;
  83
  84                   vsink = (Emotion_Video_Sink *)eina_list_data_get(vlist);
  85                   vlist = eina_list_next(vlist);
  86                   sink_pad = gst_element_get_pad(gst_bin_get_by_name(GST_BIN(ev->pipeline), "mpeg2dec"), "src");
  87                   sink_caps = gst_pad_get_caps(sink_pad);
  88                   str = gst_caps_to_string(sink_caps);
  89                   g_print(" ** caps v !! %s\n", str);
  90
  91                   emotion_video_sink_fill(vsink, sink_pad, sink_caps);
  92
  93                   gst_caps_unref(sink_caps);
  94                   gst_object_unref(sink_pad);
  95                }
  96              /* audio stream */
  97              else if (g_str_has_prefix(str, "audio/"))
  98                {
  99                   Emotion_Audio_Sink *asink;
 100                   GstPad             *sink_pad;
 101                   GstCaps            *sink_caps;
 102
 103                   asink = (Emotion_Audio_Sink *)eina_list_data_get(alist);
 104                   sink_pad = gst_element_get_pad(gst_bin_get_by_name(GST_BIN(ev->pipeline), "a52dec"), "src");
 105                   sink_caps = gst_pad_get_caps(sink_pad);
 106
 107                   emotion_audio_sink_fill(asink, sink_pad, sink_caps);
 108                }
 109              gst_caps_unref(caps);
 110              g_free(str);
 111              gst_object_unref(pad);
 112           }
 113         gst_iterator_free(it);
 114      }
 115
 116    /* The first vsink is a valid Emotion_Video_Sink * */
 117    /* If no video stream is found, it's a visualisation sink */
 118      {
 119         Emotion_Video_Sink *vsink;
 120
 121         vsink = (Emotion_Video_Sink *)eina_list_data_get(ev->video_sinks);
 122         if (vsink && vsink->sink)
 123           {
 124              g_object_set(G_OBJECT(vsink->sink), "sync", TRUE, NULL);
 125              g_object_set(G_OBJECT(vsink->sink), "signal-handoffs", TRUE, NULL);
 126              g_signal_connect(G_OBJECT(vsink->sink),
 127                               "handoff",
 128                               G_CALLBACK(cb_handoff), ev);
 129           }
 130      }
 131
 132    return 1;
 133
 134 failure_gstreamer_pause:
 135 failure_link:
 136    gst_element_set_state(ev->pipeline, GST_STATE_NULL);
 137    gst_bin_remove(GST_BIN(ev->pipeline), dvddemux);
 138 failure_dvddemux:
 139    gst_bin_remove(GST_BIN(ev->pipeline), dvdreadsrc);
 140 failure_dvdreadsrc:
 141
 142    return 0;
 143 }
 144
 145 static void
 146 dvd_pad_added_cb(GstElement *dvddemuxer,
 147                  GObject    *new_pad,
 148                  gpointer    user_data)
 149 {
 150    Emotion_Gstreamer_Video *ev;
 151    GstCaps                 *caps;
 152    gchar                   *str;
 153
 154    ev = (Emotion_Gstreamer_Video *)user_data;
 155    caps = gst_pad_get_caps(GST_PAD(new_pad));
 156    str = gst_caps_to_string(caps);
 157    /* video stream */
 158    if (g_str_has_prefix(str, "video/mpeg"))
 159      {
 160         Emotion_Video_Sink *vsink;
 161         GstElement         *queue;
 162         GstElement         *decoder;
 163         GstPad             *videopad;
 164
 165         vsink = (Emotion_Video_Sink *)malloc(sizeof(Emotion_Video_Sink));
 166         if (!vsink) return;
 167         ev->video_sinks = eina_list_append(ev->video_sinks, vsink);
 168         if (!eina_list_data_find(ev->video_sinks, vsink))
 169           {
 170              free(vsink);
 171              return;
 172           }
 173
 174         queue = gst_element_factory_make("queue", NULL);
 175         decoder = gst_element_factory_make("mpeg2dec", "mpeg2dec");
 176         vsink->sink = gst_element_factory_make("fakesink", "videosink");
 177         gst_bin_add_many(GST_BIN(ev->pipeline), queue, decoder, vsink->sink, NULL);
 178         gst_element_link(queue, decoder);
 179         gst_element_link(decoder, vsink->sink);
 180         videopad = gst_element_get_pad(queue, "sink");
 181         gst_pad_link(GST_PAD(new_pad), videopad);
 182         gst_object_unref(videopad);
 183         if (eina_list_count(ev->video_sinks) == 1)
 184           {
 185              ev->ratio = (double)vsink->width / (double)vsink->height;
 186           }
 187         gst_element_set_state(queue, GST_STATE_PAUSED);
 188         gst_element_set_state(decoder, GST_STATE_PAUSED);
 189         gst_element_set_state(vsink->sink, GST_STATE_PAUSED);
 190      }
 191    /* audio stream */
 192    else if (g_str_has_prefix(str, "audio/"))
 193      {
 194         Emotion_Audio_Sink *asink;
 195         GstElement         *queue;
 196         GstElement         *decoder;
 197         GstElement         *conv;
 198         GstElement         *resample;
 199         GstElement         *volume;
 200         GstPad             *audiopad;
 201         double              vol;
 202
 203         asink = (Emotion_Audio_Sink *)malloc(sizeof(Emotion_Audio_Sink));
 204         if (!asink) return;
 205         ev->audio_sinks = eina_list_append(ev->audio_sinks, asink);
 206         if (!eina_list_data_find(ev->audio_sinks, asink))
 207           {
 208              free(asink);
 209              return;
 210           }
 211
 212         queue = gst_element_factory_make("queue", NULL);
 213         decoder = gst_element_factory_make("a52dec", "a52dec");
 214         conv = gst_element_factory_make("audioconvert", NULL);
 215         resample = gst_element_factory_make("audioresample", NULL);
 216         volume = gst_element_factory_make("volume", "volume");
 217         g_object_get(G_OBJECT(volume), "volume", &vol, NULL);
 218         ev->volume = vol / 10.0;
 219
 220         /* FIXME: must manage several audio streams */
 221         asink->sink = gst_element_factory_make("fakesink", NULL);
 222
 223         gst_bin_add_many(GST_BIN(ev->pipeline),
 224                          queue, decoder, conv, resample, volume, asink->sink, NULL);
 225         gst_element_link_many(queue, decoder, conv, resample, volume, asink->sink, NULL);
 226
 227         audiopad = gst_element_get_pad(queue, "sink");
 228         gst_pad_link(GST_PAD(new_pad), audiopad);
 229         gst_object_unref(audiopad);
 230
 231         gst_element_set_state(queue, GST_STATE_PAUSED);
 232         gst_element_set_state(decoder, GST_STATE_PAUSED);
 233         gst_element_set_state(conv, GST_STATE_PAUSED);
 234         gst_element_set_state(resample, GST_STATE_PAUSED);
 235         gst_element_set_state(volume, GST_STATE_PAUSED);
 236         gst_element_set_state(asink->sink, GST_STATE_PAUSED);
 237      }
 238 }
 239
 240 static void
 241 dvd_no_more_pads_cb(GstElement *dvddemuxer,
 242                     gpointer    user_data)
 243 {
 244   no_more_pads = 1;
 245 }