X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/2f365d3503318b9911fe71d29878ea49a753534d..24d1e52d7fe26616e3bee87041acffe889aa4adc:/loba_besteffort.cpp?ds=inline diff --git a/loba_besteffort.cpp b/loba_besteffort.cpp index 18e8c0c..f3a8c33 100644 --- a/loba_besteffort.cpp +++ b/loba_besteffort.cpp @@ -6,8 +6,31 @@ XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(loba); void loba_besteffort::load_balance() { - // write code here... - xbt_die("Load-balancing algorithm besteffort not implemented!"); + pneigh_sort_by_load(std::less()); + print_loads_p(false, xbt_log_priority_debug); + + unsigned bound = pneigh.size(); + double sum = get_load(); + for (unsigned i = 0 ; i < bound ; ++i) { + if (get_load() <= pneigh[i]->get_load()) { + bound = i; + } else { + double newsum = sum + pneigh[i]->get_load(); + if (pneigh[i]->get_load() <= newsum / (i + 2)) + sum = newsum; + else + bound = i; + } + } + + double mean = sum / (bound + 1); + for (unsigned i = 0 ; i < bound ; ++i) { + double transfer = mean - pneigh[i]->get_load(); + if (opt::loba_best_divisor) + transfer /= opt::loba_best_divisor; + send(pneigh[i], transfer); + XBT_DEBUG("sent %g to %s", transfer, pneigh[i]->get_name()); + } } // Local variables: