renatofilho@588: #ifdef HAVE_CONFIG_H
renatofilho@588: #include "config.h"
renatofilho@588: #endif
renatofilho@588: 
renatofilho@600: #include <sys/stat.h>
renatofilho@600: #include <fcntl.h>
renatofilho@600: #include <unistd.h>
renatofilho@588: #include <glib.h>
renatofilho@588: #include <gst/gst.h>
renatofilho@588: #include <string.h>
renatofilho@762: #include <sys/types.h>
renatofilho@762: #include <sys/socket.h>
renatofilho@786: #include <libgnomevfs/gnome-vfs.h>
renatofilho@789: #include <gst/interfaces/tuner.h>
renatofilho@588: 
renatofilho@588: #include "gmencoder.h"
renatofilho@588: 
renatofilho@588: #define G_MENCODER_GET_PRIVATE(obj) \
renatofilho@588:     (G_TYPE_INSTANCE_GET_PRIVATE ((obj), G_TYPE_MENCODER, GMencoderPrivate))
renatofilho@588: 
renatofilho@807: #define USE_MANUAL_SINK
renatofilho@807: #define GMENCODER_TIMEOUT	5000
renatofilho@807: 
renatofilho@588: typedef struct _GMencoderPrivate GMencoderPrivate;
renatofilho@600: typedef struct _SetupInfo SetupInfo;
renatofilho@600: 
renatofilho@754: struct _SetupInfo {
renatofilho@754:     gchar          *video_encode;
renatofilho@754:     gchar          *mux_name;
renatofilho@754:     gchar         **video_encode_prop;
renatofilho@754:     gdouble         video_fps;
renatofilho@754:     gdouble         video_rate;
renatofilho@754:     guint           video_width;
renatofilho@754:     guint           video_height;
renatofilho@754:     gchar          *audio_encode;
renatofilho@754:     gchar         **audio_encode_prop;
renatofilho@754:     guint           audio_rate;
renatofilho@600: };
renatofilho@600: 
renatofilho@588: 
renatofilho@754: struct _GMencoderPrivate {
renatofilho@754:     GstElement     *pipe;
renatofilho@754:     GstElement     *abin;
renatofilho@754:     GstElement     *vbin;
renatofilho@754:     GstElement     *sink;
renatofilho@754:     GstElement     *src;
renatofilho@786: 
renatofilho@807:     GnomeVFSHandle  *handle;
renatofilho@786: 
renatofilho@754:     gboolean        ready;
renatofilho@754:     SetupInfo      *info;
renatofilho@754:     GstClockTime    videot;
renatofilho@754:     GstClockTime    audiot;
renatofilho@754:     gint            sources;
renatofilho@754:     gint            tick_id;
renatofilho@754:     gint64          duration;
renatofilho@768:     gboolean        send_chunked;
renatofilho@807:     gint 	    timeout_id;
renatofilho@789: 
renatofilho@789:     //V4l info
renatofilho@789:     GstElement *v4lsrc;
renatofilho@789:     gchar *channel;
renatofilho@789:     gchar *norm;
renatofilho@789:     glong frequency;
renatofilho@588: };
renatofilho@588: 
renatofilho@754: enum {
renatofilho@754:     PAUSED,
renatofilho@754:     PLAYING,
renatofilho@754:     STOPED,
renatofilho@754:     EOS,
renatofilho@754:     ERROR,
renatofilho@754:     LAST_SIGNAL
renatofilho@588: };
renatofilho@588: 
renatofilho@754: static void     g_mencoder_class_init(GMencoderClass * klass);
renatofilho@754: static void     g_mencoder_init(GMencoder * object);
renatofilho@754: static void     g_mencoder_dispose(GObject * object);
renatofilho@754: static void     g_mencoder_finalize(GObject * object);
renatofilho@752: static GstElement *_create_audio_bin(const gchar * encode,
renatofilho@754:                                      gchar ** encode_prop, gint rate);
renatofilho@752: static GstElement *_create_video_bin(const gchar * encode,
renatofilho@754:                                      gchar ** encode_prop,
renatofilho@754:                                      gdouble fps,
renatofilho@777:                                      gint rate, guint width, guint height,
renatofilho@777:                                      gboolean use_deinterlace);
renatofilho@588: 
renatofilho@754: static          gboolean
renatofilho@752: _pipeline_bus_cb(GstBus * bus, GstMessage * msg, gpointer user_data);
morphbr@748: 
renatofilho@754: static void     _decodebin_new_pad_cb(GstElement * object,
renatofilho@754:                                       GstPad * pad,
renatofilho@754:                                       gboolean flag, gpointer user_data);
morphbr@748: 
renatofilho@754: static void     _decodebin_unknown_type_cb(GstElement * object,
renatofilho@754:                                            GstPad * pad,
renatofilho@754:                                            GstCaps * caps,
renatofilho@754:                                            gpointer user_data);
morphbr@748: 
renatofilho@754: static void     _close_output(GMencoder * self);
renatofilho@757: static gboolean _open_output(GMencoder * self, const gchar * uri);
morphbr@748: 
renatofilho@789: static GstElement *_create_source(GMencoder *self, const gchar * uri);
renatofilho@752: static GstElement *_create_pipeline(GMencoder * self,
renatofilho@754:                                     const gchar * video_encode,
renatofilho@754:                                     const gchar * mux_name,
renatofilho@754:                                     gchar ** video_encode_prop,
renatofilho@754:                                     gdouble video_fps,
renatofilho@754:                                     gdouble video_rate,
renatofilho@754:                                     guint video_width,
renatofilho@754:                                     guint video_height,
renatofilho@754:                                     const gchar * audio_encode,
renatofilho@754:                                     gchar ** audio_encode_prop,
renatofilho@777:                                     guint audio_rate,
renatofilho@777: 				    gboolean deinterlace);
renatofilho@807: static gboolean	_process_timeout_cb (gpointer user_data);
renatofilho@807: #ifdef USE_MANUAL_SINK
renatofilho@789: static void _flush_queue	        (GMencoder *self);
renatofilho@761: static void _buffer_arrive_cb       (GstElement* object,
renatofilho@761:                                      GstBuffer* buff,
renatofilho@807:                                      GstPad* pad,
renatofilho@761:                                      gpointer user_data);
renatofilho@807: #endif
renatofilho@807: 
renatofilho@807: 
renatofilho@752: static gboolean _tick_cb(gpointer data);
renatofilho@588: 
renatofilho@754: static guint    g_mencoder_signals[LAST_SIGNAL] = { 0 };
renatofilho@588: 
renatofilho@588: G_DEFINE_TYPE(GMencoder, g_mencoder, G_TYPE_OBJECT)
renatofilho@761: 
renatofilho@761: static void     g_mencoder_class_init(GMencoderClass * klass)
renatofilho@752: {
renatofilho@754:     GObjectClass   *object_class;
renatofilho@754:     object_class = (GObjectClass *) klass;
renatofilho@754:     g_type_class_add_private(klass, sizeof(GMencoderPrivate));
renatofilho@588: 
renatofilho@754:     object_class->dispose = g_mencoder_dispose;
renatofilho@754:     object_class->finalize = g_mencoder_finalize;
renatofilho@588: 
renatofilho@754:     g_mencoder_signals[PAUSED] =
renatofilho@754:         g_signal_new("paused",
renatofilho@754:                      G_OBJECT_CLASS_TYPE(object_class),
renatofilho@754:                      G_SIGNAL_RUN_FIRST,
renatofilho@754:                      0, NULL, NULL,
renatofilho@754:                      g_cclosure_marshal_VOID__VOID, G_TYPE_NONE, 0);
renatofilho@588: 
renatofilho@754:     g_mencoder_signals[PLAYING] =
renatofilho@754:         g_signal_new("playing",
renatofilho@754:                      G_OBJECT_CLASS_TYPE(object_class),
renatofilho@754:                      G_SIGNAL_RUN_FIRST,
renatofilho@754:                      0, NULL, NULL,
renatofilho@754:                      g_cclosure_marshal_VOID__VOID, G_TYPE_NONE, 0);
morphbr@748: 
renatofilho@754:     g_mencoder_signals[STOPED] =
renatofilho@754:         g_signal_new("stoped",
renatofilho@754:                      G_OBJECT_CLASS_TYPE(object_class),
renatofilho@754:                      G_SIGNAL_RUN_FIRST,
renatofilho@754:                      0, NULL, NULL,
renatofilho@754:                      g_cclosure_marshal_VOID__VOID, G_TYPE_NONE, 0);
renatofilho@588: 
renatofilho@754:     g_mencoder_signals[EOS] =
renatofilho@754:         g_signal_new("eos",
renatofilho@754:                      G_OBJECT_CLASS_TYPE(object_class),
renatofilho@754:                      G_SIGNAL_RUN_FIRST,
renatofilho@754:                      0, NULL, NULL,
renatofilho@754:                      g_cclosure_marshal_VOID__VOID, G_TYPE_NONE, 0);
renatofilho@588: 
renatofilho@754:     g_mencoder_signals[ERROR] =
renatofilho@754:         g_signal_new("error",
renatofilho@754:                      G_OBJECT_CLASS_TYPE(object_class),
renatofilho@754:                      G_SIGNAL_RUN_LAST,
renatofilho@754:                      0, NULL, NULL,
renatofilho@754:                      g_cclosure_marshal_VOID__STRING,
renatofilho@754:                      G_TYPE_NONE, 1, G_TYPE_STRING);
renatofilho@588: }
renatofilho@588: 
renatofilho@588: static void
renatofilho@752: g_mencoder_init(GMencoder * self)
renatofilho@588: {
renatofilho@754:     GMencoderPrivate *priv = G_MENCODER_GET_PRIVATE(self);
renatofilho@754:     priv->info = g_new0(SetupInfo, 1);
renatofilho@588: }
renatofilho@588: 
morphbr@748: static void
renatofilho@752: g_mencoder_dispose(GObject * object)
renatofilho@588: {
renatofilho@588: }
renatofilho@588: 
morphbr@748: static void
renatofilho@752: g_mencoder_finalize(GObject * object)
renatofilho@588: {
renatofilho@762:     GMencoderPrivate *priv = G_MENCODER_GET_PRIVATE(object);
renatofilho@762: 
renatofilho@754:     // TODO: clear vars
renatofilho@754:     g_mencoder_close_stream(G_MENCODER(object));
renatofilho@762:     g_free (priv->info);
renatofilho@588: }
renatofilho@588: 
renatofilho@754: GMencoder      *
renatofilho@752: g_mencoder_new(void)
renatofilho@588: {
renatofilho@754:     return g_object_new(G_TYPE_MENCODER, NULL);
renatofilho@588: }
renatofilho@588: 
renatofilho@600: 
renatofilho@588: static void
renatofilho@754: _obj_set_prop(GObject * obj, const gchar * prop_name,
renatofilho@754:               const gchar * prop_val)
renatofilho@588: {
renatofilho@754:     GValue          p = { 0 };
renatofilho@754:     GValue          v = { 0 };
renatofilho@754:     GParamSpec     *s = NULL;
renatofilho@754:     GObjectClass   *k = G_OBJECT_GET_CLASS(obj);
renatofilho@588: 
renatofilho@588: 
renatofilho@754:     g_value_init(&v, G_TYPE_STRING);
renatofilho@754:     g_value_set_string(&v, prop_val);
renatofilho@588: 
renatofilho@754:     s = g_object_class_find_property(k, prop_name);
renatofilho@754:     if (s == NULL) {
renatofilho@754:         g_print("Invalid property name: %s\n", prop_name);
renatofilho@754:         return;
renatofilho@754:     }
renatofilho@588: 
renatofilho@754:     g_value_init(&p, s->value_type);
renatofilho@754:     switch (s->value_type) {
renatofilho@754:     case G_TYPE_INT:
renatofilho@754:         g_value_set_int(&p, atoi(prop_val));
renatofilho@754:         break;
renatofilho@772:     case G_TYPE_ULONG:
renatofilho@772:         g_value_set_ulong (&p, atol(prop_val));
renatofilho@772:         break;
renatofilho@754:     case G_TYPE_STRING:
renatofilho@754:         g_value_set_string(&p, prop_val);
renatofilho@754:         break;
renatofilho@772:     case G_TYPE_BOOLEAN:
renatofilho@772:         g_value_set_boolean(&p, (gboolean) atoi (prop_val));
renatofilho@772:         break;
renatofilho@772:     case G_TYPE_DOUBLE:
renatofilho@772:         g_value_set_double(&p, atof (prop_val));
renatofilho@772:         break;
renatofilho@772:     case G_TYPE_FLOAT:
renatofilho@772:         g_value_set_float(&p, (float) atof (prop_val));
renatofilho@772:         break;
renatofilho@754:     default:
renatofilho@777:         g_value_set_enum(&p, atoi(prop_val));
renatofilho@777:         g_warning ("Property %s of type %s. Not supported using default enum", 
renatofilho@772:                    prop_name, g_type_name (s->value_type));
renatofilho@754:         return;
renatofilho@754:     }
morphbr@748: 
renatofilho@754:     g_object_set_property(obj, prop_name, &p);
renatofilho@754:     g_value_unset(&v);
renatofilho@754:     g_value_unset(&p);
renatofilho@588: }
renatofilho@588: 
renatofilho@752: static GstElement *
renatofilho@752: _create_element_with_prop(const gchar * factory_name,
renatofilho@754:                           const gchar * element_name, gchar ** prop)
renatofilho@588: {
renatofilho@754:     GstElement     *ret;
renatofilho@754:     int             i;
renatofilho@588: 
renatofilho@754:     ret = gst_element_factory_make(factory_name, element_name);
renatofilho@754:     if (ret == NULL)
renatofilho@754:         return NULL;
renatofilho@588: 
renatofilho@754:     if (prop != NULL) {
renatofilho@754:         for (i = 0; i < g_strv_length(prop); i++) {
renatofilho@754:             if (prop[i] != NULL) {
renatofilho@781:                 char **v = g_strsplit(prop[i], "=", 2);
renatofilho@754:                 if (g_strv_length(v) == 2) {
renatofilho@754:                     _obj_set_prop(G_OBJECT(ret), v[0], v[1]);
renatofilho@754:                 }
renatofilho@754:                 g_strfreev(v);
renatofilho@754:             }
renatofilho@754:         }
renatofilho@754:     }
renatofilho@588: 
renatofilho@754:     return ret;
renatofilho@588: 
renatofilho@588: }
renatofilho@588: 
renatofilho@752: static GstElement *
renatofilho@752: _create_audio_bin(const gchar * encode, gchar ** encode_prop, gint rate)
renatofilho@588: {
renatofilho@754:     GstElement     *abin = NULL;
renatofilho@754:     GstElement     *aqueue = NULL;
renatofilho@754:     GstElement     *aconvert = NULL;
renatofilho@754:     GstElement     *aencode = NULL;
renatofilho@754:     GstElement     *aqueue_src = NULL;
renatofilho@754:     GstPad         *apad = NULL;
renatofilho@588: 
renatofilho@754:     // audio/x-raw-int ! queue ! audioconvert ! faac ! rtpmp4gpay !
renatofilho@754:     // udpsink name=upd_audio host=224.0.0.1 port=5002
renatofilho@754:     abin = gst_bin_new("abin");
renatofilho@754:     aqueue = gst_element_factory_make("queue", "aqueue");
renatofilho@754:     aconvert = gst_element_factory_make("audioconvert", "aconvert");
renatofilho@754:     aencode =
renatofilho@754:         _create_element_with_prop((encode ? encode : "lame"), "aencode",
renatofilho@754:                                   encode_prop);
renatofilho@754:     aqueue_src = gst_element_factory_make("queue", "aqueue_src");
renatofilho@588: 
renatofilho@754:     if ((abin == NULL) || (aqueue == NULL) || (aconvert == NULL)
renatofilho@754:         || (aencode == NULL) || (aqueue_src == NULL)) {
renatofilho@754:         g_warning("Audio elements not found");
renatofilho@754:         goto error;
renatofilho@754:     }
renatofilho@752: 
renatofilho@754:     g_object_set(G_OBJECT(aencode), "bitrate", 32, NULL);
renatofilho@754:     /*
renatofilho@754:      * if (rate > 0) { g_object_set (G_OBJECT (aencode), "bitrate", 32,
renatofilho@754:      * NULL); } 
renatofilho@754:      */
renatofilho@754: 
renatofilho@754:     gst_bin_add_many(GST_BIN(abin), aqueue, aconvert, aencode, aqueue_src,
renatofilho@754:                      NULL);
renatofilho@754:     if (gst_element_link_many(aqueue, aconvert, aencode, aqueue_src, NULL)
renatofilho@754:         == FALSE) {
renatofilho@754:         g_warning("Not Link audio elements");
morphbr@748:     }
renatofilho@754:     // TODO: apply audio rate
renatofilho@588: 
renatofilho@754:     // ghost pad the audio bin
renatofilho@754:     apad = gst_element_get_pad(aqueue, "sink");
renatofilho@754:     gst_element_add_pad(abin, gst_ghost_pad_new("sink", apad));
renatofilho@754:     gst_object_unref(apad);
renatofilho@600: 
renatofilho@754:     apad = gst_element_get_pad(aqueue_src, "src");
renatofilho@754:     gst_element_add_pad(abin, gst_ghost_pad_new("src", apad));
renatofilho@754:     gst_object_unref(apad);
renatofilho@588: 
renatofilho@754:     return abin;
renatofilho@754:   error:
renatofilho@754:     if (abin != NULL)
renatofilho@754:         gst_object_unref(abin);
renatofilho@588: 
renatofilho@754:     if (aqueue != NULL)
renatofilho@754:         gst_object_unref(aqueue);
morphbr@748: 
renatofilho@754:     if (aconvert != NULL)
renatofilho@754:         gst_object_unref(aconvert);
renatofilho@588: 
renatofilho@754:     if (aencode != NULL)
renatofilho@754:         gst_object_unref(aencode);
renatofilho@588: 
renatofilho@754:     if (aqueue_src != NULL)
renatofilho@754:         gst_object_unref(aqueue_src);
renatofilho@588: 
renatofilho@754:     if (apad != NULL)
renatofilho@754:         gst_object_unref(apad);
renatofilho@588: 
renatofilho@754:     return NULL;
renatofilho@588: }
renatofilho@588: 
renatofilho@588: 
renatofilho@588: 
renatofilho@588: 
renatofilho@754: // queue ! videoscale ! video/x-raw-yuv,width=240,height=144 ! colorspace
renatofilho@754: // ! rate ! encode ! queue
renatofilho@752: static GstElement *
renatofilho@752: _create_video_bin(const gchar * encode,
renatofilho@754:                   gchar ** encode_prop,
renatofilho@777:                   gdouble fps, gint rate, guint width, guint height,
renatofilho@777:                   gboolean use_deinterlace)
renatofilho@588: {
renatofilho@754:     GstElement     *vbin = NULL;
renatofilho@754:     GstElement     *vqueue = NULL;
renatofilho@754:     GstElement     *vqueue_src = NULL;
renatofilho@754:     GstElement     *vcolorspace = NULL;
renatofilho@754:     GstElement     *vencode = NULL;
renatofilho@754:     GstElement     *vrate = NULL;
renatofilho@789:     GstElement	   *deinterlace = NULL;
renatofilho@777:     GstElement     *walk = NULL;
renatofilho@754:     GstPad         *vpad = NULL;
renatofilho@588: 
renatofilho@754:     vbin = gst_bin_new("vbin");
renatofilho@754:     vqueue = gst_element_factory_make("queue", "vqueue");
renatofilho@754:     vcolorspace =
renatofilho@754:         gst_element_factory_make("ffmpegcolorspace", "colorspace");
renatofilho@616: 
renatofilho@777:     if (use_deinterlace) {
renatofilho@789:         deinterlace = gst_element_factory_make ("ffdeinterlace", "deinterlace");
renatofilho@789: 	    if (deinterlace == NULL) {
renatofilho@789: 	        g_warning ("Fail to create deinterlace element: Continue without deinterlace.");
renatofilho@789:         }
renatofilho@777:     }
renatofilho@777: 
renatofilho@777: 
renatofilho@754:     vencode = _create_element_with_prop((encode !=
renatofilho@754:                                          NULL ? encode :
renatofilho@754:                                          "ffenc_mpeg1video"), "vencode",
renatofilho@754:                                         encode_prop);
renatofilho@754:     vqueue_src = gst_element_factory_make("queue", "queue_src");
renatofilho@588: 
renatofilho@754:     if ((vbin == NULL) || (vqueue == NULL) || (vcolorspace == NULL)
renatofilho@754:         || (vencode == NULL) || (vqueue_src == NULL)) {
renatofilho@754:         g_warning("Video elements not found");
renatofilho@754:         goto error;
renatofilho@754:     }
renatofilho@588: 
renatofilho@754:     gst_bin_add_many(GST_BIN(vbin), vqueue, vcolorspace, vencode,
renatofilho@754:                      vqueue_src, NULL);
morphbr@748: 
renatofilho@777:     if (deinterlace != NULL) {
renatofilho@777:         gst_bin_add(GST_BIN(vbin), deinterlace);
renatofilho@777:         gst_element_link (vqueue, deinterlace);
renatofilho@777:         walk = deinterlace;
renatofilho@777:     } else {
renatofilho@777:         walk = vqueue;
renatofilho@777:     }
renatofilho@777: 
renatofilho@754:     if ((width > 0) && (height > 0)) {
renatofilho@754:         // Scalling video
renatofilho@754:         GstCaps        *vcaps;
renatofilho@754:         GstElement     *vscale =
renatofilho@754:             gst_element_factory_make("videoscale", "vscale");
renatofilho@588: 
renatofilho@777: 	g_object_set (G_OBJECT (vscale), "method", 1, NULL);
renatofilho@777: 
renatofilho@754:         gst_bin_add(GST_BIN(vbin), vscale);
renatofilho@588: 
renatofilho@754:         vcaps = gst_caps_new_simple("video/x-raw-yuv",
renatofilho@754:                                     "width", G_TYPE_INT, width,
renatofilho@754:                                     "height", G_TYPE_INT, height, NULL);
renatofilho@588: 
renatofilho@777:         gst_element_link(walk, vscale);
morphbr@748: 
renatofilho@754:         if (gst_element_link_filtered(vscale, vcolorspace, vcaps) == FALSE) {
renatofilho@754:             g_warning("Fail to resize video");
renatofilho@754:             gst_object_unref(vcaps);
renatofilho@754:             gst_object_unref(vscale);
renatofilho@754:             goto error;
renatofilho@754:         }
renatofilho@754:         gst_caps_unref(vcaps);
renatofilho@754:     } else {
renatofilho@777:         gst_element_link(walk, vcolorspace);
renatofilho@754:     }
renatofilho@588: 
renatofilho@754:     if (fps > 0) {
renatofilho@754:         // Changing the video fps
renatofilho@754:         GstCaps        *vcaps;
renatofilho@754:         vrate = gst_element_factory_make("videorate", "vrate");
renatofilho@588: 
renatofilho@754:         gst_bin_add(GST_BIN(vbin), vrate);
renatofilho@588: 
renatofilho@754:         if (gst_element_link(vcolorspace, vrate) == FALSE) {
renatofilho@754:             g_warning("Fail to link video elements");
renatofilho@754:             goto error;
renatofilho@754:         }
renatofilho@588: 
renatofilho@754:         vcaps = gst_caps_new_simple("video/x-raw-yuv",
renatofilho@754:                                     "framerate", GST_TYPE_FRACTION,
renatofilho@754:                                     (int) (fps * 1000), 1000, NULL);
renatofilho@588: 
renatofilho@754:         if (gst_element_link_filtered(vrate, vencode, vcaps) == FALSE) {
renatofilho@754:             g_warning("Fail to link vrate with vencode.");
renatofilho@754:             goto error;
renatofilho@754:         }
renatofilho@754:         gst_caps_unref(vcaps);
renatofilho@754:     } else {
renatofilho@754:         if (gst_element_link(vcolorspace, vencode) == FALSE) {
renatofilho@754:             g_warning("Fail to link colorspace and video encode element.");
renatofilho@754:             goto error;
renatofilho@754:         }
renatofilho@754:     }
morphbr@748: 
renatofilho@754:     gst_element_link(vencode, vqueue_src);
renatofilho@588: 
renatofilho@754:     // ghost pad the video bin
renatofilho@754:     vpad = gst_element_get_pad(vqueue, "sink");
renatofilho@754:     gst_element_add_pad(vbin, gst_ghost_pad_new("sink", vpad));
renatofilho@754:     gst_object_unref(vpad);
morphbr@748: 
renatofilho@754:     vpad = gst_element_get_pad(vqueue_src, "src");
renatofilho@754:     gst_element_add_pad(vbin, gst_ghost_pad_new("src", vpad));
renatofilho@754:     gst_object_unref(vpad);
renatofilho@588: 
renatofilho@754:     return vbin;
renatofilho@588: 
renatofilho@754:   error:
renatofilho@754:     if (vpad != NULL)
renatofilho@754:         gst_object_unref(vpad);
renatofilho@588: 
renatofilho@754:     if (vbin != NULL)
renatofilho@754:         gst_object_unref(vbin);
renatofilho@588: 
renatofilho@754:     if (vqueue != NULL)
renatofilho@754:         gst_object_unref(vqueue);
renatofilho@588: 
renatofilho@754:     if (vencode != NULL)
renatofilho@754:         gst_object_unref(vencode);
renatofilho@588: 
renatofilho@754:     if (vqueue_src != NULL)
renatofilho@754:         gst_object_unref(vqueue_src);
renatofilho@588: 
renatofilho@754:     if (vcolorspace != NULL)
renatofilho@754:         gst_object_unref(vcolorspace);
renatofilho@588: 
renatofilho@754:     return NULL;
renatofilho@588: }
renatofilho@588: 
renatofilho@588: 
renatofilho@600: 
renatofilho@757: gboolean 
renatofilho@752: g_mencoder_setup_stream(GMencoder * self,
renatofilho@768: 			gboolean chunked,
renatofilho@777: 			gboolean deinterlace,
renatofilho@754:                         const gchar * mux_name,
renatofilho@754:                         const gchar * video_encode,
renatofilho@754:                         gchar ** video_encode_prop,
renatofilho@754:                         gdouble video_fps,
renatofilho@754:                         gdouble video_rate,
renatofilho@754:                         guint video_width,
renatofilho@754:                         guint video_height,
renatofilho@754:                         const gchar * audio_encode,
renatofilho@754:                         gchar ** audio_encode_prop,
renatofilho@754:                         guint audio_rate, const gchar * out_uri)
renatofilho@600: {
renatofilho@754:     GMencoderPrivate *priv = G_MENCODER_GET_PRIVATE(self);
renatofilho@754:     if (priv->ready == TRUE) {
renatofilho@754:         g_warning
renatofilho@754:             ("Stream already configured. You need close stream first.");
renatofilho@757:         return FALSE;
renatofilho@754:     }
renatofilho@600: 
renatofilho@754:     _close_output(self);
melunko@826:     if (_open_output(self, out_uri) == FALSE) {	
renatofilho@757:         return FALSE;
renatofilho@789:     }
renatofilho@634: 
renatofilho@754:     priv->sources = 0;
renatofilho@768:     priv->send_chunked = chunked;
renatofilho@754:     priv->pipe = _create_pipeline(self,
renatofilho@754:                                   video_encode,
renatofilho@754:                                   mux_name,
renatofilho@754:                                   video_encode_prop,
renatofilho@754:                                   video_fps,
renatofilho@754:                                   video_rate,
renatofilho@754:                                   video_width,
renatofilho@754:                                   video_height,
renatofilho@754:                                   audio_encode, audio_encode_prop,
renatofilho@777:                                   audio_rate,
renatofilho@777:                                   deinterlace);
renatofilho@600: 
renatofilho@757:     return (priv->pipe != NULL);
renatofilho@600: }
renatofilho@600: 
renatofilho@600: 
renatofilho@600: gboolean
renatofilho@752: g_mencoder_append_uri(GMencoder * self, const gchar * uri)
renatofilho@600: {
renatofilho@754:     GstPad         *pad_src;
renatofilho@754:     GstPad         *pad_sink;
renatofilho@754:     GstElement     *src;
renatofilho@754:     GMencoderPrivate *priv = G_MENCODER_GET_PRIVATE(self);
renatofilho@754:     gboolean        ret = FALSE;
renatofilho@754:     GstElement     *ap = NULL;
renatofilho@754:     GstElement     *vp = NULL;
renatofilho@634: 
renatofilho@600: 
renatofilho@754:     g_return_val_if_fail(priv->pipe != NULL, FALSE);
renatofilho@754:     g_return_val_if_fail(priv->ready == FALSE, FALSE);
renatofilho@600: 
renatofilho@789:     src = _create_source(self, uri);
renatofilho@754:     if (src == NULL)
renatofilho@754:         return FALSE;
renatofilho@600: 
renatofilho@754:     priv->src = gst_bin_get_by_name(GST_BIN(src), "src");
renatofilho@671: 
renatofilho@754:     gst_bin_add(GST_BIN(priv->pipe), src);
renatofilho@600: 
renatofilho@754:     ap = gst_bin_get_by_name(GST_BIN(priv->pipe), "abin");
renatofilho@754:     vp = gst_bin_get_by_name(GST_BIN(priv->pipe), "vbin");
renatofilho@634: 
renatofilho@754:     if ((vp == NULL) || (ap == NULL)) {
renatofilho@754:         g_warning("Fail to get output bin");
renatofilho@754:         goto error;
renatofilho@754:     }
renatofilho@600: 
renatofilho@754:     pad_src = gst_element_get_pad(src, "src_audio");
renatofilho@754:     pad_sink = gst_element_get_compatible_pad(ap,
renatofilho@754:                                               pad_src,
renatofilho@754:                                               gst_pad_get_caps(pad_src));
renatofilho@600: 
renatofilho@754:     if ((pad_sink == NULL) || (pad_src == NULL))
renatofilho@754:         goto error;
renatofilho@600: 
renatofilho@754:     GstPadLinkReturn lret = gst_pad_link(pad_src, pad_sink);
renatofilho@754:     if (lret != GST_PAD_LINK_OK)
renatofilho@754:         goto error;
renatofilho@600: 
renatofilho@754:     gst_object_unref(pad_src);
renatofilho@754:     gst_object_unref(pad_sink);
renatofilho@600: 
renatofilho@754:     pad_src = gst_element_get_pad(src, "src_video");
renatofilho@754:     pad_sink = gst_element_get_compatible_pad(vp,
renatofilho@754:                                               pad_src,
renatofilho@754:                                               gst_pad_get_caps(pad_src));
renatofilho@600: 
renatofilho@754:     if ((pad_src == NULL) || (pad_sink == NULL))
renatofilho@754:         goto error;
renatofilho@600: 
renatofilho@754:     if (gst_pad_link(pad_src, pad_sink) != GST_PAD_LINK_OK) {
renatofilho@754:         g_warning("invalid source. video");
renatofilho@754:         goto error;
renatofilho@754:     }
renatofilho@600: 
renatofilho@754:     priv->sources++;
renatofilho@754:     ret = TRUE;
renatofilho@754:   error:
renatofilho@600: 
renatofilho@754:     if ((src != NULL) && (ret == FALSE)) {
renatofilho@754:         gst_bin_remove(GST_BIN(priv->pipe), src);
renatofilho@754:         gst_object_unref(src);
renatofilho@754:     }
renatofilho@600: 
renatofilho@754:     if (ap != NULL)
renatofilho@754:         gst_object_unref(ap);
renatofilho@600: 
renatofilho@754:     if (vp != NULL)
renatofilho@754:         gst_object_unref(vp);
renatofilho@600: 
renatofilho@754:     if (pad_src != NULL)
renatofilho@754:         gst_object_unref(pad_src);
renatofilho@600: 
renatofilho@754:     if (pad_sink != NULL)
renatofilho@754:         gst_object_unref(pad_sink);
renatofilho@600: 
renatofilho@754:     return ret;
renatofilho@600: }
renatofilho@600: 
renatofilho@600: 
renatofilho@600: 
morphbr@748: void
renatofilho@752: g_mencoder_remove_uri(GMencoder * self, const gchar * uri)
renatofilho@600: {
renatofilho@754:     // GMencoderPrivate *priv = G_MENCODER_GET_PRIVATE (self);
renatofilho@754:     // TODO: remove src
renatofilho@600: }
renatofilho@600: 
renatofilho@600: void
renatofilho@752: g_mencoder_play_stream(GMencoder * self)
renatofilho@600: {
renatofilho@754:     GMencoderPrivate *priv = G_MENCODER_GET_PRIVATE(self);
renatofilho@754:     g_return_if_fail(priv->ready == FALSE);
renatofilho@754:     priv->ready = TRUE;
renatofilho@754:     gst_element_set_state(priv->pipe, GST_STATE_PLAYING);
renatofilho@807:     if (priv->tick_id != 0) {
renatofilho@807:         g_source_remove (priv->tick_id);
renatofilho@807:     }
renatofilho@754:     priv->tick_id = g_timeout_add(500, _tick_cb, self);
renatofilho@807: 
renatofilho@807:     if (priv->timeout_id != 0) {
renatofilho@807:         g_source_remove (priv->timeout_id);
renatofilho@807:     }
renatofilho@810:     //priv->timeout_id = g_timeout_add(GMENCODER_TIMEOUT, _process_timeout_cb, self);
renatofilho@600: }
renatofilho@600: 
renatofilho@600: void
renatofilho@752: g_mencoder_pause_stream(GMencoder * self)
renatofilho@600: {
renatofilho@754:     GMencoderPrivate *priv = G_MENCODER_GET_PRIVATE(self);
renatofilho@754:     g_return_if_fail(priv->ready == TRUE);
renatofilho@754:     gst_element_set_state(priv->pipe, GST_STATE_PAUSED);
renatofilho@600: }
renatofilho@600: 
renatofilho@600: void
renatofilho@752: g_mencoder_close_stream(GMencoder * self)
renatofilho@600: {
renatofilho@600: 
renatofilho@754:     GMencoderPrivate *priv = G_MENCODER_GET_PRIVATE(self);
renatofilho@754:     if (priv->tick_id != 0) {
renatofilho@754:         g_source_remove(priv->tick_id);
renatofilho@754:         priv->tick_id = 0;
renatofilho@754:     }
renatofilho@600: 
renatofilho@807:     if (priv->timeout_id != 0) {
renatofilho@807:         g_source_remove (priv->timeout_id);
renatofilho@807: 	priv->timeout_id = 0;
renatofilho@807:     }
renatofilho@807: 
renatofilho@754:     if (priv->pipe != NULL) {
renatofilho@754:         // TODO: fixe pipeline dispose
renatofilho@786:         //gst_element_set_state (priv->pipe, GST_STATE_NULL);
renatofilho@754:         // g_debug ("SETING STATE TO NULL: OK");
renatofilho@754:         // gst_element_set_state (priv->pipe, GST_STATE_NULL);
renatofilho@786:         //gst_object_unref (priv->pipe);
renatofilho@780:         //gst_object_unref(priv->src);
renatofilho@754:         priv->src = NULL;
renatofilho@754:         priv->pipe = NULL;
renatofilho@754:         priv->abin = NULL;
renatofilho@754:         priv->vbin = NULL;
renatofilho@807:         priv->sink = NULL;
renatofilho@754:     }
renatofilho@754:     priv->ready = FALSE;
renatofilho@600: }
renatofilho@600: 
renatofilho@752: static GstElement *
renatofilho@752: _create_pipeline(GMencoder * self,
renatofilho@754:                  const gchar * video_encode,
renatofilho@754:                  const gchar * mux_name,
renatofilho@754:                  gchar ** video_encode_prop,
renatofilho@754:                  gdouble video_fps,
renatofilho@754:                  gdouble video_rate,
renatofilho@754:                  guint video_width,
renatofilho@754:                  guint video_height,
renatofilho@754:                  const gchar * audio_encode,
renatofilho@777:                  gchar ** audio_encode_prop, guint audio_rate,
renatofilho@789: 		         gboolean deinterlace)
renatofilho@588: {
renatofilho@754:     GstBus         *bus = NULL;
renatofilho@754:     GstElement     *pipe = NULL;
renatofilho@754:     GstElement     *sink = NULL;
renatofilho@754:     GstElement     *mux = NULL;
renatofilho@754:     GstElement     *abin = NULL;
renatofilho@754:     GstElement     *vbin = NULL;
renatofilho@754:     GstElement     *queue = NULL;
renatofilho@754:     GstPad         *aux_pad = NULL;
renatofilho@754:     GstPad         *mux_pad = NULL;
renatofilho@588: 
renatofilho@754:     pipe = gst_pipeline_new("pipe");
renatofilho@588: 
renatofilho@754:     mux =
renatofilho@754:         gst_element_factory_make((mux_name ? mux_name : "ffmux_mpeg"),
renatofilho@754:                                  "mux");
renatofilho@754:     if (mux == NULL)
renatofilho@754:         goto error;
renatofilho@588: 
renatofilho@754:     queue = gst_element_factory_make("queue", "queueu_sink");
renatofilho@807: 
renatofilho@807: 
renatofilho@807:     sink = gst_element_factory_make("fakesink", "sink");
renatofilho@807:     g_object_set (G_OBJECT (sink), "signal-handoffs", TRUE, NULL);
renatofilho@807:     g_signal_connect (G_OBJECT (sink),
renatofilho@761:                       "handoff",
renatofilho@761:                       G_CALLBACK (_buffer_arrive_cb),
renatofilho@762:                       self);
renatofilho@600: 
renatofilho@754:     abin = _create_audio_bin(audio_encode, audio_encode_prop, audio_rate);
renatofilho@754:     if (abin == NULL)
renatofilho@754:         goto error;
renatofilho@588: 
renatofilho@754:     vbin =
renatofilho@754:         _create_video_bin(video_encode, video_encode_prop, video_fps,
renatofilho@777:                           video_rate, video_width, video_height, deinterlace);
renatofilho@754:     if (vbin == NULL)
renatofilho@754:         goto error;
renatofilho@588: 
renatofilho@754:     // Finish Pipe
renatofilho@807:     gst_bin_add_many(GST_BIN(pipe), abin, vbin, mux, queue, sink, NULL);
renatofilho@600: 
renatofilho@600: 
renatofilho@754:     // Link bins with mux
renatofilho@754:     aux_pad = gst_element_get_pad(abin, "src");
renatofilho@754:     mux_pad =
renatofilho@754:         gst_element_get_compatible_pad(mux, aux_pad,
renatofilho@754:                                        GST_PAD_CAPS(aux_pad));
renatofilho@754:     if (mux_pad == NULL) {
renatofilho@754:         g_warning("Mux element no have audio PAD");
renatofilho@754:         goto error;
renatofilho@754:     }
renatofilho@754:     GstPadLinkReturn ret = gst_pad_link(aux_pad, mux_pad);
renatofilho@754:     if (ret != GST_PAD_LINK_OK) {
renatofilho@754:         g_warning("Fail link audio and mux: %d", ret);
renatofilho@754:         goto error;
morphbr@748: 
renatofilho@754:     }
renatofilho@754:     gst_object_unref(aux_pad);
renatofilho@754:     gst_object_unref(mux_pad);
renatofilho@588: 
renatofilho@754:     aux_pad = gst_element_get_pad(vbin, "src");
renatofilho@754:     mux_pad =
renatofilho@754:         gst_element_get_compatible_pad(mux, aux_pad,
renatofilho@754:                                        GST_PAD_CAPS(aux_pad));
renatofilho@754:     if (mux_pad == NULL) {
renatofilho@754:         g_warning("Mux element no have video PAD");
renatofilho@754:         goto error;
renatofilho@754:     }
renatofilho@754:     ret = gst_pad_link(aux_pad, mux_pad);
renatofilho@754:     if (ret != GST_PAD_LINK_OK) {
renatofilho@754:         g_warning("Fail link video and mux: %d", ret);
renatofilho@754:         goto error;
renatofilho@754:     }
renatofilho@754:     gst_object_unref(aux_pad);
renatofilho@754:     gst_object_unref(mux_pad);
renatofilho@754:     aux_pad = NULL;
renatofilho@754:     mux_pad = NULL;
renatofilho@588: 
renatofilho@754:     // Link mux with sink
renatofilho@807:     gst_element_link_many(mux, queue, sink, NULL);
renatofilho@588: 
renatofilho@754:     bus = gst_pipeline_get_bus(GST_PIPELINE(pipe));
renatofilho@754:     gst_bus_add_watch(bus, _pipeline_bus_cb, self);
renatofilho@754:     gst_object_unref(bus);
renatofilho@754:     return pipe;
renatofilho@588: 
renatofilho@754:   error:
renatofilho@754:     g_warning("Invalid uri");
morphbr@748: 
renatofilho@754:     if (pipe != NULL) {
renatofilho@754:         gst_object_unref(pipe);
renatofilho@754:     }
renatofilho@588: 
renatofilho@588: 
renatofilho@754:     if (mux != NULL) {
renatofilho@754:         gst_object_unref(mux);
renatofilho@754:     }
renatofilho@588: 
renatofilho@754:     if (mux_pad != NULL) {
renatofilho@754:         gst_object_unref(mux_pad);
renatofilho@754:     }
renatofilho@588: 
renatofilho@754:     if (aux_pad != NULL) {
renatofilho@754:         gst_object_unref(mux_pad);
renatofilho@754:     }
renatofilho@588: 
renatofilho@754:     if (sink != NULL) {
renatofilho@754:         gst_object_unref(sink);
renatofilho@754:     }
renatofilho@588: 
renatofilho@754:     if (abin != NULL) {
renatofilho@754:         gst_object_unref(abin);
renatofilho@754:     }
renatofilho@588: 
renatofilho@754:     if (vbin != NULL) {
renatofilho@754:         gst_object_unref(vbin);
renatofilho@754:     }
renatofilho@588: 
renatofilho@754:     return FALSE;
renatofilho@588: }
renatofilho@588: 
renatofilho@600: 
renatofilho@600: static void
renatofilho@752: _close_output(GMencoder * self)
renatofilho@588: {
renatofilho@600: }
renatofilho@600: 
renatofilho@752: static GstElement *
renatofilho@789: _create_v4l_source (GMencoder *self, const gchar * uri)
renatofilho@789: {
renatofilho@789:     gchar **info;
renatofilho@789:     GMencoderPrivate *priv = G_MENCODER_GET_PRIVATE(self);
renatofilho@789: 
renatofilho@789: 
renatofilho@789:     info = g_strsplit (uri+6, ":", 3);
renatofilho@789:     if (g_strv_length (info) != 3) {
renatofilho@789:         return NULL;
renatofilho@789:     }
renatofilho@789: 
renatofilho@789:     priv->v4lsrc = gst_element_factory_make ("v4l2src", "src");
renatofilho@789:     g_debug ("channel %s, norm %s, frequ %s", info[0], info[1], info[2]);
renatofilho@789:     g_object_set (G_OBJECT (priv->v4lsrc),
renatofilho@789:                   "channel", info[0],
renatofilho@789:                   "norm", info[1],
renatofilho@789:                   "frequency", atoi (info[2]),
renatofilho@789:                   NULL);
renatofilho@789: 
renatofilho@789:     return priv->v4lsrc;
renatofilho@789: }
renatofilho@789: 
renatofilho@789: static GstElement *
renatofilho@789: _create_source(GMencoder *self, const gchar * uri)
renatofilho@600: {
renatofilho@600: 
renatofilho@754:     GstElement     *bsrc = NULL;
renatofilho@754:     GstElement     *src = NULL;
renatofilho@754:     GstElement     *aqueue = NULL;
renatofilho@754:     GstElement     *vqueue = NULL;
renatofilho@754:     GstElement     *decode = NULL;
renatofilho@754:     GstPad         *src_pad = NULL;
renatofilho@600: 
renatofilho@600: 
renatofilho@754:     bsrc = gst_bin_new(NULL);
renatofilho@600: 
renatofilho@754:     // src = gst_element_factory_make ("gnomevfssrc", "src");
renatofilho@754:     // g_object_set (G_OBJECT (src), "location", uri, NULL);
renatofilho@789:     if (strncmp (uri, "v4l://", 6) == 0) {
renatofilho@789:         g_debug ("V4L");
renatofilho@789:         src = _create_v4l_source (self, uri);
renatofilho@789:     }
renatofilho@789:     else {
renatofilho@789:         src = gst_element_make_from_uri(GST_URI_SRC, uri, "src");
renatofilho@789:     }
renatofilho@789: 
renatofilho@754:     if (src == NULL)
renatofilho@754:         goto error;
renatofilho@600: 
renatofilho@857: 
renatofilho@857:     if (g_getenv ("USE_DECODEBIN1"))
renatofilho@857:       decode = gst_element_factory_make("decodebin", "decode");
renatofilho@857:     else
renatofilho@857:       decode = gst_element_factory_make("decodebin2", "decode");
renatofilho@754:     if (decode == NULL)
renatofilho@754:         goto error;
renatofilho@600: 
renatofilho@754:     aqueue = gst_element_factory_make("queue", "aqueue");
renatofilho@754:     if (aqueue == NULL)
renatofilho@754:         goto error;
renatofilho@600: 
renatofilho@754:     vqueue = gst_element_factory_make("queue", "vqueue");
renatofilho@754:     if (vqueue == NULL)
renatofilho@754:         goto error;
renatofilho@600: 
morphbr@831:     gst_bin_add_many(GST_BIN(bsrc), src, decode, aqueue, vqueue,
renatofilho@754:                      NULL);
morphbr@831:     gst_element_link (src, decode);
renatofilho@600: 
renatofilho@754:     g_signal_connect(G_OBJECT(decode),
renatofilho@754:                      "new-decoded-pad",
renatofilho@754:                      G_CALLBACK(_decodebin_new_pad_cb), bsrc);
renatofilho@600: 
renatofilho@754:     g_signal_connect(G_OBJECT(decode),
renatofilho@754:                      "unknown-type",
renatofilho@754:                      G_CALLBACK(_decodebin_unknown_type_cb), pipe);
renatofilho@600: 
renatofilho@754:     src_pad = gst_element_get_pad(aqueue, "src");
renatofilho@754:     gst_element_add_pad(bsrc, gst_ghost_pad_new("src_audio", src_pad));
renatofilho@754:     gst_object_unref(src_pad);
renatofilho@600: 
renatofilho@754:     src_pad = gst_element_get_pad(vqueue, "src");
renatofilho@754:     gst_element_add_pad(bsrc, gst_ghost_pad_new("src_video", src_pad));
renatofilho@754:     gst_object_unref(src_pad);
renatofilho@600: 
renatofilho@754:     return bsrc;
renatofilho@600: 
renatofilho@754:   error:
renatofilho@789:     g_debug ("Fail to create source element");
renatofilho@754:     if (src != NULL) {
renatofilho@754:         gst_object_unref(src);
renatofilho@754:     }
renatofilho@600: 
renatofilho@754:     if (decode != NULL) {
renatofilho@754:         gst_object_unref(decode);
renatofilho@754:     }
renatofilho@600: 
renatofilho@754:     if (aqueue != NULL) {
renatofilho@754:         gst_object_unref(aqueue);
renatofilho@754:     }
renatofilho@600: 
renatofilho@754:     if (vqueue != NULL) {
renatofilho@754:         gst_object_unref(vqueue);
renatofilho@754:     }
renatofilho@600: 
renatofilho@754:     return NULL;
renatofilho@600: }
renatofilho@600: 
renatofilho@757: static gboolean
renatofilho@752: _open_output(GMencoder * self, const gchar * uri)
renatofilho@600: {
renatofilho@754:     gchar         **i;
renatofilho@807:     GnomeVFSResult result;
renatofilho@754:     GMencoderPrivate *priv = G_MENCODER_GET_PRIVATE(self);
renatofilho@588: 
renatofilho@754:     i = g_strsplit(uri, "://", 0);
renatofilho@754:     if (strcmp(i[0], "fd") == 0) {
renatofilho@807:         result = gnome_vfs_open_fd (&priv->handle, atoi(i[1]));
renatofilho@789:     } else {
renatofilho@807:         if (g_file_test (i[1], G_FILE_TEST_EXISTS) == FALSE) {
melunko@826:             result = gnome_vfs_create (&priv->handle, uri, GNOME_VFS_OPEN_WRITE, FALSE,
renatofilho@807:                               GNOME_VFS_PERM_USER_WRITE | GNOME_VFS_PERM_USER_READ | GNOME_VFS_PERM_GROUP_READ);
renatofilho@807:         } else {
renatofilho@807:             result = gnome_vfs_open (&priv->handle, uri,
renatofilho@807:                                      GNOME_VFS_OPEN_WRITE | GNOME_VFS_OPEN_TRUNCATE);
renatofilho@807:         }
renatofilho@754:     }
renatofilho@588: 
renatofilho@754:     g_strfreev(i);
renatofilho@807:     return (result == GNOME_VFS_OK);
renatofilho@588: }
renatofilho@588: 
renatofilho@754: static          gboolean
renatofilho@752: _pipeline_bus_cb(GstBus * bus, GstMessage * msg, gpointer user_data)
renatofilho@588: {
renatofilho@754:     GMencoderPrivate *priv = G_MENCODER_GET_PRIVATE(user_data);
renatofilho@600: 
renatofilho@754:     switch (GST_MESSAGE_TYPE(msg)) {
renatofilho@588: 
renatofilho@754:     case GST_MESSAGE_STATE_CHANGED:
renatofilho@754:         {
renatofilho@754:             GstState        oldstate;
renatofilho@754:             GstState        newstate;
renatofilho@754:             GstState        pendingstate;
renatofilho@588: 
morphbr@748: 
renatofilho@754:             gst_message_parse_state_changed(msg, &oldstate,
renatofilho@754:                                             &newstate, &pendingstate);
renatofilho@588: 
renatofilho@754:             if (pendingstate != GST_STATE_VOID_PENDING)
renatofilho@754:                 break;
renatofilho@588: 
renatofilho@754:             if ((oldstate == GST_STATE_READY)
renatofilho@754:                 && (newstate == GST_STATE_PAUSED)) {
renatofilho@754:                 if (priv->ready)
renatofilho@754:                     g_signal_emit(user_data, g_mencoder_signals[PAUSED],
renatofilho@754:                                   0);
renatofilho@754:             } else if ((oldstate == GST_STATE_PAUSED)
renatofilho@754:                        && (newstate == GST_STATE_PLAYING)) {
renatofilho@754:                 g_signal_emit(user_data, g_mencoder_signals[PLAYING], 0);
renatofilho@754:             } else if ((oldstate == GST_STATE_READY) &&
renatofilho@754:                        (newstate == GST_STATE_NULL)) {
renatofilho@754:                 g_signal_emit(user_data, g_mencoder_signals[STOPED], 0);
renatofilho@754:             }
renatofilho@754:             break;
renatofilho@754:         }
renatofilho@678: 
renatofilho@754:     case GST_MESSAGE_ERROR:
renatofilho@754:         {
renatofilho@754:             GError         *error;
renatofilho@754:             gchar          *debug;
renatofilho@754:             gchar          *err_str;
morphbr@748: 
renatofilho@754:             if (priv->tick_id != 0) {
renatofilho@754:                 g_source_remove(priv->tick_id);
renatofilho@754:                 priv->tick_id = 0;
renatofilho@754:             }
morphbr@748: 
renatofilho@754:             gst_message_parse_error(msg, &error, &debug);
renatofilho@754:             err_str = g_strdup_printf("Error [%d] %s (%s)", error->code,
renatofilho@754:                                       error->message, debug);
renatofilho@754:             priv->ready = FALSE;
renatofilho@754:             g_signal_emit(user_data, g_mencoder_signals[ERROR], 0,
renatofilho@754:                           err_str);
renatofilho@754:             g_free(err_str);
renatofilho@754:             g_clear_error(&error);
renatofilho@754:             g_free(debug);
renatofilho@754:             break;
renatofilho@754:         }
morphbr@748: 
renatofilho@754:     case GST_MESSAGE_EOS:
renatofilho@754:         priv->ready = FALSE;
renatofilho@807: #ifdef USE_MANUAL_SINK
renatofilho@781:         _flush_queue (G_MENCODER (user_data));
renatofilho@807: #endif
renatofilho@754:         g_signal_emit(user_data, g_mencoder_signals[EOS], 0);
renatofilho@754:         break;
morphbr@748: 
renatofilho@754:     case GST_MESSAGE_DURATION:
renatofilho@754:         {
renatofilho@754:             GstFormat       format;
renatofilho@754:             gint64          duration;
renatofilho@754:             gst_message_parse_duration(msg, &format, &duration);
renatofilho@754:             if (format == GST_FORMAT_BYTES)
renatofilho@754:                 priv->duration = duration;
renatofilho@754:             break;
renatofilho@754:         }
renatofilho@754:     default:
renatofilho@754:         {
renatofilho@754:             break;
renatofilho@754:         }
renatofilho@754:     }
renatofilho@754:     return TRUE;
renatofilho@588: }
renatofilho@588: 
renatofilho@600: 
renatofilho@600: 
morphbr@748: static void
renatofilho@752: _decodebin_new_pad_cb(GstElement * object,
renatofilho@754:                       GstPad * pad, gboolean flag, gpointer user_data)
renatofilho@588: {
renatofilho@754:     GstCaps        *caps;
renatofilho@754:     gchar          *str_caps = NULL;
renatofilho@754:     GstElement     *sink_element;
renatofilho@754:     GstPad         *sink_pad;
renatofilho@588: 
renatofilho@754:     caps = gst_pad_get_caps(pad);
renatofilho@754:     str_caps = gst_caps_to_string(caps);
renatofilho@754:     if (strstr(str_caps, "audio") != NULL) {
renatofilho@754:         sink_element = gst_bin_get_by_name(GST_BIN(user_data), "aqueue");
renatofilho@754:     } else if (strstr(str_caps, "video") != NULL) {
renatofilho@754:         sink_element = gst_bin_get_by_name(GST_BIN(user_data), "vqueue");
renatofilho@754:     } else {
renatofilho@754:         g_warning("invalid caps %s", str_caps);
renatofilho@754:     }
renatofilho@588: 
renatofilho@754:     sink_pad = gst_element_get_pad(sink_element, "sink");
renatofilho@754:     gst_pad_link(pad, sink_pad);
renatofilho@600: 
renatofilho@754:     gst_object_unref(sink_element);
renatofilho@754:     gst_object_unref(sink_pad);
renatofilho@754:     g_free(str_caps);
renatofilho@754:     gst_caps_unref(caps);
renatofilho@588: }
renatofilho@588: 
morphbr@748: static void
renatofilho@752: _decodebin_unknown_type_cb(GstElement * object,
renatofilho@754:                            GstPad * pad, GstCaps * caps,
renatofilho@754:                            gpointer user_data)
renatofilho@588: {
renatofilho@754:     g_warning("Unknown Type");
renatofilho@754:     // priv->ready = FALSE;
renatofilho@588: }
renatofilho@654: 
renatofilho@754: static          gboolean
renatofilho@752: _tick_cb(gpointer user_data)
renatofilho@654: {
renatofilho@754:     GstFormat       format = GST_FORMAT_BYTES;
renatofilho@754:     gint64          cur = 0;
renatofilho@654: 
renatofilho@754:     GMencoderPrivate *priv = G_MENCODER_GET_PRIVATE(user_data);
renatofilho@654: 
renatofilho@754:     if (priv->duration == 0) {
renatofilho@754:         gint64          d = 0;
renatofilho@754:         if (gst_element_query_duration(priv->src, &format, &d))
renatofilho@754:             priv->duration = d;
renatofilho@754:     }
renatofilho@671: 
renatofilho@754:     if (priv->duration != 0) {
renatofilho@754:         gst_element_query_position(priv->src, &format, &cur);
renatofilho@754:         g_print("PROGRESS:%lli\n", (99 * cur) / priv->duration);
renatofilho@754:     }
renatofilho@654: 
renatofilho@754:     return TRUE;
renatofilho@654: }
renatofilho@761: 
renatofilho@807: static gboolean 
renatofilho@807: _process_timeout_cb (gpointer user_data)
renatofilho@807: {
renatofilho@807:     GMencoderPrivate *priv = G_MENCODER_GET_PRIVATE(user_data);
renatofilho@761: 
renatofilho@807:     g_signal_emit(user_data, g_mencoder_signals[ERROR], 0, "timeout");
renatofilho@807:     priv->timeout_id = 0;
renatofilho@807:     return FALSE;
renatofilho@807: }
renatofilho@807: 
renatofilho@807: 
renatofilho@807: #ifdef USE_MANUAL_SINK
renatofilho@807: static gboolean
renatofilho@807: _send_buffer (GnomeVFSHandle *handle, gpointer buff, gint size)
renatofilho@762: {
renatofilho@762:     gchar *msg;
renatofilho@762:     GByteArray *b_send;
renatofilho@807:     GnomeVFSResult result;
renatofilho@807:     GnomeVFSFileSize bytes_written;
renatofilho@762: 
renatofilho@762:     b_send = g_byte_array_new ();
renatofilho@807:     msg = g_strdup_printf ("%x\r\n", size);
renatofilho@762:     b_send = g_byte_array_append (b_send, (const guint8*) msg, strlen (msg) * sizeof (gchar));
renatofilho@762:     g_free (msg);
renatofilho@762: 
renatofilho@807:     b_send = g_byte_array_append (b_send, buff, size);
renatofilho@762: 
renatofilho@762:     msg = g_strdup ("\r\n");
renatofilho@762:     b_send = g_byte_array_append (b_send, (const guint8*) msg, strlen (msg) * sizeof (gchar));
renatofilho@762:     g_free (msg);
renatofilho@762: 
renatofilho@807:     result = gnome_vfs_write (handle, b_send->data, b_send->len, &bytes_written);
renatofilho@807:     g_byte_array_free (b_send, TRUE);
renatofilho@762: 
renatofilho@807:     return (result == GNOME_VFS_OK);
renatofilho@762: }
renatofilho@762: 
renatofilho@762: static void
renatofilho@762: _flush_queue (GMencoder *self)
renatofilho@762: {
renatofilho@762:     GMencoderPrivate *priv = G_MENCODER_GET_PRIVATE(self);
renatofilho@762: 
renatofilho@781:     if (priv->send_chunked) {
renatofilho@807:         GnomeVFSFileSize bytes_written;
renatofilho@781:         gchar *end_msg;
renatofilho@781:         end_msg = g_strdup ("0\r\n\r\n");
renatofilho@789:         gnome_vfs_write (priv->handle,
renatofilho@789:                          (const guint8*) end_msg,
renatofilho@786:                          strlen(end_msg) * sizeof(gchar),
renatofilho@786:                          &bytes_written);
renatofilho@781:         g_free (end_msg);
renatofilho@762:     }
renatofilho@762: }
renatofilho@786: 
renatofilho@789: static void
renatofilho@761: _buffer_arrive_cb (GstElement* object,
renatofilho@807:                    GstBuffer* buff,
renatofilho@807:                    GstPad* pad,
renatofilho@761:                    gpointer user_data)
renatofilho@761: {
renatofilho@762:     GMencoderPrivate *priv = G_MENCODER_GET_PRIVATE(user_data);
renatofilho@761: 
renatofilho@807:     if (priv->timeout_id != 0) {
renatofilho@807: 	g_source_remove (priv->timeout_id);
renatofilho@807: 	priv->timeout_id = 0;
renatofilho@807:     }
renatofilho@807: 
renatofilho@781:     if (priv->send_chunked) {
renatofilho@807:         if (_send_buffer (priv->handle, GST_BUFFER_DATA (buff), GST_BUFFER_SIZE (buff)) == FALSE)
renatofilho@807:             goto error;
renatofilho@807:     } else {
renatofilho@807:         GnomeVFSResult result;
renatofilho@807:         GnomeVFSFileSize bytes_written;
renatofilho@807: 
renatofilho@807:         result = gnome_vfs_write (priv->handle,
renatofilho@807:                                   GST_BUFFER_DATA (buff),
renatofilho@807:                                   GST_BUFFER_SIZE (buff),
renatofilho@807:                                   &bytes_written);
renatofilho@807: 
renatofilho@807:         if (result != GNOME_VFS_OK)
renatofilho@807:             goto error;
renatofilho@762:     }
renatofilho@807: 
renatofilho@807:     return;
renatofilho@807: 
renatofilho@807: error:
renatofilho@807:     if (priv->tick_id != 0) {
renatofilho@807:         g_source_remove(priv->tick_id);
renatofilho@807:         priv->tick_id = 0;
renatofilho@807:     }
renatofilho@807:     g_signal_emit(user_data, g_mencoder_signals[ERROR], 0, "Fail to write on socket");
renatofilho@807:     gst_element_set_state (priv->pipe, GST_STATE_PAUSED);
renatofilho@761: }
renatofilho@807: 
renatofilho@807: #endif