X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/bccf459a375af533649be3e8036f5040769cd594..4d5ec9803b74d0f3e9c002a92a748bd08b6640ac:/communicator.cpp?ds=inline

diff --git a/communicator.cpp b/communicator.cpp
index 5abb543..bb48bd7 100644
--- a/communicator.cpp
+++ b/communicator.cpp
@@ -1,6 +1,5 @@
 #include <algorithm>
-#include <functional>
-#include <msg/msg.h>
+#include <simgrid/msg.h>
 #include <xbt/log.h>
 
 XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(comm);
@@ -23,8 +22,7 @@ namespace {
 communicator::communicator()
     : host(static_cast<hostdata*>(MSG_host_get_data(MSG_host_self())))
 {
-    receiver_thread = new_msg_thread("receiver",
-                                     std::bind(&communicator::receiver, this));
+    receiver_thread = new_msg_thread("receiver", [this]() { this->receiver(); });
     receiver_thread->start();
 }
 
@@ -33,11 +31,11 @@ communicator::~communicator()
     msg_task_t task;
 
     XBT_DEBUG("send finalize to receiver/ctrl");
-    task = MSG_task_create("finalize", 0.0, 0, NULL);
+    task = MSG_task_create("finalize", 0.0, 0, nullptr);
     MSG_task_send(task, host->get_ctrl_mbox());
 
     XBT_DEBUG("send finalize to receiver/data");
-    task = MSG_task_create("finalize", 0.0, 0, NULL);
+    task = MSG_task_create("finalize", 0.0, 0, nullptr);
     MSG_task_send(task, host->get_data_mbox());
 
     receiver_thread->wait();
@@ -78,15 +76,15 @@ void communicator::real_flush(sent_comm_type& sent_comm, bool wait)
 
 void communicator::receiver()
 {
-    xbt_dynar_t comms = xbt_dynar_new(sizeof(msg_comm_t), NULL);
+    xbt_dynar_t comms = xbt_dynar_new(sizeof(msg_comm_t), nullptr);
     struct channel {
         msg_comm_t comm;
         msg_task_t task;
         const char* mbox;
         message_queue& received;
     };
-    channel chan[] = { { NULL, NULL, host->get_ctrl_mbox(), ctrl_received },
-                       { NULL, NULL, host->get_data_mbox(), data_received } };
+    channel chan[] = { { nullptr, nullptr, host->get_ctrl_mbox(), ctrl_received },
+                       { nullptr, nullptr, host->get_data_mbox(), data_received } };
     const int chan_size = (sizeof chan) / (sizeof chan[0]);
 
     for (int i = 0 ; i < chan_size ; ++i) {
@@ -107,15 +105,15 @@ void communicator::receiver()
         if (strcmp(MSG_task_get_name(ch->task), "finalize")) {
             XBT_DEBUG("received message on %s", ch->mbox);
             ch->received.push(ch->task);
-            ch->task = NULL;
+            ch->task = nullptr;
             ch->comm = MSG_task_irecv(&ch->task, ch->mbox);
             xbt_dynar_set_as(comms, index, msg_comm_t, ch->comm);
         } else {
             XBT_DEBUG("received finalize on %s", ch->mbox);
             MSG_task_destroy(ch->task);
-            ch->task = NULL;
-            ch->comm = NULL;
-            xbt_dynar_remove_at(comms, index, NULL);
+            ch->task = nullptr;
+            ch->comm = nullptr;
+            xbt_dynar_remove_at(comms, index, nullptr);
         }
 
     }