- 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;
+ }