FaSTTUBe/GST-Tensordecoder-ov_ep
35
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

update for adapter api changes

Browse Source
This commit is contained in:
Wim Taymans 2011-11-10 18:32:58 +01:00
parent fbaf216d25
commit 7e12b58e37
11 changed files with 33 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ext/flac/gstflactag.c
View File

@ -249,7 +249,7 @@ gst_flac_tag_chain (GstPad * pad, GstBuffer * buffer)
size = (block_header[1] << 16) size = (block_header[1] << 16)
| (block_header[2] << 8) | (block_header[2] << 8)
| block_header[3]; | block_header[3];
gst_adapter_unmap (tag->adapter, 0); gst_adapter_unmap (tag->adapter);
/* The 4 bytes long header isn't included in the metadata size */ /* The 4 bytes long header isn't included in the metadata size */
tag->metadata_block_size = size + 4; tag->metadata_block_size = size + 4;

11
gst/auparse/gstauparse.c
View File

@ -351,7 +351,8 @@ gst_au_parse_parse_header (GstAuParse * auparse)
gst_au_parse_negotiate_srcpad (auparse, tempcaps); gst_au_parse_negotiate_srcpad (auparse, tempcaps);
GST_DEBUG_OBJECT (auparse, "offset=%" G_GINT64_FORMAT, auparse->offset); GST_DEBUG_OBJECT (auparse, "offset=%" G_GINT64_FORMAT, auparse->offset);
gst_adapter_unmap (auparse->adapter, auparse->offset); gst_adapter_unmap (auparse->adapter);
gst_adapter_flush (auparse->adapter, auparse->offset);
gst_caps_unref (tempcaps); gst_caps_unref (tempcaps);
return GST_FLOW_OK; return GST_FLOW_OK;
@ -359,27 +360,27 @@ gst_au_parse_parse_header (GstAuParse * auparse)
/* ERRORS */ /* ERRORS */
unknown_header: unknown_header:
{ {
gst_adapter_unmap (auparse->adapter, 0); gst_adapter_unmap (auparse->adapter);
GST_ELEMENT_ERROR (auparse, STREAM, WRONG_TYPE, (NULL), (NULL)); GST_ELEMENT_ERROR (auparse, STREAM, WRONG_TYPE, (NULL), (NULL));
return GST_FLOW_ERROR; return GST_FLOW_ERROR;
} }
unsupported_sample_rate: unsupported_sample_rate:
{ {
gst_adapter_unmap (auparse->adapter, 0); gst_adapter_unmap (auparse->adapter);
GST_ELEMENT_ERROR (auparse, STREAM, FORMAT, (NULL), GST_ELEMENT_ERROR (auparse, STREAM, FORMAT, (NULL),
("Unsupported samplerate: %u", auparse->samplerate)); ("Unsupported samplerate: %u", auparse->samplerate));
return GST_FLOW_ERROR; return GST_FLOW_ERROR;
} }
unsupported_number_of_channels: unsupported_number_of_channels:
{ {
gst_adapter_unmap (auparse->adapter, 0); gst_adapter_unmap (auparse->adapter);
GST_ELEMENT_ERROR (auparse, STREAM, FORMAT, (NULL), GST_ELEMENT_ERROR (auparse, STREAM, FORMAT, (NULL),
("Unsupported number of channels: %u", auparse->channels)); ("Unsupported number of channels: %u", auparse->channels));
return GST_FLOW_ERROR; return GST_FLOW_ERROR;
} }
unknown_format: unknown_format:
{ {
gst_adapter_unmap (auparse->adapter, 0); gst_adapter_unmap (auparse->adapter);
GST_ELEMENT_ERROR (auparse, STREAM, FORMAT, (NULL), GST_ELEMENT_ERROR (auparse, STREAM, FORMAT, (NULL),
("Unsupported encoding: %u", auparse->encoding)); ("Unsupported encoding: %u", auparse->encoding));
return GST_FLOW_ERROR; return GST_FLOW_ERROR;

4
gst/avi/gstavidemux.c
View File

@ -914,7 +914,7 @@ gst_avi_demux_peek_chunk_info (GstAviDemux * avi, guint32 * tag, guint32 * size)
data = gst_adapter_map (avi->adapter, 8); data = gst_adapter_map (avi->adapter, 8);
*tag = GST_READ_UINT32_LE (data); *tag = GST_READ_UINT32_LE (data);
*size = GST_READ_UINT32_LE (data + 4); *size = GST_READ_UINT32_LE (data + 4);
gst_adapter_unmap (avi->adapter, 0); gst_adapter_unmap (avi->adapter);
return TRUE; return TRUE;
} }
@ -3248,7 +3248,7 @@ gst_avi_demux_stream_header_push (GstAviDemux * avi)
tag = GST_READ_UINT32_LE (data); tag = GST_READ_UINT32_LE (data);
size = GST_READ_UINT32_LE (data + 4); size = GST_READ_UINT32_LE (data + 4);
ltag = GST_READ_UINT32_LE (data + 8); ltag = GST_READ_UINT32_LE (data + 8);
gst_adapter_unmap (avi->adapter, 0); gst_adapter_unmap (avi->adapter);
if (tag == GST_RIFF_TAG_LIST) { if (tag == GST_RIFF_TAG_LIST) {
switch (ltag) { switch (ltag) {

4
gst/goom/gstgoom.c
View File

@ -612,7 +612,7 @@ gst_goom_chain (GstPad * pad, GstBuffer * buffer)
GST_DEBUG_OBJECT (goom, "allocating output buffer"); GST_DEBUG_OBJECT (goom, "allocating output buffer");
ret = gst_buffer_pool_acquire_buffer (goom->pool, &outbuf, NULL); ret = gst_buffer_pool_acquire_buffer (goom->pool, &outbuf, NULL);
if (ret != GST_FLOW_OK) { if (ret != GST_FLOW_OK) {
gst_adapter_unmap (goom->adapter, 0); gst_adapter_unmap (goom->adapter);
goto beach; goto beach;
} }
} }
@ -623,7 +623,7 @@ gst_goom_chain (GstPad * pad, GstBuffer * buffer)
out_frame = (guchar *) goom_update (goom->plugin, goom->datain, 0, 0); out_frame = (guchar *) goom_update (goom->plugin, goom->datain, 0, 0);
gst_buffer_fill (outbuf, 0, out_frame, goom->outsize); gst_buffer_fill (outbuf, 0, out_frame, goom->outsize);
gst_adapter_unmap (goom->adapter, 0); gst_adapter_unmap (goom->adapter);
GST_DEBUG ("Pushing frame with time=%" GST_TIME_FORMAT ", duration=%" GST_DEBUG ("Pushing frame with time=%" GST_TIME_FORMAT ", duration=%"
GST_TIME_FORMAT, GST_TIME_ARGS (timestamp), GST_TIME_FORMAT, GST_TIME_ARGS (timestamp),

3
gst/icydemux/gsticydemux.c
View File

@ -331,7 +331,8 @@ gst_icydemux_parse_and_send_tags (GstICYDemux * icydemux)
g_strfreev (strings); g_strfreev (strings);
g_free (buffer); g_free (buffer);
gst_adapter_unmap (icydemux->meta_adapter, length); gst_adapter_unmap (icydemux->meta_adapter);
gst_adapter_flush (icydemux->meta_adapter, length);
if (!gst_tag_list_is_empty (tags)) if (!gst_tag_list_is_empty (tags))
gst_icydemux_tag_found (icydemux, tags); gst_icydemux_tag_found (icydemux, tags);

6
gst/isomp4/qtdemux.c
View File

@ -4050,7 +4050,7 @@ gst_qtdemux_chain (GstPad * sinkpad, GstBuffer * inbuf)
/* get fourcc/length, set neededbytes */ /* get fourcc/length, set neededbytes */
extract_initial_length_and_fourcc ((guint8 *) data, demux->neededbytes, extract_initial_length_and_fourcc ((guint8 *) data, demux->neededbytes,
&size, &fourcc); &size, &fourcc);
gst_adapter_unmap (demux->adapter, 0); gst_adapter_unmap (demux->adapter);
data = NULL; data = NULL;
GST_DEBUG_OBJECT (demux, "Peeking found [%" GST_FOURCC_FORMAT "] " GST_DEBUG_OBJECT (demux, "Peeking found [%" GST_FOURCC_FORMAT "] "
"size: %" G_GUINT64_FORMAT, GST_FOURCC_ARGS (fourcc), size); "size: %" G_GUINT64_FORMAT, GST_FOURCC_ARGS (fourcc), size);
@ -4174,7 +4174,7 @@ gst_qtdemux_chain (GstPad * sinkpad, GstBuffer * inbuf)
GST_DEBUG_OBJECT (demux, "Parsing [moof]"); GST_DEBUG_OBJECT (demux, "Parsing [moof]");
if (!qtdemux_parse_moof (demux, data, demux->neededbytes, if (!qtdemux_parse_moof (demux, data, demux->neededbytes,
demux->offset, NULL)) { demux->offset, NULL)) {
gst_adapter_unmap (demux->adapter, 0); gst_adapter_unmap (demux->adapter);
ret = GST_FLOW_ERROR; ret = GST_FLOW_ERROR;
goto done; goto done;
} }
@ -4193,7 +4193,7 @@ gst_qtdemux_chain (GstPad * sinkpad, GstBuffer * inbuf)
GST_FOURCC_ARGS (fourcc)); GST_FOURCC_ARGS (fourcc));
/* Let's jump that one and go back to initial state */ /* Let's jump that one and go back to initial state */
} }
gst_adapter_unmap (demux->adapter, 0); gst_adapter_unmap (demux->adapter);
data = NULL; data = NULL;
if (demux->mdatbuffer && demux->n_streams) { if (demux->mdatbuffer && demux->n_streams) {

14
gst/multipart/multipartdemux.c
View File

@ -443,7 +443,7 @@ multipart_parse_header (GstMultipartDemux * multipart)
GST_DEBUG_OBJECT (multipart, GST_DEBUG_OBJECT (multipart,
"Parsed the header - boundary: %s, mime-type: %s, content-length: %d", "Parsed the header - boundary: %s, mime-type: %s, content-length: %d",
multipart->boundary, multipart->mime_type, multipart->content_length); multipart->boundary, multipart->mime_type, multipart->content_length);
gst_adapter_unmap (multipart->adapter, 0); gst_adapter_unmap (multipart->adapter);
return next - data; return next - data;
} }
@ -466,7 +466,7 @@ multipart_parse_header (GstMultipartDemux * multipart)
need_more_data: need_more_data:
GST_DEBUG_OBJECT (multipart, "Need more data for the header"); GST_DEBUG_OBJECT (multipart, "Need more data for the header");
gst_adapter_unmap (multipart->adapter, 0); gst_adapter_unmap (multipart->adapter);
return MULTIPART_NEED_MORE_DATA; return MULTIPART_NEED_MORE_DATA;
@ -474,13 +474,13 @@ wrong_header:
{ {
GST_ELEMENT_ERROR (multipart, STREAM, DEMUX, (NULL), GST_ELEMENT_ERROR (multipart, STREAM, DEMUX, (NULL),
("Boundary not found in the multipart header")); ("Boundary not found in the multipart header"));
gst_adapter_unmap (multipart->adapter, 0); gst_adapter_unmap (multipart->adapter);
return MULTIPART_DATA_ERROR; return MULTIPART_DATA_ERROR;
} }
eos: eos:
{ {
GST_DEBUG_OBJECT (multipart, "we are EOS"); GST_DEBUG_OBJECT (multipart, "we are EOS");
gst_adapter_unmap (multipart->adapter, 0); gst_adapter_unmap (multipart->adapter);
return MULTIPART_DATA_EOS; return MULTIPART_DATA_EOS;
} }
} }
@ -506,7 +506,7 @@ multipart_find_boundary (GstMultipartDemux * multipart, gint * datalen)
else if (data[len] == '\n') else if (data[len] == '\n')
len += 1; len += 1;
gst_adapter_unmap (multipart->adapter, 0); gst_adapter_unmap (multipart->adapter);
/* Don't check if boundary is actually there, but let the header parsing /* Don't check if boundary is actually there, but let the header parsing
* bail out if it isn't */ * bail out if it isn't */
return len; return len;
@ -535,12 +535,12 @@ multipart_find_boundary (GstMultipartDemux * multipart, gint * datalen)
len -= 1; len -= 1;
*datalen = len; *datalen = len;
gst_adapter_unmap (multipart->adapter, 0); gst_adapter_unmap (multipart->adapter);
multipart->scanpos = 0; multipart->scanpos = 0;
return pos - data; return pos - data;
} }
} }
gst_adapter_unmap (multipart->adapter, 0); gst_adapter_unmap (multipart->adapter);
multipart->scanpos = pos - data; multipart->scanpos = pos - data;
return MULTIPART_NEED_MORE_DATA; return MULTIPART_NEED_MORE_DATA;
} }

3
gst/rtp/gstrtph263pay.c
View File

@ -1769,7 +1769,8 @@ gst_rtp_h263_pay_flush (GstRtpH263Pay * rtph263pay)
end: end:
gst_rtp_h263_pay_context_destroy (context, gst_rtp_h263_pay_context_destroy (context,
context->piclayer->ptype_srcformat); context->piclayer->ptype_srcformat);
gst_adapter_unmap (rtph263pay->adapter, rtph263pay->available_data); gst_adapter_unmap (rtph263pay->adapter);
gst_adapter_flush (rtph263pay->adapter, rtph263pay->available_data);
return ret; return ret;
} }

2
gst/rtp/gstrtph263ppay.c
View File

@ -678,7 +678,7 @@ gst_rtp_h263p_pay_flush (GstRtpH263PPay * rtph263ppay)
} }
parsed_len++; parsed_len++;
} }
gst_adapter_unmap (rtph263ppay->adapter, 0); gst_adapter_unmap (rtph263ppay->adapter);
} }
/* for picture start frames (non-fragmented), we need to remove the first /* for picture start frames (non-fragmented), we need to remove the first

3
gst/rtp/gstrtph264pay.c
View File

@ -1303,7 +1303,8 @@ gst_rtp_h264_pay_handle_buffer (GstBaseRTPPayload * basepayload,
done: done:
if (bytestream) { if (bytestream) {
gst_adapter_unmap (rtph264pay->adapter, pushed); gst_adapter_unmap (rtph264pay->adapter);
gst_adapter_flush (rtph264pay->adapter, pushed);
} else { } else {
gst_buffer_unmap (buffer, bdata, bsize); gst_buffer_unmap (buffer, bdata, bsize);
gst_buffer_unref (buffer); gst_buffer_unref (buffer);

9
gst/wavparse/gstwavparse.c
View File

@ -1014,7 +1014,7 @@ gst_wavparse_peek_chunk_info (GstWavParse * wav, guint32 * tag, guint32 * size)
data = gst_adapter_map (wav->adapter, 8); data = gst_adapter_map (wav->adapter, 8);
*tag = GST_READ_UINT32_LE (data); *tag = GST_READ_UINT32_LE (data);
*size = GST_READ_UINT32_LE (data + 4); *size = GST_READ_UINT32_LE (data + 4);
gst_adapter_unmap (wav->adapter, 0); gst_adapter_unmap (wav->adapter);
GST_DEBUG ("Next chunk size is %d bytes, type %" GST_FOURCC_FORMAT, *size, GST_DEBUG ("Next chunk size is %d bytes, type %" GST_FOURCC_FORMAT, *size,
GST_FOURCC_ARGS (*tag)); GST_FOURCC_ARGS (*tag));
@ -1357,7 +1357,8 @@ gst_wavparse_stream_headers (GstWavParse * wav)
gst_adapter_flush (wav->adapter, 8); gst_adapter_flush (wav->adapter, 8);
data = gst_adapter_map (wav->adapter, data_size); data = gst_adapter_map (wav->adapter, data_size);
wav->fact = GST_READ_UINT32_LE (data); wav->fact = GST_READ_UINT32_LE (data);
gst_adapter_unmap (wav->adapter, GST_ROUND_UP_2 (size)); gst_adapter_unmap (wav->adapter);
gst_adapter_flush (wav->adapter, GST_ROUND_UP_2 (size));
} else { } else {
gst_buffer_unref (buf); gst_buffer_unref (buf);
if ((res = if ((res =
@ -1402,7 +1403,7 @@ gst_wavparse_stream_headers (GstWavParse * wav)
acid = (const gst_riff_acid *) gst_adapter_map (wav->adapter, acid = (const gst_riff_acid *) gst_adapter_map (wav->adapter,
data_size); data_size);
tempo = acid->tempo; tempo = acid->tempo;
gst_adapter_unmap (wav->adapter, 0); gst_adapter_unmap (wav->adapter);
} else { } else {
gst_buffer_unref (buf); gst_buffer_unref (buf);
if ((res = if ((res =
@ -1441,7 +1442,7 @@ gst_wavparse_stream_headers (GstWavParse * wav)
} }
data = gst_adapter_map (wav->adapter, 12); data = gst_adapter_map (wav->adapter, 12);
ltag = GST_READ_UINT32_LE (data + 8); ltag = GST_READ_UINT32_LE (data + 8);
gst_adapter_unmap (wav->adapter, 0); gst_adapter_unmap (wav->adapter);
} else { } else {
gst_buffer_unref (buf); gst_buffer_unref (buf);
if ((res = if ((res =