X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/6a266736a5a4f2e30a529662180050e8bc2b1a49..3a610d4d2775be71fa1297f7f335376b2945984e:/process.h diff --git a/process.h b/process.h index dbf9b05..cc10b04 100644 --- a/process.h +++ b/process.h @@ -21,6 +21,7 @@ #include "msg_thread.h" #include "neighbor.h" #include "options.h" +#include "synchro.h" class process { public: @@ -45,8 +46,7 @@ protected: // Get and set current load, which may be real load, or expected // load if opt::bookkeeping is true. - double get_load() const; - void set_load(double load); + double get_load() const { return expected_load; } // The load balancing algorithm comes here... virtual void load_balance(); @@ -97,15 +97,22 @@ private: double real_load; // current load double expected_load; // expected load in bookkeeping mode + mutex_t mutex; // synchronization between threads + condition_t cond; + // Load-balancing loop + msg_thread* lb_thread; void load_balance_loop(); // Simulate computation loop - msg_thread* compute_thread; void compute_loop(); + // Check if we need to stop bool still_running(); + // Returns the sum of "to_send" for all neighbors. + double get_sum_of_to_send() const; + // Send procedures void ctrl_send(neighbor& nb); void data_send(neighbor& nb); @@ -120,24 +127,6 @@ private: void handle_message(message* msg, m_host_t from); }; -inline -double process::get_load() const -{ - if (opt::bookkeeping) - return expected_load; - else - return real_load; -} - -inline -void process::set_load(double load) -{ - if (opt::bookkeeping) - expected_load = load; - else - real_load = load; -} - template void process::pneigh_sort_by_load(const Compare& comp) {