X-Git-Url: http://git.tuebingen.mpg.de/?a=blobdiff_plain;f=udp_send.c;h=8677ec5eeea4c17fcd0a5b9f7918fc47ea961c35;hb=ffb82bb4f4e34c36653a06c8ae90c6e5db0fdcd8;hp=7217c960c6597123701338aa2dfedcbcc31115b3;hpb=d353d447b837c65aeda3969bb43d4cf82aa66d11;p=paraslash.git diff --git a/udp_send.c b/udp_send.c index 7217c960..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);