X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=send.h;h=270affd5279d5bb3c1a00a05833c0859028a0c1f;hp=69ebd377e0ea27c46932a1a1e5456349e9787360;hb=1252678a5017d9a45a5cbe6319fcaaebc3fc9632;hpb=2abba90245f87fab096edfc3faf7df61646b713f diff --git a/send.h b/send.h index 69ebd377..270affd5 100644 --- a/send.h +++ b/send.h @@ -49,7 +49,8 @@ struct sender { * should be sent, and \a len is the length of this buffer. */ void (*send)(long unsigned current_chunk, long unsigned chunks_sent, - const char *buf, size_t len); + const char *buf, size_t len, const char *header_buf, + size_t header_len); /** * Add file descriptors to fd_sets. * @@ -104,7 +105,39 @@ struct sender_client { void *private_data; }; -int open_sender(unsigned l4type, int port); -void shutdown_client(struct sender_client *sc); -void send_chunk(struct sender_client *sc, size_t max_bytes_per_write, - long unsigned current_chunk, const char *buf, size_t len); +/** Describes the current status of one paraslash sender. */ +struct sender_status { + /* The file descriptor of the socket this sender is listening on. */ + int listen_fd; + /** The TCP/DCCP port used by this sender. */ + int port; + /** The current number of simultaneous connections. */ + int num_clients; + /** The maximal number of simultaneous connections. */ + int max_clients; + /** Whether the access control list is a whitelist. */ + int default_deny; + /** The whitelist/blacklist. */ + struct list_head acl; + /** The list of connected clients. */ + struct list_head client_list; +}; + +void shutdown_client(struct sender_client *sc, struct sender_status *ss); +void shutdown_clients(struct sender_status *ss); +void send_chunk(struct sender_client *sc, struct sender_status *ss, + size_t max_bytes_per_write, long unsigned current_chunk, + const char *buf, size_t len, const char *header_buf, + size_t header_len); +void init_sender_status(struct sender_status *ss, char **access_arg, int num_access_args, + int port, int max_clients, int default_deny); +char *get_sender_info(struct sender_status *ss, char *name); + +void generic_com_allow(struct sender_command_data *scd, + struct sender_status *ss); +void generic_com_deny(struct sender_command_data *scd, + struct sender_status *ss); +int generic_com_on(struct sender_status *ss, unsigned protocol); +void generic_com_off(struct sender_status *ss); +char *generic_sender_help(void); +struct sender_client *accept_sender_client(struct sender_status *ss);