#include "deployment.h"
#include "process.h"
+#include "loba_2besteffort.h"
#include "loba_besteffort.h"
+#include "loba_bulk.h"
#include "loba_fairstrategy.h"
+#include "loba_lln.h"
#include "loba_makhoul.h"
#include "loba_makhoul2.h"
+#include "loba_makhoul3.h"
#include "loba_simple.h"
#include "misc.h"
std::string program_name;
int help_requested = 0;
bool version_requested = false;
- int option_x = 0; // hidden option, for debugging purpose
+ int option_x = 0; // hidden option (int)
+ double option_X = 0.0; // hidden option (double)
// Simulation parameters
int log_rate = 1;
- bool exit_request = false;
+ volatile std::sig_atomic_t exit_request = 0;
// Platform and deployment
std::string platform_file;
bool enabled = false;
std::string topology("clique");
unsigned nhosts = 0;
- double load = 0.0;
+ double load = -1.0;
bool random_distribution = false;
unsigned long random_seed = 0;
}
// Load balancing algorithm
std::string loba_algo("simple");
bool bookkeeping = false;
+ bool egocentric = false;
double min_lb_iter_duration = 1.0; // fixme: find better defaults
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_algorithms_type loba_algorithms;
loba_algorithms_type::loba_algorithms_type()
{
+ NOL_INSERT("2besteffort", "balance with best effort strategy (take #2)",
+ loba_2besteffort);
NOL_INSERT("besteffort", "balance with best effort strategy",
loba_besteffort);
+ NOL_INSERT("bulk", "a multi-load-units assignation rule without ordering...",
+ loba_bulk);
NOL_INSERT("fairstrategy", "balance with fair strategy",
loba_fairstrategy);
+ NOL_INSERT("lln", "balance with less loaded neighbors without ordering-bulk method",
+ loba_lln);
NOL_INSERT("makhoul", "balance with Makhoul's PhD algorithm",
loba_makhoul);
NOL_INSERT("makhoul2", "balance with Makhoul's source code",
loba_makhoul2);
+ NOL_INSERT("makhoul3", "variation on Makhoul's algorithm",
+ loba_makhoul3);
NOL_INSERT("none", "no load-balancing (for testing only)",
process);
NOL_INSERT("simple", "balance with least loaded neighbor",
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.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:ehi:I:l:L:m:M:N:r:Rs:S:t:T:vVx:")) != -1) {
+ "%:"
+ "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 'b':
opt::bookkeeping = !opt::bookkeeping;
break;
- case 'e':
- opt::exit_on_close = !opt::exit_on_close;
- break;
- case 'h':
- opt::help_requested++;
- break;
case 'c':
try {
opt::comp_cost = cost_func(optarg);
case 'D':
PARSE_ARG(opt::comp_time_delay);
break;
+ case 'e':
+ opt::exit_on_close = !opt::exit_on_close;
+ break;
+ 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;
PARSE_ARG(opt::option_x);
XBT_WARN("option_x set to %d", opt::option_x);
break;
+ case 'X':
+ PARSE_ARG(opt::option_X);
+ XBT_WARN("option_X set to %g", opt::option_X);
+ break;
+ case 'Z':
+ opt::integer_transfer = !opt::integer_transfer;
+ break;
case '?':
XBT_ERROR("invalid option -- '%c'", optopt);
result = false;
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("- topology", "%s", auto_depl::topology.c_str());
DESCR("- number of hosts", "%s", h.val_or_string(auto_depl::nhosts,
"auto"));
- DESCR("- initial load", "%s", h.val_or_string(auto_depl::load,
- "auto"));
+ if (auto_depl::load < 0.0)
+ DESCR("- initial load (average)", "%g", -auto_depl::load);
+ else
+ DESCR("- initial load (total)", "%g", auto_depl::load);
DESCR("- random initial load distribution", "%s",
h.on_off(auto_depl::random_distribution));
- DESCR("- random seed", "%s",
- h.val_or_string(auto_depl::random_seed, "time based"));
+ DESCR("- random seed", "%s", // NOTE: cannot be 0 here anymore
+ h.val_or_string(auto_depl::random_seed, "constant random", 1UL));
} else {
DESCR("deployment file", "\"%s\"", deployment_file.c_str());
}
DESCR("load balancing algorithm", "%s", loba_algo.c_str());
DESCR("bookkeeping", "%s", h.on_off(bookkeeping));
- DESCR("minimum duration between lb. iterations", "%g",
- min_lb_iter_duration);
+ DESCR("egocentric mode", "%s", h.on_off(egocentric));
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);
DESCR("maximum data transfer amount", "%s",
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)
so_list(opt::topologies);
std::clog << o("-L value")
- << "total load with auto deployment, 0 for number of hosts"
+ << "total load with auto deployment, average if negative"
<< " [" << opt::auto_depl::load << "]\n";
std::clog << o("-N value")
<< "number of hosts to use with auto deployment, 0 for max."
<< " [" << opt_helper::on_off(opt::auto_depl::random_distribution)
<< "]\n";
std::clog << o("-r value")
- << "random seed, 0 for a seed based on current date"
+ << "random seed for initial load distribution, or 0, or 1"
<< " [" << opt::auto_depl::random_seed << "]\n";
+ if (opt::help_requested > 1)
+ std::clog << o("") << "- use 0 for a seed based on current date\n"
+ << o("") << "- use 1 for a constant random\n";
std::clog << "\nLoad balancing algorithm:\n";
std::clog << o("-a name") << "load balancing algorithm"
so_list(opt::loba_algorithms);
std::clog << o("-b") << "toggle bookkeeping (\"virtual load\")"
<< " [" << opt_helper::on_off(opt::bookkeeping) << "]\n";
+ std::clog << o("-E") << "toggle egocentric mode when bookkeeping"
+ << " [" << opt_helper::on_off(opt::egocentric) << "]\n";
+ 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("-M value")
<< "maximum data transfer amount, 0 for no limit"
<< " [" << opt::max_transfer_amount << "]\n";
+ std::clog << o("-Z")
+ << "toggle transfer of integer data shares only"
+ << " [" << opt_helper::on_off(opt::integer_transfer) << "]\n";
std::clog << "\nEnd of the simulation:\n";
std::clog << o("-i 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";
if (opt::help_requested < 3)
return;
+ std::clog << "\nHidden options:\n";
+ std::clog << o("-x value") << "value is an integer"
+ << " [" << opt::option_x << "]\n";
+ std::clog << o("-X value") << "value is a real number"
+ << " [" << opt::option_X << "]\n";
+
std::clog << "\nLogging support:\n"
<< " See SimGrid documentation on:\n"
<< " http://simgrid.gforge.inria.fr/doc/group__XBT__log.html#log_user\n"
