X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/41a0af5d6003337f4ca3b3aed6f5757293bddab5..5a3ad5e2d39b008be6c9467aa387b8358076f12c:/src/gras/Msg/msg_private.h diff --git a/src/gras/Msg/msg_private.h b/src/gras/Msg/msg_private.h index cb421671f7..7b03a7ae15 100644 --- a/src/gras/Msg/msg_private.h +++ b/src/gras/Msg/msg_private.h @@ -12,7 +12,7 @@ #ifndef GRAS_MESSAGE_PRIVATE_H #define GRAS_MESSAGE_PRIVATE_H -#include "gras_config.h" +#include "portable.h" #include "xbt/sysdep.h" #include "xbt/log.h" @@ -35,7 +35,7 @@ extern int gras_msg_libdata_id; /* The identifier of our libdata */ extern const char *e_gras_msg_kind_names[e_gras_msg_kind_count]; /* declare either regular messages or RPC or whatever */ -void +XBT_PUBLIC void gras_msgtype_declare_ext(const char *name, short int version, e_gras_msg_kind_t kind, @@ -65,9 +65,9 @@ void gras_msgtype_free(void *msgtype); /* functions to extract msg from socket or put it on wire (depend RL vs SG) */ -void gras_msg_recv(gras_socket_t sock, +XBT_PUBLIC void gras_msg_recv(gras_socket_t sock, gras_msg_t msg/*OUT*/); -void gras_msg_send_ext(gras_socket_t sock, +XBT_PUBLIC void gras_msg_send_ext(gras_socket_t sock, e_gras_msg_kind_t kind, unsigned long int ID, gras_msgtype_t msgtype, @@ -84,8 +84,8 @@ struct s_gras_cblist { }; typedef struct s_gras_cblist gras_cblist_t; -void gras_cbl_free(void *); /* used to free the memory at the end */ -void gras_cblist_free(void *cbl); +XBT_PUBLIC void gras_cbl_free(void *); /* used to free the memory at the end */ +XBT_PUBLIC void gras_cblist_free(void *cbl); /** * gras_msg_cb_ctx_t: @@ -97,6 +97,7 @@ struct s_gras_msg_cb_ctx { gras_msgtype_t msgtype; unsigned long int ID; double timeout; + int answer_due; /* Whether the callback is expected to return a result (for sanity checks) */ }; typedef struct s_gras_msg_cb_ctx s_gras_msg_cb_ctx_t; @@ -111,8 +112,13 @@ typedef struct { } s_gras_timer_t, *gras_timer_t; /* returns 0 if it handled a timer, or the delay until next timer, or -1 if no armed timer */ -double gras_msg_timer_handle(void); +XBT_PUBLIC double gras_msg_timer_handle(void); +XBT_PUBLIC gras_msg_cb_ctx_t gras_msg_cb_ctx_new(gras_socket_t expe, + gras_msgtype_t msgtype, + unsigned long int ID, + int answer_due, + double timeout); #endif /* GRAS_MESSAGE_PRIVATE_H */