X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0e9c0448c6566825b170b98ecff716b098bda10e..b3b356352e87ae00a20f737c48e19b0c8413455a:/src/smpi/colls/smpi_automatic_selector.c diff --git a/src/smpi/colls/smpi_automatic_selector.c b/src/smpi/colls/smpi_automatic_selector.c index a94bd31d32..72c62a7149 100644 --- a/src/smpi/colls/smpi_automatic_selector.c +++ b/src/smpi/colls/smpi_automatic_selector.c @@ -1,40 +1,51 @@ +/* Copyright (c) 2013-2015. The SimGrid Team. + * All rights reserved. */ + +/* This program is free software; you can redistribute it and/or modify it + * under the terms of the license (GNU LGPL) which comes with this package. */ + #include "colls_private.h" -#include +#ifdef HAVE_MC #include "mc/mc_private.h" +#endif +#include //attempt to do a quick autotuning version of the collective, -#ifdef HAVE_TRACING #define TRACE_AUTO_COLL(cat) if (TRACE_is_enabled()){\ type_t type = PJ_type_get_or_null (#cat, PJ_type_get_root());\ if (!type){\ type=PJ_type_event_new(#cat, PJ_type_get_root());\ }\ - char* cont_name=malloc(25*sizeof(char*));\ + char cont_name[25];\ sprintf(cont_name, "rank-%d", smpi_process_index());\ val_t value = PJ_value_get_or_new(mpi_coll_##cat##_description[i].name,"1.0 1.0 1.0", type);\ new_pajeNewEvent (SIMIX_get_clock(), PJ_container_get(cont_name), type, value);\ } -#else -#define TRACE_AUTO_COLL(cat) -#endif #define AUTOMATIC_COLL_BENCH(cat, ret, args, args2)\ ret smpi_coll_tuned_ ## cat ## _ ## automatic(COLL_UNPAREN args)\ {\ - double time1, time2, time_min=INT_MAX;\ - int min_coll=-1, global_coll=-1;\ - int i;\ - double buf_in, buf_out, max_min=INT_MAX;\ + double time1, time2, time_min=DBL_MAX;\ + volatile int min_coll=-1, global_coll=-1;\ + volatile int i;\ + xbt_ex_t ex;\ + double buf_in, buf_out, max_min=DBL_MAX;\ for (i = 0; mpi_coll_##cat##_description[i].name; i++){\ if(!strcmp(mpi_coll_##cat##_description[i].name, "automatic"))continue;\ if(!strcmp(mpi_coll_##cat##_description[i].name, "default"))continue;\ smpi_mpi_barrier(comm);\ TRACE_AUTO_COLL(cat)\ time1 = SIMIX_get_clock();\ + TRY{\ ((int (*) args)\ mpi_coll_##cat##_description[i].coll) args2 ;\ + }\ + CATCH(ex) {\ + xbt_ex_free(ex);\ + continue;\ + }\ time2 = SIMIX_get_clock();\ buf_out=time2-time1;\ smpi_mpi_reduce((void*)&buf_out,(void*)&buf_in, 1, MPI_DOUBLE, MPI_MAX, 0,comm );\