X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/97a4b4dbf628a627e3c2d5689be89265f56074df..ac9e5de4c0ff479ce265da01df4d53771e096d9d:/process.h diff --git a/process.h b/process.h index 68dcd9b..c30b243 100644 --- a/process.h +++ b/process.h @@ -61,6 +61,8 @@ private: // on ctrl channel 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 unsigned iter; // counter of iterations @@ -84,10 +86,8 @@ private: void send(); // Receive procedure: wait (or not) for a message to come. - // Returns false if some "close" message was received, returns true - // otherwise. enum recv_wait_mode { NO_WAIT = 0, WAIT, WAIT_FOR_CLOSE }; - bool receive(recv_wait_mode wait); + void receive(recv_wait_mode wait); // Finalize sends a "close" message to each neighbor and wait for // all of them to answer.