diff --git a/gst/elements/gsthttpsrc.c b/gst/elements/gsthttpsrc.c index 7fbc5eb107..f5fa68e778 100644 --- a/gst/elements/gsthttpsrc.c +++ b/gst/elements/gsthttpsrc.c @@ -146,6 +146,7 @@ gst_httpsrc_get(GstPad *pad) return NULL; } + g_print ("%d\n", readbytes); if (readbytes < src->bytes_per_read) { // FIXME: set the buffer's EOF bit here } @@ -168,6 +169,7 @@ gst_httpsrc_open_url (GstHttpSrc *httpsrc) ghttp_set_uri (httpsrc->request, httpsrc->url); ghttp_set_sync (httpsrc->request, ghttp_async); + ghttp_set_chunksize (httpsrc->request, httpsrc->bytes_per_read); ghttp_set_header (httpsrc->request, "User-Agent", "GstHttpSrc"); ghttp_prepare (httpsrc->request); diff --git a/gst/gobject2gtk.h b/gst/gobject2gtk.h index c6544445d5..de45fdb901 100644 --- a/gst/gobject2gtk.h +++ b/gst/gobject2gtk.h @@ -72,6 +72,11 @@ typedef struct _GObjectClass GObjectClass; #define gst_marshal_VOID__OBJECT_POINTER gtk_marshal_NONE__POINTER_POINTER #define gst_marshal_VOID__INT_INT gtk_marshal_NONE__INT_INT +#define gst_marshal_VOID__INT gtk_marshal_NONE__INT +#define gst_marshal_VOID__STRING gtk_marshal_NONE__STRING +#define gst_marshal_VOID__VOID gtk_marshal_NONE__NONE +#define gst_marshal_VOID__BOOLEAN gtk_marshal_NONE__BOOL +#define gst_marshal_VOID__POINTER gtk_marshal_NONE__POINTER /* General macros */ #ifdef __cplusplus diff --git a/gst/gstbin.c b/gst/gstbin.c index de2cf7176f..0e5670b3d6 100644 --- a/gst/gstbin.c +++ b/gst/gstbin.c @@ -109,7 +109,7 @@ gst_bin_class_init (GstBinClass *klass) gst_bin_signals[OBJECT_ADDED] = g_signal_new ("object_added", G_TYPE_FROM_CLASS(klass), G_SIGNAL_RUN_FIRST, G_STRUCT_OFFSET (GstBinClass, object_added), NULL, NULL, - gst_marshal_VOID__OBJECT, G_TYPE_NONE, 1, + gst_marshal_VOID__OBJECT_POINTER, G_TYPE_NONE, 1, GST_TYPE_ELEMENT); klass->change_state_type = gst_bin_change_state_type; diff --git a/gst/gstbuffer.c b/gst/gstbuffer.c index 3b13f1e1ac..3970c60176 100644 --- a/gst/gstbuffer.c +++ b/gst/gstbuffer.c @@ -102,7 +102,6 @@ gst_buffer_new_from_pool (GstBufferPool *pool, guint64 location, gint size) buffer->pool = pool; buffer->free = pool->buffer_free; buffer->copy = pool->buffer_copy; - buffer->pool_private = pool->user_data; return buffer; } @@ -454,9 +453,6 @@ gst_buffer_span (GstBuffer *buf1, guint32 offset, GstBuffer *buf2, guint32 len) if (buf2->maxage > buf1->maxage) newbuf->maxage = buf2->maxage; else newbuf->maxage = buf1->maxage; - newbuf->parent = NULL; - newbuf->pool = NULL; - return newbuf; } diff --git a/gst/gstelement.c b/gst/gstelement.c index 2122a11fb7..388c139e18 100644 --- a/gst/gstelement.c +++ b/gst/gstelement.c @@ -108,22 +108,22 @@ gst_element_class_init (GstElementClass *klass) gst_element_signals[NEW_PAD] = g_signal_new ("new_pad", G_TYPE_FROM_CLASS(klass), G_SIGNAL_RUN_LAST, G_STRUCT_OFFSET (GstElementClass, new_pad), NULL, NULL, - gst_marshal_VOID__OBJECT, G_TYPE_NONE, 1, + gst_marshal_VOID__OBJECT_POINTER, G_TYPE_NONE, 1, GST_TYPE_PAD); gst_element_signals[PAD_REMOVED] = g_signal_new ("pad_removed", G_TYPE_FROM_CLASS(klass), G_SIGNAL_RUN_LAST, G_STRUCT_OFFSET (GstElementClass, pad_removed), NULL, NULL, - gst_marshal_VOID__OBJECT, G_TYPE_NONE, 1, + gst_marshal_VOID__OBJECT_POINTER, G_TYPE_NONE, 1, GST_TYPE_PAD); gst_element_signals[NEW_GHOST_PAD] = g_signal_new ("new_ghost_pad", G_TYPE_FROM_CLASS(klass), G_SIGNAL_RUN_LAST, G_STRUCT_OFFSET (GstElementClass, new_ghost_pad), NULL, NULL, - gst_marshal_VOID__OBJECT, G_TYPE_NONE, 1, + gst_marshal_VOID__OBJECT_POINTER, G_TYPE_NONE, 1, GST_TYPE_PAD); gst_element_signals[GHOST_PAD_REMOVED] = g_signal_new ("ghost_pad_removed", G_TYPE_FROM_CLASS(klass), G_SIGNAL_RUN_LAST, G_STRUCT_OFFSET (GstElementClass, ghost_pad_removed), NULL, NULL, - gst_marshal_VOID__OBJECT, G_TYPE_NONE, 1, + gst_marshal_VOID__OBJECT_POINTER, G_TYPE_NONE, 1, GST_TYPE_PAD); gst_element_signals[ERROR] = g_signal_new ("error", G_TYPE_FROM_CLASS(klass), G_SIGNAL_RUN_LAST, diff --git a/gst/gstpad.c b/gst/gstpad.c index 0f94ea9eeb..8bd351c0ea 100644 --- a/gst/gstpad.c +++ b/gst/gstpad.c @@ -28,7 +28,6 @@ #include "gsttype.h" #include "gstbin.h" #include "gstscheduler.h" -#include "gstmarshal.h" /***** Start with the base GstPad class *****/ @@ -1632,7 +1631,7 @@ gst_padtemplate_class_init (GstPadTemplateClass *klass) gst_padtemplate_signals[TEMPL_PAD_CREATED] = g_signal_new ("pad_created", G_TYPE_FROM_CLASS(klass), G_SIGNAL_RUN_LAST, G_STRUCT_OFFSET (GstPadTemplateClass, pad_created), NULL, NULL, - gst_marshal_VOID__OBJECT, G_TYPE_NONE, 1, + gst_marshal_VOID__OBJECT_POINTER, G_TYPE_NONE, 1, GST_TYPE_PAD); diff --git a/plugins/elements/gsthttpsrc.c b/plugins/elements/gsthttpsrc.c index 7fbc5eb107..f5fa68e778 100644 --- a/plugins/elements/gsthttpsrc.c +++ b/plugins/elements/gsthttpsrc.c @@ -146,6 +146,7 @@ gst_httpsrc_get(GstPad *pad) return NULL; } + g_print ("%d\n", readbytes); if (readbytes < src->bytes_per_read) { // FIXME: set the buffer's EOF bit here } @@ -168,6 +169,7 @@ gst_httpsrc_open_url (GstHttpSrc *httpsrc) ghttp_set_uri (httpsrc->request, httpsrc->url); ghttp_set_sync (httpsrc->request, ghttp_async); + ghttp_set_chunksize (httpsrc->request, httpsrc->bytes_per_read); ghttp_set_header (httpsrc->request, "User-Agent", "GstHttpSrc"); ghttp_prepare (httpsrc->request);