X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/956cb23848021301bcb4c20fd31675f65e4348e5..2d2995483b57463581ffdc4365fe1999ddc306c2:/src/kernel/activity/MutexImpl.cpp diff --git a/src/kernel/activity/MutexImpl.cpp b/src/kernel/activity/MutexImpl.cpp index 396c537a9e..9581637a40 100644 --- a/src/kernel/activity/MutexImpl.cpp +++ b/src/kernel/activity/MutexImpl.cpp @@ -1,24 +1,19 @@ -/* Copyright (c) 2007-2017. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2007-2018. 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 "smx_private.hpp" -#include "src/surf/cpu_interface.hpp" -#include "src/surf/surf_interface.hpp" -#include -#include -#include - +#include "src/kernel/activity/MutexImpl.hpp" #include "src/kernel/activity/SynchroRaw.hpp" -#include "src/simix/MutexImpl.hpp" +#include "src/simix/smx_synchro_private.hpp" XBT_LOG_NEW_DEFAULT_SUBCATEGORY(simix_mutex, simix_synchro, "Mutex kernel-space implementation"); namespace simgrid { -namespace simix { +namespace kernel { +namespace activity { -MutexImpl::MutexImpl() : mutex_(this) +MutexImpl::MutexImpl() : piface_(this) { XBT_IN("(%p)", this); XBT_OUT(); @@ -39,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->host_, -1); + synchro->simcalls_.push_back(&issuer->simcall); issuer->waiting_synchro = synchro; this->sleeping.push_back(*issuer); } else { @@ -85,8 +80,8 @@ 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:%lu), not by you.", - this->owner->getCname(), this->owner->pid); + THROWF(mismatch_error, 0, "Cannot release that mutex: it was locked by %s (pid:%ld), not by you.", + this->owner->get_cname(), this->owner->pid_); if (not this->sleeping.empty()) { /*process to wake up */ @@ -104,6 +99,7 @@ void MutexImpl::unlock(smx_actor_t issuer) } } } +} /** Increase the refcount for this mutex */ smx_mutex_t SIMIX_mutex_ref(smx_mutex_t mutex)