comp = 0.0;
- prev_load_broadcast = -1; // force sending of load on first send()
+ prev_load_broadcast = -1; // force sending of load on first send_all()
expected_load = load;
total_load_running += load;
total_load_init += load;
lb_load() = ld;
// send load information, and load (data) if any
- send();
+ send_all();
if (load > 0.0) {
++comp_iter;
compute();
comm.send(nb.get_data_mbox(), new message(message::LOAD, load_to_send));
}
-void process::send()
+void process::send_all()
{
using std::tr1::bind;
using std::tr1::placeholders::_1;
// Send procedures, with helpers for bookkeeping mode or not
void send1_no_bookkeeping(neighbor& nb);
void send1_bookkeeping(neighbor& nb);
- void send();
+ void send_all();
// Returns true if there remains neighbors to listen for
bool may_receive() { return ctrl_close_pending || data_close_pending; }