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     {
  21
  22         double delta = get_load() - pneigh[i]->get_load();
  23
  24         // do not violate ping-pong condition
  25         double transfer = std::min(alpha * delta, get_load() - neighborLoadMax);
  26         // note: alpha <= 1/2
  27         XBT_DEBUG("delta = %g ; transfer = %g", delta, transfer);
  28
  29         send(pneigh[i], transfer);
  30         XBT_DEBUG("sent %g to %s", transfer, pneigh[i]->get_name());
  31
  32         double newNeighborLoad = pneigh[i]->get_load();
  33         if (newNeighborLoad > neighborLoadMax)
  34             neighborLoadMax = newNeighborLoad;
  35     }
  36 }
  37
  38 // Local variables:
  39 // mode: c++
  40 // End: