Wip...

[loba.git] / process.cpp

diff --git a/process.cpp b/process.cpp
index 8ceb4692fd00c9e2c2e5a28b45555a7ec9b7efe5..76058180c01d7a4e08cd008b07eaa043e0575fbf 100644 (file)
--- a/process.cpp
+++ b/process.cpp
@@ -5,6 +5,7 @@
 #include <sstream>
 #include <xbt/log.h>
 #include "misc.h"
+#include "options.h"
 #include "process.h"
 
 XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(simu);
@@ -36,22 +37,6 @@ process::process(int argc, char *argv[])
     print_loads(logp);
 }
 
-void process::print_loads(e_xbt_log_priority_t logp)
-{
-    if (!LOG_ISENABLED(logp))
-        return;
-    std::ostringstream oss;
-    if (neigh.empty()) {
-        oss << "no neighbor!";
-    } else {
-        std::transform(neigh.begin(), neigh.end() - 1,
-                       std::ostream_iterator<double>(oss, ", "),
-                       std::mem_fun_ref(&neighbor::getLoad));
-        oss << neigh.back().getLoad();
-    }
-    LOG1(logp, "Neighbor loads: %s", oss.str().c_str());
-}
-
 int process::run()
 {
     INFO0("Coucou !");
@@ -76,6 +61,30 @@ int process::run()
     return 0;
 }
 
+void process::compute()
+{
+    double duration = opt::comp_cost(load);
+    m_task_t task = MSG_task_create("computation", duration, 0.0, NULL);
+    MSG_task_execute(task);
+    MSG_task_destroy(task);
+}
+
+void process::print_loads(e_xbt_log_priority_t logp)
+{
+    if (!LOG_ISENABLED(logp))
+        return;
+    std::ostringstream oss;
+    if (neigh.empty()) {
+        oss << "no neighbor!";
+    } else {
+        std::transform(neigh.begin(), neigh.end() - 1,
+                       std::ostream_iterator<double>(oss, ", "),
+                       std::mem_fun_ref(&neighbor::getLoad));
+        oss << neigh.back().getLoad();
+    }
+    LOG1(logp, "Neighbor loads: %s", oss.str().c_str());
+}
+
 // Local variables:
 // mode: c++
 // End: