print_loads_p(false, xbt_log_priority_debug);
double alpha = 1.0 / (pneigh.size() + 1.0);
- double myLoad = get_load();
- for (unsigned i = 0; i < pneigh.size(); i++) {
- double delta = std::max(myLoad - pneigh[i]->get_load(), 0.0);
+ double my_load = get_load();
+ bool cont = true;
+ for (unsigned i = 0 ;
+ cont && i < pneigh.size() && pneigh[i]->get_load() < my_load ; ++i) {
+
+ double delta = my_load - pneigh[i]->get_load();
double transfer = alpha * delta;
XBT_DEBUG("delta = %g ; transfer = %g", delta, transfer);
- if (get_load() - 2 * transfer < pneigh[i]->get_load())
- break;
- send(pneigh[i], transfer);
- XBT_DEBUG("sent %g to %s", transfer, pneigh[i]->get_name());
+ if (pneigh[i]->get_load() + transfer <= get_load() - transfer) {
+ send(pneigh[i], transfer);
+ XBT_DEBUG("sent %g to %s", transfer, pneigh[i]->get_name());
+ } else {
+ cont = false;
+ }
}
}