diff options
author | Sebastian Dröge <slomo@circular-chaos.org> | 2008-08-03 12:23:49 +0000 |
---|---|---|
committer | Sebastian Dröge <slomo@circular-chaos.org> | 2008-08-03 12:23:49 +0000 |
commit | df707c666433a78d3878af6f055698d5756226c4 (patch) | |
tree | d29cafc62ce2e471fd8e52c0452fde3dadc273f7 | |
parent | e3e4257ac93a5a7926650ed9898b547ba19a3fd3 (diff) |
ext/flac/gstflacenc.c: Set an estimate for the total number of samples that will be encoded if possible to help decod...
Original commit message from CVS:
* ext/flac/gstflacenc.c: (gst_flac_enc_query_peer_total_samples),
(gst_flac_enc_sink_setcaps), (gst_flac_enc_write_callback):
Set an estimate for the total number of samples that will be encoded
if possible to help decoders if the streaminfo can't be rewritten
later (like when muxing into Ogg containers).
Add a warning if we get header packets after data packets as those
will get lost when muxing into Ogg, i.e. rewriting the headers doesn't
work.
-rw-r--r-- | ChangeLog | 12 | ||||
-rw-r--r-- | ext/flac/gstflacenc.c | 42 |
2 files changed, 54 insertions, 0 deletions
@@ -1,5 +1,17 @@ 2008-08-03 Sebastian Dröge <sebastian.droege@collabora.co.uk> + * ext/flac/gstflacenc.c: (gst_flac_enc_query_peer_total_samples), + (gst_flac_enc_sink_setcaps), (gst_flac_enc_write_callback): + Set an estimate for the total number of samples that will be encoded + if possible to help decoders if the streaminfo can't be rewritten + later (like when muxing into Ogg containers). + + Add a warning if we get header packets after data packets as those + will get lost when muxing into Ogg, i.e. rewriting the headers doesn't + work. + +2008-08-03 Sebastian Dröge <sebastian.droege@collabora.co.uk> + * ext/flac/gstflacdec.c: (gst_flac_dec_metadata_callback), (gst_flac_dec_write): Support decoding of all depths between 4 and 32 bits and read the diff --git a/ext/flac/gstflacenc.c b/ext/flac/gstflacenc.c index 475d7a67..1a2a34b6 100644 --- a/ext/flac/gstflacenc.c +++ b/ext/flac/gstflacenc.c @@ -554,11 +554,41 @@ gst_flac_enc_sink_getcaps (GstPad * pad) return ret; } +static guint64 +gst_flac_enc_query_peer_total_samples (GstFlacEnc * flacenc, GstPad * pad) +{ + GstFormat fmt = GST_FORMAT_DEFAULT; + gint64 duration; + + if (gst_pad_query_peer_duration (pad, &fmt, &duration) + && fmt == GST_FORMAT_DEFAULT && duration != GST_CLOCK_TIME_NONE) + goto done; + + fmt = GST_FORMAT_TIME; + + if (gst_pad_query_peer_duration (pad, &fmt, &duration) && + fmt == GST_FORMAT_TIME && duration != GST_CLOCK_TIME_NONE) { + duration = GST_FRAMES_TO_CLOCK_TIME (duration, flacenc->sample_rate); + + goto done; + } + + GST_DEBUG_OBJECT (flacenc, "Upstream reported no total samples"); + return GST_CLOCK_TIME_NONE; + +done: + GST_DEBUG_OBJECT (flacenc, + "Upstream reported %" G_GUINT64_FORMAT " total samples", duration); + + return duration; +} + static gboolean gst_flac_enc_sink_setcaps (GstPad * pad, GstCaps * caps) { GstFlacEnc *flacenc; GstStructure *structure; + guint64 total_samples = GST_CLOCK_TIME_NONE; #ifdef LEGACY_FLAC FLAC__SeekableStreamEncoderState state; @@ -603,6 +633,8 @@ gst_flac_enc_sink_setcaps (GstPad * pad, GstCaps * caps) gst_caps_unref (caps); + total_samples = gst_flac_enc_query_peer_total_samples (flacenc, pad); + #ifdef LEGACY_FLAC FLAC__seekable_stream_encoder_set_bits_per_sample (flacenc->encoder, flacenc->depth); @@ -611,6 +643,10 @@ gst_flac_enc_sink_setcaps (GstPad * pad, GstCaps * caps) FLAC__seekable_stream_encoder_set_channels (flacenc->encoder, flacenc->channels); + if (total_samples != GST_CLOCK_TIME_NONE) + FLAC__seekable_stream_encoder_set_total_samples_estimate (flacenc->encoder, + total_samples); + FLAC__seekable_stream_encoder_set_write_callback (flacenc->encoder, gst_flac_enc_write_callback); FLAC__seekable_stream_encoder_set_seek_callback (flacenc->encoder, @@ -623,6 +659,10 @@ gst_flac_enc_sink_setcaps (GstPad * pad, GstCaps * caps) FLAC__stream_encoder_set_bits_per_sample (flacenc->encoder, flacenc->depth); FLAC__stream_encoder_set_sample_rate (flacenc->encoder, flacenc->sample_rate); FLAC__stream_encoder_set_channels (flacenc->encoder, flacenc->channels); + + if (total_samples != GST_CLOCK_TIME_NONE) + FLAC__stream_encoder_set_total_samples_estimate (flacenc->encoder, + total_samples); #endif gst_flac_enc_set_metadata (flacenc); @@ -952,6 +992,8 @@ gst_flac_enc_write_callback (const FLAC__StreamEncoder * encoder, gst_flac_enc_process_stream_headers (flacenc); flacenc->got_headers = TRUE; } + } else if (flacenc->got_headers && samples == 0) { + GST_WARNING_OBJECT (flacenc, "Got header packet after data packets"); } GST_LOG ("Pushing buffer: ts=%" GST_TIME_FORMAT ", samples=%u, size=%u, " |