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