X-Git-Url: https://bilbo.iut-bm.univ-fcomte.fr/and/gitweb/loba.git/blobdiff_plain/f581799445893c1b953c365fbfb025e3dbcc775a..4d5ec9803b74d0f3e9c002a92a748bd08b6640ac:/communicator.cpp diff --git a/communicator.cpp b/communicator.cpp index 2df6d76..bb48bd7 100644 --- a/communicator.cpp +++ b/communicator.cpp @@ -31,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(); @@ -76,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) { @@ -105,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); } }