X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=recv.h;h=ee8138f9d9c12a9674600091d3073b1807dc41ba;hp=6d318d6adbc0d80e9a8df99a9f4a9888da15fd5e;hb=bda95f9508b456dcea89d300f6d4104e30ab9f3e;hpb=19d9318abf42debb15d833d4e56ab636893285c3;ds=sidebyside diff --git a/recv.h b/recv.h index 6d318d6a..ee8138f9 100644 --- a/recv.h +++ b/recv.h @@ -1,133 +1,134 @@ /* - * Copyright (C) 2005-2007 Andre Noll + * Copyright (C) 2005-2011 Andre Noll * * Licensed under the GPL v2. For licencing details see COPYING. */ -/** \file recv.h receiver-related structures and exported symbols of recv_common.c */ +/** \file recv.h Receiver-related structures and exported symbols of recv_common.c. */ /** - * describes one instance of a receiver + * Describes one instance of a receiver. */ struct receiver_node { - /** points to the corresponding receiver */ + /** Points to the corresponding receiver. */ struct receiver *receiver; - /** the output buffer */ - char *buf; - /** the amount of bytes in \a buf */ - size_t loaded; - /** receiver-specific data */ + /** Receiver-specific data. */ void *private_data; - /** Set to non-zero error value on errors or on end of file. */ - int error; - /** Pointer to the error member of the consumer. */ - int *output_error; - /** pointer to the configuration data for this instance */ + /** Pointer to the configuration data for this instance. */ void *conf; - /** the task associated with this instance */ + /** The task associated with this instance. */ struct task task; + /** The receiver node is always the root of the buffer tree. */ + struct btr_node *btrn; }; /** - * describes one supported paraslash receiver + * Describes one supported paraslash receiver. * - * \sa http_recv.c, ortp_recv.c + * \sa http_recv.c, udp_recv.c */ struct receiver { -/** - * the name of the receiver - */ + /** + * The name of the receiver. + */ const char *name; -/** - * the receiver init function - * - * It must fill in all other function pointers and is assumed to succeed. - * - * \sa http_recv_init ortp_recv_init - */ + /** + * The receiver init function. + * + * It must fill in all other function pointers and is assumed to succeed. + * + * \sa http_recv_init udp_recv_init. + */ void (*init)(struct receiver *r); -/** - * the command line parser of the receiver - * - * It should check whether the command line options given by \a argc and \a - * argv are valid. On success, it should return a pointer to the - * receiver-specific configuration data determined by \a argc and \a argv. - * Note that this might be called more than once with different values of - * \a argc and \a argv. - */ - void * (*parse_config)(int argc, char **argv); -/** - * open one instance of the receiver - * - * This should allocate the output buffer of \a rn. and may also perform any - * other work necessary for retrieving the stream according to the - * configuration stored in the \a conf member of \a rn which is guaranteed to - * point to valid configuration data (as previously obtained from the config - * parser). - * - * \sa receiver_node::conf, receiver_node::buf - */ + /** + * The command line parser of the receiver. + * + * It should check whether the command line options given by \a argc and \a + * argv are valid. On success, it should return a pointer to the + * receiver-specific configuration data determined by \a argc and \a argv. + * Note that this might be called more than once with different values of + * \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. + * + * This should allocate the output buffer of \a rn. and may also + * perform any other work necessary for retrieving the stream according + * to the configuration stored in the \a conf member of \a rn which is + * guaranteed to point to valid configuration data (as previously + * obtained from the config parser). + * + * \sa receiver_node::conf, receiver_node::buf. + */ int (*open)(struct receiver_node *rn); -/** - * close this instance of the receiver - * - * It should free all resources associated with given receiver node that were - * allocated during the corresponding open call. - * - * \sa receiver_node - */ + /** + * Close this instance of the receiver. + * + * It should free all resources associated with given receiver node + * that were allocated during the corresponding open call. + * + * \sa receiver_node. + */ void (*close)(struct receiver_node *rn); -/** - * deactivate the receiver - * - * Clean up what init has allocated. - */ - void (*shutdown)(void); -/** - * add file descriptors to fd_sets and compute timeout for select(2) - * - * The pre_select function gets called from the driving application before - * entering its select loop. The receiver may use this hook to add any file - * descriptors to the sets of file descriptors given by \a s. - * - * \sa select(2), time.c struct task, struct sched - */ + /** + * Add file descriptors to fd_sets and compute timeout for select(2). + * + * The pre_select function gets called from the driving application + * before entering its select loop. The receiver may use this hook to + * add any file descriptors to the sets of file descriptors given by \a + * s. + * + * \sa select(2), time.c struct task, struct sched. + */ void (*pre_select)(struct sched *s, struct task *t); -/** - * 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 receive the audio data. - * - * \sa select(2), 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 + * receive the audio data. + * + * \sa select(2), struct receiver. + */ void (*post_select)(struct sched *s, struct task *t); + + /** The two help texts of this receiver. */ + struct ggo_help help; }; +/** Define an array of all available receivers. */ +#define DEFINE_RECEIVER_ARRAY struct receiver receivers[] = { \ + HTTP_RECEIVER \ + DCCP_RECEIVER \ + UDP_RECEIVER \ + {.name = NULL}}; + +/** Iterate over all available receivers. */ +#define FOR_EACH_RECEIVER(i) for (i = 0; receivers[i].name; i++) + +void recv_init(void); +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 */ 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); #define DCCP_RECEIVER {.name = "dccp", .init = dccp_recv_init}, - -#ifdef HAVE_ORTP -extern void ortp_recv_init(struct receiver *r); -#define ORTP_RECEIVER {.name = "ortp", .init = ortp_recv_init}, -#else -#define ORTP_RECEIVER -#endif +extern void udp_recv_init(struct receiver *r); +#define UDP_RECEIVER {.name = "udp", .init = udp_recv_init}, extern struct receiver receivers[]; /** \endcond */ -/** define an array of all available receivers */ -#define DEFINE_RECEIVER_ARRAY struct receiver receivers[] = { \ - HTTP_RECEIVER \ - DCCP_RECEIVER \ - ORTP_RECEIVER \ - {.name = NULL}}; - -void *check_receiver_arg(char *ra, int *receiver_num);