loba_makhoul2.cpp

   1 #include <xbt/log.h>
   2
   3 XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(loba);
   4
   5 #include "loba_makhoul2.h"
   6
   7 // Note: adapted from Makhoul's code
   8
   9 void loba_makhoul2::load_balance()
  10 {
  11     pneigh_sort_by_load(std::less<double>());
  12
  13     print_loads_p(false, xbt_log_priority_debug);
  14
  15     double alpha = 1.0 / (pneigh.size() + 1.0);
  16     double neighborLoadMax = 0.0; // maximum load of neighbors to
  17                                   // which something has been sent
  18     for (unsigned i = 0;
  19          i < pneigh.size() && pneigh[i]->get_load() < get_load(); i++) {
  20         double delta = get_load() - pneigh[i]->get_load();
  21
  22         // do not violate ping-pong condition
  23         double transfer = std::min(alpha * delta, get_load() - neighborLoadMax);
  24         XBT_DEBUG("delta = %g ; transfer = %g", delta, transfer);
  25
  26         send(pneigh[i], transfer);
  27         XBT_DEBUG("sent %g to %s", transfer, pneigh[i]->get_name());
  28
  29         double newNeighborLoad = pneigh[i]->get_load();
  30         if (newNeighborLoad > neighborLoadMax)
  31             neighborLoadMax = newNeighborLoad;
  32     }
  33 }
  34
  35 // Local variables:
  36 // mode: c++
  37 // End: