X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=write.c;h=3b5f2d193f31ddc1d8c130703637810f807f255f;hp=9762c40cd8e2b85dab8e0281eed1adc4c5acae86;hb=784c2391535a896aff0e51bf3976b52bf9f06b71;hpb=f2dfd6d47a71433c530773cfbf4039de8b065369 diff --git a/write.c b/write.c index 9762c40c..3b5f2d19 100644 --- a/write.c +++ b/write.c @@ -185,26 +185,24 @@ __noreturn static void print_help_and_die(void) * * \return Standard. */ -static int setup_writer_node(const char *arg, struct btr_node *parent, +static void setup_writer_node(const char *arg, struct btr_node *parent, struct writer_node *wn) { if (arg) - wn->conf = check_writer_arg(arg, &wn->writer_num); + wn->conf = check_writer_arg_or_die(arg, &wn->writer_num); else { wn->writer_num = DEFAULT_WRITER; wn->conf = writers[DEFAULT_WRITER].parse_config_or_die(""); } - if (!wn->conf) - return -E_WRITE_COMMON_SYNTAX; register_writer_node(wn, parent); - return 1; } -static int main_btr(struct sched *s) +static int setup_and_schedule(void) { int i, ret; struct check_wav_task _cwt, *cwt = &_cwt; struct writer_node *wns; + static struct sched s; loglevel = get_loglevel_by_name(conf.loglevel_arg); sit.btrn = btr_new_node(&(struct btr_node_description) @@ -223,27 +221,20 @@ static int main_btr(struct sched *s) cwt->task.error = 0; register_task(&cwt->task); - ret = -E_WRITE_SYNTAX; if (!conf.writer_given) { - i = 0; wns = para_calloc(sizeof(*wns)); - ret = setup_writer_node(NULL, cwt->btrn, wns); - if (ret < 0) - goto out; + setup_writer_node(NULL, cwt->btrn, wns); i = 1; } else { wns = para_calloc(conf.writer_given * sizeof(*wns)); - for (i = 0; i < conf.writer_given; i++) { - ret = setup_writer_node(conf.writer_arg[i], - cwt->btrn, wns + i); - if (ret < 0) - goto out; - } + for (i = 0; i < conf.writer_given; i++) + setup_writer_node(conf.writer_arg[i], cwt->btrn, + wns + i); } - s->default_timeout.tv_sec = 10; - s->default_timeout.tv_usec = 50000; - ret = schedule(s); + s.default_timeout.tv_sec = 10; + s.default_timeout.tv_usec = 50000; + ret = schedule(&s); if (ret >= 0) { int j; for (j = 0; j < i; j++) { @@ -258,7 +249,6 @@ static int main_btr(struct sched *s) } } } -out: for (i--; i >= 0; i--) { struct writer_node *wn = wns + i; struct writer *w = writers + wn->writer_num; @@ -286,8 +276,7 @@ out: */ int main(int argc, char *argv[]) { - int ret = -E_WRITE_SYNTAX; - static struct sched s; + int ret; writer_init(); write_cmdline_parser(argc, argv, &conf); @@ -295,7 +284,7 @@ int main(int argc, char *argv[]) if (conf.help_given || conf.detailed_help_given) print_help_and_die(); - ret = main_btr(&s); + ret = setup_and_schedule(); if (ret < 0) { PARA_ERROR_LOG("%s\n", para_strerror(-ret)); exit(EXIT_FAILURE);