#include <algorithm>
-#include <msg/msg.h>
+#include <simgrid/msg.h>
#include <xbt/log.h>
XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(comm);
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();
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) {
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);
}
}