mirror of
https://gitlab.xiph.org/xiph/icecast-server.git
synced 2024-06-23 06:25:24 +00:00
205d225b73
causing stuttering in some clients. Thank goodness icecast uses an odd metainterval, or this bug would never have been discoverd :) svn path=/trunk/icecast/; revision=5044
126 lines
3.0 KiB
C
126 lines
3.0 KiB
C
/* format.c
|
|
**
|
|
** format plugin implementation
|
|
**
|
|
*/
|
|
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <time.h>
|
|
|
|
#include "connection.h"
|
|
#include "refbuf.h"
|
|
|
|
#include "source.h"
|
|
#include "format.h"
|
|
#include "global.h"
|
|
#include "httpp.h"
|
|
|
|
#include "format_vorbis.h"
|
|
#include "format_mp3.h"
|
|
|
|
#include "log.h"
|
|
#include "logging.h"
|
|
#define CATMODULE "format"
|
|
|
|
#ifdef WIN32
|
|
#define strcasecmp stricmp
|
|
#define strncasecmp strnicmp
|
|
#endif
|
|
|
|
format_type_t format_get_type(char *contenttype)
|
|
{
|
|
if(strcmp(contenttype, "application/x-ogg") == 0)
|
|
return FORMAT_TYPE_VORBIS; /* Backwards compatibility */
|
|
else if(strcmp(contenttype, "application/ogg") == 0)
|
|
return FORMAT_TYPE_VORBIS; /* Now blessed by IANA */
|
|
else if(strcmp(contenttype, "audio/mpeg") == 0)
|
|
return FORMAT_TYPE_MP3;
|
|
else
|
|
return FORMAT_ERROR;
|
|
}
|
|
|
|
char *format_get_mimetype(format_type_t type)
|
|
{
|
|
switch(type) {
|
|
case FORMAT_TYPE_VORBIS:
|
|
return "application/ogg";
|
|
break;
|
|
case FORMAT_TYPE_MP3:
|
|
return "audio/mpeg";
|
|
break;
|
|
default:
|
|
return NULL;
|
|
}
|
|
}
|
|
|
|
format_plugin_t *format_get_plugin(format_type_t type, char *mount,
|
|
http_parser_t *parser)
|
|
{
|
|
format_plugin_t *plugin;
|
|
|
|
switch (type) {
|
|
case FORMAT_TYPE_VORBIS:
|
|
plugin = format_vorbis_get_plugin();
|
|
if (plugin) plugin->mount = mount;
|
|
break;
|
|
case FORMAT_TYPE_MP3:
|
|
plugin = format_mp3_get_plugin(parser);
|
|
if (plugin) plugin->mount = mount;
|
|
break;
|
|
default:
|
|
plugin = NULL;
|
|
break;
|
|
}
|
|
|
|
return plugin;
|
|
}
|
|
|
|
int format_generic_write_buf_to_client(format_plugin_t *format,
|
|
client_t *client, unsigned char *buf, int len)
|
|
{
|
|
int ret;
|
|
|
|
ret = sock_write_bytes(client->con->sock, buf, len);
|
|
|
|
if(ret < 0) {
|
|
if(sock_recoverable(sock_error())) {
|
|
DEBUG1("Client had recoverable error %ld", ret);
|
|
ret = 0;
|
|
}
|
|
}
|
|
else
|
|
client->con->sent_bytes += ret;
|
|
|
|
return ret;
|
|
}
|
|
|
|
void format_send_general_headers(format_plugin_t *format,
|
|
source_t *source, client_t *client)
|
|
{
|
|
http_var_t *var;
|
|
avl_node *node;
|
|
int 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-password") &&
|
|
strcasecmp(var->name, "icy-metaint") &&
|
|
(!strncasecmp("ice-", var->name, 4) ||
|
|
!strncasecmp("icy-", 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;
|
|
}
|
|
node = avl_get_next(node);
|
|
}
|
|
avl_tree_unlock(source->parser->vars);
|
|
bytes = sock_write(client->con->sock,
|
|
"Server: %s\r\n", ICECAST_VERSION_STRING);
|
|
if(bytes > 0) client->con->sent_bytes += bytes;
|
|
}
|
|
|