process.cpp

   1 #include <algorithm>
   2 #include <functional>
   3 #include <iterator>
   4 #include <stdexcept>
   5 #include <sstream>
   6 #include <xbt/log.h>
   7 #include "misc.h"
   8 #include "options.h"
   9 #include "process.h"
  10
  11 XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(simu);
  12
  13 struct message {
  14     double measure;
  15     double transfer;
  16 };
  17
  18 process::process(int argc, char *argv[])
  19 {
  20     if (argc < 2 || !(std::istringstream(argv[1]) >> load))
  21         throw std::invalid_argument("bad or missing initial load");
  22     neigh.assign(argv + 2, argv + argc);
  23     e_xbt_log_priority_t logp = xbt_log_priority_verbose;
  24     if (!LOG_ISENABLED(logp))
  25         return;
  26     LOG1(logp, "My initial load is: %g", load);
  27     std::ostringstream oss;
  28     oss << neigh.size() << " neighbor";
  29     if (!neigh.empty()) {
  30         oss << (neigh.size() > 1 ? "s: " : ": ");
  31         std::transform(neigh.begin(), neigh.end() - 1,
  32                        std::ostream_iterator<std::string>(oss, ", "),
  33                        std::mem_fun_ref(&neighbor::getName));
  34         oss << neigh.back().getName();
  35     }
  36     LOG1(logp, "Got %s.", oss.str().c_str());
  37     print_loads(logp);
  38 }
  39
  40 int process::run()
  41 {
  42     INFO0("Coucou !");
  43     MSG_process_sleep(100.0);   // xxx
  44     /* xxx:
  45      * while (there is something to do) {
  46      *    compute some task;
  47      *    get received tasks;
  48      *    compute load balancing;
  49      *    send tasks to neighbors;
  50      * }
  51      */
  52
  53     /* Open Questions :
  54      * - definition of load on heterogeneous hosts ?
  55      * - how to detect convergence ?
  56      * - how to manage link failures ?
  57      */
  58
  59     // xxx: shall we retrieve pending tasks?
  60
  61     return 0;
  62 }
  63
  64 void process::compute()
  65 {
  66     double duration = opt::comp_cost(load);
  67     m_task_t task = MSG_task_create("computation", duration, 0.0, NULL);
  68     MSG_task_execute(task);
  69     MSG_task_destroy(task);
  70 }
  71
  72 void process::print_loads(e_xbt_log_priority_t logp)
  73 {
  74     if (!LOG_ISENABLED(logp))
  75         return;
  76     std::ostringstream oss;
  77     if (neigh.empty()) {
  78         oss << "no neighbor!";
  79     } else {
  80         std::transform(neigh.begin(), neigh.end() - 1,
  81                        std::ostream_iterator<double>(oss, ", "),
  82                        std::mem_fun_ref(&neighbor::getLoad));
  83         oss << neigh.back().getLoad();
  84     }
  85     LOG1(logp, "Neighbor loads: %s", oss.str().c_str());
  86 }
  87
  88 // Local variables:
  89 // mode: c++
  90 // End: