X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=vss.c;h=b73562f9733a98e1bea760ea109f1a7cf883d426;hp=3632cf54557350f35dc19ec8a2ce07ce9a6d5c0f;hb=96c1602f28d5ef601bad10941cf079686fc67dfd;hpb=8d106ca317a2c42f35a86ba244f843688f6939e6 diff --git a/vss.c b/vss.c index 3632cf54..b73562f9 100644 --- a/vss.c +++ b/vss.c @@ -1032,8 +1032,7 @@ static void vss_send(struct vss_task *vsst) return; if (chk_barrier("eof", &vsst->eof_barrier, &due, 1) < 0) return; - if (chk_barrier("data send", &vsst->data_send_barrier, - &due, 1) < 0) + if (chk_barrier("data send", &vsst->data_send_barrier, &due, 1) < 0) return; list_for_each_entry_safe(fc, tmp_fc, &fec_client_list, node) { if (fc->state == FEC_STATE_DISABLED) @@ -1046,9 +1045,9 @@ static void vss_send(struct vss_task *vsst) continue; PARA_DEBUG_LOG("sending %u:%u (%u bytes)\n", fc->group.num, fc->current_slice_num, fc->group.slice_bytes); + fc->current_slice_num++; fc->fcp->send_fec(fc->sc, (char *)fc->enc_buf, fc->group.slice_bytes + FEC_HEADER_SIZE); - fc->current_slice_num++; fec_active = 1; } if (mmd->current_chunk >= mmd->afd.afhi.chunks_total) { /* eof */