aniani/icecast-server
1
0
Fork 0
mirror of https://gitlab.xiph.org/xiph/icecast-server.git synced 2024-11-03 04:17:17 -05:00
Code

add writ stream handling

Browse Source 
svn path=/icecast/branches/kh/icecast/; revision=7218
This commit is contained in:
Karl Heyes 2004-07-21 13:01:56 +00:00
parent 5fae00fb71
commit cd2b53697e
1 changed files with 67 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

67
src/format_ogg.c
View File

@ -220,6 +220,70 @@ static ogg_codec_t *initial_vorbis_page (ogg_page *page)
return codec;
}
/* Writ codec handler */
static void writ_codec_free (ogg_codec_t *codec)
{
ogg_stream_clear (&codec->os);
free (codec);
}
static refbuf_t *process_writ_page (ogg_codec_t *codec, ogg_page *page)
{
refbuf_t *refbuf;
if (codec->headers)
{
ogg_packet pkt;
ogg_stream_pagein (&codec->os, page);
while (ogg_stream_packetout (&codec->os, &pkt) > 0)
{
if (pkt.bytes >= 5 && pkt.packet[0] != (unsigned char)'\xff' &&
memcmp (pkt.packet+1, "writ", 4) == 0)
{
codec->headers++;
continue;
}
codec->headers = 0;
}
if (codec->headers)
return NULL;
}
refbuf = make_refbuf_with_page (page);
/* allow clients to start here if nothing prevents it */
if (codec->feed->codec_sync == NULL)
refbuf->sync_point = 1;
return refbuf;
}
static ogg_codec_t *initial_writ_page (ogg_page *page)
{
ogg_packet packet;
ogg_codec_t *codec = calloc (1, sizeof (ogg_codec_t));
ogg_stream_init (&codec->os, ogg_page_serialno (page));
ogg_stream_pagein (&codec->os, page);
ogg_stream_packetout (&codec->os, &packet);
if (memcmp (packet.packet, "\x00writ", 5) == 0)
{
INFO0 ("seen initial writ header");
codec->process_page = process_writ_page;
codec->codec_free = writ_codec_free;
codec->headers = 1;
return codec;
}
ogg_stream_clear (&codec->os);
free (codec);
return NULL;
}
#ifdef HAVE_SPEEX
static void speex_codec_free (ogg_codec_t *codec)
@ -531,6 +595,9 @@ static int process_initial_page (ogg_state_t *ogg_info, ogg_page *page)
codec = initial_vorbis_page (page);
if (codec)
break;
codec = initial_writ_page (page);
if (codec)
break;
#ifdef HAVE_THEORA
codec = initial_theora_page (page);
if (codec)