#include "loba_makhoul.h"
#include "loba_makhoul2.h"
#include "loba_makhoul3.h"
+#include "loba_pstar.h"
#include "loba_simple.h"
#include "misc.h"
double min_transfer_amount = 0.0;
double max_transfer_amount = 0.0;
bool integer_transfer = false;
+ unsigned loba_best_divisor = 1;
// Application parameters
cost_func comp_cost("1e9, 0"); // fixme: find better defaults
double comp_time_delay = 0.0; // fixme: find better defaults
// Parameters for the end of the simulation
+ double avg_load_ratio = 0.0;
unsigned lb_maxiter = 0;
unsigned comp_maxiter = 0;
double time_limit = 0;
+ unsigned exit_on_convergence = 0;
bool exit_on_close = true;
// Named parameters lists
loba_makhoul3);
NOL_INSERT("none", "no load-balancing (for testing only)",
process);
+ NOL_INSERT("pstar", "balance with pstar strategy",
+ loba_pstar);
NOL_INSERT("simple", "balance with least loaded neighbor",
loba_simple);
}
const char* opt_helper::descr(const char* str)
{
- std::string& res = descr_str;
- res = str;
- res.resize(DATA_DESCR_WIDTH, '.');
- return res.c_str();
+ descr_str = str;
+ descr_str.push_back(' ');
+ descr_str.resize(DATA_DESCR_WIDTH, '.');
+ return descr_str.c_str();
}
template <typename T>
const char* opt_helper::val_or_string(const T& val, const char* str,
const T& deflt)
{
- std::string& res = val_or_string_str;
if (val != deflt) {
std::ostringstream oss;
oss << val;
- res = oss.str();
+ val_or_string_str = oss.str();
} else {
- res = str;
+ val_or_string_str = str;
}
- return res.c_str();
+ return val_or_string_str.c_str();
}
template <typename T>
int c;
opterr = 0;
while ((c = getopt(*argc, argv,
- "a:bc:C:d:D:eEhi:I:l:L:m:M:N:r:Rs:S:t:T:vVx:X:Z"))
+ "%:"
+ "a:bc:C:d:D:eEg:hi:I:k:l:L:m:M:N:r:Rs:S:t:T:vVx:X:Z"))
!= -1) {
switch (c) {
+ case '%':
+ PARSE_ARG(opt::avg_load_ratio);
+ break;
case 'a':
opt::loba_algo = optarg;
result = opt_helper::nol_find_prefix(opt::loba_algorithms,
case 'E':
opt::egocentric = !opt::egocentric;
break;
+ case 'g':
+ PARSE_ARG(opt::exit_on_convergence);
+ break;
case 'h':
opt::help_requested++;
break;
case 'i':
PARSE_ARG(opt::lb_maxiter);
break;
+ case 'k':
+ PARSE_ARG(opt::loba_best_divisor);
+ break;
case 'I':
PARSE_ARG(opt::comp_maxiter);
break;
if (opt::max_transfer_amount &&
opt::max_transfer_amount < opt::min_transfer_amount) {
- XBT_ERROR("max. data transfer amount < min. data transfer amount");
+ XBT_ERROR("max. data transfer amount (%g) <"
+ " min. data transfer amount (%g)",
+ opt::max_transfer_amount, opt::min_transfer_amount);
+ result = false;
+ }
+
+ if (opt::loba_best_divisor <= 0) {
+ XBT_ERROR("divisor for algorithms *best* (%u) should be positive",
+ opt::loba_best_divisor);
result = false;
}
DESCR("load balancing algorithm", "%s", loba_algo.c_str());
DESCR("bookkeeping", "%s", h.on_off(bookkeeping));
DESCR("egocentric mode", "%s", h.on_off(egocentric));
- DESCR("minimum duration between lb. iterations", "%g",
- min_lb_iter_duration);
DESCR("computation cost factors", "[%s]", comp_cost.to_string().c_str());
DESCR("communication cost factors", "[%s]", comm_cost.to_string().c_str());
DESCR("minimum data transfer amount", "%g", min_transfer_amount);
h.val_or_string(max_transfer_amount, "no limit"));
DESCR("only transfer integer data shares", "%s",
h.on_off(integer_transfer));
+ DESCR("divisor for algorithms *best*", "%u", loba_best_divisor);
+ DESCR("minimum duration between lb. iterations", "%g",
+ min_lb_iter_duration);
DESCR("minimum duration between comp. iterations", "%g",
min_comp_iter_duration);
DESCR("computations start after lb. iter", "%u", comp_iter_delay);
h.val_or_string(lb_maxiter, "no limit"));
DESCR("maximum number of comp. iterations", "%s",
h.val_or_string(comp_maxiter, "no limit"));
+ DESCR("convergence is assumed within (\%)", "%g", opt::avg_load_ratio);
DESCR("time limit", "%s", h.val_or_string(time_limit, "no limit"));
+ DESCR("exit on convergence", "%s",
+ h.val_or_string(exit_on_convergence, "disabled"));
DESCR("exit on close", "%s", h.on_off(exit_on_close));
XBT_INFO("`----");
if (opt::help_requested > 1)
std::clog << o("")
<< "(a not so good idea introduced by git commit f5336c5)\n";
+ std::clog << o("-k value") << "divisor for algorithms *best*"
+ << " [" << opt::loba_best_divisor << "]\n";
std::clog << "\nLb. and comp. iterations:\n";
std::clog << o("-s value")
std::clog << o("-I value")
<< "maximum number of comp. iterations, 0 for no limit"
<< " [" << opt::comp_maxiter << "]\n";
+ std::clog << o("-% value")
+ << "percent of the load average to assume the convergence"
+ << " [" << opt::avg_load_ratio << "]\n";
+ if (opt::help_requested > 1)
+ std::clog << o("")
+ << "- if negative: use 100 * (nhosts / -value) / avg_load\n";
+ std::clog << o("-g value")
+ << "number of consecutive detections of convergence to exit"
+ << " [" << opt::exit_on_convergence << "]\n";
+ if (opt::help_requested > 1)
+ std::clog << o("")
+ << "- use 0 to disable\n";
std::clog << o("-t value")
<< "time limit (simulated time), 0 for no limit"
<< " [" << opt::time_limit << "]\n";
std::clog << "\nLogging support:\n"
<< " See SimGrid documentation on:\n"
- << " http://simgrid.gforge.inria.fr/doc/group__XBT__log.html#log_user\n"
+ << " http://simgrid.gforge.inria.fr/simgrid/latest/doc/outcomes_logs.html#log_user\n"
<< " Existing categories are:\n"
<< " simu : root of following categories\n"
<< " main : messages from global infrastructure\n"
