X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/1faf1e4ac5d8295ab562c45a5507a471ad4540a6..eb5b6b0c3c4d9a38bb205b2c8bc9aeeba8674a25:/src/smpi/colls/allgather-smp-simple.c diff --git a/src/smpi/colls/allgather-smp-simple.c b/src/smpi/colls/allgather-smp-simple.c index 143887052e..1a38857619 100644 --- a/src/smpi/colls/allgather-smp-simple.c +++ b/src/smpi/colls/allgather-smp-simple.c @@ -1,3 +1,9 @@ +/* Copyright (c) 2013-2014. 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" #ifndef NUM_CORE #define NUM_CORE 8 @@ -10,6 +16,15 @@ int smpi_coll_tuned_allgather_smp_simple(void *send_buf, int scount, { int src, dst, comm_size, rank; comm_size = smpi_comm_size(comm); + + int num_core = simcall_host_get_core(SIMIX_host_self()); + // do we use the default one or the number of cores in the platform ? + // if the number of cores is one, the platform may be simulated with 1 node = 1 core + if (num_core == 1) num_core = NUM_CORE; + + if(comm_size%num_core) + THROWF(arg_error,0, "allgather SMP simple algorithm can't be used with non multiple of NUM_CORE=%d number of processes ! ", num_core); + rank = smpi_comm_rank(comm); MPI_Aint rextent, sextent; rextent = smpi_datatype_get_extent(rtype); @@ -18,7 +33,6 @@ int smpi_coll_tuned_allgather_smp_simple(void *send_buf, int scount, MPI_Status status; int i, send_offset, recv_offset; int intra_rank, inter_rank; - int num_core = NUM_CORE; intra_rank = rank % num_core; inter_rank = rank / num_core; int inter_comm_size = (comm_size + num_core - 1) / num_core;