Wip++...

[loba.git] / process.cpp

diff --git a/process.cpp b/process.cpp
index 76058180c01d7a4e08cd008b07eaa043e0575fbf..d1576cef6f6330589d79edaec9d2e7a396045163 100644 (file)
--- a/process.cpp
+++ b/process.cpp
@@ -40,7 +40,13 @@ process::process(int argc, char *argv[])
 int process::run()
 {
     INFO0("Coucou !");
 int process::run()
 {
     INFO0("Coucou !");

-    MSG_process_sleep(100.0);   // xxx
+
+    int n = 100;
+    while (n--) {
+        compute();
+        receive();
+    }
+    //    MSG_process_sleep(100.0);   // xxx

     /* xxx:
      * while (there is something to do) {
      *    compute some task;
     /* xxx:
      * while (there is something to do) {
      *    compute some task;


@@ -61,10 +67,25 @@ int process::run()
     return 0;
 }
 
     return 0;
 }
 

+void process::receive()
+{
+    m_task_t task;
+    while ((task = comm.recv())) {
+        message *msg = (message *)MSG_task_get_data(task);
+        DEBUG3("Received load: %g, info: %g from %s",
+               msg->transfer, msg->measure,
+               MSG_host_get_name(MSG_task_get_source(task)));
+        load += msg->transfer;
+        // fixme: what is xxx ???
+        // neigh[xxx].setLoad(msg->measure);
+    }
+}
+

 void process::compute()
 {
     double duration = opt::comp_cost(load);
     m_task_t task = MSG_task_create("computation", duration, 0.0, NULL);
 void process::compute()
 {
     double duration = opt::comp_cost(load);
     m_task_t task = MSG_task_create("computation", duration, 0.0, NULL);

+    DEBUG2("Compute %g flop%s.", duration, duration > 1 ? "s" : "");

     MSG_task_execute(task);
     MSG_task_destroy(task);
 }
     MSG_task_execute(task);
     MSG_task_destroy(task);
 }