X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/431ac6bd7924ab99473c9a621a25ab0c555c3e60..b78d5563826957045678f4c3bcfdcef6c9bfc48d:/process.cpp?ds=sidebyside diff --git a/process.cpp b/process.cpp index 339938a..b0d7026 100644 --- a/process.cpp +++ b/process.cpp @@ -16,7 +16,7 @@ XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(proc); 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); @@ -129,6 +129,8 @@ double process::sum_of_to_send() const double process::load_balance(double /*my_load*/) { + if (iter == 1) + WARN0("process::load_balance is a no-op!"); return 0.0; } @@ -186,7 +188,6 @@ void process::send() 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)); @@ -198,7 +199,6 @@ void process::send() } } -// Returns false if a CLOSE message was received. bool process::receive(recv_wait_mode wait) { bool result = true;