process.h

   1 #ifndef PROCESS_H
   2 #define PROCESS_H
   3
   4 #include <vector>
   5 #include <xbt/log.h>
   6 #include "communicator.h"
   7 #include "neighbor.h"
   8
   9 class process {
  10 public:
  11     process(int argc, char* argv[]);
  12     ~process() { };
  13     int run();
  14
  15 private:
  16     communicator comm;
  17     std::vector<neighbor> neigh;
  18     double load;
  19     double expected_load;
  20
  21     int ctrl_close_pending;
  22     int data_close_pending;
  23
  24     void compute();
  25     bool receive(bool wait_for_close);
  26     void finalize();
  27     void print_loads(e_xbt_log_priority_t logp = xbt_log_priority_info);
  28 };
  29
  30 #endif // !PROCESS_H
  31
  32 // Local variables:
  33 // mode: c++
  34 // End: