X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=write.c;h=2efe07ce730264be610fc35adc2bc1cdd9fc0721;hp=b692ac5080af8dfee4efd79a95048e6c8ad6999d;hb=4b6458e9fc11eb741200dfebd8dc96a333956e4b;hpb=4255eeea6a72f82d4b57a8c6f6b218ecd0d04afc

diff --git a/write.c b/write.c
index b692ac50..2efe07ce 100644
--- a/write.c
+++ b/write.c
@@ -161,6 +161,17 @@ out:
 	return NULL;
 }
 
+static void wng_event_handler(struct task *t)
+{
+	struct writer_node_group *g = t->private_data;
+
+	PARA_INFO_LOG("%s\n", PARA_STRERROR(-t->ret));
+	unregister_task(t);
+	wng_close(g);
+	wng_destroy(g);
+}
+
+
 static void idt_event_handler(struct task *t)
 {
 	int ret;
@@ -170,6 +181,7 @@ static void idt_event_handler(struct task *t)
 	wng->buf = sit.buf;
 	wng->loaded = &sit.loaded;
 	wng->input_eof = &sit.eof;
+	wng->task.event_handler = wng_event_handler;
 	ret = wng_open(wng);
 	if (ret < 0) {
 		PARA_ERROR_LOG("%s\n", PARA_STRERROR(-ret));