aniani/icecast-server
1
0
Fork 0
mirror of https://gitlab.xiph.org/xiph/icecast-server.git synced 2024-06-23 06:25:24 +00:00
Code

cleanup headers sent to listeners

Browse Source 
svn path=/trunk/icecast/; revision=5808
This commit is contained in:
Karl Heyes 2004-02-03 00:29:36 +00:00
parent b24028f620
commit aabbde37bc
2 changed files with 42 additions and 43 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
src/format.c
View File

@ -124,14 +124,44 @@ void format_send_general_headers(format_plugin_t *format,
/* iterate through source http headers and send to client */
avl_tree_rlock(source->parser->vars);
node = avl_get_first(source->parser->vars);
while (node) {
while (node)
{
var = (http_var_t *)node->key;
if (strcasecmp(var->name, "ice-password") &&
(!strncasecmp("ice-", var->name, 4))) {
bytes = sock_write(client->con->sock,
"%s: %s\r\n", var->name, var->value);
if (bytes > 0)
client->con->sent_bytes += bytes;
if (!strcasecmp(var->name, "ice-audio-info")) {
/* convert ice-audio-info to icy-br */
char *brfield;
unsigned int bitrate;
brfield = strstr(var->value, "bitrate=");
if (brfield && sscanf(var->value, "bitrate=%u", &bitrate)) {
bytes = sock_write(client->con->sock, "icy-br:%u\r\n", bitrate);
if (bytes > 0)
client->con->sent_bytes += bytes;
}
}
else
{
if (strcasecmp(var->name, "ice-password") &&
strcasecmp(var->name, "icy-metaint"))
{
bytes = 0;
if (!strncasecmp("ice-", var->name, 4))
{
if (!strcasecmp("ice-bitrate", var->name))
bytes += sock_write(client->con->sock, "icy-br:%s\r\n", var->value);
else
bytes = sock_write(client->con->sock, "icy%s:%s\r\n",
var->name + 3, var->value);
}
if (!strncasecmp("icy-", var->name, 4))
{
bytes = sock_write(client->con->sock, "icy%s:%s\r\n",
var->name + 3, var->value);
}
if (bytes > 0)
client->con->sent_bytes += bytes;
}
}
node = avl_get_next(node);
}

41
src/format_mp3.c
View File

@ -405,47 +405,16 @@ static void format_mp3_send_headers(format_plugin_t *self,
"Content-Type: %s\r\n",
format_get_mimetype(source->format->type));
if(bytes > 0) client->con->sent_bytes += bytes;
if (bytes > 0)
client->con->sent_bytes += bytes;
/* iterate through source http headers and send to client */
avl_tree_rlock(source->parser->vars);
node = avl_get_first(source->parser->vars);
while (node) {
var = (http_var_t *)node->key;
if (!strcasecmp(var->name, "ice-audio-info")) {
/* convert ice-audio-info to icy-br */
char *brfield;
unsigned int bitrate;
brfield = strstr(var->value, "bitrate=");
if (brfield && sscanf(var->value, "bitrate=%u", &bitrate)) {
bytes = sock_write(client->con->sock, "icy-br:%u\r\n", bitrate);
if (bytes > 0)
client->con->sent_bytes += bytes;
}
} else if (strcasecmp(var->name, "ice-password") &&
strcasecmp(var->name, "icy-metaint") &&
(!strncasecmp("ice-", var->name, 4) ||
!strncasecmp("icy-", var->name, 4))) {
bytes = sock_write(client->con->sock, "icy%s:%s\r\n",
var->name + 3, var->value);
if (bytes > 0)
client->con->sent_bytes += bytes;
}
node = avl_get_next(node);
}
avl_tree_unlock(source->parser->vars);
if (mp3data->use_metadata) {
if (mp3data->use_metadata)
{
int bytes = sock_write(client->con->sock, "icy-metaint:%d\r\n",
ICY_METADATA_INTERVAL);
if(bytes > 0)
client->con->sent_bytes += bytes;
}
bytes = sock_write(client->con->sock,
"Server: %s\r\n", ICECAST_VERSION_STRING);
if (bytes > 0)
client->con->sent_bytes += bytes;
format_send_general_headers(self, source, client);
}