From 520514e03c9d7dde9b37284fe9ea75805f0f99c5 Mon Sep 17 00:00:00 2001 From: "Ronald S. Bultje" Date: Sun, 4 Jan 2004 15:23:03 +0000 Subject: [PATCH] gst/matroska/matroska-demux.c: Fix EBML-laced block parsing. Diffs are relative to previous lace, not the first lace.... Original commit message from CVS: 2004-01-04 Ronald Bultje * gst/matroska/matroska-demux.c: Fix EBML-laced block parsing. Diffs are relative to previous lace, not the first lace. Thanks to Mosu from the Matroska team for detecting this. (gst_matroska_demux_parse_blockgroup): * gst/wavparse/gstwavparse.c: (gst_wavparse_init), (gst_wavparse_parse_fmt), (gst_wavparse_getcaps), (gst_wavparse_handle_sink_event), (gst_wavparse_loop), (gst_wavparse_change_state): * gst/wavparse/gstwavparse.h: Quickfix for capsnego. --- ChangeLog | 14 ++++++++++++++ gst/matroska/matroska-demux.c | 2 +- gst/wavparse/gstwavparse.c | 43 ++++++++++++++++++++++++++++++++++++++----- gst/wavparse/gstwavparse.h | 1 + 4 files changed, 54 insertions(+), 6 deletions(-) diff --git a/ChangeLog b/ChangeLog index ea57469..4ae6163 100644 --- a/ChangeLog +++ b/ChangeLog @@ -1,5 +1,19 @@ 2004-01-04 Ronald Bultje + * gst/matroska/matroska-demux.c: + Fix EBML-laced block parsing. Diffs are relative to previous + lace, not the first lace. Thanks to Mosu from the Matroska + team for detecting this. + (gst_matroska_demux_parse_blockgroup): + * gst/wavparse/gstwavparse.c: (gst_wavparse_init), + (gst_wavparse_parse_fmt), (gst_wavparse_getcaps), + (gst_wavparse_handle_sink_event), (gst_wavparse_loop), + (gst_wavparse_change_state): + * gst/wavparse/gstwavparse.h: + Quickfix for capsnego. + +2004-01-04 Ronald Bultje + * gst/wavenc/gstwavenc.c: (set_property), (gst_wavenc_init): Fix indenting, fix pad creation. diff --git a/gst/matroska/matroska-demux.c b/gst/matroska/matroska-demux.c index eb04ebb..1cd3919 100644 --- a/gst/matroska/matroska-demux.c +++ b/gst/matroska/matroska-demux.c @@ -1730,7 +1730,7 @@ gst_matroska_demux_parse_blockgroup (GstMatroskaDemux *demux, break; } data += r; size -= r; - lace_size[n] = lace_size[0] + snum; + lace_size[n] = lace_size[n - 1] + snum; total += lace_size[n]; } lace_size[n] = size - total; diff --git a/gst/wavparse/gstwavparse.c b/gst/wavparse/gstwavparse.c index d256455..1635508 100644 --- a/gst/wavparse/gstwavparse.c +++ b/gst/wavparse/gstwavparse.c @@ -47,6 +47,7 @@ static gboolean gst_wavparse_pad_convert (GstPad *pad, gint64 *dest_value); static void gst_wavparse_loop (GstElement *element); +static GstCaps * gst_wavparse_getcaps (GstPad *pad); static const GstEventMask* gst_wavparse_get_event_masks (GstPad *pad); static gboolean gst_wavparse_srcpad_event (GstPad *pad, GstEvent *event); @@ -202,7 +203,8 @@ gst_wavparse_init (GstWavParse *wavparse) gst_pad_set_query_function (wavparse->srcpad, gst_wavparse_pad_query); gst_pad_set_event_function (wavparse->srcpad, gst_wavparse_srcpad_event); gst_pad_set_event_mask_function (wavparse->srcpad, gst_wavparse_get_event_masks); - gst_pad_use_explicit_caps (wavparse->srcpad); + gst_pad_set_getcaps_function (wavparse->srcpad, gst_wavparse_getcaps); + wavparse->caps = NULL; gst_element_set_loop_function (GST_ELEMENT (wavparse), gst_wavparse_loop); @@ -661,14 +663,31 @@ gst_wavparse_parse_fmt (GstWavParse *wavparse) gst_element_error (GST_ELEMENT (wavparse), "wavparse: format %d not handled", wavparse->format); return; } - - gst_pad_set_explicit_caps (wavparse->srcpad, caps); + + if (wavparse->caps) + gst_caps_free (wavparse->caps); + wavparse->caps = caps ? gst_caps_copy (caps) : gst_caps_new_empty (); + if (caps) + gst_pad_try_set_caps (wavparse->srcpad, caps); GST_DEBUG ("frequency %d, channels %d", wavparse->rate, wavparse->channels); } } +static GstCaps * +gst_wavparse_getcaps (GstPad *pad) +{ + GstWavParse *wavparse = GST_WAVPARSE (gst_pad_get_parent (pad)); + GstPadTemplate *templ; + + if (wavparse->caps) + return gst_caps_copy (wavparse->caps); + + templ = gst_static_pad_template_get (&src_template_factory); + return gst_caps_copy (gst_pad_template_get_caps (templ)); +} + static gboolean gst_wavparse_handle_sink_event (GstWavParse *wavparse) { @@ -678,12 +697,14 @@ gst_wavparse_handle_sink_event (GstWavParse *wavparse) gboolean res = TRUE; gst_bytestream_get_status (wavparse->bs, &remaining, &event); +g_print ("Handle sink event\n"); type = event ? GST_EVENT_TYPE (event) : GST_EVENT_UNKNOWN; GST_DEBUG ("wavparse: event %p %d", event, type); switch (type) { case GST_EVENT_EOS: +g_print ("EOS\n"); gst_bytestream_flush (wavparse->bs, remaining); gst_pad_event_default (wavparse->sinkpad, event); res = FALSE; @@ -744,7 +765,16 @@ gst_wavparse_loop (GstElement *element) desired = MIN (wavparse->dataleft, MAX_BUFFER_SIZE); got_bytes = gst_bytestream_peek (bs, &buf, desired); - if (got_bytes == 0) { + if (got_bytes != desired) { + /* EOS? */ + GstEvent *event; + guint32 remaining; + gst_bytestream_get_status (bs, &remaining, &event); + if (event && GST_EVENT_TYPE (event) == GST_EVENT_EOS) { + gst_pad_event_default (wavparse->sinkpad, event); + } else { + gst_element_error (element, "Read failure"); + } return; } @@ -1088,7 +1118,10 @@ gst_wavparse_change_state (GstElement *element) wavparse->bps = 0; wavparse->seek_pending = FALSE; wavparse->seek_offset = 0; - + if (wavparse->caps) { + gst_caps_free (wavparse->caps); + wavparse->caps = NULL; + } break; case GST_STATE_READY_TO_NULL: break; diff --git a/gst/wavparse/gstwavparse.h b/gst/wavparse/gstwavparse.h index 3893a29..802ecee 100644 --- a/gst/wavparse/gstwavparse.h +++ b/gst/wavparse/gstwavparse.h @@ -57,6 +57,7 @@ struct _GstWavParse { GstByteStream *bs; /* pads */ GstPad *sinkpad,*srcpad; + GstCaps *caps; /* WAVE decoding state */ gint state; -- 2.7.4