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;
process::~process()
{
total_load_exit += load;
+ if (opt::bookkeeping) {
+ INFO4("Final load after %d:%d iterations: %g ; expected: %g",
+ lb_iter, comp_iter, load, expected_load);
+ } else {
+ INFO2("Final load after %d iterations: %g",
+ lb_iter, load);
+ if (lb_iter != comp_iter)
+ WARN2("lb_iter (%d) and comp_iter (%d) differ!",
+ lb_iter, comp_iter);
+ }
+ VERB1("Total computation for this process: %g", comp);
}
int process::run()
lb_load() = ld;
// send load information, and load (data) if any
- send();
+ send_all();
if (load > 0.0) {
++comp_iter;
compute();
*/
VERB0("Done.");
- if (opt::bookkeeping) {
- INFO4("Final load after %d:%d iterations: %g ; expected: %g",
- lb_iter, comp_iter, load, expected_load);
- } else {
- INFO2("Final load after %d iterations: %g",
- lb_iter, load);
- if (lb_iter != comp_iter)
- WARN2("lb_iter (%d) and comp_iter (%d) differ!",
- lb_iter, comp_iter);
- }
return 0;
}
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;