mirror of
https://gitlab.xiph.org/xiph/icecast-server.git
synced 2024-06-23 06:25:24 +00:00
93 lines
2.3 KiB
C
93 lines
2.3 KiB
C
/* Icecast
|
|
*
|
|
* This program is distributed under the GNU General Public License, version 2.
|
|
* A copy of this license is included with this source.
|
|
*
|
|
* Copyright 2000-2004, Jack Moffitt <jack@xiph.org,
|
|
* Michael Smith <msmith@xiph.org>,
|
|
* oddsock <oddsock@xiph.org>,
|
|
* Karl Heyes <karl@xiph.org>
|
|
* and others (see AUTHORS for details).
|
|
*/
|
|
|
|
#ifndef __SOURCE_H__
|
|
#define __SOURCE_H__
|
|
|
|
#include "cfgfile.h"
|
|
#include "yp.h"
|
|
#include "util.h"
|
|
#include "format.h"
|
|
|
|
#include <stdio.h>
|
|
|
|
struct auth_tag;
|
|
|
|
typedef struct source_tag
|
|
{
|
|
client_t *client;
|
|
connection_t *con;
|
|
http_parser_t *parser;
|
|
|
|
char *mount;
|
|
|
|
/* If this source drops, try to move all clients to this fallback */
|
|
char *fallback_mount;
|
|
|
|
/* set to zero to request the source to shutdown without causing a global
|
|
* shutdown */
|
|
int running;
|
|
|
|
struct _format_plugin_tag *format;
|
|
|
|
avl_tree *client_tree;
|
|
avl_tree *pending_tree;
|
|
|
|
rwlock_t *shutdown_rwlock;
|
|
util_dict *audio_info;
|
|
|
|
char *dumpfilename; /* Name of a file to dump incoming stream to */
|
|
FILE *dumpfile;
|
|
|
|
long listeners;
|
|
long max_listeners;
|
|
int yp_public;
|
|
struct auth_tag *authenticator;
|
|
int fallback_override;
|
|
int no_mount;
|
|
|
|
/* per source burst handling for connecting clients */
|
|
unsigned int burst_size; /* trigger level for burst on connect */
|
|
unsigned int burst_offset;
|
|
refbuf_t *burst_point;
|
|
|
|
unsigned int queue_size;
|
|
unsigned int queue_size_limit;
|
|
|
|
unsigned timeout; /* source timeout in seconds */
|
|
time_t last_read;
|
|
int short_delay;
|
|
|
|
refbuf_t *stream_data;
|
|
refbuf_t *stream_data_tail;
|
|
|
|
} source_t;
|
|
|
|
source_t *source_reserve (const char *mount);
|
|
void *source_client_thread (void *arg);
|
|
void source_apply_mount (source_t *source, mount_proxy *mountinfo);
|
|
void source_clear_source (source_t *source);
|
|
source_t *source_find_mount(const char *mount);
|
|
source_t *source_find_mount_raw(const char *mount);
|
|
client_t *source_find_client(source_t *source, int id);
|
|
int source_compare_sources(void *arg, void *a, void *b);
|
|
void source_free_source(source_t *source);
|
|
void source_move_clients (source_t *source, source_t *dest);
|
|
int source_remove_client(void *key);
|
|
void source_main(source_t *source);
|
|
|
|
extern mutex_t move_clients_mutex;
|
|
|
|
#endif
|
|
|
|
|