From 949138b814880ec20e78ab4d36d7ace8e90b63d2 Mon Sep 17 00:00:00 2001 From: mquinson Date: Sun, 9 Jul 2006 09:11:48 +0000 Subject: [PATCH] Deal properly with assymetric RPCs git-svn-id: svn+ssh://scm.gforge.inria.fr/svn/simgrid/simgrid/trunk@2507 48e7efb5-ca39-0410-a469-dd3cf9ba447f --- src/gras/Msg/rl_msg.c | 14 ++++++++++++++ 1 file changed, 14 insertions(+) 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) { -- 2.20.1