X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=udp_recv.c;h=d899e43933eddc9c72de93354ada14c3a607012a;hp=61b5312f520c9a3f5ed0a511695e0c28db1fda2a;hb=694d9ae83695e54ffbb51acb1db0496c4281f4b4;hpb=a512404111e4134a300e8da66fcacc12cd05f2a9 diff --git a/udp_recv.c b/udp_recv.c index 61b5312f..d899e439 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,13 +203,13 @@ static int udp_recv_open(struct receiver_node *rn) return purd->fd; err: free(rn->private_data); - free(rn->buf); return ret; } static void udp_recv_free_config(void *conf) { udp_recv_cmdline_parser_free(conf); + free(conf); } /**