#include "src/msg/msg_private.h"
#include "simgrid/s4u/comm.hpp"
+#include <simgrid/s4u/Mailbox.hpp>
+
XBT_LOG_NEW_DEFAULT_SUBCATEGORY(s4u_comm,s4u_activity,"S4U asynchronous communications");
}
}
state_ = finished;
+ delete this;
}
void Comm::wait(double timeout) {
xbt_assert(state_ == started || state_ == inited);
userData_, timeout, rate_);
}
state_ = finished;
+ delete this;
}
s4u::Comm &Comm::send_async(MailboxPtr dest, void *data, int simulatedSize) {
if(simcall_comm_test(pimpl_)){
state_ = finished;
+ delete this;
return true;
}
return false;