X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=audiod.h;h=234c67a0d9eb9d09643544a498d96e5be5d69093;hp=4cd35954f403c37d2f6d4ef7b62f4234bb4281d3;hb=c4012aab461993e6c8a9930d27d924a8462a9775;hpb=258534d8a29be72e529acdbf4daf54d6cd8bf5c7 diff --git a/audiod.h b/audiod.h index 4cd35954..234c67a0 100644 --- a/audiod.h +++ b/audiod.h @@ -1,13 +1,98 @@ /** \file audiod.h symbols exported from audiod.c */ int num_filters(int audio_format_num); int get_audio_format_num(char *name); -enum { - AUDIO_FORMAT_MP3, - AUDIO_FORMAT_OGG, - AUDIO_FORMAT_AAC, - NUM_AUDIO_FORMATS -}; + +/** enum of audio formats supported by para_audiod */ +enum {AUDIOD_AUDIO_FORMATS_ENUM}; + +/** array of audio format names supported by para_audiod */ extern const char *audio_formats[]; -#define DEFINE_AUDIO_FORMAT_ARRAY const char *audio_formats[] = {"mp3", "ogg", "aac", NULL} + +/** maximal number of simultaneous instances */ #define MAX_STREAM_SLOTS 5 +/** + * the possible modes of operation + * + * - off: disconnect from para_server + * - on: receive status information from para_server and play the audio stream + * - sb: only receive status information but not the audio stream +*/ +enum {AUDIOD_OFF, AUDIOD_ON, AUDIOD_STANDBY}; + +/** + * describes one instance of a receiver-filter-writer chain + * + * \sa receier_node, receiver, filter, filter_node, filter_chain, writer, + * writer_node, writer_node_group. + */ +struct slot_info { + /** number of the audio format in this slot */ + int format; + /** writer start time */ + struct timeval wstime; + /** the receiver info associated with this slot */ + struct receiver_node *receiver_node; + /** the active filter chain */ + struct filter_chain *fc; + /** the active writer node group */ + struct writer_node_group *wng; +}; + +/** + * the main task of audiod + * + * \sa struct task, struct sched + */ +struct audiod_task { + struct timeval *now; + struct task task; +}; + +/** + * the task for obtaining para_server's status (para_client stat) + * + * \sa struct task, struct sched + */ +struct status_task { + /** the associated task structure of audiod */ + struct task task; + /** client data associated with the stat task */ + struct private_client_data *pcd; + /** the array of status items sent by para_server */ + char *stat_item_values[NUM_STAT_ITEMS]; + /** do not restart client command until this time */ + struct timeval restart_barrier; + /** last time we received status data from para_server */ + struct timeval last_status_read; + /** the offset value announced by para_server */ + int offset_seconds; + /** the length of the current audio file as announced by para_server */ + int length_seconds; + /** the start of the current stream from the view of para_server */ + struct timeval server_stream_start; + /** the average time deviation between para_server and para_audiod */ + struct timeval sa_time_diff; + /** whether client time is ahead of server time */ + int sa_time_diff_sign; + /** non-zero if para_server's status is "playing" */ + int playing; + /** number of times the clock difference is to be checked */ + unsigned clock_diff_count; + /** when to start the next check for clock difference */ + struct timeval clock_diff_barrier; +}; + +extern struct status_task *stat_task; +extern struct slot_info slot[MAX_STREAM_SLOTS]; +extern struct audiod_args_info conf; +extern int audiod_status; +extern const char *status_item_list[NUM_STAT_ITEMS]; + +void __noreturn clean_exit(int status, const char *msg); +int handle_connect(int accept_fd); +void audiod_status_dump(void); +void dump_empty_status(void); + +/** iterate over all slots */ +#define FOR_EACH_SLOT(_slot) for (_slot = 0; _slot < MAX_STREAM_SLOTS; _slot++)