process::process(int argc, char* argv[])
{
if (argc < 2 || !(std::istringstream(argv[1]) >> load))
- throw std::invalid_argument("bad or missing initial load");
+ throw std::invalid_argument("bad or missing initial load parameter");
neigh.assign(argv + 2, argv + argc);
double process::load_balance(double /*my_load*/)
{
+ if (iter == 1)
+ WARN0("process::load_balance is a no-op!");
return 0.0;
}
using namespace std::tr1;
using namespace std::tr1::placeholders;
- // fixme: shall we send data at all iterations?
if (opt::bookkeeping) {
std::for_each(neigh.begin(), neigh.end(),
bind(&process::send1_bookkeeping, this, _1));
}
}
-// Returns false if a CLOSE message was received.
bool process::receive(recv_wait_mode wait)
{
bool result = true;