X-Git-Url: http://git.tuebingen.mpg.de/?a=blobdiff_plain;f=http_recv.c;h=a8c982e66fbe069f39141be3124a4ccd2fd60808;hb=65d6f677cb6f79c69b8b35c5b3fe6aa337dbfb23;hp=b81ba8023ea080d42c502a474a198395d223f6ea;hpb=ff63e4b709e037fda044beae858f494e2868e7d7;p=paraslash.git diff --git a/http_recv.c b/http_recv.c index b81ba802..a8c982e6 100644 --- a/http_recv.c +++ b/http_recv.c @@ -68,11 +68,6 @@ struct private_http_recv_data { struct btr_pool *btrp; }; -static void http_shutdown(void) -{ - return; -} - static char *make_request_msg(void) { char *ret, *hn = para_hostname(); @@ -159,8 +154,7 @@ static void http_recv_post_select(struct sched *s, struct task *t) ret = -E_RECV_EOF; if (ret < 0) goto err; - btr_pool_allocate(phd->btrp, ret); - btr_add_output_pool(phd->btrp, buf, ret, btrn); + btr_add_output_pool(phd->btrp, ret, btrn); return; } ret = -E_HTTP_RECV_OVERRUN; @@ -219,7 +213,7 @@ static int http_recv_open(struct receiver_node *rn) rn->private_data = phd = para_calloc(sizeof(struct private_http_recv_data)); phd->fd = fd; phd->status = HTTP_CONNECTED; - phd->btrp = btr_pool_new(320 * 1024); + phd->btrp = btr_pool_new("http_recv", 320 * 1024); return 1; } @@ -244,7 +238,6 @@ void http_recv_init(struct receiver *r) r->close = http_recv_close; r->pre_select = http_recv_pre_select; r->post_select = http_recv_post_select; - r->shutdown = http_shutdown; r->parse_config = http_recv_parse_config; r->free_config = http_recv_free_config; r->help = (struct ggo_help) {