X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/ea74f5d95928a521a588737e81f1de94eef25d19..8e3525c475262f259a70a3f9a2a4f12d36b3d243:/src/s4u/s4u_ConditionVariable.cpp diff --git a/src/s4u/s4u_ConditionVariable.cpp b/src/s4u/s4u_ConditionVariable.cpp index 1e654dd515..2558b0478a 100644 --- a/src/s4u/s4u_ConditionVariable.cpp +++ b/src/s4u/s4u_ConditionVariable.cpp @@ -18,7 +18,7 @@ namespace s4u { ConditionVariablePtr ConditionVariable::create() { kernel::activity::ConditionVariableImpl* cond = - kernel::actor::simcall([] { return new kernel::activity::ConditionVariableImpl(); }); + kernel::actor::simcall_answered([] { return new kernel::activity::ConditionVariableImpl(); }); return ConditionVariablePtr(cond->get_iface(), false); } @@ -77,12 +77,12 @@ std::cv_status ConditionVariable::wait_until(const std::unique_lock& lock */ void ConditionVariable::notify_one() { - simgrid::kernel::actor::simcall([this]() { pimpl_->signal(); }); + simgrid::kernel::actor::simcall_answered([this]() { pimpl_->signal(); }); } void ConditionVariable::notify_all() { - simgrid::kernel::actor::simcall([this]() { pimpl_->broadcast(); }); + simgrid::kernel::actor::simcall_answered([this]() { pimpl_->broadcast(); }); } void intrusive_ptr_add_ref(const ConditionVariable* cond) @@ -111,7 +111,7 @@ void sg_cond_wait(sg_cond_t cond, sg_mutex_t mutex) int sg_cond_wait_for(sg_cond_t cond, sg_mutex_t mutex, double delay) { - std::unique_lock lock(*mutex); + std::unique_lock lock(*mutex); return cond->wait_for(lock, delay) == std::cv_status::timeout; }