X-Git-Url: http://git.tuebingen.mpg.de/?a=blobdiff_plain;f=udp_send.c;h=8677ec5eeea4c17fcd0a5b9f7918fc47ea961c35;hb=4d5a9b90c3e9cbdff019776d05792beb57fbfa31;hp=0838d0283f8d78e4ab375096312d3df2610da393;hpb=4cc509155034d2079a8ba8d697003c9603ea6a6d;p=paraslash.git diff --git a/udp_send.c b/udp_send.c index 0838d028..8677ec5e 100644 --- a/udp_send.c +++ b/udp_send.c @@ -179,9 +179,7 @@ static int udp_init_session(struct udp_target *ut) } add_close_on_fork_list(ut->fd); ut->cq = cq_new(UDP_CQ_BYTES); - PARA_NOTICE_LOG("sending to udp %s#%d using fec parms %d:%d:%d\n", - ut->host, ut->port , ut->fcp.max_slice_bytes, - ut->fcp.data_slices_per_group, ut->fcp.slices_per_group); + PARA_NOTICE_LOG("sending to udp %s#%d\n", ut->host, ut->port); return 1; } @@ -232,8 +230,11 @@ static int udp_com_delete(struct sender_command_data *scd) static int udp_send_fec(char *buf, size_t len, void *private_data) { struct udp_target *ut = private_data; - int ret = udp_init_session(ut); + int ret; + if (sender_status == SENDER_OFF) + return 0; + ret = udp_init_session(ut); if (ret < 0) goto fail; ret = send_queued_chunks(ut->fd, ut->cq, 0); @@ -349,7 +350,7 @@ static char *udp_help(void) /** * The init function of para_server's udp sender. * - * \param s Pointer to the http sender struct. + * \param s Pointer to the udp sender struct. * * It initializes all function pointers of \a s and the list of udp targets. */