From: Frederic Suter Date: Thu, 5 Jul 2018 13:24:39 +0000 (+0200) Subject: Merge branch 'master' of git+ssh://scm.gforge.inria.fr//gitroot/simgrid/simgrid X-Git-Tag: v3_21~559 X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/commitdiff_plain/1fc5d774ff8e253d3127812d681e7d08b489fc4a?hp=1bd7cbc6f7c9069a69935f33ab7867de949babe7 Merge branch 'master' of git+ssh://scm.gforge.inria.fr//gitroot/simgrid/simgrid --- diff --git a/src/s4u/s4u_Barrier.cpp b/src/s4u/s4u_Barrier.cpp index 713245c9e1..a8ce588842 100644 --- a/src/s4u/s4u_Barrier.cpp +++ b/src/s4u/s4u_Barrier.cpp @@ -18,10 +18,8 @@ XBT_LOG_NEW_DEFAULT_CATEGORY(s4u_barrier, "S4U barrier"); namespace simgrid { namespace s4u { -Barrier::Barrier(unsigned int count) : expected_processes_(count) +Barrier::Barrier(unsigned int expected_processes) : mutex_(Mutex::create()), cond_(ConditionVariable::create()), expected_processes_(expected_processes) { - mutex_ = Mutex::create(); - cond_ = ConditionVariable::create(); } /** diff --git a/src/simgrid/sg_config.cpp b/src/simgrid/sg_config.cpp index c026309c48..415a9c78d1 100644 --- a/src/simgrid/sg_config.cpp +++ b/src/simgrid/sg_config.cpp @@ -446,6 +446,9 @@ void sg_config_init(int *argc, char **argv) simgrid::config::declare_flag("smpi/alltoallv", "Which collective to use for alltoallv", ""); simgrid::config::declare_flag("smpi/bcast", "Which collective to use for bcast", ""); simgrid::config::declare_flag("smpi/reduce", "Which collective to use for reduce", ""); + + simgrid::config::declare_flag("smpi/plugin/lb/migration-frequency", "After how many migrations should the load balancer" + "compute a new mapping?", 10); #endif // HAVE_SMPI /* Others */ diff --git a/src/smpi/internals/smpi_bench.cpp b/src/smpi/internals/smpi_bench.cpp index ac7f78ca32..f7101a3e4c 100644 --- a/src/smpi/internals/smpi_bench.cpp +++ b/src/smpi/internals/smpi_bench.cpp @@ -166,7 +166,7 @@ void smpi_bench_end() for (auto const& pair : counter_data) { simgrid::instr::VariableType* variable = static_cast(container->type_->by_name(pair.first)); - variable->set_event(surf_get_clock(), pair.second); + variable->set_event(SIMIX_get_clock(), pair.second); } } #endif diff --git a/src/smpi/internals/smpi_global.cpp b/src/smpi/internals/smpi_global.cpp index 3ce72e12f4..bb67c34626 100644 --- a/src/smpi/internals/smpi_global.cpp +++ b/src/smpi/internals/smpi_global.cpp @@ -366,7 +366,7 @@ static void smpi_init_options(){ simgrid::smpi::Colls::smpi_coll_cleanup_callback = nullptr; smpi_cpu_threshold = simgrid::config::get_value("smpi/cpu-threshold"); smpi_host_speed = simgrid::config::get_value("smpi/host-speed"); - xbt_assert(smpi_host_speed >= 0, "You're trying to set the host_speed to a negative value (%f)", smpi_host_speed); + xbt_assert(smpi_host_speed > 0.0, "You're trying to set the host_speed to a non-positive value (given: %f)", smpi_host_speed); std::string smpi_privatize_option = simgrid::config::get_value("smpi/privatization"); if (smpi_privatize_option == "no" || smpi_privatize_option == "0") smpi_privatize_global_variables = SmpiPrivStrategies::NONE;