X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/f05d4e0b1657f5cbb15fa2932c7d4a194f3804d9..18627870cf7119153d3f07f122ecef0b314623bb:/src/s4u/s4u_Comm.cpp diff --git a/src/s4u/s4u_Comm.cpp b/src/s4u/s4u_Comm.cpp index c034a25ab4..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( - [&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( - [&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"); }