X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=file_write.c;h=7a24b3ac6b78e9d56b1f194c0479c3584cabbfb3;hp=8baaa8420a4aea56b0b315956fda7f5d9e0c7698;hb=0750c5dfa5404cdc6baef58cc1fc6b56fc2b5f43;hpb=b71a84c94992821c4bd70f80a2fdb3d4e9a39a62 diff --git a/file_write.c b/file_write.c index 8baaa842..7a24b3ac 100644 --- a/file_write.c +++ b/file_write.c @@ -96,7 +96,7 @@ static void file_write_pre_select_btr(struct sched *s, struct task *t) t->error = 0; pfwd->check_fd = 0; - ret = btr_node_status(wn->btrn, wn->min_iqs); + ret = btr_node_status(wn->btrn, wn->min_iqs, BTR_NT_LEAF); if (ret > 0) { para_fd_set(pfwd->fd, &s->wfds, &s->max_fileno); pfwd->check_fd = 1; @@ -147,7 +147,7 @@ static void file_write_post_select_btr(__a_unused struct sched *s, size_t bytes; t->error = 0; - ret = btr_node_status(btrn, wn->min_iqs); + ret = btr_node_status(btrn, wn->min_iqs, BTR_NT_LEAF); if (ret == 0) return; if (ret < 0) @@ -182,6 +182,11 @@ __malloc static void *file_write_parse_config(const char *options) return NULL; } +static void file_write_free_config(void *conf) +{ + file_cmdline_parser_free(conf); +} + /** the init function of the file writer */ void file_write_init(struct writer *w) { @@ -194,6 +199,7 @@ void file_write_init(struct writer *w) w->post_select = file_write_post_select; w->post_select_btr = file_write_post_select_btr; w->parse_config = file_write_parse_config; + w->free_config = file_write_free_config; w->close = file_write_close; w->shutdown = NULL; /* nothing to do */ w->help = (struct ggo_help) {