X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=write_common.c;h=4619d40702338901d3437a4989afaf54889e334d;hp=dcf7bb166ade3f9efa4d04afd4fb55e67e9c2d8e;hb=f87868b3147b189b6d4ee4e44817f092bd1c2895;hpb=343f3c63fc3a7f9ca4ba4163c9e4cf06cde8d0c3 diff --git a/write_common.c b/write_common.c index dcf7bb16..4619d407 100644 --- a/write_common.c +++ b/write_common.c @@ -27,6 +27,8 @@ static void wng_pre_select(__a_unused struct sched *s, struct task *t) FOR_EACH_WRITER_NODE(i, g) { struct writer_node *wn = &g->writer_nodes[i]; + if (!wn->writer->pre_select) + continue; t->error = wn->writer->pre_select(s, wn); if (t->error < 0) return; @@ -97,7 +99,9 @@ err_out: struct writer_node *wn = &g->writer_nodes[--i]; wn->writer->close(wn); } + free(g->writer_nodes); g->num_writers = 0; + g->task.error = -E_TASK_UNREGISTERED; return ret; }