X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/3c79423e7376662ff7bcfa809c4803564cf82acb..778f65057da68465382593cd036b6ee59ada54e9:/src/gras/Msg/msg_interface.h diff --git a/src/gras/Msg/msg_interface.h b/src/gras/Msg/msg_interface.h index 28816ec3f0..3595ead608 100644 --- a/src/gras/Msg/msg_interface.h +++ b/src/gras/Msg/msg_interface.h @@ -20,18 +20,29 @@ * FIXME: it could be cleaned up ? */ typedef struct { - /*queue of msgs storing the ones got while msg_wait'ing for something else */ - xbt_dynar_t msg_queue; /* elm type: 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 */ } s_gras_msg_procdata_t,*gras_msg_procdata_t; -xbt_error_t gras_msg_send_namev(gras_socket_t sock, - const char *namev, - void *payload); +void gras_msg_send_namev(gras_socket_t sock, + const char *namev, + void *payload); #define GRAS_PROTOCOL_VERSION '\0';