-Subproject commit b7abb510aa14e8692df39ea8c2c758e37d8a8d8a
+Subproject commit e903f88a7388f0b463204ea1f960a4ace840175b
static void gst_aasink_init (GstAASink *aasink);
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,
const GValue *value, GParamSpec *pspec);
}
static void
-gst_aasink_chain (GstPad *pad, GstBuffer *buf)
+gst_aasink_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstAASink *aasink;
g_return_if_fail (pad != NULL);
GstEvent *discont;
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) &&
(dvdec->next_ts >= dvdec->end_position)) {
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
- gst_pad_push (pad, GST_BUFFER(gst_event_new (GST_EVENT_EOS)));
+ gst_pad_push (pad, GST_DATA(gst_event_new (GST_EVENT_EOS))));
}
}
static GstElementStateReturn gst_esdmon_change_state (GstElement *element);
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,
const GValue *value, GParamSpec *pspec);
return gst_esdmon_open_audio (esdmon);
}
-static GstBuffer *
+static GstData *
gst_esdmon_get (GstPad *pad)
{
GstEsdmon *esdmon;
esdmon->samples_since_basetime += readsamples;
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 GstClockTime gst_esdsink_get_time (GstClock *clock, gpointer data);
static GstClock * gst_esdsink_get_clock (GstElement *element);
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,
const GValue *value, GParamSpec *pspec);
}
static void
-gst_esdsink_chain (GstPad *pad, GstBuffer *buf)
+gst_esdsink_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstEsdsink *esdsink;
esdsink = GST_ESDSINK (gst_pad_get_parent (pad));
GST_FORMAT_DEFAULT, flacdec->total_samples,
NULL);
- gst_pad_push (flacdec->srcpad, GST_BUFFER (discont));
+ gst_pad_push (flacdec->srcpad, GST_DATA (discont));
}
}
}
g_warning ("flacdec: invalid depth %d found\n", depth);
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;
if (GST_PAD_IS_USABLE (flacdec->srcpad)) {
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);
}
static GstPadLinkReturn
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 void gst_flacenc_set_property (GObject *object, guint prop_id,
event = gst_event_new_seek ((GstSeekType)(int)(GST_FORMAT_BYTES | GST_SEEK_METHOD_SET), absolute_byte_offset);
if (event)
- gst_pad_push (flacenc->srcpad, GST_BUFFER (event));
+ gst_pad_push (flacenc->srcpad, GST_DATA (event));
return FLAC__STREAM_ENCODER_OK;
}
flacenc->first = FALSE;
}
- gst_pad_push (flacenc->srcpad, outbuf);
+ gst_pad_push (flacenc->srcpad, GST_DATA (outbuf));
return FLAC__STREAM_ENCODER_OK;
}
static void
-gst_flacenc_chain (GstPad *pad, GstBuffer *buf)
+gst_flacenc_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
FlacEnc *flacenc;
FLAC__int32 *data;
gulong insize;
GValue *value,
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 void
-gst_gdk_pixbuf_chain (GstPad *pad, GstBuffer *buf)
+gst_gdk_pixbuf_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstGdkPixbuf *filter;
GdkPixbufLoader *pixbuf_loader;
GdkPixbuf *pixbuf;
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 gst_jpegdec_class_init (GstJpegDec *klass);
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
gst_jpegdec_link (GstPad *pad, GstCaps *caps);
}
static void
-gst_jpegdec_chain (GstPad *pad, GstBuffer *buf)
+gst_jpegdec_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstJpegDec *jpegdec;
guchar *data, *outdata;
gulong size, outsize;
jpeg_finish_decompress(&jpegdec->cinfo);
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);
}
static void gst_jpegenc_class_init (GstJpegEnc *klass);
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 GstBuffer *gst_jpegenc_get (GstPad *pad);
+static GstData *gst_jpegenc_get (GstPad *pad);
static void gst_jpegenc_resync (GstJpegEnc *jpegenc);
GST_DEBUG ("gst_jpegenc_resync: resync done");
}
-static GstBuffer*
+static GstData*
gst_jpegenc_get (GstPad *pad)
{
GstJpegEnc *jpegenc;
}
gst_buffer_ref(jpegenc->buffer);
- return jpegenc->buffer;
+ return GST_DATA (jpegenc->buffer);
}
static void
-gst_jpegenc_chain (GstPad *pad, GstBuffer *buf)
+gst_jpegenc_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstJpegEnc *jpegenc;
guchar *data, *outdata;
gulong size, outsize;
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);
static GstElementStateReturn gst_ladspa_change_state (GstElement *element);
static void gst_ladspa_loop (GstElement *element);
-static void gst_ladspa_chain (GstPad *pad,GstBuffer *buf);
-static GstBuffer * gst_ladspa_get (GstPad *pad);
+static void gst_ladspa_chain (GstPad *pad,GstData *_data);
+static GstData * gst_ladspa_get (GstPad *pad);
static GstElementClass *parent_class = NULL;
/* first get all the necessary data from the input ports */
for (i=0 ; i<numsinkpads ; i++){
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])) {
/* push it out on all pads */
gst_data_ref_by_count ((GstData*)buffers_in[i], numsrcpads);
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) {
/* shut down */
gst_element_set_eos (element);
}
for (i=0 ; i<numsrcpads ; 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;
buffers_out[i] = NULL;
}
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_Data *data_in, **data_out = NULL;
GstBuffer **buffers_out = NULL;
for (i=0; i<numsrcpads; i++) {
DEBUG_OBJ (ladspa, "pushing buffer (%p, length %u bytes) on src pad %d",
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);
}
}
-static GstBuffer *
+static GstData *
gst_ladspa_get(GstPad *pad)
{
GstLADSPA *ladspa;
num_processed = num_to_process;
}
- return buf;
+ return GST_DATA (buf);
}
static void
static void gst_pngenc_class_init (GstPngEncClass *klass);
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;
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)));
}
}
static void
-gst_pngenc_chain (GstPad *pad, GstBuffer *buf)
+gst_pngenc_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstPngEnc *pngenc;
gint row_index;
png_byte *row_pointers[MAX_HEIGHT];
png_destroy_info_struct (pngenc->png_struct_ptr, &pngenc->png_info_ptr);
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 */
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);
}
/* FIXME, send a flush event or something */
need_sync = 0 ;
}
- gst_pad_push( srcpad, outdata );
+ gst_pad_push( srcpad, GST_DATA (outdata ));
}
srcpad = mikmod->srcpad;
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) ) {
GstEvent *event = GST_EVENT (buffer_in);
}
else {
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))));
}
}
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;
guchar *pixbuf;
gint x0, y0;
if (overlay->bitmap.buffer)
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) \
g_return_if_fail(GST_IS_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);
/*
if(!GST_PAD_IS_USABLE(overlay->text_sinkpad)){
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)
break;
overlay->need_render = FALSE;
}
- gst_textoverlay_video_chain(overlay->srcpad, video_frame);
+ gst_textoverlay_video_chain(overlay->srcpad, GST_DATA (video_frame));
}
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 guint gst_filter_signals[LAST_SIGNAL] = { 0 }; */
return 0;
}
-static GstBuffer *
+static GstData *
gst_dv1394src_get (GstPad *pad)
{
GstDV1394Src *dv1394src = GST_DV1394SRC (GST_PAD_PARENT(pad));
static void gst_shout2send_class_init (GstShout2sendClass *klass);
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 void gst_shout2send_set_property (GObject *object, guint prop_id, const GValue *value, GParamSpec *pspec);
}
static void
-gst_shout2send_chain (GstPad *pad, GstBuffer *buf)
+gst_shout2send_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstShout2send *shout2send;
glong ret;
static void gst_speexdec_class_init (GstSpeexDec *klass);
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 GstElementClass *parent_class = NULL;
}
static void
-gst_speexdec_chain (GstPad *pad, GstBuffer *buf)
+gst_speexdec_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstSpeexDec *speexdec;
gchar *data;
guint size;
static void gst_speexenc_class_init (GstSpeexEnc *klass);
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 GstElementClass *parent_class = NULL;
}
static void
-gst_speexenc_chain (GstPad *pad, GstBuffer *buf)
+gst_speexenc_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstSpeexEnc *speexenc;
GstBuffer *outbuf;
gint16 *data;
GST_BUFFER_DATA (outbuf) = header_data;
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);
GST_BUFFER_TIMESTAMP (outbuf) = speexenc->next_ts;
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;
}
GST_BUFFER_TIMESTAMP (outbuf) = speexenc->next_ts;
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;
}
static void gst_bpwsinc_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec);
-static void gst_bpwsinc_chain (GstPad * pad, GstBuffer * buf);
+static void gst_bpwsinc_chain (GstPad * pad, GstData *_data);
static GstPadLinkReturn
gst_bpwsinc_sink_connect (GstPad * pad, GstCaps * caps);
}
static void
-gst_bpwsinc_chain (GstPad *pad, GstBuffer *buf)
+gst_bpwsinc_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstBPWSinc *filter;
gfloat *src;
gfloat *input;
}
g_free (input);
- gst_pad_push (filter->srcpad, buf);
+ gst_pad_push (filter->srcpad, GST_DATA (buf));
}
static void
static void gst_lpwsinc_get_property (GObject * object, guint prop_id,
GValue * value, GParamSpec * pspec);
-static void gst_lpwsinc_chain (GstPad * pad, GstBuffer * buf);
+static void gst_lpwsinc_chain (GstPad * pad, GstData *_data);
static GstPadLinkReturn
gst_lpwsinc_sink_connect (GstPad * pad, GstCaps * caps);
}
static void
-gst_lpwsinc_chain (GstPad * pad, GstBuffer * buf)
+gst_lpwsinc_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstLPWSinc *filter;
gfloat *src;
gfloat *input;
}
g_free (input);
- gst_pad_push (filter->srcpad, buf);
+ gst_pad_push (filter->srcpad, GST_DATA (buf));
}
static void
static void gst_auparse_class_init (GstAuParseClass *klass);
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 guint gst_auparse_signals[LAST_SIGNAL] = { 0 }; */
}
static void
-gst_auparse_chain (GstPad *pad, GstBuffer *buf)
+gst_auparse_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstAuParse *auparse;
gchar *data;
glong size;
gst_buffer_unref (buf);
- gst_pad_push (auparse->srcpad, newbuf);
+ gst_pad_push (auparse->srcpad, GST_DATA (newbuf));
return;
}
- gst_pad_push (auparse->srcpad, buf);
+ gst_pad_push (auparse->srcpad, GST_DATA (buf));
}
discont = gst_event_new_discontinuous (FALSE, GST_FORMAT_TIME,
avi_demux->last_seek + stream->delay , NULL);
- gst_pad_push (stream->pad, GST_BUFFER (discont));
+ gst_pad_push (stream->pad, GST_DATA (discont));
}
}
break;
else {
if (GST_PAD_IS_USABLE (stream->pad)) {
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,
stream_id, next_ts, stream->current_frame - 1,
stream->end_pos);
stream_id, next_ts, stream->current_frame - 1,
stream->delay, chunk.size);
- gst_pad_push(stream->pad, buf);
+ gst_pad_push(stream->pad, GST_DATA (buf));
}
}
}
memcpy(GST_BUFFER_DATA(buffer), "idx1", 4);
temp32 = LE_FROM_GUINT32(avimux->idx_index * sizeof(gst_riff_index_entry));
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();
GST_BUFFER_SIZE(buffer) = avimux->idx_index * sizeof(gst_riff_index_entry);
GST_BUFFER_DATA(buffer) = (unsigned char*) avimux->idx;
avimux->idx = NULL; /* will be free()'ed by gst_buffer_unref() */
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;
GST_SEEK_FLAG_FLUSH,
avimux->avix_start);
/* if the event succeeds */
- gst_pad_push(avimux->srcpad, GST_BUFFER(event));
+ gst_pad_push(avimux->srcpad, GST_DATA(event));
/* rewrite AVIX header */
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 */
event = gst_event_new_seek (GST_FORMAT_BYTES |
GST_SEEK_METHOD_SET |
GST_SEEK_FLAG_FLUSH,
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;
header = gst_avimux_riff_get_avix_header(0);
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 */
header = gst_avimux_riff_get_avi_header(avimux);
avimux->total_data += GST_BUFFER_SIZE(header);
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->restart = FALSE;
header = gst_avimux_riff_get_avi_header(avimux);
event = gst_event_new_seek (GST_FORMAT_BYTES |
GST_SEEK_METHOD_SET, 0);
- gst_pad_push(avimux->srcpad, GST_BUFFER(event));
- gst_pad_push(avimux->srcpad, header);
+ gst_pad_push(avimux->srcpad, GST_DATA(event));
+ gst_pad_push(avimux->srcpad, GST_DATA (header));
event = gst_event_new_seek (GST_FORMAT_BYTES |
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;
gst_avimux_stop_file(avimux);
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_PAD_IS_USABLE(avimux->audiosinkpad) &&
!avimux->audio_pad_eos)
{
- buffer = gst_pad_pull(avimux->audiosinkpad);
+ buffer = GST_BUFFER (gst_pad_pull(avimux->audiosinkpad));
if (GST_IS_EVENT(buffer)) {
gst_avimux_handle_event(avimux->audiosinkpad, GST_EVENT(buffer));
} else {
GST_PAD_IS_USABLE(avimux->videosinkpad) &&
!avimux->video_pad_eos)
{
- buffer = gst_pad_pull(avimux->videosinkpad);
+ buffer = GST_BUFFER (gst_pad_pull(avimux->videosinkpad));
if (GST_IS_EVENT(buffer)) {
gst_avimux_handle_event(avimux->videosinkpad, GST_EVENT(buffer));
} else {
GST_BUFFER_DATA(buffer) = g_malloc(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 */
gst_avimux_add_index(avimux, "01wb", 0x0, GST_BUFFER_SIZE(data));
}
- gst_pad_push(avimux->srcpad, header);
- gst_pad_push(avimux->srcpad, data);
+ gst_pad_push(avimux->srcpad, GST_DATA (header));
+ gst_pad_push(avimux->srcpad, GST_DATA (data));
if (pad_bytes) {
gst_avimux_send_pad_data(avimux, pad_bytes);
}
gst_avimux_add_index(avimux, "00db", flags, GST_BUFFER_SIZE(data));
}
- gst_pad_push(avimux->srcpad, header);
- gst_pad_push(avimux->srcpad, data);
+ gst_pad_push(avimux->srcpad, GST_DATA (header));
+ gst_pad_push(avimux->srcpad, GST_DATA (data));
if (pad_bytes) {
gst_avimux_send_pad_data(avimux, pad_bytes);
}
/* simply finish off the file and send EOS */
gst_avimux_stop_file(avimux);
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));
return FALSE;
}
static void gst_cutter_get_property (GObject *object, guint prop_id,
GValue *value, GParamSpec *pspec);
-static void gst_cutter_chain (GstPad *pad, GstBuffer *buf);
+static void gst_cutter_chain (GstPad *pad, GstData *_data);
static double
inline gst_cutter_16bit_ms (gint16* data, guint numsamples);
static double
}
static void
-gst_cutter_chain (GstPad *pad, GstBuffer *buf)
+gst_cutter_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstCutter *filter;
gint16 *in_data;
double RMS = 0.0; /* RMS of signal in buffer */
{
prebuf = (g_list_first (filter->pre_buffer))->data;
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;
}
GST_DEBUG ("flushed %d buffers", count);
filter->pre_run_length -= gst_audio_length (filter->srcpad, prebuf);
/* only pass buffers if we don't leak */
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 */
gst_buffer_unref (prebuf);
}
}
else
- gst_pad_push (filter->srcpad, buf);
+ gst_pad_push (filter->srcpad, GST_DATA (buf));
}
static double inline
GValue *value,
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 void
-gst_efence_chain (GstPad *pad, GstBuffer *buffer)
+gst_efence_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buffer = GST_BUFFER (_data);
GstEFence *efence;
GstBuffer *copy;
void *ptr;
GST_BUFFER_POOL_PRIVATE (copy) = NULL;
gst_buffer_unref(buffer);
- gst_pad_push (efence->srcpad, copy);
+ gst_pad_push (efence->srcpad, GST_DATA (copy));
}
static void
static void gst_agingtv_get_property (GObject * object, guint prop_id,
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 guint gst_agingtv_signals[LAST_SIGNAL] = { 0 }; */
}
static void
-gst_agingtv_chain (GstPad * pad, GstBuffer * buf)
+gst_agingtv_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstAgingTV *filter;
guint32 *src, *dest;
GstBuffer *outbuf;
gst_buffer_unref (buf);
- gst_pad_push (filter->srcpad, outbuf);
+ gst_pad_push (filter->srcpad, GST_DATA (outbuf));
}
static void
static void gst_dicetv_get_property (GObject * object, guint prop_id,
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 guint gst_dicetv_signals[LAST_SIGNAL] = { 0 };
}
static void
-gst_dicetv_chain (GstPad * pad, GstBuffer * buf)
+gst_dicetv_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstDiceTV *filter;
guint32 *src, *dest;
GstBuffer *outbuf;
gst_buffer_unref (buf);
- gst_pad_push (filter->srcpad, outbuf);
+ gst_pad_push (filter->srcpad, GST_DATA (outbuf));
}
static void
static void gst_edgetv_get_property (GObject * object, guint prop_id,
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 guint gst_edgetv_signals[LAST_SIGNAL] = { 0 }; */
}
static void
-gst_edgetv_chain (GstPad * pad, GstBuffer * buf)
+gst_edgetv_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstEdgeTV *filter;
int x, y;
int r, g, b;
}
gst_buffer_unref (buf);
- gst_pad_push (filter->srcpad, outbuf);
+ gst_pad_push (filter->srcpad, GST_DATA (outbuf));
}
static void
static void gst_quarktv_get_property (GObject * object, guint prop_id,
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 guint gst_quarktv_signals[LAST_SIGNAL] = { 0 }; */
}
static void
-gst_quarktv_chain (GstPad * pad, GstBuffer * buf)
+gst_quarktv_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstQuarkTV *filter;
guint32 *src, *dest;
GstBuffer *outbuf;
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--;
static void gst_revtv_get_property (GObject * object, guint prop_id,
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 guint gst_revtv_signals[LAST_SIGNAL] = { 0 }; */
static void
-gst_revtv_chain (GstPad * pad, GstBuffer * buf)
+gst_revtv_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstRevTV *filter;
guint32 *src, *dest;
GstBuffer *outbuf;
gst_buffer_unref (buf);
- gst_pad_push (filter->srcpad, outbuf);
+ gst_pad_push (filter->srcpad, GST_DATA (outbuf));
}
static void
static void gst_shagadelictv_get_property (GObject * object, guint prop_id,
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 guint gst_shagadelictv_signals[LAST_SIGNAL] = { 0 }; */
return 0;
}
static void
-gst_shagadelictv_chain (GstPad * pad, GstBuffer * buf)
+gst_shagadelictv_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstShagadelicTV *filter;
guint32 *src, *dest;
GstBuffer *outbuf;
gst_buffer_unref (buf);
- gst_pad_push (filter->srcpad, outbuf);
+ gst_pad_push (filter->srcpad, GST_DATA (outbuf));
}
static void
static void gst_vertigotv_get_property (GObject * object, guint prop_id,
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 guint gst_vertigotv_signals[LAST_SIGNAL] = { 0 };
}
static void
-gst_vertigotv_chain (GstPad * pad, GstBuffer * buf)
+gst_vertigotv_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstVertigoTV *filter;
guint32 *src, *dest;
GstBuffer *outbuf;
gst_buffer_unref (buf);
- gst_pad_push (filter->srcpad, outbuf);
+ gst_pad_push (filter->srcpad, GST_DATA (outbuf));
p = filter->current_buffer;
filter->current_buffer = filter->alt_buffer;
static void gst_warptv_get_property (GObject * object, guint prop_id,
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 guint gst_warptv_signals[LAST_SIGNAL] = { 0 }; */
}
static void
-gst_warptv_chain (GstPad * pad, GstBuffer * buf)
+gst_warptv_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstWarpTV *filter;
guint32 *src, *dest;
gint xw,yw,cw;
gst_buffer_unref (buf);
- gst_pad_push (filter->srcpad, outbuf);
+ gst_pad_push (filter->srcpad, GST_DATA (outbuf));
}
static void
GST_BUFFER_TIMESTAMP (out) = flxdec->next_time;
flxdec->next_time += flxdec->frame_time;
- gst_pad_push(flxdec->srcpad, out);
+ gst_pad_push(flxdec->srcpad, GST_DATA (out));
break;
}
static GstElementStateReturn
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_srcconnect (GstPad *pad, GstCaps *caps);
}
static void
-gst_goom_chain (GstPad *pad, GstBuffer *bufin)
+gst_goom_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *bufin = GST_BUFFER (_data);
GstGOOM *goom;
GstBuffer *bufout;
guint32 samples_in;
goom->next_time += GST_SECOND / goom->fps;
- gst_pad_push (goom->srcpad, bufout);
+ gst_pad_push (goom->srcpad, GST_DATA (bufout));
done:
gst_buffer_unref (bufin);
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_chain (GstPad *pad, GstBuffer *buf);
+static void gst_alawdec_chain (GstPad *pad, GstData *_data);
static GstElementClass *parent_class = NULL;
}
static void
-gst_alawdec_chain (GstPad *pad,GstBuffer *buf)
+gst_alawdec_chain (GstPad *pad,GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstALawDec *alawdec;
gint16 *linear_data;
guint8 *alaw_data;
}
gst_buffer_unref(buf);
- gst_pad_push(alawdec->srcpad,outbuf);
+ gst_pad_push(alawdec->srcpad,GST_DATA (outbuf));
}
static void
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_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
}
static void
-gst_alawenc_chain (GstPad *pad,GstBuffer *buf)
+gst_alawenc_chain (GstPad *pad,GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstALawEnc *alawenc;
gint16 *linear_data;
guint8 *alaw_data;
linear_data++;
}
gst_buffer_unref(buf);
- gst_pad_push(alawenc->srcpad,outbuf);
+ gst_pad_push(alawenc->srcpad,GST_DATA (outbuf));
}
static void
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_chain (GstPad *pad, GstBuffer *buf);
+static void gst_mulawdec_chain (GstPad *pad, GstData *_data);
static GstElementClass *parent_class = NULL;
}
static void
-gst_mulawdec_chain (GstPad *pad,GstBuffer *buf)
+gst_mulawdec_chain (GstPad *pad,GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstMuLawDec *mulawdec;
gint16 *linear_data;
guint8 *mulaw_data;
mulaw_decode(mulaw_data,linear_data,GST_BUFFER_SIZE(buf));
gst_buffer_unref(buf);
- gst_pad_push(mulawdec->srcpad,outbuf);
+ gst_pad_push(mulawdec->srcpad,GST_DATA (outbuf));
}
static void
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_chain (GstPad *pad, GstBuffer *buf);
+static void gst_mulawenc_chain (GstPad *pad, GstData *_data);
static GstElementClass *parent_class = NULL;
}
static void
-gst_mulawenc_chain (GstPad *pad,GstBuffer *buf)
+gst_mulawenc_chain (GstPad *pad,GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstMuLawEnc *mulawenc;
gint16 *linear_data;
guint8 *mulaw_data;
mulaw_encode(linear_data,mulaw_data,GST_BUFFER_SIZE(outbuf));
gst_buffer_unref(buf);
- gst_pad_push(mulawenc->srcpad,outbuf);
+ gst_pad_push(mulawenc->srcpad,GST_DATA (outbuf));
}
static void
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_chain (GstPad *pad, GstBuffer *buf);
+static void gst_level_chain (GstPad *pad, GstData *_data);
static GstElementClass *parent_class = NULL;
static guint gst_filter_signals[LAST_SIGNAL] = { 0 };
#include "filter.func"
static void
-gst_level_chain (GstPad *pad, GstBuffer *buf)
+gst_level_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstLevel *filter;
gint16 *in_data;
filter->CS[i] += CS;
}
- gst_pad_push (filter->srcpad, buf);
+ gst_pad_push (filter->srcpad, GST_DATA (buf));
filter->num_samples += num_samples;
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 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_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec);
}
static void
-gst_median_chain (GstPad *pad, GstBuffer *buf)
+gst_median_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstMedian *median;
guchar *data;
gulong size;
median = GST_MEDIAN (GST_OBJECT_PARENT (pad));
if (!median->active) {
- gst_pad_push(median->srcpad,buf);
+ gst_pad_push(median->srcpad,GST_DATA (buf));
return;
}
gst_buffer_unref(buf);
- gst_pad_push(median->srcpad,outbuf);
+ gst_pad_push(median->srcpad,GST_DATA (outbuf));
}
static void
static void gst_monoscope_class_init (GstMonoscopeClass *klass);
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
gst_monoscope_sinkconnect (GstPad *pad, GstCaps *caps);
}
static void
-gst_monoscope_chain (GstPad *pad, GstBuffer *bufin)
+gst_monoscope_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *bufin = GST_BUFFER (_data);
GstMonoscope *monoscope;
GstBuffer *bufout;
guint32 samples_in;
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);
if(index==-1){
for(i=0;i<qtdemux->n_streams;i++){
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);
GST_DEBUG ("seek returned %d",ret);
GST_BUFFER_TIMESTAMP(buf) = stream->samples[stream->sample_index].timestamp;
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++;
break;
static void gst_rtpL16parse_class_init (GstRtpL16ParseClass * klass);
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,
const GValue * value, GParamSpec * pspec);
}
static void
-gst_rtpL16parse_chain (GstPad * pad, GstBuffer * buf)
+gst_rtpL16parse_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstRtpL16Parse *rtpL16parse;
GstBuffer *outbuf;
Rtp_Packet packet;
gst_rtpL16parse_ntohs (outbuf);
#endif
- gst_pad_push (rtpL16parse->srcpad, outbuf);
+ gst_pad_push (rtpL16parse->srcpad, GST_DATA (outbuf));
rtp_packet_free (packet);
gst_buffer_unref (buf);
static void gst_rtpL16enc_class_init (GstRtpL16EncClass * klass);
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,
const GValue * value, GParamSpec * pspec);
static void gst_rtpL16enc_get_property (GObject * object, guint prop_id,
}
static void
-gst_rtpL16enc_chain (GstPad * pad, GstBuffer * buf)
+gst_rtpL16enc_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstRtpL16Enc *rtpL16enc;
GstBuffer *outbuf;
Rtp_Packet packet;
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_pad_push (rtpL16enc->srcpad, outbuf);
+ gst_pad_push (rtpL16enc->srcpad, GST_DATA (outbuf));
++rtpL16enc->seq;
rtpL16enc->next_time += rtpL16enc->time_interval * GST_BUFFER_SIZE (buf);
static void gst_rtpL16parse_class_init (GstRtpL16ParseClass * klass);
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,
const GValue * value, GParamSpec * pspec);
}
static void
-gst_rtpL16parse_chain (GstPad * pad, GstBuffer * buf)
+gst_rtpL16parse_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstRtpL16Parse *rtpL16parse;
GstBuffer *outbuf;
Rtp_Packet packet;
gst_rtpL16parse_ntohs (outbuf);
#endif
- gst_pad_push (rtpL16parse->srcpad, outbuf);
+ gst_pad_push (rtpL16parse->srcpad, GST_DATA (outbuf));
rtp_packet_free (packet);
gst_buffer_unref (buf);
static void gst_rtpL16enc_class_init (GstRtpL16EncClass * klass);
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,
const GValue * value, GParamSpec * pspec);
static void gst_rtpL16enc_get_property (GObject * object, guint prop_id,
}
static void
-gst_rtpL16enc_chain (GstPad * pad, GstBuffer * buf)
+gst_rtpL16enc_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstRtpL16Enc *rtpL16enc;
GstBuffer *outbuf;
Rtp_Packet packet;
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_pad_push (rtpL16enc->srcpad, outbuf);
+ gst_pad_push (rtpL16enc->srcpad, GST_DATA (outbuf));
++rtpL16enc->seq;
rtpL16enc->next_time += rtpL16enc->time_interval * GST_BUFFER_SIZE (buf);
static void gst_rtpgsmparse_class_init (GstRtpGSMParseClass * klass);
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,
const GValue * value, GParamSpec * pspec);
}
static void
-gst_rtpgsmparse_chain (GstPad * pad, GstBuffer * buf)
+gst_rtpgsmparse_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstRtpGSMParse *rtpgsmparse;
GstBuffer *outbuf;
Rtp_Packet packet;
gst_rtpgsmparse_ntohs (outbuf);
#endif
- gst_pad_push (rtpgsmparse->srcpad, outbuf);
+ gst_pad_push (rtpgsmparse->srcpad, GST_DATA (outbuf));
rtp_packet_free (packet);
gst_buffer_unref (buf);
static void gst_rtpgsmenc_class_init (GstRtpGSMEncClass * klass);
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,
const GValue * value, GParamSpec * pspec);
static void gst_rtpgsmenc_get_property (GObject * object, guint prop_id,
}
static void
-gst_rtpgsmenc_chain (GstPad * pad, GstBuffer * buf)
+gst_rtpgsmenc_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstRtpGSMEnc *rtpgsmenc;
GstBuffer *outbuf;
Rtp_Packet packet;
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_pad_push (rtpgsmenc->srcpad, outbuf);
+ gst_pad_push (rtpgsmenc->srcpad, GST_DATA (outbuf));
++rtpgsmenc->seq;
rtpgsmenc->next_time += rtpgsmenc->time_interval * GST_BUFFER_SIZE (buf);
static void gst_rtpgsmparse_class_init (GstRtpGSMParseClass * klass);
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,
const GValue * value, GParamSpec * pspec);
}
static void
-gst_rtpgsmparse_chain (GstPad * pad, GstBuffer * buf)
+gst_rtpgsmparse_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstRtpGSMParse *rtpgsmparse;
GstBuffer *outbuf;
Rtp_Packet packet;
gst_rtpgsmparse_ntohs (outbuf);
#endif
- gst_pad_push (rtpgsmparse->srcpad, outbuf);
+ gst_pad_push (rtpgsmparse->srcpad, GST_DATA (outbuf));
rtp_packet_free (packet);
gst_buffer_unref (buf);
static void gst_rtpgsmenc_class_init (GstRtpGSMEncClass * klass);
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,
const GValue * value, GParamSpec * pspec);
static void gst_rtpgsmenc_get_property (GObject * object, guint prop_id,
}
static void
-gst_rtpgsmenc_chain (GstPad * pad, GstBuffer * buf)
+gst_rtpgsmenc_chain (GstPad * pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstRtpGSMEnc *rtpgsmenc;
GstBuffer *outbuf;
Rtp_Packet packet;
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_pad_push (rtpgsmenc->srcpad, outbuf);
+ gst_pad_push (rtpgsmenc->srcpad, GST_DATA (outbuf));
++rtpgsmenc->seq;
rtpgsmenc->next_time += rtpgsmenc->time_interval * GST_BUFFER_SIZE (buf);
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_chain (GstPad *pad, GstBuffer *buf);
+static void gst_smoothwave_chain (GstPad *pad, GstData *_data);
static GstElementClass *parent_class = NULL;
/*static guint gst_smoothwave_signals[LAST_SIGNAL] = { 0 }; */
}
static void
-gst_smoothwave_chain (GstPad *pad, GstBuffer *buf)
+gst_smoothwave_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstSmoothWave *smoothwave;
gint16 *samples;
gint samplecount,i;
ts = smpte->position * GST_SECOND / smpte->fps;
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)) {
- gst_pad_push (smpte->srcpad, in1);
+ gst_pad_push (smpte->srcpad, GST_DATA (in1));
in1 = NULL;
}
else
ts = GST_BUFFER_TIMESTAMP (in1);
}
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)) {
- gst_pad_push (smpte->srcpad, in2);
+ gst_pad_push (smpte->srcpad, GST_DATA (in2));
in2 = NULL;
}
else
gst_buffer_unref (in2);
GST_BUFFER_TIMESTAMP (outbuf) = ts;
- gst_pad_push (smpte->srcpad, outbuf);
+ gst_pad_push (smpte->srcpad, GST_DATA (outbuf));
}
static void
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
int gst_spectrum_fix_fft(fixed fr[], fixed fi[], int m, int inverse);
}
static void
-gst_spectrum_chain (GstPad *pad, GstBuffer *buf)
+gst_spectrum_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstSpectrum *spectrum;
gint spec_base, spec_len;
gint16 *re, *im, *loud;
GST_BUFFER_DATA(newbuf) = spect;
GST_BUFFER_SIZE(newbuf) = spectrum->width;
- gst_pad_push(spectrum->srcpad,newbuf);
+ gst_pad_push(spectrum->srcpad,GST_DATA (newbuf));
}
static gboolean
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 void gst_udpsink_set_property (GObject *object, guint prop_id,
}
static void
-gst_udpsink_chain (GstPad *pad, GstBuffer *buf)
+gst_udpsink_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstUDPSink *udpsink;
guint tolen, i;
static void gst_udpsrc_class_init (GstUDPSrc *klass);
static void gst_udpsrc_init (GstUDPSrc *udpsrc);
-static GstBuffer* gst_udpsrc_get (GstPad *pad);
+static GstData* gst_udpsrc_get (GstPad *pad);
static GstElementStateReturn
gst_udpsrc_change_state (GstElement *element);
udpsrc->first_buf = TRUE;
}
-static GstBuffer*
+static GstData*
gst_udpsrc_get (GstPad *pad)
{
GstUDPSrc *udpsrc;
discont = gst_event_new_discontinuous (FALSE, GST_FORMAT_TIME,
current_time, NULL);
- gst_pad_push (udpsrc->srcpad, GST_BUFFER (discont));
+ gst_pad_push (udpsrc->srcpad, GST_DATA (discont));
}
udpsrc->first_buf = FALSE;
perror ("select");
outbuf = NULL;
}
- return outbuf;
+ return GST_DATA (outbuf);
}
static GstPadLinkReturn
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
gst_video_crop_change_state (GstElement *element);
}
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;
GstBuffer *outbuf;
gint new_width, new_height;
gst_video_crop_i420 (video_crop, buffer, outbuf);
gst_buffer_unref (buffer);
- gst_pad_push (video_crop->srcpad, outbuf);
+ gst_pad_push (video_crop->srcpad, GST_DATA (outbuf));
}
static GstElementStateReturn
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_chain (GstPad *pad, GstBuffer *buf);
+static void gst_videofilter_chain (GstPad *pad, GstData *_data);
GstCaps * gst_videofilter_class_get_capslist(GstVideofilterClass *klass);
static void gst_videofilter_setup(GstVideofilter *videofilter);
static void
-gst_videofilter_chain (GstPad *pad, GstBuffer *buf)
+gst_videofilter_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstVideofilter *videofilter;
guchar *data;
gulong size;
size = GST_BUFFER_SIZE(buf);
if(videofilter->passthru){
- gst_pad_push(videofilter->srcpad, buf);
+ gst_pad_push(videofilter->srcpad, GST_DATA (buf));
return;
}
GST_DEBUG ("gst_videofilter_chain: pushing buffer of %d bytes in '%s'",GST_BUFFER_SIZE(outbuf),
GST_OBJECT_NAME (videofilter));
- gst_pad_push(videofilter->srcpad, outbuf);
+ gst_pad_push(videofilter->srcpad, GST_DATA (outbuf));
gst_buffer_unref(buf);
}
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_chain (GstPad *pad, GstBuffer *buf);
+static void gst_videoflip_chain (GstPad *pad, GstData *_data);
static GstCaps * gst_videoflip_get_capslist(void);
static GstElementClass *parent_class = NULL;
static void
-gst_videoflip_chain (GstPad *pad, GstBuffer *buf)
+gst_videoflip_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstVideoflip *videoflip;
guchar *data;
gulong size;
size = GST_BUFFER_SIZE(buf);
if(videoflip->passthru){
- gst_pad_push(videoflip->srcpad, buf);
+ gst_pad_push(videoflip->srcpad, GST_DATA (buf));
return;
}
GST_DEBUG ("gst_videoflip_chain: pushing buffer of %d bytes in '%s'",GST_BUFFER_SIZE(outbuf),
GST_OBJECT_NAME (videoflip));
- gst_pad_push(videoflip->srcpad, outbuf);
+ gst_pad_push(videoflip->srcpad, GST_DATA (outbuf));
gst_buffer_unref(buf);
}
static void gst_wavenc_class_init (GstWavEncClass *klass);
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
WRITE_U32 (wavenc->header + 4, wavenc->length);
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
gst_wavenc_chain (GstPad *pad,
- GstBuffer *buf)
+ GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstWavEnc *wavenc;
wavenc = GST_WAVENC (gst_pad_get_parent (pad));
wavenc->pad_eos = TRUE;
gst_wavenc_stop_file (wavenc);
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));
} else {
gst_pad_event_default (wavenc->srcpad, GST_EVENT (buf));
memcpy (GST_BUFFER_DATA (outbuf), wavenc->header, WAV_HEADER_LEN);
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->length += GST_BUFFER_SIZE (buf);
- gst_pad_push (wavenc->srcpad, buf);
+ gst_pad_push (wavenc->srcpad, GST_DATA (buf));
}
}
gint64 src_value,
GstFormat *dest_format,
gint64 *dest_value);
-static void gst_wavparse_chain (GstPad *pad, GstBuffer *buf);
+static void gst_wavparse_chain (GstPad *pad, GstData *_data);
static const GstEventMask*
gst_wavparse_get_event_masks (GstPad *pad);
}
static void
-gst_wavparse_chain (GstPad *pad, GstBuffer *buf)
+gst_wavparse_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstWavParse *wavparse;
gboolean buffer_riffed = FALSE; /* so we don't parse twice */
gulong size;
if (wavparse->need_discont) {
if (buf && GST_BUFFER_TIMESTAMP_IS_VALID (buf)) {
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_TIME, GST_BUFFER_TIMESTAMP (buf),
NULL)));
} else {
gst_pad_push (wavparse->srcpad,
- GST_BUFFER (gst_event_new_discontinuous (FALSE,
+ GST_DATA (gst_event_new_discontinuous (FALSE,
GST_FORMAT_BYTES, wavparse->offset,
NULL)));
}
wavparse->need_discont = FALSE;
}
- gst_pad_push (wavparse->srcpad, buf);
+ gst_pad_push (wavparse->srcpad, GST_DATA (buf));
} else {
gst_buffer_unref (buf);
}
GST_BUFFER_TIMESTAMP (newbuf) = 0;
if (GST_PAD_IS_USABLE (wavparse->srcpad))
- gst_pad_push (wavparse->srcpad, newbuf);
+ gst_pad_push (wavparse->srcpad, GST_DATA (newbuf));
else
gst_buffer_unref (newbuf);
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 GstBuffer* gst_ossgst_get (GstPad *pad);
+static GstData* gst_ossgst_get (GstPad *pad);
/* OssGst signals and args */
enum {
return caps;
}
-static GstBuffer*
+static GstData*
gst_ossgst_get (GstPad *pad)
{
GstOssGst *ossgst;
}
}
- return buf;
+ return GST_DATA (buf);
}
static void
static void gst_osssink_get_property (GObject *object, guint prop_id, GValue *value,
GParamSpec *pspec);
-static void gst_osssink_chain (GstPad *pad,GstBuffer *buf);
+static void gst_osssink_chain (GstPad *pad,GstData *_data);
/* OssSink signals and args */
enum {
}
static void
-gst_osssink_chain (GstPad *pad, GstBuffer *buf)
+gst_osssink_chain (GstPad *pad, GstData *_data)
{
+ GstBuffer *buf = GST_BUFFER (_data);
GstOssSink *osssink;
GstClockTime buftime;
static gboolean gst_osssrc_src_query (GstPad *pad, GstQueryType type,
GstFormat *format, gint64 *value);
-static GstBuffer * gst_osssrc_get (GstPad *pad);
+static GstData * gst_osssrc_get (GstPad *pad);
static GstElementClass *parent_class = NULL;
/*static guint gst_osssrc_signals[LAST_SIGNAL] = { 0 }; */
osssrc->clock = clock;
}
-static GstBuffer *
+static GstData *
gst_osssrc_get (GstPad *pad)
{
GstOssSrc *src;
if (src->need_eos) {
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);
if (!gst_osssrc_negotiate (pad)) {
gst_buffer_unref (buf);
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) {
gst_buffer_unref (buf);
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),
gst_buffer_unref (buf);
gst_element_error (GST_ELEMENT (src), "error reading data (%s)",
strerror (errno));
- return GST_BUFFER (gst_event_new (GST_EVENT_INTERRUPT));
+ return GST_DATA (gst_event_new (GST_EVENT_INTERRUPT));
}
if (readbytes == 0) {
gst_buffer_unref (buf);
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_DEBUG ("pushed buffer from soundcard of %ld bytes, timestamp %" G_GINT64_FORMAT,
readbytes, GST_BUFFER_TIMESTAMP (buf));
- return buf;
+ return GST_DATA (buf);
}
static void
GstCaps *caps);
static GstCaps * gst_v4l2src_getcaps (GstPad *pad,
GstCaps *caps);
-static GstBuffer * gst_v4l2src_get (GstPad *pad);
+static GstData * gst_v4l2src_get (GstPad *pad);
/* get/set params */
static void gst_v4l2src_set_property (GObject *object,
}
-static GstBuffer*
+static GstData*
gst_v4l2src_get (GstPad *pad)
{
GstV4l2Src *v4l2src;
g_signal_emit(G_OBJECT(v4l2src),
gst_v4l2src_signals[SIGNAL_FRAME_CAPTURE], 0);
- return buf;
+ return GST_DATA (buf);
}
extern gboolean _gst_plugin_spew;
-void spectrum_chain(GstPad *pad,GstBuffer *buf);
+void spectrum_chain(GstPad *pad,GstData *_data);
gboolean idle_func(gpointer data);
GtkWidget *drawingarea;
}
-void spectrum_chain(GstPad *pad,GstBuffer *buf) {
+void spectrum_chain(GstPad *pad,GstData *_data) {
+ GstBuffer *buf = GST_BUFFER (_data);
gint i;
guchar *data = buf->data;
projects / platform / upstream / gstreamer.git / commitdiff