void* data, double timeout)
{
simgrid::kernel::activity::ActivityImplPtr comm = simcall_HANDLER_comm_isend(
- simcall, src, mbox, task_size, rate, src_buff, src_buff_size, match_fun, nullptr, copy_data_fun, data, 0);
+ simcall, src, mbox, task_size, rate, src_buff, src_buff_size, match_fun, nullptr, copy_data_fun, data, false);
SIMCALL_SET_MC_VALUE(*simcall, 0);
simcall_HANDLER_comm_wait(simcall, static_cast<simgrid::kernel::activity::CommImpl*>(comm.get()), timeout);
}
other_comm->clean_fun = clean_fun;
} else {
other_comm->clean_fun = nullptr;
- src_proc->comms.push_back(other_comm);
+ src_proc->activities_.push_back(other_comm);
}
/* Setup the communication synchro */
other_comm->state_ = simgrid::kernel::activity::State::READY;
other_comm->set_type(simgrid::kernel::activity::CommImpl::Type::READY);
}
- receiver->comms.push_back(other_comm);
+ receiver->activities_.push_back(other_comm);
}
/* Setup communication synchro */
}
}
- simcall->issuer_->waiting_synchro = nullptr;
- simcall->issuer_->comms.remove(this);
+ simcall->issuer_->waiting_synchro_ = nullptr;
+ simcall->issuer_->activities_.remove(this);
if (detached_) {
if (simcall->issuer_ == src_actor_) {
if (dst_actor_)
- dst_actor_->comms.remove(this);
+ dst_actor_->activities_.remove(this);
} else if (simcall->issuer_ == dst_actor_) {
if (src_actor_)
- src_actor_->comms.remove(this);
+ src_actor_->activities_.remove(this);
} else {
- dst_actor_->comms.remove(this);
- src_actor_->comms.remove(this);
+ dst_actor_->activities_.remove(this);
+ src_actor_->activities_.remove(this);
}
}
}