X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/15ace044d0d9e82ef744e22cf84168771e669678..HEAD:/deployment.cpp?ds=inline diff --git a/deployment.cpp b/deployment.cpp index 705c1ea..0af3e3b 100644 --- a/deployment.cpp +++ b/deployment.cpp @@ -1,11 +1,11 @@ #include +#include #include -#include #include #include #include #include -#include +#include #include #include @@ -50,27 +50,50 @@ void deployment_generator::set_link(int host1, int host2) void deployment_generator::distribute_load() { - using std::tr1::bind; - using std::tr1::placeholders::_1; - if (!opt::auto_depl::random_distribution) { set_load(0, opt::auto_depl::load); return; } - srand48(opt::auto_depl::random_seed); std::vector loads(hosts.size()); - std::generate(loads.begin(), loads.end(), drand48); + if (opt::auto_depl::random_seed != 1) { + srand48(opt::auto_depl::random_seed); + std::generate(loads.begin(), loads.end(), drand48); + } else { + std::fill(loads.begin(), loads.end(), 1.0); + } double factor = opt::auto_depl::load / std::accumulate(loads.begin(), loads.end(), 0.0); std::transform(loads.begin(), loads.end(), loads.begin(), - bind(std::multiplies(), _1, factor)); + [&factor](double a) { return factor * a; }); + if (opt::integer_transfer) { + double iload; + double residue = 0.0; + unsigned i; + for (i = 0 ; i < hosts.size() - 1; ++i) { + if (residue < 0.0) + iload = std::floor(loads[i]); + else if (residue > 0.0) + iload = std::ceil(loads[i]); + else // residue == 0.0 + iload = std::round(loads[i]); + residue += (loads[i] - iload); + loads[i] = iload; + } + // abs(round(...)) to avoid rounding errors, or a value of -0 + // Note: i == hosts.size() - 1 + iload = std::abs(std::round(loads[i] + residue)); + loads[i] = iload; + // final sanity check + xbt_assert(opt::auto_depl::load == + std::accumulate(loads.begin(), loads.end(), 0.0)); + } for (unsigned i = 0 ; i < hosts.size() ; ++i) set_load(i, loads[i]); } void deployment_generator::deploy() { - xbt_dynar_t args = xbt_dynar_new(sizeof(const char*), NULL); + xbt_dynar_t args = xbt_dynar_new(sizeof(const char*), nullptr); for (unsigned i = 0 ; i < hosts.size() ; ++i) { const char* hostname = hostdata::at(i).get_name(); std::ostringstream oss; @@ -160,7 +183,7 @@ void deployment_torus::generate() b = c; } unsigned width = b; - // here width == ceil(sqrt(size)) + // here width == std::ceil(std::sqrt(size)) unsigned first_on_last_line = (size() - 1) - (size() - 1) % width; XBT_DEBUG("torus size = %zu ; width = %u ; height = %zu ; foll = %u",