X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/ab12e5fdde759c1a4545159b2667d2cf3531591c..e3c678215b3df16d01f50325c346b8845930552c:/process.h?ds=sidebyside diff --git a/process.h b/process.h index c30b243..654237b 100644 --- a/process.h +++ b/process.h @@ -19,12 +19,15 @@ class process { public: - static double get_total_load_init() { return total_load_init; } - static double get_total_load_exit() { return total_load_exit; } + static double get_total_load_init() { return total_load_init; } + static double get_total_load_running() { return total_load_running; } + static double get_total_load_exit() { return total_load_exit; } process(int argc, char* argv[]); virtual ~process(); + double get_load() const { return load; } + int run(); protected: @@ -48,8 +51,9 @@ protected: xbt_log_category_t cat = _XBT_LOGV(default)) const; private: - static double total_load_init; // sum of neighbor loads at init - static double total_load_exit; // sum of neighbor loads at exit + 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_exit; // sum of process loads at exit typedef MAP_TEMPLATE rev_neigh_type; neigh_type neigh; // list of neighbors (do not alter @@ -63,8 +67,10 @@ private: // 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