+ if (opt::log_rate >= 0)
+ XBT_INFO("Initial load: %g", real_load);
+ XBT_VERB("Starting...");
+ compute_thread->start();
+ load_balance_loop();
+ compute_thread->wait();
+ XBT_VERB("Done.");
+ return 0;
+}
+
+void process::load_balance_loop()
+{
+ using std::tr1::bind;
+ using std::tr1::placeholders::_1;
+
+ double next_iter_after_date = MSG_get_clock() + opt::min_lb_iter_duration;
+ while (still_running()) {
+ ++lb_iter;
+
+ if (opt::log_rate && lb_iter % opt::log_rate == 0) {
+ if (opt::bookkeeping)
+ XBT_INFO("(%u:%u) current load: %g ; expected: %g",
+ lb_iter, comp_iter, real_load, expected_load);
+ else
+ XBT_INFO("(%u:%u) current load: %g",
+ lb_iter, comp_iter, real_load);
+ }
+
+ if (get_load() > 0.0)
+ load_balance();
+
+ print_loads(true, xbt_log_priority_debug);
+
+ // send
+ std::for_each(neigh.begin(), neigh.end(),
+ bind(&process::ctrl_send, this, _1));
+ prev_load_broadcast = get_load();
+
+ sleep_until_date(next_iter_after_date, opt::min_lb_iter_duration);
+ ctrl_receive(0.0);
+
+ comm.ctrl_flush(false);
+ }
+
+ XBT_VERB("Going to finalize for %s...", __func__);
+ XBT_DEBUG("send CTRL_CLOSE to %zu neighbor%s",
+ neigh.size(), ESSE(neigh.size()));
+ std::for_each(neigh.begin(), neigh.end(),
+ bind(&process::ctrl_close, this, _1));
+ while (ctrl_close_pending) {
+ comm.ctrl_flush(false);
+ XBT_DEBUG("waiting for %d CTRL CLOSE", ctrl_close_pending);
+ ctrl_receive(-1.0);
+ }
+ comm.ctrl_flush(true);
+}
+
+void process::compute_loop()
+{
+ using std::tr1::bind;
+ using std::tr1::placeholders::_1;
