X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=http_recv.c;h=48673afb478aadd242d5ad4829d78623beedf1f9;hp=b4bf1530d811fefb04c4f5b107e752e45d8e9048;hb=e541d7bea7febed8cb9f8a65ae4bd9bdd1b5c8a0;hpb=39ec52d7bfec591dcad0d41bcdbdf6d980bf5913 diff --git a/http_recv.c b/http_recv.c index b4bf1530..48673afb 100644 --- a/http_recv.c +++ b/http_recv.c @@ -15,12 +15,12 @@ #include "list.h" #include "sched.h" #include "ggo.h" +#include "buffer_tree.h" #include "recv.h" #include "http_recv.cmdline.h" #include "net.h" #include "string.h" #include "fd.h" -#include "buffer_tree.h" /** * the possible states of a http receiver node @@ -83,7 +83,9 @@ static void http_recv_post_select(struct sched *s, struct task *t) struct iovec iov[2]; size_t num_bytes; - t->error = 0; + ret = task_get_notification(t); + if (ret < 0) + goto out; ret = btr_node_status(btrn, 0, BTR_NT_ROOT); if (ret < 0) goto out; @@ -128,7 +130,7 @@ static void http_recv_post_select(struct sched *s, struct task *t) out: if (ret >= 0) return; - btr_remove_node(rn->btrn); + btr_remove_node(&rn->btrn); t->error = ret; }