X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/37151c0d4c6efccef4ac99502864f1a7d8fc830b..ccedb07575381e28a3143247e9028fe4f73bcd96:/src/smpi/smpi_global.c diff --git a/src/smpi/smpi_global.c b/src/smpi/smpi_global.c index c864c5c6fe..95d44578c6 100644 --- a/src/smpi/smpi_global.c +++ b/src/smpi/smpi_global.c @@ -95,6 +95,7 @@ int smpi_process_argc(void) { return data->argc ? *(data->argc) - 1 : 0; } +#ifdef SMPI_F2C int smpi_process_getarg(integer* index, char* dst, ftnlen len) { smpi_process_data_t data = smpi_process_data(); char* arg; @@ -113,6 +114,7 @@ int smpi_process_getarg(integer* index, char* dst, ftnlen len) { } return 0; } +#endif int smpi_global_size(void) { char* value = getenv("SMPI_GLOBAL_SIZE"); @@ -213,13 +215,27 @@ void print_request(const char *message, MPI_Request request) { request->src, request->dst, request->tag, request->flags); } +static void SMPI_comm_copy_buffer_callback(smx_action_t comm, void* buff, size_t buff_size) +{ + XBT_DEBUG("Copy the data over"); + memcpy(comm->comm.dst_buff, buff, buff_size); + if (comm->comm.detached) { // if this is a detached send, the source buffer was duplicated by SMPI sender to make the original buffer available to the application ASAP + xbt_free(buff); + //It seems that the request is used after the call there this should + //be free somewhereelse but where??? + //xbt_free(comm->comm.src_data);// inside SMPI the request is keep + //inside the user data and should be free + comm->comm.src_buff = NULL; + } +} + void smpi_global_init(void) { int i; MPI_Group group; char name[MAILBOX_NAME_MAXLEN]; - SIMIX_comm_set_copy_data_callback(&SIMIX_comm_copy_buffer_callback); + SIMIX_comm_set_copy_data_callback(&SMPI_comm_copy_buffer_callback); process_count = SIMIX_process_count(); process_data = xbt_new(smpi_process_data_t, process_count); for (i = 0; i < process_count; i++) { @@ -274,6 +290,23 @@ int __attribute__((weak)) main(int argc, char** argv) { return MAIN__(); } +#ifdef WIN32 +#include + +int __attribute__((weak)) smpi_simulated_main(int argc, char** argv) { + xbt_die("Should not be in this smpi_simulated_main"); + return 1; +} + +/* TODO FOR WIN32 */ +/* Dummy prototype to make gcc happy */ +int APIENTRY WinMain(HINSTANCE hInst,HINSTANCE hInst2,LPSTR lpstr01,int nCmdShow) +{ + return MAIN__(); +} + +#endif + int MAIN__(void) { srand(SMPI_RAND_SEED); @@ -318,7 +351,7 @@ int MAIN__(void) fflush(stdout); fflush(stderr); - if (MC_IS_ENABLED) + if (MC_is_active()) MC_modelcheck(); else SIMIX_run();