X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/51909edd89ccd195ba335606743a650807123999..95ffb98a8d08ef20672d6ef91ea8fb4320c5ea85:/process.h?ds=inline diff --git a/process.h b/process.h index 38a6c42..dbf9b05 100644 --- a/process.h +++ b/process.h @@ -18,6 +18,7 @@ #include #include "communicator.h" #include "misc.h" +#include "msg_thread.h" #include "neighbor.h" #include "options.h" @@ -42,18 +43,22 @@ protected: pneigh_type pneigh; // list of pointers to neighbors that // we are free to reorder - template - void pneigh_sort_by_load(const Compare& comp); - // 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); + // The load balancing algorithm comes here... + virtual void load_balance(); + // Register some amount of load to send to given neighbor. void send(neighbor& nb, double amount); void send(neighbor* nb, double amount) { send(*nb, amount); } + // Sort pneigh by applying comp to their loads + template + void pneigh_sort_by_load(const Compare& comp); + // Calls neighbor::print(verbose, logp, cat) for each member of neigh. void print_loads(bool verbose = false, e_xbt_log_priority_t logp = xbt_log_priority_info, @@ -92,31 +97,27 @@ private: double real_load; // current load double expected_load; // expected load in bookkeeping mode - // The load balancing algorithm comes here... - virtual void load_balance(); + // Load-balancing loop + void load_balance_loop(); - // Virtually do some computation - void compute(); + // Simulate computation loop + msg_thread* compute_thread; + void compute_loop(); - // Send procedures, with helpers for bookkeeping mode or not - void send1_no_bookkeeping(neighbor& nb); - void send1_bookkeeping(neighbor& nb); - void send_all(); + bool still_running(); - // Returns true if there remains neighbors to listen for - bool may_receive() const { - return ctrl_close_pending || data_close_pending; - } + // Send procedures + void ctrl_send(neighbor& nb); + void data_send(neighbor& nb); + void ctrl_close(neighbor& nb); + void data_close(neighbor& nb); // 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. - void finalize1(neighbor& nb); - void finalize(); + void ctrl_receive(double timeout); + void data_receive(double timeout); + void handle_message(message* msg, m_host_t from); }; inline