From 1585b49c3b4c38379d8ebc955f0c86c8b3467aba Mon Sep 17 00:00:00 2001 From: Arnaud Giersch Date: Wed, 1 Jun 2011 17:01:33 +0200 Subject: [PATCH 1/1] Be consistent, and start lb-loop by a receive too. --- NOTES | 2 +- process.cpp | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/NOTES b/NOTES index 19fafe8..71e2729 100644 --- a/NOTES +++ b/NOTES @@ -47,10 +47,10 @@ thread, and a load-balancing thread. --------------------- Loop + | receive ctrl messages | call load-balancing algorithm | send ctrl messages | sleep (min_lb_iter_duration) - | receive ctrl messages +- send CLOSE on ctrl for all neighbors wait for CLOSE on ctrl from all neighbors diff --git a/process.cpp b/process.cpp index 2de3016..47dd94a 100644 --- a/process.cpp +++ b/process.cpp @@ -127,6 +127,8 @@ void process::load_balance_loop() ++lb_iter; } + ctrl_receive(0.0); + mutex.acquire(); if (!opt::bookkeeping) expected_load = real_load - get_sum_of_to_send(); @@ -150,7 +152,6 @@ void process::load_balance_loop() mutex.release(); sleep_until_date(next_iter_after_date, opt::min_lb_iter_duration); - ctrl_receive(0.0); } XBT_VERB("Going to finalize for %s...", __func__); -- 2.39.5