+/* declaration */
+XBT_PUBLIC(void) gras_msgtype_declare_rpc(const char *name,
+ xbt_datadesc_type_t
+ payload_request,
+ xbt_datadesc_type_t
+ payload_answer);
+
+XBT_PUBLIC(void) gras_msgtype_declare_rpc_v(const char *name,
+ short int version,
+ xbt_datadesc_type_t
+ payload_request,
+ xbt_datadesc_type_t
+ payload_answer);
+
+/* client side */
+
+/** @brief Conduct a RPC call
+ * @hideinitializer
+ */
+#define gras_msg_rpccall(server,timeout,msg,req,ans) gras_msg_rpccall_(server,timeout,gras_msgtype_by_name(msg),req,ans)
+XBT_PUBLIC(void) gras_msg_rpccall_(xbt_socket_t server,
+ double timeOut,
+ gras_msgtype_t msgtype,
+ void *request, void *answer);
+XBT_PUBLIC(gras_msg_cb_ctx_t)
+
+/** @brief Launch a RPC call, but do not block for the answer
+ * @hideinitializer
+ */
+#define gras_msg_rpc_async_call(server,timeout,msg,req) gras_msg_rpc_async_call_(server,timeout,gras_msgtype_by_name(msg),req)
+ gras_msg_rpc_async_call_(xbt_socket_t server,
+ double timeOut,
+ gras_msgtype_t msgtype, void *request);
+XBT_PUBLIC(void) gras_msg_rpc_async_wait(gras_msg_cb_ctx_t ctx,
+ void *answer);
+
+/* server side */
+XBT_PUBLIC(void) gras_msg_rpcreturn(double timeOut, gras_msg_cb_ctx_t ctx,
+ void *answer);
+
+
+/** @} */
+
+/** @defgroup GRAS_msg_exchangeadv Message exchange (advanced interface)
+ * @ingroup GRAS_msg
+ *
+ */
+/** @{ */
+
+/** @brief Message kind (internal enum) */
+typedef enum {
+ e_gras_msg_kind_unknown = 0,
+
+ e_gras_msg_kind_oneway = 1,
+ /**< good old regular messages */
+
+ e_gras_msg_kind_rpccall = 2,
+ /**< RPC request */
+ /* HACK: e_gras_msg_kind_rpccall also designate RPC message *type* in
+ msgtype_t, not only in msg_t */
+ e_gras_msg_kind_rpcanswer = 3,
+ /**< RPC successful answer */
+ e_gras_msg_kind_rpcerror = 4,
+ /**< RPC failure on server (payload=exception); should not leak to user-space */
+
+ /* future:
+ call cancel, and others
+ even after:
+ forwarding request and other application level routing stuff
+ group communication
+ */
+
+ e_gras_msg_kind_count = 5 /* sentinel, don't mess with */
+} e_gras_msg_kind_t;
+
+
+/** @brief Message instance (internal struct) */
+typedef struct {
+ xbt_socket_t expe;
+ e_gras_msg_kind_t kind;
+ gras_msgtype_t type;
+ unsigned long int ID;
+ void *payl;
+ int payl_size;
+} s_gras_msg_t, *gras_msg_t;
+
+typedef int (*gras_msg_filter_t) (gras_msg_t msg, void *ctx);
+
+#define gras_msg_wait_ext(timeout, msg, expe, filter, fctx,got) gras_msg_wait_ext_(timeout, gras_msgtype_by_name(msg), expe, filter, fctx,got)
+XBT_PUBLIC(void) gras_msg_wait_ext_(double timeout,
+ gras_msgtype_t msgt_want,
+ xbt_socket_t expe_want,
+ gras_msg_filter_t filter,
+ void *filter_ctx, gras_msg_t msg_got);
+
+XBT_PUBLIC(void) gras_msg_wait_or(double timeout,
+ xbt_dynar_t msgt_want,
+ gras_msg_cb_ctx_t * ctx,
+ int *msgt_got, void *payload);