X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/128fe1a78cca2649fbe50297fa7750bc497ff324..51c23076e2b42ff07dc167dea1cb0e3a4ab3cf68:/src/s4u/s4u_ConditionVariable.cpp diff --git a/src/s4u/s4u_ConditionVariable.cpp b/src/s4u/s4u_ConditionVariable.cpp index c42a524daf..2a08728eca 100644 --- a/src/s4u/s4u_ConditionVariable.cpp +++ b/src/s4u/s4u_ConditionVariable.cpp @@ -27,12 +27,12 @@ ConditionVariablePtr ConditionVariable::create() */ void ConditionVariable::wait(MutexPtr lock) { - simcall_cond_wait(cond_, lock->mutex_); + simcall_cond_wait(cond_, lock->pimpl_); } void ConditionVariable::wait(std::unique_lock& lock) { - simcall_cond_wait(cond_, lock.mutex()->mutex_); + simcall_cond_wait(cond_, lock.mutex()->pimpl_); } std::cv_status s4u::ConditionVariable::wait_for(std::unique_lock& lock, double timeout) @@ -41,7 +41,7 @@ std::cv_status s4u::ConditionVariable::wait_for(std::unique_lock& lock, d if (timeout < 0) timeout = 0.0; - if (simcall_cond_wait_timeout(cond_, lock.mutex()->mutex_, timeout)) { + if (simcall_cond_wait_timeout(cond_, lock.mutex()->pimpl_, timeout)) { // If we reached the timeout, we have to take the lock again: lock.mutex()->lock(); return std::cv_status::timeout; @@ -66,12 +66,12 @@ std::cv_status ConditionVariable::wait_until(std::unique_lock& lock, doub */ void ConditionVariable::notify_one() { - simgrid::simix::kernelImmediate([this]() { cond_->signal(); }); + simgrid::simix::simcall([this]() { cond_->signal(); }); } void ConditionVariable::notify_all() { - simgrid::simix::kernelImmediate([this]() { cond_->broadcast(); }); + simgrid::simix::simcall([this]() { cond_->broadcast(); }); } void intrusive_ptr_add_ref(ConditionVariable* cond)