#include "smpi_op.hpp"
#include "src/kernel/activity/CommImpl.hpp"
#include "src/mc/mc_replay.hpp"
-#include "src/simix/ActorImpl.hpp"
#include "src/smpi/include/smpi_actor.hpp"
#include "xbt/config.hpp"
cancelled_ = 0;
}
-MPI_Comm Request::comm(){
- return comm_;
-}
-
-int Request::src(){
- return src_;
-}
-
-int Request::dst(){
- return dst_;
-}
-
-int Request::tag(){
- return tag_;
-}
-
-int Request::flags(){
- return flags_;
-}
-
-int Request::detached(){
- return detached_;
-}
-
-MPI_Datatype Request::type(){
- return old_type_;
-}
-
-size_t Request::size(){
- return size_;
-}
-
-size_t Request::real_size(){
- return real_size_;
-}
-
void Request::ref(){
refcount_++;
}
void Request::start()
{
- s4u::MailboxPtr mailbox;
+ s4u::Mailbox* mailbox;
xbt_assert(action_ == nullptr, "Cannot (re-)start unfinished communication");
flags_ &= ~MPI_REQ_PREPARED;
->wait();
}
// behave like a receive, but don't do it
- s4u::MailboxPtr mailbox;
+ s4u::Mailbox* mailbox;
request->print_request("New iprobe");
// We have to test both mailboxes as we don't know if we will receive one one or another