X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/9ec598fc7b8d73ed8e9822aed084ad1e1b2918b6..366ebfe19c715dc3773637f786f5a591a6bb8199:/process.h?ds=inline diff --git a/process.h b/process.h index 1b4f9ca..fb1fe3f 100644 --- a/process.h +++ b/process.h @@ -27,6 +27,7 @@ public: process(int argc, char* argv[]); virtual ~process(); + double get_comp() const { return comp; } double get_load() const { return load; } int run(); @@ -53,7 +54,7 @@ protected: private: static double total_load_init; // sum of process loads at init - static double total_load_running; // summ of loads while running + static double total_load_running; // sum of loads while running static double total_load_exit; // sum of process loads at exit typedef MAP_TEMPLATE rev_neigh_type; @@ -72,6 +73,8 @@ private: unsigned lb_iter; // counter of load-balancing iterations unsigned comp_iter; // counter of computation iterations + double comp; // total computing done so far (flops) + double prev_load_broadcast; // used to ensure that we do not send // a same information messages double load; // current load @@ -96,8 +99,10 @@ private: // 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); + // Receive procedure + // Parameter "timeout" may be 0 for non-blocking operation, -1 for + // infinite waiting, or any positive timeout. + void receive(double timeout); // Finalize sends a "close" message to each neighbor and wait for // all of them to answer.