X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=udp_recv.c;h=2657beec952059a58cac468f02d0dc2d3350777c;hp=61b5312f520c9a3f5ed0a511695e0c28db1fda2a;hb=49c897ce4cffb9ab355540043cd85d22d9a78299;hpb=a512404111e4134a300e8da66fcacc12cd05f2a9 diff --git a/udp_recv.c b/udp_recv.c index 61b5312f..2657beec 100644 --- a/udp_recv.c +++ b/udp_recv.c @@ -23,8 +23,6 @@ #include "fd.h" #include "buffer_tree.h" -/** The size of the receiver node buffer. */ -#define UDP_RECV_CHUNK_SIZE (128 * 1024) /** * Data specific to the udp receiver. * @@ -97,7 +95,6 @@ static void udp_recv_close(struct receiver_node *rn) close(purd->fd); btr_pool_free(purd->btrp); free(rn->private_data); - free(rn->buf); } static void *udp_recv_parse_config(int argc, char **argv) @@ -181,7 +178,6 @@ static int udp_recv_open(struct receiver_node *rn) char *iface = c->iface_given ? c->iface_arg : NULL; int ret; - rn->buf = para_calloc(UDP_RECV_CHUNK_SIZE); rn->private_data = para_calloc(sizeof(struct private_udp_recv_data)); purd = rn->private_data; @@ -207,7 +203,6 @@ static int udp_recv_open(struct receiver_node *rn) return purd->fd; err: free(rn->private_data); - free(rn->buf); return ret; }