X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=vss.c;h=adc0cb63cea1204d3bfef811c492b807b74001c2;hp=14cff6960eb2ef1dcfbff1f03dee7da4e3cb6a18;hb=645175864a613fc539f46ffa4028742aad3b1b30;hpb=96dd1284a1b7d565560979fdc7ec647aeceb6b52 diff --git a/vss.c b/vss.c index 14cff696..adc0cb63 100644 --- a/vss.c +++ b/vss.c @@ -169,8 +169,6 @@ struct fec_client { int num_extra_slices; /** Contains the FEC-encoded data. */ unsigned char *enc_buf; - /** Pointer obtained from sender when the client is added. */ - void *private_data; }; /** @@ -956,8 +954,12 @@ static void vss_post_select(struct sched *s, struct task *t) int num = mmd->sender_cmd_data.cmd_num, sender_num = mmd->sender_cmd_data.sender_num; - if (senders[sender_num].client_cmds[num]) - senders[sender_num].client_cmds[num](&mmd->sender_cmd_data); + if (senders[sender_num].client_cmds[num]) { + ret = senders[sender_num].client_cmds[num] + (&mmd->sender_cmd_data); + if (ret < 0) + PARA_ERROR_LOG("%s\n", para_strerror(-ret)); + } mmd->sender_cmd_data.cmd_num = -1; } if (vsst->afsss != AFS_SOCKET_CHECK_FOR_WRITE)