X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b8df87e176f27b25534f27d7e240defa32ca35bc..fbf5fafb60eb44c0c00a7283fd05a6dec5f2b58f:/src/s4u/s4u_Mutex.cpp diff --git a/src/s4u/s4u_Mutex.cpp b/src/s4u/s4u_Mutex.cpp index b46c2986bf..2f90b265d9 100644 --- a/src/s4u/s4u_Mutex.cpp +++ b/src/s4u/s4u_Mutex.cpp @@ -9,6 +9,12 @@ namespace simgrid { namespace s4u { +Mutex::~Mutex() +{ + if (pimpl_ != nullptr) + pimpl_->unref(); +} + /** @brief Blocks the calling actor until the mutex can be obtained */ void Mutex::lock() { @@ -36,7 +42,7 @@ bool Mutex::try_lock() */ MutexPtr Mutex::create() { - smx_mutex_t mutex = simcall_mutex_init(); + kernel::activity::MutexImpl* mutex = simix::simcall([] { return new kernel::activity::MutexImpl(); }); return MutexPtr(&mutex->mutex(), false); } @@ -44,12 +50,15 @@ MutexPtr Mutex::create() void intrusive_ptr_add_ref(Mutex* mutex) { xbt_assert(mutex); - SIMIX_mutex_ref(mutex->pimpl_); + if (mutex->pimpl_) + mutex->pimpl_->ref(); } void intrusive_ptr_release(Mutex* mutex) { xbt_assert(mutex); - SIMIX_mutex_unref(mutex->pimpl_); + if (mutex->pimpl_) + mutex->pimpl_->unref(); } + } // namespace s4u } // namespace simgrid