#include <vector>
#include <msg/msg.h>
#include <xbt/log.h>
+#include "atomic_compat.h"
#include "communicator.h"
#include "misc.h"
#include "msg_thread.h"
class process {
public:
+ static void set_proc_mutex(mutex_t* m) { proc_mutex = m; }
+
+ // Note: normally used with proc_mutex locked.
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; }
xbt_log_category_t cat = _XBT_LOGV(default)) const;
private:
+ static mutex_t *proc_mutex; // protect access to global variables
+ // (must be set before constructing
+ // the first object!)
+
static double total_load_init; // sum of process loads at init
static double total_load_running; // sum of loads while running
static double total_load_exit; // sum of process loads at exit
static int process_counter;
static double total_load_average;
+ static double average_load_ratio;
static double load_diff_threshold;
+ static std::atomic<int> convergence_counter;
+
typedef MAP_TEMPLATE<m_host_t, neighbor*> rev_neigh_type;
neigh_type neigh; // list of neighbors (do not alter
// after construction!)
double idle_duration; // how long we had nothing to compute
double convergence; // date when convergence was achieved, or -1.0
+ int local_convergence_counter; // number of iterations since convergence
mutex_t mutex; // synchronization between threads
condition_t cond;
