X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/7becbfd663eec7e290caa5580974a84dc5f65650..2cf13759ba1696d88f5ff86afee5324f30ccdbfc:/src/kernel/activity/MutexImpl.cpp?ds=sidebyside diff --git a/src/kernel/activity/MutexImpl.cpp b/src/kernel/activity/MutexImpl.cpp index 7d90c8a7aa..538e418f37 100644 --- a/src/kernel/activity/MutexImpl.cpp +++ b/src/kernel/activity/MutexImpl.cpp @@ -1,12 +1,11 @@ -/* Copyright (c) 2007-2017. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2019. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ #include "src/kernel/activity/MutexImpl.hpp" #include "src/kernel/activity/SynchroRaw.hpp" - -#include "src/simix/smx_private.hpp" +#include "src/simix/smx_synchro_private.hpp" XBT_LOG_NEW_DEFAULT_SUBCATEGORY(simix_mutex, simix_synchro, "Mutex kernel-space implementation"); @@ -14,7 +13,7 @@ namespace simgrid { namespace kernel { namespace activity { -MutexImpl::MutexImpl() : mutex_(this) +MutexImpl::MutexImpl() : piface_(this) { XBT_IN("(%p)", this); XBT_OUT(); @@ -35,8 +34,8 @@ void MutexImpl::lock(smx_actor_t issuer) if (this->locked) { /* FIXME: check if the host is active ? */ /* Somebody using the mutex, use a synchronization to get host failures */ - synchro = SIMIX_synchro_wait(issuer->host, -1); - synchro->simcalls.push_back(&issuer->simcall); + synchro = SIMIX_synchro_wait(issuer->get_host(), -1); + synchro->simcalls_.push_back(&issuer->simcall); issuer->waiting_synchro = synchro; this->sleeping.push_back(*issuer); } else { @@ -50,8 +49,8 @@ void MutexImpl::lock(smx_actor_t issuer) /** Tries to lock the mutex for a process * - * \param issuer the process that tries to acquire the mutex - * \return whether we managed to lock the mutex + * @param issuer the process that tries to acquire the mutex + * @return whether we managed to lock the mutex */ bool MutexImpl::try_lock(smx_actor_t issuer) { @@ -82,7 +81,7 @@ void MutexImpl::unlock(smx_actor_t issuer) /* If the mutex is not owned by the issuer, that's not good */ if (issuer != this->owner) THROWF(mismatch_error, 0, "Cannot release that mutex: it was locked by %s (pid:%ld), not by you.", - this->owner->getCname(), this->owner->pid); + this->owner->get_cname(), this->owner->get_pid()); if (not this->sleeping.empty()) { /*process to wake up */