update for buffer changes

This commit is contained in:
Wim Taymans 2012-03-28 12:49:54 +02:00
parent 3963204e34
commit a9ec4d62a8
17 changed files with 23 additions and 23 deletions

View file

@ -635,7 +635,9 @@ gst_jasper_dec_chain (GstPad * pad, GstBuffer * buf)
if (dec->codec_data) { if (dec->codec_data) {
GstBuffer *tmp; GstBuffer *tmp;
tmp = gst_buffer_merge (dec->codec_data, buf); tmp =
gst_buffer_append (gst_buffer_ref (dec->codec_data),
gst_buffer_ref (buf));
gst_buffer_copy_metadata (tmp, buf, GST_BUFFER_COPY_TIMESTAMPS); gst_buffer_copy_metadata (tmp, buf, GST_BUFFER_COPY_TIMESTAMPS);
gst_buffer_unref (buf); gst_buffer_unref (buf);
buf = tmp; buf = tmp;

View file

@ -232,7 +232,7 @@ gst_rtmp_sink_render (GstBaseSink * bsink, GstBuffer * buf)
GST_LOG_OBJECT (sink, "Joining 2nd buffer of size %" G_GSIZE_FORMAT GST_LOG_OBJECT (sink, "Joining 2nd buffer of size %" G_GSIZE_FORMAT
" to cached buf", gst_buffer_get_size (buf)); " to cached buf", gst_buffer_get_size (buf));
gst_buffer_ref (buf); gst_buffer_ref (buf);
reffed_buf = buf = gst_buffer_join (sink->cache, buf); reffed_buf = buf = gst_buffer_append (sink->cache, buf);
sink->cache = NULL; sink->cache = NULL;
} }

View file

@ -179,7 +179,7 @@ gst_spc_dec_chain (GstPad * pad, GstBuffer * buffer)
GstSpcDec *spc = GST_SPC_DEC (gst_pad_get_parent (pad)); GstSpcDec *spc = GST_SPC_DEC (gst_pad_get_parent (pad));
if (spc->buf) { if (spc->buf) {
spc->buf = gst_buffer_join (spc->buf, buffer); spc->buf = gst_buffer_append (spc->buf, buffer);
} else { } else {
spc->buf = buffer; spc->buf = buffer;
} }

View file

@ -181,7 +181,7 @@ gst_asf_parse_pull_headers (GstAsfParse * asfparse)
GST_ERROR_OBJECT (asfparse, "Failed to pull data from headers"); GST_ERROR_OBJECT (asfparse, "Failed to pull data from headers");
goto leave; goto leave;
} }
headers = gst_buffer_join (guid_and_size, headers); headers = gst_buffer_append (guid_and_size, headers);
guid_and_size = NULL; guid_and_size = NULL;
asfparse->offset += size - ASF_GUID_OBJSIZE_SIZE; asfparse->offset += size - ASF_GUID_OBJSIZE_SIZE;
if (!gst_asf_parse_headers (headers, asfparse->asfinfo)) { if (!gst_asf_parse_headers (headers, asfparse->asfinfo)) {
@ -282,7 +282,7 @@ gst_asf_parse_pull_indexes (GstAsfParse * asfparse)
} }
asfparse->offset += obj_size - ASF_GUID_OBJSIZE_SIZE; asfparse->offset += obj_size - ASF_GUID_OBJSIZE_SIZE;
buf = gst_buffer_join (guid_and_size, buf); buf = gst_buffer_append (guid_and_size, buf);
ret = gst_asf_parse_push (asfparse, buf); ret = gst_asf_parse_push (asfparse, buf);
if (ret != GST_FLOW_OK) if (ret != GST_FLOW_OK)
break; break;

View file

@ -425,7 +425,7 @@ gst_rtp_asf_pay_handle_buffer (GstBaseRTPPayload * rtppay, GstBuffer * buffer)
if (gst_asf_match_guid (GST_BUFFER_DATA (buffer), if (gst_asf_match_guid (GST_BUFFER_DATA (buffer),
&(guids[ASF_DATA_OBJECT_INDEX]))) { &(guids[ASF_DATA_OBJECT_INDEX]))) {
GST_DEBUG_OBJECT (rtpasfpay, "Received data object header"); GST_DEBUG_OBJECT (rtpasfpay, "Received data object header");
rtpasfpay->headers = gst_buffer_join (rtpasfpay->headers, buffer); rtpasfpay->headers = gst_buffer_append (rtpasfpay->headers, buffer);
rtpasfpay->state = ASF_PACKETS; rtpasfpay->state = ASF_PACKETS;
return gst_rtp_asf_pay_parse_headers (rtpasfpay); return gst_rtp_asf_pay_parse_headers (rtpasfpay);

View file

@ -912,7 +912,7 @@ gst_dvd_spu_subpic_chain (GstPad * pad, GstObject * parent, GstBuffer * buf)
if (GST_BUFFER_TIMESTAMP_IS_VALID (buf)) if (GST_BUFFER_TIMESTAMP_IS_VALID (buf))
GST_WARNING_OBJECT (dvdspu, GST_WARNING_OBJECT (dvdspu,
"Joining subpicture buffer with timestamp to previous"); "Joining subpicture buffer with timestamp to previous");
dvdspu->partial_spu = gst_buffer_join (dvdspu->partial_spu, buf); dvdspu->partial_spu = gst_buffer_append (dvdspu->partial_spu, buf);
} else { } else {
/* If we don't yet have a buffer, wait for one with a timestamp, /* If we don't yet have a buffer, wait for one with a timestamp,
* since that will avoid collecting the 2nd half of a partial buf */ * since that will avoid collecting the 2nd half of a partial buf */

View file

@ -603,7 +603,7 @@ gst_hls_demux_chain (GstPad * pad, GstBuffer * buf)
if (demux->playlist == NULL) if (demux->playlist == NULL)
demux->playlist = buf; demux->playlist = buf;
else else
demux->playlist = gst_buffer_join (demux->playlist, buf); demux->playlist = gst_buffer_append (demux->playlist, buf);
gst_object_unref (demux); gst_object_unref (demux);

View file

@ -2360,7 +2360,7 @@ gst_ts_demux_push_pending_data (GstTSDemux * demux, TSDemuxStream * stream)
} }
for (tmp = stream->currentlist->next; tmp; tmp = tmp->next) { for (tmp = stream->currentlist->next; tmp; tmp = tmp->next) {
buf = gst_buffer_join (buf, (GstBuffer *) tmp->data); buf = gst_buffer_append (buf, (GstBuffer *) tmp->data);
} }
GST_BUFFER_TIMESTAMP (buf) = ts; GST_BUFFER_TIMESTAMP (buf) = ts;

View file

@ -451,7 +451,7 @@ gst_nsfdec_chain (GstPad * pad, GstBuffer * buffer)
/* collect all data, we start doing something when we get an EOS /* collect all data, we start doing something when we get an EOS
* event */ * event */
if (nsfdec->tune_buffer) { if (nsfdec->tune_buffer) {
nsfdec->tune_buffer = gst_buffer_join (nsfdec->tune_buffer, buffer); nsfdec->tune_buffer = gst_buffer_append (nsfdec->tune_buffer, buffer);
} else { } else {
nsfdec->tune_buffer = buffer; nsfdec->tune_buffer = buffer;
} }

View file

@ -372,7 +372,7 @@ gst_rtp_vp8_payload_next (GstRtpVP8Pay * self,
offset == self->partition_offset[partition], mark, buffer); offset == self->partition_offset[partition], mark, buffer);
sub = gst_buffer_copy_region (buffer, GST_BUFFER_COPY_ALL, offset, available); sub = gst_buffer_copy_region (buffer, GST_BUFFER_COPY_ALL, offset, available);
out = gst_buffer_join (header, sub); out = gst_buffer_append (header, sub);
gst_buffer_list_insert (list, -1, out); gst_buffer_list_insert (list, -1, out);

View file

@ -696,7 +696,9 @@ gst_mpeg4vparse_pre_push_frame (GstBaseParse * parse, GstBaseParseFrame * frame)
GstBuffer *superbuf; GstBuffer *superbuf;
/* insert header */ /* insert header */
superbuf = gst_buffer_merge (mp4vparse->config, buffer); superbuf =
gst_buffer_append (gst_buffer_ref (mp4vparse->config),
gst_buffer_ref (buffer));
gst_buffer_copy_into (superbuf, buffer, GST_BUFFER_COPY_METADATA, 0, gst_buffer_copy_into (superbuf, buffer, GST_BUFFER_COPY_METADATA, 0,
csize); csize);
gst_buffer_replace (&frame->out_buffer, superbuf); gst_buffer_replace (&frame->out_buffer, superbuf);

View file

@ -973,7 +973,7 @@ gst_decklink_sink_audiosink_chain (GstPad * pad, GstBuffer * buffer)
// concatenate both buffers // concatenate both buffers
g_mutex_lock (decklinksink->audio_mutex); g_mutex_lock (decklinksink->audio_mutex);
decklinksink->audio_buffer = decklinksink->audio_buffer =
gst_buffer_join (decklinksink->audio_buffer, buffer); gst_buffer_append (decklinksink->audio_buffer, buffer);
g_mutex_unlock (decklinksink->audio_mutex); g_mutex_unlock (decklinksink->audio_mutex);
// GST_DEBUG("Audio Buffer Size: %d", GST_BUFFER_SIZE (decklinksink->audio_buffer)); // GST_DEBUG("Audio Buffer Size: %d", GST_BUFFER_SIZE (decklinksink->audio_buffer));

View file

@ -599,7 +599,6 @@ dxr3videosink_chain (GstPad * pad, GstData * _data)
{ {
GstBuffer *buf = GST_BUFFER (_data); GstBuffer *buf = GST_BUFFER (_data);
Dxr3VideoSink *sink; Dxr3VideoSink *sink;
GstBuffer *merged;
g_return_if_fail (pad != NULL); g_return_if_fail (pad != NULL);
g_return_if_fail (GST_IS_PAD (pad)); g_return_if_fail (GST_IS_PAD (pad));
@ -617,10 +616,7 @@ dxr3videosink_chain (GstPad * pad, GstData * _data)
if (sink->cur_buf == NULL) { if (sink->cur_buf == NULL) {
sink->cur_buf = buf; sink->cur_buf = buf;
} else { } else {
merged = gst_buffer_merge (sink->cur_buf, buf); sink->cur_buf = gst_buffer_append (sink->cur_buf, buf);
gst_buffer_unref (sink->cur_buf);
gst_buffer_unref (buf);
sink->cur_buf = merged;
} }
sink->last_ts = GST_BUFFER_TIMESTAMP (buf); sink->last_ts = GST_BUFFER_TIMESTAMP (buf);

View file

@ -36,7 +36,7 @@ gst_vdp_mpeg_frame_add_slice (GstVdpMpegFrame * mpeg_frame, GstBuffer * buf)
if (!mpeg_frame->slices) if (!mpeg_frame->slices)
mpeg_frame->slices = buf; mpeg_frame->slices = buf;
else else
mpeg_frame->slices = gst_buffer_join (mpeg_frame->slices, buf); mpeg_frame->slices = gst_buffer_append (mpeg_frame->slices, buf);
mpeg_frame->n_slices++; mpeg_frame->n_slices++;
} }

View file

@ -159,7 +159,7 @@ GST_START_TEST (test_adts)
buf = gst_buffer_new_and_alloc (size); buf = gst_buffer_new_and_alloc (size);
gst_buffer_fill (buf, 0, raw_data_block, size); gst_buffer_fill (buf, 0, raw_data_block, size);
buf = gst_buffer_join (header_buf, buf); buf = gst_buffer_append (header_buf, buf);
caps = gst_caps_from_string (AAC_CAPS_STRING); caps = gst_caps_from_string (AAC_CAPS_STRING);
do_test (buf, caps); do_test (buf, caps);
gst_caps_unref (caps); gst_caps_unref (caps);

View file

@ -247,7 +247,7 @@ gst_parser_test_run (GstParserTest * test, GstCaps ** out_caps)
if (!k) if (!k)
buffer = buffer_new (test->series[j].data, test->series[j].size); buffer = buffer_new (test->series[j].data, test->series[j].size);
else { else {
buffer = gst_buffer_join (buffer, buffer = gst_buffer_append (buffer,
buffer_new (test->series[j].data, test->series[j].size)); buffer_new (test->series[j].data, test->series[j].size));
} }
} }

View file

@ -24,7 +24,7 @@
#define GST_LICENSE "LGPL" #define GST_LICENSE "LGPL"
/* package name in plugins */ /* package name in plugins */
#define GST_PACKAGE_NAME "GStreamer Bad Plug-ins source release" #define GST_PACKAGE_NAME "GStreamer Bad Plug-ins git"
/* package origin */ /* package origin */
#define GST_PACKAGE_ORIGIN "Unknown package origin" #define GST_PACKAGE_ORIGIN "Unknown package origin"
@ -199,7 +199,7 @@
#undef USE_POISONING #undef USE_POISONING
/* Version number of package */ /* Version number of package */
#define VERSION "0.11.2" #define VERSION "0.11.2.1"
/* Define to 1 if your processor stores words with the most significant byte /* Define to 1 if your processor stores words with the most significant byte
first (like Motorola and SPARC, unlike Intel and VAX). */ first (like Motorola and SPARC, unlike Intel and VAX). */