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);
}
}
action.sa_handler = signal_handler;
sigemptyset(&action.sa_mask);
action.sa_flags = SA_RESTART;
- if (sigaction(SIGINT, &action, NULL) == -1) {
+ if (sigaction(SIGINT, &action, nullptr) == -1) {
std::cerr << "ERROR: sigaction: " << strerror(errno) << "\n";
exit(EXIT_FAILURE_OTHER);
}
simulated_time = MSG_get_clock();
XBT_INFO("Simulation ended at %f.", simulated_time);
- process::set_proc_mutex(NULL);
+ process::set_proc_mutex(nullptr);
delete proc_cond;
delete proc_mutex;
idle_duration += MSG_get_clock() - idle_since_date;
++comp_iter;
double flops = opt::comp_cost(real_load);
- msg_task_t task = MSG_task_create("computation", flops, 0.0, NULL);
+ msg_task_t task = MSG_task_create("computation", flops, 0.0, nullptr);
// MSG_task_set_category(task, TRACE_CAT_COMP);
XBT_DEBUG("compute %g flop%s", flops, ESSE(flops));
MSG_task_execute(task);