X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dd31c88767cdfc44114e2f0a79ae153621a4caec..778f65057da68465382593cd036b6ee59ada54e9:/src/gras/Msg/rl_msg.c?ds=sidebyside diff --git a/src/gras/Msg/rl_msg.c b/src/gras/Msg/rl_msg.c index fecc8cb59b..a4c4e160d5 100644 --- a/src/gras/Msg/rl_msg.c +++ b/src/gras/Msg/rl_msg.c @@ -149,6 +149,20 @@ gras_msg_recv(gras_socket_t sock, msg->payl=xbt_malloc(msg->payl_size); gras_datadesc_recv(sock, gras_datadesc_by_name("ex_t"), r_arch, msg->payl); + } else if (msg->kind == e_gras_msg_kind_rpcanswer) { + /* answer to RPC */ + if (msg->type->answer_type) { + msg->payl_size=gras_datadesc_size(msg->type->answer_type); + xbt_assert2(msg->payl_size > 0, + "%s %s", + "Dynamic array as payload is forbided for now (FIXME?).", + "Reference to dynamic array is allowed."); + msg->payl = xbt_malloc(msg->payl_size); + gras_datadesc_recv(sock, msg->type->answer_type, r_arch, msg->payl); + } else { + msg->payl = NULL; + msg->payl_size = 0; + } } else { /* regular message */ if (msg->type->ctn_type) {