-#include <algorithm>
#include <xbt/log.h>
XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(loba);
void loba_makhoul::load_balance()
{
- std::sort(pneigh.begin(), pneigh.end(), pneigh_load_less());
+ pneigh_sort_by_load(std::less<double>());
print_loads_p(false, xbt_log_priority_debug);
double alpha = 1.0 / (pneigh.size() + 1.0);
- double delta;
- for (unsigned i = 0 ;
- i < pneigh.size() &&
- (delta = get_load() - pneigh[i]->get_load()) > 0.0 ;
- ++i) {
- send(pneigh[i], delta * alpha);
+ double myLoad = get_load();
+ for (unsigned i = 0; i < pneigh.size(); i++) {
+ double delta = std::max(myLoad - pneigh[i]->get_load(), 0.0);
+ double transfer = alpha * delta;
+ XBT_DEBUG("delta = %g ; transfer = %g", delta, transfer);
+ if (pneigh[i]->get_load() <= get_load() - 2 * transfer) {
+ send(pneigh[i], transfer);
+ XBT_DEBUG("sent %g to %s", transfer, pneigh[i]->get_name());
+ } else {
+ break;
+ }
}
}