mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-03-30 12:49:40 +00:00
Code Issues 1 Projects Releases Wiki Activity

/GstBuffer/GstData/ in the API where you can pass events. Fix the plugins to deal with that. Fixes #113488.

Browse source 
Original commit message from CVS:
/GstBuffer/GstData/ in the API where you can pass events. Fix the plugins to deal with that. Fixes #113488.
This commit is contained in:
Andy Wingo 2003-10-08 16:08:18 +00:00
parent 9246e54331
commit f2d5cae8da
67 changed files with 288 additions and 237 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
common

@ -1 +1 @@
Subproject commit b7abb510aa14e8692df39ea8c2c758e37d8a8d8a Subproject commit e903f88a7388f0b463204ea1f960a4ace840175b

5
ext/aalib/gstaasink.c
View file

@ -78,7 +78,7 @@ static void gst_aasink_class_init (GstAASinkClass *klass);
static void gst_aasink_init (GstAASink *aasink); static void gst_aasink_init (GstAASink *aasink);
static void gst_aasink_set_clock (GstElement *element, GstClock *clock); static void gst_aasink_set_clock (GstElement *element, GstClock *clock);
static void gst_aasink_chain (GstPad *pad, GstBuffer *buf); static void gst_aasink_chain (GstPad *pad, GstData *_data);
static void gst_aasink_set_property (GObject *object, guint prop_id, static void gst_aasink_set_property (GObject *object, guint prop_id,
const GValue *value, GParamSpec *pspec); const GValue *value, GParamSpec *pspec);
@ -333,8 +333,9 @@ gst_aasink_scale (GstAASink *aasink, gchar *src, gchar *dest,
} }
static void static void
gst_aasink_chain (GstPad *pad, GstBuffer *buf) gst_aasink_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstAASink *aasink; GstAASink *aasink;
g_return_if_fail (pad != NULL); g_return_if_fail (pad != NULL);

8
ext/dv/gstdvdec.c
View file

@ -689,17 +689,17 @@ gst_dvdec_push (GstDVDec *dvdec, GstBuffer *outbuf, GstPad *pad, GstClockTime ts
GstEvent *discont; GstEvent *discont;
discont = gst_event_new_discontinuous (FALSE, GST_FORMAT_TIME, ts, NULL); discont = gst_event_new_discontinuous (FALSE, GST_FORMAT_TIME, ts, NULL);
gst_pad_push (pad, GST_BUFFER (discont)); gst_pad_push (pad, GST_DATA (discont));
} }
gst_pad_push (pad, outbuf); gst_pad_push (pad, GST_DATA (outbuf));
if ((dvdec->end_position != -1) && if ((dvdec->end_position != -1) &&
(dvdec->next_ts >= dvdec->end_position)) { (dvdec->next_ts >= dvdec->end_position)) {
if (dvdec->loop) if (dvdec->loop)
gst_pad_push (pad, GST_BUFFER(gst_event_new (GST_EVENT_SEGMENT_DONE))); gst_pad_push (pad, GST_DATA(gst_event_new (GST_EVENT_SEGMENT_DONE))));
else else
gst_pad_push (pad, GST_BUFFER(gst_event_new (GST_EVENT_EOS))); gst_pad_push (pad, GST_DATA(gst_event_new (GST_EVENT_EOS))));
} }
} }

6
ext/esd/esdmon.c
View file

@ -92,7 +92,7 @@ static void gst_esdmon_close_audio (GstEsdmon *src);
static GstElementStateReturn gst_esdmon_change_state (GstElement *element); static GstElementStateReturn gst_esdmon_change_state (GstElement *element);
static gboolean gst_esdmon_sync_parms (GstEsdmon *esdmon); static gboolean gst_esdmon_sync_parms (GstEsdmon *esdmon);
static GstBuffer * gst_esdmon_get (GstPad *pad); static GstData * gst_esdmon_get (GstPad *pad);
static void gst_esdmon_set_property (GObject *object, guint prop_id, static void gst_esdmon_set_property (GObject *object, guint prop_id,
const GValue *value, GParamSpec *pspec); const GValue *value, GParamSpec *pspec);
@ -225,7 +225,7 @@ gst_esdmon_sync_parms (GstEsdmon *esdmon)
return gst_esdmon_open_audio (esdmon); return gst_esdmon_open_audio (esdmon);
} }
static GstBuffer * static GstData *
gst_esdmon_get (GstPad *pad) gst_esdmon_get (GstPad *pad)
{ {
GstEsdmon *esdmon; GstEsdmon *esdmon;
@ -282,7 +282,7 @@ gst_esdmon_get (GstPad *pad)
esdmon->samples_since_basetime += readsamples; esdmon->samples_since_basetime += readsamples;
GST_DEBUG ("pushed buffer from esdmon of %ld bytes, timestamp %" G_GINT64_FORMAT, readbytes, GST_BUFFER_TIMESTAMP (buf)); GST_DEBUG ("pushed buffer from esdmon of %ld bytes, timestamp %" G_GINT64_FORMAT, readbytes, GST_BUFFER_TIMESTAMP (buf));
return buf; return GST_DATA (buf);
} }
static void static void

5
ext/esd/esdsink.c
View file

@ -93,7 +93,7 @@ static GstPadLinkReturn gst_esdsink_sinkconnect (GstPad *pad, GstCaps *caps);
static GstClockTime gst_esdsink_get_time (GstClock *clock, gpointer data); static GstClockTime gst_esdsink_get_time (GstClock *clock, gpointer data);
static GstClock * gst_esdsink_get_clock (GstElement *element); static GstClock * gst_esdsink_get_clock (GstElement *element);
static void gst_esdsink_set_clock (GstElement *element, GstClock *clock); static void gst_esdsink_set_clock (GstElement *element, GstClock *clock);
static void gst_esdsink_chain (GstPad *pad, GstBuffer *buf); static void gst_esdsink_chain (GstPad *pad, GstData *_data);
static void gst_esdsink_set_property (GObject *object, guint prop_id, static void gst_esdsink_set_property (GObject *object, guint prop_id,
const GValue *value, GParamSpec *pspec); const GValue *value, GParamSpec *pspec);
@ -259,8 +259,9 @@ gst_esdsink_set_clock (GstElement *element, GstClock *clock)
} }
static void static void
gst_esdsink_chain (GstPad *pad, GstBuffer *buf) gst_esdsink_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstEsdsink *esdsink; GstEsdsink *esdsink;
esdsink = GST_ESDSINK (gst_pad_get_parent (pad)); esdsink = GST_ESDSINK (gst_pad_get_parent (pad));

6
ext/flac/gstflacdec.c
View file

@ -451,7 +451,7 @@ gst_flacdec_write (const FLAC__SeekableStreamDecoder *decoder,
GST_FORMAT_DEFAULT, flacdec->total_samples, GST_FORMAT_DEFAULT, flacdec->total_samples,
NULL); NULL);
gst_pad_push (flacdec->srcpad, GST_BUFFER (discont)); gst_pad_push (flacdec->srcpad, GST_DATA (discont));
} }
} }
} }
@ -502,7 +502,7 @@ gst_flacdec_write (const FLAC__SeekableStreamDecoder *decoder,
g_warning ("flacdec: invalid depth %d found\n", depth); g_warning ("flacdec: invalid depth %d found\n", depth);
return FLAC__STREAM_DECODER_WRITE_STATUS_ABORT; return FLAC__STREAM_DECODER_WRITE_STATUS_ABORT;
} }
gst_pad_push (flacdec->srcpad, outbuf); gst_pad_push (flacdec->srcpad, GST_DATA (outbuf));
} }
flacdec->total_samples += samples; flacdec->total_samples += samples;
@ -555,7 +555,7 @@ gst_flacdec_loop (GstElement *element)
if (GST_PAD_IS_USABLE (flacdec->srcpad)) { if (GST_PAD_IS_USABLE (flacdec->srcpad)) {
event = gst_event_new (GST_EVENT_EOS); event = gst_event_new (GST_EVENT_EOS);
gst_pad_push (flacdec->srcpad, GST_BUFFER (event)); gst_pad_push (flacdec->srcpad, GST_DATA (event));
} }
gst_element_set_eos (element); gst_element_set_eos (element);
} }

9
ext/flac/gstflacenc.c
View file

@ -70,7 +70,7 @@ static void gst_flacenc_dispose (GObject *object);
static GstPadLinkReturn static GstPadLinkReturn
gst_flacenc_sinkconnect (GstPad *pad, GstCaps *caps); gst_flacenc_sinkconnect (GstPad *pad, GstCaps *caps);
static void gst_flacenc_chain (GstPad *pad, GstBuffer *buf); static void gst_flacenc_chain (GstPad *pad, GstData *_data);
static gboolean gst_flacenc_update_quality (FlacEnc *flacenc, gint quality); static gboolean gst_flacenc_update_quality (FlacEnc *flacenc, gint quality);
static void gst_flacenc_set_property (GObject *object, guint prop_id, static void gst_flacenc_set_property (GObject *object, guint prop_id,
@ -410,7 +410,7 @@ GstEvent *event;
event = gst_event_new_seek ((GstSeekType)(int)(GST_FORMAT_BYTES | GST_SEEK_METHOD_SET), absolute_byte_offset); event = gst_event_new_seek ((GstSeekType)(int)(GST_FORMAT_BYTES | GST_SEEK_METHOD_SET), absolute_byte_offset);
if (event) if (event)
gst_pad_push (flacenc->srcpad, GST_BUFFER (event)); gst_pad_push (flacenc->srcpad, GST_DATA (event));
return FLAC__STREAM_ENCODER_OK; return FLAC__STREAM_ENCODER_OK;
} }
@ -439,7 +439,7 @@ gst_flacenc_write_callback (const FLAC__SeekableStreamEncoder *encoder,
flacenc->first = FALSE; flacenc->first = FALSE;
} }
gst_pad_push (flacenc->srcpad, outbuf); gst_pad_push (flacenc->srcpad, GST_DATA (outbuf));
return FLAC__STREAM_ENCODER_OK; return FLAC__STREAM_ENCODER_OK;
} }
@ -485,8 +485,9 @@ gst_flacenc_set_metadata (FlacEnc *flacenc, GstCaps *caps)
static void static void
gst_flacenc_chain (GstPad *pad, GstBuffer *buf) gst_flacenc_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
FlacEnc *flacenc; FlacEnc *flacenc;
FLAC__int32 *data; FLAC__int32 *data;
gulong insize; gulong insize;

7
ext/gdk_pixbuf/gstgdkpixbuf.c
View file

@ -106,7 +106,7 @@ static void gst_gdk_pixbuf_get_property(GObject *object, guint prop_id,
GValue *value, GValue *value,
GParamSpec *pspec); GParamSpec *pspec);
static void gst_gdk_pixbuf_chain (GstPad *pad, GstBuffer *buf); static void gst_gdk_pixbuf_chain (GstPad *pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
@ -267,8 +267,9 @@ gst_gdk_pixbuf_init (GstGdkPixbuf *filter)
} }
static void static void
gst_gdk_pixbuf_chain (GstPad *pad, GstBuffer *buf) gst_gdk_pixbuf_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstGdkPixbuf *filter; GstGdkPixbuf *filter;
GdkPixbufLoader *pixbuf_loader; GdkPixbufLoader *pixbuf_loader;
GdkPixbuf *pixbuf; GdkPixbuf *pixbuf;
@ -322,7 +323,7 @@ gst_gdk_pixbuf_chain (GstPad *pad, GstBuffer *buf)
g_object_unref(G_OBJECT(pixbuf_loader)); g_object_unref(G_OBJECT(pixbuf_loader));
gst_pad_push (filter->srcpad, outbuf); gst_pad_push (filter->srcpad, GST_DATA (outbuf));
} }
static void static void

7
ext/jpeg/gstjpegdec.c
View file

@ -53,7 +53,7 @@ enum {
static void gst_jpegdec_class_init (GstJpegDec *klass); static void gst_jpegdec_class_init (GstJpegDec *klass);
static void gst_jpegdec_init (GstJpegDec *jpegdec); static void gst_jpegdec_init (GstJpegDec *jpegdec);
static void gst_jpegdec_chain (GstPad *pad, GstBuffer *buf); static void gst_jpegdec_chain (GstPad *pad, GstData *_data);
static GstPadLinkReturn static GstPadLinkReturn
gst_jpegdec_link (GstPad *pad, GstCaps *caps); gst_jpegdec_link (GstPad *pad, GstCaps *caps);
@ -303,8 +303,9 @@ static void guarantee_huff_tables(j_decompress_ptr dinfo)
} }
static void static void
gst_jpegdec_chain (GstPad *pad, GstBuffer *buf) gst_jpegdec_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstJpegDec *jpegdec; GstJpegDec *jpegdec;
guchar *data, *outdata; guchar *data, *outdata;
gulong size, outsize; gulong size, outsize;
@ -410,7 +411,7 @@ gst_jpegdec_chain (GstPad *pad, GstBuffer *buf)
jpeg_finish_decompress(&jpegdec->cinfo); jpeg_finish_decompress(&jpegdec->cinfo);
GST_DEBUG ("gst_jpegdec_chain: sending buffer"); GST_DEBUG ("gst_jpegdec_chain: sending buffer");
gst_pad_push(jpegdec->srcpad, outbuf); gst_pad_push(jpegdec->srcpad, GST_DATA (outbuf));
gst_buffer_unref(buf); gst_buffer_unref(buf);
} }

13
ext/jpeg/gstjpegenc.c
View file

@ -51,10 +51,10 @@ enum {
static void gst_jpegenc_class_init (GstJpegEnc *klass); static void gst_jpegenc_class_init (GstJpegEnc *klass);
static void gst_jpegenc_init (GstJpegEnc *jpegenc); static void gst_jpegenc_init (GstJpegEnc *jpegenc);
static void gst_jpegenc_chain (GstPad *pad,GstBuffer *buf); static void gst_jpegenc_chain (GstPad *pad,GstData *_data);
static GstPadLinkReturn gst_jpegenc_link (GstPad *pad, GstCaps *caps); static GstPadLinkReturn gst_jpegenc_link (GstPad *pad, GstCaps *caps);
static GstBuffer *gst_jpegenc_get (GstPad *pad); static GstData *gst_jpegenc_get (GstPad *pad);
static void gst_jpegenc_resync (GstJpegEnc *jpegenc); static void gst_jpegenc_resync (GstJpegEnc *jpegenc);
@ -241,7 +241,7 @@ gst_jpegenc_resync (GstJpegEnc *jpegenc)
GST_DEBUG ("gst_jpegenc_resync: resync done"); GST_DEBUG ("gst_jpegenc_resync: resync done");
} }
static GstBuffer* static GstData*
gst_jpegenc_get (GstPad *pad) gst_jpegenc_get (GstPad *pad)
{ {
GstJpegEnc *jpegenc; GstJpegEnc *jpegenc;
@ -263,12 +263,13 @@ gst_jpegenc_get (GstPad *pad)
} }
gst_buffer_ref(jpegenc->buffer); gst_buffer_ref(jpegenc->buffer);
return jpegenc->buffer; return GST_DATA (jpegenc->buffer);
} }
static void static void
gst_jpegenc_chain (GstPad *pad, GstBuffer *buf) gst_jpegenc_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstJpegEnc *jpegenc; GstJpegEnc *jpegenc;
guchar *data, *outdata; guchar *data, *outdata;
gulong size, outsize; gulong size, outsize;
@ -326,7 +327,7 @@ gst_jpegenc_chain (GstPad *pad, GstBuffer *buf)
GST_BUFFER_SIZE(outbuf) = (((outsize - jpegenc->jdest.free_in_buffer)+3)&~3); GST_BUFFER_SIZE(outbuf) = (((outsize - jpegenc->jdest.free_in_buffer)+3)&~3);
gst_pad_push(jpegenc->srcpad, outbuf); gst_pad_push(jpegenc->srcpad, GST_DATA (outbuf));
g_signal_emit(G_OBJECT(jpegenc),gst_jpegenc_signals[FRAME_ENCODED], 0); g_signal_emit(G_OBJECT(jpegenc),gst_jpegenc_signals[FRAME_ENCODED], 0);

19
ext/ladspa/gstladspa.c
View file

@ -76,8 +76,8 @@ static void gst_ladspa_deactivate (GstLADSPA *ladspa);
static GstElementStateReturn gst_ladspa_change_state (GstElement *element); static GstElementStateReturn gst_ladspa_change_state (GstElement *element);
static void gst_ladspa_loop (GstElement *element); static void gst_ladspa_loop (GstElement *element);
static void gst_ladspa_chain (GstPad *pad,GstBuffer *buf); static void gst_ladspa_chain (GstPad *pad,GstData *_data);
static GstBuffer * gst_ladspa_get (GstPad *pad); static GstData * gst_ladspa_get (GstPad *pad);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
@ -676,13 +676,13 @@ gst_ladspa_loop (GstElement *element)
/* first get all the necessary data from the input ports */ /* first get all the necessary data from the input ports */
for (i=0 ; i<numsinkpads ; i++){ for (i=0 ; i<numsinkpads ; i++){
get_buffer: get_buffer:
buffers_in[i] = gst_pad_pull (ladspa->sinkpads[i]); buffers_in[i] = GST_BUFFER (gst_pad_pull (ladspa->sinkpads[i]));
if (GST_IS_EVENT (buffers_in[i])) { if (GST_IS_EVENT (buffers_in[i])) {
/* push it out on all pads */ /* push it out on all pads */
gst_data_ref_by_count ((GstData*)buffers_in[i], numsrcpads); gst_data_ref_by_count ((GstData*)buffers_in[i], numsrcpads);
for (j=0; j<numsrcpads; j++) for (j=0; j<numsrcpads; j++)
gst_pad_push (ladspa->srcpads[j], buffers_in[i]); gst_pad_push (ladspa->srcpads[j], GST_DATA (buffers_in[i]));
if (GST_EVENT_TYPE (buffers_in[i]) == GST_EVENT_EOS) { if (GST_EVENT_TYPE (buffers_in[i]) == GST_EVENT_EOS) {
/* shut down */ /* shut down */
gst_element_set_eos (element); gst_element_set_eos (element);
@ -753,7 +753,7 @@ gst_ladspa_loop (GstElement *element)
} }
for (i=0 ; i<numsrcpads ; i++) { for (i=0 ; i<numsrcpads ; i++) {
DEBUG_OBJ (ladspa, "pushing buffer (%p) on src pad %d", buffers_out[i], i); DEBUG_OBJ (ladspa, "pushing buffer (%p) on src pad %d", buffers_out[i], i);
gst_pad_push (ladspa->srcpads[i], buffers_out[i]); gst_pad_push (ladspa->srcpads[i], GST_DATA (buffers_out[i]));
data_out[i] = NULL; data_out[i] = NULL;
buffers_out[i] = NULL; buffers_out[i] = NULL;
@ -770,8 +770,9 @@ gst_ladspa_loop (GstElement *element)
} }
static void static void
gst_ladspa_chain (GstPad *pad, GstBuffer *buffer_in) gst_ladspa_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buffer_in = GST_BUFFER (_data);
LADSPA_Descriptor *desc; LADSPA_Descriptor *desc;
LADSPA_Data *data_in, **data_out = NULL; LADSPA_Data *data_in, **data_out = NULL;
GstBuffer **buffers_out = NULL; GstBuffer **buffers_out = NULL;
@ -850,7 +851,7 @@ gst_ladspa_chain (GstPad *pad, GstBuffer *buffer_in)
for (i=0; i<numsrcpads; i++) { for (i=0; i<numsrcpads; i++) {
DEBUG_OBJ (ladspa, "pushing buffer (%p, length %u bytes) on src pad %d", DEBUG_OBJ (ladspa, "pushing buffer (%p, length %u bytes) on src pad %d",
buffers_out[i], GST_BUFFER_SIZE (buffers_out[i]), i); buffers_out[i], GST_BUFFER_SIZE (buffers_out[i]), i);
gst_pad_push (ladspa->srcpads[i], buffers_out[i]); gst_pad_push (ladspa->srcpads[i], GST_DATA (buffers_out[i]));
} }
g_free(buffers_out); g_free(buffers_out);
@ -858,7 +859,7 @@ gst_ladspa_chain (GstPad *pad, GstBuffer *buffer_in)
} }
} }
static GstBuffer * static GstData *
gst_ladspa_get(GstPad *pad) gst_ladspa_get(GstPad *pad)
{ {
GstLADSPA *ladspa; GstLADSPA *ladspa;
@ -902,7 +903,7 @@ gst_ladspa_get(GstPad *pad)
num_processed = num_to_process; num_processed = num_to_process;
} }
return buf; return GST_DATA (buf);
} }
static void static void

11
ext/libpng/gstpngenc.c
View file

@ -52,7 +52,7 @@ enum
static void gst_pngenc_class_init (GstPngEncClass *klass); static void gst_pngenc_class_init (GstPngEncClass *klass);
static void gst_pngenc_init (GstPngEnc *pngenc); static void gst_pngenc_init (GstPngEnc *pngenc);
static void gst_pngenc_chain (GstPad *pad, GstBuffer *buf); static void gst_pngenc_chain (GstPad *pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
@ -151,7 +151,7 @@ GstPngEnc *pngenc;
pngenc = (GstPngEnc *) png_get_io_ptr (png_ptr); pngenc = (GstPngEnc *) png_get_io_ptr (png_ptr);
gst_pad_push (pngenc->srcpad, GST_BUFFER (gst_event_new (GST_EVENT_FLUSH))); gst_pad_push (pngenc->srcpad, GST_DATA (gst_event_new (GST_EVENT_FLUSH)));
} }
@ -176,8 +176,9 @@ void user_write_data (png_structp png_ptr, png_bytep data, png_uint_32 length)
} }
static void static void
gst_pngenc_chain (GstPad *pad, GstBuffer *buf) gst_pngenc_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstPngEnc *pngenc; GstPngEnc *pngenc;
gint row_index; gint row_index;
png_byte *row_pointers[MAX_HEIGHT]; png_byte *row_pointers[MAX_HEIGHT];
@ -246,11 +247,11 @@ gst_pngenc_chain (GstPad *pad, GstBuffer *buf)
png_destroy_info_struct (pngenc->png_struct_ptr, &pngenc->png_info_ptr); png_destroy_info_struct (pngenc->png_struct_ptr, &pngenc->png_info_ptr);
png_destroy_write_struct (&pngenc->png_struct_ptr, (png_infopp) NULL); png_destroy_write_struct (&pngenc->png_struct_ptr, (png_infopp) NULL);
gst_pad_push (pngenc->srcpad, pngenc->buffer_out); gst_pad_push (pngenc->srcpad, GST_DATA (pngenc->buffer_out));
/* send EOS event, since a frame has been pushed out */ /* send EOS event, since a frame has been pushed out */
event = gst_event_new (GST_EVENT_EOS); event = gst_event_new (GST_EVENT_EOS);
gst_pad_push (pngenc->srcpad, GST_BUFFER (event)); gst_pad_push (pngenc->srcpad, GST_DATA (event));
gst_buffer_unref (buf); gst_buffer_unref (buf);
} }

2
ext/mikmod/drv_gst.c
View file

@ -51,7 +51,7 @@ static void mikmod_Update( void )
/* FIXME, send a flush event or something */ /* FIXME, send a flush event or something */
need_sync = 0 ; need_sync = 0 ;
} }
gst_pad_push( srcpad, outdata ); gst_pad_push( srcpad, GST_DATA (outdata ));
} }

4
ext/mikmod/gstmikmod.c
View file

@ -290,7 +290,7 @@ gst_mikmod_loop (GstElement *element)
srcpad = mikmod->srcpad; srcpad = mikmod->srcpad;
mikmod->Buffer = NULL; mikmod->Buffer = NULL;
while ((buffer_in = gst_pad_pull( mikmod->sinkpad ))) { while ((buffer_in = GST_BUFFER (gst_pad_pull( mikmod->sinkpad )))) {
if ( GST_IS_EVENT (buffer_in) ) { if ( GST_IS_EVENT (buffer_in) ) {
GstEvent *event = GST_EVENT (buffer_in); GstEvent *event = GST_EVENT (buffer_in);
@ -338,7 +338,7 @@ gst_mikmod_loop (GstElement *element)
} }
else { else {
gst_element_set_eos (GST_ELEMENT (mikmod)); gst_element_set_eos (GST_ELEMENT (mikmod));
gst_pad_push (mikmod->srcpad, GST_BUFFER (gst_event_new (GST_EVENT_EOS))); gst_pad_push (mikmod->srcpad, GST_DATA (gst_event_new (GST_EVENT_EOS))));
} }
} }

11
ext/pango/gsttextoverlay.c
View file

@ -324,8 +324,9 @@ gst_text_overlay_blit_yuv420(GstTextOverlay *overlay, FT_Bitmap *bitmap,
static void static void
gst_textoverlay_video_chain(GstPad *pad, GstBuffer *buf) gst_textoverlay_video_chain(GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstTextOverlay *overlay; GstTextOverlay *overlay;
guchar *pixbuf; guchar *pixbuf;
gint x0, y0; gint x0, y0;
@ -368,7 +369,7 @@ gst_textoverlay_video_chain(GstPad *pad, GstBuffer *buf)
if (overlay->bitmap.buffer) if (overlay->bitmap.buffer)
gst_text_overlay_blit_yuv420(overlay, &overlay->bitmap, pixbuf, x0, y0); gst_text_overlay_blit_yuv420(overlay, &overlay->bitmap, pixbuf, x0, y0);
gst_pad_push(overlay->srcpad, buf); gst_pad_push(overlay->srcpad, GST_DATA (buf));
} }
#define PAST_END(buffer, time) \ #define PAST_END(buffer, time) \
@ -388,7 +389,7 @@ gst_textoverlay_loop(GstElement *element)
g_return_if_fail(GST_IS_TEXTOVERLAY(element)); g_return_if_fail(GST_IS_TEXTOVERLAY(element));
overlay = GST_TEXTOVERLAY(element); overlay = GST_TEXTOVERLAY(element);
video_frame = gst_pad_pull(overlay->video_sinkpad); video_frame = GST_BUFFER (gst_pad_pull(overlay->video_sinkpad));
now = GST_BUFFER_TIMESTAMP(video_frame); now = GST_BUFFER_TIMESTAMP(video_frame);
/* /*
@ -409,7 +410,7 @@ gst_textoverlay_loop(GstElement *element)
if(!GST_PAD_IS_USABLE(overlay->text_sinkpad)){ if(!GST_PAD_IS_USABLE(overlay->text_sinkpad)){
break; break;
} }
overlay->next_buffer = gst_pad_pull(overlay->text_sinkpad); overlay->next_buffer = GST_BUFFER (gst_pad_pull(overlay->text_sinkpad));
if (!overlay->next_buffer) if (!overlay->next_buffer)
break; break;
@ -458,7 +459,7 @@ gst_textoverlay_loop(GstElement *element)
overlay->need_render = FALSE; overlay->need_render = FALSE;
} }
gst_textoverlay_video_chain(overlay->srcpad, video_frame); gst_textoverlay_video_chain(overlay->srcpad, GST_DATA (video_frame));
} }

4
ext/raw1394/gstdv1394src.c
View file

@ -77,7 +77,7 @@ static void gst_dv1394src_get_property (GObject *object, guint prop_id, GValue
static GstElementStateReturn gst_dv1394src_change_state (GstElement *element); static GstElementStateReturn gst_dv1394src_change_state (GstElement *element);
static GstBuffer * gst_dv1394src_get (GstPad *pad); static GstData * gst_dv1394src_get (GstPad *pad);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
/*static guint gst_filter_signals[LAST_SIGNAL] = { 0 }; */ /*static guint gst_filter_signals[LAST_SIGNAL] = { 0 }; */
@ -314,7 +314,7 @@ int gst_dv1394src_bus_reset(raw1394handle_t handle,
return 0; return 0;
} }
static GstBuffer * static GstData *
gst_dv1394src_get (GstPad *pad) gst_dv1394src_get (GstPad *pad)
{ {
GstDV1394Src *dv1394src = GST_DV1394SRC (GST_PAD_PARENT(pad)); GstDV1394Src *dv1394src = GST_DV1394SRC (GST_PAD_PARENT(pad));

5
ext/shout2/gstshout2.c
View file

@ -89,7 +89,7 @@ sink_template_factory (void)
static void gst_shout2send_class_init (GstShout2sendClass *klass); static void gst_shout2send_class_init (GstShout2sendClass *klass);
static void gst_shout2send_init (GstShout2send *shout2send); static void gst_shout2send_init (GstShout2send *shout2send);
static void gst_shout2send_chain (GstPad *pad, GstBuffer *buf); static void gst_shout2send_chain (GstPad *pad, GstData *_data);
static GstPadLinkReturn gst_shout2send_connect (GstPad *pad, GstCaps *caps); static GstPadLinkReturn gst_shout2send_connect (GstPad *pad, GstCaps *caps);
static void gst_shout2send_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); static void gst_shout2send_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
@ -217,8 +217,9 @@ gst_shout2send_init (GstShout2send *shout2send)
} }
static void static void
gst_shout2send_chain (GstPad *pad, GstBuffer *buf) gst_shout2send_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstShout2send *shout2send; GstShout2send *shout2send;
glong ret; glong ret;

5
ext/speex/gstspeexdec.c
View file

@ -52,7 +52,7 @@ enum {
static void gst_speexdec_class_init (GstSpeexDec *klass); static void gst_speexdec_class_init (GstSpeexDec *klass);
static void gst_speexdec_init (GstSpeexDec *speexdec); static void gst_speexdec_init (GstSpeexDec *speexdec);
static void gst_speexdec_chain (GstPad *pad, GstBuffer *buf); static void gst_speexdec_chain (GstPad *pad, GstData *_data);
static GstPadLinkReturn gst_speexdec_sinkconnect (GstPad *pad, GstCaps *caps); static GstPadLinkReturn gst_speexdec_sinkconnect (GstPad *pad, GstCaps *caps);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
@ -135,8 +135,9 @@ gst_speexdec_sinkconnect (GstPad *pad, GstCaps *caps)
} }
static void static void
gst_speexdec_chain (GstPad *pad, GstBuffer *buf) gst_speexdec_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstSpeexDec *speexdec; GstSpeexDec *speexdec;
gchar *data; gchar *data;
guint size; guint size;

11
ext/speex/gstspeexenc.c
View file

@ -53,7 +53,7 @@ enum {
static void gst_speexenc_class_init (GstSpeexEnc *klass); static void gst_speexenc_class_init (GstSpeexEnc *klass);
static void gst_speexenc_init (GstSpeexEnc *speexenc); static void gst_speexenc_init (GstSpeexEnc *speexenc);
static void gst_speexenc_chain (GstPad *pad,GstBuffer *buf); static void gst_speexenc_chain (GstPad *pad,GstData *_data);
static GstPadLinkReturn gst_speexenc_sinkconnect (GstPad *pad, GstCaps *caps); static GstPadLinkReturn gst_speexenc_sinkconnect (GstPad *pad, GstCaps *caps);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
@ -149,8 +149,9 @@ gst_speexenc_sinkconnect (GstPad *pad, GstCaps *caps)
} }
static void static void
gst_speexenc_chain (GstPad *pad, GstBuffer *buf) gst_speexenc_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstSpeexEnc *speexenc; GstSpeexEnc *speexenc;
GstBuffer *outbuf; GstBuffer *outbuf;
gint16 *data; gint16 *data;
@ -188,7 +189,7 @@ gst_speexenc_chain (GstPad *pad, GstBuffer *buf)
GST_BUFFER_DATA (outbuf) = header_data; GST_BUFFER_DATA (outbuf) = header_data;
GST_BUFFER_SIZE (outbuf) = size; GST_BUFFER_SIZE (outbuf) = size;
gst_pad_push (speexenc->srcpad, outbuf); gst_pad_push (speexenc->srcpad, GST_DATA (outbuf));
} }
data = (gint16 *) GST_BUFFER_DATA (buf); data = (gint16 *) GST_BUFFER_DATA (buf);
@ -214,7 +215,7 @@ gst_speexenc_chain (GstPad *pad, GstBuffer *buf)
GST_BUFFER_TIMESTAMP (outbuf) = speexenc->next_ts; GST_BUFFER_TIMESTAMP (outbuf) = speexenc->next_ts;
speex_bits_reset(&speexenc->bits); speex_bits_reset(&speexenc->bits);
gst_pad_push (speexenc->srcpad, outbuf); gst_pad_push (speexenc->srcpad, GST_DATA (outbuf));
speexenc->next_ts += frame_size * GST_SECOND / speexenc->rate; speexenc->next_ts += frame_size * GST_SECOND / speexenc->rate;
} }
@ -240,7 +241,7 @@ gst_speexenc_chain (GstPad *pad, GstBuffer *buf)
GST_BUFFER_TIMESTAMP (outbuf) = speexenc->next_ts; GST_BUFFER_TIMESTAMP (outbuf) = speexenc->next_ts;
speex_bits_reset(&speexenc->bits); speex_bits_reset(&speexenc->bits);
gst_pad_push (speexenc->srcpad, outbuf); gst_pad_push (speexenc->srcpad, GST_DATA (outbuf));
speexenc->next_ts += frame_size * GST_SECOND / speexenc->rate; speexenc->next_ts += frame_size * GST_SECOND / speexenc->rate;
} }

7
gst/audiofx/audiowsincband.c
View file

@ -104,7 +104,7 @@ static void gst_bpwsinc_set_property (GObject * object, guint prop_id,
static void gst_bpwsinc_get_property (GObject * object, guint prop_id, static void gst_bpwsinc_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec); GValue * value, GParamSpec * pspec);
static void gst_bpwsinc_chain (GstPad * pad, GstBuffer * buf); static void gst_bpwsinc_chain (GstPad * pad, GstData *_data);
static GstPadLinkReturn static GstPadLinkReturn
gst_bpwsinc_sink_connect (GstPad * pad, GstCaps * caps); gst_bpwsinc_sink_connect (GstPad * pad, GstCaps * caps);
@ -273,8 +273,9 @@ gst_bpwsinc_sink_connect (GstPad * pad, GstCaps * caps)
} }
static void static void
gst_bpwsinc_chain (GstPad *pad, GstBuffer *buf) gst_bpwsinc_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstBPWSinc *filter; GstBPWSinc *filter;
gfloat *src; gfloat *src;
gfloat *input; gfloat *input;
@ -321,7 +322,7 @@ gst_bpwsinc_chain (GstPad *pad, GstBuffer *buf)
} }
g_free (input); g_free (input);
gst_pad_push (filter->srcpad, buf); gst_pad_push (filter->srcpad, GST_DATA (buf));
} }
static void static void

7
gst/audiofx/audiowsinclimit.c
View file

@ -101,7 +101,7 @@ static void gst_lpwsinc_set_property (GObject * object, guint prop_id,
static void gst_lpwsinc_get_property (GObject * object, guint prop_id, static void gst_lpwsinc_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec); GValue * value, GParamSpec * pspec);
static void gst_lpwsinc_chain (GstPad * pad, GstBuffer * buf); static void gst_lpwsinc_chain (GstPad * pad, GstData *_data);
static GstPadLinkReturn static GstPadLinkReturn
gst_lpwsinc_sink_connect (GstPad * pad, GstCaps * caps); gst_lpwsinc_sink_connect (GstPad * pad, GstCaps * caps);
@ -221,8 +221,9 @@ gst_lpwsinc_sink_connect (GstPad * pad, GstCaps * caps)
} }
static void static void
gst_lpwsinc_chain (GstPad * pad, GstBuffer * buf) gst_lpwsinc_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstLPWSinc *filter; GstLPWSinc *filter;
gfloat *src; gfloat *src;
gfloat *input; gfloat *input;
@ -269,7 +270,7 @@ gst_lpwsinc_chain (GstPad * pad, GstBuffer * buf)
} }
g_free (input); g_free (input);
gst_pad_push (filter->srcpad, buf); gst_pad_push (filter->srcpad, GST_DATA (buf));
} }
static void static void

9
gst/auparse/gstauparse.c
View file

@ -128,7 +128,7 @@ enum {
static void gst_auparse_class_init (GstAuParseClass *klass); static void gst_auparse_class_init (GstAuParseClass *klass);
static void gst_auparse_init (GstAuParse *auparse); static void gst_auparse_init (GstAuParse *auparse);
static void gst_auparse_chain (GstPad *pad,GstBuffer *buf); static void gst_auparse_chain (GstPad *pad,GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
/*static guint gst_auparse_signals[LAST_SIGNAL] = { 0 }; */ /*static guint gst_auparse_signals[LAST_SIGNAL] = { 0 }; */
@ -184,8 +184,9 @@ gst_auparse_init (GstAuParse *auparse)
} }
static void static void
gst_auparse_chain (GstPad *pad, GstBuffer *buf) gst_auparse_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstAuParse *auparse; GstAuParse *auparse;
gchar *data; gchar *data;
glong size; glong size;
@ -305,11 +306,11 @@ gst_auparse_chain (GstPad *pad, GstBuffer *buf)
gst_buffer_unref (buf); gst_buffer_unref (buf);
gst_pad_push (auparse->srcpad, newbuf); gst_pad_push (auparse->srcpad, GST_DATA (newbuf));
return; return;
} }
gst_pad_push (auparse->srcpad, buf); gst_pad_push (auparse->srcpad, GST_DATA (buf));
} }

6
gst/avi/gstavidemux.c
View file

@ -1599,7 +1599,7 @@ gst_avi_demux_handle_sink_event (GstAviDemux *avi_demux)
discont = gst_event_new_discontinuous (FALSE, GST_FORMAT_TIME, discont = gst_event_new_discontinuous (FALSE, GST_FORMAT_TIME,
avi_demux->last_seek + stream->delay , NULL); avi_demux->last_seek + stream->delay , NULL);
gst_pad_push (stream->pad, GST_BUFFER (discont)); gst_pad_push (stream->pad, GST_DATA (discont));
} }
} }
break; break;
@ -1807,7 +1807,7 @@ gst_avi_demux_loop (GstElement *element)
else { else {
if (GST_PAD_IS_USABLE (stream->pad)) { if (GST_PAD_IS_USABLE (stream->pad)) {
if (next_ts >= stream->end_pos) { if (next_ts >= stream->end_pos) {
gst_pad_push (stream->pad, GST_BUFFER (gst_event_new (GST_EVENT_EOS))); gst_pad_push (stream->pad, GST_DATA (gst_event_new (GST_EVENT_EOS)));
GST_DEBUG ("end stream %d: %" G_GINT64_FORMAT " %d %" G_GINT64_FORMAT, GST_DEBUG ("end stream %d: %" G_GINT64_FORMAT " %d %" G_GINT64_FORMAT,
stream_id, next_ts, stream->current_frame - 1, stream_id, next_ts, stream->current_frame - 1,
stream->end_pos); stream->end_pos);
@ -1833,7 +1833,7 @@ gst_avi_demux_loop (GstElement *element)
stream_id, next_ts, stream->current_frame - 1, stream_id, next_ts, stream->current_frame - 1,
stream->delay, chunk.size); stream->delay, chunk.size);
gst_pad_push(stream->pad, buf); gst_pad_push(stream->pad, GST_DATA (buf));
} }
} }
} }

38
gst/avi/gstavimux.c
View file

@ -919,14 +919,14 @@ gst_avimux_write_index (GstAviMux *avimux)
memcpy(GST_BUFFER_DATA(buffer), "idx1", 4); memcpy(GST_BUFFER_DATA(buffer), "idx1", 4);
temp32 = LE_FROM_GUINT32(avimux->idx_index * sizeof(gst_riff_index_entry)); temp32 = LE_FROM_GUINT32(avimux->idx_index * sizeof(gst_riff_index_entry));
memcpy(GST_BUFFER_DATA(buffer)+4, &temp32, 4); memcpy(GST_BUFFER_DATA(buffer)+4, &temp32, 4);
gst_pad_push(avimux->srcpad, buffer); gst_pad_push(avimux->srcpad, GST_DATA (buffer));
buffer = gst_buffer_new(); buffer = gst_buffer_new();
GST_BUFFER_SIZE(buffer) = avimux->idx_index * sizeof(gst_riff_index_entry); GST_BUFFER_SIZE(buffer) = avimux->idx_index * sizeof(gst_riff_index_entry);
GST_BUFFER_DATA(buffer) = (unsigned char*) avimux->idx; GST_BUFFER_DATA(buffer) = (unsigned char*) avimux->idx;
avimux->idx = NULL; /* will be free()'ed by gst_buffer_unref() */ avimux->idx = NULL; /* will be free()'ed by gst_buffer_unref() */
avimux->total_data += GST_BUFFER_SIZE(buffer); avimux->total_data += GST_BUFFER_SIZE(buffer);
gst_pad_push(avimux->srcpad, buffer); gst_pad_push(avimux->srcpad, GST_DATA (buffer));
avimux->idx_size += avimux->idx_index * sizeof(gst_riff_index_entry) + 8; avimux->idx_size += avimux->idx_index * sizeof(gst_riff_index_entry) + 8;
@ -962,18 +962,18 @@ gst_avimux_bigfile(GstAviMux *avimux, gboolean last)
GST_SEEK_FLAG_FLUSH, GST_SEEK_FLAG_FLUSH,
avimux->avix_start); avimux->avix_start);
/* if the event succeeds */ /* if the event succeeds */
gst_pad_push(avimux->srcpad, GST_BUFFER(event)); gst_pad_push(avimux->srcpad, GST_DATA(event));
/* rewrite AVIX header */ /* rewrite AVIX header */
header = gst_avimux_riff_get_avix_header(avimux->datax_size); header = gst_avimux_riff_get_avix_header(avimux->datax_size);
gst_pad_push(avimux->srcpad, header); gst_pad_push(avimux->srcpad, GST_DATA (header));
/* go back to current location */ /* go back to current location */
event = gst_event_new_seek (GST_FORMAT_BYTES | event = gst_event_new_seek (GST_FORMAT_BYTES |
GST_SEEK_METHOD_SET | GST_SEEK_METHOD_SET |
GST_SEEK_FLAG_FLUSH, GST_SEEK_FLAG_FLUSH,
avimux->total_data); avimux->total_data);
gst_pad_push(avimux->srcpad, GST_BUFFER(event)); gst_pad_push(avimux->srcpad, GST_DATA(event));
} }
avimux->avix_start = avimux->total_data; avimux->avix_start = avimux->total_data;
@ -986,7 +986,7 @@ gst_avimux_bigfile(GstAviMux *avimux, gboolean last)
header = gst_avimux_riff_get_avix_header(0); header = gst_avimux_riff_get_avix_header(0);
avimux->total_data += GST_BUFFER_SIZE(header); avimux->total_data += GST_BUFFER_SIZE(header);
gst_pad_push(avimux->srcpad, header); gst_pad_push(avimux->srcpad, GST_DATA (header));
} }
/* enough header blabla now, let's go on to actually writing the headers */ /* enough header blabla now, let's go on to actually writing the headers */
@ -1019,7 +1019,7 @@ gst_avimux_start_file (GstAviMux *avimux)
header = gst_avimux_riff_get_avi_header(avimux); header = gst_avimux_riff_get_avi_header(avimux);
avimux->total_data += GST_BUFFER_SIZE(header); avimux->total_data += GST_BUFFER_SIZE(header);
avimux->idx_offset = avimux->total_data; avimux->idx_offset = avimux->total_data;
gst_pad_push(avimux->srcpad, header); gst_pad_push(avimux->srcpad, GST_DATA (header));
avimux->write_header = FALSE; avimux->write_header = FALSE;
avimux->restart = FALSE; avimux->restart = FALSE;
@ -1080,11 +1080,11 @@ gst_avimux_stop_file (GstAviMux *avimux)
header = gst_avimux_riff_get_avi_header(avimux); header = gst_avimux_riff_get_avi_header(avimux);
event = gst_event_new_seek (GST_FORMAT_BYTES | event = gst_event_new_seek (GST_FORMAT_BYTES |
GST_SEEK_METHOD_SET, 0); GST_SEEK_METHOD_SET, 0);
gst_pad_push(avimux->srcpad, GST_BUFFER(event)); gst_pad_push(avimux->srcpad, GST_DATA(event));
gst_pad_push(avimux->srcpad, header); gst_pad_push(avimux->srcpad, GST_DATA (header));
event = gst_event_new_seek (GST_FORMAT_BYTES | event = gst_event_new_seek (GST_FORMAT_BYTES |
GST_SEEK_METHOD_SET, avimux->total_data); GST_SEEK_METHOD_SET, avimux->total_data);
gst_pad_push(avimux->srcpad, GST_BUFFER(event)); gst_pad_push(avimux->srcpad, GST_DATA(event));
} }
avimux->write_header = TRUE; avimux->write_header = TRUE;
@ -1098,7 +1098,7 @@ gst_avimux_restart_file (GstAviMux *avimux)
gst_avimux_stop_file(avimux); gst_avimux_stop_file(avimux);
event = gst_event_new(GST_EVENT_EOS); event = gst_event_new(GST_EVENT_EOS);
gst_pad_push(avimux->srcpad, GST_BUFFER(event)); gst_pad_push(avimux->srcpad, GST_DATA(event));
gst_avimux_start_file(avimux); gst_avimux_start_file(avimux);
} }
@ -1145,7 +1145,7 @@ gst_avimux_fill_queue (GstAviMux *avimux)
GST_PAD_IS_USABLE(avimux->audiosinkpad) && GST_PAD_IS_USABLE(avimux->audiosinkpad) &&
!avimux->audio_pad_eos) !avimux->audio_pad_eos)
{ {
buffer = gst_pad_pull(avimux->audiosinkpad); buffer = GST_BUFFER (gst_pad_pull(avimux->audiosinkpad));
if (GST_IS_EVENT(buffer)) { if (GST_IS_EVENT(buffer)) {
gst_avimux_handle_event(avimux->audiosinkpad, GST_EVENT(buffer)); gst_avimux_handle_event(avimux->audiosinkpad, GST_EVENT(buffer));
} else { } else {
@ -1160,7 +1160,7 @@ gst_avimux_fill_queue (GstAviMux *avimux)
GST_PAD_IS_USABLE(avimux->videosinkpad) && GST_PAD_IS_USABLE(avimux->videosinkpad) &&
!avimux->video_pad_eos) !avimux->video_pad_eos)
{ {
buffer = gst_pad_pull(avimux->videosinkpad); buffer = GST_BUFFER (gst_pad_pull(avimux->videosinkpad));
if (GST_IS_EVENT(buffer)) { if (GST_IS_EVENT(buffer)) {
gst_avimux_handle_event(avimux->videosinkpad, GST_EVENT(buffer)); gst_avimux_handle_event(avimux->videosinkpad, GST_EVENT(buffer));
} else { } else {
@ -1183,7 +1183,7 @@ gst_avimux_send_pad_data (GstAviMux *avimux,
GST_BUFFER_DATA(buffer) = g_malloc(num_bytes); GST_BUFFER_DATA(buffer) = g_malloc(num_bytes);
memset(GST_BUFFER_DATA(buffer), 0, num_bytes); memset(GST_BUFFER_DATA(buffer), 0, num_bytes);
gst_pad_push(avimux->srcpad, buffer); gst_pad_push(avimux->srcpad, GST_DATA (buffer));
} }
/* do audio buffer */ /* do audio buffer */
@ -1212,8 +1212,8 @@ gst_avimux_do_audio_buffer (GstAviMux *avimux)
gst_avimux_add_index(avimux, "01wb", 0x0, GST_BUFFER_SIZE(data)); gst_avimux_add_index(avimux, "01wb", 0x0, GST_BUFFER_SIZE(data));
} }
gst_pad_push(avimux->srcpad, header); gst_pad_push(avimux->srcpad, GST_DATA (header));
gst_pad_push(avimux->srcpad, data); gst_pad_push(avimux->srcpad, GST_DATA (data));
if (pad_bytes) { if (pad_bytes) {
gst_avimux_send_pad_data(avimux, pad_bytes); gst_avimux_send_pad_data(avimux, pad_bytes);
} }
@ -1265,8 +1265,8 @@ gst_avimux_do_video_buffer (GstAviMux *avimux)
gst_avimux_add_index(avimux, "00db", flags, GST_BUFFER_SIZE(data)); gst_avimux_add_index(avimux, "00db", flags, GST_BUFFER_SIZE(data));
} }
gst_pad_push(avimux->srcpad, header); gst_pad_push(avimux->srcpad, GST_DATA (header));
gst_pad_push(avimux->srcpad, data); gst_pad_push(avimux->srcpad, GST_DATA (data));
if (pad_bytes) { if (pad_bytes) {
gst_avimux_send_pad_data(avimux, pad_bytes); gst_avimux_send_pad_data(avimux, pad_bytes);
} }
@ -1302,7 +1302,7 @@ gst_avimux_do_one_buffer (GstAviMux *avimux)
/* simply finish off the file and send EOS */ /* simply finish off the file and send EOS */
gst_avimux_stop_file(avimux); gst_avimux_stop_file(avimux);
gst_pad_push(avimux->srcpad, gst_pad_push(avimux->srcpad,
GST_BUFFER(gst_event_new(GST_EVENT_EOS))); GST_DATA(gst_event_new(GST_EVENT_EOS)));
gst_element_set_eos(GST_ELEMENT(avimux)); gst_element_set_eos(GST_ELEMENT(avimux));
return FALSE; return FALSE;
} }

11
gst/cutter/gstcutter.c
View file

@ -95,7 +95,7 @@ static void gst_cutter_set_property (GObject *object, guint prop_id,
static void gst_cutter_get_property (GObject *object, guint prop_id, static void gst_cutter_get_property (GObject *object, guint prop_id,
GValue *value, GParamSpec *pspec); GValue *value, GParamSpec *pspec);
static void gst_cutter_chain (GstPad *pad, GstBuffer *buf); static void gst_cutter_chain (GstPad *pad, GstData *_data);
static double static double
inline gst_cutter_16bit_ms (gint16* data, guint numsamples); inline gst_cutter_16bit_ms (gint16* data, guint numsamples);
static double static double
@ -212,8 +212,9 @@ gst_cutter_init (GstCutter *filter)
} }
static void static void
gst_cutter_chain (GstPad *pad, GstBuffer *buf) gst_cutter_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstCutter *filter; GstCutter *filter;
gint16 *in_data; gint16 *in_data;
double RMS = 0.0; /* RMS of signal in buffer */ double RMS = 0.0; /* RMS of signal in buffer */
@ -299,7 +300,7 @@ gst_cutter_chain (GstPad *pad, GstBuffer *buf)
{ {
prebuf = (g_list_first (filter->pre_buffer))->data; prebuf = (g_list_first (filter->pre_buffer))->data;
filter->pre_buffer = g_list_remove (filter->pre_buffer, prebuf); filter->pre_buffer = g_list_remove (filter->pre_buffer, prebuf);
gst_pad_push (filter->srcpad, prebuf); gst_pad_push (filter->srcpad, GST_DATA (prebuf));
++count; ++count;
} }
GST_DEBUG ("flushed %d buffers", count); GST_DEBUG ("flushed %d buffers", count);
@ -327,13 +328,13 @@ gst_cutter_chain (GstPad *pad, GstBuffer *buf)
filter->pre_run_length -= gst_audio_length (filter->srcpad, prebuf); filter->pre_run_length -= gst_audio_length (filter->srcpad, prebuf);
/* only pass buffers if we don't leak */ /* only pass buffers if we don't leak */
if (!filter->leaky) if (!filter->leaky)
gst_pad_push (filter->srcpad, prebuf); gst_pad_push (filter->srcpad, GST_DATA (prebuf));
/* we unref it after getting it out of the pre_buffer */ /* we unref it after getting it out of the pre_buffer */
gst_buffer_unref (prebuf); gst_buffer_unref (prebuf);
} }
} }
else else
gst_pad_push (filter->srcpad, buf); gst_pad_push (filter->srcpad, GST_DATA (buf));
} }
static double inline static double inline

7
gst/debug/efence.c
View file

@ -83,7 +83,7 @@ static void gst_efence_get_property(GObject *object, guint prop_id,
GValue *value, GValue *value,
GParamSpec *pspec); GParamSpec *pspec);
static void gst_efence_chain (GstPad *pad, GstBuffer *buf); static void gst_efence_chain (GstPad *pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
@ -201,8 +201,9 @@ gst_efence_init (GstEFence *filter)
*/ */
static void static void
gst_efence_chain (GstPad *pad, GstBuffer *buffer) gst_efence_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buffer = GST_BUFFER (_data);
GstEFence *efence; GstEFence *efence;
GstBuffer *copy; GstBuffer *copy;
void *ptr; void *ptr;
@ -231,7 +232,7 @@ gst_efence_chain (GstPad *pad, GstBuffer *buffer)
GST_BUFFER_POOL_PRIVATE (copy) = NULL; GST_BUFFER_POOL_PRIVATE (copy) = NULL;
gst_buffer_unref(buffer); gst_buffer_unref(buffer);
gst_pad_push (efence->srcpad, copy); gst_pad_push (efence->srcpad, GST_DATA (copy));
} }
static void static void

7
gst/effectv/gstaging.c
View file

@ -111,7 +111,7 @@ static void gst_agingtv_set_property (GObject * object, guint prop_id,
static void gst_agingtv_get_property (GObject * object, guint prop_id, static void gst_agingtv_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec); GValue * value, GParamSpec * pspec);
static void gst_agingtv_chain (GstPad * pad, GstBuffer * buf); static void gst_agingtv_chain (GstPad * pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
/*static guint gst_agingtv_signals[LAST_SIGNAL] = { 0 }; */ /*static guint gst_agingtv_signals[LAST_SIGNAL] = { 0 }; */
@ -342,8 +342,9 @@ aging_mode_switch (GstAgingTV *filter)
} }
static void static void
gst_agingtv_chain (GstPad * pad, GstBuffer * buf) gst_agingtv_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstAgingTV *filter; GstAgingTV *filter;
guint32 *src, *dest; guint32 *src, *dest;
GstBuffer *outbuf; GstBuffer *outbuf;
@ -365,7 +366,7 @@ gst_agingtv_chain (GstPad * pad, GstBuffer * buf)
gst_buffer_unref (buf); gst_buffer_unref (buf);
gst_pad_push (filter->srcpad, outbuf); gst_pad_push (filter->srcpad, GST_DATA (outbuf));
} }
static void static void

7
gst/effectv/gstdice.c
View file

@ -102,7 +102,7 @@ static void gst_dicetv_set_property (GObject * object, guint prop_id,
static void gst_dicetv_get_property (GObject * object, guint prop_id, static void gst_dicetv_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec); GValue * value, GParamSpec * pspec);
static void gst_dicetv_chain (GstPad * pad, GstBuffer * buf); static void gst_dicetv_chain (GstPad * pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
static guint gst_dicetv_signals[LAST_SIGNAL] = { 0 }; static guint gst_dicetv_signals[LAST_SIGNAL] = { 0 };
@ -301,8 +301,9 @@ gst_dicetv_create_map (GstDiceTV *filter)
} }
static void static void
gst_dicetv_chain (GstPad * pad, GstBuffer * buf) gst_dicetv_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstDiceTV *filter; GstDiceTV *filter;
guint32 *src, *dest; guint32 *src, *dest;
GstBuffer *outbuf; GstBuffer *outbuf;
@ -320,7 +321,7 @@ gst_dicetv_chain (GstPad * pad, GstBuffer * buf)
gst_buffer_unref (buf); gst_buffer_unref (buf);
gst_pad_push (filter->srcpad, outbuf); gst_pad_push (filter->srcpad, GST_DATA (outbuf));
} }
static void static void

7
gst/effectv/gstedge.c
View file

@ -91,7 +91,7 @@ static void gst_edgetv_set_property (GObject * object, guint prop_id,
static void gst_edgetv_get_property (GObject * object, guint prop_id, static void gst_edgetv_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec); GValue * value, GParamSpec * pspec);
static void gst_edgetv_chain (GstPad * pad, GstBuffer * buf); static void gst_edgetv_chain (GstPad * pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
/*static guint gst_edgetv_signals[LAST_SIGNAL] = { 0 }; */ /*static guint gst_edgetv_signals[LAST_SIGNAL] = { 0 }; */
@ -171,8 +171,9 @@ gst_edgetv_init (GstEdgeTV * filter)
} }
static void static void
gst_edgetv_chain (GstPad * pad, GstBuffer * buf) gst_edgetv_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstEdgeTV *filter; GstEdgeTV *filter;
int x, y; int x, y;
int r, g, b; int r, g, b;
@ -269,7 +270,7 @@ gst_edgetv_chain (GstPad * pad, GstBuffer * buf)
} }
gst_buffer_unref (buf); gst_buffer_unref (buf);
gst_pad_push (filter->srcpad, outbuf); gst_pad_push (filter->srcpad, GST_DATA (outbuf));
} }
static void static void

7
gst/effectv/gstquark.c
View file

@ -101,7 +101,7 @@ static void gst_quarktv_set_property (GObject * object, guint prop_id,
static void gst_quarktv_get_property (GObject * object, guint prop_id, static void gst_quarktv_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec); GValue * value, GParamSpec * pspec);
static void gst_quarktv_chain (GstPad * pad, GstBuffer * buf); static void gst_quarktv_chain (GstPad * pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
/* static guint gst_quarktv_signals[LAST_SIGNAL] = { 0 }; */ /* static guint gst_quarktv_signals[LAST_SIGNAL] = { 0 }; */
@ -200,8 +200,9 @@ gst_quarktv_init (GstQuarkTV * filter)
} }
static void static void
gst_quarktv_chain (GstPad * pad, GstBuffer * buf) gst_quarktv_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstQuarkTV *filter; GstQuarkTV *filter;
guint32 *src, *dest; guint32 *src, *dest;
GstBuffer *outbuf; GstBuffer *outbuf;
@ -232,7 +233,7 @@ gst_quarktv_chain (GstPad * pad, GstBuffer * buf)
dest[area] = (rand ? ((guint32 *)GST_BUFFER_DATA (rand))[area] : 0); dest[area] = (rand ? ((guint32 *)GST_BUFFER_DATA (rand))[area] : 0);
} }
gst_pad_push (filter->srcpad, outbuf); gst_pad_push (filter->srcpad, GST_DATA (outbuf));
filter->current_plane--; filter->current_plane--;

7
gst/effectv/gstrev.c
View file

@ -120,7 +120,7 @@ static void gst_revtv_set_property (GObject * object, guint prop_id,
static void gst_revtv_get_property (GObject * object, guint prop_id, static void gst_revtv_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec); GValue * value, GParamSpec * pspec);
static void gst_revtv_chain (GstPad * pad, GstBuffer * buf); static void gst_revtv_chain (GstPad * pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
/* static guint gst_revtv_signals[LAST_SIGNAL] = { 0 }; */ /* static guint gst_revtv_signals[LAST_SIGNAL] = { 0 }; */
@ -206,8 +206,9 @@ gst_revtv_init (GstRevTV * filter)
static void static void
gst_revtv_chain (GstPad * pad, GstBuffer * buf) gst_revtv_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstRevTV *filter; GstRevTV *filter;
guint32 *src, *dest; guint32 *src, *dest;
GstBuffer *outbuf; GstBuffer *outbuf;
@ -248,7 +249,7 @@ gst_revtv_chain (GstPad * pad, GstBuffer * buf)
gst_buffer_unref (buf); gst_buffer_unref (buf);
gst_pad_push (filter->srcpad, outbuf); gst_pad_push (filter->srcpad, GST_DATA (outbuf));
} }
static void static void

7
gst/effectv/gstshagadelic.c
View file

@ -100,7 +100,7 @@ static void gst_shagadelictv_set_property (GObject * object, guint prop_id,
static void gst_shagadelictv_get_property (GObject * object, guint prop_id, static void gst_shagadelictv_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec); GValue * value, GParamSpec * pspec);
static void gst_shagadelictv_chain (GstPad * pad, GstBuffer * buf); static void gst_shagadelictv_chain (GstPad * pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
/*static guint gst_shagadelictv_signals[LAST_SIGNAL] = { 0 }; */ /*static guint gst_shagadelictv_signals[LAST_SIGNAL] = { 0 }; */
@ -250,8 +250,9 @@ int shagadelicDraw()
return 0; return 0;
} }
static void static void
gst_shagadelictv_chain (GstPad * pad, GstBuffer * buf) gst_shagadelictv_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstShagadelicTV *filter; GstShagadelicTV *filter;
guint32 *src, *dest; guint32 *src, *dest;
GstBuffer *outbuf; GstBuffer *outbuf;
@ -300,7 +301,7 @@ gst_shagadelictv_chain (GstPad * pad, GstBuffer * buf)
gst_buffer_unref (buf); gst_buffer_unref (buf);
gst_pad_push (filter->srcpad, outbuf); gst_pad_push (filter->srcpad, GST_DATA (outbuf));
} }
static void static void

7
gst/effectv/gstvertigo.c
View file

@ -105,7 +105,7 @@ static void gst_vertigotv_set_property (GObject * object, guint prop_id,
static void gst_vertigotv_get_property (GObject * object, guint prop_id, static void gst_vertigotv_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec); GValue * value, GParamSpec * pspec);
static void gst_vertigotv_chain (GstPad * pad, GstBuffer * buf); static void gst_vertigotv_chain (GstPad * pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
static guint gst_vertigotv_signals[LAST_SIGNAL] = { 0 }; static guint gst_vertigotv_signals[LAST_SIGNAL] = { 0 };
@ -263,8 +263,9 @@ gst_vertigotv_set_parms (GstVertigoTV *filter)
} }
static void static void
gst_vertigotv_chain (GstPad * pad, GstBuffer * buf) gst_vertigotv_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstVertigoTV *filter; GstVertigoTV *filter;
guint32 *src, *dest; guint32 *src, *dest;
GstBuffer *outbuf; GstBuffer *outbuf;
@ -315,7 +316,7 @@ gst_vertigotv_chain (GstPad * pad, GstBuffer * buf)
gst_buffer_unref (buf); gst_buffer_unref (buf);
gst_pad_push (filter->srcpad, outbuf); gst_pad_push (filter->srcpad, GST_DATA (outbuf));
p = filter->current_buffer; p = filter->current_buffer;
filter->current_buffer = filter->alt_buffer; filter->current_buffer = filter->alt_buffer;

7
gst/effectv/gstwarp.c
View file

@ -107,7 +107,7 @@ static void gst_warptv_set_property (GObject * object, guint prop_id,
static void gst_warptv_get_property (GObject * object, guint prop_id, static void gst_warptv_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec); GValue * value, GParamSpec * pspec);
static void gst_warptv_chain (GstPad * pad, GstBuffer * buf); static void gst_warptv_chain (GstPad * pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
/*static guint gst_warptv_signals[LAST_SIGNAL] = { 0 }; */ /*static guint gst_warptv_signals[LAST_SIGNAL] = { 0 }; */
@ -249,8 +249,9 @@ gst_warptv_initialize (GstWarpTV *filter)
} }
static void static void
gst_warptv_chain (GstPad * pad, GstBuffer * buf) gst_warptv_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstWarpTV *filter; GstWarpTV *filter;
guint32 *src, *dest; guint32 *src, *dest;
gint xw,yw,cw; gint xw,yw,cw;
@ -312,7 +313,7 @@ gst_warptv_chain (GstPad * pad, GstBuffer * buf)
gst_buffer_unref (buf); gst_buffer_unref (buf);
gst_pad_push (filter->srcpad, outbuf); gst_pad_push (filter->srcpad, GST_DATA (outbuf));
} }
static void static void

2
gst/flx/gstflxdec.c
View file

@ -609,7 +609,7 @@ gst_flxdec_loop (GstElement *element)
GST_BUFFER_TIMESTAMP (out) = flxdec->next_time; GST_BUFFER_TIMESTAMP (out) = flxdec->next_time;
flxdec->next_time += flxdec->frame_time; flxdec->next_time += flxdec->frame_time;
gst_pad_push(flxdec->srcpad, out); gst_pad_push(flxdec->srcpad, GST_DATA (out));
break; break;
} }

7
gst/goom/gstgoom.c
View file

@ -117,7 +117,7 @@ static void gst_goom_dispose (GObject *object);
static GstElementStateReturn static GstElementStateReturn
gst_goom_change_state (GstElement *element); gst_goom_change_state (GstElement *element);
static void gst_goom_chain (GstPad *pad, GstBuffer *buf); static void gst_goom_chain (GstPad *pad, GstData *_data);
static GstPadLinkReturn gst_goom_sinkconnect (GstPad *pad, GstCaps *caps); static GstPadLinkReturn gst_goom_sinkconnect (GstPad *pad, GstCaps *caps);
static GstPadLinkReturn gst_goom_srcconnect (GstPad *pad, GstCaps *caps); static GstPadLinkReturn gst_goom_srcconnect (GstPad *pad, GstCaps *caps);
@ -268,8 +268,9 @@ gst_goom_negotiate_default (GstGOOM *goom)
} }
static void static void
gst_goom_chain (GstPad *pad, GstBuffer *bufin) gst_goom_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *bufin = GST_BUFFER (_data);
GstGOOM *goom; GstGOOM *goom;
GstBuffer *bufout; GstBuffer *bufout;
guint32 samples_in; guint32 samples_in;
@ -344,7 +345,7 @@ gst_goom_chain (GstPad *pad, GstBuffer *bufin)
goom->next_time += GST_SECOND / goom->fps; goom->next_time += GST_SECOND / goom->fps;
gst_pad_push (goom->srcpad, bufout); gst_pad_push (goom->srcpad, GST_DATA (bufout));
done: done:
gst_buffer_unref (bufin); gst_buffer_unref (bufin);

7
gst/law/alaw-decode.c
View file

@ -41,7 +41,7 @@ static void gst_alawdec_init (GstALawDec *alawdec);
static void gst_alawdec_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); static void gst_alawdec_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
static void gst_alawdec_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec); static void gst_alawdec_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec);
static void gst_alawdec_chain (GstPad *pad, GstBuffer *buf); static void gst_alawdec_chain (GstPad *pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
@ -146,8 +146,9 @@ gst_alawdec_init (GstALawDec *alawdec)
} }
static void static void
gst_alawdec_chain (GstPad *pad,GstBuffer *buf) gst_alawdec_chain (GstPad *pad,GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstALawDec *alawdec; GstALawDec *alawdec;
gint16 *linear_data; gint16 *linear_data;
guint8 *alaw_data; guint8 *alaw_data;
@ -175,7 +176,7 @@ gst_alawdec_chain (GstPad *pad,GstBuffer *buf)
} }
gst_buffer_unref(buf); gst_buffer_unref(buf);
gst_pad_push(alawdec->srcpad,outbuf); gst_pad_push(alawdec->srcpad,GST_DATA (outbuf));
} }
static void static void

7
gst/law/alaw-encode.c
View file

@ -41,7 +41,7 @@ static void gst_alawenc_init (GstALawEnc *alawenc);
static void gst_alawenc_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); static void gst_alawenc_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
static void gst_alawenc_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec); static void gst_alawenc_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec);
static void gst_alawenc_chain (GstPad *pad, GstBuffer *buf); static void gst_alawenc_chain (GstPad *pad, GstData *_data);
/* /*
* s16_to_alaw() - Convert a 16-bit linear PCM value to 8-bit A-law * s16_to_alaw() - Convert a 16-bit linear PCM value to 8-bit A-law
@ -185,8 +185,9 @@ gst_alawenc_init (GstALawEnc *alawenc)
} }
static void static void
gst_alawenc_chain (GstPad *pad,GstBuffer *buf) gst_alawenc_chain (GstPad *pad,GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstALawEnc *alawenc; GstALawEnc *alawenc;
gint16 *linear_data; gint16 *linear_data;
guint8 *alaw_data; guint8 *alaw_data;
@ -214,7 +215,7 @@ gst_alawenc_chain (GstPad *pad,GstBuffer *buf)
linear_data++; linear_data++;
} }
gst_buffer_unref(buf); gst_buffer_unref(buf);
gst_pad_push(alawenc->srcpad,outbuf); gst_pad_push(alawenc->srcpad,GST_DATA (outbuf));
} }
static void static void

7
gst/law/mulaw-decode.c
View file

@ -40,7 +40,7 @@ static void gst_mulawdec_init (GstMuLawDec *mulawdec);
static void gst_mulawdec_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); static void gst_mulawdec_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
static void gst_mulawdec_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec); static void gst_mulawdec_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec);
static void gst_mulawdec_chain (GstPad *pad, GstBuffer *buf); static void gst_mulawdec_chain (GstPad *pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
@ -125,8 +125,9 @@ gst_mulawdec_init (GstMuLawDec *mulawdec)
} }
static void static void
gst_mulawdec_chain (GstPad *pad,GstBuffer *buf) gst_mulawdec_chain (GstPad *pad,GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstMuLawDec *mulawdec; GstMuLawDec *mulawdec;
gint16 *linear_data; gint16 *linear_data;
guint8 *mulaw_data; guint8 *mulaw_data;
@ -149,7 +150,7 @@ gst_mulawdec_chain (GstPad *pad,GstBuffer *buf)
mulaw_decode(mulaw_data,linear_data,GST_BUFFER_SIZE(buf)); mulaw_decode(mulaw_data,linear_data,GST_BUFFER_SIZE(buf));
gst_buffer_unref(buf); gst_buffer_unref(buf);
gst_pad_push(mulawdec->srcpad,outbuf); gst_pad_push(mulawdec->srcpad,GST_DATA (outbuf));
} }
static void static void

7
gst/law/mulaw-encode.c
View file

@ -40,7 +40,7 @@ static void gst_mulawenc_init (GstMuLawEnc *mulawenc);
static void gst_mulawenc_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); static void gst_mulawenc_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
static void gst_mulawenc_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec); static void gst_mulawenc_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec);
static void gst_mulawenc_chain (GstPad *pad, GstBuffer *buf); static void gst_mulawenc_chain (GstPad *pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
@ -123,8 +123,9 @@ gst_mulawenc_init (GstMuLawEnc *mulawenc)
} }
static void static void
gst_mulawenc_chain (GstPad *pad,GstBuffer *buf) gst_mulawenc_chain (GstPad *pad,GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstMuLawEnc *mulawenc; GstMuLawEnc *mulawenc;
gint16 *linear_data; gint16 *linear_data;
guint8 *mulaw_data; guint8 *mulaw_data;
@ -147,7 +148,7 @@ gst_mulawenc_chain (GstPad *pad,GstBuffer *buf)
mulaw_encode(linear_data,mulaw_data,GST_BUFFER_SIZE(outbuf)); mulaw_encode(linear_data,mulaw_data,GST_BUFFER_SIZE(outbuf));
gst_buffer_unref(buf); gst_buffer_unref(buf);
gst_pad_push(mulawenc->srcpad,outbuf); gst_pad_push(mulawenc->srcpad,GST_DATA (outbuf));
} }
static void static void

7
gst/level/gstlevel.c
View file

@ -101,7 +101,7 @@ static void gst_level_init (GstLevel *filter);
static void gst_level_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); static void gst_level_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
static void gst_level_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec); static void gst_level_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec);
static void gst_level_chain (GstPad *pad, GstBuffer *buf); static void gst_level_chain (GstPad *pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
static guint gst_filter_signals[LAST_SIGNAL] = { 0 }; static guint gst_filter_signals[LAST_SIGNAL] = { 0 };
@ -193,8 +193,9 @@ gst_level_fast_8bit_chain (gint8* in, guint num, gint channels,
#include "filter.func" #include "filter.func"
static void static void
gst_level_chain (GstPad *pad, GstBuffer *buf) gst_level_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstLevel *filter; GstLevel *filter;
gint16 *in_data; gint16 *in_data;
@ -239,7 +240,7 @@ gst_level_chain (GstPad *pad, GstBuffer *buf)
filter->CS[i] += CS; filter->CS[i] += CS;
} }
gst_pad_push (filter->srcpad, buf); gst_pad_push (filter->srcpad, GST_DATA (buf));
filter->num_samples += num_samples; filter->num_samples += num_samples;

9
gst/median/gstmedian.c
View file

@ -81,7 +81,7 @@ static void gst_median_init (GstMedian *median);
static void median_5 (unsigned char *src, unsigned char *dest, int height, int width); static void median_5 (unsigned char *src, unsigned char *dest, int height, int width);
static void median_9 (unsigned char *src, unsigned char *dest, int height, int width); static void median_9 (unsigned char *src, unsigned char *dest, int height, int width);
static void gst_median_chain (GstPad *pad, GstBuffer *buf); static void gst_median_chain (GstPad *pad, GstData *_data);
static void gst_median_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); static void gst_median_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
static void gst_median_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec); static void gst_median_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec);
@ -267,8 +267,9 @@ median_9 (unsigned char *src, unsigned char *dest, int width, int height)
} }
static void static void
gst_median_chain (GstPad *pad, GstBuffer *buf) gst_median_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstMedian *median; GstMedian *median;
guchar *data; guchar *data;
gulong size; gulong size;
@ -283,7 +284,7 @@ gst_median_chain (GstPad *pad, GstBuffer *buf)
median = GST_MEDIAN (GST_OBJECT_PARENT (pad)); median = GST_MEDIAN (GST_OBJECT_PARENT (pad));
if (!median->active) { if (!median->active) {
gst_pad_push(median->srcpad,buf); gst_pad_push(median->srcpad,GST_DATA (buf));
return; return;
} }
@ -323,7 +324,7 @@ gst_median_chain (GstPad *pad, GstBuffer *buf)
gst_buffer_unref(buf); gst_buffer_unref(buf);
gst_pad_push(median->srcpad,outbuf); gst_pad_push(median->srcpad,GST_DATA (outbuf));
} }
static void static void

7
gst/monoscope/gstmonoscope.c
View file

@ -124,7 +124,7 @@ GST_PAD_TEMPLATE_FACTORY (sink_template,
static void gst_monoscope_class_init (GstMonoscopeClass *klass); static void gst_monoscope_class_init (GstMonoscopeClass *klass);
static void gst_monoscope_init (GstMonoscope *monoscope); static void gst_monoscope_init (GstMonoscope *monoscope);
static void gst_monoscope_chain (GstPad *pad, GstBuffer *buf); static void gst_monoscope_chain (GstPad *pad, GstData *_data);
static GstPadLinkReturn static GstPadLinkReturn
gst_monoscope_sinkconnect (GstPad *pad, GstCaps *caps); gst_monoscope_sinkconnect (GstPad *pad, GstCaps *caps);
@ -250,8 +250,9 @@ gst_monoscope_srcconnect (GstPad *pad, GstCaps *caps)
} }
static void static void
gst_monoscope_chain (GstPad *pad, GstBuffer *bufin) gst_monoscope_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *bufin = GST_BUFFER (_data);
GstMonoscope *monoscope; GstMonoscope *monoscope;
GstBuffer *bufout; GstBuffer *bufout;
guint32 samples_in; guint32 samples_in;
@ -300,7 +301,7 @@ gst_monoscope_chain (GstPad *pad, GstBuffer *bufin)
monoscope->next_time += GST_SECOND / monoscope->fps; monoscope->next_time += GST_SECOND / monoscope->fps;
gst_pad_push (monoscope->srcpad, bufout); gst_pad_push (monoscope->srcpad, GST_DATA (bufout));
gst_buffer_unref (bufin); gst_buffer_unref (bufin);

4
gst/qtdemux/qtdemux.c
View file

@ -462,7 +462,7 @@ static void gst_qtdemux_loop_header (GstElement *element)
if(index==-1){ if(index==-1){
for(i=0;i<qtdemux->n_streams;i++){ for(i=0;i<qtdemux->n_streams;i++){
gst_pad_push(qtdemux->streams[i]->pad, gst_pad_push(qtdemux->streams[i]->pad,
GST_BUFFER(gst_event_new (GST_EVENT_EOS))); GST_DATA(gst_event_new (GST_EVENT_EOS)));
} }
ret = gst_bytestream_seek(qtdemux->bs, 0, GST_SEEK_METHOD_END); ret = gst_bytestream_seek(qtdemux->bs, 0, GST_SEEK_METHOD_END);
GST_DEBUG ("seek returned %d",ret); GST_DEBUG ("seek returned %d",ret);
@ -516,7 +516,7 @@ static void gst_qtdemux_loop_header (GstElement *element)
GST_BUFFER_TIMESTAMP(buf) = stream->samples[stream->sample_index].timestamp; GST_BUFFER_TIMESTAMP(buf) = stream->samples[stream->sample_index].timestamp;
GST_BUFFER_DURATION(buf) = stream->samples[stream->sample_index].duration; GST_BUFFER_DURATION(buf) = stream->samples[stream->sample_index].duration;
gst_pad_push(stream->pad, buf); gst_pad_push(stream->pad, GST_DATA (buf));
} }
stream->sample_index++; stream->sample_index++;
break; break;

7
gst/rtp/gstrtpL16depay.c
View file

@ -72,7 +72,7 @@ GST_PAD_TEMPLATE_FACTORY (sink_factory,
static void gst_rtpL16parse_class_init (GstRtpL16ParseClass * klass); static void gst_rtpL16parse_class_init (GstRtpL16ParseClass * klass);
static void gst_rtpL16parse_init (GstRtpL16Parse * rtpL16parse); static void gst_rtpL16parse_init (GstRtpL16Parse * rtpL16parse);
static void gst_rtpL16parse_chain (GstPad * pad, GstBuffer * buf); static void gst_rtpL16parse_chain (GstPad * pad, GstData *_data);
static void gst_rtpL16parse_set_property (GObject * object, guint prop_id, static void gst_rtpL16parse_set_property (GObject * object, guint prop_id,
const GValue * value, GParamSpec * pspec); const GValue * value, GParamSpec * pspec);
@ -195,8 +195,9 @@ gst_rtpL16parse_payloadtype_change (GstRtpL16Parse *rtpL16parse, rtp_payload_t p
} }
static void static void
gst_rtpL16parse_chain (GstPad * pad, GstBuffer * buf) gst_rtpL16parse_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstRtpL16Parse *rtpL16parse; GstRtpL16Parse *rtpL16parse;
GstBuffer *outbuf; GstBuffer *outbuf;
Rtp_Packet packet; Rtp_Packet packet;
@ -244,7 +245,7 @@ gst_rtpL16parse_chain (GstPad * pad, GstBuffer * buf)
gst_rtpL16parse_ntohs (outbuf); gst_rtpL16parse_ntohs (outbuf);
#endif #endif
gst_pad_push (rtpL16parse->srcpad, outbuf); gst_pad_push (rtpL16parse->srcpad, GST_DATA (outbuf));
rtp_packet_free (packet); rtp_packet_free (packet);
gst_buffer_unref (buf); gst_buffer_unref (buf);

7
gst/rtp/gstrtpL16enc.c
View file

@ -75,7 +75,7 @@ GST_PAD_TEMPLATE_FACTORY (src_factory,
static void gst_rtpL16enc_class_init (GstRtpL16EncClass * klass); static void gst_rtpL16enc_class_init (GstRtpL16EncClass * klass);
static void gst_rtpL16enc_init (GstRtpL16Enc * rtpL16enc); static void gst_rtpL16enc_init (GstRtpL16Enc * rtpL16enc);
static void gst_rtpL16enc_chain (GstPad * pad, GstBuffer * buf); static void gst_rtpL16enc_chain (GstPad * pad, GstData *_data);
static void gst_rtpL16enc_set_property (GObject * object, guint prop_id, static void gst_rtpL16enc_set_property (GObject * object, guint prop_id,
const GValue * value, GParamSpec * pspec); const GValue * value, GParamSpec * pspec);
static void gst_rtpL16enc_get_property (GObject * object, guint prop_id, static void gst_rtpL16enc_get_property (GObject * object, guint prop_id,
@ -176,8 +176,9 @@ gst_rtpL16enc_htons (GstBuffer *buf)
} }
static void static void
gst_rtpL16enc_chain (GstPad * pad, GstBuffer * buf) gst_rtpL16enc_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstRtpL16Enc *rtpL16enc; GstRtpL16Enc *rtpL16enc;
GstBuffer *outbuf; GstBuffer *outbuf;
Rtp_Packet packet; Rtp_Packet packet;
@ -240,7 +241,7 @@ gst_rtpL16enc_chain (GstPad * pad, GstBuffer * buf)
memcpy (GST_BUFFER_DATA (outbuf) + rtp_packet_get_packet_len(packet), GST_BUFFER_DATA (buf), GST_BUFFER_SIZE (buf)); memcpy (GST_BUFFER_DATA (outbuf) + rtp_packet_get_packet_len(packet), GST_BUFFER_DATA (buf), GST_BUFFER_SIZE (buf));
GST_DEBUG ("gst_rtpL16enc_chain: pushing buffer of size %d", GST_BUFFER_SIZE(outbuf)); GST_DEBUG ("gst_rtpL16enc_chain: pushing buffer of size %d", GST_BUFFER_SIZE(outbuf));
gst_pad_push (rtpL16enc->srcpad, outbuf); gst_pad_push (rtpL16enc->srcpad, GST_DATA (outbuf));
++rtpL16enc->seq; ++rtpL16enc->seq;
rtpL16enc->next_time += rtpL16enc->time_interval * GST_BUFFER_SIZE (buf); rtpL16enc->next_time += rtpL16enc->time_interval * GST_BUFFER_SIZE (buf);

7
gst/rtp/gstrtpL16parse.c
View file

@ -72,7 +72,7 @@ GST_PAD_TEMPLATE_FACTORY (sink_factory,
static void gst_rtpL16parse_class_init (GstRtpL16ParseClass * klass); static void gst_rtpL16parse_class_init (GstRtpL16ParseClass * klass);
static void gst_rtpL16parse_init (GstRtpL16Parse * rtpL16parse); static void gst_rtpL16parse_init (GstRtpL16Parse * rtpL16parse);
static void gst_rtpL16parse_chain (GstPad * pad, GstBuffer * buf); static void gst_rtpL16parse_chain (GstPad * pad, GstData *_data);
static void gst_rtpL16parse_set_property (GObject * object, guint prop_id, static void gst_rtpL16parse_set_property (GObject * object, guint prop_id,
const GValue * value, GParamSpec * pspec); const GValue * value, GParamSpec * pspec);
@ -195,8 +195,9 @@ gst_rtpL16parse_payloadtype_change (GstRtpL16Parse *rtpL16parse, rtp_payload_t p
} }
static void static void
gst_rtpL16parse_chain (GstPad * pad, GstBuffer * buf) gst_rtpL16parse_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstRtpL16Parse *rtpL16parse; GstRtpL16Parse *rtpL16parse;
GstBuffer *outbuf; GstBuffer *outbuf;
Rtp_Packet packet; Rtp_Packet packet;
@ -244,7 +245,7 @@ gst_rtpL16parse_chain (GstPad * pad, GstBuffer * buf)
gst_rtpL16parse_ntohs (outbuf); gst_rtpL16parse_ntohs (outbuf);
#endif #endif
gst_pad_push (rtpL16parse->srcpad, outbuf); gst_pad_push (rtpL16parse->srcpad, GST_DATA (outbuf));
rtp_packet_free (packet); rtp_packet_free (packet);
gst_buffer_unref (buf); gst_buffer_unref (buf);

7
gst/rtp/gstrtpL16pay.c
View file

@ -75,7 +75,7 @@ GST_PAD_TEMPLATE_FACTORY (src_factory,
static void gst_rtpL16enc_class_init (GstRtpL16EncClass * klass); static void gst_rtpL16enc_class_init (GstRtpL16EncClass * klass);
static void gst_rtpL16enc_init (GstRtpL16Enc * rtpL16enc); static void gst_rtpL16enc_init (GstRtpL16Enc * rtpL16enc);
static void gst_rtpL16enc_chain (GstPad * pad, GstBuffer * buf); static void gst_rtpL16enc_chain (GstPad * pad, GstData *_data);
static void gst_rtpL16enc_set_property (GObject * object, guint prop_id, static void gst_rtpL16enc_set_property (GObject * object, guint prop_id,
const GValue * value, GParamSpec * pspec); const GValue * value, GParamSpec * pspec);
static void gst_rtpL16enc_get_property (GObject * object, guint prop_id, static void gst_rtpL16enc_get_property (GObject * object, guint prop_id,
@ -176,8 +176,9 @@ gst_rtpL16enc_htons (GstBuffer *buf)
} }
static void static void
gst_rtpL16enc_chain (GstPad * pad, GstBuffer * buf) gst_rtpL16enc_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstRtpL16Enc *rtpL16enc; GstRtpL16Enc *rtpL16enc;
GstBuffer *outbuf; GstBuffer *outbuf;
Rtp_Packet packet; Rtp_Packet packet;
@ -240,7 +241,7 @@ gst_rtpL16enc_chain (GstPad * pad, GstBuffer * buf)
memcpy (GST_BUFFER_DATA (outbuf) + rtp_packet_get_packet_len(packet), GST_BUFFER_DATA (buf), GST_BUFFER_SIZE (buf)); memcpy (GST_BUFFER_DATA (outbuf) + rtp_packet_get_packet_len(packet), GST_BUFFER_DATA (buf), GST_BUFFER_SIZE (buf));
GST_DEBUG ("gst_rtpL16enc_chain: pushing buffer of size %d", GST_BUFFER_SIZE(outbuf)); GST_DEBUG ("gst_rtpL16enc_chain: pushing buffer of size %d", GST_BUFFER_SIZE(outbuf));
gst_pad_push (rtpL16enc->srcpad, outbuf); gst_pad_push (rtpL16enc->srcpad, GST_DATA (outbuf));
++rtpL16enc->seq; ++rtpL16enc->seq;
rtpL16enc->next_time += rtpL16enc->time_interval * GST_BUFFER_SIZE (buf); rtpL16enc->next_time += rtpL16enc->time_interval * GST_BUFFER_SIZE (buf);

7
gst/rtp/gstrtpgsmdepay.c
View file

@ -67,7 +67,7 @@ GST_PAD_TEMPLATE_FACTORY (sink_factory,
static void gst_rtpgsmparse_class_init (GstRtpGSMParseClass * klass); static void gst_rtpgsmparse_class_init (GstRtpGSMParseClass * klass);
static void gst_rtpgsmparse_init (GstRtpGSMParse * rtpgsmparse); static void gst_rtpgsmparse_init (GstRtpGSMParse * rtpgsmparse);
static void gst_rtpgsmparse_chain (GstPad * pad, GstBuffer * buf); static void gst_rtpgsmparse_chain (GstPad * pad, GstData *_data);
static void gst_rtpgsmparse_set_property (GObject * object, guint prop_id, static void gst_rtpgsmparse_set_property (GObject * object, guint prop_id,
const GValue * value, GParamSpec * pspec); const GValue * value, GParamSpec * pspec);
@ -160,8 +160,9 @@ gst_rtpgsm_caps_nego (GstRtpGSMParse *rtpgsmparse)
} }
static void static void
gst_rtpgsmparse_chain (GstPad * pad, GstBuffer * buf) gst_rtpgsmparse_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstRtpGSMParse *rtpgsmparse; GstRtpGSMParse *rtpgsmparse;
GstBuffer *outbuf; GstBuffer *outbuf;
Rtp_Packet packet; Rtp_Packet packet;
@ -212,7 +213,7 @@ gst_rtpgsmparse_chain (GstPad * pad, GstBuffer * buf)
gst_rtpgsmparse_ntohs (outbuf); gst_rtpgsmparse_ntohs (outbuf);
#endif #endif
gst_pad_push (rtpgsmparse->srcpad, outbuf); gst_pad_push (rtpgsmparse->srcpad, GST_DATA (outbuf));
rtp_packet_free (packet); rtp_packet_free (packet);
gst_buffer_unref (buf); gst_buffer_unref (buf);

7
gst/rtp/gstrtpgsmenc.c
View file

@ -71,7 +71,7 @@ GST_PAD_TEMPLATE_FACTORY (src_factory,
static void gst_rtpgsmenc_class_init (GstRtpGSMEncClass * klass); static void gst_rtpgsmenc_class_init (GstRtpGSMEncClass * klass);
static void gst_rtpgsmenc_init (GstRtpGSMEnc * rtpgsmenc); static void gst_rtpgsmenc_init (GstRtpGSMEnc * rtpgsmenc);
static void gst_rtpgsmenc_chain (GstPad * pad, GstBuffer * buf); static void gst_rtpgsmenc_chain (GstPad * pad, GstData *_data);
static void gst_rtpgsmenc_set_property (GObject * object, guint prop_id, static void gst_rtpgsmenc_set_property (GObject * object, guint prop_id,
const GValue * value, GParamSpec * pspec); const GValue * value, GParamSpec * pspec);
static void gst_rtpgsmenc_get_property (GObject * object, guint prop_id, static void gst_rtpgsmenc_get_property (GObject * object, guint prop_id,
@ -170,8 +170,9 @@ gst_rtpgsmenc_htons (GstBuffer *buf)
} }
static void static void
gst_rtpgsmenc_chain (GstPad * pad, GstBuffer * buf) gst_rtpgsmenc_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstRtpGSMEnc *rtpgsmenc; GstRtpGSMEnc *rtpgsmenc;
GstBuffer *outbuf; GstBuffer *outbuf;
Rtp_Packet packet; Rtp_Packet packet;
@ -227,7 +228,7 @@ gst_rtpgsmenc_chain (GstPad * pad, GstBuffer * buf)
memcpy (GST_BUFFER_DATA (outbuf) + rtp_packet_get_packet_len(packet), GST_BUFFER_DATA (buf), GST_BUFFER_SIZE (buf)); memcpy (GST_BUFFER_DATA (outbuf) + rtp_packet_get_packet_len(packet), GST_BUFFER_DATA (buf), GST_BUFFER_SIZE (buf));
GST_DEBUG ("gst_rtpgsmenc_chain: pushing buffer of size %d", GST_BUFFER_SIZE(outbuf)); GST_DEBUG ("gst_rtpgsmenc_chain: pushing buffer of size %d", GST_BUFFER_SIZE(outbuf));
gst_pad_push (rtpgsmenc->srcpad, outbuf); gst_pad_push (rtpgsmenc->srcpad, GST_DATA (outbuf));
++rtpgsmenc->seq; ++rtpgsmenc->seq;
rtpgsmenc->next_time += rtpgsmenc->time_interval * GST_BUFFER_SIZE (buf); rtpgsmenc->next_time += rtpgsmenc->time_interval * GST_BUFFER_SIZE (buf);

7
gst/rtp/gstrtpgsmparse.c
View file

@ -67,7 +67,7 @@ GST_PAD_TEMPLATE_FACTORY (sink_factory,
static void gst_rtpgsmparse_class_init (GstRtpGSMParseClass * klass); static void gst_rtpgsmparse_class_init (GstRtpGSMParseClass * klass);
static void gst_rtpgsmparse_init (GstRtpGSMParse * rtpgsmparse); static void gst_rtpgsmparse_init (GstRtpGSMParse * rtpgsmparse);
static void gst_rtpgsmparse_chain (GstPad * pad, GstBuffer * buf); static void gst_rtpgsmparse_chain (GstPad * pad, GstData *_data);
static void gst_rtpgsmparse_set_property (GObject * object, guint prop_id, static void gst_rtpgsmparse_set_property (GObject * object, guint prop_id,
const GValue * value, GParamSpec * pspec); const GValue * value, GParamSpec * pspec);
@ -160,8 +160,9 @@ gst_rtpgsm_caps_nego (GstRtpGSMParse *rtpgsmparse)
} }
static void static void
gst_rtpgsmparse_chain (GstPad * pad, GstBuffer * buf) gst_rtpgsmparse_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstRtpGSMParse *rtpgsmparse; GstRtpGSMParse *rtpgsmparse;
GstBuffer *outbuf; GstBuffer *outbuf;
Rtp_Packet packet; Rtp_Packet packet;
@ -212,7 +213,7 @@ gst_rtpgsmparse_chain (GstPad * pad, GstBuffer * buf)
gst_rtpgsmparse_ntohs (outbuf); gst_rtpgsmparse_ntohs (outbuf);
#endif #endif
gst_pad_push (rtpgsmparse->srcpad, outbuf); gst_pad_push (rtpgsmparse->srcpad, GST_DATA (outbuf));
rtp_packet_free (packet); rtp_packet_free (packet);
gst_buffer_unref (buf); gst_buffer_unref (buf);

7
gst/rtp/gstrtpgsmpay.c
View file

@ -71,7 +71,7 @@ GST_PAD_TEMPLATE_FACTORY (src_factory,
static void gst_rtpgsmenc_class_init (GstRtpGSMEncClass * klass); static void gst_rtpgsmenc_class_init (GstRtpGSMEncClass * klass);
static void gst_rtpgsmenc_init (GstRtpGSMEnc * rtpgsmenc); static void gst_rtpgsmenc_init (GstRtpGSMEnc * rtpgsmenc);
static void gst_rtpgsmenc_chain (GstPad * pad, GstBuffer * buf); static void gst_rtpgsmenc_chain (GstPad * pad, GstData *_data);
static void gst_rtpgsmenc_set_property (GObject * object, guint prop_id, static void gst_rtpgsmenc_set_property (GObject * object, guint prop_id,
const GValue * value, GParamSpec * pspec); const GValue * value, GParamSpec * pspec);
static void gst_rtpgsmenc_get_property (GObject * object, guint prop_id, static void gst_rtpgsmenc_get_property (GObject * object, guint prop_id,
@ -170,8 +170,9 @@ gst_rtpgsmenc_htons (GstBuffer *buf)
} }
static void static void
gst_rtpgsmenc_chain (GstPad * pad, GstBuffer * buf) gst_rtpgsmenc_chain (GstPad * pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstRtpGSMEnc *rtpgsmenc; GstRtpGSMEnc *rtpgsmenc;
GstBuffer *outbuf; GstBuffer *outbuf;
Rtp_Packet packet; Rtp_Packet packet;
@ -227,7 +228,7 @@ gst_rtpgsmenc_chain (GstPad * pad, GstBuffer * buf)
memcpy (GST_BUFFER_DATA (outbuf) + rtp_packet_get_packet_len(packet), GST_BUFFER_DATA (buf), GST_BUFFER_SIZE (buf)); memcpy (GST_BUFFER_DATA (outbuf) + rtp_packet_get_packet_len(packet), GST_BUFFER_DATA (buf), GST_BUFFER_SIZE (buf));
GST_DEBUG ("gst_rtpgsmenc_chain: pushing buffer of size %d", GST_BUFFER_SIZE(outbuf)); GST_DEBUG ("gst_rtpgsmenc_chain: pushing buffer of size %d", GST_BUFFER_SIZE(outbuf));
gst_pad_push (rtpgsmenc->srcpad, outbuf); gst_pad_push (rtpgsmenc->srcpad, GST_DATA (outbuf));
++rtpgsmenc->seq; ++rtpgsmenc->seq;
rtpgsmenc->next_time += rtpgsmenc->time_interval * GST_BUFFER_SIZE (buf); rtpgsmenc->next_time += rtpgsmenc->time_interval * GST_BUFFER_SIZE (buf);

5
gst/smoothwave/gstsmoothwave.c
View file

@ -56,7 +56,7 @@ static void gst_smoothwave_init (GstSmoothWave *smoothwave);
static void gst_smoothwave_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); static void gst_smoothwave_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
static void gst_smoothwave_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec); static void gst_smoothwave_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec);
static void gst_smoothwave_chain (GstPad *pad, GstBuffer *buf); static void gst_smoothwave_chain (GstPad *pad, GstData *_data);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
/*static guint gst_smoothwave_signals[LAST_SIGNAL] = { 0 }; */ /*static guint gst_smoothwave_signals[LAST_SIGNAL] = { 0 }; */
@ -146,8 +146,9 @@ gst_smoothwave_init (GstSmoothWave *smoothwave)
} }
static void static void
gst_smoothwave_chain (GstPad *pad, GstBuffer *buf) gst_smoothwave_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstSmoothWave *smoothwave; GstSmoothWave *smoothwave;
gint16 *samples; gint16 *samples;
gint samplecount,i; gint samplecount,i;

10
gst/smpte/gstsmpte.c
View file

@ -323,18 +323,18 @@ gst_smpte_loop (GstElement *element)
ts = smpte->position * GST_SECOND / smpte->fps; ts = smpte->position * GST_SECOND / smpte->fps;
while (GST_PAD_IS_USABLE (smpte->sinkpad1) && in1 == NULL) { while (GST_PAD_IS_USABLE (smpte->sinkpad1) && in1 == NULL) {
in1 = gst_pad_pull (smpte->sinkpad1); in1 = GST_BUFFER (gst_pad_pull (smpte->sinkpad1));
if (GST_IS_EVENT (in1)) { if (GST_IS_EVENT (in1)) {
gst_pad_push (smpte->srcpad, in1); gst_pad_push (smpte->srcpad, GST_DATA (in1));
in1 = NULL; in1 = NULL;
} }
else else
ts = GST_BUFFER_TIMESTAMP (in1); ts = GST_BUFFER_TIMESTAMP (in1);
} }
if (GST_PAD_IS_USABLE (smpte->sinkpad2) && in2 == NULL) { if (GST_PAD_IS_USABLE (smpte->sinkpad2) && in2 == NULL) {
in2 = gst_pad_pull (smpte->sinkpad2); in2 = GST_BUFFER (gst_pad_pull (smpte->sinkpad2));
if (GST_IS_EVENT (in2)) { if (GST_IS_EVENT (in2)) {
gst_pad_push (smpte->srcpad, in2); gst_pad_push (smpte->srcpad, GST_DATA (in2));
in2 = NULL; in2 = NULL;
} }
else else
@ -390,7 +390,7 @@ gst_smpte_loop (GstElement *element)
gst_buffer_unref (in2); gst_buffer_unref (in2);
GST_BUFFER_TIMESTAMP (outbuf) = ts; GST_BUFFER_TIMESTAMP (outbuf) = ts;
gst_pad_push (smpte->srcpad, outbuf); gst_pad_push (smpte->srcpad, GST_DATA (outbuf));
} }
static void static void

7
gst/spectrum/gstspectrum.c
View file

@ -52,7 +52,7 @@ static void gst_spectrum_init (GstSpectrum *spectrum);
static void gst_spectrum_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); static void gst_spectrum_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
static void gst_spectrum_chain (GstPad *pad, GstBuffer *buf); static void gst_spectrum_chain (GstPad *pad, GstData *_data);
#define fixed short #define fixed short
int gst_spectrum_fix_fft(fixed fr[], fixed fi[], int m, int inverse); int gst_spectrum_fix_fft(fixed fr[], fixed fi[], int m, int inverse);
@ -131,8 +131,9 @@ gst_spectrum_set_property (GObject *object, guint prop_id, const GValue *value,
} }
static void static void
gst_spectrum_chain (GstPad *pad, GstBuffer *buf) gst_spectrum_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstSpectrum *spectrum; GstSpectrum *spectrum;
gint spec_base, spec_len; gint spec_base, spec_len;
gint16 *re, *im, *loud; gint16 *re, *im, *loud;
@ -188,7 +189,7 @@ gst_spectrum_chain (GstPad *pad, GstBuffer *buf)
GST_BUFFER_DATA(newbuf) = spect; GST_BUFFER_DATA(newbuf) = spect;
GST_BUFFER_SIZE(newbuf) = spectrum->width; GST_BUFFER_SIZE(newbuf) = spectrum->width;
gst_pad_push(spectrum->srcpad,newbuf); gst_pad_push(spectrum->srcpad,GST_DATA (newbuf));
} }
static gboolean static gboolean

5
gst/udp/gstudpsink.c
View file

@ -75,7 +75,7 @@ static void gst_udpsink_init (GstUDPSink *udpsink);
static void gst_udpsink_set_clock (GstElement *element, GstClock *clock); static void gst_udpsink_set_clock (GstElement *element, GstClock *clock);
static void gst_udpsink_chain (GstPad *pad,GstBuffer *buf); static void gst_udpsink_chain (GstPad *pad,GstData *_data);
static GstElementStateReturn gst_udpsink_change_state (GstElement *element); static GstElementStateReturn gst_udpsink_change_state (GstElement *element);
static void gst_udpsink_set_property (GObject *object, guint prop_id, static void gst_udpsink_set_property (GObject *object, guint prop_id,
@ -257,8 +257,9 @@ gst_udpsink_init (GstUDPSink *udpsink)
} }
static void static void
gst_udpsink_chain (GstPad *pad, GstBuffer *buf) gst_udpsink_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstUDPSink *udpsink; GstUDPSink *udpsink;
guint tolen, i; guint tolen, i;

8
gst/udp/gstudpsrc.c
View file

@ -72,7 +72,7 @@ gst_udpsrc_control_get_type(void) {
static void gst_udpsrc_class_init (GstUDPSrc *klass); static void gst_udpsrc_class_init (GstUDPSrc *klass);
static void gst_udpsrc_init (GstUDPSrc *udpsrc); static void gst_udpsrc_init (GstUDPSrc *udpsrc);
static GstBuffer* gst_udpsrc_get (GstPad *pad); static GstData* gst_udpsrc_get (GstPad *pad);
static GstElementStateReturn static GstElementStateReturn
gst_udpsrc_change_state (GstElement *element); gst_udpsrc_change_state (GstElement *element);
@ -166,7 +166,7 @@ gst_udpsrc_init (GstUDPSrc *udpsrc)
udpsrc->first_buf = TRUE; udpsrc->first_buf = TRUE;
} }
static GstBuffer* static GstData*
gst_udpsrc_get (GstPad *pad) gst_udpsrc_get (GstPad *pad)
{ {
GstUDPSrc *udpsrc; GstUDPSrc *udpsrc;
@ -254,7 +254,7 @@ gst_udpsrc_get (GstPad *pad)
discont = gst_event_new_discontinuous (FALSE, GST_FORMAT_TIME, discont = gst_event_new_discontinuous (FALSE, GST_FORMAT_TIME,
current_time, NULL); current_time, NULL);
gst_pad_push (udpsrc->srcpad, GST_BUFFER (discont)); gst_pad_push (udpsrc->srcpad, GST_DATA (discont));
} }
udpsrc->first_buf = FALSE; udpsrc->first_buf = FALSE;
@ -283,7 +283,7 @@ gst_udpsrc_get (GstPad *pad)
perror ("select"); perror ("select");
outbuf = NULL; outbuf = NULL;
} }
return outbuf; return GST_DATA (outbuf);
} }

7
gst/videocrop/gstvideocrop.c
View file

@ -118,7 +118,7 @@ static void gst_video_crop_get_property (GObject *object, guint prop_id,
static GstPadLinkReturn static GstPadLinkReturn
gst_video_crop_sink_connect (GstPad *pad, GstCaps *caps); gst_video_crop_sink_connect (GstPad *pad, GstCaps *caps);
static void gst_video_crop_chain (GstPad *pad, GstBuffer *buffer); static void gst_video_crop_chain (GstPad *pad, GstData *_data);
static GstElementStateReturn static GstElementStateReturn
gst_video_crop_change_state (GstElement *element); gst_video_crop_change_state (GstElement *element);
@ -345,8 +345,9 @@ gst_video_crop_i420 (GstVideoCrop *video_crop, GstBuffer *src_buffer, GstBuffer
} }
static void static void
gst_video_crop_chain (GstPad *pad, GstBuffer *buffer) gst_video_crop_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buffer = GST_BUFFER (_data);
GstVideoCrop *video_crop; GstVideoCrop *video_crop;
GstBuffer *outbuf; GstBuffer *outbuf;
gint new_width, new_height; gint new_width, new_height;
@ -391,7 +392,7 @@ gst_video_crop_chain (GstPad *pad, GstBuffer *buffer)
gst_video_crop_i420 (video_crop, buffer, outbuf); gst_video_crop_i420 (video_crop, buffer, outbuf);
gst_buffer_unref (buffer); gst_buffer_unref (buffer);
gst_pad_push (video_crop->srcpad, outbuf); gst_pad_push (video_crop->srcpad, GST_DATA (outbuf));
} }
static GstElementStateReturn static GstElementStateReturn

9
gst/videofilter/gstvideofilter.c
View file

@ -56,7 +56,7 @@ static void gst_videofilter_init (GstVideofilter *videofilter);
static void gst_videofilter_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); static void gst_videofilter_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
static void gst_videofilter_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec); static void gst_videofilter_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec);
static void gst_videofilter_chain (GstPad *pad, GstBuffer *buf); static void gst_videofilter_chain (GstPad *pad, GstData *_data);
GstCaps * gst_videofilter_class_get_capslist(GstVideofilterClass *klass); GstCaps * gst_videofilter_class_get_capslist(GstVideofilterClass *klass);
static void gst_videofilter_setup(GstVideofilter *videofilter); static void gst_videofilter_setup(GstVideofilter *videofilter);
@ -366,8 +366,9 @@ gst_videofilter_postinit (GstVideofilter *videofilter)
static void static void
gst_videofilter_chain (GstPad *pad, GstBuffer *buf) gst_videofilter_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstVideofilter *videofilter; GstVideofilter *videofilter;
guchar *data; guchar *data;
gulong size; gulong size;
@ -386,7 +387,7 @@ gst_videofilter_chain (GstPad *pad, GstBuffer *buf)
size = GST_BUFFER_SIZE(buf); size = GST_BUFFER_SIZE(buf);
if(videofilter->passthru){ if(videofilter->passthru){
gst_pad_push(videofilter->srcpad, buf); gst_pad_push(videofilter->srcpad, GST_DATA (buf));
return; return;
} }
@ -419,7 +420,7 @@ gst_videofilter_chain (GstPad *pad, GstBuffer *buf)
GST_DEBUG ("gst_videofilter_chain: pushing buffer of %d bytes in '%s'",GST_BUFFER_SIZE(outbuf), GST_DEBUG ("gst_videofilter_chain: pushing buffer of %d bytes in '%s'",GST_BUFFER_SIZE(outbuf),
GST_OBJECT_NAME (videofilter)); GST_OBJECT_NAME (videofilter));
gst_pad_push(videofilter->srcpad, outbuf); gst_pad_push(videofilter->srcpad, GST_DATA (outbuf));
gst_buffer_unref(buf); gst_buffer_unref(buf);
} }

9
gst/videoflip/gstvideoflip.c
View file

@ -56,7 +56,7 @@ static void gst_videoflip_init (GstVideoflip *videoflip);
static void gst_videoflip_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); static void gst_videoflip_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
static void gst_videoflip_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec); static void gst_videoflip_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec);
static void gst_videoflip_chain (GstPad *pad, GstBuffer *buf); static void gst_videoflip_chain (GstPad *pad, GstData *_data);
static GstCaps * gst_videoflip_get_capslist(void); static GstCaps * gst_videoflip_get_capslist(void);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
@ -341,8 +341,9 @@ gst_videoflip_init (GstVideoflip *videoflip)
static void static void
gst_videoflip_chain (GstPad *pad, GstBuffer *buf) gst_videoflip_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstVideoflip *videoflip; GstVideoflip *videoflip;
guchar *data; guchar *data;
gulong size; gulong size;
@ -361,7 +362,7 @@ gst_videoflip_chain (GstPad *pad, GstBuffer *buf)
size = GST_BUFFER_SIZE(buf); size = GST_BUFFER_SIZE(buf);
if(videoflip->passthru){ if(videoflip->passthru){
gst_pad_push(videoflip->srcpad, buf); gst_pad_push(videoflip->srcpad, GST_DATA (buf));
return; return;
} }
@ -392,7 +393,7 @@ gst_videoflip_chain (GstPad *pad, GstBuffer *buf)
GST_DEBUG ("gst_videoflip_chain: pushing buffer of %d bytes in '%s'",GST_BUFFER_SIZE(outbuf), GST_DEBUG ("gst_videoflip_chain: pushing buffer of %d bytes in '%s'",GST_BUFFER_SIZE(outbuf),
GST_OBJECT_NAME (videoflip)); GST_OBJECT_NAME (videoflip));
gst_pad_push(videoflip->srcpad, outbuf); gst_pad_push(videoflip->srcpad, GST_DATA (outbuf));
gst_buffer_unref(buf); gst_buffer_unref(buf);
} }

13
gst/wavenc/gstwavenc.c
View file

@ -27,7 +27,7 @@
static void gst_wavenc_class_init (GstWavEncClass *klass); static void gst_wavenc_class_init (GstWavEncClass *klass);
static void gst_wavenc_init (GstWavEnc *wavenc); static void gst_wavenc_init (GstWavEnc *wavenc);
static void gst_wavenc_chain (GstPad *pad, GstBuffer *buf); static void gst_wavenc_chain (GstPad *pad, GstData *_data);
#define WAVE_FORMAT_PCM 0x0001 #define WAVE_FORMAT_PCM 0x0001
@ -253,7 +253,7 @@ gst_wavenc_stop_file (GstWavEnc *wavenc)
WRITE_U32 (wavenc->header + 4, wavenc->length); WRITE_U32 (wavenc->header + 4, wavenc->length);
memcpy (GST_BUFFER_DATA (outbuf), wavenc->header, WAV_HEADER_LEN); memcpy (GST_BUFFER_DATA (outbuf), wavenc->header, WAV_HEADER_LEN);
gst_pad_push (wavenc->srcpad, outbuf); gst_pad_push (wavenc->srcpad, GST_DATA (outbuf));
} }
static void static void
@ -275,8 +275,9 @@ gst_wavenc_init (GstWavEnc *wavenc)
static void static void
gst_wavenc_chain (GstPad *pad, gst_wavenc_chain (GstPad *pad,
GstBuffer *buf) GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstWavEnc *wavenc; GstWavEnc *wavenc;
wavenc = GST_WAVENC (gst_pad_get_parent (pad)); wavenc = GST_WAVENC (gst_pad_get_parent (pad));
@ -292,7 +293,7 @@ gst_wavenc_chain (GstPad *pad,
wavenc->pad_eos = TRUE; wavenc->pad_eos = TRUE;
gst_wavenc_stop_file (wavenc); gst_wavenc_stop_file (wavenc);
gst_pad_push (wavenc->srcpad, gst_pad_push (wavenc->srcpad,
GST_BUFFER (gst_event_new (GST_EVENT_EOS))); GST_DATA (gst_event_new (GST_EVENT_EOS)));
gst_element_set_eos (GST_ELEMENT (wavenc)); gst_element_set_eos (GST_ELEMENT (wavenc));
} else { } else {
gst_pad_event_default (wavenc->srcpad, GST_EVENT (buf)); gst_pad_event_default (wavenc->srcpad, GST_EVENT (buf));
@ -308,12 +309,12 @@ gst_wavenc_chain (GstPad *pad,
memcpy (GST_BUFFER_DATA (outbuf), wavenc->header, WAV_HEADER_LEN); memcpy (GST_BUFFER_DATA (outbuf), wavenc->header, WAV_HEADER_LEN);
GST_BUFFER_TIMESTAMP (outbuf) = GST_BUFFER_TIMESTAMP (buf); GST_BUFFER_TIMESTAMP (outbuf) = GST_BUFFER_TIMESTAMP (buf);
gst_pad_push (wavenc->srcpad, outbuf); gst_pad_push (wavenc->srcpad, GST_DATA (outbuf));
wavenc->flush_header = FALSE; wavenc->flush_header = FALSE;
} }
wavenc->length += GST_BUFFER_SIZE (buf); wavenc->length += GST_BUFFER_SIZE (buf);
gst_pad_push (wavenc->srcpad, buf); gst_pad_push (wavenc->srcpad, GST_DATA (buf));
} }
} }

13
gst/wavparse/gstwavparse.c
View file

@ -46,7 +46,7 @@ static gboolean gst_wavparse_pad_convert (GstPad *pad,
gint64 src_value, gint64 src_value,
GstFormat *dest_format, GstFormat *dest_format,
gint64 *dest_value); gint64 *dest_value);
static void gst_wavparse_chain (GstPad *pad, GstBuffer *buf); static void gst_wavparse_chain (GstPad *pad, GstData *_data);
static const GstEventMask* static const GstEventMask*
gst_wavparse_get_event_masks (GstPad *pad); gst_wavparse_get_event_masks (GstPad *pad);
@ -324,8 +324,9 @@ static void wav_new_chunk_callback(GstRiffChunk *chunk, gpointer data)
} }
static void static void
gst_wavparse_chain (GstPad *pad, GstBuffer *buf) gst_wavparse_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstWavParse *wavparse; GstWavParse *wavparse;
gboolean buffer_riffed = FALSE; /* so we don't parse twice */ gboolean buffer_riffed = FALSE; /* so we don't parse twice */
gulong size; gulong size;
@ -380,19 +381,19 @@ gst_wavparse_chain (GstPad *pad, GstBuffer *buf)
if (wavparse->need_discont) { if (wavparse->need_discont) {
if (buf && GST_BUFFER_TIMESTAMP_IS_VALID (buf)) { if (buf && GST_BUFFER_TIMESTAMP_IS_VALID (buf)) {
gst_pad_push (wavparse->srcpad, gst_pad_push (wavparse->srcpad,
GST_BUFFER (gst_event_new_discontinuous (FALSE, GST_DATA (gst_event_new_discontinuous (FALSE,
GST_FORMAT_BYTES, wavparse->offset, GST_FORMAT_BYTES, wavparse->offset,
GST_FORMAT_TIME, GST_BUFFER_TIMESTAMP (buf), GST_FORMAT_TIME, GST_BUFFER_TIMESTAMP (buf),
NULL))); NULL)));
} else { } else {
gst_pad_push (wavparse->srcpad, gst_pad_push (wavparse->srcpad,
GST_BUFFER (gst_event_new_discontinuous (FALSE, GST_DATA (gst_event_new_discontinuous (FALSE,
GST_FORMAT_BYTES, wavparse->offset, GST_FORMAT_BYTES, wavparse->offset,
NULL))); NULL)));
} }
wavparse->need_discont = FALSE; wavparse->need_discont = FALSE;
} }
gst_pad_push (wavparse->srcpad, buf); gst_pad_push (wavparse->srcpad, GST_DATA (buf));
} else { } else {
gst_buffer_unref (buf); gst_buffer_unref (buf);
} }
@ -494,7 +495,7 @@ gst_wavparse_chain (GstPad *pad, GstBuffer *buf)
GST_BUFFER_TIMESTAMP (newbuf) = 0; GST_BUFFER_TIMESTAMP (newbuf) = 0;
if (GST_PAD_IS_USABLE (wavparse->srcpad)) if (GST_PAD_IS_USABLE (wavparse->srcpad))
gst_pad_push (wavparse->srcpad, newbuf); gst_pad_push (wavparse->srcpad, GST_DATA (newbuf));
else else
gst_buffer_unref (newbuf); gst_buffer_unref (newbuf);

6
sys/oss/gstossgst.c
View file

@ -55,7 +55,7 @@ static GstElementStateReturn gst_ossgst_change_state (GstElement *element);
static void gst_ossgst_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec); static void gst_ossgst_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
static void gst_ossgst_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec); static void gst_ossgst_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec);
static GstBuffer* gst_ossgst_get (GstPad *pad); static GstData* gst_ossgst_get (GstPad *pad);
/* OssGst signals and args */ /* OssGst signals and args */
enum { enum {
@ -277,7 +277,7 @@ gst_ossgst_format_to_caps (gint format, gint stereo, gint rate)
return caps; return caps;
} }
static GstBuffer* static GstData*
gst_ossgst_get (GstPad *pad) gst_ossgst_get (GstPad *pad)
{ {
GstOssGst *ossgst; GstOssGst *ossgst;
@ -320,7 +320,7 @@ gst_ossgst_get (GstPad *pad)
} }
} }
return buf; return GST_DATA (buf);
} }
static void static void

5
sys/oss/gstosssink.c
View file

@ -67,7 +67,7 @@ static void gst_osssink_set_property (GObject *object, guint prop_id, const G
static void gst_osssink_get_property (GObject *object, guint prop_id, GValue *value, static void gst_osssink_get_property (GObject *object, guint prop_id, GValue *value,
GParamSpec *pspec); GParamSpec *pspec);
static void gst_osssink_chain (GstPad *pad,GstBuffer *buf); static void gst_osssink_chain (GstPad *pad,GstData *_data);
/* OssSink signals and args */ /* OssSink signals and args */
enum { enum {
@ -316,8 +316,9 @@ gst_osssink_set_clock (GstElement *element, GstClock *clock)
} }
static void static void
gst_osssink_chain (GstPad *pad, GstBuffer *buf) gst_osssink_chain (GstPad *pad, GstData *_data)
{ {
GstBuffer *buf = GST_BUFFER (_data);
GstOssSink *osssink; GstOssSink *osssink;
GstClockTime buftime; GstClockTime buftime;

16
sys/oss/gstosssrc.c
View file

@ -112,7 +112,7 @@ static const GstQueryType* gst_osssrc_get_query_types (GstPad *pad);
static gboolean gst_osssrc_src_query (GstPad *pad, GstQueryType type, static gboolean gst_osssrc_src_query (GstPad *pad, GstQueryType type,
GstFormat *format, gint64 *value); GstFormat *format, gint64 *value);
static GstBuffer * gst_osssrc_get (GstPad *pad); static GstData * gst_osssrc_get (GstPad *pad);
static GstElementClass *parent_class = NULL; static GstElementClass *parent_class = NULL;
/*static guint gst_osssrc_signals[LAST_SIGNAL] = { 0 }; */ /*static guint gst_osssrc_signals[LAST_SIGNAL] = { 0 }; */
@ -293,7 +293,7 @@ gst_osssrc_set_clock (GstElement *element, GstClock *clock)
osssrc->clock = clock; osssrc->clock = clock;
} }
static GstBuffer * static GstData *
gst_osssrc_get (GstPad *pad) gst_osssrc_get (GstPad *pad)
{ {
GstOssSrc *src; GstOssSrc *src;
@ -306,7 +306,7 @@ gst_osssrc_get (GstPad *pad)
if (src->need_eos) { if (src->need_eos) {
src->need_eos = FALSE; src->need_eos = FALSE;
return GST_BUFFER (gst_event_new (GST_EVENT_EOS)); return GST_DATA (gst_event_new (GST_EVENT_EOS));
} }
buf = gst_buffer_new_and_alloc (src->buffersize); buf = gst_buffer_new_and_alloc (src->buffersize);
@ -316,13 +316,13 @@ gst_osssrc_get (GstPad *pad)
if (!gst_osssrc_negotiate (pad)) { if (!gst_osssrc_negotiate (pad)) {
gst_buffer_unref (buf); gst_buffer_unref (buf);
gst_element_error (GST_ELEMENT (src), "could not negotiate format"); gst_element_error (GST_ELEMENT (src), "could not negotiate format");
return GST_BUFFER (gst_event_new (GST_EVENT_INTERRUPT)); return GST_DATA (gst_event_new (GST_EVENT_INTERRUPT));
} }
} }
if (GST_OSSELEMENT (src)->bps == 0) { if (GST_OSSELEMENT (src)->bps == 0) {
gst_buffer_unref (buf); gst_buffer_unref (buf);
gst_element_error (GST_ELEMENT (src), "no format negotiated"); gst_element_error (GST_ELEMENT (src), "no format negotiated");
return GST_BUFFER (gst_event_new (GST_EVENT_INTERRUPT)); return GST_DATA (gst_event_new (GST_EVENT_INTERRUPT));
} }
readbytes = read (GST_OSSELEMENT (src)->fd,GST_BUFFER_DATA (buf), readbytes = read (GST_OSSELEMENT (src)->fd,GST_BUFFER_DATA (buf),
@ -331,13 +331,13 @@ gst_osssrc_get (GstPad *pad)
gst_buffer_unref (buf); gst_buffer_unref (buf);
gst_element_error (GST_ELEMENT (src), "error reading data (%s)", gst_element_error (GST_ELEMENT (src), "error reading data (%s)",
strerror (errno)); strerror (errno));
return GST_BUFFER (gst_event_new (GST_EVENT_INTERRUPT)); return GST_DATA (gst_event_new (GST_EVENT_INTERRUPT));
} }
if (readbytes == 0) { if (readbytes == 0) {
gst_buffer_unref (buf); gst_buffer_unref (buf);
gst_element_set_eos (GST_ELEMENT (src)); gst_element_set_eos (GST_ELEMENT (src));
return GST_BUFFER (gst_event_new (GST_EVENT_INTERRUPT)); return GST_DATA (gst_event_new (GST_EVENT_INTERRUPT));
} }
GST_BUFFER_SIZE (buf) = readbytes; GST_BUFFER_SIZE (buf) = readbytes;
@ -353,7 +353,7 @@ gst_osssrc_get (GstPad *pad)
GST_DEBUG ("pushed buffer from soundcard of %ld bytes, timestamp %" G_GINT64_FORMAT, GST_DEBUG ("pushed buffer from soundcard of %ld bytes, timestamp %" G_GINT64_FORMAT,
readbytes, GST_BUFFER_TIMESTAMP (buf)); readbytes, GST_BUFFER_TIMESTAMP (buf));
return buf; return GST_DATA (buf);
} }
static void static void

6
sys/v4l2/gstv4l2src.c
View file

@ -74,7 +74,7 @@ static GstPadLinkReturn gst_v4l2src_srcconnect (GstPad *pad,
GstCaps *caps); GstCaps *caps);
static GstCaps * gst_v4l2src_getcaps (GstPad *pad, static GstCaps * gst_v4l2src_getcaps (GstPad *pad,
GstCaps *caps); GstCaps *caps);
static GstBuffer * gst_v4l2src_get (GstPad *pad); static GstData * gst_v4l2src_get (GstPad *pad);
/* get/set params */ /* get/set params */
static void gst_v4l2src_set_property (GObject *object, static void gst_v4l2src_set_property (GObject *object,
@ -765,7 +765,7 @@ gst_v4l2src_getcaps (GstPad *pad,
} }
static GstBuffer* static GstData*
gst_v4l2src_get (GstPad *pad) gst_v4l2src_get (GstPad *pad)
{ {
GstV4l2Src *v4l2src; GstV4l2Src *v4l2src;
@ -874,7 +874,7 @@ gst_v4l2src_get (GstPad *pad)
g_signal_emit(G_OBJECT(v4l2src), g_signal_emit(G_OBJECT(v4l2src),
gst_v4l2src_signals[SIGNAL_FRAME_CAPTURE], 0); gst_v4l2src_signals[SIGNAL_FRAME_CAPTURE], 0);
return buf; return GST_DATA (buf);
} }

5
tests/examples/spectrum/demo-osssrc.c
View file

@ -3,7 +3,7 @@
extern gboolean _gst_plugin_spew; extern gboolean _gst_plugin_spew;
void spectrum_chain(GstPad *pad,GstBuffer *buf); void spectrum_chain(GstPad *pad,GstData *_data);
gboolean idle_func(gpointer data); gboolean idle_func(gpointer data);
GtkWidget *drawingarea; GtkWidget *drawingarea;
@ -62,7 +62,8 @@ int main(int argc,char *argv[]) {
} }
void spectrum_chain(GstPad *pad,GstBuffer *buf) { void spectrum_chain(GstPad *pad,GstData *_data) {
GstBuffer *buf = GST_BUFFER (_data);
gint i; gint i;
guchar *data = buf->data; guchar *data = buf->data;