X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/089f7e843d3f07571c398fb880550fdc6ff3c8e1..37151c0d4c6efccef4ac99502864f1a7d8fc830b:/src/simix/smx_user.c diff --git a/src/simix/smx_user.c b/src/simix/smx_user.c index 8fb5b34e81..9344984a17 100644 --- a/src/simix/smx_user.c +++ b/src/simix/smx_user.c @@ -1021,6 +1021,30 @@ smx_action_t simcall_comm_irecv(smx_rdv_t rdv, void *dst_buff, size_t * dst_buff SIMIX_simcall_push(simcall->issuer); return simcall->comm_irecv.result; } + + +/** + * \ingroup simix_comm_management + */ +smx_action_t simcall_comm_iprobe(smx_rdv_t rdv, int src, int tag, + int (*match_fun)(void *, void *, smx_action_t), void *data) +{ + xbt_assert(rdv, "No rendez-vous point defined for iprobe"); + + smx_simcall_t simcall = SIMIX_simcall_mine(); + + simcall->call = SIMCALL_COMM_IPROBE; + simcall->comm_iprobe.rdv = rdv; + simcall->comm_iprobe.src = src; + simcall->comm_iprobe.match_fun = match_fun; + simcall->comm_iprobe.data = data; + if(MC_IS_ENABLED) /* Initialize result to NULL for snapshot comparison done during simcall */ + simcall->comm_iprobe.result = NULL; + SIMIX_simcall_push(simcall->issuer); + return simcall->comm_iprobe.result; +} + + void simcall_comm_destroy(smx_action_t comm) { xbt_assert(comm, "Invalid parameter"); @@ -1254,7 +1278,7 @@ smx_mutex_t simcall_mutex_init(void) { if(!simix_global) { fprintf(stderr,"You must run MSG_init or gras_init before using MSG or GRAS\n"); // I would have loved using xbt_die but I can't since it is not initialized yet... :) - abort(); + xbt_abort(); } smx_simcall_t simcall = SIMIX_simcall_mine();