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                   alist = eina_list_next(alist);
 105                   sink_pad = gst_element_get_pad(gst_bin_get_by_name(GST_BIN(ev->pipeline), "a52dec"), "src");
 106                   sink_caps = gst_pad_get_caps(sink_pad);
 107
 108                   emotion_audio_sink_fill(asink, sink_pad, sink_caps);
 109                }
 110              gst_caps_unref(caps);
 111              g_free(str);
 112              gst_object_unref(pad);
 113           }
 114         gst_iterator_free(it);
 115      }
 116
 117    /* The first vsink is a valid Emotion_Video_Sink * */
 118    /* If no video stream is found, it's a visualisation sink */
 119      {
 120         Emotion_Video_Sink *vsink;
 121
 122         vsink = (Emotion_Video_Sink *)eina_list_data_get(ev->video_sinks);
 123         if (vsink && vsink->sink)
 124           {
 125              g_object_set(G_OBJECT(vsink->sink), "sync", TRUE, NULL);
 126              g_object_set(G_OBJECT(vsink->sink), "signal-handoffs", TRUE, NULL);
 127              g_signal_connect(G_OBJECT(vsink->sink),
 128                               "handoff",
 129                               G_CALLBACK(cb_handoff), ev);
 130           }
 131      }
 132
 133    return 1;
 134
 135 failure_gstreamer_pause:
 136 failure_link:
 137    gst_element_set_state(ev->pipeline, GST_STATE_NULL);
 138    gst_bin_remove(GST_BIN(ev->pipeline), dvddemux);
 139 failure_dvddemux:
 140    gst_bin_remove(GST_BIN(ev->pipeline), dvdreadsrc);
 141 failure_dvdreadsrc:
 142
 143    return 0;
 144 }
 145
 146 static void
 147 dvd_pad_added_cb(GstElement *dvddemuxer,
 148                  GObject    *new_pad,
 149                  gpointer    user_data)
 150 {
 151    Emotion_Gstreamer_Video *ev;
 152    GstCaps                 *caps;
 153    gchar                   *str;
 154
 155    ev = (Emotion_Gstreamer_Video *)user_data;
 156    caps = gst_pad_get_caps(GST_PAD(new_pad));
 157    str = gst_caps_to_string(caps);
 158    /* video stream */
 159    if (g_str_has_prefix(str, "video/mpeg"))
 160      {
 161         Emotion_Video_Sink *vsink;
 162         GstElement         *queue;
 163         GstElement         *decoder;
 164         GstPad             *videopad;
 165
 166         vsink = (Emotion_Video_Sink *)malloc(sizeof(Emotion_Video_Sink));
 167         if (!vsink) return;
 168         ev->video_sinks = eina_list_append(ev->video_sinks, vsink);
 169         if (eina_error_get())
 170           {
 171              free(vsink);
 172              return;
 173           }
 174
 175         queue = gst_element_factory_make("queue", NULL);
 176         decoder = gst_element_factory_make("mpeg2dec", "mpeg2dec");
 177         vsink->sink = gst_element_factory_make("fakesink", "videosink");
 178         gst_bin_add_many(GST_BIN(ev->pipeline), queue, decoder, vsink->sink, NULL);
 179         gst_element_link(queue, decoder);
 180         gst_element_link(decoder, vsink->sink);
 181         videopad = gst_element_get_pad(queue, "sink");
 182         gst_pad_link(GST_PAD(new_pad), videopad);
 183         gst_object_unref(videopad);
 184         if (eina_list_count(ev->video_sinks) == 1)
 185           {
 186              ev->ratio = (double)vsink->width / (double)vsink->height;
 187           }
 188         gst_element_set_state(queue, GST_STATE_PAUSED);
 189         gst_element_set_state(decoder, GST_STATE_PAUSED);
 190         gst_element_set_state(vsink->sink, GST_STATE_PAUSED);
 191      }
 192    /* audio stream */
 193    else if (g_str_has_prefix(str, "audio/"))
 194      {
 195         Emotion_Audio_Sink *asink;
 196         GstElement         *queue;
 197         GstElement         *decoder;
 198         GstElement         *conv;
 199         GstElement         *resample;
 200         GstElement         *volume;
 201         GstPad             *audiopad;
 202         double              vol;
 203
 204         asink = (Emotion_Audio_Sink *)malloc(sizeof(Emotion_Audio_Sink));
 205         if (!asink) return;
 206         ev->audio_sinks = eina_list_append(ev->audio_sinks, asink);
 207         if (eina_error_get())
 208           {
 209              free(asink);
 210              return;
 211           }
 212
 213         queue = gst_element_factory_make("queue", NULL);
 214         decoder = gst_element_factory_make("a52dec", "a52dec");
 215         conv = gst_element_factory_make("audioconvert", NULL);
 216         resample = gst_element_factory_make("audioresample", NULL);
 217         volume = gst_element_factory_make("volume", "volume");
 218         g_object_get(G_OBJECT(volume), "volume", &vol, NULL);
 219         ev->volume = vol / 10.0;
 220
 221         /* FIXME: must manage several audio streams */
 222         asink->sink = gst_element_factory_make("fakesink", NULL);
 223
 224         gst_bin_add_many(GST_BIN(ev->pipeline),
 225                          queue, decoder, conv, resample, volume, asink->sink, NULL);
 226         gst_element_link_many(queue, decoder, conv, resample, volume, asink->sink, NULL);
 227
 228         audiopad = gst_element_get_pad(queue, "sink");
 229         gst_pad_link(GST_PAD(new_pad), audiopad);
 230         gst_object_unref(audiopad);
 231
 232         gst_element_set_state(queue, GST_STATE_PAUSED);
 233         gst_element_set_state(decoder, GST_STATE_PAUSED);
 234         gst_element_set_state(conv, GST_STATE_PAUSED);
 235         gst_element_set_state(resample, GST_STATE_PAUSED);
 236         gst_element_set_state(volume, GST_STATE_PAUSED);
 237         gst_element_set_state(asink->sink, GST_STATE_PAUSED);
 238      }
 239 }
 240
 241 static void
 242 dvd_no_more_pads_cb(GstElement *dvddemuxer,
 243                     gpointer    user_data)
 244 {
 245   no_more_pads = 1;
 246 }