/* 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;

    client_t *active_clients;
    client_t **active_clients_tail;

    client_t *pending_clients;
    client_t **pending_clients_tail;
    unsigned new_listeners;

    rwlock_t *shutdown_rwlock;
    ypdata_t *ypdata[MAX_YP_DIRECTORIES];
    util_dict *audio_info;

    char *dumpfilename; /* Name of a file to dump incoming stream to */
    FILE *dumpfile;

    int    num_yp_directories;
    long listeners;
    long max_listeners;
    int yp_public;
    struct auth_tag *authenticator;
    int fallback_override;
    int no_mount;
    unsigned queue_size_limit;
    unsigned timeout;  /* source timeout in seconds */

    int on_demand;
    int on_demand_req;

    time_t last_read;
    int short_delay;
    char *on_connect;
    char *on_disconnect;

    mutex_t lock;
    unsigned queue_size;
    unsigned burst_size;

    refbuf_t *starting_point;
    unsigned starting_max;
    unsigned starting_count;

    refbuf_t *(*get_buffer)(struct source_tag *);
    refbuf_t *stream_data, *stream_data_tail;

    refbuf_t *associated;

} 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