X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=write.c;h=6b574414b6b13c227c98b008addd28f4b2302b33;hp=2ea9d2132bee5f64224f3f9d635af8f83777a33e;hb=656a02453498156bab09763011ff43b81db57634;hpb=10b9efd6235b3b14214f4a84b3f4e17c1b11bd1a diff --git a/write.c b/write.c index 2ea9d213..6b574414 100644 --- a/write.c +++ b/write.c @@ -8,7 +8,6 @@ #include #include -#include #include #include "para.h" @@ -23,6 +22,7 @@ #include "write_common.h" #include "fd.h" #include "error.h" +#include "version.h" INIT_WRITE_ERRLISTS; @@ -209,6 +209,20 @@ static int main_btr(struct sched *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++) { + struct task *t = &wns[j].task; + assert(t->error < 0); + if (t->error != -E_WRITE_COMMON_EOF + && t->error != -E_BTR_EOF) { + PARA_ERROR_LOG("%s: %s\n", t->status, + para_strerror(-t->error)); + if (ret >= 0) + ret = t->error; + } + } + } out: for (i--; i >= 0; i--) { struct writer_node *wn = wns + i;