Skip to content
GitLab
Commit fa8b737a authored by Michael Smith's avatar Michael Smith
Browse files

Make other annoying people stop complaining about indentation styles by 

converting this to consistent use of spaces as well.

svn path=/trunk/ices/; revision=4496
parent 592601bb
Expand all Hide whitespace changes
Inline Side-by-side
src/config.c
View file @ fa8b737a
This diff is collapsed.
src/config.h
View file @ fa8b737a
/* config.h
* - configuration, and global structures built from config
*
* $Id: config.h,v 1.15 2002/08/16 15:47:36 msmith Exp $
* $Id: config.h,v 1.16 2003/03/16 14:21:48 msmith Exp $
*
* Copyright (c) 2001 Michael Smith <msmith@labyrinth.net.au>
*
......@@ -21,10 +21,10 @@
typedef struct _module_param_tag
{
char *name;
char *value;
char *name;
char *value;
struct _module_param_tag *next;
struct _module_param_tag *next;
} module_param_t;
/* FIXME: orward declaraction because my headers are a mess. */
......@@ -32,81 +32,81 @@ struct buffer_queue;
typedef struct _instance_tag
{
char *hostname;
int port;
char *password;
char *hostname;
int port;
char *password;
char *user;
char *mount;
int reconnect_delay;
int reconnect_attempts;
int encode;
char *mount;
int reconnect_delay;
int reconnect_attempts;
int encode;
int downmix;
int resampleinrate;
int resampleoutrate;
int max_queue_length;
char *savefilename;
int max_queue_length;
char *savefilename;
/* local metadata */
char *stream_name;
char *stream_genre;
char *stream_description;
char *stream_name;
char *stream_genre;
char *stream_description;
/* Parameters for re-encoding */
/* Parameters for re-encoding */
int managed;
int min_br, nom_br, max_br;
int min_br, nom_br, max_br;
float quality;
int samplerate;
int channels;
/* private */
int samplerate;
int channels;
/* private */
FILE *savefile;
int serial;
int buffer_failures;
int died;
int kill;
int skip;
int serial;
int buffer_failures;
int died;
int kill;
int skip;
int wait_for_critical;
struct buffer_queue *queue;
struct buffer_queue *queue;
struct _instance_tag *next;
struct _instance_tag *next;
} instance_t;
typedef struct _config_tag
{
int background;
char *logpath;
char *logfile;
int loglevel;
int background;
char *logpath;
char *logfile;
int loglevel;
int log_stderr;
/* <stream> */
/* <stream> */
/* <metadata> */
/* <metadata> */
char *stream_name;
char *stream_genre;
char *stream_description;
/* <playlist> */
char *playlist_module;
module_param_t *module_params;
char *stream_name;
char *stream_genre;
char *stream_description;
/* <playlist> */
char *playlist_module;
module_param_t *module_params;
/* <instance> */
/* <instance> */
instance_t *instances;
instance_t *instances;
/* private */
int log_id;
int shutdown;
/* private */
int log_id;
int shutdown;
char *metadata_filename;
cond_t queue_cond;
cond_t event_pending_cond;
mutex_t refcount_lock;
mutex_t flush_lock;
input_module_t *inmod;
struct _config_tag *next;
cond_t queue_cond;
cond_t event_pending_cond;
mutex_t refcount_lock;
mutex_t flush_lock;
input_module_t *inmod;
struct _config_tag *next;
} config_t;
extern config_t *ices_config;
......
src/encode.c
View file @ fa8b737a
/* encode.c
* - runtime encoding of PCM data.
*
* $Id: encode.c,v 1.13 2002/11/22 13:01:34 msmith Exp $
* $Id: encode.c,v 1.14 2003/03/16 14:21:48 msmith Exp $
*
* Copyright (c) 2001 Michael Smith <msmith@labyrinth.net.au>
*
......@@ -27,115 +27,115 @@
void encode_clear(encoder_state *s)
{
if(s)
{
LOG_DEBUG0("Clearing encoder engine");
ogg_stream_clear(&s->os);
vorbis_block_clear(&s->vb);
vorbis_dsp_clear(&s->vd);
vorbis_info_clear(&s->vi);
free(s);
}
if(s)
{
LOG_DEBUG0("Clearing encoder engine");
ogg_stream_clear(&s->os);
vorbis_block_clear(&s->vb);
vorbis_dsp_clear(&s->vd);
vorbis_info_clear(&s->vi);
free(s);
}
}
encoder_state *encode_initialise(int channels, int rate, int managed,
int min_br, int nom_br, int max_br, float quality,
int serial, vorbis_comment *vc)
int serial, vorbis_comment *vc)
{
encoder_state *s = calloc(1, sizeof(encoder_state));
ogg_packet h1,h2,h3;
/* If none of these are set, it's obviously not supposed to be managed */
if (nom_br < 0 && min_br < 0 && max_br < 0) {
managed = 0;
}
if (managed) {
LOG_INFO5("Encoder initialising with bitrate management: %d "
"channels, %d Hz, minimum bitrate %d, nominal %d, "
"maximum %d", channels, rate, min_br, nom_br, max_br);
} else {
if (min_br > 0 || max_br > 0) {
LOG_INFO5("Encoder initialising in constrained VBR mode: %d "
"channels, %d Hz, quality %f, minimum bitrate %d, "
"maximum %d", channels, rate, quality, min_br, max_br);
} else {
LOG_INFO3("Encoder initialising in VBR mode: %d channel(s), %d Hz, "
"quality %f", channels, rate, quality);
}
}
/* Have vorbisenc choose a mode for us */
vorbis_info_init(&s->vi);
if (managed) {
if (vorbis_encode_setup_managed(&s->vi, channels, rate,
max_br>0?max_br:-1, nom_br, min_br>0?min_br:-1)) {
LOG_ERROR5("Failed to configure managed encoding for "
"%d channel(s), at %d Hz, with bitrates %d max %d "
"nominal, %d min", channels, rate, max_br, nom_br, min_br);
vorbis_info_clear(&s->vi);
free(s);
return NULL;
}
} else {
if (vorbis_encode_setup_vbr(&s->vi, channels, rate, quality*0.1)) {
LOG_ERROR3("Failed to configure VBR encoding for %d channel(s), "
"at %d Hz, quality level %f", channels, rate, quality);
vorbis_info_clear(&s->vi);
free(s);
return NULL;
}
if (max_br > 0 || min_br > 0) {
struct ovectl_ratemanage_arg ai;
vorbis_encode_ctl(&s->vi, OV_ECTL_RATEMANAGE_GET, &ai);
ai.bitrate_hard_min = min_br;
ai.bitrate_hard_max = max_br;
ai.management_active = 1;
vorbis_encode_ctl(&s->vi, OV_ECTL_RATEMANAGE_SET, &ai);
}
}
if (managed && nom_br < 0) {
vorbis_encode_ctl(&s->vi, OV_ECTL_RATEMANAGE_AVG, NULL);
} else if (!managed) {
vorbis_encode_ctl(&s->vi, OV_ECTL_RATEMANAGE_SET, NULL);
}
encoder_state *s = calloc(1, sizeof(encoder_state));
ogg_packet h1,h2,h3;
/* If none of these are set, it's obviously not supposed to be managed */
if (nom_br < 0 && min_br < 0 && max_br < 0) {
managed = 0;
}
if (managed) {
LOG_INFO5("Encoder initialising with bitrate management: %d "
"channels, %d Hz, minimum bitrate %d, nominal %d, "
"maximum %d", channels, rate, min_br, nom_br, max_br);
} else {
if (min_br > 0 || max_br > 0) {
LOG_INFO5("Encoder initialising in constrained VBR mode: %d "
"channels, %d Hz, quality %f, minimum bitrate %d, "
"maximum %d", channels, rate, quality, min_br, max_br);
} else {
LOG_INFO3("Encoder initialising in VBR mode: %d channel(s), %d Hz, "
"quality %f", channels, rate, quality);
}
}
/* Have vorbisenc choose a mode for us */
vorbis_info_init(&s->vi);
if (managed) {
if (vorbis_encode_setup_managed(&s->vi, channels, rate,
max_br>0?max_br:-1, nom_br, min_br>0?min_br:-1)) {
LOG_ERROR5("Failed to configure managed encoding for "
"%d channel(s), at %d Hz, with bitrates %d max %d "
"nominal, %d min", channels, rate, max_br, nom_br, min_br);
vorbis_info_clear(&s->vi);
free(s);
return NULL;
}
} else {
if (vorbis_encode_setup_vbr(&s->vi, channels, rate, quality*0.1)) {
LOG_ERROR3("Failed to configure VBR encoding for %d channel(s), "
"at %d Hz, quality level %f", channels, rate, quality);
vorbis_info_clear(&s->vi);
free(s);
return NULL;
}
if (max_br > 0 || min_br > 0) {
struct ovectl_ratemanage_arg ai;
vorbis_encode_ctl(&s->vi, OV_ECTL_RATEMANAGE_GET, &ai);
ai.bitrate_hard_min = min_br;
ai.bitrate_hard_max = max_br;
ai.management_active = 1;
vorbis_encode_ctl(&s->vi, OV_ECTL_RATEMANAGE_SET, &ai);
}
}
if (managed && nom_br < 0) {
vorbis_encode_ctl(&s->vi, OV_ECTL_RATEMANAGE_AVG, NULL);
} else if (!managed) {
vorbis_encode_ctl(&s->vi, OV_ECTL_RATEMANAGE_SET, NULL);
}
vorbis_encode_setup_init(&s->vi);
vorbis_analysis_init(&s->vd, &s->vi);
vorbis_block_init(&s->vd, &s->vb);
vorbis_analysis_init(&s->vd, &s->vi);
vorbis_block_init(&s->vd, &s->vb);
ogg_stream_init(&s->os, serial);
ogg_stream_init(&s->os, serial);
vorbis_analysis_headerout(&s->vd, vc, &h1,&h2,&h3);
ogg_stream_packetin(&s->os, &h1);
ogg_stream_packetin(&s->os, &h2);
ogg_stream_packetin(&s->os, &h3);
vorbis_analysis_headerout(&s->vd, vc, &h1,&h2,&h3);
ogg_stream_packetin(&s->os, &h1);
ogg_stream_packetin(&s->os, &h2);
ogg_stream_packetin(&s->os, &h3);
s->in_header = 1;
s->in_header = 1;
s->samplerate = rate;
s->samples_in_current_page = 0;
s->prevgranulepos = 0;
return s;
return s;
}
void encode_data_float(encoder_state *s, float **pcm, int samples)
{
float **buf;
int i;
float **buf;
int i;
buf = vorbis_analysis_buffer(&s->vd, samples);
buf = vorbis_analysis_buffer(&s->vd, samples);
for(i=0; i < s->vi.channels; i++)
{
memcpy(buf[i], pcm[i], samples*sizeof(float));
}
for(i=0; i < s->vi.channels; i++)
{
memcpy(buf[i], pcm[i], samples*sizeof(float));
}
vorbis_analysis_wrote(&s->vd, samples);
vorbis_analysis_wrote(&s->vd, samples);
s->samples_in_current_page += samples;
}
......@@ -143,37 +143,37 @@ void encode_data_float(encoder_state *s, float **pcm, int samples)
/* Requires little endian data (currently) */
void encode_data(encoder_state *s, signed char *buf, int bytes, int bigendian)
{
float **buffer;
int i,j;
int channels = s->vi.channels;
int samples = bytes/(2*channels);
buffer = vorbis_analysis_buffer(&s->vd, samples);
if(bigendian)
{
for(i=0; i < samples; i++)
{
for(j=0; j < channels; j++)
{
buffer[j][i]=((buf[2*(i*channels + j)]<<8) |
(0x00ff&(int)buf[2*(i*channels + j)+1]))/32768.f;
}
}
}
else
{
for(i=0; i < samples; i++)
{
for(j=0; j < channels; j++)
{
buffer[j][i]=((buf[2*(i*channels + j) + 1]<<8) |
(0x00ff&(int)buf[2*(i*channels + j)]))/32768.f;
}
}
}
vorbis_analysis_wrote(&s->vd, samples);
float **buffer;
int i,j;
int channels = s->vi.channels;
int samples = bytes/(2*channels);
buffer = vorbis_analysis_buffer(&s->vd, samples);
if(bigendian)
{
for(i=0; i < samples; i++)
{
for(j=0; j < channels; j++)
{
buffer[j][i]=((buf[2*(i*channels + j)]<<8) |
(0x00ff&(int)buf[2*(i*channels + j)+1]))/32768.f;
}
}
}
else
{
for(i=0; i < samples; i++)
{
for(j=0; j < channels; j++)
{
buffer[j][i]=((buf[2*(i*channels + j) + 1]<<8) |
(0x00ff&(int)buf[2*(i*channels + j)]))/32768.f;
}
}
}
vorbis_analysis_wrote(&s->vd, samples);
s->samples_in_current_page += samples;
}
......@@ -188,30 +188,30 @@ void encode_data(encoder_state *s, signed char *buf, int bytes, int bigendian)
*/
int encode_dataout(encoder_state *s, ogg_page *og)
{
ogg_packet op;
int result;
if(s->in_header)
{
result = ogg_stream_flush(&s->os, og);
if(result==0)
{
s->in_header = 0;
return encode_dataout(s,og);
}
else
return 1;
}
else
{
while(vorbis_analysis_blockout(&s->vd, &s->vb)==1)
{
vorbis_analysis(&s->vb, NULL);
ogg_packet op;
int result;
if(s->in_header)
{
result = ogg_stream_flush(&s->os, og);
if(result==0)
{
s->in_header = 0;
return encode_dataout(s,og);
}
else
return 1;
}
else
{
while(vorbis_analysis_blockout(&s->vd, &s->vb)==1)
{
vorbis_analysis(&s->vb, NULL);
vorbis_bitrate_addblock(&s->vb);
while(vorbis_bitrate_flushpacket(&s->vd, &op))
ogg_stream_packetin(&s->os, &op);
}
ogg_stream_packetin(&s->os, &op);
}
/* FIXME: Make this threshold configurable.
* We don't want to buffer too many samples in one page when doing
......@@ -226,43 +226,43 @@ int encode_dataout(encoder_state *s, ogg_page *og)
result = ogg_stream_flush(&s->os, og);
}
else
result = ogg_stream_pageout(&s->os, og);
result = ogg_stream_pageout(&s->os, og);
if(result==0)
return 0;
else /* Page found! */
if(result==0)
return 0;
else /* Page found! */
{
s->samples_in_current_page -= ogg_page_granulepos(og) -
s->prevgranulepos;
s->prevgranulepos = ogg_page_granulepos(og);
return 1;
return 1;
}
}
}
}
void encode_finish(encoder_state *s)
{
ogg_packet op;
vorbis_analysis_wrote(&s->vd, 0);
ogg_packet op;
vorbis_analysis_wrote(&s->vd, 0);
while(vorbis_analysis_blockout(&s->vd, &s->vb)==1)
{
while(vorbis_analysis_blockout(&s->vd, &s->vb)==1)
{
vorbis_analysis(&s->vb, NULL);
vorbis_bitrate_addblock(&s->vb);
while(vorbis_bitrate_flushpacket(&s->vd, &op))
ogg_stream_packetin(&s->os, &op);
}
ogg_stream_packetin(&s->os, &op);
}
}
int encode_flush(encoder_state *s, ogg_page *og)
{
int result = ogg_stream_pageout(&s->os, og);
int result = ogg_stream_pageout(&s->os, og);
if(result<=0)
return 0;
else
return 1;
if(result<=0)
return 0;
else
return 1;
}
......
src/encode.h
View file @ fa8b737a
/* encode.h
* - encoding functions
*
* $Id: encode.h,v 1.3 2002/01/28 00:19:15 msmith Exp $
* $Id: encode.h,v 1.4 2003/03/16 14:21:48 msmith Exp $
*
* Copyright (c) 2001 Michael Smith <msmith@labyrinth.net.au>
*
......@@ -18,20 +18,20 @@
#include <vorbis/codec.h>
typedef struct {
ogg_stream_state os;
vorbis_block vb;
vorbis_dsp_state vd;
vorbis_info vi;
ogg_stream_state os;
vorbis_block vb;
vorbis_dsp_state vd;
vorbis_info vi;
int samples_in_current_page;
int samplerate;
ogg_int64_t prevgranulepos;
int in_header;
int in_header;
} encoder_state;
encoder_state *encode_initialise(int channels, int rate, int managed,
int min_br, int nom_br, int max_br, float quality,
int serial, vorbis_comment *vc);
int serial, vorbis_comment *vc);
void encode_clear(encoder_state *s);
void encode_data_float(encoder_state *s, float **pcm, int samples);
void encode_data(encoder_state *s, signed char *buf, int bytes, int bigendian);
......
src/event.h
View file @ fa8b737a
/* event.h
* - Generic interface for passing events to modules.
*
* $Id: event.h,v 1.2 2001/09/25 12:04:21 msmith Exp $
* $Id: event.h,v 1.3 2003/03/16 14:21:48 msmith Exp $
*
* Copyright (c) 2001 Michael Smith <msmith@labyrinth.net.au>
*
......@@ -15,11 +15,11 @@
#define __EVENT_H__
enum event_type {
EVENT_SHUTDOWN, /* Full/final shutdown. MUST NOT ignore */
EVENT_PAUSE, /* temporary shutdown. Can be ignored */
EVENT_NEXTTRACK, /* Start a new track in some way */
EVENT_RECONF, /* Reconfigure self, if possible */
EVENT_METADATAUPDATE, /* Incoming new metadata */
EVENT_SHUTDOWN, /* Full/final shutdown. MUST NOT ignore */
EVENT_PAUSE, /* temporary shutdown. Can be ignored */
EVENT_NEXTTRACK, /* Start a new track in some way */
EVENT_RECONF, /* Reconfigure self, if possible */
EVENT_METADATAUPDATE, /* Incoming new metadata */
};
#endif /* __EVENT_H__ */
......
src/ices.c
View file @ fa8b737a
/* ices.c
* - Main startup, thread launching, and cleanup code.
*