X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=recv.c;h=7b46d78cac4602b1032508818c710fbcd2b0cc98;hp=3a3d142692aeab0018c13770d7eab1a94502cccc;hb=a35c113e0bb9fa9ac02b77eb01dd32f49cd5c8d0;hpb=2c679eeb8bbc93220f85403eca6e9380dc624a6a diff --git a/recv.c b/recv.c index 3a3d1426..7b46d78c 100644 --- a/recv.c +++ b/recv.c @@ -1,60 +1,56 @@ -/* - * Copyright (C) 2005-2007 Andre Noll - * - * Licensed under the GPL v2. For licencing details see COPYING. - */ +/* Copyright (C) 2005 Andre Noll , see file COPYING. */ /** \file recv.c the stand-alone audio stream receiver */ +#include #include -#include +#include +#include "recv_cmd.lsg.h" +#include "recv.lsg.h" #include "para.h" #include "list.h" #include "sched.h" +#include "buffer_tree.h" #include "recv.h" -#include "recv.cmdline.h" #include "fd.h" +#include "string.h" #include "error.h" #include "stdout.h" +#include "version.h" -/** the gengetopt args info struct */ -struct recv_args_info conf; +/** Array of error strings. */ +DEFINE_PARA_ERRLIST; -/** always log to stderr */ -INIT_STDERR_LOGGING(conf.loglevel_arg); +#define CMD_PTR (lls_cmd(0, recv_suite)) +#define OPT_RESULT(_name, _lpr) \ + (lls_opt_result(LSG_RECV_PARA_RECV_OPT_ ## _name, lpr)) +#define OPT_GIVEN(_name, _lpr) (lls_opt_given(OPT_RESULT(_name, _lpr))) +#define OPT_UINT32_VAL(_name, _lpr) (lls_uint32_val(0, OPT_RESULT(_name, _lpr))) +#define OPT_STRING_VAL(_name, _lpr) (lls_string_val(0, OPT_RESULT(_name, _lpr))) -/** init array of error codes used by para_recv */ -INIT_RECV_ERRLISTS; +static int loglevel; +/** Always log to stderr. */ +INIT_STDERR_LOGGING(loglevel); -static void *parse_config(int argc, char *argv[], int *receiver_num) +static void handle_help_flag(struct lls_parse_result *lpr) { - int i; - - if (recv_cmdline_parser(argc, argv, &conf)) - return NULL; - HANDLE_VERSION_FLAG("recv", conf); - if (conf.list_receivers_given) { - printf("available receivers: "); - for (i = 0; receivers[i].name; i++) - printf("%s%s", i? " " : "", receivers[i].name); - printf("\nTry\n\tpara_recv -r ' -h'\n" - "for help on .\n"); - exit(EXIT_SUCCESS); - } - return check_receiver_arg(conf.receiver_arg, receiver_num); -} + char *help; -static void rn_event_handler(struct task *t) -{ - struct receiver_node *rn = t->private_data; - PARA_NOTICE_LOG("%s\n", PARA_STRERROR(-t->ret)); - rn->eof = 1; - unregister_task(t); + if (OPT_GIVEN(DETAILED_HELP, lpr)) + help = lls_long_help(CMD_PTR); + else if (OPT_GIVEN(HELP, lpr)) + help = lls_short_help(CMD_PTR); + else + return; + printf("%s\n", help); + free(help); + print_receiver_helps(OPT_GIVEN(DETAILED_HELP, lpr)); + exit(EXIT_SUCCESS); } /** - * the main function of para_recv + * The main function of para_recv. * * \param argc number of arguments * \param argv vector of arguments @@ -66,51 +62,64 @@ static void rn_event_handler(struct task *t) */ int main(int argc, char *argv[]) { - int ret, r_opened = 0, receiver_num; - struct receiver *r = NULL; + int ret; + const struct receiver *r = NULL; struct receiver_node rn; - struct stdout_task sot; - struct sched s; + struct stdout_task sot = {.btrn = NULL}; + static struct sched s; + struct task_info ti; + const struct lls_command *cmd; + struct lls_parse_result *lpr; /* command line */ + struct lls_parse_result *receiver_lpr; /* receiver specific options */ + char *errctx; - s.default_timeout.tv_sec = 1; - s.default_timeout.tv_usec = 0; - - memset(&rn, 0, sizeof(struct receiver_node)); - for (ret = 0; receivers[ret].name; ret++) - receivers[ret].init(&receivers[ret]); - ret = -E_RECV_SYNTAX; - rn.conf = parse_config(argc, argv, &receiver_num); - if (!rn.conf) { - PARA_EMERG_LOG("%s", "parse failed\n"); + ret = lls(lls_parse(argc, argv, CMD_PTR, &lpr, &errctx)); + if (ret < 0) goto out; - } - r = &receivers[receiver_num]; + loglevel = OPT_UINT32_VAL(LOGLEVEL, lpr); + version_handle_flag("recv", OPT_GIVEN(VERSION, lpr)); + handle_help_flag(lpr); + recv_init(); + memset(&rn, 0, sizeof(struct receiver_node)); + ret = check_receiver_arg(OPT_STRING_VAL(RECEIVER, lpr), &receiver_lpr); + if (ret < 0) + goto free_lpr; + cmd = lls_cmd(ret, recv_cmd_suite); + r = lls_user_data(cmd); rn.receiver = r; + rn.lpr = receiver_lpr; + rn.btrn = btr_new_node(&(struct btr_node_description) + EMBRACE(.name = lls_command_name(cmd))); ret = r->open(&rn); if (ret < 0) - goto out; - r_opened = 1; + goto remove_btrn; + sot.btrn = btr_new_node(&(struct btr_node_description) + EMBRACE(.parent = rn.btrn, .name = "stdout")); + stdout_task_register(&sot, &s); - stdout_set_defaults(&sot); - sot.buf = rn.buf; - sot.loaded = &rn.loaded; - sot.input_eof = &rn.eof; - register_task(&sot.task); + ti.name = lls_command_name(cmd); + ti.pre_select = r->pre_select; + ti.post_select = r->post_select; + ti.context = &rn; + rn.task = task_register(&ti, &s); - rn.task.private_data = &rn; - rn.task.pre_select = r->pre_select; - rn.task.post_select = r->post_select; - rn.task.event_handler = rn_event_handler; - sprintf(rn.task.status, "receiver node"); - register_task(&rn.task); - - ret = sched(&s); + s.default_timeout.tv_sec = 1; + s.default_timeout.tv_usec = 0; + ret = schedule(&s); + sched_shutdown(&s); + r->close(&rn); + btr_remove_node(&sot.btrn); +remove_btrn: + btr_remove_node(&rn.btrn); + lls_free_parse_result(receiver_lpr, cmd); +free_lpr: + lls_free_parse_result(lpr, CMD_PTR); out: - if (r_opened) - r->close(&rn); - if (r) - r->shutdown(); - if (ret < 0) - PARA_ERROR_LOG("%s\n", PARA_STRERROR(-ret)); + if (ret < 0) { + if (errctx) + PARA_ERROR_LOG("%s\n", errctx); + free(errctx); + PARA_ERROR_LOG("%s\n", para_strerror(-ret)); + } return ret < 0? EXIT_FAILURE : EXIT_SUCCESS; }