X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/404a8d5b50296756e0896c1914750fa235720946..99ec08fb32d4b65c88628e45f9ebdb26741b9674:/process.cpp?ds=sidebyside diff --git a/process.cpp b/process.cpp index b6afb49..34590f3 100644 --- a/process.cpp +++ b/process.cpp @@ -65,10 +65,21 @@ process::~process() int process::run() { + double next_iter_after_date = 0.0; INFO1("Initial load: %g", load); VERB0("Starting..."); comp_iter = lb_iter = 0; while (true) { + if (opt::min_iter_duration) { + double now = MSG_get_clock(); + if (now < next_iter_after_date){ + double delay = next_iter_after_date - now; + DEBUG1("sleeping for %g s", delay); + MSG_process_sleep(next_iter_after_date - now); + } + next_iter_after_date = MSG_get_clock() + opt::min_iter_duration; + } + if (load > 0.0) { ++comp_iter; if (opt::log_rate && comp_iter % opt::log_rate == 0) { @@ -156,7 +167,7 @@ double process::sum_of_to_send() const double process::load_balance(double /*my_load*/) { if (lb_iter == 1) // warn only once - WARN0("process::load_balance is a no-op!"); + WARN0("process::load_balance() is a no-op!"); return 0.0; }