X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/806a8ef96de0bc6fbb75cadb0fbd8f3ef824d0b8..901dca0c34d7c5411125d67ac97ad8e1df788157:/src/gras/Msg/msg_interface.h diff --git a/src/gras/Msg/msg_interface.h b/src/gras/Msg/msg_interface.h index 9c98503096..7c72a76db6 100644 --- a/src/gras/Msg/msg_interface.h +++ b/src/gras/Msg/msg_interface.h @@ -12,20 +12,39 @@ #ifndef GRAS_MSG_INTERFACE_H #define GRAS_MSG_INTERFACE_H -/* gras_msg_t is dereferenced to be stored in procdata, living in Virtu */ +#include "gras/transport.h" + +/* + * Data of this module specific to each process + * (used by sg_process.c to check some usual errors at the end of the simulation) + * FIXME: it could be cleaned up ? + */ typedef struct { - gras_socket_t expeditor; - gras_msgtype_t type; - void *payload; - int payload_size; -} gras_msg_t; + /* set headers */ + unsigned int ID; + char *name; + unsigned int name_len; + + /* queue storing the msgs got while msg_wait'ing for something else. Reuse them ASAP. */ + xbt_dynar_t msg_queue; /* elm type: s_gras_msg_t */ + + /* queue storing the msgs without callback got when handling. Feed them to wait() */ + xbt_dynar_t msg_waitqueue; /* elm type: s_gras_msg_t */ + + /* registered callbacks for each message */ + xbt_dynar_t cbl_list; /* elm type: gras_cblist_t */ + + /* registered timers */ + xbt_dynar_t timers; /* elm type: s_gras_timer_t */ -xbt_error_t gras_msg_send_namev(gras_socket_t sock, - const char *namev, - void *payload); +} s_gras_msg_procdata_t,*gras_msg_procdata_t; + + +XBT_PUBLIC void gras_msg_send_namev(gras_socket_t sock, + const char *namev, + void *payload); #define GRAS_PROTOCOL_VERSION '\0'; -typedef struct s_gras_cblist gras_cblist_t; -void gras_cbl_free(void *); /* virtu use that to free the memory at the end */ + #endif /* GRAS_MSG_INTERFACE_H */