X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/50a00235743c59840ee2db2258e9e6dd7444f646..8bdfda4ed37966fcac00b37ddca740afaba48b28:/process.h diff --git a/process.h b/process.h index c72fdf2..b15f982 100644 --- a/process.h +++ b/process.h @@ -66,10 +66,10 @@ private: int data_close_pending; // number of "close" messages to wait // on data channel bool close_received; // true if we received a "close" message - bool may_receive; // true if there remains neighbors to listen for bool finalizing; // true when finalize() is running - unsigned iter; // counter of iterations + unsigned lb_iter; // counter of load-balancing iterations + unsigned comp_iter; // counter of computation iterations double prev_load_broadcast; // used to ensure that we do not send // a same information messages @@ -90,9 +90,11 @@ private: void send1_bookkeeping(neighbor& nb); void send(); - // Receive procedure: wait (or not) for a message to come. - enum recv_wait_mode { NO_WAIT = 0, WAIT, WAIT_FOR_CLOSE }; - void receive(recv_wait_mode wait); + // Returns true if there remains neighbors to listen for + bool may_receive() { return ctrl_close_pending || data_close_pending; } + + // Receive procedure: wait (or not) for a message to come + void receive(bool wait); // Finalize sends a "close" message to each neighbor and wait for // all of them to answer.