mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-27 12:11:13 +00:00
Code Issues 1 Projects Releases Wiki Activity

gst/qtdemux/qtdemux.*: Some QT demux loving.

Browse source 
Original commit message from CVS:
* gst/qtdemux/qtdemux.c: (gst_qtdemux_handle_src_query),
(gst_qtdemux_handle_src_event), (gst_qtdemux_loop_header),
(qtdemux_inflate), (qtdemux_parse), (qtdemux_parse_trak),
(qtdemux_parse_udta), (qtdemux_tag_add_str), (qtdemux_tag_add_num),
(qtdemux_tag_add_gnre), (gst_qtdemux_handle_esds),
(qtdemux_video_caps), (qtdemux_audio_caps):
* gst/qtdemux/qtdemux.h:
Some QT demux loving.
Handle seeking in a less broken way.
Fix AMR caps to match the AMR decoder.
Set first timestamp on AMR samples to 0 for now.
Remove some \n in DEBUG strings.
Use _scale_int for maximum precision.
This commit is contained in:
Wim Taymans 2006-02-06 15:41:25 +00:00
parent 5118effe7a
commit 2651b40adf
2 changed files with 82 additions and 57 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

128
gst/qtdemux/qtdemux.c
View file

@ -317,8 +317,12 @@ gst_qtdemux_handle_src_query (GstPad * pad, GstQuery * query)
break; break;
case GST_QUERY_DURATION: case GST_QUERY_DURATION:
if (qtdemux->duration != 0 && qtdemux->timescale != 0) { if (qtdemux->duration != 0 && qtdemux->timescale != 0) {
gst_query_set_duration (query, GST_FORMAT_TIME, gint64 duration;
(guint64) qtdemux->duration * GST_SECOND / qtdemux->timescale);
duration = gst_util_uint64_scale_int (qtdemux->duration,
GST_SECOND, qtdemux->timescale);
gst_query_set_duration (query, GST_FORMAT_TIME, duration);
res = TRUE; res = TRUE;
} }
break; break;
@ -327,6 +331,8 @@ gst_qtdemux_handle_src_query (GstPad * pad, GstQuery * query)
break; break;
} }
gst_object_unref (qtdemux);
return res; return res;
} }
@ -358,6 +364,7 @@ gst_qtdemux_handle_src_event (GstPad * pad, GstEvent * event)
GstSeekFlags flags; GstSeekFlags flags;
gint64 desired_offset; gint64 desired_offset;
/* FIXME do seeking correctly */
gst_event_parse_seek (event, NULL, &format, &flags, NULL, gst_event_parse_seek (event, NULL, &format, &flags, NULL,
&desired_offset, NULL, NULL); &desired_offset, NULL, NULL);
GST_DEBUG ("seek format %d", format); GST_DEBUG ("seek format %d", format);
@ -374,11 +381,14 @@ gst_qtdemux_handle_src_event (GstPad * pad, GstEvent * event)
break; break;
} }
/* unlock upstream pull_range */
gst_pad_push_event (qtdemux->sinkpad, gst_event_new_flush_start ()); gst_pad_push_event (qtdemux->sinkpad, gst_event_new_flush_start ());
GST_PAD_STREAM_LOCK (pad); /* make sure out loop function exits */
gst_qtdemux_send_event (qtdemux, gst_event_new_flush_start ()); gst_qtdemux_send_event (qtdemux, gst_event_new_flush_start ());
/* wait for streaming to finish */
GST_PAD_STREAM_LOCK (qtdemux->sinkpad);
/* resync to new time */ /* resync to new time */
for (n = 0; n < qtdemux->n_streams; n++) { for (n = 0; n < qtdemux->n_streams; n++) {
QtDemuxStream *str = qtdemux->streams[n]; QtDemuxStream *str = qtdemux->streams[n];
@ -394,6 +404,7 @@ gst_qtdemux_handle_src_event (GstPad * pad, GstEvent * event)
} }
str->sample_index = i; str->sample_index = i;
} }
/* prepare for streaming again */
gst_pad_push_event (qtdemux->sinkpad, gst_event_new_flush_stop ()); gst_pad_push_event (qtdemux->sinkpad, gst_event_new_flush_stop ());
gst_qtdemux_send_event (qtdemux, gst_event_new_flush_stop ()); gst_qtdemux_send_event (qtdemux, gst_event_new_flush_stop ());
@ -405,7 +416,7 @@ gst_qtdemux_handle_src_event (GstPad * pad, GstEvent * event)
gst_pad_start_task (qtdemux->sinkpad, gst_pad_start_task (qtdemux->sinkpad,
(GstTaskFunction) gst_qtdemux_loop_header, qtdemux->sinkpad); (GstTaskFunction) gst_qtdemux_loop_header, qtdemux->sinkpad);
GST_PAD_STREAM_UNLOCK (pad); GST_PAD_STREAM_UNLOCK (qtdemux->sinkpad);
break; break;
} }
default: default:
@ -419,6 +430,8 @@ gst_qtdemux_handle_src_event (GstPad * pad, GstEvent * event)
break; break;
} }
gst_object_unref (qtdemux);
gst_event_unref (event); gst_event_unref (event);
return res; return res;
@ -442,6 +455,7 @@ GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
plugin_init, VERSION, "LGPL", GST_PACKAGE, GST_ORIGIN); plugin_init, VERSION, "LGPL", GST_PACKAGE, GST_ORIGIN);
#if 0 #if 0
/* not needed, we don't work in streaming mode yet */
static gboolean static gboolean
gst_qtdemux_handle_sink_event (GstQTDemux * qtdemux) gst_qtdemux_handle_sink_event (GstQTDemux * qtdemux)
{ {
@ -529,8 +543,8 @@ gst_qtdemux_loop_header (GstPad * pad)
switch (qtdemux->state) { switch (qtdemux->state) {
case QTDEMUX_STATE_HEADER:{ case QTDEMUX_STATE_HEADER:{
if (gst_pad_pull_range (qtdemux->sinkpad, ret = gst_pad_pull_range (qtdemux->sinkpad, cur_offset, 16, &buf);
cur_offset, 16, &buf) != GST_FLOW_OK) if (ret != GST_FLOW_OK)
goto error; goto error;
data = GST_BUFFER_DATA (buf); data = GST_BUFFER_DATA (buf);
length = GST_READ_UINT32_BE (data); length = GST_READ_UINT32_BE (data);
@ -567,8 +581,9 @@ gst_qtdemux_loop_header (GstPad * pad)
case GST_MAKE_FOURCC ('m', 'o', 'o', 'v'):{ case GST_MAKE_FOURCC ('m', 'o', 'o', 'v'):{
GstBuffer *moov; GstBuffer *moov;
if (gst_pad_pull_range (qtdemux->sinkpad, cur_offset, length, ret =
&moov) != GST_FLOW_OK) gst_pad_pull_range (qtdemux->sinkpad, cur_offset, length, &moov);
if (ret != GST_FLOW_OK)
goto error; goto error;
cur_offset += length; cur_offset += length;
qtdemux->offset += length; qtdemux->offset += length;
@ -638,7 +653,7 @@ gst_qtdemux_loop_header (GstPad * pad)
size = stream->samples[stream->sample_index].size; size = stream->samples[stream->sample_index].size;
GST_INFO GST_INFO
("pushing from stream %d, sample_index=%d offset=%d size=%d timestamp=%lld", ("pushing from stream %d, sample_index=%d offset=%lld size=%d timestamp=%lld",
index, stream->sample_index, offset, size, index, stream->sample_index, offset, size,
stream->samples[stream->sample_index].timestamp); stream->samples[stream->sample_index].timestamp);
@ -646,8 +661,8 @@ gst_qtdemux_loop_header (GstPad * pad)
if (size > 0) { if (size > 0) {
GST_LOG_OBJECT (qtdemux, "reading %d bytes @ %lld", size, offset); GST_LOG_OBJECT (qtdemux, "reading %d bytes @ %lld", size, offset);
if (gst_pad_pull_range (qtdemux->sinkpad, offset, ret = gst_pad_pull_range (qtdemux->sinkpad, offset, size, &buf);
size, &buf) != GST_FLOW_OK) if (ret != GST_FLOW_OK)
goto error; goto error;
} }
@ -679,9 +694,13 @@ gst_qtdemux_loop_header (GstPad * pad)
GST_BUFFER_TIMESTAMP (buf) = GST_BUFFER_TIMESTAMP (buf) =
stream->samples[stream->sample_index].timestamp; stream->samples[stream->sample_index].timestamp;
qtdemux->last_ts = GST_BUFFER_TIMESTAMP (buf); qtdemux->last_ts = GST_BUFFER_TIMESTAMP (buf);
GST_BUFFER_DURATION (buf) = GST_BUFFER_DURATION (buf) = gst_util_uint64_scale_int
GST_SECOND * stream->samples[stream->sample_index].duration (stream->samples[stream->sample_index].duration, GST_SECOND,
/ stream->timescale; stream->timescale);
} else {
if (stream->sample_index == 0) {
GST_BUFFER_TIMESTAMP (buf) = 0;
}
} }
GST_DEBUG ("Pushing buffer with time %" GST_TIME_FORMAT " on pad %p", GST_DEBUG ("Pushing buffer with time %" GST_TIME_FORMAT " on pad %p",
@ -702,10 +721,17 @@ gst_qtdemux_loop_header (GstPad * pad)
return; return;
error: error:
GST_LOG_OBJECT (qtdemux, "pausing task and sending EOS"); {
gst_pad_pause_task (qtdemux->sinkpad); GST_LOG_OBJECT (qtdemux, "pausing task, reason %s",
gst_pad_event_default (qtdemux->sinkpad, gst_event_new_eos ()); gst_flow_get_name (ret));
return; gst_pad_pause_task (qtdemux->sinkpad);
if (GST_FLOW_IS_FATAL (ret)) {
gst_pad_event_default (qtdemux->sinkpad, gst_event_new_eos ());
GST_ELEMENT_ERROR (qtdemux, STREAM, FAILED,
(NULL), ("stream stopped, reason %s", gst_flow_get_name (ret)));
}
return;
}
} }
static gboolean static gboolean
@ -1022,7 +1048,7 @@ qtdemux_inflate (void *z_buffer, int z_length, int length)
break; break;
} }
if (ret != Z_STREAM_END) { if (ret != Z_STREAM_END) {
g_warning ("inflate() returned %d\n", ret); g_warning ("inflate() returned %d", ret);
} }
g_free (z); g_free (z);
@ -1192,9 +1218,9 @@ qtdemux_parse (GstQTDemux * qtdemux, GNode * node, void *buffer, int length)
guint32 version; guint32 version;
int tlen; int tlen;
GST_DEBUG ("parsing in mp4v\n"); GST_DEBUG ("parsing in mp4v");
version = QTDEMUX_GUINT32_GET (buffer + 16); version = QTDEMUX_GUINT32_GET (buffer + 16);
GST_DEBUG ("version %08x\n", version); GST_DEBUG ("version %08x", version);
if (1 || version == 0x00000000) { if (1 || version == 0x00000000) {
buf = buffer + 0x32; buf = buffer + 0x32;
@ -1204,9 +1230,9 @@ qtdemux_parse (GstQTDemux * qtdemux, GNode * node, void *buffer, int length)
* the iso format uses C strings. Check the file * the iso format uses C strings. Check the file
* type before attempting to parse the string here. */ * type before attempting to parse the string here. */
tlen = QTDEMUX_GUINT8_GET (buf); tlen = QTDEMUX_GUINT8_GET (buf);
GST_DEBUG ("tlen = %d\n", tlen); GST_DEBUG ("tlen = %d", tlen);
buf++; buf++;
GST_DEBUG ("string = %.*s\n", tlen, (char *) buf); GST_DEBUG ("string = %.*s", tlen, (char *) buf);
/* the string has a reserved space of 32 bytes so skip /* the string has a reserved space of 32 bytes so skip
* the remaining 31 */ * the remaining 31 */
buf += 31; buf += 31;
@ -1274,20 +1300,20 @@ qtdemux_parse (GstQTDemux * qtdemux, GNode * node, void *buffer, int length)
guint32 version; guint32 version;
int tlen; int tlen;
GST_LOG ("parsing in SVQ3\n"); GST_LOG ("parsing in SVQ3");
buf = buffer + 12; buf = buffer + 12;
end = buffer + length; end = buffer + length;
version = QTDEMUX_GUINT32_GET (buffer + 16); version = QTDEMUX_GUINT32_GET (buffer + 16);
GST_DEBUG ("version %08x\n", version); GST_DEBUG ("version %08x", version);
if (1 || version == 0x00000000) { if (1 || version == 0x00000000) {
buf = buffer + 0x32; buf = buffer + 0x32;
end = buffer + length; end = buffer + length;
tlen = QTDEMUX_GUINT8_GET (buf); tlen = QTDEMUX_GUINT8_GET (buf);
GST_DEBUG ("tlen = %d\n", tlen); GST_DEBUG ("tlen = %d", tlen);
buf++; buf++;
GST_DEBUG ("string = %.*s\n", tlen, (char *) buf); GST_DEBUG ("string = %.*s", tlen, (char *) buf);
buf += tlen; buf += tlen;
buf += 23; buf += 23;
@ -2279,7 +2305,8 @@ qtdemux_parse_trak (GstQTDemux * qtdemux, GNode * trak)
n = QTDEMUX_GUINT32_GET (stts->data + 16 + 8 * i); n = QTDEMUX_GUINT32_GET (stts->data + 16 + 8 * i);
duration = QTDEMUX_GUINT32_GET (stts->data + 16 + 8 * i + 4); duration = QTDEMUX_GUINT32_GET (stts->data + 16 + 8 * i + 4);
time = (GST_SECOND * duration) / stream->timescale; time =
gst_util_uint64_scale_int (duration, GST_SECOND, stream->timescale);
for (j = 0; j < n; j++) { for (j = 0; j < n; j++) {
//GST_INFO("moo %lld", timestamp); //GST_INFO("moo %lld", timestamp);
samples[index].timestamp = timestamp; samples[index].timestamp = timestamp;
@ -2344,7 +2371,8 @@ qtdemux_parse_trak (GstQTDemux * qtdemux, GNode * trak)
samples[j].duration = samples[j].duration =
samples_per_chunk * stream->timescale / (stream->rate / 2); samples_per_chunk * stream->timescale / (stream->rate / 2);
samples[j].timestamp = timestamp; samples[j].timestamp = timestamp;
timestamp += (samples_per_chunk * GST_SECOND) / stream->rate; timestamp += gst_util_uint64_scale_int (samples_per_chunk, GST_SECOND,
stream->rate);
#if 0 #if 0
GST_INFO ("moo samples_per_chunk=%d rate=%d dur=%lld %lld", GST_INFO ("moo samples_per_chunk=%d rate=%d dur=%lld %lld",
(int) samples_per_chunk, (int) samples_per_chunk,
@ -2414,7 +2442,7 @@ qtdemux_parse_udta (GstQTDemux * qtdemux, GNode * udta)
return; return;
} }
GST_DEBUG ("new tag list\n"); GST_DEBUG ("new tag list");
qtdemux->tag_list = gst_tag_list_new (); qtdemux->tag_list = gst_tag_list_new ();
node = qtdemux_tree_get_child_by_type (ilst, FOURCC__nam); node = qtdemux_tree_get_child_by_type (ilst, FOURCC__nam);
@ -2479,7 +2507,7 @@ qtdemux_tag_add_str (GstQTDemux * qtdemux, const char *tag, GNode * node)
type = QTDEMUX_GUINT32_GET (data->data + 8); type = QTDEMUX_GUINT32_GET (data->data + 8);
if (type == 0x00000001) { if (type == 0x00000001) {
s = g_strndup ((char *) data->data + 16, len - 16); s = g_strndup ((char *) data->data + 16, len - 16);
GST_DEBUG ("adding tag %s\n", s); GST_DEBUG ("adding tag %s", s);
gst_tag_list_add (qtdemux->tag_list, GST_TAG_MERGE_REPLACE, tag, s, NULL); gst_tag_list_add (qtdemux->tag_list, GST_TAG_MERGE_REPLACE, tag, s, NULL);
g_free (s); g_free (s);
} }
@ -2502,7 +2530,7 @@ qtdemux_tag_add_num (GstQTDemux * qtdemux, const char *tag1,
if (type == 0x00000000 && len >= 22) { if (type == 0x00000000 && len >= 22) {
n1 = GST_READ_UINT16_BE (data->data + 18); n1 = GST_READ_UINT16_BE (data->data + 18);
n2 = GST_READ_UINT16_BE (data->data + 20); n2 = GST_READ_UINT16_BE (data->data + 20);
GST_DEBUG ("adding tag %d/%d\n", n1, n2); GST_DEBUG ("adding tag %d/%d", n1, n2);
gst_tag_list_add (qtdemux->tag_list, GST_TAG_MERGE_REPLACE, gst_tag_list_add (qtdemux->tag_list, GST_TAG_MERGE_REPLACE,
tag1, n1, tag2, n2, NULL); tag1, n1, tag2, n2, NULL);
} }
@ -2555,7 +2583,7 @@ qtdemux_tag_add_gnre (GstQTDemux * qtdemux, const char *tag, GNode * node)
if (type == 0x00000000 && len >= 18) { if (type == 0x00000000 && len >= 18) {
n = GST_READ_UINT16_BE (data->data + 16); n = GST_READ_UINT16_BE (data->data + 16);
if (n > 0 && n < sizeof (genres) / sizeof (char *)) { if (n > 0 && n < sizeof (genres) / sizeof (char *)) {
GST_DEBUG ("adding %d [%s]\n", n, genres[n]); GST_DEBUG ("adding %d [%s]", n, genres[n]);
gst_tag_list_add (qtdemux->tag_list, GST_TAG_MERGE_REPLACE, gst_tag_list_add (qtdemux->tag_list, GST_TAG_MERGE_REPLACE,
tag, genres[n], NULL); tag, genres[n], NULL);
} }
@ -2596,42 +2624,42 @@ gst_qtdemux_handle_esds (GstQTDemux * qtdemux, QtDemuxStream * stream,
gst_util_dump_mem (ptr, len); gst_util_dump_mem (ptr, len);
ptr += 8; ptr += 8;
GST_DEBUG ("version/flags = %08x\n", QTDEMUX_GUINT32_GET (ptr)); GST_DEBUG ("version/flags = %08x", QTDEMUX_GUINT32_GET (ptr));
ptr += 4; ptr += 4;
while (ptr < end) { while (ptr < end) {
tag = QTDEMUX_GUINT8_GET (ptr); tag = QTDEMUX_GUINT8_GET (ptr);
GST_DEBUG ("tag = %02x\n", tag); GST_DEBUG ("tag = %02x", tag);
ptr++; ptr++;
len = get_size (ptr, &ptr); len = get_size (ptr, &ptr);
GST_DEBUG ("len = %d\n", len); GST_DEBUG ("len = %d", len);
switch (tag) { switch (tag) {
case 0x03: case 0x03:
GST_DEBUG ("ID %04x\n", QTDEMUX_GUINT16_GET (ptr)); GST_DEBUG ("ID %04x", QTDEMUX_GUINT16_GET (ptr));
GST_DEBUG ("priority %04x\n", QTDEMUX_GUINT8_GET (ptr + 2)); GST_DEBUG ("priority %04x", QTDEMUX_GUINT8_GET (ptr + 2));
ptr += 3; ptr += 3;
break; break;
case 0x04: case 0x04:
GST_DEBUG ("object_type_id %02x\n", QTDEMUX_GUINT8_GET (ptr)); GST_DEBUG ("object_type_id %02x", QTDEMUX_GUINT8_GET (ptr));
GST_DEBUG ("stream_type %02x\n", QTDEMUX_GUINT8_GET (ptr + 1)); GST_DEBUG ("stream_type %02x", QTDEMUX_GUINT8_GET (ptr + 1));
GST_DEBUG ("buffer_size_db %02x\n", QTDEMUX_GUINT24_GET (ptr + 2)); GST_DEBUG ("buffer_size_db %02x", QTDEMUX_GUINT24_GET (ptr + 2));
GST_DEBUG ("max bitrate %d\n", QTDEMUX_GUINT32_GET (ptr + 5)); GST_DEBUG ("max bitrate %d", QTDEMUX_GUINT32_GET (ptr + 5));
GST_DEBUG ("avg bitrate %d\n", QTDEMUX_GUINT32_GET (ptr + 9)); GST_DEBUG ("avg bitrate %d", QTDEMUX_GUINT32_GET (ptr + 9));
ptr += 13; ptr += 13;
break; break;
case 0x05: case 0x05:
GST_DEBUG ("data:\n"); GST_DEBUG ("data:");
gst_util_dump_mem (ptr, len); gst_util_dump_mem (ptr, len);
data_ptr = ptr; data_ptr = ptr;
data_len = len; data_len = len;
ptr += len; ptr += len;
break; break;
case 0x06: case 0x06:
GST_DEBUG ("data %02x\n", QTDEMUX_GUINT8_GET (ptr)); GST_DEBUG ("data %02x", QTDEMUX_GUINT8_GET (ptr));
ptr += 1; ptr += 1;
break; break;
default: default:
GST_ERROR ("parse error\n"); GST_ERROR ("parse error");
} }
} }
@ -2749,7 +2777,7 @@ qtdemux_video_caps (GstQTDemux * qtdemux, guint32 fourcc,
default: default:
#if 0 #if 0
g_critical ("Don't know how to convert fourcc '%" GST_FOURCC_FORMAT g_critical ("Don't know how to convert fourcc '%" GST_FOURCC_FORMAT
"' to caps\n", GST_FOURCC_ARGS (fourcc)); "' to caps", GST_FOURCC_ARGS (fourcc));
return NULL; return NULL;
#endif #endif
{ {
@ -2883,7 +2911,7 @@ qtdemux_audio_caps (GstQTDemux * qtdemux, QtDemuxStream * stream,
return gst_caps_new_simple ("audio/x-gsm", NULL); return gst_caps_new_simple ("audio/x-gsm", NULL);
case GST_MAKE_FOURCC ('s', 'a', 'm', 'r'): case GST_MAKE_FOURCC ('s', 'a', 'm', 'r'):
_codec ("AMR audio"); _codec ("AMR audio");
return gst_caps_new_simple ("audio/x-amr-nb", NULL); return gst_caps_new_simple ("audio/AMR", NULL);
case GST_MAKE_FOURCC ('i', 'm', 'a', '4'): case GST_MAKE_FOURCC ('i', 'm', 'a', '4'):
_codec ("Quicktime IMA ADPCM"); _codec ("Quicktime IMA ADPCM");
return gst_caps_new_simple ("audio/x-adpcm", return gst_caps_new_simple ("audio/x-adpcm",
@ -2900,7 +2928,7 @@ qtdemux_audio_caps (GstQTDemux * qtdemux, QtDemuxStream * stream,
default: default:
#if 0 #if 0
g_critical ("Don't know how to convert fourcc '%" GST_FOURCC_FORMAT g_critical ("Don't know how to convert fourcc '%" GST_FOURCC_FORMAT
"' to caps\n", GST_FOURCC_ARGS (fourcc)); "' to caps", GST_FOURCC_ARGS (fourcc));
return NULL; return NULL;
#endif #endif
{ {

11
gst/qtdemux/qtdemux.h
View file

@ -23,10 +23,7 @@
#include <gst/gst.h> #include <gst/gst.h>
#ifdef __cplusplus G_BEGIN_DECLS
extern "C" {
#endif /* __cplusplus */
#define GST_TYPE_QTDEMUX \ #define GST_TYPE_QTDEMUX \
(gst_qtdemux_get_type()) (gst_qtdemux_get_type())
@ -71,14 +68,14 @@ struct _GstQTDemux {
/* track stuff */ /* track stuff */
guint64 last_ts; guint64 last_ts;
GstSegment segment;
}; };
struct _GstQTDemuxClass { struct _GstQTDemuxClass {
GstElementClass parent_class; GstElementClass parent_class;
}; };
#ifdef __cplusplus G_END_DECLS
}
#endif /* __cplusplus */
#endif /* __GST_QTDEMUX_H__ */ #endif /* __GST_QTDEMUX_H__ */