X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/124a609e80fa7bb5b7a7a698df9c6abef910d83e..c769579a8be568370d2657059486574371e914c2:/process.cpp?ds=sidebyside

diff --git a/process.cpp b/process.cpp
index 11129e4..8a73f38 100644
--- a/process.cpp
+++ b/process.cpp
@@ -157,7 +157,7 @@ void process::load_balance_loop()
                   std::bind(&process::ctrl_close, this, _1));
     while (ctrl_close_pending) {
         comm.ctrl_flush(false);
-        XBT_DEBUG("waiting for %d CTRL CLOSE", ctrl_close_pending);
+        XBT_DEBUG("waiting for %d CTRL_CLOSE", ctrl_close_pending);
         ctrl_receive(-1.0);
     }
     comm.ctrl_flush(true);
@@ -201,9 +201,6 @@ void process::compute_loop()
     }
 
     XBT_VERB("Going to finalize for %s...", __func__);
-    // last send, for not losing load scheduled to be sent
-    std::for_each(neigh.begin(), neigh.end(),
-                  std::bind(&process::data_send, this, _1));
     finalizing = true;
     total_load_running -= real_load;
     XBT_DEBUG("send DATA_CLOSE to %zu neighbor%s",
@@ -212,7 +209,7 @@ void process::compute_loop()
                   std::bind(&process::data_close, this, _1));
     while (data_close_pending) {
         comm.data_flush(false);
-        XBT_DEBUG("waiting for %d DATA CLOSE", data_close_pending);
+        XBT_DEBUG("waiting for %d DATA_CLOSE", data_close_pending);
         data_receive(-1.0);
     }
     comm.data_flush(true);