X-Git-Url: http://git.tuebingen.mpg.de/?a=blobdiff_plain;f=udp_recv.c;h=6637988a3fa4d2efdda8734988fa4f4801bfdb47;hb=3dd2078d278f922cb373dc7ed36fa2b18367098f;hp=3d680814c163816cd8dd8cdbe9f579a955c5b4fc;hpb=5f303cc5a96bfeaa66d2d6e899bf56d1d03ed085;p=paraslash.git diff --git a/udp_recv.c b/udp_recv.c index 3d680814..6637988a 100644 --- a/udp_recv.c +++ b/udp_recv.c @@ -152,18 +152,12 @@ static void udp_recv_post_select(__a_unused struct sched *s, struct task *t) udp_recv_post_select_nobtr(s, t); } -static void udp_shutdown(void) -{ - return; -} - static void udp_recv_close(struct receiver_node *rn) { struct private_udp_recv_data *purd = rn->private_data; if (purd->fd >= 0) close(purd->fd); - PARA_CRIT_LOG("%p: close\n", rn); btr_pool_free(purd->btrp); free(rn->private_data); free(rn->buf); @@ -270,7 +264,7 @@ static int udp_recv_open(struct receiver_node *rn) close(purd->fd); goto err; } - PARA_CRIT_LOG("rn %p: receiving from %s:%d, fd=%d\n", rn, c->host_arg, + PARA_INFO_LOG("receiving from %s:%d, fd=%d\n", c->host_arg, c->port_arg, purd->fd); purd->btrp = btr_pool_new("udp_recv", 320 * 1024); return purd->fd; @@ -297,7 +291,6 @@ void udp_recv_init(struct receiver *r) struct udp_recv_args_info dummy; udp_recv_cmdline_parser_init(&dummy); - r->shutdown = udp_shutdown; r->open = udp_recv_open; r->close = udp_recv_close; r->pre_select = udp_recv_pre_select;