]> git.tuebingen.mpg.de Git - paraslash.git/blobdiff - http_recv.c
Remove ->shutdown of struct receiver.
[paraslash.git] / http_recv.c
index b81ba8023ea080d42c502a474a198395d223f6ea..a8c982e66fbe069f39141be3124a4ccd2fd60808 100644 (file)
@@ -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) {