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

At end of stream, rewrite the header with the correct number of bytes

Browse source 
Original commit message from CVS:
At end of stream, rewrite the header with the correct number of bytes
This commit is contained in:
Iain Holmes 2003-07-29 17:46:14 +00:00
parent 066b70c789
commit 27d2925a1a
3 changed files with 80 additions and 39 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
common

@ -1 +1 @@
Subproject commit d6e219fd076d8f182bd1ee84228b1b85cdb807a6
Subproject commit 8b323f41bfaccb8f30bddfc6ff8bd6a4be04a3e1

110
gst/wavenc/gstwavenc.c
View file

@ -1,3 +1,4 @@
/* -*- Mode: C; tab-width: 2; indent-tabs-mode: t; c-basic-offset: 2 -*- */
/* GStreamer
* Copyright (C) <2002> Iain Holmes <iain@prettypeople.org>
*
@ -112,6 +113,17 @@ GST_PAD_TEMPLATE_FACTORY (src_factory,
static GstElementClass *parent_class = NULL;
static const GstEventMask *
gst_wavenc_get_event_masks (GstPad *pad)
{
static const GstEventMask src_event_masks[] = {
{ GST_EVENT_EOS, 0 },
{ 0, }
};
return src_event_masks;
}
static GType
gst_wavenc_get_type (void)
{
@ -239,6 +251,50 @@ gst_wavenc_sinkconnect (GstPad *pad,
return GST_PAD_LINK_REFUSED;
}
static void
gst_wavenc_stop_file (GstWavEnc *wavenc)
{
GstEvent *event;
GstBuffer *outbuf;
event = gst_event_new_seek (GST_FORMAT_BYTES |
GST_SEEK_METHOD_SET, 0);
gst_pad_send_event (GST_PAD_PEER (wavenc->srcpad), event);
outbuf = gst_buffer_new_and_alloc (WAV_HEADER_LEN);
WRITE_U32 (wavenc->header + 4, wavenc->length);
memcpy (GST_BUFFER_DATA (outbuf), wavenc->header, WAV_HEADER_LEN);
gst_pad_push (wavenc->srcpad, outbuf);
}
static gboolean
gst_wavenc_handle_event (GstPad *pad,
GstEvent *event)
{
GstWavEnc *wavenc;
GstEventType type;
wavenc = GST_WAVENC (gst_pad_get_parent (pad));
type = event ? GST_EVENT_TYPE (event) : GST_EVENT_UNKNOWN;
switch (type) {
case GST_EVENT_EOS:
wavenc->pad_eos = TRUE;
gst_wavenc_stop_file (wavenc);
gst_pad_push (wavenc->srcpad,
GST_BUFFER (gst_event_new (GST_EVENT_EOS)));
gst_element_set_eos (GST_ELEMENT (wavenc));
break;
default:
break;
}
return TRUE;
}
static void
gst_wavenc_init (GstWavEnc *wavenc)
{
@ -246,6 +302,8 @@ gst_wavenc_init (GstWavEnc *wavenc)
gst_element_add_pad (GST_ELEMENT (wavenc), wavenc->sinkpad);
gst_pad_set_chain_function (wavenc->sinkpad, gst_wavenc_chain);
gst_pad_set_link_function (wavenc->sinkpad, gst_wavenc_sinkconnect);
gst_pad_set_event_function (wavenc->sinkpad, gst_wavenc_handle_event);
gst_pad_set_event_mask_function (wavenc->sinkpad, gst_wavenc_get_event_masks);
wavenc->srcpad = gst_pad_new_from_template (srctemplate, "src");
gst_element_add_pad (GST_ELEMENT (wavenc), wavenc->srcpad);
@ -262,44 +320,26 @@ gst_wavenc_chain (GstPad *pad,
wavenc = GST_WAVENC (gst_pad_get_parent (pad));
if (GST_IS_EVENT (buf)) {
GstEvent *event = GST_EVENT (buf);
switch (GST_EVENT_TYPE (event)) {
case GST_EVENT_EOS:
/* Should do something... */
gst_event_unref (event);
if (GST_PAD_IS_USABLE (wavenc->srcpad))
gst_pad_push (wavenc->srcpad, GST_BUFFER (gst_event_new (GST_EVENT_EOS)));
gst_element_set_eos (GST_ELEMENT (wavenc));
break;
default:
gst_pad_event_default (pad, event);
return;
}
if (!wavenc->setup) {
gst_buffer_unref (buf);
gst_element_error (GST_ELEMENT (wavenc), "encoder not initialised (input is not audio?)");
return;
}
else {
if (!wavenc->setup) {
gst_buffer_unref (buf);
gst_element_error (GST_ELEMENT (wavenc), "encoder not initialised (input is not audio?)");
return;
if (GST_PAD_IS_USABLE (wavenc->srcpad)) {
if (wavenc->flush_header) {
GstBuffer *outbuf;
outbuf = gst_buffer_new_and_alloc (WAV_HEADER_LEN);
memcpy (GST_BUFFER_DATA (outbuf), wavenc->header, WAV_HEADER_LEN);
GST_BUFFER_TIMESTAMP (outbuf) = GST_BUFFER_TIMESTAMP (buf);
gst_pad_push (wavenc->srcpad, outbuf);
wavenc->flush_header = FALSE;
}
if (GST_PAD_IS_USABLE (wavenc->srcpad)) {
if (wavenc->flush_header) {
GstBuffer *outbuf;
outbuf = gst_buffer_new_and_alloc (WAV_HEADER_LEN);
memcpy (GST_BUFFER_DATA (outbuf), wavenc->header, WAV_HEADER_LEN);
GST_BUFFER_TIMESTAMP (outbuf) = GST_BUFFER_TIMESTAMP (buf);
gst_pad_push (wavenc->srcpad, outbuf);
wavenc->flush_header = FALSE;
}
gst_pad_push (wavenc->srcpad, buf);
}
wavenc->length += GST_BUFFER_SIZE (buf);
gst_pad_push (wavenc->srcpad, buf);
}
}

3
gst/wavenc/gstwavenc.h
View file

@ -54,8 +54,9 @@ struct _GstWavEnc {
guint rate;
guint channels;
guint width;
guint32 length;
gboolean setup, flush_header;
gboolean setup, flush_header, pad_eos;
guchar header[WAV_HEADER_LEN];
};