X-Git-Url: http://git.tuebingen.mpg.de/?a=blobdiff_plain;f=write_common.c;h=6c0faa7c18fb70c5421426bd81be0e207a41bc54;hb=b0cad48a864fe3f621138e717ff025060c396fad;hp=0b2772ae8ea4d6928b828aa8bb2e2c5916833309;hpb=37db6c718cbd9e350d46703c36dc6860477de476;p=paraslash.git

diff --git a/write_common.c b/write_common.c
index 0b2772ae..6c0faa7c 100644
--- a/write_common.c
+++ b/write_common.c
@@ -45,7 +45,7 @@ static void wng_post_select(struct sched *s, struct task *t)
 			min_written = PARA_MIN(min_written, t->ret);
 	}
 	*g->loaded -= min_written;
-	if (!*g->loaded && *g->eof)
+	if (!*g->loaded && *g->input_eof)
 		t->ret = -E_WNG_EOF;
 	else
 		t->ret = 1;
@@ -72,6 +72,8 @@ int wng_open(struct writer_node_group *g)
 		wn->task.private_data = wn;
 		register_task(&wn->task);
 	}
+	sprintf(g->task.status, "%s", "writer node group");
+	g->eof = 0;
 	register_task(&g->task);
 out:
 	return ret;