+ 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);
+}