err = sg_comm_wait_for(comm, timeout);
if (err == SG_ERROR_TIMEOUT) {
XBT_DEBUG("Timeout expired when forwarding join to next %d", next);
+ xbt_free(request);
break;
}
type = JOIN_REPLY;
err = sg_comm_wait_for(comm, timeout);
if (err == SG_ERROR_TIMEOUT) {
XBT_DEBUG("Timeout expired when sending back the current node state to the joining node to %d", node->id);
+ message_free(request);
}
break;
/* Join reply from all the node touched by the join */
err = sg_comm_wait_for(comm, timeout);
if (err == SG_ERROR_TIMEOUT) {
XBT_DEBUG("Timeout expired when sending update to %d", j);
+ message_free(request);
break;
}
}