diff options
| -rw-r--r-- | gst/avi/gstavidemux.c | 404 |
1 files changed, 0 insertions, 404 deletions
diff --git a/gst/avi/gstavidemux.c b/gst/avi/gstavidemux.c index 42d5ce5d1..3233c5bd3 100644 --- a/gst/avi/gstavidemux.c +++ b/gst/avi/gstavidemux.c @@ -2235,195 +2235,12 @@ out_of_mem: (guint) sizeof (GstAviIndexEntry), num, (guint) sizeof (GstAviIndexEntry) * num)); return; } } -#if 0 -/* - * gst_avi_demux_parse_index: - * @avi: calling element (used for debugging/errors). - * @buf: buffer containing the full index. - * @entries_list: list (returned by this function) containing the index - * entries parsed from the buffer. The first in the list - * is also a pointer to the allocated data and should be - * free'ed at some point. - * - * Read index entries from the provided buffer. Takes ownership of @buf. - * The buffer should contain a GST_RIFF_TAG_idx1 chunk. - */ -static void -gst_avi_demux_parse_index (GstAviDemux * avi, - GstBuffer * buf, GList ** _entries_list) -{ - guint64 pos_before = avi->offset; - gst_avi_index_entry *entries = NULL; - guint8 *data; - GList *entries_list = NULL; - guint i, num, n; -#ifndef GST_DISABLE_GST_DEBUG - gulong _nr_keyframes = 0; -#endif - GstClockTime stamp; - - if (!buf || !GST_BUFFER_SIZE (buf)) { - *_entries_list = NULL; - GST_DEBUG ("empty index"); - if (buf) - gst_buffer_unref (buf); - return; - } - - stamp = gst_util_get_timestamp (); - - data = GST_BUFFER_DATA (buf); - num = GST_BUFFER_SIZE (buf) / sizeof (gst_riff_index_entry); - if (!(entries = g_try_new (gst_avi_index_entry, num))) - goto out_of_mem; - - GST_INFO_OBJECT (avi, "Parsing index, nr_entries = %6d", num); - - for (i = 0, n = 0; i < num; i++) { - gint64 next_ts; - gst_riff_index_entry entry, *_entry; - GstAviStream *stream; - guint stream_nr; - gst_avi_index_entry *target; - - _entry = &((gst_riff_index_entry *) data)[i]; - entry.id = GST_READ_UINT32_LE (&_entry->id); - entry.offset = GST_READ_UINT32_LE (&_entry->offset); - entry.flags = GST_READ_UINT32_LE (&_entry->flags); - entry.size = GST_READ_UINT32_LE (&_entry->size); - target = &entries[n]; - - if (entry.id == GST_RIFF_rec || entry.id == 0 || - (entry.offset == 0 && n > 0)) - continue; - - stream_nr = CHUNKID_TO_STREAMNR (entry.id); - if (stream_nr >= avi->num_streams) { - GST_WARNING_OBJECT (avi, - "Index entry %d has invalid stream nr %d", i, stream_nr); - continue; - } - target->stream_nr = stream_nr; - stream = &avi->stream[stream_nr]; - - if (!stream->strh) { - GST_WARNING_OBJECT (avi, "Unhandled stream %d, skipping", stream_nr); - continue; - } - - target->index_nr = i; - target->flags = - (entry.flags & GST_RIFF_IF_KEYFRAME) ? GST_AVI_INDEX_ENTRY_FLAG_KEYFRAME - : 0; - target->size = entry.size; - target->offset = entry.offset + 8; - - /* figure out if the index is 0 based or relative to the MOVI start */ - if (n == 0) { - if (target->offset < pos_before) - avi->index_offset = pos_before + 8; - else - avi->index_offset = 0; - GST_DEBUG ("index_offset = %" G_GUINT64_FORMAT, avi->index_offset); - } - - if (stream->strh->type == GST_RIFF_FCC_auds) { - /* all audio frames are keyframes */ - target->flags |= GST_AVI_INDEX_ENTRY_FLAG_KEYFRAME; - } -#ifndef GST_DISABLE_GST_DEBUG - if (target->flags & GST_AVI_INDEX_ENTRY_FLAG_KEYFRAME) - _nr_keyframes++; -#endif - - /* stream duration unknown, now we can calculate it */ - if (stream->idx_duration == -1) - stream->idx_duration = 0; - - /* timestamps */ - target->ts = stream->idx_duration; - if (stream->is_vbr) { - /* VBR stream next timestamp */ - if (stream->strh->type == GST_RIFF_FCC_auds) { - next_ts = avi_stream_convert_frames_to_time_unchecked (stream, - stream->total_blocks + 1); - } else { - next_ts = avi_stream_convert_frames_to_time_unchecked (stream, - stream->idx_n + 1); - } - } else { - /* constant rate stream */ - next_ts = avi_stream_convert_bytes_to_time_unchecked (stream, - stream->total_bytes + target->size); - } - /* duration is next - current */ - target->dur = next_ts - target->ts; - - /* stream position */ - target->bytes_before = stream->total_bytes; - target->frames_before = stream->idx_n; - - stream->total_bytes += target->size; - stream->idx_n++; - if (stream->strh->type == GST_RIFF_FCC_auds) { - if (stream->strf.auds->blockalign > 0) - stream->total_blocks += - (target->size + stream->strf.auds->blockalign - - 1) / stream->strf.auds->blockalign; - else - stream->total_blocks++; - } - stream->idx_duration = next_ts; - - GST_LOG_OBJECT (avi, - "Adding index entry %d (%6u), flags %02x, stream %d, size %u " - ", offset %" G_GUINT64_FORMAT ", time %" GST_TIME_FORMAT ", dur %" - GST_TIME_FORMAT, - target->index_nr, stream->idx_n - 1, target->flags, - target->stream_nr, target->size, target->offset, - GST_TIME_ARGS (target->ts), GST_TIME_ARGS (target->dur)); - entries_list = g_list_prepend (entries_list, target); - - n++; - } - - GST_INFO_OBJECT (avi, "Parsed index, %6u/%6u entries, %5lu keyframes, " - "entry size = %2u, total size = %10u", n, num, _nr_keyframes, - (guint) sizeof (gst_avi_index_entry), - (guint) (n * sizeof (gst_avi_index_entry))); - - gst_buffer_unref (buf); - - if (n > 0) { - *_entries_list = g_list_reverse (entries_list); - } else { - g_free (entries); - } - - stamp = gst_util_get_timestamp () - stamp; - GST_CAT_DEBUG (GST_CAT_PERFORMANCE, "parsing index %" GST_TIME_FORMAT, - GST_TIME_ARGS (stamp)); - - return; - - /* ERRORS */ -out_of_mem: - { - GST_ELEMENT_ERROR (avi, RESOURCE, NO_SPACE_LEFT, (NULL), - ("Cannot allocate memory for %u*%u=%u bytes", - (guint) sizeof (gst_avi_index_entry), num, - (guint) sizeof (gst_avi_index_entry) * num)); - gst_buffer_unref (buf); - } -} -#endif - /* * gst_avi_demux_stream_index: * @avi: avi demuxer object. * * Seeks to index and reads it. */ @@ -4238,224 +4055,12 @@ gst_avi_demux_combine_flows (GstAviDemux * avi, GstAviStream * stream, * NOT_LINKED then */ done: GST_LOG_OBJECT (avi, "combined return %s", gst_flow_get_name (ret)); return ret; } -#if 0 -/* - * Read data from one index entry - */ -static GstFlowReturn -gst_avi_demux_process_next_entry (GstAviDemux * avi) -{ - GstFlowReturn res = GST_FLOW_OK; - gboolean processed = FALSE; - GstAviStream *stream; - gst_avi_index_entry *entry; - GstBuffer *buf; - - do { - /* see if we are at the end */ - if ((avi->segment.rate > 0 && avi->current_entry >= avi->index_size)) - goto eos; - - /* get next entry, this will work as we checked for the index size above */ - entry = &avi->index_entries[avi->current_entry++]; - - /* check for reverse playback */ - if (avi->segment.rate < 0 && avi->current_entry > avi->reverse_stop_index) { - GST_LOG_OBJECT (avi, "stop_index %d reached", avi->reverse_stop_index); - - /* check if we have pushed enough data for this segment */ - if (avi->reverse_start_index == 0) - goto eos_reverse_zero; - if (avi->index_entries[avi->reverse_start_index].ts < avi->segment.start) - goto eos_reverse_segment; - - if (!(entry = gst_avi_demux_step_reverse (avi))) - goto eos; - - avi->current_entry++; - } - - /* see if we have a valid stream, ignore if not - * FIXME: can't we check this when building the index? - * we check it in _parse_index(), _stream_scan() - */ - if (entry->stream_nr >= avi->num_streams) { - GST_WARNING_OBJECT (avi, - "Entry %d has non-existing stream nr %d", - avi->current_entry - 1, entry->stream_nr); - continue; - } - - /* get stream now */ - stream = &avi->stream[entry->stream_nr]; - - if (avi->segment.rate > 0.0) { - /* only check this for fowards playback for now */ - if ((entry->flags & GST_AVI_INDEX_ENTRY_FLAG_KEYFRAME) - && GST_CLOCK_TIME_IS_VALID (entry->ts) - && GST_CLOCK_TIME_IS_VALID (avi->segment.stop) - && (entry->ts > avi->segment.stop)) { - goto eos_stop; - } - } - - /* skip empty entries */ - if (entry->size == 0 || !stream->pad) { - GST_DEBUG_OBJECT (avi, "Skipping entry %d (%d, %p)", - avi->current_entry - 1, entry->size, stream->pad); - goto next; - } - - GST_LOG ("reading buffer (size=%d) from stream %d at current pos %" - G_GUINT64_FORMAT " (%llx)", entry->size, entry->stream_nr, - avi->index_offset + entry->offset, avi->index_offset + entry->offset); - - /* pull in the data */ - res = gst_pad_pull_range (avi->sinkpad, entry->offset + - avi->index_offset, entry->size, &buf); - if (res != GST_FLOW_OK) - goto pull_failed; - - /* check for short buffers, this is EOS as well */ - if (GST_BUFFER_SIZE (buf) < entry->size) - goto short_buffer; - - /* invert the picture if needed */ - buf = gst_avi_demux_invert (stream, buf); - - /* mark non-keyframes */ - if (!(entry->flags & GST_AVI_INDEX_ENTRY_FLAG_KEYFRAME)) - GST_BUFFER_FLAG_SET (buf, GST_BUFFER_FLAG_DELTA_UNIT); - - GST_BUFFER_TIMESTAMP (buf) = entry->ts; - GST_BUFFER_DURATION (buf) = entry->dur; - if (stream->strh->type == GST_RIFF_FCC_vids) { - if (stream->current_frame >= 0) - GST_BUFFER_OFFSET (buf) = stream->current_frame; - else { - gint64 framenum; - GstFormat fmt = GST_FORMAT_DEFAULT; - - if (gst_pad_query_convert (stream->pad, GST_FORMAT_TIME, entry->ts, - &fmt, &framenum)) - GST_BUFFER_OFFSET (buf) = framenum; - else - GST_BUFFER_OFFSET (buf) = GST_BUFFER_OFFSET_NONE; - } - } else - GST_BUFFER_OFFSET (buf) = GST_BUFFER_OFFSET_NONE; - GST_BUFFER_OFFSET_END (buf) = GST_BUFFER_OFFSET_NONE; - gst_buffer_set_caps (buf, GST_PAD_CAPS (stream->pad)); - - GST_DEBUG_OBJECT (avi, "Pushing buffer of size %d, offset %" - G_GUINT64_FORMAT " and time %" - GST_TIME_FORMAT " on pad %s", - GST_BUFFER_SIZE (buf), GST_BUFFER_OFFSET (buf), - GST_TIME_ARGS (entry->ts), GST_PAD_NAME (stream->pad)); - - /* update current position in the segment */ - gst_segment_set_last_stop (&avi->segment, GST_FORMAT_TIME, entry->ts); - - /* mark discont when pending */ - if (stream->discont) { - GST_BUFFER_FLAG_SET (buf, GST_BUFFER_FLAG_DISCONT); - stream->discont = FALSE; - } - - res = gst_pad_push (stream->pad, buf); - - /* mark as processed, we increment the frame and byte counters then - * leave the while loop and return the GstFlowReturn */ - processed = TRUE; - GST_DEBUG_OBJECT (avi, "Processed buffer %d: %s", entry->index_nr, - gst_flow_get_name (res)); - - if (avi->segment.rate < 0 - && entry->ts > avi->segment.stop && res == GST_FLOW_UNEXPECTED) { - /* In reverse playback we can get a GST_FLOW_UNEXPECTED when - * we are at the end of the segment, so we just need to jump - * back to the previous section. - */ - GST_DEBUG_OBJECT (avi, "downstream has reached end of segment"); - - if (!(entry = gst_avi_demux_step_reverse (avi))) - goto eos; - - res = GST_FLOW_OK; - - stream->current_frame = entry->frames_before; - stream->current_byte = entry->bytes_before; - - continue; - } - - /* combine flows */ - res = gst_avi_demux_combine_flows (avi, stream, res); - - next: - stream->current_frame = entry->frames_before + 1; - stream->current_byte = entry->bytes_before + entry->size; - } while (!processed); - -beach: - GST_DEBUG_OBJECT (avi, "returning %s", gst_flow_get_name (res)); - - return res; - - /* ERRORS */ -eos: - { - GST_LOG_OBJECT (avi, "Handled last index entry, setting EOS (%d > %d)", - avi->current_entry, avi->index_size); - /* we mark the first stream as EOS */ - res = GST_FLOW_UNEXPECTED; - goto beach; - } -eos_stop: - { - GST_LOG_OBJECT (avi, "Found keyframe after segment," - " setting EOS (%" GST_TIME_FORMAT " > %" GST_TIME_FORMAT ")", - GST_TIME_ARGS (entry->ts), GST_TIME_ARGS (avi->segment.stop)); - res = GST_FLOW_UNEXPECTED; - goto beach; - } -eos_reverse_zero: - { - GST_DEBUG_OBJECT (avi, "start_index was 0, setting EOS"); - res = GST_FLOW_UNEXPECTED; - goto beach; - } -eos_reverse_segment: - { - GST_DEBUG_OBJECT (avi, "full segment pushed, setting EOS"); - res = GST_FLOW_UNEXPECTED; - goto beach; - } -pull_failed: - { - GST_DEBUG_OBJECT (avi, - "pull range failed: pos=%" G_GUINT64_FORMAT " size=%d", - entry->offset + avi->index_offset, entry->size); - goto beach; - } -short_buffer: - { - GST_WARNING_OBJECT (avi, "Short read at offset %" G_GUINT64_FORMAT - ", only got %d/%d bytes (truncated file?)", entry->offset + - avi->index_offset, GST_BUFFER_SIZE (buf), entry->size); - gst_buffer_unref (buf); - res = GST_FLOW_UNEXPECTED; - goto beach; - } -} -#endif - /* move @stream to the next position in its index */ static GstFlowReturn gst_avi_demux_advance (GstAviDemux * avi, GstAviStream * stream, GstFlowReturn ret) { guint old_entry, new_entry; @@ -4702,21 +4307,12 @@ short_buffer: ", only got %d/%d bytes (truncated file?)", offset, GST_BUFFER_SIZE (buf), size); gst_buffer_unref (buf); ret = GST_FLOW_UNEXPECTED; goto beach; } -#if 0 -eos_stream: - { - GST_DEBUG_OBJECT (avi, "No samples left for stream"); - /* EOS will be raised if all are EOS */ - ret = GST_FLOW_OK; - goto beach; - } -#endif } /* * Read data. If we have an index it delegates to * gst_avi_demux_process_next_entry(). */ |