A
lgorithmique
N
umérique
D
istribuée
Public GIT Repository
projects
/
simgrid.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Kill non-portable comment
[simgrid.git]
/
src
/
gras
/
Msg
/
rpc.c
diff --git
a/src/gras/Msg/rpc.c
b/src/gras/Msg/rpc.c
index
a3c09c5
..
1cef669
100644
(file)
--- a/
src/gras/Msg/rpc.c
+++ b/
src/gras/Msg/rpc.c
@@
-19,8
+19,8
@@
XBT_LOG_NEW_DEFAULT_SUBCATEGORY(gras_rpc,gras_msg,"RPC mecanism");
/** @brief declare a new versionned RPC type of the given name and payloads
*
* @param name: name as it should be used for logging messages (must be uniq)
/** @brief declare a new versionned RPC type of the given name and payloads
*
* @param name: name as it should be used for logging messages (must be uniq)
- * @param
version: something like versionning symbol
- * @param payload
: datadescription of the payload
+ * @param
payload_request: datatype of request
+ * @param payload
_answer: datatype of answer
*
* Registers a new RPC message to the GRAS mechanism. RPC are constituted of a pair
* of messages.
*
* Registers a new RPC message to the GRAS mechanism. RPC are constituted of a pair
* of messages.
@@
-40,7
+40,8
@@
gras_msgtype_declare_rpc(const char *name,
*
* @param name: name as it should be used for logging messages (must be uniq)
* @param version: something like versionning symbol
*
* @param name: name as it should be used for logging messages (must be uniq)
* @param version: something like versionning symbol
- * @param payload: datadescription of the payload
+ * @param payload_request: datatype of request
+ * @param payload_answer: datatype of answer
*
* Registers a new RPC message to the GRAS mechanism. RPC are constituted of a pair
* of messages.
*
* Registers a new RPC message to the GRAS mechanism. RPC are constituted of a pair
* of messages.
@@
-86,7
+87,10
@@
void gras_msg_rpccall(gras_socket_t server,
unsigned long int msg_ID = last_msg_ID++;
s_gras_msg_t received;
unsigned long int msg_ID = last_msg_ID++;
s_gras_msg_t received;
- DEBUG2("Send a RPC of type '%s' (ID=%lu)",msgtype->name,msg_ID);
+ DEBUG4("Send to %s:%d a RPC of type '%s' (ID=%lu)",
+ gras_socket_peer_name(server),
+ gras_socket_peer_port(server),
+ msgtype->name,msg_ID);
gras_msg_send_ext(server, e_gras_msg_kind_rpccall, msg_ID, msgtype, request);
gras_msg_wait_ext(timeOut,
gras_msg_send_ext(server, e_gras_msg_kind_rpccall, msg_ID, msgtype, request);
gras_msg_wait_ext(timeOut,