X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/9539c77f2b5e0eef8d06da7a7ddd1d5546ba0731..d67fee4c5988698b045480ac86a67b7a5a21a8b2:/process.cpp diff --git a/process.cpp b/process.cpp index b6a6d28..e6c7bc2 100644 --- a/process.cpp +++ b/process.cpp @@ -67,6 +67,7 @@ process::process(int argc, char* argv[]) total_load_init += real_load; received_load = 0.0; + idle_duration = 0.0; convergence = -1.0; process_counter++; @@ -202,6 +203,7 @@ void process::compute_loop() using std::placeholders::_1; double next_iter_after_date = MSG_get_clock() + opt::min_comp_iter_duration; + double idle_since_date = 0.0; while (still_running()) { do { @@ -226,6 +228,7 @@ void process::compute_loop() convergence_check(); // compute + idle_duration += MSG_get_clock() - idle_since_date; ++comp_iter; double flops = opt::comp_cost(real_load); m_task_t task = MSG_task_create("computation", flops, 0.0, NULL); @@ -235,10 +238,13 @@ void process::compute_loop() add_comp_amount(flops); MSG_task_destroy(task); + idle_since_date = MSG_get_clock(); + sleep_until_date(next_iter_after_date, opt::min_comp_iter_duration); } XBT_VERB("Going to finalize for %s...", __func__); + // Note: idle duration is not counted during finalization finalizing = true; XBT_DEBUG("send DATA_CLOSE to %zu neighbor%s", neigh.size(), ESSE(neigh.size()));