X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/0e99de43ec10a2f793478999e7b092458cc642b9..d236809e6149a03ef3e53599458f51c98f79f94d:/src/s4u/s4u_Comm.cpp diff --git a/src/s4u/s4u_Comm.cpp b/src/s4u/s4u_Comm.cpp index c77b32a0e8..cd8ea25a73 100644 --- a/src/s4u/s4u_Comm.cpp +++ b/src/s4u/s4u_Comm.cpp @@ -230,14 +230,7 @@ Comm* Comm::start() copy_data_function_, get_data(), detached_}; - pimpl_ = kernel::actor::simcall_blocking( - [&observer] { - return kernel::activity::CommImpl::isend( - observer.get_issuer(), observer.get_mailbox(), observer.get_payload_size(), observer.get_rate(), - observer.get_src_buff(), observer.get_src_buff_size(), observer.match_fun_, observer.clean_fun_, - observer.copy_data_fun_, observer.get_payload(), observer.is_detached()); - }, - &observer); + pimpl_ = kernel::actor::simcall([&observer] { return kernel::activity::CommImpl::isend(&observer); }, &observer); } else if (dst_buff_ != nullptr) { // Receiver side xbt_assert(not detached_, "Receive cannot be detached"); on_recv(*this); @@ -249,13 +242,7 @@ Comm* Comm::start() copy_data_function_, get_data(), rate_}; - pimpl_ = kernel::actor::simcall_blocking( - [&observer] { - return kernel::activity::CommImpl::irecv( - observer.get_issuer(), observer.get_mailbox(), observer.get_dst_buff(), observer.get_dst_buff_size(), - observer.match_fun_, observer.copy_data_fun_, observer.get_payload(), observer.get_rate()); - }, - &observer); + pimpl_ = kernel::actor::simcall([&observer] { return kernel::activity::CommImpl::irecv(&observer); }, &observer); } else { xbt_die("Cannot start a communication before specifying whether we are the sender or the receiver"); }