X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/48de9544b7eac2f9d40ea34a42c1d1a3d7ccbbfe..cf1922f71c0526c79679a2de24b312a8aef8d766:/process.h?ds=sidebyside diff --git a/process.h b/process.h index 57ece07..9ea0521 100644 --- a/process.h +++ b/process.h @@ -34,6 +34,8 @@ public: double get_real_load() const { return real_load; } double get_comp_amount() const { return acc.comp_amount; } + unsigned get_comp_iter() const { return comp_iter; } + unsigned get_all_comp_iter() const { return all_comp_iter; } double get_data_send_amount() const { return acc.data_send.amount; } double get_data_recv_amount() const { return acc.data_recv.amount; } unsigned get_data_send_count() const { return acc.data_send.count; } @@ -97,6 +99,8 @@ private: unsigned lb_iter; // counter of load-balancing iterations unsigned comp_iter; // counter of computation iterations + unsigned all_comp_iter; // counter of computation iterations + // (counting empty iterations too) double prev_load_broadcast; // used to ensure that we do not send // a same information messages @@ -120,7 +124,9 @@ private: mesg_accounting ctrl_recv; // ctrl message received accounting(): comp_amount(0.0) { } }; - accounting acc; + accounting acc; // use a structure so that it is + // automatically initialized a + // construction void add_comp_amount(double amount) { acc.comp_amount += amount; } void add_data_send_mesg(double amount) { @@ -153,6 +159,9 @@ private: // Returns the sum of "to_send" for all neighbors. double get_sum_of_to_send() const; + // Compute load_to_send (for data_send), subject to the execution parameters + static double compute_load_to_send(double desired); + // Send procedures void ctrl_send(neighbor& nb); void data_send(neighbor& nb);