X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=recv.h;h=c69520e402905524ebcb120bc44221f371d29371;hp=05c5ed7615729219990859d2f953f85b96437c0a;hb=869f0e06ec4e15abc9230c1b2d7615da5250802e;hpb=92f089b820b45a5dbdc5b4f69d596105d5acba68;ds=sidebyside diff --git a/recv.h b/recv.h index 05c5ed76..c69520e4 100644 --- a/recv.h +++ b/recv.h @@ -1,5 +1,5 @@ /* - * Copyright (C) 2005-2011 Andre Noll + * Copyright (C) 2005-2012 Andre Noll * * Licensed under the GPL v2. For licencing details see COPYING. */ @@ -20,6 +20,21 @@ struct receiver_node { struct task task; /** The receiver node is always the root of the buffer tree. */ struct btr_node *btrn; + /** Each receiver node maintains a buffer pool for the received data. */ + struct btr_pool *btrp; + /** + * The file descriptor to receive the stream. + * + * The pre_select function of the receiver adds this file descriptor to + * the set of file descriptors which are watched for readability or + * writability, depending on the state of the connection (if any). + * + * If \a fd is readable, the post_select function of the receiver reads + * data from this fd into the buffer pool area of \a btrp. + * + * \sa \ref receiver. + */ + int fd; }; /** @@ -50,6 +65,12 @@ struct receiver { * \a argc and \a argv. */ void *(*parse_config)(int argc, char **argv); + /** + * Deallocate the configuration structure of a receiver node. + * + * This calls the receiver-specific cleanup function generated by + * gengetopt. + */ void (*free_config)(void *conf); /** * Open one instance of the receiver. @@ -87,9 +108,9 @@ struct receiver { * Evaluate the result from select(). * * This hook gets called after the call to select(). It should check - * all file descriptors which were added to any of the the fd sets - * during the previous call to pre_select. According to the result, it - * may then use any non-blocking I/O to establish a connection or to + * all file descriptors which were added to any of the fd sets during + * the previous call to pre_select. According to the result, it may + * then use any non-blocking I/O to establish a connection or to * receive the audio data. * * \sa select(2), struct receiver. @@ -115,7 +136,7 @@ void *check_receiver_arg(char *ra, int *receiver_num); void print_receiver_helps(int detailed); int generic_recv_pre_select(struct sched *s, struct task *t); -/** \cond */ +/** \cond receiver */ extern void http_recv_init(struct receiver *r); #define HTTP_RECEIVER {.name = "http", .init = http_recv_init}, extern void dccp_recv_init(struct receiver *r); @@ -124,5 +145,5 @@ extern void udp_recv_init(struct receiver *r); #define UDP_RECEIVER {.name = "udp", .init = udp_recv_init}, extern struct receiver receivers[]; -/** \endcond */ +/** \endcond receiver */