X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/32f134d2bd99b42aaf41ead6aa8fdb58962efd16..a45d028524d1b21fbe820ce93e87867963b7239b:/src/simix/smx_network_private.h diff --git a/src/simix/smx_network_private.h b/src/simix/smx_network_private.h index ac8dcdcebb..558aa16a0e 100644 --- a/src/simix/smx_network_private.h +++ b/src/simix/smx_network_private.h @@ -7,7 +7,7 @@ #ifndef _SIMIX_NETWORK_PRIVATE_H #define _SIMIX_NETWORK_PRIVATE_H -#include "simix/datatypes.h" +#include "simgrid/simix.h" #include "smx_smurf_private.h" /** @brief Rendez-vous point datatype */ @@ -15,6 +15,8 @@ typedef struct s_smx_rvpoint { char *name; xbt_fifo_t comm_fifo; void *data; + smx_process_t permanent_receiver; //process which the mailbox is attached to + xbt_fifo_t done_comm_fifo;//messages already received in the permanent receive mode } s_smx_rvpoint_t; void SIMIX_network_init(void); @@ -30,6 +32,8 @@ smx_rdv_t SIMIX_rdv_get_by_name(const char *name); void SIMIX_rdv_remove(smx_rdv_t rdv, smx_action_t comm); int SIMIX_rdv_comm_count_by_host(smx_rdv_t rdv, smx_host_t host); smx_action_t SIMIX_rdv_get_head(smx_rdv_t rdv); +void SIMIX_rdv_set_receiver(smx_rdv_t rdv, smx_process_t proc); +smx_process_t SIMIX_rdv_get_receiver(smx_rdv_t rdv); void SIMIX_comm_start(smx_action_t action); void SIMIX_comm_send(smx_process_t src_proc, smx_rdv_t rdv, double task_size, double rate,