return NULL;
}
+ g_print ("%d\n", readbytes);
if (readbytes < src->bytes_per_read) {
// FIXME: set the buffer's EOF bit here
}
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);
#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
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;
buffer->pool = pool;
buffer->free = pool->buffer_free;
buffer->copy = pool->buffer_copy;
- buffer->pool_private = pool->user_data;
return buffer;
}
if (buf2->maxage > buf1->maxage) newbuf->maxage = buf2->maxage;
else newbuf->maxage = buf1->maxage;
- newbuf->parent = NULL;
- newbuf->pool = NULL;
-
return newbuf;
}
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,
#include "gsttype.h"
#include "gstbin.h"
#include "gstscheduler.h"
-#include "gstmarshal.h"
/***** Start with the base GstPad class *****/
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);
return NULL;
}
+ g_print ("%d\n", readbytes);
if (readbytes < src->bytes_per_read) {
// FIXME: set the buffer's EOF bit here
}
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);